blob: ff589cdc3a5985bb3b11060e0bf6d5e87b1db34e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
#include "WPXSvStream.h"
#include <tools/stream.hxx>
#include <unotools/streamwrap.hxx>
#include <unotools/ucbstreamhelper.hxx>
#ifndef _COM_SUN_STAR_IO_XINPUTSTREAM_H_
#include <com/sun/star/io/XSeekable.hpp>
#endif
using namespace ::com::sun::star::uno;
using namespace ::com::sun::star::io;
WPXSvInputStream::WPXSvInputStream( Reference< XInputStream > xStream ) :
WPXInputStream(true),
mxChildStorage(),
mxChildStream(),
mxStream(xStream),
mnOffset(0)
{
Reference < XSeekable> xSeekable = Reference < XSeekable > (xStream, UNO_QUERY);
if (!xSeekable.is())
mnLength = 0;
else
mnLength = xSeekable->getLength(); // exception
}
WPXSvInputStream::~WPXSvInputStream()
{
}
const uint8_t * WPXSvInputStream::read(size_t numBytes)
{
// FIXME: assume no short reads (?)
mnOffset += mxStream->readBytes (maData, numBytes);
return (const uint8_t *)maData.getConstArray();
}
int WPXSvInputStream::seek(long offset, WPX_SEEK_TYPE seekType)
{
if (seekType == WPX_SEEK_CUR && offset >= 0)
{
mxStream->skipBytes (offset); // exception ?
mnOffset += offset;
return FALSE;
}
Reference < XSeekable> xSeekable = Reference < XSeekable >(mxStream, UNO_QUERY);
if (!xSeekable.is())
return TRUE;
if (seekType == WPX_SEEK_CUR)
mnOffset += offset;
else
mnOffset = offset;
xSeekable->seek(mnOffset); // FIXME: catch exception!
return FALSE;
}
long WPXSvInputStream::tell()
{
return mnOffset;
}
bool WPXSvInputStream::atEOS()
{
return mnOffset >= mnLength;
}
bool WPXSvInputStream::isOLEStream()
{
bool bAns;
SvStream *pStream = utl::UcbStreamHelper::CreateStream( mxStream );
bAns = pStream && SotStorage::IsOLEStorage( pStream );
delete pStream;
seek (0, WPX_SEEK_SET);
return bAns;
}
WPXInputStream * WPXSvInputStream::getDocumentOLEStream()
{
SvStream *pStream = utl::UcbStreamHelper::CreateStream( mxStream );
mxChildStorage = new SotStorage( pStream, TRUE );
mxChildStream = mxChildStorage->OpenSotStream(
rtl::OUString::createFromAscii( "PerfectOffice_MAIN" ),
STREAM_STD_READ );
Reference < XInputStream > xContents = new utl::OInputStreamWrapper( mxChildStream );
if (xContents.is())
return new WPXSvInputStream( xContents );
else
return NULL;
}
|
