io/source/connector/ctr_pipe.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: ctr_pipe.cxx,v $
  10  * $Revision: 1.7 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_io.hxx"
  33
  34 #include "connector.hxx"
  35
  36 using namespace ::osl;
  37 using namespace ::rtl;
  38 using namespace ::com::sun::star::uno;
  39 using namespace ::com::sun::star::io;
  40 using namespace ::com::sun::star::connection;
  41
  42
  43 namespace stoc_connector {
  44
  45     PipeConnection::PipeConnection( const OUString & sConnectionDescription ) :
  46         m_nStatus( 0 ),
  47         m_sDescription( sConnectionDescription )
  48     {
  49         g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt );
  50         // make it unique
  51         m_sDescription += OUString::createFromAscii( ",uniqueValue=" );
  52         m_sDescription += OUString::valueOf(
  53             sal::static_int_cast< sal_Int64 >(
  54                 reinterpret_cast< sal_IntPtr >(&m_pipe)),
  55             10 );
  56     }
  57
  58     PipeConnection::~PipeConnection()
  59     {
  60         g_moduleCount.modCnt.release( &g_moduleCount.modCnt );
  61     }
  62
  63     sal_Int32 PipeConnection::read( Sequence < sal_Int8 > & aReadBytes , sal_Int32 nBytesToRead )
  64             throw(::com::sun::star::io::IOException,
  65                   ::com::sun::star::uno::RuntimeException)
  66     {
  67         if( ! m_nStatus )
  68         {
  69             if( aReadBytes.getLength() != nBytesToRead )
  70             {
  71                 aReadBytes.realloc( nBytesToRead );
  72             }
  73             return m_pipe.read( aReadBytes.getArray()  , aReadBytes.getLength() );
  74         }
  75         else {
  76             throw IOException();
  77         }
  78     }
  79
  80     void PipeConnection::write( const Sequence < sal_Int8 > &seq )
  81             throw(::com::sun::star::io::IOException,
  82                   ::com::sun::star::uno::RuntimeException)
  83     {
  84         if( ! m_nStatus )
  85         {
  86             if( m_pipe.write( seq.getConstArray() , seq.getLength() ) != seq.getLength() )
  87             {
  88                 throw IOException();
  89             }
  90         }
  91         else {
  92             throw IOException();
  93         }
  94     }
  95
  96     void PipeConnection::flush( )
  97             throw(::com::sun::star::io::IOException,
  98                   ::com::sun::star::uno::RuntimeException)
  99     {
 100
 101     }
 102
 103     void PipeConnection::close()
 104             throw(::com::sun::star::io::IOException,
 105                   ::com::sun::star::uno::RuntimeException)
 106     {
 107         // ensure that close is called only once
 108         if(1 == osl_incrementInterlockedCount( (&m_nStatus) ) )
 109         {
 110             m_pipe.close();
 111         }
 112     }
 113
 114     OUString PipeConnection::getDescription()
 115             throw( ::com::sun::star::uno::RuntimeException)
 116     {
 117         return m_sDescription;
 118     }
 119
 120 }
 121