1*3716f815SAndrew Rist /************************************************************** 2cdf0e10cSrcweir * 3*3716f815SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one 4*3716f815SAndrew Rist * or more contributor license agreements. See the NOTICE file 5*3716f815SAndrew Rist * distributed with this work for additional information 6*3716f815SAndrew Rist * regarding copyright ownership. The ASF licenses this file 7*3716f815SAndrew Rist * to you under the Apache License, Version 2.0 (the 8*3716f815SAndrew Rist * "License"); you may not use this file except in compliance 9*3716f815SAndrew Rist * with the License. You may obtain a copy of the License at 10*3716f815SAndrew Rist * 11*3716f815SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0 12*3716f815SAndrew Rist * 13*3716f815SAndrew Rist * Unless required by applicable law or agreed to in writing, 14*3716f815SAndrew Rist * software distributed under the License is distributed on an 15*3716f815SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16*3716f815SAndrew Rist * KIND, either express or implied. See the License for the 17*3716f815SAndrew Rist * specific language governing permissions and limitations 18*3716f815SAndrew Rist * under the License. 19*3716f815SAndrew Rist * 20*3716f815SAndrew Rist *************************************************************/ 21*3716f815SAndrew Rist 22*3716f815SAndrew Rist 23cdf0e10cSrcweir 24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove 25cdf0e10cSrcweir #include "precompiled_io.hxx" 26cdf0e10cSrcweir #include <osl/mutex.hxx> 27cdf0e10cSrcweir 28cdf0e10cSrcweir #include <uno/mapping.hxx> 29cdf0e10cSrcweir 30cdf0e10cSrcweir #include <cppuhelper/factory.hxx> 31cdf0e10cSrcweir #include <cppuhelper/implbase2.hxx> 32cdf0e10cSrcweir #include <cppuhelper/implementationentry.hxx> 33cdf0e10cSrcweir #include "cppuhelper/unourl.hxx" 34cdf0e10cSrcweir #include "rtl/malformeduriexception.hxx" 35cdf0e10cSrcweir 36cdf0e10cSrcweir #include <com/sun/star/connection/XAcceptor.hpp> 37cdf0e10cSrcweir #include <com/sun/star/lang/XServiceInfo.hpp> 38cdf0e10cSrcweir 39cdf0e10cSrcweir #include "acceptor.hxx" 40cdf0e10cSrcweir 41cdf0e10cSrcweir #define IMPLEMENTATION_NAME "com.sun.star.comp.io.Acceptor" 42cdf0e10cSrcweir #define SERVICE_NAME "com.sun.star.connection.Acceptor" 43cdf0e10cSrcweir 44cdf0e10cSrcweir using namespace ::osl; 45cdf0e10cSrcweir using namespace ::rtl; 46cdf0e10cSrcweir using namespace ::cppu; 47cdf0e10cSrcweir using namespace ::com::sun::star::uno; 48cdf0e10cSrcweir using namespace ::com::sun::star::lang; 49cdf0e10cSrcweir using namespace ::com::sun::star::registry; 50cdf0e10cSrcweir using namespace ::com::sun::star::connection; 51cdf0e10cSrcweir 52cdf0e10cSrcweir namespace io_acceptor 53cdf0e10cSrcweir { 54cdf0e10cSrcweir rtl_StandardModuleCount g_moduleCount = MODULE_COUNT_INIT; 55cdf0e10cSrcweir 56cdf0e10cSrcweir class OAcceptor : public WeakImplHelper2< XAcceptor, XServiceInfo > 57cdf0e10cSrcweir { 58cdf0e10cSrcweir public: 59cdf0e10cSrcweir OAcceptor(const Reference< XComponentContext > & xCtx); 60cdf0e10cSrcweir virtual ~OAcceptor(); 61cdf0e10cSrcweir public: 62cdf0e10cSrcweir // Methods 63cdf0e10cSrcweir virtual Reference< XConnection > SAL_CALL accept( const OUString& sConnectionDescription ) 64cdf0e10cSrcweir throw( AlreadyAcceptingException, 65cdf0e10cSrcweir ConnectionSetupException, 66cdf0e10cSrcweir IllegalArgumentException, 67cdf0e10cSrcweir RuntimeException); 68cdf0e10cSrcweir virtual void SAL_CALL stopAccepting( ) throw( RuntimeException); 69cdf0e10cSrcweir 70cdf0e10cSrcweir public: // XServiceInfo 71cdf0e10cSrcweir virtual OUString SAL_CALL getImplementationName() throw(); 72cdf0e10cSrcweir virtual Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw(); 73cdf0e10cSrcweir virtual sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw(); 74cdf0e10cSrcweir 75cdf0e10cSrcweir private: 76cdf0e10cSrcweir PipeAcceptor *m_pPipe; 77cdf0e10cSrcweir SocketAcceptor *m_pSocket; 78cdf0e10cSrcweir Mutex m_mutex; 79cdf0e10cSrcweir OUString m_sLastDescription; 80cdf0e10cSrcweir sal_Bool m_bInAccept; 81cdf0e10cSrcweir 82cdf0e10cSrcweir Reference< XMultiComponentFactory > _xSMgr; 83cdf0e10cSrcweir Reference< XComponentContext > _xCtx; 84cdf0e10cSrcweir Reference<XAcceptor> _xAcceptor; 85cdf0e10cSrcweir }; 86cdf0e10cSrcweir 87cdf0e10cSrcweir 88cdf0e10cSrcweir OAcceptor::OAcceptor( const Reference< XComponentContext > & xCtx ) 89cdf0e10cSrcweir : m_pPipe( 0 ) 90cdf0e10cSrcweir , m_pSocket( 0 ) 91cdf0e10cSrcweir , m_bInAccept( sal_False ) 92cdf0e10cSrcweir , _xSMgr( xCtx->getServiceManager() ) 93cdf0e10cSrcweir , _xCtx( xCtx ) 94cdf0e10cSrcweir { 95cdf0e10cSrcweir g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); 96cdf0e10cSrcweir } 97cdf0e10cSrcweir 98cdf0e10cSrcweir OAcceptor::~OAcceptor() 99cdf0e10cSrcweir { 100cdf0e10cSrcweir if( m_pPipe ) 101cdf0e10cSrcweir { 102cdf0e10cSrcweir delete m_pPipe; 103cdf0e10cSrcweir } 104cdf0e10cSrcweir if( m_pSocket ) 105cdf0e10cSrcweir { 106cdf0e10cSrcweir delete m_pSocket; 107cdf0e10cSrcweir } 108cdf0e10cSrcweir g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); 109cdf0e10cSrcweir } 110cdf0e10cSrcweir 111cdf0e10cSrcweir struct BeingInAccept 112cdf0e10cSrcweir { 113cdf0e10cSrcweir BeingInAccept( sal_Bool *pFlag,const OUString & sConnectionDescription ) throw( AlreadyAcceptingException) 114cdf0e10cSrcweir : m_pFlag( pFlag ) 115cdf0e10cSrcweir { 116cdf0e10cSrcweir if( *m_pFlag ) 117cdf0e10cSrcweir { 118cdf0e10cSrcweir OUString sMessage( RTL_CONSTASCII_USTRINGPARAM( "AlreadyAcceptingException :" ) ); 119cdf0e10cSrcweir sMessage += sConnectionDescription; 120cdf0e10cSrcweir throw AlreadyAcceptingException( sMessage , Reference< XInterface > () ); 121cdf0e10cSrcweir } 122cdf0e10cSrcweir *m_pFlag = sal_True; 123cdf0e10cSrcweir } 124cdf0e10cSrcweir ~BeingInAccept() 125cdf0e10cSrcweir { 126cdf0e10cSrcweir *m_pFlag = sal_False; 127cdf0e10cSrcweir } 128cdf0e10cSrcweir sal_Bool *m_pFlag; 129cdf0e10cSrcweir }; 130cdf0e10cSrcweir 131cdf0e10cSrcweir Reference< XConnection > OAcceptor::accept( const OUString &sConnectionDescription ) 132cdf0e10cSrcweir throw( AlreadyAcceptingException, 133cdf0e10cSrcweir ConnectionSetupException, 134cdf0e10cSrcweir IllegalArgumentException, 135cdf0e10cSrcweir RuntimeException) 136cdf0e10cSrcweir { 137cdf0e10cSrcweir OSL_TRACE( 138cdf0e10cSrcweir "acceptor %s\n", 139cdf0e10cSrcweir OUStringToOString( 140cdf0e10cSrcweir sConnectionDescription, RTL_TEXTENCODING_ASCII_US).getStr()); 141cdf0e10cSrcweir // if there is a thread alread accepting in this object, throw an exception. 142cdf0e10cSrcweir struct BeingInAccept guard( &m_bInAccept, sConnectionDescription ); 143cdf0e10cSrcweir 144cdf0e10cSrcweir Reference< XConnection > r; 145cdf0e10cSrcweir if( m_sLastDescription.getLength() && 146cdf0e10cSrcweir m_sLastDescription != sConnectionDescription ) 147cdf0e10cSrcweir { 148cdf0e10cSrcweir // instantiate another acceptor for different ports 149cdf0e10cSrcweir OUString sMessage = OUString( RTL_CONSTASCII_USTRINGPARAM( 150cdf0e10cSrcweir "acceptor::accept called multiple times with different conncetion strings\n" ) ); 151cdf0e10cSrcweir throw ConnectionSetupException( sMessage, Reference< XInterface > () ); 152cdf0e10cSrcweir } 153cdf0e10cSrcweir 154cdf0e10cSrcweir if( ! m_sLastDescription.getLength() ) 155cdf0e10cSrcweir { 156cdf0e10cSrcweir // setup the acceptor 157cdf0e10cSrcweir try 158cdf0e10cSrcweir { 159cdf0e10cSrcweir cppu::UnoUrlDescriptor aDesc(sConnectionDescription); 160cdf0e10cSrcweir if (aDesc.getName().equalsAsciiL( 161cdf0e10cSrcweir RTL_CONSTASCII_STRINGPARAM("pipe"))) 162cdf0e10cSrcweir { 163cdf0e10cSrcweir rtl::OUString aName( 164cdf0e10cSrcweir aDesc.getParameter( 165cdf0e10cSrcweir rtl::OUString(RTL_CONSTASCII_USTRINGPARAM( 166cdf0e10cSrcweir "name")))); 167cdf0e10cSrcweir 168cdf0e10cSrcweir m_pPipe = new PipeAcceptor(aName, sConnectionDescription); 169cdf0e10cSrcweir 170cdf0e10cSrcweir try 171cdf0e10cSrcweir { 172cdf0e10cSrcweir m_pPipe->init(); 173cdf0e10cSrcweir } 174cdf0e10cSrcweir catch( ... ) 175cdf0e10cSrcweir { 176cdf0e10cSrcweir { 177cdf0e10cSrcweir MutexGuard g( m_mutex ); 178cdf0e10cSrcweir delete m_pPipe; 179cdf0e10cSrcweir m_pPipe = 0; 180cdf0e10cSrcweir } 181cdf0e10cSrcweir throw; 182cdf0e10cSrcweir } 183cdf0e10cSrcweir } 184cdf0e10cSrcweir else if (aDesc.getName().equalsAsciiL( 185cdf0e10cSrcweir RTL_CONSTASCII_STRINGPARAM("socket"))) 186cdf0e10cSrcweir { 187cdf0e10cSrcweir rtl::OUString aHost; 188cdf0e10cSrcweir if (aDesc.hasParameter( 189cdf0e10cSrcweir rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("host")))) 190cdf0e10cSrcweir aHost = aDesc.getParameter( 191cdf0e10cSrcweir rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("host"))); 192cdf0e10cSrcweir else 193cdf0e10cSrcweir aHost = rtl::OUString(RTL_CONSTASCII_USTRINGPARAM( 194cdf0e10cSrcweir "localhost")); 195cdf0e10cSrcweir sal_uInt16 nPort = static_cast< sal_uInt16 >( 196cdf0e10cSrcweir aDesc.getParameter( 197cdf0e10cSrcweir rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("port"))). 198cdf0e10cSrcweir toInt32()); 199cdf0e10cSrcweir bool bTcpNoDelay 200cdf0e10cSrcweir = aDesc.getParameter( 201cdf0e10cSrcweir rtl::OUString(RTL_CONSTASCII_USTRINGPARAM( 202cdf0e10cSrcweir "tcpnodelay"))).toInt32() != 0; 203cdf0e10cSrcweir 204cdf0e10cSrcweir m_pSocket = new SocketAcceptor( 205cdf0e10cSrcweir aHost, nPort, bTcpNoDelay, sConnectionDescription); 206cdf0e10cSrcweir 207cdf0e10cSrcweir try 208cdf0e10cSrcweir { 209cdf0e10cSrcweir m_pSocket->init(); 210cdf0e10cSrcweir } 211cdf0e10cSrcweir catch( ... ) 212cdf0e10cSrcweir { 213cdf0e10cSrcweir { 214cdf0e10cSrcweir MutexGuard g( m_mutex ); 215cdf0e10cSrcweir delete m_pSocket; 216cdf0e10cSrcweir m_pSocket = 0; 217cdf0e10cSrcweir } 218cdf0e10cSrcweir throw; 219cdf0e10cSrcweir } 220cdf0e10cSrcweir } 221cdf0e10cSrcweir else 222cdf0e10cSrcweir { 223cdf0e10cSrcweir OUString delegatee = OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Acceptor.")); 224cdf0e10cSrcweir delegatee += aDesc.getName(); 225cdf0e10cSrcweir 226cdf0e10cSrcweir OSL_TRACE( 227cdf0e10cSrcweir "trying to get service %s\n", 228cdf0e10cSrcweir OUStringToOString( 229cdf0e10cSrcweir delegatee, RTL_TEXTENCODING_ASCII_US).getStr()); 230cdf0e10cSrcweir _xAcceptor = Reference<XAcceptor>( 231cdf0e10cSrcweir _xSMgr->createInstanceWithContext(delegatee, _xCtx), UNO_QUERY); 232cdf0e10cSrcweir 233cdf0e10cSrcweir if(!_xAcceptor.is()) 234cdf0e10cSrcweir { 235cdf0e10cSrcweir OUString message(RTL_CONSTASCII_USTRINGPARAM("Acceptor: unknown delegatee ")); 236cdf0e10cSrcweir message += delegatee; 237cdf0e10cSrcweir 238cdf0e10cSrcweir throw ConnectionSetupException(message, Reference<XInterface>()); 239cdf0e10cSrcweir } 240cdf0e10cSrcweir } 241cdf0e10cSrcweir } 242cdf0e10cSrcweir catch (rtl::MalformedUriException & rEx) 243cdf0e10cSrcweir { 244cdf0e10cSrcweir throw IllegalArgumentException( 245cdf0e10cSrcweir rEx.getMessage(), 246cdf0e10cSrcweir Reference< XInterface > (), 247cdf0e10cSrcweir 0 ); 248cdf0e10cSrcweir } 249cdf0e10cSrcweir m_sLastDescription = sConnectionDescription; 250cdf0e10cSrcweir } 251cdf0e10cSrcweir 252cdf0e10cSrcweir if( m_pPipe ) 253cdf0e10cSrcweir { 254cdf0e10cSrcweir r = m_pPipe->accept(); 255cdf0e10cSrcweir } 256cdf0e10cSrcweir else if( m_pSocket ) 257cdf0e10cSrcweir { 258cdf0e10cSrcweir r = m_pSocket->accept(); 259cdf0e10cSrcweir } 260cdf0e10cSrcweir else 261cdf0e10cSrcweir { 262cdf0e10cSrcweir r = _xAcceptor->accept(sConnectionDescription); 263cdf0e10cSrcweir } 264cdf0e10cSrcweir 265cdf0e10cSrcweir return r; 266cdf0e10cSrcweir } 267cdf0e10cSrcweir 268cdf0e10cSrcweir void SAL_CALL OAcceptor::stopAccepting( ) throw( RuntimeException) 269cdf0e10cSrcweir { 270cdf0e10cSrcweir MutexGuard guard( m_mutex ); 271cdf0e10cSrcweir 272cdf0e10cSrcweir if( m_pPipe ) 273cdf0e10cSrcweir { 274cdf0e10cSrcweir m_pPipe->stopAccepting(); 275cdf0e10cSrcweir } 276cdf0e10cSrcweir else if ( m_pSocket ) 277cdf0e10cSrcweir { 278cdf0e10cSrcweir m_pSocket->stopAccepting(); 279cdf0e10cSrcweir } 280cdf0e10cSrcweir else if( _xAcceptor.is() ) 281cdf0e10cSrcweir { 282cdf0e10cSrcweir _xAcceptor->stopAccepting(); 283cdf0e10cSrcweir } 284cdf0e10cSrcweir 285cdf0e10cSrcweir } 286cdf0e10cSrcweir 287cdf0e10cSrcweir OUString acceptor_getImplementationName() 288cdf0e10cSrcweir { 289cdf0e10cSrcweir return OUString( RTL_CONSTASCII_USTRINGPARAM( IMPLEMENTATION_NAME ) ); 290cdf0e10cSrcweir } 291cdf0e10cSrcweir 292cdf0e10cSrcweir Reference< XInterface > SAL_CALL acceptor_CreateInstance( const Reference< XComponentContext > & xCtx) 293cdf0e10cSrcweir { 294cdf0e10cSrcweir return Reference < XInterface >( ( OWeakObject * ) new OAcceptor(xCtx) ); 295cdf0e10cSrcweir } 296cdf0e10cSrcweir 297cdf0e10cSrcweir Sequence< OUString > acceptor_getSupportedServiceNames() 298cdf0e10cSrcweir { 299cdf0e10cSrcweir static Sequence < OUString > *pNames = 0; 300cdf0e10cSrcweir if( ! pNames ) 301cdf0e10cSrcweir { 302cdf0e10cSrcweir MutexGuard guard( Mutex::getGlobalMutex() ); 303cdf0e10cSrcweir if( !pNames ) 304cdf0e10cSrcweir { 305cdf0e10cSrcweir static Sequence< OUString > seqNames(1); 306cdf0e10cSrcweir seqNames.getArray()[0] = OUString::createFromAscii( SERVICE_NAME ); 307cdf0e10cSrcweir pNames = &seqNames; 308cdf0e10cSrcweir } 309cdf0e10cSrcweir } 310cdf0e10cSrcweir return *pNames; 311cdf0e10cSrcweir } 312cdf0e10cSrcweir 313cdf0e10cSrcweir OUString OAcceptor::getImplementationName() throw() 314cdf0e10cSrcweir { 315cdf0e10cSrcweir return acceptor_getImplementationName(); 316cdf0e10cSrcweir } 317cdf0e10cSrcweir 318cdf0e10cSrcweir sal_Bool OAcceptor::supportsService(const OUString& ServiceName) throw() 319cdf0e10cSrcweir { 320cdf0e10cSrcweir Sequence< OUString > aSNL = getSupportedServiceNames(); 321cdf0e10cSrcweir const OUString * pArray = aSNL.getConstArray(); 322cdf0e10cSrcweir 323cdf0e10cSrcweir for( sal_Int32 i = 0; i < aSNL.getLength(); i++ ) 324cdf0e10cSrcweir if( pArray[i] == ServiceName ) 325cdf0e10cSrcweir return sal_True; 326cdf0e10cSrcweir 327cdf0e10cSrcweir return sal_False; 328cdf0e10cSrcweir } 329cdf0e10cSrcweir 330cdf0e10cSrcweir Sequence< OUString > OAcceptor::getSupportedServiceNames(void) throw() 331cdf0e10cSrcweir { 332cdf0e10cSrcweir return acceptor_getSupportedServiceNames(); 333cdf0e10cSrcweir } 334cdf0e10cSrcweir 335cdf0e10cSrcweir 336cdf0e10cSrcweir } 337cdf0e10cSrcweir 338cdf0e10cSrcweir using namespace io_acceptor; 339cdf0e10cSrcweir 340cdf0e10cSrcweir static struct ImplementationEntry g_entries[] = 341cdf0e10cSrcweir { 342cdf0e10cSrcweir { 343cdf0e10cSrcweir acceptor_CreateInstance, acceptor_getImplementationName , 344cdf0e10cSrcweir acceptor_getSupportedServiceNames, createSingleComponentFactory , 345cdf0e10cSrcweir &g_moduleCount.modCnt , 0 346cdf0e10cSrcweir }, 347cdf0e10cSrcweir { 0, 0, 0, 0, 0, 0 } 348cdf0e10cSrcweir }; 349cdf0e10cSrcweir 350cdf0e10cSrcweir extern "C" 351cdf0e10cSrcweir { 352cdf0e10cSrcweir 353cdf0e10cSrcweir sal_Bool SAL_CALL component_canUnload( TimeValue *pTime ) 354cdf0e10cSrcweir { 355cdf0e10cSrcweir return g_moduleCount.canUnload( &g_moduleCount , pTime ); 356cdf0e10cSrcweir } 357cdf0e10cSrcweir 358cdf0e10cSrcweir //================================================================================================== 359cdf0e10cSrcweir void SAL_CALL component_getImplementationEnvironment( 360cdf0e10cSrcweir const sal_Char ** ppEnvTypeName, uno_Environment ** ) 361cdf0e10cSrcweir { 362cdf0e10cSrcweir *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME; 363cdf0e10cSrcweir } 364cdf0e10cSrcweir //================================================================================================== 365cdf0e10cSrcweir void * SAL_CALL component_getFactory( 366cdf0e10cSrcweir const sal_Char * pImplName, void * pServiceManager, void * pRegistryKey ) 367cdf0e10cSrcweir { 368cdf0e10cSrcweir return component_getFactoryHelper( pImplName, pServiceManager, pRegistryKey , g_entries ); 369cdf0e10cSrcweir } 370cdf0e10cSrcweir } 371cdf0e10cSrcweir 372cdf0e10cSrcweir 373cdf0e10cSrcweir 374