diff options
Diffstat (limited to 'io/source/acceptor/acc_pipe.cxx')
| -rw-r--r-- | io/source/acceptor/acc_pipe.cxx | 226 |
1 files changed, 226 insertions, 0 deletions
diff --git a/io/source/acceptor/acc_pipe.cxx b/io/source/acceptor/acc_pipe.cxx new file mode 100644 index 000000000000..91165b1e4879 --- /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(); + } +} |