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_comphelper.hxx"
26*b1cdbd2cSJim Jagielski #include <comphelper/streamsection.hxx>
27*b1cdbd2cSJim Jagielski #include <osl/diagnose.h>
28*b1cdbd2cSJim Jagielski
29*b1cdbd2cSJim Jagielski namespace comphelper
30*b1cdbd2cSJim Jagielski {
31*b1cdbd2cSJim Jagielski
32*b1cdbd2cSJim Jagielski //-------------------------------------------------------------------------
OStreamSection(const staruno::Reference<stario::XDataInputStream> & _rxInput)33*b1cdbd2cSJim Jagielski OStreamSection::OStreamSection(const staruno::Reference< stario::XDataInputStream >& _rxInput)
34*b1cdbd2cSJim Jagielski :m_xMarkStream(_rxInput, ::com::sun::star::uno::UNO_QUERY)
35*b1cdbd2cSJim Jagielski ,m_xInStream(_rxInput)
36*b1cdbd2cSJim Jagielski ,m_nBlockStart(-1)
37*b1cdbd2cSJim Jagielski ,m_nBlockLen(-1)
38*b1cdbd2cSJim Jagielski {
39*b1cdbd2cSJim Jagielski OSL_ENSURE(m_xInStream.is() && m_xMarkStream.is(), "OStreamSection::OStreamSection : invalid argument !");
40*b1cdbd2cSJim Jagielski if (m_xInStream.is() && m_xMarkStream.is())
41*b1cdbd2cSJim Jagielski {
42*b1cdbd2cSJim Jagielski m_nBlockLen = _rxInput->readLong();
43*b1cdbd2cSJim Jagielski m_nBlockStart = m_xMarkStream->createMark();
44*b1cdbd2cSJim Jagielski }
45*b1cdbd2cSJim Jagielski }
46*b1cdbd2cSJim Jagielski
47*b1cdbd2cSJim Jagielski //-------------------------------------------------------------------------
OStreamSection(const staruno::Reference<stario::XDataOutputStream> & _rxOutput,sal_Int32 _nPresumedLength)48*b1cdbd2cSJim Jagielski OStreamSection::OStreamSection(const staruno::Reference< stario::XDataOutputStream >& _rxOutput, sal_Int32 _nPresumedLength)
49*b1cdbd2cSJim Jagielski :m_xMarkStream(_rxOutput, ::com::sun::star::uno::UNO_QUERY)
50*b1cdbd2cSJim Jagielski ,m_xOutStream(_rxOutput)
51*b1cdbd2cSJim Jagielski ,m_nBlockStart(-1)
52*b1cdbd2cSJim Jagielski ,m_nBlockLen(-1)
53*b1cdbd2cSJim Jagielski {
54*b1cdbd2cSJim Jagielski OSL_ENSURE(m_xOutStream.is() && m_xMarkStream.is(), "OStreamSection::OStreamSection : invalid argument !");
55*b1cdbd2cSJim Jagielski if (m_xOutStream.is() && m_xMarkStream.is())
56*b1cdbd2cSJim Jagielski {
57*b1cdbd2cSJim Jagielski m_nBlockStart = m_xMarkStream->createMark();
58*b1cdbd2cSJim Jagielski // a placeholder where we will write the overall length (within the destructor)
59*b1cdbd2cSJim Jagielski if (_nPresumedLength > 0)
60*b1cdbd2cSJim Jagielski m_nBlockLen = _nPresumedLength + sizeof(m_nBlockLen);
61*b1cdbd2cSJim Jagielski // as the caller did not consider - of course - the placeholder we are going to write
62*b1cdbd2cSJim Jagielski else
63*b1cdbd2cSJim Jagielski m_nBlockLen = 0;
64*b1cdbd2cSJim Jagielski m_xOutStream->writeLong(m_nBlockLen);
65*b1cdbd2cSJim Jagielski }
66*b1cdbd2cSJim Jagielski }
67*b1cdbd2cSJim Jagielski
68*b1cdbd2cSJim Jagielski //-------------------------------------------------------------------------
~OStreamSection()69*b1cdbd2cSJim Jagielski OStreamSection::~OStreamSection()
70*b1cdbd2cSJim Jagielski {
71*b1cdbd2cSJim Jagielski try
72*b1cdbd2cSJim Jagielski { // don't allow any exceptions to leave this block, this may be called during the stack unwinding of an exception
73*b1cdbd2cSJim Jagielski // handling routing
74*b1cdbd2cSJim Jagielski if (m_xInStream.is() && m_xMarkStream.is())
75*b1cdbd2cSJim Jagielski { // we're working on an input stream
76*b1cdbd2cSJim Jagielski m_xMarkStream->jumpToMark(m_nBlockStart);
77*b1cdbd2cSJim Jagielski m_xInStream->skipBytes(m_nBlockLen);
78*b1cdbd2cSJim Jagielski m_xMarkStream->deleteMark(m_nBlockStart);
79*b1cdbd2cSJim Jagielski }
80*b1cdbd2cSJim Jagielski else if (m_xOutStream.is() && m_xMarkStream.is())
81*b1cdbd2cSJim Jagielski {
82*b1cdbd2cSJim Jagielski sal_Int32 nRealBlockLength = m_xMarkStream->offsetToMark(m_nBlockStart) - sizeof(m_nBlockLen);
83*b1cdbd2cSJim Jagielski if (m_nBlockLen && (m_nBlockLen == nRealBlockLength))
84*b1cdbd2cSJim Jagielski // nothing to do : the estimation the caller gave us (in the ctor) was correct
85*b1cdbd2cSJim Jagielski m_xMarkStream->deleteMark(m_nBlockStart);
86*b1cdbd2cSJim Jagielski else
87*b1cdbd2cSJim Jagielski { // the estimation was wrong (or we didn't get one)
88*b1cdbd2cSJim Jagielski m_nBlockLen = nRealBlockLength;
89*b1cdbd2cSJim Jagielski m_xMarkStream->jumpToMark(m_nBlockStart);
90*b1cdbd2cSJim Jagielski m_xOutStream->writeLong(m_nBlockLen);
91*b1cdbd2cSJim Jagielski m_xMarkStream->jumpToFurthest();
92*b1cdbd2cSJim Jagielski m_xMarkStream->deleteMark(m_nBlockStart);
93*b1cdbd2cSJim Jagielski }
94*b1cdbd2cSJim Jagielski }
95*b1cdbd2cSJim Jagielski }
96*b1cdbd2cSJim Jagielski catch(const staruno::Exception&)
97*b1cdbd2cSJim Jagielski {
98*b1cdbd2cSJim Jagielski }
99*b1cdbd2cSJim Jagielski }
100*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
available()101*b1cdbd2cSJim Jagielski sal_Int32 OStreamSection::available()
102*b1cdbd2cSJim Jagielski {
103*b1cdbd2cSJim Jagielski sal_Int32 nBytes = 0;
104*b1cdbd2cSJim Jagielski try
105*b1cdbd2cSJim Jagielski { // don't allow any exceptions to leave this block, this may be called during the stack unwinding of an exception
106*b1cdbd2cSJim Jagielski if (m_xInStream.is() && m_xMarkStream.is())
107*b1cdbd2cSJim Jagielski nBytes = m_xMarkStream->offsetToMark(m_nBlockStart) - sizeof(m_nBlockLen);
108*b1cdbd2cSJim Jagielski }
109*b1cdbd2cSJim Jagielski catch(const staruno::Exception&)
110*b1cdbd2cSJim Jagielski {
111*b1cdbd2cSJim Jagielski }
112*b1cdbd2cSJim Jagielski return nBytes;
113*b1cdbd2cSJim Jagielski }
114*b1cdbd2cSJim Jagielski // -----------------------------------------------------------------------------
115*b1cdbd2cSJim Jagielski
116*b1cdbd2cSJim Jagielski } // namespace comphelper
117*b1cdbd2cSJim Jagielski
118*b1cdbd2cSJim Jagielski
119