diff options
Diffstat (limited to 'bridges/test/testserver.cxx')
| -rw-r--r-- | bridges/test/testserver.cxx | 243 |
1 files changed, 0 insertions, 243 deletions
diff --git a/bridges/test/testserver.cxx b/bridges/test/testserver.cxx deleted file mode 100644 index df2c22d9ef43..000000000000 --- a/bridges/test/testserver.cxx +++ /dev/null @@ -1,243 +0,0 @@ -/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ -/* - * This file is part of the LibreOffice project. - * - * This Source Code Form is subject to the terms of the Mozilla Public - * License, v. 2.0. If a copy of the MPL was not distributed with this - * file, You can obtain one at http://mozilla.org/MPL/2.0/. - * - * This file incorporates work covered by the following license notice: - * - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed - * with this work for additional information regarding copyright - * ownership. The ASF licenses this file to you under the Apache - * License, Version 2.0 (the "License"); you may not use this file - * except in compliance with the License. You may obtain a copy of - * the License at http://www.apache.org/licenses/LICENSE-2.0 . - */ - -#include <string.h> -#include <osl/time.h> - -#include <osl/mutex.hxx> -#include <osl/conditn.h> - -#include <osl/thread.hxx> - -#include <cppuhelper/servicefactory.hxx> - -#include <com/sun/star/connection/XAcceptor.hpp> -#include <com/sun/star/connection/XConnection.hpp> - -#include <com/sun/star/bridge/XInstanceProvider.hpp> -#include <com/sun/star/bridge/XBridgeFactory.hpp> - -#include <com/sun/star/lang/XComponent.hpp> -#include <com/sun/star/lang/XInitialization.hpp> - - -#include <test/XTestFactory.hpp> - -#include <cppuhelper/weak.hxx> - -using namespace ::test; -using namespace ::osl; -using namespace ::cppu; -using namespace ::com::sun::star::uno; -using namespace ::com::sun::star::lang; -using namespace ::com::sun::star::bridge; -using namespace ::com::sun::star::connection; -#include "testcomp.h" -#ifdef SAL_W32 -#include <conio.h> -#endif - -/********* - * - ********/ - - - -class MyThread : - public Thread -{ -public: - MyThread( const Reference< XAcceptor > &r , - const Reference< XBridgeFactory > &rFactory, - const Reference< XMultiServiceFactory > &rSMgr, - const OUString &sConnectionDescription, - const OUString &sProtocol, - sal_Bool bReverse, - sal_Bool bLatency ) : - m_rAcceptor( r ), - m_rBridgeFactory ( rFactory ), - m_rSMgr( rSMgr ), - m_sConnectionDescription( sConnectionDescription ), - m_sProtocol( sProtocol ), - m_bReverse( bReverse ), - m_bLatency( bLatency ) - {} - virtual void SAL_CALL run(); - - void latencyTest( const Reference< XConnection > &r ); - -private: - Reference < XAcceptor > m_rAcceptor; - Reference < XBridgeFactory > m_rBridgeFactory; - Reference < XMultiServiceFactory > m_rSMgr; - OUString m_sConnectionDescription; - OUString m_sProtocol; - sal_Bool m_bReverse; - sal_Bool m_bLatency; -}; - - -void MyThread::latencyTest( const Reference< XConnection > &r ) -{ - Sequence < sal_Int8 > s; - while( 12 == r->read( s , 12 ) ) - { - r->read( s , 188 ); - s = Sequence < sal_Int8 >(60); - r->write( s ); - } -} - -void MyThread::run() -{ - - while ( true ) - { - try - { - Reference < XConnection > rConnection = - m_rAcceptor->accept( m_sConnectionDescription ); - - if( ! rConnection.is() ) - { - break; - } - if( m_bLatency ) - { - latencyTest( rConnection ); - } - else - { - - Reference < XBridge > rBridge = - m_rBridgeFactory->createBridge( - OUString() , - m_sProtocol, - rConnection , - (XInstanceProvider * ) new OInstanceProvider(m_rSMgr) ); - - - if( m_bReverse ) - { - printf( "doing reverse callme test (test is ok, when on each line a +- appears\n" ); - Reference < XInterface > r = rBridge->getInstance( - OUString("blubber" )); - Reference < XTestFactory > rFactory( r , UNO_QUERY ); - Reference < XCallMe > rCallMe = rFactory->createCallMe(); - - for( sal_Int32 i = 0 ; i < 1 ; i ++ ) - { - rCallMe->callOneway( - OUString("my test string") , 2 ); - } - printf( "all oneway are send\n" ); - rCallMe->call( OUString( "reverse call me test finished" ) , 0 ); - printf( "revers callme test finished\n" ); - } - } - } - catch ( Exception & e ) - { - printf( "Exception was thrown by acceptor \n" ); - OString o = OUStringToOString( e.Message , RTL_TEXTENCODING_ASCII_US ); - printf( "%s\n" , o.getStr() ); - break; - } - catch ( ... ) - { - printf( "Exception was thrown by acceptor thread\n" ); - break; - } - } -} - - -int main( int argc, char *argv[] ) -{ -// testserver(); - - if( argc < 2 ) - { - printf( "usage : testserver [-r] connectionstring\n" - " -r does a reverse test (server calls client)\n" ); - return 0; - } - - OUString sConnectionString; - OUString sProtocol; - sal_Bool bReverse = sal_False; - sal_Bool bLatency = sal_False; - - parseCommandLine( argv , &sConnectionString , &sProtocol , &bLatency , &bReverse ); - - { - Reference< XMultiServiceFactory > rSMgr = createRegistryServiceFactory( - OUString( "server.rdb" ) ); - - Reference < XBridgeFactory > rBridgeFactory ( createComponent( - OUString("com.sun.star.bridge.BridgeFactory"), - OUString( "bridgefac.uno" SAL_DLLEXTENSION ), - rSMgr ), - UNO_QUERY ); - - - createComponent( OUString("com.sun.star.bridge.Bridge.iiop"), - OUString( "remotebridge.uno" SAL_DLLEXTENSION), - rSMgr ); - - - Reference < XAcceptor > rAcceptor( - createComponent( OUString("com.sun.star.connection.Acceptor"), - OUString( "acceptor.uno" SAL_DLLEXTENSION), - rSMgr ) , - UNO_QUERY ); - - MyThread thread( rAcceptor , - rBridgeFactory, - rSMgr, - sConnectionString, - sProtocol, - bReverse, - bLatency); - thread.create(); - -#ifdef SAL_W32 - _getch(); -#elif SOLARIS - getchar(); -#elif LINUX - TimeValue value={360,0}; - osl_waitThread( &value ); -#endif - printf( "Closing...\n" ); - - rAcceptor->stopAccepting(); - thread.join(); - - printf( "Closed\n" ); - - Reference < XComponent > rComp2( rBridgeFactory , UNO_QUERY ); - rComp2->dispose(); - Reference < XComponent > rComp( rSMgr, UNO_QUERY ); - rComp->dispose(); - } - return 0; -} - -/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |