io/source/acceptor/acceptor.cxx

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