comphelper/source/streaming/seqoutputstreamserv.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: seqoutputstreamserv.cxx,v $
  10  * $Revision: 1.3 $
  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 #include "precompiled_comphelper.hxx"
  32
  33 #include "comphelper_module.hxx"
  34
  35 #include <sal/config.h>
  36 #include <osl/mutex.hxx>
  37 #include <cppuhelper/factory.hxx>
  38 #include <cppuhelper/implementationentry.hxx>
  39 #include <cppuhelper/implbase2.hxx>
  40 #include <comphelper/seqstream.hxx>
  41 #include <com/sun/star/lang/XServiceInfo.hpp>
  42 #include <com/sun/star/io/XSequenceOutputStream.hpp>
  43 #include <com/sun/star/uno/XComponentContext.hpp>
  44
  45 using namespace ::com::sun::star;
  46
  47
  48 namespace {
  49
  50 class SequenceOutputStreamService:
  51 public ::cppu::WeakImplHelper2 < lang::XServiceInfo, io::XSequenceOutputStream >
  52 {
  53 public:
  54     explicit SequenceOutputStreamService();
  55
  56     // ::com::sun::star::lang::XServiceInfo:
  57     virtual ::rtl::OUString SAL_CALL getImplementationName() throw ( uno::RuntimeException );
  58     virtual ::sal_Bool SAL_CALL supportsService( const ::rtl::OUString & ServiceName ) throw ( uno::RuntimeException );
  59     virtual uno::Sequence< ::rtl::OUString > SAL_CALL getSupportedServiceNames() throw ( uno::RuntimeException );
  60
  61     // XServiceInfo - static versions (used for component registration)
  62     static ::rtl::OUString SAL_CALL getImplementationName_static();
  63     static uno::Sequence< ::rtl::OUString > SAL_CALL getSupportedServiceNames_static();
  64     static uno::Reference< uno::XInterface > SAL_CALL Create( const uno::Reference< uno::XComponentContext >& );
  65
  66     // ::com::sun::star::io::XOutputStream:
  67     virtual void SAL_CALL writeBytes( const uno::Sequence< ::sal_Int8 > & aData ) throw ( io::NotConnectedException, io::BufferSizeExceededException, io::IOException, uno::RuntimeException );
  68     virtual void SAL_CALL flush() throw ( uno::RuntimeException, io::NotConnectedException, io::BufferSizeExceededException, io::IOException );
  69     virtual void SAL_CALL closeOutput() throw ( uno::RuntimeException, io::NotConnectedException, io::BufferSizeExceededException, io::IOException );
  70
  71     // ::com::sun::star::io::XSequenceOutputStream:
  72     virtual uno::Sequence< ::sal_Int8 > SAL_CALL getWrittenBytes(  ) throw ( io::NotConnectedException, io::IOException, uno::RuntimeException);
  73
  74 private:
  75     SequenceOutputStreamService( SequenceOutputStreamService & ); //not defined
  76     void operator =( SequenceOutputStreamService & ); //not defined
  77
  78     virtual ~SequenceOutputStreamService() {};
  79
  80
  81     ::osl::Mutex m_aMutex;
  82     uno::Reference< io::XOutputStream > m_xOutputStream;
  83     uno::Sequence< ::sal_Int8 > m_aSequence;
  84 };
  85 SequenceOutputStreamService::SequenceOutputStreamService()
  86 {
  87     m_xOutputStream.set( static_cast < ::cppu::OWeakObject* >( new ::comphelper::OSequenceOutputStream( m_aSequence ) ), uno::UNO_QUERY_THROW );
  88 }
  89
  90 // com.sun.star.uno.XServiceInfo:
  91 ::rtl::OUString SAL_CALL SequenceOutputStreamService::getImplementationName() throw ( uno::RuntimeException )
  92 {
  93     return getImplementationName_static();
  94 }
  95
  96 ::rtl::OUString SAL_CALL SequenceOutputStreamService::getImplementationName_static()
  97 {
  98     return ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.comp.SequenceOutputStreamService" ) );
  99 }
 100
 101 ::sal_Bool SAL_CALL SequenceOutputStreamService::supportsService( ::rtl::OUString const & serviceName ) throw ( uno::RuntimeException )
 102 {
 103     uno::Sequence< ::rtl::OUString > serviceNames = getSupportedServiceNames();
 104     for ( ::sal_Int32 i = 0; i < serviceNames.getLength(); ++i ) {
 105         if ( serviceNames[i] == serviceName )
 106             return sal_True;
 107     }
 108     return sal_False;
 109 }
 110
 111 uno::Sequence< ::rtl::OUString > SAL_CALL SequenceOutputStreamService::getSupportedServiceNames() throw ( uno::RuntimeException )
 112 {
 113     return getSupportedServiceNames_static();
 114 }
 115
 116 uno::Sequence< ::rtl::OUString > SAL_CALL SequenceOutputStreamService::getSupportedServiceNames_static()
 117 {
 118     uno::Sequence< ::rtl::OUString > s( 1 );
 119     s[0] = ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "com.sun.star.io.SequenceOutputStream" ) );
 120     return s;
 121 }
 122
 123 uno::Reference< uno::XInterface > SAL_CALL SequenceOutputStreamService::Create(
 124     const uno::Reference< uno::XComponentContext >& )
 125 {
 126     return static_cast< ::cppu::OWeakObject * >( new SequenceOutputStreamService());
 127 }
 128
 129 // ::com::sun::star::io::XOutputStream:
 130 void SAL_CALL SequenceOutputStreamService::writeBytes( const uno::Sequence< ::sal_Int8 > & aData ) throw ( uno::RuntimeException, io::NotConnectedException, io::BufferSizeExceededException, io::IOException )
 131 {
 132     ::osl::MutexGuard aGuard( m_aMutex );
 133     if ( !m_xOutputStream.is() )
 134         throw io::NotConnectedException();
 135
 136     m_xOutputStream->writeBytes( aData );
 137     m_aSequence = aData;
 138 }
 139
 140 void SAL_CALL SequenceOutputStreamService::flush() throw ( uno::RuntimeException, io::NotConnectedException, io::BufferSizeExceededException, io::IOException )
 141 {
 142     ::osl::MutexGuard aGuard( m_aMutex );
 143     if ( !m_xOutputStream.is() )
 144         throw io::NotConnectedException();
 145
 146     m_xOutputStream->flush();
 147 };
 148
 149 void SAL_CALL SequenceOutputStreamService::closeOutput() throw ( uno::RuntimeException, io::NotConnectedException, io::BufferSizeExceededException, io::IOException )
 150 {
 151     ::osl::MutexGuard aGuard( m_aMutex );
 152     if ( !m_xOutputStream.is() )
 153         throw io::NotConnectedException();
 154
 155     m_xOutputStream->closeOutput();
 156     m_xOutputStream = uno::Reference< io::XOutputStream >();
 157 }
 158
 159 // ::com::sun::star::io::XSequenceOutputStream:
 160 uno::Sequence< ::sal_Int8 > SAL_CALL SequenceOutputStreamService::getWrittenBytes() throw ( io::NotConnectedException, io::IOException, uno::RuntimeException)
 161 {
 162     ::osl::MutexGuard aGuard( m_aMutex );
 163     if ( !m_xOutputStream.is() )
 164         throw io::NotConnectedException();
 165
 166     m_xOutputStream->flush();
 167     return m_aSequence;
 168 }
 169
 170 } // anonymous namespace
 171
 172 void createRegistryInfo_SequenceOutputStream()
 173 {
 174     static ::comphelper::module::OAutoRegistration< SequenceOutputStreamService > aAutoRegistration;
 175 }