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 #include <stdio.h>
  30 #include <osl/time.h>
  31
  32 #include <osl/diagnose.h>
  33 #include <osl/thread.hxx>
  34
  35 #include <cppuhelper/servicefactory.hxx>
  36
  37 #include <com/sun/star/lang/XComponent.hpp>
  38
  39 #include <com/sun/star/registry/XImplementationRegistration.hpp>
  40
  41 #include <com/sun/star/connection/XConnector.hpp>
  42 #include <com/sun/star/connection/XAcceptor.hpp>
  43
  44 using namespace ::osl;
  45 using namespace ::rtl;
  46 using namespace ::cppu;
  47 using namespace ::com::sun::star::uno;
  48 using namespace ::com::sun::star::io;
  49 using namespace ::com::sun::star::lang;
  50 using namespace ::com::sun::star::registry;
  51 using namespace ::com::sun::star::connection;
  52
  53
  54 class MyThread :
  55     public Thread
  56 {
  57 public:
  58     MyThread( const Reference< XAcceptor > &r , const OUString & sConnectionDescription) :
  59         m_rAcceptor( r ),
  60         m_sConnectionDescription( sConnectionDescription )
  61         {}
  62     virtual void SAL_CALL run();
  63
  64     Reference < XAcceptor > m_rAcceptor;
  65 private:
  66     Reference < XConnection > m_rConnection;
  67     OUString m_sConnectionDescription;
  68 };
  69
  70 void doWrite( const Reference < XConnection > &r )
  71 {
  72     Sequence < sal_Int8 > seq(10);
  73     for( sal_Int32 i = 0 ; i < 10 ; i ++ )
  74     {
  75         seq.getArray()[i] = i;
  76     }
  77
  78     r->write( seq );
  79 }
  80
  81 void doRead( const Reference < XConnection > &r )
  82 {
  83     Sequence < sal_Int8 > seq(10);
  84
  85     OSL_ASSERT( 10 == r->read( seq , 10 ) );
  86
  87     for( sal_Int32 i = 0 ; i < 10 ; i ++ )
  88     {
  89         OSL_ASSERT( seq.getConstArray()[i] == i );
  90     }
  91 }
  92
  93
  94 void MyThread::run()
  95 {
  96     try
  97     {
  98         m_rConnection = m_rAcceptor->accept( m_sConnectionDescription );
  99     }
 100     catch ( const Exception &e)
 101     {
 102         OString tmp= OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US );
 103         printf( "Exception was thrown by acceptor thread: %s\n", tmp.getStr() );
 104     }
 105
 106     if( m_rConnection.is() )
 107     {
 108         Sequence < sal_Int8 > seq(12);
 109         try
 110         {
 111             doWrite( m_rConnection );
 112             doRead( m_rConnection );
 113         }
 114         catch (... )
 115         {
 116             printf( "unknown exception was thrown\n" );
 117             throw;
 118         }
 119     }
 120
 121 }
 122
 123
 124
 125
 126
 127 void testConnection( const OUString &sConnectionDescription  ,
 128                      const Reference < XAcceptor > &rAcceptor,
 129                      const Reference < XConnector > &rConnector )
 130 {
 131     {
 132         MyThread thread( rAcceptor , sConnectionDescription );
 133         thread.create();
 134
 135         sal_Bool bGotit = sal_False;
 136         Reference < XConnection > r;
 137
 138         while( ! bGotit )
 139         {
 140             try
 141             {
 142                 // Why is this wait necessary ????
 143                 TimeValue value = {1,0};
 144                 osl_waitThread( &value );
 145                 r = rConnector->connect( sConnectionDescription );
 146                 OSL_ASSERT( r.is() );
 147                 doWrite( r );
 148                 doRead( r );
 149                 bGotit = sal_True;
 150             }
 151             catch( ... )
 152             {
 153                 printf( "Couldn't connect, retrying ...\n" );
 154
 155             }
 156         }
 157
 158         r->close();
 159
 160         try
 161         {
 162             Sequence < sal_Int8 > seq(10);
 163             r->write( seq );
 164             OSL_FAIL( "expected exception not thrown" );
 165         }
 166         catch ( IOException & )
 167         {
 168             // everything is ok
 169         }
 170         catch ( ... )
 171         {
 172             OSL_FAIL( "wrong exception was thrown" );
 173         }
 174
 175         thread.join();
 176     }
 177 }
 178
 179
 180 int SAL_CALL main( int argc, char * argv[] )
 181 {
 182     Reference< XMultiServiceFactory > xMgr(
 183         createRegistryServiceFactory( OUString( "applicat.rdb") ) );
 184
 185     Reference< XImplementationRegistration > xImplReg(
 186         xMgr->createInstance( OUString("com.sun.star.registry.ImplementationRegistration") ), UNO_QUERY );
 187     OSL_ENSURE( xImplReg.is(), "### no impl reg!" );
 188
 189     OUString aLibName =
 190         OUString( "connector.uno" SAL_DLLEXTENSION );
 191     xImplReg->registerImplementation(
 192         OUString("com.sun.star.loader.SharedLibrary"), aLibName, Reference< XSimpleRegistry >() );
 193
 194     aLibName = OUString( "acceptor.uno" SAL_DLLEXTENSION );
 195     xImplReg->registerImplementation(
 196         OUString("com.sun.star.loader.SharedLibrary"), aLibName, Reference< XSimpleRegistry >() );
 197
 198     Reference < XAcceptor >  rAcceptor(
 199         xMgr->createInstance(
 200             OUString("com.sun.star.connection.Acceptor") ) , UNO_QUERY );
 201
 202     Reference < XAcceptor >  rAcceptorPipe(
 203         xMgr->createInstance(
 204             OUString("com.sun.star.connection.Acceptor") ) , UNO_QUERY );
 205
 206     Reference < XConnector >  rConnector(
 207         xMgr->createInstance( OUString("com.sun.star.connection.Connector") ) , UNO_QUERY );
 208
 209
 210     printf( "Testing sockets" );
 211     fflush( stdout );
 212     testConnection( OUString("socket,host=localhost,port=2001"), rAcceptor , rConnector );
 213     printf( " Done\n" );
 214
 215     printf( "Testing pipe" );
 216     fflush( stdout );
 217     testConnection( OUString("pipe,name=bla") , rAcceptorPipe , rConnector );
 218     printf( " Done\n" );
 219
 220     // check, if errornous strings make any problem
 221     rAcceptor = Reference< XAcceptor > (
 222         xMgr->createInstance( OUString("com.sun.star.connection.Acceptor") ),
 223         UNO_QUERY );
 224
 225     try
 226     {
 227         rAcceptor->accept( OUString() );
 228         OSL_FAIL( "empty connection string" );
 229     }
 230     catch( IllegalArgumentException & )
 231     {
 232         // everything is fine
 233     }
 234     catch( ... )
 235     {
 236         OSL_FAIL( "unexpected akexception with empty connection string" );
 237     }
 238
 239     try
 240     {
 241         rConnector->connect( OUString() );
 242         OSL_FAIL( "empty connection string" );
 243     }
 244     catch( ConnectionSetupException & )
 245     {
 246         // everything is fine
 247     }
 248     catch( ... )
 249     {
 250         OSL_FAIL( "unexpected exception with empty connection string" );
 251     }
 252
 253
 254     MyThread thread( rAcceptor , OUString("socket,host=localhost,port=2001") );
 255     thread.create();
 256
 257     TimeValue value = {0,1};
 258     osl_waitThread( &value );
 259     try
 260     {
 261         rAcceptor->accept( OUString("socket,host=localhost,port=2001") );
 262         OSL_FAIL( "already existing exception expected" );
 263     }
 264     catch( AlreadyAcceptingException & )
 265     {
 266         // everything is fine
 267     }
 268     catch( ... )
 269     {
 270         OSL_FAIL( "unknown exception, already existing existing expected" );
 271     }
 272
 273     rAcceptor->stopAccepting();
 274     thread.join();
 275
 276     Reference < XComponent > rComp( xMgr , UNO_QUERY );
 277     if( rComp.is() )
 278     {
 279         rComp->dispose();
 280     }
 281 }
 282
 283 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */