?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Version 3.6.0.4, tag libreoffice-3.6.0.4
[LibreOffice.git] / store / workben / t_store.cxx
bloba6184eb480c290b81c133991eb6e80258b10e11b
1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 /*************************************************************************
3 *
4 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
5 *
6 * Copyright 2000, 2010 Oracle and/or its affiliates.
7 *
8 * OpenOffice.org - a multi-platform office productivity suite
9 *
10 * This file is part of OpenOffice.org.
11 *
12 * OpenOffice.org is free software: you can redistribute it and/or modify
13 * it under the terms of the GNU Lesser General Public License version 3
14 * only, as published by the Free Software Foundation.
15 *
16 * OpenOffice.org is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 * GNU Lesser General Public License version 3 for more details
20 * (a copy is included in the LICENSE file that accompanied this code).
21 *
22 * You should have received a copy of the GNU Lesser General Public License
23 * version 3 along with OpenOffice.org. If not, see
24 * <http://www.openoffice.org/license.html>
25 * for a copy of the LGPLv3 License.
26 *
27 ************************************************************************/
28
29
30 #define _T_STORE_CXX
31 #include <sal/types.h>
32 #include <osl/diagnose.h>
33 #include <osl/thread.h>
34 #include <osl/time.h>
35 #include <rtl/ustring.hxx>
36 #include <store/store.hxx>
37
38 #include <stdio.h>
39
40 #if (defined(WNT) && defined(PROFILE))
41 extern "C"
42 {
43 void StartCAP (void);
44 void StopCAP (void);
45 void DumpCAP (void);
46 }
47 #endif /* PROFILE */
48
49 using rtl::OUString;
50
51 /*========================================================================
52 *
53 * Internals.
54 *
55 *======================================================================*/
56 #define _DEMOSTOR_BUFSIZ 512 /* 4096, 1024, 512 */
57 #define _DEMOSTOR_LOOPS 1000 /* 1000, 2000 */
58
59 #define _DEMOSTOR_REMOVE 0
60 #define _DEMOSTOR_REBUILD 0
61
62 enum Options
63 {
64 OPTION_HELP = 0x0001,
65 OPTION_FILE = 0x0002,
66 OPTION_PAUSE = 0x0004,
67 OPTION_REBUILD = 0x0008,
68
69 OPTION_DUMP = 0x0010,
70 OPTION_ITER = 0x0020,
71 OPTION_LINK = 0x0040,
72
73 OPTION_READ = 0x0100,
74 OPTION_WRITE = 0x0200,
75 OPTION_CREAT = 0x0400,
76 OPTION_TRUNC = 0x0800
77 };
78
79 inline sal_Char ascii_toLowerCase (sal_Char ch)
80 {
81 if ((ch >= 0x41) && (ch <= 0x5A))
82 return (ch + 0x20);
83 else
84 return (ch);
85 }
86
87 /*========================================================================
88 *
89 * Timing.
90 *
91 *======================================================================*/
92 struct OTime : public TimeValue
93 {
94 OTime (void)
95 {
96 Seconds = 0;
97 Nanosec = 0;
98 }
99
100 static OTime getSystemTime (void)
101 {
102 OTime tv;
103 osl_getSystemTime (&tv);
104 return tv;
105 }
106
107 OTime& operator-= (const OTime& rPast)
108 {
109 Seconds -= rPast.Seconds;
110 if (Nanosec < rPast.Nanosec)
111 {
112 Seconds -= 1;
113 Nanosec += 1000000000;
114 }
115 Nanosec -= rPast.Nanosec;
116 return *this;
117 }
118
119 friend OTime operator- (const OTime& rTimeA, const OTime& rTimeB)
120 {
121 OTime aTimeC (rTimeA);
122 aTimeC -= rTimeB;
123 return aTimeC;
124 }
125 };
126
127 /*========================================================================
128 *
129 * DirectoryTraveller.
130 *
131 *======================================================================*/
132 typedef store::OStoreDirectory Directory;
133
134 class DirectoryTraveller : public Directory::traveller
135 {
136 typedef store::OStoreFile file;
137 typedef Directory::iterator iter;
138
139 store::OStoreFile m_aFile;
140 OUString m_aPath;
141
142 sal_uInt32 m_nOptions;
143 unsigned int m_nLevel;
144 unsigned int m_nCount;
145
146 public:
147 DirectoryTraveller (
148 const file& rFile,
149 const OUString &rPath,
150 const OUString &rName,
151 sal_uInt32 nOptions,
152 unsigned int nLevel = 0);
153
154 virtual ~DirectoryTraveller (void);
155
156 virtual sal_Bool visit (const iter& it);
157 };
158
159 /*
160 * DirectoryTraveller.
161 */
162 DirectoryTraveller::DirectoryTraveller (
163 const file& rFile,
164 const OUString &rPath,
165 const OUString &rName,
166 sal_uInt32 nOptions,
167 unsigned int nLevel)
168 : m_aFile (rFile),
169 m_aPath (rPath),
170 m_nOptions (nOptions),
171 m_nLevel (nLevel),
172 m_nCount (0)
173 {
174 m_aPath += rName;
175 m_aPath += OUString("/");
176 }
177
178 /*
179 * ~DirectoryTraveller.
180 */
181 DirectoryTraveller::~DirectoryTraveller (void)
182 {
183 }
184
185 /*
186 * visit.
187 */
188 sal_Bool DirectoryTraveller::visit (const iter& it)
189 {
190 m_nCount++;
191 if (m_nOptions & OPTION_DUMP)
192 {
193 rtl::OString aName (it.m_pszName, it.m_nLength, RTL_TEXTENCODING_UTF8);
194 printf ("Visit(%d,%d): %s [0x%08x] %d [Bytes]\n",
195 m_nLevel, m_nCount,
196 aName.pData->buffer, (unsigned int)(it.m_nAttrib), (unsigned int)(it.m_nSize));
197 }
198 if (it.m_nAttrib & STORE_ATTRIB_ISDIR)
199 {
200 OUString aName (it.m_pszName, it.m_nLength);
201 if (aName.compareToAscii ("XTextViewCursorSupplier") == 0)
202 {
203 m_nCount += 1 - 1;
204 }
205 Directory aSubDir;
206
207 storeError eErrCode = aSubDir.create (
208 m_aFile, m_aPath, aName, store_AccessReadOnly);
209 if (eErrCode == store_E_None)
210 {
211 sal_uInt32 nRefCount = 0;
212 m_aFile.getRefererCount (nRefCount);
213
214 DirectoryTraveller aSubTraveller (
215 m_aFile, m_aPath, aName, m_nOptions, m_nLevel + 1);
216 aSubDir.travel (aSubTraveller);
217 }
218 }
219 return sal_True;
220 }
221
222 /*========================================================================
223 *
224 * main.
225 *
226 *======================================================================*/
227 int SAL_CALL main (int argc, char **argv)
228 {
229 #if (defined(WNT) && defined(PROFILE))
230 StartCAP();
231 #else
232 OTime aMainStartTime (OTime::getSystemTime());
233 #endif /* PROFILE */
234
235 store::OStoreFile aFile;
236 storeError eErrCode = store_E_None;
237
238 sal_uInt32 nOptions = 0;
239 for (int i = 1; i < argc; i++)
240 {
241 const char *opt = argv[i];
242 if (opt[0] == '-')
243 {
244 switch (ascii_toLowerCase(sal_Char(opt[1])))
245 {
246 case 'f':
247 nOptions |= OPTION_FILE;
248 break;
249
250 case 'd':
251 nOptions |= OPTION_DUMP;
252 break;
253 case 'i':
254 nOptions |= OPTION_ITER;
255 break;
256 case 'l':
257 nOptions |= OPTION_LINK;
258 break;
259
260 case 'r':
261 nOptions |= OPTION_READ;
262 break;
263 case 'w':
264 nOptions |= OPTION_WRITE;
265 break;
266 case 'c':
267 nOptions |= OPTION_CREAT;
268 break;
269 case 't':
270 nOptions |= OPTION_TRUNC;
271 break;
272
273 case 'p':
274 nOptions |= OPTION_PAUSE;
275 break;
276
277 case 'h':
278 default:
279 nOptions |= OPTION_HELP;
280 break;
281 }
282 }
283 else
284 {
285 if (nOptions & OPTION_FILE)
286 {
287 OUString aName (
288 argv[i], rtl_str_getLength(argv[i]),
289 osl_getThreadTextEncoding());
290 if ((nOptions & OPTION_CREAT) && (nOptions & OPTION_TRUNC))
291 eErrCode = aFile.create (aName, store_AccessCreate);
292 else if (nOptions & OPTION_CREAT)
293 eErrCode = aFile.create (aName, store_AccessReadCreate);
294 else if (nOptions & OPTION_WRITE)
295 eErrCode = aFile.create (aName, store_AccessReadWrite);
296 else
297 eErrCode = aFile.create (aName, store_AccessReadOnly);
298 if (eErrCode != store_E_None)
299 {
300 printf ("Error: can't open file: %s\n", argv[i]);
301 exit (0);
302 }
303 }
304 }
305 }
306
307 if ((nOptions == 0) || (nOptions & OPTION_HELP))
308 {
309 printf ("Usage:\tt_store "
310 "[[-c] [-t] [-r] [-w]] [[-i] [-d] [-h]] "
311 "[-f filename]\n");
312
313 printf ("\nOptions:\n");
314 printf ("-c\tcreate\n");
315 printf ("-t\ttruncate\n");
316 printf ("-r\tread\n");
317 printf ("-w\twrite\n");
318 printf ("-i\titerate\n");
319 printf ("-d\tdump\n");
320 printf ("-h\thelp\n");
321 printf ("-f\tfilename\n");
322
323 printf ("\nExamples:");
324 printf ("\nt_store -c -w -f t_store.rdb\n");
325 printf ("\tCreate file 't_store.rdb',\n"
326 "\twrite fixed number (1000) of streams.\n");
327 printf ("\nt_store -c -i -d -f t_store.rdb\n");
328 printf ("\tOpen file 't_store.rdb', "
329 "create '/' directory,\n"
330 "\titerate directory tree, "
331 "dump directory info.\n");
332
333 exit (0);
334 }
335
336 if (!aFile.isValid())
337 {
338 eErrCode = aFile.createInMemory();
339 if (eErrCode != store_E_None)
340 {
341 printf ("Error: can't create memory file\n");
342 exit (0);
343 }
344 }
345
346 // Stream Read/Write.
347 OUString aPath ("/");
348 if ((nOptions & OPTION_READ) || (nOptions & OPTION_WRITE))
349 {
350 // Mode.
351 storeAccessMode eMode = store_AccessReadOnly;
352 if (nOptions & OPTION_WRITE)
353 eMode = store_AccessReadWrite;
354 if (nOptions & OPTION_CREAT)
355 eMode = store_AccessCreate;
356
357 // Buffer.
358 char pBuffer[_DEMOSTOR_BUFSIZ] = "Hello World";
359 pBuffer[_DEMOSTOR_BUFSIZ - 2] = 'B';
360 pBuffer[_DEMOSTOR_BUFSIZ - 1] = '\0';
361
362 // Load/Save.
363 #ifndef PROFILE
364 OTime aStartTime (OTime::getSystemTime());
365 #endif /* PROFILE */
366
367 for (int i = 0; i < _DEMOSTOR_LOOPS; i++)
368 {
369 OUString aName ("demostor-");
370 aName += OUString::valueOf ((sal_Int32)(i + 1), 10);
371 aName += OUString(".dat");
372
373 #if (_DEMOSTOR_REMOVE == 1)
374 eErrCode = aFile.remove (aPath, aName);
375 if ((eErrCode != store_E_None ) &&
376 (eErrCode != store_E_NotExists) )
377 break;
378 #endif /* _REMOVE */
379
380 store::OStoreStream aStream;
381 eErrCode = aStream.create (aFile, aPath, aName, eMode);
382 if (eErrCode != store_E_None)
383 {
384 OSL_TRACE("OStoreStream(%d)::create(): error: %d", i, eErrCode);
385 break;
386 }
387
388 if (nOptions & OPTION_TRUNC)
389 {
390 eErrCode = aStream.setSize(0);
391 if (eErrCode != store_E_None)
392 {
393 OSL_TRACE("OStoreStream(%d)::setSize(0): error: %d", i, eErrCode);
394 break;
395 }
396 }
397
398 sal_uInt32 nDone = 0;
399 if (nOptions & OPTION_WRITE)
400 {
401 eErrCode = aStream.writeAt (
402 0, pBuffer, sizeof(pBuffer), nDone);
403 if (eErrCode != store_E_None)
404 {
405 OSL_TRACE("OStoreStream(%d)::writeAt(): error: %d", i, eErrCode);
406 break;
407 }
408 }
409
410 if (nOptions & OPTION_READ)
411 {
412 sal_uInt32 nOffset = 0;
413 for (;;)
414 {
415 eErrCode = aStream.readAt (
416 nOffset, pBuffer, sizeof(pBuffer), nDone);
417 if (eErrCode != store_E_None)
418 {
419 OSL_TRACE("OStoreStream(%d)::readAt(): error: %d", i, eErrCode);
420 break;
421 }
422 if (nDone == 0)
423 break;
424 nOffset += nDone;
425 }
426 }
427
428 aStream.close();
429
430 #ifndef PROFILE
431 if (((i + 1) % (_DEMOSTOR_LOOPS/10)) == 0)
432 {
433 OTime aDelta (OTime::getSystemTime() - aStartTime);
434
435 sal_uInt32 nDelta = aDelta.Seconds * 1000000;
436 nDelta += (aDelta.Nanosec / 1000);
437
438 printf ("%d: %12.4g[usec]\n", (i+1),
439 (double)(nDelta)/(double)(i+1));
440 }
441 #endif /* PROFILE */
442 }
443
444 #ifndef PROFILE
445 OTime aDelta (OTime::getSystemTime() - aStartTime);
446
447 sal_uInt32 nDelta = aDelta.Seconds * 1000000;
448 nDelta += (aDelta.Nanosec / 1000);
449
450 printf ("Total(rd,wr): %d[usec]\n", (unsigned int)(nDelta));
451 #endif /* PROFILE */
452 }
453
454 // Link/Rename.
455 if (nOptions & OPTION_LINK)
456 {
457 // Create symlink to (root) directory.
458 eErrCode = aFile.symlink (
459 aPath, OUString("000000/"),
460 OUString(), aPath);
461 OSL_POSTCOND(
462 ((eErrCode == store_E_None ) ||
463 (eErrCode == store_E_AlreadyExists) ),
464 "t_store::main(): store_symlink() failed");
465
466 // Create symlink to file.
467 OUString aLinkName ("demostor-1.lnk");
468
469 eErrCode = aFile.symlink (
470 aPath, aLinkName,
471 aPath, OUString("demostor-1.dat"));
472 OSL_POSTCOND(
473 ((eErrCode == store_E_None ) ||
474 (eErrCode == store_E_AlreadyExists) ),
475 "t_store::main(): store_symlink() failed");
476 if ((eErrCode == store_E_None ) ||
477 (eErrCode == store_E_AlreadyExists) )
478 {
479 OUString aShortcut (
480 "Shortcut to demostor-1.dat");
481 eErrCode = aFile.rename (
482 aPath, aLinkName,
483 aPath, aShortcut);
484 OSL_POSTCOND(
485 ((eErrCode == store_E_None ) ||
486 (eErrCode == store_E_AlreadyExists) ),
487 "t_store::main(): store_rename() failed");
488 }
489
490 // Create directory.
491 OUString aDirName ("demostor-1.dir");
492 store::OStoreDirectory aDir;
493
494 eErrCode = aDir.create (
495 aFile, aPath, aDirName, store_AccessReadCreate);
496 OSL_POSTCOND(
497 (eErrCode == store_E_None),
498 "t_store::main(): store_createDirectory() failed");
499 if (eErrCode == store_E_None)
500 {
501 }
502 }
503
504 // Directory iteration.
505 if (nOptions & OPTION_ITER)
506 {
507 #ifndef PROFILE
508 OTime aStartTime (OTime::getSystemTime());
509 #endif /* PROFILE */
510 OUString aEmpty;
511
512 // Root directory.
513 store::OStoreDirectory aRootDir;
514 if (nOptions & OPTION_LINK)
515 {
516 // Open symlink entry.
517 eErrCode = aRootDir.create (
518 aFile, aPath, OUString("000000"),
519 store_AccessReadOnly);
520 }
521 else
522 {
523 // Open direct entry.
524 if (nOptions & OPTION_CREAT)
525 eErrCode = aRootDir.create (
526 aFile, aEmpty, aEmpty, store_AccessReadCreate);
527 else if (nOptions & OPTION_WRITE)
528 eErrCode = aRootDir.create (
529 aFile, aEmpty, aEmpty, store_AccessReadWrite);
530 else
531 eErrCode = aRootDir.create (
532 aFile, aEmpty, aEmpty, store_AccessReadOnly);
533 }
534
535 if (eErrCode == store_E_None)
536 {
537 // Traverse directory tree.
538 DirectoryTraveller aTraveller (
539 aFile, aEmpty, aEmpty, nOptions, 0);
540 aRootDir.travel (aTraveller);
541 }
542 else
543 {
544 // Failure.
545 printf ("Error: can't open directory: \"/\"\n");
546 }
547
548 #ifndef PROFILE
549 OTime aDelta (OTime::getSystemTime() - aStartTime);
550
551 sal_uInt32 nDelta = aDelta.Seconds * 1000000;
552 nDelta += (aDelta.Nanosec / 1000);
553
554 printf ("Total(iter): %d[usec]\n", (unsigned int)(nDelta));
555 #endif /* PROFILE */
556 }
557
558 if (nOptions & OPTION_PAUSE)
559 {
560 TimeValue tv;
561 tv.Seconds = 300;
562 tv.Nanosec = 0;
563 osl_waitThread (&tv);
564 }
565
566 // Size.
567 sal_uInt32 nSize = 0;
568 aFile.getSize (nSize);
569
570 // Done.
571 aFile.close();
572
573 #if (defined(WNT) && defined(PROFILE))
574 StopCAP();
575 DumpCAP();
576 #endif /* PROFILE */
577 #ifndef PROFILE
578 OTime aDelta (OTime::getSystemTime() - aMainStartTime);
579
580 sal_uInt32 nDelta = aDelta.Seconds * 1000000;
581 nDelta += (aDelta.Nanosec / 1000);
582
583 printf ("Total: %d[usec]\n", (unsigned int)(nDelta));
584 #endif /* PROFILE */
585
586 return 0;
587 }
588
589 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
FREE OFFICE SUITE