io/test/testconnection.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*************************************************************************
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   6  * Copyright 2000, 2010 Oracle and/or its affiliates.
   7  *
   8  * OpenOffice.org - a multi-platform office productivity suite
   9  *
  10  * This file is part of OpenOffice.org.
  11  *
  12  * OpenOffice.org is free software: you can redistribute it and/or modify
  13  * it under the terms of the GNU Lesser General Public License version 3
  14  * only, as published by the Free Software Foundation.
  15  *
  16  * OpenOffice.org is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19  * GNU Lesser General Public License version 3 for more details
  20  * (a copy is included in the LICENSE file that accompanied this code).
  21  *
  22  * You should have received a copy of the GNU Lesser General Public License
  23  * version 3 along with OpenOffice.org.  If not, see
  24  * <http://www.openoffice.org/license.html>
  25  * for a copy of the LGPLv3 License.
  26  *
  27  ************************************************************************/
  28
  29 // MARKER(update_precomp.py): autogen include statement, do not remove
  30 #include "precompiled_io.hxx"
  31 #include <stdio.h>
  32 #include <osl/time.h>
  33
  34 #include <osl/diagnose.h>
  35 #include <osl/thread.hxx>
  36
  37 #include <cppuhelper/servicefactory.hxx>
  38
  39 #include <com/sun/star/lang/XComponent.hpp>
  40
  41 #include <com/sun/star/registry/XImplementationRegistration.hpp>
  42
  43 #include <com/sun/star/connection/XConnector.hpp>
  44 #include <com/sun/star/connection/XAcceptor.hpp>
  45
  46 using namespace ::osl;
  47 using namespace ::rtl;
  48 using namespace ::cppu;
  49 using namespace ::com::sun::star::uno;
  50 using namespace ::com::sun::star::io;
  51 using namespace ::com::sun::star::lang;
  52 using namespace ::com::sun::star::registry;
  53 using namespace ::com::sun::star::connection;
  54
  55
  56 class MyThread :
  57     public Thread
  58 {
  59 public:
  60     MyThread( const Reference< XAcceptor > &r , const OUString & sConnectionDescription) :
  61         m_rAcceptor( r ),
  62         m_sConnectionDescription( sConnectionDescription )
  63         {}
  64     virtual void SAL_CALL run();
  65
  66     Reference < XAcceptor > m_rAcceptor;
  67 private:
  68     Reference < XConnection > m_rConnection;
  69     OUString m_sConnectionDescription;
  70 };
  71
  72 void doWrite( const Reference < XConnection > &r )
  73 {
  74     Sequence < sal_Int8 > seq(10);
  75     for( sal_Int32 i = 0 ; i < 10 ; i ++ )
  76     {
  77         seq.getArray()[i] = i;
  78     }
  79
  80     r->write( seq );
  81 }
  82
  83 void doRead( const Reference < XConnection > &r )
  84 {
  85     Sequence < sal_Int8 > seq(10);
  86
  87     OSL_ASSERT( 10 == r->read( seq , 10 ) );
  88
  89     for( sal_Int32 i = 0 ; i < 10 ; i ++ )
  90     {
  91         OSL_ASSERT( seq.getConstArray()[i] == i );
  92     }
  93 }
  94
  95
  96 void MyThread::run()
  97 {
  98     try
  99     {
 100         m_rConnection = m_rAcceptor->accept( m_sConnectionDescription );
 101     }
 102     catch ( Exception &e)
 103     {
 104         OString tmp= OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US );
 105         printf( "Exception was thrown by acceptor thread: %s\n", tmp.getStr() );
 106     }
 107
 108     if( m_rConnection.is() )
 109     {
 110         Sequence < sal_Int8 > seq(12);
 111         try
 112         {
 113             doWrite( m_rConnection );
 114             doRead( m_rConnection );
 115         }
 116         catch (... )
 117         {
 118             printf( "unknown exception was thrown\n" );
 119             throw;
 120         }
 121     }
 122
 123 }
 124
 125
 126
 127
 128
 129 void testConnection( const OUString &sConnectionDescription  ,
 130                      const Reference < XAcceptor > &rAcceptor,
 131                      const Reference < XConnector > &rConnector )
 132 {
 133     {
 134         MyThread thread( rAcceptor , sConnectionDescription );
 135         thread.create();
 136
 137         sal_Bool bGotit = sal_False;
 138         Reference < XConnection > r;
 139
 140         while( ! bGotit )
 141         {
 142             try
 143             {
 144                 // Why is this wait necessary ????
 145                 TimeValue value = {1,0};
 146                 osl_waitThread( &value );
 147                 r = rConnector->connect( sConnectionDescription );
 148                 OSL_ASSERT( r.is() );
 149                 doWrite( r );
 150                 doRead( r );
 151                 bGotit = sal_True;
 152             }
 153             catch( ... )
 154             {
 155                 printf( "Couldn't connect, retrying ...\n" );
 156
 157             }
 158         }
 159
 160         r->close();
 161
 162         try
 163         {
 164             Sequence < sal_Int8 > seq(10);
 165             r->write( seq );
 166             OSL_FAIL( "expected exception not thrown" );
 167         }
 168         catch ( IOException & )
 169         {
 170             // everything is ok
 171         }
 172         catch ( ... )
 173         {
 174             OSL_FAIL( "wrong exception was thrown" );
 175         }
 176
 177         thread.join();
 178     }
 179 }
 180
 181
 182 int SAL_CALL main( int argc, char * argv[] )
 183 {
 184     Reference< XMultiServiceFactory > xMgr(
 185         createRegistryServiceFactory( OUString( RTL_CONSTASCII_USTRINGPARAM("applicat.rdb")) ) );
 186
 187     Reference< XImplementationRegistration > xImplReg(
 188         xMgr->createInstance( OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.registry.ImplementationRegistration")) ), UNO_QUERY );
 189     OSL_ENSURE( xImplReg.is(), "### no impl reg!" );
 190
 191     OUString aLibName =
 192         OUString(RTL_CONSTASCII_USTRINGPARAM( "connector.uno" SAL_DLLEXTENSION ));
 193     xImplReg->registerImplementation(
 194         OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.loader.SharedLibrary")), aLibName, Reference< XSimpleRegistry >() );
 195
 196     aLibName = OUString(RTL_CONSTASCII_USTRINGPARAM( "acceptor.uno" SAL_DLLEXTENSION ));
 197     xImplReg->registerImplementation(
 198         OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.loader.SharedLibrary")), aLibName, Reference< XSimpleRegistry >() );
 199
 200     Reference < XAcceptor >  rAcceptor(
 201         xMgr->createInstance(
 202             OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Acceptor")) ) , UNO_QUERY );
 203
 204     Reference < XAcceptor >  rAcceptorPipe(
 205         xMgr->createInstance(
 206             OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Acceptor")) ) , UNO_QUERY );
 207
 208     Reference < XConnector >  rConnector(
 209         xMgr->createInstance( OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Connector")) ) , UNO_QUERY );
 210
 211
 212     printf( "Testing sockets" );
 213     fflush( stdout );
 214     testConnection( OUString(RTL_CONSTASCII_USTRINGPARAM("socket,host=localhost,port=2001")), rAcceptor , rConnector );
 215     printf( " Done\n" );
 216
 217     printf( "Testing pipe" );
 218     fflush( stdout );
 219     testConnection( OUString(RTL_CONSTASCII_USTRINGPARAM("pipe,name=bla")) , rAcceptorPipe , rConnector );
 220     printf( " Done\n" );
 221
 222     // check, if errornous strings make any problem
 223     rAcceptor = Reference< XAcceptor > (
 224         xMgr->createInstance( OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Acceptor")) ),
 225         UNO_QUERY );
 226
 227     try
 228     {
 229         rAcceptor->accept( OUString() );
 230         OSL_FAIL( "empty connection string" );
 231     }
 232     catch( IllegalArgumentException & )
 233     {
 234         // everything is fine
 235     }
 236     catch( ... )
 237     {
 238         OSL_FAIL( "unexpected akexception with empty connection string" );
 239     }
 240
 241     try
 242     {
 243         rConnector->connect( OUString() );
 244         OSL_FAIL( "empty connection string" );
 245     }
 246     catch( ConnectionSetupException & )
 247     {
 248         // everything is fine
 249     }
 250     catch( ... )
 251     {
 252         OSL_FAIL( "unexpected exception with empty connection string" );
 253     }
 254
 255
 256     MyThread thread( rAcceptor , OUString(RTL_CONSTASCII_USTRINGPARAM("socket,host=localhost,port=2001")) );
 257     thread.create();
 258
 259     TimeValue value = {0,1};
 260     osl_waitThread( &value );
 261     try
 262     {
 263         rAcceptor->accept( OUString(RTL_CONSTASCII_USTRINGPARAM("socket,host=localhost,port=2001")) );
 264         OSL_FAIL( "already existing exception expected" );
 265     }
 266     catch( AlreadyAcceptingException & e)
 267     {
 268         // everything is fine
 269     }
 270     catch( ... )
 271     {
 272         OSL_FAIL( "unknown exception, already existing existing expected" );
 273     }
 274
 275     rAcceptor->stopAccepting();
 276     thread.join();
 277
 278     Reference < XComponent > rComp( xMgr , UNO_QUERY );
 279     if( rComp.is() )
 280     {
 281         rComp->dispose();
 282     }
 283 }
 284
 285 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */