io/source/connector/connector.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: connector.cxx,v $
  10  * $Revision: 1.22 $
  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 #include "osl/security.hxx"
  35
  36 #include <uno/mapping.hxx>
  37
  38 #include <cppuhelper/factory.hxx>
  39 #include <cppuhelper/implbase2.hxx>
  40 #include <cppuhelper/implementationentry.hxx>
  41 #include "cppuhelper/unourl.hxx"
  42 #include "rtl/malformeduriexception.hxx"
  43
  44 #include <com/sun/star/lang/XServiceInfo.hpp>
  45 #include <com/sun/star/lang/IllegalArgumentException.hpp>
  46 #include <com/sun/star/connection/XConnector.hpp>
  47
  48 #include "connector.hxx"
  49
  50 #define IMPLEMENTATION_NAME "com.sun.star.comp.io.Connector"
  51 #define SERVICE_NAME "com.sun.star.connection.Connector"
  52
  53 using namespace ::osl;
  54 using namespace ::rtl;
  55 using namespace ::cppu;
  56 using namespace ::com::sun::star::uno;
  57 using namespace ::com::sun::star::lang;
  58 using namespace ::com::sun::star::registry;
  59 using namespace ::com::sun::star::connection;
  60
  61 namespace stoc_connector
  62 {
  63     rtl_StandardModuleCount g_moduleCount = MODULE_COUNT_INIT;
  64
  65     class OConnector : public WeakImplHelper2< XConnector, XServiceInfo >
  66     {
  67         Reference< XMultiComponentFactory > _xSMgr;
  68         Reference< XComponentContext > _xCtx;
  69     public:
  70         OConnector(const Reference< XComponentContext > &xCtx);
  71         ~OConnector();
  72         // Methods
  73         virtual Reference< XConnection > SAL_CALL connect(
  74             const OUString& sConnectionDescription )
  75             throw( NoConnectException, ConnectionSetupException, 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
  83     OConnector::OConnector(const Reference< XComponentContext > &xCtx)
  84         : _xSMgr( xCtx->getServiceManager() )
  85         , _xCtx( xCtx )
  86     {
  87         g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt );
  88     }
  89
  90     OConnector::~OConnector()
  91     {
  92         g_moduleCount.modCnt.release( &g_moduleCount.modCnt );
  93     }
  94
  95     Reference< XConnection > SAL_CALL OConnector::connect( const OUString& sConnectionDescription )
  96         throw( NoConnectException, ConnectionSetupException, RuntimeException)
  97     {
  98         OSL_TRACE(
  99             "connector %s\n",
 100             OUStringToOString(
 101                 sConnectionDescription, RTL_TEXTENCODING_ASCII_US).getStr());
 102
 103         // split string into tokens
 104         try
 105         {
 106             cppu::UnoUrlDescriptor aDesc(sConnectionDescription);
 107
 108             Reference< XConnection > r;
 109             if (aDesc.getName().equalsAsciiL(RTL_CONSTASCII_STRINGPARAM(
 110                                                  "pipe")))
 111             {
 112                 rtl::OUString aName(
 113                     aDesc.getParameter(
 114                         rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("name"))));
 115
 116                 PipeConnection *pConn = new PipeConnection( sConnectionDescription );
 117
 118                 if( pConn->m_pipe.create( aName.pData, osl_Pipe_OPEN, osl::Security() ) )
 119                 {
 120                     r = Reference < XConnection > ( (XConnection * ) pConn );
 121                 }
 122                 else
 123                 {
 124                     OUString sMessage = OUString::createFromAscii( "Connector : couldn't connect to pipe " );
 125                     sMessage += aName;
 126                     sMessage += OUString::createFromAscii( "(" );
 127                     sMessage += OUString::valueOf( (sal_Int32 ) pConn->m_pipe.getError() );
 128                     sMessage += OUString::createFromAscii( ")" );
 129                     delete pConn;
 130                     throw NoConnectException( sMessage ,Reference< XInterface > () );
 131                 }
 132             }
 133             else if (aDesc.getName().equalsAsciiL(RTL_CONSTASCII_STRINGPARAM(
 134                                                       "socket")))
 135             {
 136                 rtl::OUString aHost;
 137                 if (aDesc.hasParameter(
 138                         rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("host"))))
 139                     aHost = aDesc.getParameter(
 140                         rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("host")));
 141                 else
 142                     aHost = rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(
 143                                               "localhost"));
 144                 sal_uInt16 nPort = static_cast< sal_uInt16 >(
 145                     aDesc.getParameter(
 146                         rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("port"))).
 147                     toInt32());
 148                 bool bTcpNoDelay
 149                     = aDesc.getParameter(
 150                         rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(
 151                                           "tcpnodelay"))).toInt32() != 0;
 152
 153                 SocketConnection *pConn = new SocketConnection( sConnectionDescription);
 154
 155                 SocketAddr AddrTarget( aHost.pData, nPort );
 156                 if(pConn->m_socket.connect(AddrTarget) != osl_Socket_Ok)
 157                 {
 158                     OUString sMessage = OUString::createFromAscii( "Connector : couldn't connect to socket (" );
 159                     OUString sError = pConn->m_socket.getErrorAsString();
 160                     sMessage += sError;
 161                     sMessage += OUString::createFromAscii( ")" );
 162                     delete pConn;
 163                     throw NoConnectException( sMessage, Reference < XInterface > () );
 164                 }
 165                 if( bTcpNoDelay )
 166                 {
 167                     sal_Int32 nTcpNoDelay = sal_True;
 168                     pConn->m_socket.setOption( osl_Socket_OptionTcpNoDelay , &nTcpNoDelay,
 169                                                sizeof( nTcpNoDelay ) , osl_Socket_LevelTcp );
 170                 }
 171                 pConn->completeConnectionString();
 172                 r = Reference< XConnection > ( (XConnection * ) pConn );
 173             }
 174             else
 175             {
 176                 OUString delegatee = OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Connector."));
 177                 delegatee += aDesc.getName();
 178
 179                 OSL_TRACE(
 180                     "connector: trying to get service %s\n",
 181                     OUStringToOString(
 182                         delegatee, RTL_TEXTENCODING_ASCII_US).getStr());
 183                 Reference<XConnector> xConnector(
 184                     _xSMgr->createInstanceWithContext(delegatee, _xCtx), UNO_QUERY );
 185
 186                 if(!xConnector.is())
 187                 {
 188                     OUString message(RTL_CONSTASCII_USTRINGPARAM("Connector: unknown delegatee "));
 189                     message += delegatee;
 190
 191                     throw ConnectionSetupException(message, Reference<XInterface>());
 192                 }
 193
 194                 sal_Int32 index = sConnectionDescription.indexOf((sal_Unicode) ',');
 195
 196                 r = xConnector->connect(sConnectionDescription.copy(index + 1).trim());
 197             }
 198             return r;
 199         }
 200         catch (rtl::MalformedUriException & rEx)
 201         {
 202             throw ConnectionSetupException(rEx.getMessage(),
 203                                            Reference< XInterface > ());
 204         }
 205     }
 206
 207     Sequence< OUString > connector_getSupportedServiceNames()
 208     {
 209         static Sequence < OUString > *pNames = 0;
 210         if( ! pNames )
 211         {
 212             MutexGuard guard( Mutex::getGlobalMutex() );
 213             if( !pNames )
 214             {
 215                 static Sequence< OUString > seqNames(1);
 216                 seqNames.getArray()[0] = OUString::createFromAscii( SERVICE_NAME );
 217                 pNames = &seqNames;
 218             }
 219         }
 220         return *pNames;
 221     }
 222
 223     OUString connector_getImplementationName()
 224     {
 225         return OUString( RTL_CONSTASCII_USTRINGPARAM( IMPLEMENTATION_NAME ) );
 226     }
 227
 228         OUString OConnector::getImplementationName() throw()
 229     {
 230         return connector_getImplementationName();
 231     }
 232
 233         sal_Bool OConnector::supportsService(const OUString& ServiceName) throw()
 234     {
 235         Sequence< OUString > aSNL = getSupportedServiceNames();
 236         const OUString * pArray = aSNL.getConstArray();
 237
 238         for( sal_Int32 i = 0; i < aSNL.getLength(); i++ )
 239             if( pArray[i] == ServiceName )
 240                 return sal_True;
 241
 242         return sal_False;
 243     }
 244
 245         Sequence< OUString > OConnector::getSupportedServiceNames(void) throw()
 246     {
 247         return connector_getSupportedServiceNames();
 248     }
 249
 250     Reference< XInterface > SAL_CALL connector_CreateInstance( const Reference< XComponentContext > & xCtx)
 251     {
 252         return Reference < XInterface >( ( OWeakObject * ) new OConnector(xCtx) );
 253     }
 254
 255
 256 }
 257 using namespace stoc_connector;
 258
 259 static struct ImplementationEntry g_entries[] =
 260 {
 261     {
 262         connector_CreateInstance, connector_getImplementationName ,
 263         connector_getSupportedServiceNames, createSingleComponentFactory ,
 264         &g_moduleCount.modCnt , 0
 265     },
 266     { 0, 0, 0, 0, 0, 0 }
 267 };
 268
 269 extern "C"
 270 {
 271
 272 sal_Bool SAL_CALL component_canUnload( TimeValue *pTime )
 273 {
 274     return g_moduleCount.canUnload( &g_moduleCount , pTime );
 275 }
 276
 277 //==================================================================================================
 278 void SAL_CALL component_getImplementationEnvironment(
 279     const sal_Char ** ppEnvTypeName, uno_Environment ** )
 280 {
 281     *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME;
 282 }
 283 //==================================================================================================
 284 sal_Bool SAL_CALL component_writeInfo(
 285     void * pServiceManager, void * pRegistryKey )
 286 {
 287     return component_writeInfoHelper( pServiceManager, pRegistryKey, g_entries );
 288 }
 289 //==================================================================================================
 290 void * SAL_CALL component_getFactory(
 291     const sal_Char * pImplName, void * pServiceManager, void * pRegistryKey )
 292 {
 293     return component_getFactoryHelper( pImplName, pServiceManager, pRegistryKey , g_entries );
 294 }
 295
 296 }
 297
 298