diff options
Diffstat (limited to 'io/source/TextInputStream/TextInputStream.cxx')
| -rw-r--r-- | io/source/TextInputStream/TextInputStream.cxx | 518 |
1 files changed, 0 insertions, 518 deletions
diff --git a/io/source/TextInputStream/TextInputStream.cxx b/io/source/TextInputStream/TextInputStream.cxx deleted file mode 100644 index c157bc171..000000000 --- a/io/source/TextInputStream/TextInputStream.cxx +++ /dev/null @@ -1,518 +0,0 @@ -/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ -/************************************************************************* - * - * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. - * - * Copyright 2000, 2010 Oracle and/or its affiliates. - * - * OpenOffice.org - a multi-platform office productivity suite - * - * This file is part of OpenOffice.org. - * - * OpenOffice.org is free software: you can redistribute it and/or modify - * it under the terms of the GNU Lesser General Public License version 3 - * only, as published by the Free Software Foundation. - * - * OpenOffice.org 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 version 3 for more details - * (a copy is included in the LICENSE file that accompanied this code). - * - * You should have received a copy of the GNU Lesser General Public License - * version 3 along with OpenOffice.org. If not, see - * <http://www.openoffice.org/license.html> - * for a copy of the LGPLv3 License. - * - ************************************************************************/ - -// MARKER(update_precomp.py): autogen include statement, do not remove -#include "precompiled_io.hxx" - - -#include <string.h> -#include <osl/mutex.hxx> -#include <osl/diagnose.h> - -#include <rtl/unload.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 <com/sun/star/io/XTextInputStream.hpp> -#include <com/sun/star/io/XActiveDataSink.hpp> -#include <com/sun/star/lang/XServiceInfo.hpp> - - -#define IMPLEMENTATION_NAME "com.sun.star.comp.io.TextInputStream" -#define SERVICE_NAME "com.sun.star.io.TextInputStream" - -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_TextInputStream -{ - rtl_StandardModuleCount g_moduleCount = MODULE_COUNT_INIT; - -//=========================================================================== -// Implementation XTextInputStream - -typedef WeakImplHelper3< XTextInputStream, XActiveDataSink, XServiceInfo > TextInputStreamHelper; -class OCommandEnvironment; - -#define INITIAL_UNICODE_BUFFER_CAPACITY 0x100 -#define READ_BYTE_COUNT 0x100 - -class OTextInputStream : public TextInputStreamHelper -{ - Reference< XInputStream > mxStream; - - // Encoding - OUString mEncoding; - sal_Bool mbEncodingInitialized; - rtl_TextToUnicodeConverter mConvText2Unicode; - rtl_TextToUnicodeContext mContextText2Unicode; - Sequence<sal_Int8> mSeqSource; - - // Internal buffer for characters that are already converted successfully - sal_Unicode* mpBuffer; - sal_Int32 mnBufferSize; - sal_Int32 mnCharsInBuffer; - sal_Bool mbReachedEOF; - - void implResizeBuffer( void ); - OUString implReadString( const Sequence< sal_Unicode >& Delimiters, - sal_Bool bRemoveDelimiter, sal_Bool bFindLineEnd ) - throw(IOException, RuntimeException); - sal_Int32 implReadNext() throw(IOException, RuntimeException); - -public: - OTextInputStream(); - virtual ~OTextInputStream(); - - // Methods XTextInputStream - virtual OUString SAL_CALL readLine( ) - throw(IOException, RuntimeException); - virtual OUString SAL_CALL readString( const Sequence< sal_Unicode >& Delimiters, sal_Bool bRemoveDelimiter ) - throw(IOException, RuntimeException); - virtual sal_Bool SAL_CALL isEOF( ) - throw(IOException, RuntimeException); - virtual void SAL_CALL setEncoding( const OUString& Encoding ) throw(RuntimeException); - - // Methods XInputStream - virtual sal_Int32 SAL_CALL readBytes( Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) - throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException); - virtual sal_Int32 SAL_CALL readSomeBytes( Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) - throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException); - virtual void SAL_CALL skipBytes( sal_Int32 nBytesToSkip ) - throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException); - virtual sal_Int32 SAL_CALL available( ) - throw(NotConnectedException, IOException, RuntimeException); - virtual void SAL_CALL closeInput( ) - throw(NotConnectedException, IOException, RuntimeException); - - // Methods XActiveDataSink - virtual void SAL_CALL setInputStream( const Reference< XInputStream >& aStream ) - throw(RuntimeException); - virtual Reference< XInputStream > SAL_CALL getInputStream() - 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(); -}; - -OTextInputStream::OTextInputStream() - : mSeqSource( READ_BYTE_COUNT ), mpBuffer( NULL ), mnBufferSize( 0 ) - , mnCharsInBuffer( 0 ), mbReachedEOF( sal_False ) -{ - g_moduleCount.modCnt.acquire( &g_moduleCount.modCnt ); - mbEncodingInitialized = false; -} - -OTextInputStream::~OTextInputStream() -{ - if( mbEncodingInitialized ) - { - rtl_destroyUnicodeToTextContext( mConvText2Unicode, mContextText2Unicode ); - rtl_destroyUnicodeToTextConverter( mConvText2Unicode ); - } - g_moduleCount.modCnt.release( &g_moduleCount.modCnt ); -} - -void OTextInputStream::implResizeBuffer( void ) -{ - sal_Int32 mnNewBufferSize = mnBufferSize * 2; - sal_Unicode* pNewBuffer = new sal_Unicode[ mnNewBufferSize ]; - memcpy( pNewBuffer, mpBuffer, mnCharsInBuffer * sizeof( sal_Unicode ) ); - mpBuffer = pNewBuffer; - mnBufferSize = mnNewBufferSize; -} - - -//=========================================================================== -// XTextInputStream - -OUString OTextInputStream::readLine( ) - throw(IOException, RuntimeException) -{ - static Sequence< sal_Unicode > aDummySeq; - return implReadString( aDummySeq, sal_True, sal_True ); -} - -OUString OTextInputStream::readString( const Sequence< sal_Unicode >& Delimiters, sal_Bool bRemoveDelimiter ) - throw(IOException, RuntimeException) -{ - return implReadString( Delimiters, bRemoveDelimiter, sal_False ); -} - -sal_Bool OTextInputStream::isEOF() - throw(IOException, RuntimeException) -{ - sal_Bool bRet = sal_False; - if( mnCharsInBuffer == 0 && mbReachedEOF ) - bRet = sal_True; - return bRet; -} - - -OUString OTextInputStream::implReadString( const Sequence< sal_Unicode >& Delimiters, - sal_Bool bRemoveDelimiter, sal_Bool bFindLineEnd ) - throw(IOException, RuntimeException) -{ - OUString aRetStr; - if( !mbEncodingInitialized ) - { - OUString aUtf8Str( RTL_CONSTASCII_USTRINGPARAM("utf8") ); - setEncoding( aUtf8Str ); - } - if( !mbEncodingInitialized ) - return aRetStr; - - if( !mpBuffer ) - { - mnBufferSize = INITIAL_UNICODE_BUFFER_CAPACITY; - mpBuffer = new sal_Unicode[ mnBufferSize ]; - } - - // Only for bFindLineEnd - sal_Unicode cLineEndChar1 = 0x0D; - sal_Unicode cLineEndChar2 = 0x0A; - - sal_Int32 nBufferReadPos = 0; - sal_Int32 nCopyLen = 0; - sal_Bool bFound = sal_False; - sal_Bool bFoundFirstLineEndChar = sal_False; - sal_Unicode cFirstLineEndChar = 0; - const sal_Unicode* pDelims = Delimiters.getConstArray(); - const sal_Int32 nDelimCount = Delimiters.getLength(); - while( !bFound ) - { - // Still characters available? - if( nBufferReadPos == mnCharsInBuffer ) - { - // Already reached EOF? Then we can't read any more - if( mbReachedEOF ) - break; - - // No, so read new characters - if( !implReadNext() ) - break; - } - - // Now there should be characters available - // (otherwise the loop should have been breaked before) - sal_Unicode c = mpBuffer[ nBufferReadPos++ ]; - - if( bFindLineEnd ) - { - if( bFoundFirstLineEndChar ) - { - bFound = sal_True; - nCopyLen = nBufferReadPos - 2; - if( c == cLineEndChar1 || c == cLineEndChar2 ) - { - // Same line end char -> new line break - if( c == cFirstLineEndChar ) - { - nBufferReadPos--; - } - } - else - { - // No second line end char - nBufferReadPos--; - } - } - else if( c == cLineEndChar1 || c == cLineEndChar2 ) - { - bFoundFirstLineEndChar = sal_True; - cFirstLineEndChar = c; - } - } - else - { - for( sal_Int32 i = 0 ; i < nDelimCount ; i++ ) - { - if( c == pDelims[ i ] ) - { - bFound = sal_True; - nCopyLen = nBufferReadPos; - if( bRemoveDelimiter ) - nCopyLen--; - } - } - } - } - - // Nothing found? Return all - if( !nCopyLen && !bFound && mbReachedEOF ) - nCopyLen = nBufferReadPos; - - // Create string - if( nCopyLen ) - aRetStr = OUString( mpBuffer, nCopyLen ); - - // Copy rest of buffer - memmove( mpBuffer, mpBuffer + nBufferReadPos, - (mnCharsInBuffer - nBufferReadPos) * sizeof( sal_Unicode ) ); - mnCharsInBuffer -= nBufferReadPos; - - return aRetStr; -} - - -sal_Int32 OTextInputStream::implReadNext() - throw(IOException, RuntimeException) -{ - sal_Int32 nFreeBufferSize = mnBufferSize - mnCharsInBuffer; - if( nFreeBufferSize < READ_BYTE_COUNT ) - implResizeBuffer(); - nFreeBufferSize = mnBufferSize - mnCharsInBuffer; - - try - { - sal_Int32 nBytesToRead = READ_BYTE_COUNT; - sal_Int32 nRead = mxStream->readSomeBytes( mSeqSource, nBytesToRead ); - sal_Int32 nTotalRead = nRead; - if( nRead < nBytesToRead ) - mbReachedEOF = sal_True; - - // Try to convert - sal_uInt32 uiInfo; - sal_Size nSrcCvtBytes = 0; - sal_Size nTargetCount = 0; - sal_Size nSourceCount = 0; - while( sal_True ) - { - const sal_Int8 *pbSource = mSeqSource.getConstArray(); - - // All invalid characters are transformed to the unicode undefined char - nTargetCount += rtl_convertTextToUnicode( - mConvText2Unicode, - mContextText2Unicode, - (const sal_Char*) &( pbSource[nSourceCount] ), - nTotalRead - nSourceCount, - mpBuffer + mnCharsInBuffer + nTargetCount, - nFreeBufferSize - nTargetCount, - RTL_TEXTTOUNICODE_FLAGS_UNDEFINED_DEFAULT | - RTL_TEXTTOUNICODE_FLAGS_MBUNDEFINED_DEFAULT | - RTL_TEXTTOUNICODE_FLAGS_INVALID_DEFAULT, - &uiInfo, - &nSrcCvtBytes ); - nSourceCount += nSrcCvtBytes; - - sal_Bool bCont = sal_False; - if( uiInfo & RTL_TEXTTOUNICODE_INFO_DESTBUFFERTOSMALL ) - { - implResizeBuffer(); - bCont = sal_True; - } - - if( uiInfo & RTL_TEXTTOUNICODE_INFO_SRCBUFFERTOSMALL ) - { - // read next byte - static Sequence< sal_Int8 > aOneByteSeq( 1 ); - nRead = mxStream->readSomeBytes( aOneByteSeq, 1 ); - if( nRead == 0 ) - { - mbReachedEOF = sal_True; - break; - } - - sal_Int32 nOldLen = mSeqSource.getLength(); - nTotalRead++; - if( nTotalRead > nOldLen ) - { - mSeqSource.realloc( nTotalRead ); - } - mSeqSource.getArray()[ nOldLen ] = aOneByteSeq.getConstArray()[ 0 ]; - pbSource = mSeqSource.getConstArray(); - bCont = sal_True; - } - - if( bCont ) - continue; - break; - } - - mnCharsInBuffer += nTargetCount; - return nTargetCount; - } - catch( NotConnectedException& ) - { - throw IOException(); - //throw IOException( L"OTextInputStream::implReadString failed" ); - } - catch( BufferSizeExceededException& ) - { - throw IOException(); - } -} - -void OTextInputStream::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; - mConvText2Unicode = rtl_createTextToUnicodeConverter( encoding ); - mContextText2Unicode = rtl_createTextToUnicodeContext( mConvText2Unicode ); - mEncoding = Encoding; -} - -//=========================================================================== -// XInputStream - -sal_Int32 OTextInputStream::readBytes( Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) - throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException) -{ - return mxStream->readBytes( aData, nBytesToRead ); -} - -sal_Int32 OTextInputStream::readSomeBytes( Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) - throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException) -{ - return mxStream->readSomeBytes( aData, nMaxBytesToRead ); -} - -void OTextInputStream::skipBytes( sal_Int32 nBytesToSkip ) - throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException) -{ - mxStream->skipBytes( nBytesToSkip ); -} - -sal_Int32 OTextInputStream::available( ) - throw(NotConnectedException, IOException, RuntimeException) -{ - return mxStream->available(); -} - -void OTextInputStream::closeInput( ) - throw(NotConnectedException, IOException, RuntimeException) -{ - mxStream->closeInput(); -} - - -//=========================================================================== -// XActiveDataSink - -void OTextInputStream::setInputStream( const Reference< XInputStream >& aStream ) - throw(RuntimeException) -{ - mxStream = aStream; -} - -Reference< XInputStream > OTextInputStream::getInputStream() - throw(RuntimeException) -{ - return mxStream; -} - - -Reference< XInterface > SAL_CALL TextInputStream_CreateInstance( const Reference< XComponentContext > &) -{ - return Reference < XInterface >( ( OWeakObject * ) new OTextInputStream() ); -} - -OUString TextInputStream_getImplementationName() -{ - return OUString( RTL_CONSTASCII_USTRINGPARAM( IMPLEMENTATION_NAME ) ); -} - -Sequence< OUString > TextInputStream_getSupportedServiceNames() -{ - Sequence< OUString > seqNames(1); - seqNames.getArray()[0] = OUString( RTL_CONSTASCII_USTRINGPARAM( SERVICE_NAME ) ); - return seqNames; -} - -OUString OTextInputStream::getImplementationName() throw() -{ - return TextInputStream_getImplementationName(); -} - -sal_Bool OTextInputStream::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 > OTextInputStream::getSupportedServiceNames(void) throw() -{ - return TextInputStream_getSupportedServiceNames(); -} - -} - -using namespace io_TextInputStream; - -static struct ImplementationEntry g_entries[] = -{ - { - TextInputStream_CreateInstance, TextInputStream_getImplementationName , - TextInputStream_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 ); -} - -//================================================================================================== -SAL_DLLPUBLIC_EXPORT void * SAL_CALL component_getFactory( - const sal_Char * pImplName, void * pServiceManager, void * pRegistryKey ) -{ - return component_getFactoryHelper( pImplName, pServiceManager, pRegistryKey , g_entries ); -} -} - - -/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |