1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_toolkit.hxx"
26*b1cdbd2cSJim Jagielski
27*b1cdbd2cSJim Jagielski
28*b1cdbd2cSJim Jagielski #include <toolkit/helper/unomemorystream.hxx>
29*b1cdbd2cSJim Jagielski #include <algorithm>
30*b1cdbd2cSJim Jagielski
31*b1cdbd2cSJim Jagielski // ----------------------------------------------------
32*b1cdbd2cSJim Jagielski // class UnoMemoryStream
33*b1cdbd2cSJim Jagielski // ----------------------------------------------------
UnoMemoryStream(sal_uInt32 nInitSize,sal_uInt32 nInitResize)34*b1cdbd2cSJim Jagielski UnoMemoryStream::UnoMemoryStream( sal_uInt32 nInitSize, sal_uInt32 nInitResize )
35*b1cdbd2cSJim Jagielski : SvMemoryStream( nInitSize, nInitResize )
36*b1cdbd2cSJim Jagielski {
37*b1cdbd2cSJim Jagielski }
38*b1cdbd2cSJim Jagielski
39*b1cdbd2cSJim Jagielski // ::com::sun::star::uno::XInterface
queryInterface(const::com::sun::star::uno::Type & rType)40*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Any UnoMemoryStream::queryInterface( const ::com::sun::star::uno::Type & rType ) throw(::com::sun::star::uno::RuntimeException)
41*b1cdbd2cSJim Jagielski {
42*b1cdbd2cSJim Jagielski ::com::sun::star::uno::Any aRet = ::cppu::queryInterface( rType,
43*b1cdbd2cSJim Jagielski SAL_STATIC_CAST( ::com::sun::star::io::XInputStream*, this ) );
44*b1cdbd2cSJim Jagielski return (aRet.hasValue() ? aRet : OWeakObject::queryInterface( rType ));
45*b1cdbd2cSJim Jagielski }
46*b1cdbd2cSJim Jagielski
47*b1cdbd2cSJim Jagielski
48*b1cdbd2cSJim Jagielski // ::com::sun::star::io::XInputStream
readBytes(::com::sun::star::uno::Sequence<sal_Int8> & rData,sal_Int32 nBytesToRead)49*b1cdbd2cSJim Jagielski 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)
50*b1cdbd2cSJim Jagielski {
51*b1cdbd2cSJim Jagielski ::osl::Guard< ::osl::Mutex > aGuard( GetMutex() );
52*b1cdbd2cSJim Jagielski
53*b1cdbd2cSJim Jagielski sal_Int32 nRead = available();
54*b1cdbd2cSJim Jagielski if ( nRead > nBytesToRead )
55*b1cdbd2cSJim Jagielski nRead = nBytesToRead;
56*b1cdbd2cSJim Jagielski
57*b1cdbd2cSJim Jagielski rData = ::com::sun::star::uno::Sequence< sal_Int8 >( nRead );
58*b1cdbd2cSJim Jagielski Read( rData.getArray(), nRead );
59*b1cdbd2cSJim Jagielski
60*b1cdbd2cSJim Jagielski return nRead;
61*b1cdbd2cSJim Jagielski }
62*b1cdbd2cSJim Jagielski
readSomeBytes(::com::sun::star::uno::Sequence<sal_Int8> & rData,sal_Int32 nMaxBytesToRead)63*b1cdbd2cSJim Jagielski 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)
64*b1cdbd2cSJim Jagielski {
65*b1cdbd2cSJim Jagielski ::osl::Guard< ::osl::Mutex > aGuard( GetMutex() );
66*b1cdbd2cSJim Jagielski
67*b1cdbd2cSJim Jagielski sal_Int32 nAvailable = available();
68*b1cdbd2cSJim Jagielski if( nAvailable )
69*b1cdbd2cSJim Jagielski {
70*b1cdbd2cSJim Jagielski return readBytes( rData, std::min( nMaxBytesToRead , nAvailable ) );
71*b1cdbd2cSJim Jagielski }
72*b1cdbd2cSJim Jagielski else
73*b1cdbd2cSJim Jagielski {
74*b1cdbd2cSJim Jagielski // Not the most effective method, but it sticks to the specification
75*b1cdbd2cSJim Jagielski return readBytes( rData, 1 );
76*b1cdbd2cSJim Jagielski }
77*b1cdbd2cSJim Jagielski }
78*b1cdbd2cSJim Jagielski
skipBytes(sal_Int32 nBytesToSkip)79*b1cdbd2cSJim Jagielski 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)
80*b1cdbd2cSJim Jagielski {
81*b1cdbd2cSJim Jagielski ::osl::Guard< ::osl::Mutex > aGuard( GetMutex() );
82*b1cdbd2cSJim Jagielski
83*b1cdbd2cSJim Jagielski SeekRel( nBytesToSkip );
84*b1cdbd2cSJim Jagielski }
85*b1cdbd2cSJim Jagielski
available()86*b1cdbd2cSJim Jagielski sal_Int32 UnoMemoryStream::available() throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
87*b1cdbd2cSJim Jagielski {
88*b1cdbd2cSJim Jagielski ::osl::Guard< ::osl::Mutex > aGuard( GetMutex() );
89*b1cdbd2cSJim Jagielski
90*b1cdbd2cSJim Jagielski sal_uInt32 nStreamPos = Tell();
91*b1cdbd2cSJim Jagielski sal_uInt32 nEnd = Seek( STREAM_SEEK_TO_END );
92*b1cdbd2cSJim Jagielski Seek( nStreamPos );
93*b1cdbd2cSJim Jagielski return nEnd - nStreamPos;
94*b1cdbd2cSJim Jagielski }
95*b1cdbd2cSJim Jagielski
closeInput()96*b1cdbd2cSJim Jagielski void UnoMemoryStream::closeInput() throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
97*b1cdbd2cSJim Jagielski {
98*b1cdbd2cSJim Jagielski // nothing to do
99*b1cdbd2cSJim Jagielski }
100*b1cdbd2cSJim Jagielski
101*b1cdbd2cSJim Jagielski
102*b1cdbd2cSJim Jagielski
103*b1cdbd2cSJim Jagielski
104*b1cdbd2cSJim Jagielski
105