toolkit/source/helper/unomemorystream.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: unomemorystream.cxx,v $
  10  * $Revision: 1.8 $
  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_toolkit.hxx"
  33
  34
  35 #include <toolkit/helper/unomemorystream.hxx>
  36 #include <algorithm>
  37
  38 //      ----------------------------------------------------
  39 //      class UnoMemoryStream
  40 //      ----------------------------------------------------
  41 UnoMemoryStream::UnoMemoryStream( sal_uInt32 nInitSize, sal_uInt32 nInitResize )
  42     : SvMemoryStream( nInitSize, nInitResize )
  43 {
  44 }
  45
  46 // ::com::sun::star::uno::XInterface
  47 ::com::sun::star::uno::Any UnoMemoryStream::queryInterface( const ::com::sun::star::uno::Type & rType ) throw(::com::sun::star::uno::RuntimeException)
  48 {
  49     ::com::sun::star::uno::Any aRet = ::cppu::queryInterface( rType,
  50                                         SAL_STATIC_CAST( ::com::sun::star::io::XInputStream*, this ) );
  51     return (aRet.hasValue() ? aRet : OWeakObject::queryInterface( rType ));
  52 }
  53
  54
  55 // ::com::sun::star::io::XInputStream
  56 sal_Int32 UnoMemoryStream::readBytes( ::com::sun::star::uno::Sequence< sal_Int8 >& rData, sal_Int32 nBytesToRead ) throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::BufferSizeExceededException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
  57 {
  58     ::osl::Guard< ::osl::Mutex > aGuard( GetMutex() );
  59
  60     sal_Int32 nRead = available();
  61     if ( nRead > nBytesToRead )
  62         nRead = nBytesToRead;
  63
  64     rData = ::com::sun::star::uno::Sequence< sal_Int8 >( nRead );
  65     Read( rData.getArray(), nRead );
  66
  67     return nRead;
  68 }
  69
  70 sal_Int32 UnoMemoryStream::readSomeBytes( ::com::sun::star::uno::Sequence< sal_Int8 >& rData, sal_Int32 nMaxBytesToRead ) throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::BufferSizeExceededException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
  71 {
  72     ::osl::Guard< ::osl::Mutex > aGuard( GetMutex() );
  73
  74     sal_Int32 nAvailable = available();
  75     if( nAvailable )
  76     {
  77         return readBytes( rData, std::min( nMaxBytesToRead , nAvailable ) );
  78     }
  79     else
  80     {
  81         // Not the most effective method, but it sticks to the specification
  82         return readBytes( rData, 1 );
  83     }
  84 }
  85
  86 void UnoMemoryStream::skipBytes( sal_Int32 nBytesToSkip ) throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::BufferSizeExceededException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
  87 {
  88     ::osl::Guard< ::osl::Mutex > aGuard( GetMutex() );
  89
  90     SeekRel( nBytesToSkip );
  91 }
  92
  93 sal_Int32 UnoMemoryStream::available() throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
  94 {
  95     ::osl::Guard< ::osl::Mutex > aGuard( GetMutex() );
  96
  97     sal_uInt32 nStreamPos = Tell();
  98     sal_uInt32 nEnd = Seek( STREAM_SEEK_TO_END );
  99     Seek( nStreamPos );
 100     return nEnd - nStreamPos;
 101 }
 102
 103 void UnoMemoryStream::closeInput() throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
 104 {
 105     // nothing to do
 106 }
 107
 108
 109
 110
 111