blob: ad32e6e55a6bae27fece700ab32a6dd3791fd9fe (
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
package complex.olesimplestorage;
import com.sun.star.lang.XMultiServiceFactory;
import com.sun.star.io.XInputStream;
import com.sun.star.io.XOutputStream;
import com.sun.star.io.XTempFile;
import com.sun.star.embed.XOLESimpleStorage;
import com.sun.star.uno.UnoRuntime;
import java.util.Random;
public class Test01 implements OLESimpleStorageTest
{
XMultiServiceFactory m_xMSF = null;
TestHelper m_aTestHelper = null;
final int pStreamCnt = 5;
final int pBytesCnt = 10;
public Test01 ( XMultiServiceFactory xMSF )
{
m_xMSF = xMSF;
m_aTestHelper = new TestHelper ("Test01: ");
}
public boolean test ()
{
try
{
//create a new temporary stream
Object oTempFile = m_xMSF.createInstance ( "com.sun.star.io.TempFile" );
XTempFile xTempFile = UnoRuntime.queryInterface(XTempFile.class, oTempFile);
m_aTestHelper.Message ( "A new temporary stream created." );
//create OLESimpleStorage based on it
Object pArgs[] = new Object[2];
pArgs[0] = (Object) xTempFile;
pArgs[1] = new Boolean( true );
Object oOLESimpleStorage = m_xMSF.createInstanceWithArguments ( "com.sun.star.embed.OLESimpleStorage", pArgs );
XOLESimpleStorage xOLESimpleStorage = UnoRuntime.queryInterface(XOLESimpleStorage.class, oOLESimpleStorage);
m_aTestHelper.Message ( "OLESimpleStorage based on XStream created." );
//fill it with some streams
Object oStream[] = new Object[pStreamCnt];
byte pBytesIn[][][] = new byte [pStreamCnt][1][pBytesCnt];
byte pBytesOut[][] = new byte [pStreamCnt][pBytesCnt];
XTempFile xTempStream[] = new XTempFile[pStreamCnt];
Random oRandom = new Random ();
final String sSubStreamPrefix = "SubStream";
for ( int i = 0; i < pStreamCnt; i++ )
{
oRandom.nextBytes (pBytesOut[i]);
oStream[i] = m_xMSF.createInstance ( "com.sun.star.io.TempFile" );
xTempStream[i] = UnoRuntime.queryInterface(XTempFile.class, oStream[i]);
xTempStream[i].getOutputStream ().writeBytes (pBytesOut[i]);
xTempStream[i].seek (0);
m_aTestHelper.Message ( "Substream " + i + " initialized." );
if (xOLESimpleStorage.hasByName (sSubStreamPrefix + i))
{
xOLESimpleStorage.replaceByName ( sSubStreamPrefix + i, xTempStream[i] );
}
else
{
xOLESimpleStorage.insertByName ( sSubStreamPrefix + i, xTempStream[i] );
m_aTestHelper.Message ( "Substream " + i + " inserted." );
}
}
//commit the storage and close it
xOLESimpleStorage.commit ();
m_aTestHelper.Message ( "Storage commited." );
xOLESimpleStorage.dispose ();
for ( int i = 0; i < pStreamCnt; ++i )
{
xTempStream[i].setRemoveFile ( true );
xTempStream[i].getInputStream ().closeInput ();
xTempStream[i].getOutputStream ().closeOutput ();
}
m_aTestHelper.Message ( "Storage closed." );
//open the same stream with the constructor for inputstream
pArgs[0] = (Object)xTempFile.getInputStream ();
oOLESimpleStorage = m_xMSF.createInstanceWithArguments ( "com.sun.star.embed.OLESimpleStorage", pArgs );
xOLESimpleStorage = UnoRuntime.queryInterface(XOLESimpleStorage.class, oOLESimpleStorage);
m_aTestHelper.Message ( "Storage reopened, based on XInputStream." );
//check that all the streams contain correct information
m_aTestHelper.Message ( "Checking data contained in all the substreams..." );
for ( int i = 0; i < pStreamCnt; ++i )
{
if ( xOLESimpleStorage.hasByName (sSubStreamPrefix + i) )
{
xTempStream[i] = UnoRuntime.queryInterface(XTempFile.class, xOLESimpleStorage.getByName(sSubStreamPrefix + i));
xTempStream[i].seek (0);
xTempStream[i].getInputStream ().readBytes (pBytesIn[i], pBytesIn[i][0].length + 1 );
for ( int j = 0; j < pBytesCnt; ++j )
{
if ( pBytesIn[i][0][j] != pBytesOut[i][j] )
{
m_aTestHelper.Error ( "Stream " + i + " byte " + j + ": INCORRECT DATA!");
return false;
}
else
{
m_aTestHelper.Message ( "Stream " + i + " byte " + j + ": CORRECT." );
}
}
}
else
{
m_aTestHelper.Error( "Stream " + i + " is lost!");
return false;
}
}
m_aTestHelper.Message ( "All substreams contain correct data. SUCCESS." );
}
catch ( Exception e )
{
m_aTestHelper.Error ( "Exception: " + e );
return false;
}
return true;
}
}
|
