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