diff options
author | Jens-Heiner Rechtien <hr@openoffice.org> | 2000-09-18 16:24:28 +0000 |
---|---|---|
committer | Jens-Heiner Rechtien <hr@openoffice.org> | 2000-09-18 16:24:28 +0000 |
commit | c368188fa9e6677a1d8a1fb41bca0e0244de3c60 (patch) | |
tree | e8f2631b0404a23a126accab0a0c80780fd6c5d1 /io/source/acceptor | |
parent | 1ab65692f0a23cf8757a0937b325abcaa841d610 (diff) |
initial import
Diffstat (limited to 'io/source/acceptor')
-rw-r--r-- | io/source/acceptor/acc_pipe.cxx | 226 | ||||
-rw-r--r-- | io/source/acceptor/acc_socket.cxx | 403 | ||||
-rw-r--r-- | io/source/acceptor/acceptor.cxx | 410 | ||||
-rw-r--r-- | io/source/acceptor/acceptor.hxx | 106 | ||||
-rw-r--r-- | io/source/acceptor/acceptor.xml | 56 | ||||
-rw-r--r-- | io/source/acceptor/makefile.mk | 109 |
6 files changed, 1310 insertions, 0 deletions
diff --git a/io/source/acceptor/acc_pipe.cxx b/io/source/acceptor/acc_pipe.cxx new file mode 100644 index 000000000..521267750 --- /dev/null +++ b/io/source/acceptor/acc_pipe.cxx @@ -0,0 +1,226 @@ +/************************************************************************* + * + * $RCSfile: acc_pipe.cxx,v $ + * + * $Revision: 1.1.1.1 $ + * + * last change: $Author: hr $ $Date: 2000-09-18 17:24:17 $ + * + * The Contents of this file are made available subject to the terms of + * either of the following licenses + * + * - GNU Lesser General Public License Version 2.1 + * - Sun Industry Standards Source License Version 1.1 + * + * Sun Microsystems Inc., October, 2000 + * + * GNU Lesser General Public License Version 2.1 + * ============================================= + * Copyright 2000 by Sun Microsystems, Inc. + * 901 San Antonio Road, Palo Alto, CA 94303, USA + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software Foundation. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, + * MA 02111-1307 USA + * + * + * Sun Industry Standards Source License Version 1.1 + * ================================================= + * The contents of this file are subject to the Sun Industry Standards + * Source License Version 1.1 (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.openoffice.org/license.html. + * + * Software provided under this License is provided on an "AS IS" basis, + * WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, + * WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS, + * MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING. + * See the License for the specific provisions governing your rights and + * obligations concerning the Software. + * + * The Initial Developer of the Original Code is: Sun Microsystems, Inc. + * + * Copyright: 2000 by Sun Microsystems, Inc. + * + * All Rights Reserved. + * + * Contributor(s): _______________________________________ + * + * + ************************************************************************/ +#include "acceptor.hxx" +#include <com/sun/star/connection/ConnectionSetupException.hpp> + +#include <cppuhelper/implbase1.hxx> + +using namespace ::vos; +using namespace ::rtl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::connection; +using namespace ::com::sun::star::io; + + +namespace stoc_acceptor +{ + + typedef WeakImplHelper1< XConnection > MyPipeConnection; + + class PipeConnection : + public MyPipeConnection + { + public: + PipeConnection( const OUString & s , sal_Bool bIgnoreClose); + + virtual sal_Int32 SAL_CALL read( Sequence< sal_Int8 >& aReadBytes, sal_Int32 nBytesToRead ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL write( const Sequence< sal_Int8 >& aData ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL flush( ) throw( + ::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL close( ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException); + virtual ::rtl::OUString SAL_CALL getDescription( ) + throw(::com::sun::star::uno::RuntimeException); + public: + ::vos::OStreamPipe m_pipe; + oslInterlockedCount m_nStatus; + OUString m_sDescription; + sal_Bool m_bIgnoreClose; + }; + + + + PipeConnection::PipeConnection( const OUString &s , sal_Bool bIgnoreClose) : + m_nStatus( 0 ), + m_sDescription( OUString::createFromAscii( "pipe:" ) ), + m_bIgnoreClose( bIgnoreClose ) + { + m_sDescription += s; + m_sDescription += OUString::createFromAscii( ":" ); + + // make it unique + m_sDescription += OUString::valueOf( (sal_Int64) (OObject * ) &m_pipe , 10 ); + } + + sal_Int32 PipeConnection::read( Sequence < sal_Int8 > & aReadBytes , sal_Int32 nBytesToRead ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException) + { + if( ! m_nStatus ) + { + if( aReadBytes.getLength() != nBytesToRead ) + { + aReadBytes.realloc( nBytesToRead ); + } + return m_pipe.read( aReadBytes.getArray() , aReadBytes.getLength() ); + } + else { + throw IOException(); + } + + return 0; + } + + void PipeConnection::write( const Sequence < sal_Int8 > &seq ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException) + { + if( ! m_nStatus ) + { + if( m_pipe.write( seq.getConstArray() , seq.getLength() ) != seq.getLength() ) + { + throw IOException(); + } + } + else { + throw IOException(); + } + } + + void PipeConnection::flush( ) + throw( ::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException) + { + } + + void PipeConnection::close() + throw( ::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException) + { + if( ! m_bIgnoreClose && 1 == osl_incrementInterlockedCount( (&m_nStatus) ) ) + { + m_pipe.close(); + } + } + + OUString PipeConnection::getDescription() + throw(::com::sun::star::uno::RuntimeException) + { + return m_sDescription; + } + + /*************** + * PipeAcceptor + **************/ + PipeAcceptor::PipeAcceptor( const OUString &sPipeName , sal_Bool bIgnoreClose) : + m_bClosed( sal_False ), + m_sPipeName( sPipeName ), + m_bIgnoreClose( bIgnoreClose ) + { + } + + + void PipeAcceptor::init() + { +#ifdef ENABLEUNICODE + m_pipe.create( m_sPipeName.pData , ::vos::OPipe::TOption_Create ); +#else + OString o = OUStringToOString( m_sPipeName , RTL_TEXTENCODING_ASCII_US ); + m_pipe.create( o.pData->buffer , ::vos::OPipe::TOption_Create ); +#endif + } + + Reference< XConnection > PipeAcceptor::accept( ) + { + PipeConnection *pConn = new PipeConnection( m_sPipeName , m_bIgnoreClose ); + + OPipe::TPipeError status = m_pipe.accept( pConn->m_pipe ); + + if( m_bClosed ) + { + // stopAccepting was called ! + delete pConn; + return Reference < XConnection >(); + } + else if( OPipe::E_None == status ) + { + return Reference < XConnection > ( (XConnection * ) pConn ); + } + else + { + throw ConnectionSetupException(); + } + } + + void PipeAcceptor::stopAccepting() + { + m_bClosed = sal_True; + m_pipe.close(); + } +} diff --git a/io/source/acceptor/acc_socket.cxx b/io/source/acceptor/acc_socket.cxx new file mode 100644 index 000000000..58c7a7480 --- /dev/null +++ b/io/source/acceptor/acc_socket.cxx @@ -0,0 +1,403 @@ +/************************************************************************* + * + * $RCSfile: acc_socket.cxx,v $ + * + * $Revision: 1.1.1.1 $ + * + * last change: $Author: hr $ $Date: 2000-09-18 17:24:17 $ + * + * The Contents of this file are made available subject to the terms of + * either of the following licenses + * + * - GNU Lesser General Public License Version 2.1 + * - Sun Industry Standards Source License Version 1.1 + * + * Sun Microsystems Inc., October, 2000 + * + * GNU Lesser General Public License Version 2.1 + * ============================================= + * Copyright 2000 by Sun Microsystems, Inc. + * 901 San Antonio Road, Palo Alto, CA 94303, USA + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software Foundation. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, + * MA 02111-1307 USA + * + * + * Sun Industry Standards Source License Version 1.1 + * ================================================= + * The contents of this file are subject to the Sun Industry Standards + * Source License Version 1.1 (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.openoffice.org/license.html. + * + * Software provided under this License is provided on an "AS IS" basis, + * WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, + * WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS, + * MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING. + * See the License for the specific provisions governing your rights and + * obligations concerning the Software. + * + * The Initial Developer of the Original Code is: Sun Microsystems, Inc. + * + * Copyright: 2000 by Sun Microsystems, Inc. + * + * All Rights Reserved. + * + * Contributor(s): _______________________________________ + * + * + ************************************************************************/ +#include "acceptor.hxx" + +#include <stl/hash_set> + +#include <com/sun/star/connection/XConnectionBroadcaster.hpp> +#include <com/sun/star/connection/ConnectionSetupException.hpp> + +#include <cppuhelper/implbase2.hxx> + +using namespace ::osl; +using namespace ::rtl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::io; +using namespace ::com::sun::star::connection; + + +namespace stoc_acceptor { + static void callStarted(Reference<XStreamListener> xStreamListener) + { + xStreamListener->started(); + } + + struct callError { + const Any & any; + + callError(const Any & any); + + void operator () (Reference<XStreamListener> xStreamListener); + }; + + callError::callError(const Any & any) + : any(any) + { + } + + void callError::operator () (Reference<XStreamListener> xStreamListener) + { + xStreamListener->error(any); + } + + static void callClosed(Reference<XStreamListener> xStreamListener) + { + xStreamListener->closed(); + } + + + template<class T> + struct ReferenceHash + { + size_t operator () (const ::com::sun::star::uno::Reference<T> & ref) const + { + return (size_t)ref.get(); + } + }; + + template<class T> + struct ReferenceEqual + { + sal_Bool operator () (const ::com::sun::star::uno::Reference<T> & op1, + const ::com::sun::star::uno::Reference<T> & op2) const + { + return op1.get() == op2.get(); + } + }; + + + class SocketConnection : public ::cppu::WeakImplHelper2< + ::com::sun::star::connection::XConnection, + ::com::sun::star::connection::XConnectionBroadcaster> + + { + public: + SocketConnection( const ::rtl::OUString & s , sal_uInt16 nPort , sal_Bool bIgnoreClose ); + + virtual sal_Int32 SAL_CALL read( ::com::sun::star::uno::Sequence< sal_Int8 >& aReadBytes, + sal_Int32 nBytesToRead ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL write( const ::com::sun::star::uno::Sequence< sal_Int8 >& aData ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL flush( ) throw( + ::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL close( ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException); + virtual ::rtl::OUString SAL_CALL getDescription( ) + throw(::com::sun::star::uno::RuntimeException); + + // XConnectionBroadcaster + virtual void SAL_CALL addStreamListener(const ::com::sun::star::uno::Reference< ::com::sun::star::io::XStreamListener>& aListener) + throw(::com::sun::star::uno::RuntimeException); + virtual void SAL_CALL removeStreamListener(const ::com::sun::star::uno::Reference< ::com::sun::star::io::XStreamListener>& aListener) + throw(::com::sun::star::uno::RuntimeException); + + public: + ::vos::OStreamSocket m_socket; + ::vos::OInetSocketAddr m_addr; + oslInterlockedCount m_nStatus; + ::rtl::OUString m_sDescription; + sal_Bool m_bIgnoreClose; + + ::osl::Mutex _mutex; + sal_Bool _firstRead; + ::std::hash_set< ::com::sun::star::uno::Reference< ::com::sun::star::io::XStreamListener>, + ReferenceHash< ::com::sun::star::io::XStreamListener>, + ReferenceEqual< ::com::sun::star::io::XStreamListener> > _listeners; + }; + + template<class T> + void notifyListeners(SocketConnection * pCon, T t) + { + ::osl::MutexGuard guard(pCon->_mutex); + ::std::for_each(pCon->_listeners.begin(), pCon->_listeners.end(), t); + } + + + SocketConnection::SocketConnection( const OUString &s, + sal_uInt16 nPort , + sal_Bool bIgnoreClose) : + m_nStatus( 0 ), + m_sDescription( OUString::createFromAscii( "socket:" ) ), + m_bIgnoreClose( bIgnoreClose ) + { + m_sDescription += s; + m_sDescription += OUString::createFromAscii( ":" ); + m_sDescription += OUString::valueOf( (sal_Int32) nPort , 10 ); + m_sDescription += OUString::createFromAscii( ":" ); + + // make it unique + m_sDescription += OUString::valueOf( (sal_Int64) (::vos::OObject * ) &m_socket , 10 ); + } + + sal_Int32 SocketConnection::read( Sequence < sal_Int8 > & aReadBytes , sal_Int32 nBytesToRead ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException) + { + if( ! m_nStatus ) + { + if(_firstRead) { + _firstRead = false; + + notifyListeners(this, callStarted); + } + + if( aReadBytes.getLength() != nBytesToRead ) + { + aReadBytes.realloc( nBytesToRead ); + } + + sal_Int32 i = 0; + i = m_socket.read( aReadBytes.getArray() , aReadBytes.getLength() ); + + if(i != nBytesToRead) + { + if(i < 0) // error? + { + OUString errMessage; + m_socket.getError(errMessage); + + OUString message(RTL_CONSTASCII_USTRINGPARAM("acc_socket.cxx:SocketConnection::read: error - ")); + message += errMessage; + + IOException ioException(message, Reference<XInterface>(static_cast<XConnection *>(this))); + + Any any; + any <<= ioException; + + notifyListeners(this, callError(any)); + + throw ioException; + } + else // connection closed! + { + notifyListeners(this, callClosed); + } + } + + return i; + } + else + { + OUString message(RTL_CONSTASCII_USTRINGPARAM("acc_socket.cxx:SocketConnection::read: error - connection already closed")); + + IOException ioException(message, Reference<XInterface>(static_cast<XConnection *>(this))); + + Any any; + any <<= ioException; + + notifyListeners(this, callError(any)); + + throw ioException; + } + } + + void SocketConnection::write( const Sequence < sal_Int8 > &seq ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException) + { + if( ! m_nStatus ) + { + if( m_socket.write( seq.getConstArray() , seq.getLength() ) != seq.getLength() ) + { + OUString errMessage; + m_socket.getError(errMessage); + + OUString message(RTL_CONSTASCII_USTRINGPARAM("acc_socket.cxx:SocketConnection::write: error - ")); + message += errMessage; + + IOException ioException(message, Reference<XInterface>(static_cast<XConnection *>(this))); + + Any any; + any <<= ioException; + + notifyListeners(this, callError(any)); + + throw ioException; + } + } + else + { + OUString message(RTL_CONSTASCII_USTRINGPARAM("acc_socket.cxx:SocketConnection::write: error - connection already closed")); + + IOException ioException(message, Reference<XInterface>(static_cast<XConnection *>(this))); + + Any any; + any <<= ioException; + + notifyListeners(this, callError(any)); + + throw ioException; + } + } + + void SocketConnection::flush( ) + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException) + { + + } + + void SocketConnection::close() + throw(::com::sun::star::io::IOException, + ::com::sun::star::uno::RuntimeException) + { + // enshure close is called only once + if( ! m_bIgnoreClose && 1 == osl_incrementInterlockedCount( (&m_nStatus) ) ) + { + m_socket.close(); + } + } + + OUString SocketConnection::getDescription() + throw( ::com::sun::star::uno::RuntimeException) + { + return m_sDescription; + } + + + // XConnectionBroadcaster + void SAL_CALL SocketConnection::addStreamListener(const Reference<XStreamListener> & aListener) throw(RuntimeException) + { + MutexGuard guard(_mutex); + + _listeners.insert(aListener); + } + + void SAL_CALL SocketConnection::removeStreamListener(const Reference<XStreamListener> & aListener) throw(RuntimeException) + { + MutexGuard guard(_mutex); + + _listeners.erase(aListener); + } + + SocketAcceptor::SocketAcceptor( const OUString &sSocketName , + sal_uInt16 nPort , + sal_Bool bIgnoreClose ) : + m_bClosed( sal_False ), + m_sSocketName( sSocketName ), + m_nPort( nPort ), + m_bIgnoreClose( bIgnoreClose ) + { + } + + + void SocketAcceptor::init() + { + m_addr.setPort( m_nPort ); +#ifdef ENABLEUNICODE + m_addr.setAddr( m_sSocketName.pData ); +#else + OString o = OUStringToOString( m_sSocketName , RTL_TEXTENCODING_ASCII_US ); + m_addr.setAddr( o.pData->buffer ); +#endif + m_socket.setReuseAddr(1); + + if(! m_socket.bind(m_addr) ) + { + throw ConnectionSetupException( + OUString(RTL_CONSTASCII_USTRINGPARAM("acc_socket.cxx:SocketAcceptor::init - error - couldn't bind")), + Reference<XInterface>()); + } + + if(! m_socket.listen() ) + { + throw ConnectionSetupException( + OUString(RTL_CONSTASCII_USTRINGPARAM("acc_socket.cxx:SocketAcceptor::init - error - can not listen")), + Reference<XInterface>()); + } + } + + Reference< XConnection > SocketAcceptor::accept( ) + { + + SocketConnection *pConn = new SocketConnection( m_sSocketName , m_nPort, m_bIgnoreClose ); + + if( m_socket.acceptConnection( pConn->m_socket, pConn->m_addr )!= osl_Socket_Ok ) + { + // stopAccepting was called + delete pConn; + return Reference < XConnection > (); + } + if( m_bClosed ) + { + delete pConn; + return Reference < XConnection > (); + } + + pConn->m_socket.setTcpNoDelay( 1 ); + + return Reference < XConnection > ( (XConnection * ) pConn ); + } + + void SocketAcceptor::stopAccepting() + { + m_bClosed = sal_True; + m_socket.close(); + } +} + + diff --git a/io/source/acceptor/acceptor.cxx b/io/source/acceptor/acceptor.cxx new file mode 100644 index 000000000..44d3f2deb --- /dev/null +++ b/io/source/acceptor/acceptor.cxx @@ -0,0 +1,410 @@ +/************************************************************************* + * + * $RCSfile: acceptor.cxx,v $ + * + * $Revision: 1.1.1.1 $ + * + * last change: $Author: hr $ $Date: 2000-09-18 17:24:17 $ + * + * The Contents of this file are made available subject to the terms of + * either of the following licenses + * + * - GNU Lesser General Public License Version 2.1 + * - Sun Industry Standards Source License Version 1.1 + * + * Sun Microsystems Inc., October, 2000 + * + * GNU Lesser General Public License Version 2.1 + * ============================================= + * Copyright 2000 by Sun Microsystems, Inc. + * 901 San Antonio Road, Palo Alto, CA 94303, USA + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software Foundation. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, + * MA 02111-1307 USA + * + * + * Sun Industry Standards Source License Version 1.1 + * ================================================= + * The contents of this file are subject to the Sun Industry Standards + * Source License Version 1.1 (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.openoffice.org/license.html. + * + * Software provided under this License is provided on an "AS IS" basis, + * WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, + * WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS, + * MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING. + * See the License for the specific provisions governing your rights and + * obligations concerning the Software. + * + * The Initial Developer of the Original Code is: Sun Microsystems, Inc. + * + * Copyright: 2000 by Sun Microsystems, Inc. + * + * All Rights Reserved. + * + * Contributor(s): _______________________________________ + * + * + ************************************************************************/ +#include <osl/mutex.hxx> + +#include <uno/mapping.hxx> + +#include <cppuhelper/factory.hxx> +#include <cppuhelper/implbase1.hxx> + +#include <com/sun/star/connection/XAcceptor.hpp> + +#include "acceptor.hxx" + +#define IMPLEMENTATION_NAME "com.sun.star.comp.io.Acceptor" +#define SERVICE_NAME "com.sun.star.connection.Acceptor" + +using namespace ::osl; +using namespace ::rtl; +using namespace ::cppu; +using namespace ::com::sun::star::uno; +using namespace ::com::sun::star::lang; +using namespace ::com::sun::star::registry; +using namespace ::com::sun::star::connection; + + +namespace stoc_acceptor +{ + typedef WeakImplHelper1< XAcceptor > MyImplHelper; + + class OAcceptor : public MyImplHelper + { + public: + OAcceptor(Reference< XMultiServiceFactory > xMultiServiceFactory); + ~OAcceptor(); + + public: + // Methods + virtual Reference< XConnection > SAL_CALL accept( const OUString& sConnectionDescription ) + throw( AlreadyAcceptingException, + ConnectionSetupException, + IllegalArgumentException, + RuntimeException); + virtual void SAL_CALL stopAccepting( ) throw( RuntimeException); + + PipeAcceptor *m_pPipe; + SocketAcceptor *m_pSocket; + Mutex m_mutex; + OUString m_sLastDescription; + + Reference<XMultiServiceFactory> _xMultiServiceFactory; + Reference<XAcceptor> _xAcceptor; + }; + + + OAcceptor::OAcceptor(Reference< XMultiServiceFactory > xMultiServiceFactory) : + m_pPipe( 0 ), + m_pSocket( 0 ), + _xMultiServiceFactory(xMultiServiceFactory) + {} + + OAcceptor::~OAcceptor() + { + if( m_pPipe ) + { + delete m_pPipe; + } + if( m_pSocket ) + { + delete m_pSocket; + } + } + + Reference< XConnection > OAcceptor::accept( const OUString &sConnectionDescription ) + throw( AlreadyAcceptingException, + ConnectionSetupException, + IllegalArgumentException, + RuntimeException) + { +#ifdef DEBUG + OString tmp = OUStringToOString(sConnectionDescription, RTL_TEXTENCODING_ASCII_US); + OSL_TRACE("acceptor %s\n", tmp.getStr()); +#endif + + Reference< XConnection > r; + if( m_sLastDescription.getLength() && + m_sLastDescription != sConnectionDescription ) + { + // instantiate another acceptor for different ports + throw ConnectionSetupException(); + } + + if( ! m_sLastDescription.getLength() ) + { + // setup the acceptor + + OUString aTokens[10]; + + // split into separate tokens + sal_Int32 i = 0,nIndex = 0; +// OUString sConnectionId = OUStringToOString( sConnectionDescription , RTL_TEXTENCODING_ASCII_US ); + + for(i=0; i < 10 ; i ++ ) + { + sal_Int32 nLastIndex = nIndex; + nIndex = sConnectionDescription.indexOf( ( sal_Unicode ) ',' , nIndex ); + if( -1 == nIndex ) + { + aTokens[i] = sConnectionDescription.copy( nLastIndex ); + break; + } + else + { + aTokens[i] = sConnectionDescription.copy( nLastIndex , nIndex-nLastIndex ); + } + aTokens[i] = aTokens[i].trim(); + nIndex ++; + } + + if( aTokens[0] == OUString( RTL_CONSTASCII_USTRINGPARAM("pipe") ) ) + { + OUString sName; + sal_Bool bIgnoreFirstClose = sal_False;; + + for( i = 1 ; i < 10 ; i ++ ) + { + sal_Int32 nIndex = aTokens[i].indexOf( '=' ); + if( -1 != nIndex ) + { + OUString aName = aTokens[i].copy( 0 , nIndex ).trim().toLowerCase(); + if( nIndex < aTokens[i].getLength() ) + { + OUString oValue = aTokens[i].copy( nIndex+1 , aTokens[i].getLength() - nIndex -1 ).trim(); + if( aName == OUString( RTL_CONSTASCII_USTRINGPARAM("ignorefirstclose") ) ) + { + bIgnoreFirstClose = ( OUString( RTL_CONSTASCII_USTRINGPARAM("1")) == oValue ); + } + else if ( aName == OUString( RTL_CONSTASCII_USTRINGPARAM("name") ) ) + { + sName = oValue; + } + } + } + } + m_pPipe = new PipeAcceptor(sName , bIgnoreFirstClose ); + + try + { + m_pPipe->init(); + } + catch( ... ) + { + { + MutexGuard guard( m_mutex ); + delete m_pPipe; + m_pPipe = 0; + } + throw; + } + } + else if ( aTokens[0] == OUString( RTL_CONSTASCII_USTRINGPARAM("socket")) ) + { + OUString sHost = OUString( RTL_CONSTASCII_USTRINGPARAM("localhost")); + sal_uInt16 nPort; + sal_Bool bIgnoreFirstClose = sal_False;; + + for( i = 1 ; i < 10 ; i ++ ) + { + sal_Int32 nIndex = aTokens[i].indexOf( '=' ); + if( -1 != nIndex ) + { + OUString aName = aTokens[i].copy( 0 , nIndex ).trim().toLowerCase(); + if( nIndex < aTokens[i].getLength() ) + { + OUString oValue = aTokens[i].copy( nIndex+1 , aTokens[i].getLength() - nIndex -1 ).trim(); + if( aName == OUString( RTL_CONSTASCII_USTRINGPARAM("ignorefirstclose")) ) + { + bIgnoreFirstClose = ( OUString( RTL_CONSTASCII_USTRINGPARAM("1")) == oValue ); + } + else if( OUString( RTL_CONSTASCII_USTRINGPARAM("host")) == aName ) + { + sHost = oValue; + } + else if( OUString( RTL_CONSTASCII_USTRINGPARAM("port")) == aName ) + { + nPort = oValue.toInt32(); + } + } + } + } + + m_pSocket = new SocketAcceptor( sHost , nPort , bIgnoreFirstClose ); + + try + { + m_pSocket->init(); + } + catch( ... ) + { + { + MutexGuard guard( m_mutex ); + delete m_pSocket; + m_pSocket = 0; + } + throw; + } + } + else { + OUString delegatee = OUString(RTL_CONSTASCII_USTRINGPARAM("com.sun.star.connection.Acceptor.")); + delegatee += aTokens[0]; + +#ifdef DEBUG + OString tmp = OUStringToOString(delegatee, RTL_TEXTENCODING_ASCII_US); + OSL_TRACE("trying to get service %s\n", tmp.getStr()); +#endif + _xAcceptor = Reference<XAcceptor>(_xMultiServiceFactory->createInstance(delegatee), UNO_QUERY); + + if(!_xAcceptor.is()) + { + OUString message(RTL_CONSTASCII_USTRINGPARAM("Acceptor: unknown delegatee ")); + message += delegatee; + + throw ConnectionSetupException(message, Reference<XInterface>()); + } + } + m_sLastDescription = sConnectionDescription; + } + + if( m_pPipe ) + { + r = m_pPipe->accept(); + } + else if( m_pSocket ) + { + r = m_pSocket->accept(); + } + else + { + sal_Int32 index = sConnectionDescription.indexOf((sal_Unicode) ','); + + r = _xAcceptor->accept(m_sLastDescription.copy(index + 1).trim()); + } + + return r; + } + + void SAL_CALL OAcceptor::stopAccepting( ) throw( RuntimeException) + { + MutexGuard guard( m_mutex ); + + if( m_pPipe ) + { + m_pPipe->stopAccepting(); + } + else if ( m_pSocket ) + { + m_pSocket->stopAccepting(); + } + else + { + _xAcceptor->stopAccepting(); + } + + } + + + Reference< XInterface > SAL_CALL acceptor_CreateInstance( const Reference< XMultiServiceFactory > & xMultiServiceFactory) + { + return Reference < XInterface >( ( OWeakObject * ) new OAcceptor(xMultiServiceFactory) ); + } + + Sequence< OUString > acceptor_getSupportedServiceNames() + { + static Sequence < OUString > *pNames = 0; + if( ! pNames ) + { + MutexGuard guard( Mutex::getGlobalMutex() ); + if( !pNames ) + { + static Sequence< OUString > seqNames(1); + seqNames.getArray()[0] = OUString::createFromAscii( SERVICE_NAME ); + pNames = &seqNames; + } + } + return *pNames; + } + +} + +using namespace stoc_acceptor; + + + +extern "C" +{ +//================================================================================================== +void SAL_CALL component_getImplementationEnvironment( + const sal_Char ** ppEnvTypeName, uno_Environment ** ppEnv ) +{ + *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME; +} +//================================================================================================== +sal_Bool SAL_CALL component_writeInfo( + void * pServiceManager, void * pRegistryKey ) +{ + if (pRegistryKey) + { + try + { + Reference< XRegistryKey > xNewKey( + reinterpret_cast< XRegistryKey * >( pRegistryKey )->createKey( + OUString::createFromAscii("/" IMPLEMENTATION_NAME "/UNO/SERVICES" ) ) ); + + const Sequence< OUString > & rSNL = acceptor_getSupportedServiceNames(); + const OUString * pArray = rSNL.getConstArray(); + for ( sal_Int32 nPos = rSNL.getLength(); nPos--; ) + xNewKey->createKey( pArray[nPos] ); + + return sal_True; + } + catch (InvalidRegistryException &) + { + OSL_ENSHURE( sal_False, "### InvalidRegistryException!" ); + } + } + return sal_False; +} +//================================================================================================== +void * SAL_CALL component_getFactory( + const sal_Char * pImplName, void * pServiceManager, void * pRegistryKey ) +{ + void * pRet = 0; + + if (pServiceManager && rtl_str_compare( pImplName, IMPLEMENTATION_NAME ) == 0) + { + Reference< XSingleServiceFactory > xFactory( createSingleFactory( + reinterpret_cast< XMultiServiceFactory * >( pServiceManager ), + OUString::createFromAscii( pImplName ), + acceptor_CreateInstance, acceptor_getSupportedServiceNames() ) ); + + if (xFactory.is()) + { + xFactory->acquire(); + pRet = xFactory.get(); + } + } + + return pRet; +} +} + + + diff --git a/io/source/acceptor/acceptor.hxx b/io/source/acceptor/acceptor.hxx new file mode 100644 index 000000000..017017100 --- /dev/null +++ b/io/source/acceptor/acceptor.hxx @@ -0,0 +1,106 @@ +/************************************************************************* + * + * $RCSfile: acceptor.hxx,v $ + * + * $Revision: 1.1.1.1 $ + * + * last change: $Author: hr $ $Date: 2000-09-18 17:24:18 $ + * + * The Contents of this file are made available subject to the terms of + * either of the following licenses + * + * - GNU Lesser General Public License Version 2.1 + * - Sun Industry Standards Source License Version 1.1 + * + * Sun Microsystems Inc., October, 2000 + * + * GNU Lesser General Public License Version 2.1 + * ============================================= + * Copyright 2000 by Sun Microsystems, Inc. + * 901 San Antonio Road, Palo Alto, CA 94303, USA + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software Foundation. + * + * This library is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, + * MA 02111-1307 USA + * + * + * Sun Industry Standards Source License Version 1.1 + * ================================================= + * The contents of this file are subject to the Sun Industry Standards + * Source License Version 1.1 (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.openoffice.org/license.html. + * + * Software provided under this License is provided on an "AS IS" basis, + * WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, + * WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS, + * MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING. + * See the License for the specific provisions governing your rights and + * obligations concerning the Software. + * + * The Initial Developer of the Original Code is: Sun Microsystems, Inc. + * + * Copyright: 2000 by Sun Microsystems, Inc. + * + * All Rights Reserved. + * + * Contributor(s): _______________________________________ + * + * + ************************************************************************/ + +#include <vos/pipe.hxx> +#include <vos/socket.hxx> + +#include <com/sun/star/connection/XConnection.hpp> + +namespace stoc_acceptor { + + class PipeAcceptor + { + public: + PipeAcceptor( const ::rtl::OUString &sPipeName , sal_Bool bIgnoreClose ); + + void init(); + ::com::sun::star::uno::Reference < ::com::sun::star::connection::XConnection > + accept( ); + + void stopAccepting(); + + ::vos::OPipe m_pipe; + ::rtl::OUString m_sPipeName; + sal_Bool m_bClosed; + sal_Bool m_bIgnoreClose; + }; + + class SocketAcceptor + { + public: + SocketAcceptor( const ::rtl::OUString & sSocketName , sal_uInt16 nPort, sal_Bool bIgnoreClose ); + + void init(); + ::com::sun::star::uno::Reference < ::com::sun::star::connection::XConnection > + accept(); + + void stopAccepting(); + + ::vos::OInetSocketAddr m_addr; + ::vos::OAcceptorSocket m_socket; + ::rtl::OUString m_sSocketName; + sal_uInt16 m_nPort; + sal_Bool m_bClosed; + sal_Bool m_bIgnoreClose; + }; + +}; + diff --git a/io/source/acceptor/acceptor.xml b/io/source/acceptor/acceptor.xml new file mode 100644 index 000000000..340bed0ae --- /dev/null +++ b/io/source/acceptor/acceptor.xml @@ -0,0 +1,56 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!DOCTYPE COMPONENTDESCRIPTION PUBLIC "-//StarOffice//DTD ComponentDescription 1.0//EN" "componentdescription.dtd"> + +<COMPONENTDESCRIPTION + xmlns:xlink="http://www.w3.org/1999/xlink/Namespace" > + +<Author> Joerg Budischewski </Author> + +<Name> com.sun.star.comp.io.Acceptor </Name> + +<Description> + This component allows + to accept an connect-attempt from a different process. +</Description> + +<ModuleName> acceptor </ModuleName> + +<LoaderName> com.sun.star.loader.SharedLibrary </LoaderName> + +<Language> c++ </Language> + +<Status StatusValue="final"/> + +<SupportedService> com.sun.star.io.Acceptor </SupportedService> + +<ServiceDependency> ... </ServiceDependency> + +<ProjectBuildDependency> cppuhelper </ProjectBuildDependency> +<ProjectBuildDependency> cppu </ProjectBuildDependency> +<ProjectBuildDependency> vos </ProjectBuildDependency> +<ProjectBuildDependency> sal </ProjectBuildDependency> + +<RuntimeModuleDependency> cppuhelper </RuntimeModuleDependency> +<RuntimeModuleDependency> cppu2 </RuntimeModuleDependency> +<RuntimeModuleDependency> vos2MSC </RuntimeModuleDependency> +<RuntimeModuleDependency> sal2 </RuntimeModuleDependency> + +<Type> com.sun.star.connection.XAcceptor </Type> +<Type> com.sun.star.connection.XConnectionBroadcaster </Type> +<Type> com.sun.star.io.UnexpectedEOFException </Type> +<Type> com.sun.star.io.WrongFormatException </Type> +<Type> com.sun.star.lang.XComponent </Type> +<Type> com.sun.star.lang.XMultiServiceFactory </Type> +<Type> com.sun.star.lang.XSingleServiceFactory </Type> +<Type> com.sun.star.lang.XServiceInfo </Type> +<Type> com.sun.star.lang.XTypeProvider </Type> +<Type> com.sun.star.lang.IllegalArgumentException </Type> +<Type> com.sun.star.registry.XRegistryKey </Type> +<Type> com.sun.star.registry.XImplementationRegistration </Type> +<Type> com.sun.star.test.XSimpleTest </Type> +<Type> com.sun.star.uno.TypeClass </Type> +<Type> com.sun.star.uno.XWeak </Type> +<Type> com.sun.star.uno.XAggregation </Type> + +</COMPONENTDESCRIPTION> + diff --git a/io/source/acceptor/makefile.mk b/io/source/acceptor/makefile.mk new file mode 100644 index 000000000..b8b9871d2 --- /dev/null +++ b/io/source/acceptor/makefile.mk @@ -0,0 +1,109 @@ +#************************************************************************* +# +# $RCSfile: makefile.mk,v $ +# +# $Revision: 1.1.1.1 $ +# +# last change: $Author: hr $ $Date: 2000-09-18 17:24:18 $ +# +# The Contents of this file are made available subject to the terms of +# either of the following licenses +# +# - GNU Lesser General Public License Version 2.1 +# - Sun Industry Standards Source License Version 1.1 +# +# Sun Microsystems Inc., October, 2000 +# +# GNU Lesser General Public License Version 2.1 +# ============================================= +# Copyright 2000 by Sun Microsystems, Inc. +# 901 San Antonio Road, Palo Alto, CA 94303, USA +# +# This library is free software; you can redistribute it and/or +# modify it under the terms of the GNU Lesser General Public +# License version 2.1, as published by the Free Software Foundation. +# +# This library is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +# Lesser General Public License for more details. +# +# You should have received a copy of the GNU Lesser General Public +# License along with this library; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place, Suite 330, Boston, +# MA 02111-1307 USA +# +# +# Sun Industry Standards Source License Version 1.1 +# ================================================= +# The contents of this file are subject to the Sun Industry Standards +# Source License Version 1.1 (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.openoffice.org/license.html. +# +# Software provided under this License is provided on an "AS IS" basis, +# WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, +# WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS, +# MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING. +# See the License for the specific provisions governing your rights and +# obligations concerning the Software. +# +# The Initial Developer of the Original Code is: Sun Microsystems, Inc. +# +# Copyright: 2000 by Sun Microsystems, Inc. +# +# All Rights Reserved. +# +# Contributor(s): _______________________________________ +# +# +# +#************************************************************************* + +PRJ=..$/.. + +PRJNAME=io +TARGET=acceptor +ENABLE_EXCEPTIONS=TRUE +NO_BSYMBOLIC=TRUE +COMP1TYPELIST=$(TARGET) +COMPRDB=$(SOLARBINDIR)$/applicat.rdb + +# --- Settings ----------------------------------------------------- +.INCLUDE : svpre.mk +.INCLUDE : settings.mk +.INCLUDE : sv.mk +# ------------------------------------------------------------------ + +UNOUCRDEP=$(SOLARBINDIR)$/applicat.rdb +UNOUCRRDB=$(SOLARBINDIR)$/applicat.rdb +UNOUCROUT=$(OUT)$/inc$/acceptor +INCPRE+= $(UNOUCROUT) + +UNOTYPES=$($(TARGET)_XML2CMPTYPES) + +SLOFILES= \ + $(SLO)$/acceptor.obj \ + $(SLO)$/acc_pipe.obj \ + $(SLO)$/acc_socket.obj \ + $(SLO)$/$(COMP1TYPELIST)_description.obj + + +SHL1TARGET= $(TARGET) + +SHL1STDLIBS= \ + $(SALLIB) \ + $(VOSLIB) \ + $(CPPULIB) \ + $(CPPUHELPERLIB) + +SHL1DEPN= +SHL1IMPLIB= i$(TARGET) +SHL1LIBS= $(SLB)$/$(TARGET).lib +SHL1DEF= $(MISC)$/$(SHL1TARGET).def + +DEF1NAME= $(SHL1TARGET) +DEF1EXPORTFILE= exports.dxp + +# --- Targets ------------------------------------------------------ +.INCLUDE : target.mk |