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_package.hxx"
26*b1cdbd2cSJim Jagielski #include <ZipPackageBuffer.hxx>
27*b1cdbd2cSJim Jagielski #include <string.h> // for memcpy
28*b1cdbd2cSJim Jagielski
29*b1cdbd2cSJim Jagielski using namespace ::com::sun::star;
30*b1cdbd2cSJim Jagielski using namespace com::sun::star::uno;
31*b1cdbd2cSJim Jagielski using namespace com::sun::star::io;
32*b1cdbd2cSJim Jagielski using com::sun::star::lang::IllegalArgumentException;
33*b1cdbd2cSJim Jagielski
ZipPackageBuffer(sal_Int64 nNewBufferSize)34*b1cdbd2cSJim Jagielski ZipPackageBuffer::ZipPackageBuffer(sal_Int64 nNewBufferSize )
35*b1cdbd2cSJim Jagielski : m_nBufferSize (nNewBufferSize)
36*b1cdbd2cSJim Jagielski , m_nEnd(0)
37*b1cdbd2cSJim Jagielski , m_nCurrent(0)
38*b1cdbd2cSJim Jagielski , m_bMustInitBuffer ( sal_True )
39*b1cdbd2cSJim Jagielski {
40*b1cdbd2cSJim Jagielski }
~ZipPackageBuffer(void)41*b1cdbd2cSJim Jagielski ZipPackageBuffer::~ZipPackageBuffer(void)
42*b1cdbd2cSJim Jagielski {
43*b1cdbd2cSJim Jagielski }
44*b1cdbd2cSJim Jagielski
readBytes(Sequence<sal_Int8> & aData,sal_Int32 nBytesToRead)45*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL ZipPackageBuffer::readBytes( Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead )
46*b1cdbd2cSJim Jagielski throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
47*b1cdbd2cSJim Jagielski {
48*b1cdbd2cSJim Jagielski if (nBytesToRead < 0)
49*b1cdbd2cSJim Jagielski throw BufferSizeExceededException( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX ) ), *this );
50*b1cdbd2cSJim Jagielski
51*b1cdbd2cSJim Jagielski if (nBytesToRead + m_nCurrent > m_nEnd)
52*b1cdbd2cSJim Jagielski nBytesToRead = static_cast < sal_Int32 > (m_nEnd - m_nCurrent);
53*b1cdbd2cSJim Jagielski
54*b1cdbd2cSJim Jagielski aData.realloc ( nBytesToRead );
55*b1cdbd2cSJim Jagielski memcpy(aData.getArray(), m_aBuffer.getConstArray() + m_nCurrent, nBytesToRead);
56*b1cdbd2cSJim Jagielski m_nCurrent +=nBytesToRead;
57*b1cdbd2cSJim Jagielski return nBytesToRead;
58*b1cdbd2cSJim Jagielski }
59*b1cdbd2cSJim Jagielski
readSomeBytes(Sequence<sal_Int8> & aData,sal_Int32 nMaxBytesToRead)60*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL ZipPackageBuffer::readSomeBytes( Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead )
61*b1cdbd2cSJim Jagielski throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
62*b1cdbd2cSJim Jagielski {
63*b1cdbd2cSJim Jagielski return readBytes(aData, nMaxBytesToRead);
64*b1cdbd2cSJim Jagielski }
skipBytes(sal_Int32 nBytesToSkip)65*b1cdbd2cSJim Jagielski void SAL_CALL ZipPackageBuffer::skipBytes( sal_Int32 nBytesToSkip )
66*b1cdbd2cSJim Jagielski throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
67*b1cdbd2cSJim Jagielski {
68*b1cdbd2cSJim Jagielski if (nBytesToSkip < 0)
69*b1cdbd2cSJim Jagielski throw BufferSizeExceededException( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX ) ), *this );
70*b1cdbd2cSJim Jagielski
71*b1cdbd2cSJim Jagielski if (nBytesToSkip + m_nCurrent > m_nEnd)
72*b1cdbd2cSJim Jagielski nBytesToSkip = static_cast < sal_Int32 > (m_nEnd - m_nCurrent);
73*b1cdbd2cSJim Jagielski
74*b1cdbd2cSJim Jagielski m_nCurrent+=nBytesToSkip;
75*b1cdbd2cSJim Jagielski }
available()76*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL ZipPackageBuffer::available( )
77*b1cdbd2cSJim Jagielski throw(NotConnectedException, IOException, RuntimeException)
78*b1cdbd2cSJim Jagielski {
79*b1cdbd2cSJim Jagielski return static_cast < sal_Int32 > (m_nEnd - m_nCurrent);
80*b1cdbd2cSJim Jagielski }
closeInput()81*b1cdbd2cSJim Jagielski void SAL_CALL ZipPackageBuffer::closeInput( )
82*b1cdbd2cSJim Jagielski throw(NotConnectedException, IOException, RuntimeException)
83*b1cdbd2cSJim Jagielski {
84*b1cdbd2cSJim Jagielski }
writeBytes(const Sequence<sal_Int8> & aData)85*b1cdbd2cSJim Jagielski void SAL_CALL ZipPackageBuffer::writeBytes( const Sequence< sal_Int8 >& aData )
86*b1cdbd2cSJim Jagielski throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
87*b1cdbd2cSJim Jagielski {
88*b1cdbd2cSJim Jagielski sal_Int64 nDataLen = aData.getLength(), nCombined = m_nEnd + nDataLen;
89*b1cdbd2cSJim Jagielski
90*b1cdbd2cSJim Jagielski if ( nCombined > m_nBufferSize)
91*b1cdbd2cSJim Jagielski {
92*b1cdbd2cSJim Jagielski do
93*b1cdbd2cSJim Jagielski m_nBufferSize *=2;
94*b1cdbd2cSJim Jagielski while (nCombined > m_nBufferSize);
95*b1cdbd2cSJim Jagielski m_aBuffer.realloc(static_cast < sal_Int32 > (m_nBufferSize));
96*b1cdbd2cSJim Jagielski m_bMustInitBuffer = sal_False;
97*b1cdbd2cSJim Jagielski }
98*b1cdbd2cSJim Jagielski else if (m_bMustInitBuffer)
99*b1cdbd2cSJim Jagielski {
100*b1cdbd2cSJim Jagielski m_aBuffer.realloc ( static_cast < sal_Int32 > ( m_nBufferSize ) );
101*b1cdbd2cSJim Jagielski m_bMustInitBuffer = sal_False;
102*b1cdbd2cSJim Jagielski }
103*b1cdbd2cSJim Jagielski memcpy( m_aBuffer.getArray() + m_nCurrent, aData.getConstArray(), static_cast < sal_Int32 > (nDataLen));
104*b1cdbd2cSJim Jagielski m_nCurrent+=nDataLen;
105*b1cdbd2cSJim Jagielski if (m_nCurrent>m_nEnd)
106*b1cdbd2cSJim Jagielski m_nEnd = m_nCurrent;
107*b1cdbd2cSJim Jagielski }
flush()108*b1cdbd2cSJim Jagielski void SAL_CALL ZipPackageBuffer::flush( )
109*b1cdbd2cSJim Jagielski throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
110*b1cdbd2cSJim Jagielski {
111*b1cdbd2cSJim Jagielski }
closeOutput()112*b1cdbd2cSJim Jagielski void SAL_CALL ZipPackageBuffer::closeOutput( )
113*b1cdbd2cSJim Jagielski throw(NotConnectedException, BufferSizeExceededException, IOException, RuntimeException)
114*b1cdbd2cSJim Jagielski {
115*b1cdbd2cSJim Jagielski }
seek(sal_Int64 location)116*b1cdbd2cSJim Jagielski void SAL_CALL ZipPackageBuffer::seek( sal_Int64 location )
117*b1cdbd2cSJim Jagielski throw( IllegalArgumentException, IOException, RuntimeException)
118*b1cdbd2cSJim Jagielski {
119*b1cdbd2cSJim Jagielski if ( location > m_nEnd || location < 0 )
120*b1cdbd2cSJim Jagielski throw IllegalArgumentException( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX ) ), uno::Reference< uno::XInterface >(), 1 );
121*b1cdbd2cSJim Jagielski m_nCurrent = location;
122*b1cdbd2cSJim Jagielski }
getPosition()123*b1cdbd2cSJim Jagielski sal_Int64 SAL_CALL ZipPackageBuffer::getPosition( )
124*b1cdbd2cSJim Jagielski throw(IOException, RuntimeException)
125*b1cdbd2cSJim Jagielski {
126*b1cdbd2cSJim Jagielski return m_nCurrent;
127*b1cdbd2cSJim Jagielski }
getLength()128*b1cdbd2cSJim Jagielski sal_Int64 SAL_CALL ZipPackageBuffer::getLength( )
129*b1cdbd2cSJim Jagielski throw(IOException, RuntimeException)
130*b1cdbd2cSJim Jagielski {
131*b1cdbd2cSJim Jagielski return m_nEnd;
132*b1cdbd2cSJim Jagielski }
133