office-gobmx/io/source/TextOutputStream/TextOutputStream.cxx
Oliver Bolte 1692acefd5 INTEGRATION: CWS pchfix02 (1.9.8); FILE MERGED
2006/09/01 17:31:22 kaib 1.9.8.1: #i68856# Added header markers and pch files
2006-09-16 22:41:54 +00:00

343 lines
11 KiB
C++

/*************************************************************************
*
* OpenOffice.org - a multi-platform office productivity suite
*
* $RCSfile: TextOutputStream.cxx,v $
*
* $Revision: 1.10 $
*
* last change: $Author: obo $ $Date: 2006-09-16 23:41:54 $
*
* The Contents of this file are made available subject to
* the terms of GNU Lesser General Public License Version 2.1.
*
*
* GNU Lesser General Public License Version 2.1
* =============================================
* Copyright 2005 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
*
************************************************************************/
// MARKER(update_precomp.py): autogen include statement, do not remove
#include "precompiled_io.hxx"
#include <osl/mutex.hxx>
#include <osl/diagnose.h>
#include <uno/mapping.hxx>
#include <cppuhelper/factory.hxx>
#include <cppuhelper/implbase3.hxx>
#include <cppuhelper/implementationentry.hxx>
#include <rtl/textenc.h>
#include <rtl/tencinfo.h>
#include <rtl/unload.h>
#include <com/sun/star/io/XTextOutputStream.hpp>
#include <com/sun/star/io/XActiveDataSource.hpp>
#include <com/sun/star/lang/XServiceInfo.hpp>
#define IMPLEMENTATION_NAME "com.sun.star.comp.io.TextOutputStream"
#define SERVICE_NAME "com.sun.star.io.TextOutputStream"
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::io;
using namespace ::com::sun::star::registry;
namespace io_TextOutputStream
{
rtl_StandardModuleCount g_moduleCount = MODULE_COUNT_INIT;
//===========================================================================
// Implementation XTextOutputStream
typedef WeakImplHelper3< XTextOutputStream, XActiveDataSource, XServiceInfo > TextOutputStreamHelper;
class OCommandEnvironment;
class OTextOutputStream : public TextOutputStreamHelper
{
Reference< XOutputStream > mxStream;
// Encoding
OUString mEncoding;
sal_Bool mbEncodingInitialized;
rtl_UnicodeToTextConverter mConvUnicode2Text;
rtl_UnicodeToTextContext mContextUnicode2Text;
Sequence<sal_Int8> implConvert( const OUString& rSource );
public:
OTextOutputStream();
~OTextOutputStream();
// Methods XTextOutputStream
virtual void SAL_CALL writeString( const OUString& aString )
throw(IOException, RuntimeException);
virtual void SAL_CALL setEncoding( const OUString& Encoding )
throw(RuntimeException);
// Methods XOutputStream
virtual void SAL_CALL writeBytes( const Sequence< sal_Int8 >& aData )
throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
virtual void SAL_CALL flush( )
throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
virtual void SAL_CALL closeOutput( )
throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException);
// Methods XActiveDataSource
virtual void SAL_CALL setOutputStream( const Reference< XOutputStream >& aStream )
throw(RuntimeException);
virtual Reference< XOutputStream > SAL_CALL getOutputStream( )
throw(RuntimeException);
// Methods XServiceInfo
virtual OUString SAL_CALL getImplementationName() throw();
virtual Sequence< OUString > SAL_CALL getSupportedServiceNames(void) throw();
virtual sal_Bool SAL_CALL supportsService(const OUString& ServiceName) throw();
};
OTextOutputStream::OTextOutputStream()
{
mbEncodingInitialized = false;
}
OTextOutputStream::~OTextOutputStream()
{
if( mbEncodingInitialized )
{
rtl_destroyUnicodeToTextContext( mConvUnicode2Text, mContextUnicode2Text );
rtl_destroyUnicodeToTextConverter( mConvUnicode2Text );
}
}
Sequence<sal_Int8> OTextOutputStream::implConvert( const OUString& rSource )
{
const sal_Unicode *puSource = rSource.getStr();
sal_Int32 nSourceSize = rSource.getLength();
sal_Size nTargetCount = 0;
sal_Size nSourceCount = 0;
sal_uInt32 uiInfo;
sal_Size nSrcCvtChars;
// take nSourceSize * 3 as preference
// this is an upper boundary for converting to utf8,
// which most often used as the target.
sal_Int32 nSeqSize = nSourceSize * 3;
Sequence<sal_Int8> seqText( nSeqSize );
sal_Char *pTarget = (sal_Char *) seqText.getArray();
while( sal_True )
{
nTargetCount += rtl_convertUnicodeToText(
mConvUnicode2Text,
mContextUnicode2Text,
&( puSource[nSourceCount] ),
nSourceSize - nSourceCount ,
&( pTarget[nTargetCount] ),
nSeqSize - nTargetCount,
RTL_UNICODETOTEXT_FLAGS_UNDEFINED_DEFAULT |
RTL_UNICODETOTEXT_FLAGS_INVALID_DEFAULT ,
&uiInfo,
&nSrcCvtChars);
nSourceCount += nSrcCvtChars;
if( uiInfo & RTL_UNICODETOTEXT_INFO_DESTBUFFERTOSMALL )
{
nSeqSize *= 2;
seqText.realloc( nSeqSize ); // double array size
pTarget = (sal_Char*) seqText.getArray();
continue;
}
break;
}
// reduce the size of the buffer (fast, no copy necessary)
seqText.realloc( nTargetCount );
return seqText;
}
//===========================================================================
// XTextOutputStream
void OTextOutputStream::writeString( const OUString& aString )
throw(IOException, RuntimeException)
{
if( !mbEncodingInitialized )
{
OUString aUtf8Str( RTL_CONSTASCII_USTRINGPARAM("utf8") );
setEncoding( aUtf8Str );
}
if( !mbEncodingInitialized )
return;
Sequence<sal_Int8> aByteSeq = implConvert( aString );
mxStream->writeBytes( aByteSeq );
}
void OTextOutputStream::setEncoding( const OUString& Encoding )
throw(RuntimeException)
{
OString aOEncodingStr = OUStringToOString( Encoding, RTL_TEXTENCODING_ASCII_US );
rtl_TextEncoding encoding = rtl_getTextEncodingFromMimeCharset( aOEncodingStr.getStr() );
if( RTL_TEXTENCODING_DONTKNOW == encoding )
return;
mbEncodingInitialized = true;
mConvUnicode2Text = rtl_createUnicodeToTextConverter( encoding );
mContextUnicode2Text = rtl_createUnicodeToTextContext( mConvUnicode2Text );
mEncoding = Encoding;
}
//===========================================================================
// XOutputStream
void OTextOutputStream::writeBytes( const Sequence< sal_Int8 >& aData )
throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
{
mxStream->writeBytes( aData );
}
void OTextOutputStream::flush( )
throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
{
mxStream->flush();
}
void OTextOutputStream::closeOutput( )
throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
{
mxStream->closeOutput();
}
//===========================================================================
// XActiveDataSource
void OTextOutputStream::setOutputStream( const Reference< XOutputStream >& aStream )
throw(RuntimeException)
{
mxStream = aStream;
}
Reference< XOutputStream > OTextOutputStream::getOutputStream()
throw(RuntimeException)
{
return mxStream;
}
Reference< XInterface > SAL_CALL TextOutputStream_CreateInstance( const Reference< XComponentContext > &)
{
return Reference < XInterface >( ( OWeakObject * ) new OTextOutputStream() );
}
OUString TextOutputStream_getImplementationName() SAL_THROW( () )
{
return OUString( RTL_CONSTASCII_USTRINGPARAM( IMPLEMENTATION_NAME ) );
}
Sequence< OUString > TextOutputStream_getSupportedServiceNames()
{
static Sequence < OUString > *pNames = 0;
if( ! pNames )
{
MutexGuard guard( Mutex::getGlobalMutex() );
if( !pNames )
{
static Sequence< OUString > seqNames(1);
seqNames.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( SERVICE_NAME ) );
pNames = &seqNames;
}
}
return *pNames;
}
OUString OTextOutputStream::getImplementationName() throw()
{
return TextOutputStream_getImplementationName();
}
sal_Bool OTextOutputStream::supportsService(const OUString& ServiceName) throw()
{
Sequence< OUString > aSNL = getSupportedServiceNames();
const OUString * pArray = aSNL.getConstArray();
for( sal_Int32 i = 0; i < aSNL.getLength(); i++ )
if( pArray[i] == ServiceName )
return sal_True;
return sal_False;
}
Sequence< OUString > OTextOutputStream::getSupportedServiceNames(void) throw()
{
return TextOutputStream_getSupportedServiceNames();
}
}
using namespace io_TextOutputStream;
static struct ImplementationEntry g_entries[] =
{
{
TextOutputStream_CreateInstance, TextOutputStream_getImplementationName ,
TextOutputStream_getSupportedServiceNames, createSingleComponentFactory ,
&g_moduleCount.modCnt , 0
},
{ 0, 0, 0, 0, 0, 0 }
};
extern "C"
{
sal_Bool SAL_CALL component_canUnload( TimeValue *pTime )
{
return g_moduleCount.canUnload( &g_moduleCount , pTime );
}
//==================================================================================================
void SAL_CALL component_getImplementationEnvironment(
const sal_Char ** ppEnvTypeName, uno_Environment ** )
{
*ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME;
}
//==================================================================================================
sal_Bool SAL_CALL component_writeInfo(
void * pServiceManager, void * pRegistryKey )
{
return component_writeInfoHelper( pServiceManager, pRegistryKey, g_entries );
}
//==================================================================================================
void * SAL_CALL component_getFactory(
const sal_Char * pImplName, void * pServiceManager, void * pRegistryKey )
{
return component_getFactoryHelper( pImplName, pServiceManager, pRegistryKey , g_entries );
}
}