173d9b18aSAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
373d9b18aSAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
473d9b18aSAndrew Rist * or more contributor license agreements. See the NOTICE file
573d9b18aSAndrew Rist * distributed with this work for additional information
673d9b18aSAndrew Rist * regarding copyright ownership. The ASF licenses this file
773d9b18aSAndrew Rist * to you under the Apache License, Version 2.0 (the
873d9b18aSAndrew Rist * "License"); you may not use this file except in compliance
973d9b18aSAndrew Rist * with the License. You may obtain a copy of the License at
1073d9b18aSAndrew Rist *
1173d9b18aSAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
1273d9b18aSAndrew Rist *
1373d9b18aSAndrew Rist * Unless required by applicable law or agreed to in writing,
1473d9b18aSAndrew Rist * software distributed under the License is distributed on an
1573d9b18aSAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
1673d9b18aSAndrew Rist * KIND, either express or implied. See the License for the
1773d9b18aSAndrew Rist * specific language governing permissions and limitations
1873d9b18aSAndrew Rist * under the License.
1973d9b18aSAndrew Rist *
2073d9b18aSAndrew Rist *************************************************************/
2173d9b18aSAndrew Rist
2273d9b18aSAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_store.hxx"
26cdf0e10cSrcweir
27cdf0e10cSrcweir #include "store/store.h"
28ff8369f8SDamjan Jovanovic #include "store/dllapi.h"
29cdf0e10cSrcweir
30cdf0e10cSrcweir #include <sal/types.h>
31cdf0e10cSrcweir #include <rtl/memory.h>
32cdf0e10cSrcweir #include <rtl/string.hxx>
33cdf0e10cSrcweir #include <rtl/ref.hxx>
34cdf0e10cSrcweir
35cdf0e10cSrcweir #include "object.hxx"
36cdf0e10cSrcweir #include "lockbyte.hxx"
37cdf0e10cSrcweir
38cdf0e10cSrcweir #include "storbase.hxx"
39cdf0e10cSrcweir #include "storpage.hxx"
40cdf0e10cSrcweir #include "stordir.hxx"
41cdf0e10cSrcweir #include "storlckb.hxx"
42cdf0e10cSrcweir
43cdf0e10cSrcweir using rtl::Reference;
44cdf0e10cSrcweir using rtl::OString;
45cdf0e10cSrcweir
46cdf0e10cSrcweir namespace store
47cdf0e10cSrcweir {
48cdf0e10cSrcweir /** Template helper class as type safe Reference to store_handle_type.
49cdf0e10cSrcweir */
50cdf0e10cSrcweir template<class store_handle_type>
51cdf0e10cSrcweir class OStoreHandle : public rtl::Reference<store_handle_type>
52cdf0e10cSrcweir {
53cdf0e10cSrcweir public:
OStoreHandle(store_handle_type * pHandle)54cdf0e10cSrcweir OStoreHandle (store_handle_type * pHandle)
55cdf0e10cSrcweir : rtl::Reference<store_handle_type> (pHandle)
56cdf0e10cSrcweir {}
57cdf0e10cSrcweir
query(void * pHandle)58cdf0e10cSrcweir static store_handle_type * SAL_CALL query (void * pHandle)
59cdf0e10cSrcweir {
60cdf0e10cSrcweir return store::query (
61cdf0e10cSrcweir static_cast<IStoreHandle*>(pHandle),
62cdf0e10cSrcweir static_cast<store_handle_type*>(0));
63cdf0e10cSrcweir }
64cdf0e10cSrcweir };
65cdf0e10cSrcweir }
66cdf0e10cSrcweir
67cdf0e10cSrcweir
68cdf0e10cSrcweir using namespace store;
69cdf0e10cSrcweir
70cdf0e10cSrcweir /*========================================================================
71cdf0e10cSrcweir *
72cdf0e10cSrcweir * storeHandle implementation.
73cdf0e10cSrcweir *
74cdf0e10cSrcweir *======================================================================*/
75cdf0e10cSrcweir /*
76cdf0e10cSrcweir * store_acquireHandle.
77cdf0e10cSrcweir */
store_acquireHandle(storeHandle Handle)78*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_acquireHandle (
79cdf0e10cSrcweir storeHandle Handle
80cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
81cdf0e10cSrcweir {
82cdf0e10cSrcweir IStoreHandle *pHandle = static_cast<IStoreHandle*>(Handle);
83cdf0e10cSrcweir if (!pHandle)
84cdf0e10cSrcweir return store_E_InvalidHandle;
85cdf0e10cSrcweir
86cdf0e10cSrcweir pHandle->acquire();
87cdf0e10cSrcweir return store_E_None;
88cdf0e10cSrcweir }
89cdf0e10cSrcweir
90cdf0e10cSrcweir /*
91cdf0e10cSrcweir * store_releaseHandle.
92cdf0e10cSrcweir */
store_releaseHandle(storeHandle Handle)93*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_releaseHandle (
94cdf0e10cSrcweir storeHandle Handle
95cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
96cdf0e10cSrcweir {
97cdf0e10cSrcweir IStoreHandle *pHandle = static_cast<IStoreHandle*>(Handle);
98cdf0e10cSrcweir if (!pHandle)
99cdf0e10cSrcweir return store_E_InvalidHandle;
100cdf0e10cSrcweir
101cdf0e10cSrcweir pHandle->release();
102cdf0e10cSrcweir return store_E_None;
103cdf0e10cSrcweir }
104cdf0e10cSrcweir
105cdf0e10cSrcweir /*========================================================================
106cdf0e10cSrcweir *
107cdf0e10cSrcweir * storeFileHandle implementation.
108cdf0e10cSrcweir *
109cdf0e10cSrcweir *======================================================================*/
110cdf0e10cSrcweir /*
111cdf0e10cSrcweir * store_createMemoryFile.
112cdf0e10cSrcweir */
store_createMemoryFile(sal_uInt16 nPageSize,storeFileHandle * phFile)113*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_createMemoryFile (
114cdf0e10cSrcweir sal_uInt16 nPageSize,
115cdf0e10cSrcweir storeFileHandle *phFile
116cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
117cdf0e10cSrcweir {
118cdf0e10cSrcweir if (!phFile)
119cdf0e10cSrcweir return store_E_InvalidParameter;
120cdf0e10cSrcweir *phFile = NULL;
121cdf0e10cSrcweir
122cdf0e10cSrcweir Reference<ILockBytes> xLockBytes;
123cdf0e10cSrcweir
124cdf0e10cSrcweir storeError eErrCode = MemoryLockBytes_createInstance(xLockBytes);
125cdf0e10cSrcweir if (eErrCode != store_E_None)
126cdf0e10cSrcweir return eErrCode;
127cdf0e10cSrcweir OSL_ASSERT(xLockBytes.is());
128cdf0e10cSrcweir
129cdf0e10cSrcweir Reference<OStorePageManager> xManager (new OStorePageManager());
130cdf0e10cSrcweir if (!xManager.is())
131cdf0e10cSrcweir return store_E_OutOfMemory;
132cdf0e10cSrcweir
133cdf0e10cSrcweir eErrCode = xManager->initialize (
134cdf0e10cSrcweir &*xLockBytes, store_AccessCreate, nPageSize);
135cdf0e10cSrcweir if (eErrCode != store_E_None)
136cdf0e10cSrcweir return eErrCode;
137cdf0e10cSrcweir
138cdf0e10cSrcweir xManager->acquire();
139cdf0e10cSrcweir
140cdf0e10cSrcweir *phFile = (storeFileHandle)&(*xManager);
141cdf0e10cSrcweir return store_E_None;
142cdf0e10cSrcweir }
143cdf0e10cSrcweir
144cdf0e10cSrcweir /*
145cdf0e10cSrcweir * store_openFile.
146cdf0e10cSrcweir */
store_openFile(rtl_uString * pFilename,storeAccessMode eAccessMode,sal_uInt16 nPageSize,storeFileHandle * phFile)147*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_openFile (
148cdf0e10cSrcweir rtl_uString *pFilename,
149cdf0e10cSrcweir storeAccessMode eAccessMode,
150cdf0e10cSrcweir sal_uInt16 nPageSize,
151cdf0e10cSrcweir storeFileHandle *phFile
152cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
153cdf0e10cSrcweir {
154cdf0e10cSrcweir if (phFile)
155cdf0e10cSrcweir *phFile = NULL;
156cdf0e10cSrcweir
157cdf0e10cSrcweir if (!(pFilename && phFile))
158cdf0e10cSrcweir return store_E_InvalidParameter;
159cdf0e10cSrcweir
160cdf0e10cSrcweir Reference<ILockBytes> xLockBytes;
161cdf0e10cSrcweir
162cdf0e10cSrcweir storeError eErrCode = FileLockBytes_createInstance (xLockBytes, pFilename, eAccessMode);
163cdf0e10cSrcweir if (eErrCode != store_E_None)
164cdf0e10cSrcweir return eErrCode;
165cdf0e10cSrcweir OSL_ASSERT(xLockBytes.is());
166cdf0e10cSrcweir
167cdf0e10cSrcweir Reference<OStorePageManager> xManager (new OStorePageManager());
168cdf0e10cSrcweir if (!xManager.is())
169cdf0e10cSrcweir return store_E_OutOfMemory;
170cdf0e10cSrcweir
171cdf0e10cSrcweir eErrCode = xManager->initialize (
172cdf0e10cSrcweir &*xLockBytes, eAccessMode, nPageSize);
173cdf0e10cSrcweir if (eErrCode != store_E_None)
174cdf0e10cSrcweir return eErrCode;
175cdf0e10cSrcweir
176cdf0e10cSrcweir xManager->acquire();
177cdf0e10cSrcweir
178cdf0e10cSrcweir *phFile = (storeFileHandle)&(*xManager);
179cdf0e10cSrcweir return store_E_None;
180cdf0e10cSrcweir }
181cdf0e10cSrcweir
182cdf0e10cSrcweir /*
183cdf0e10cSrcweir * store_closeFile.
184cdf0e10cSrcweir */
store_closeFile(storeFileHandle Handle)185*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_closeFile (
186cdf0e10cSrcweir storeFileHandle Handle
187cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
188cdf0e10cSrcweir {
189cdf0e10cSrcweir OStorePageManager *pManager =
190cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle);
191cdf0e10cSrcweir if (!pManager)
192cdf0e10cSrcweir return store_E_InvalidHandle;
193cdf0e10cSrcweir
194cdf0e10cSrcweir storeError eErrCode = pManager->close();
195cdf0e10cSrcweir pManager->release();
196cdf0e10cSrcweir return eErrCode;
197cdf0e10cSrcweir }
198cdf0e10cSrcweir
199cdf0e10cSrcweir /*
200cdf0e10cSrcweir * store_flushFile.
201cdf0e10cSrcweir */
store_flushFile(storeFileHandle Handle)202*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_flushFile (
203cdf0e10cSrcweir storeFileHandle Handle
204cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
205cdf0e10cSrcweir {
206cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
207cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle));
208cdf0e10cSrcweir if (!xManager.is())
209cdf0e10cSrcweir return store_E_InvalidHandle;
210cdf0e10cSrcweir
211cdf0e10cSrcweir return xManager->flush();
212cdf0e10cSrcweir }
213cdf0e10cSrcweir
214cdf0e10cSrcweir /*
215cdf0e10cSrcweir * store_getFileRefererCount.
216cdf0e10cSrcweir */
store_getFileRefererCount(storeFileHandle Handle,sal_uInt32 * pnRefCount)217*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_getFileRefererCount (
218cdf0e10cSrcweir storeFileHandle Handle,
219cdf0e10cSrcweir sal_uInt32 *pnRefCount
220cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
221cdf0e10cSrcweir {
222cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
223cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle));
224cdf0e10cSrcweir if (!xManager.is())
225cdf0e10cSrcweir return store_E_InvalidHandle;
226cdf0e10cSrcweir
227cdf0e10cSrcweir if (!pnRefCount)
228cdf0e10cSrcweir return store_E_InvalidParameter;
229cdf0e10cSrcweir
230cdf0e10cSrcweir *pnRefCount = xManager->getRefererCount();
231cdf0e10cSrcweir return store_E_None;
232cdf0e10cSrcweir }
233cdf0e10cSrcweir
234cdf0e10cSrcweir /*
235cdf0e10cSrcweir * store_getFileSize.
236cdf0e10cSrcweir */
store_getFileSize(storeFileHandle Handle,sal_uInt32 * pnSize)237*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_getFileSize (
238cdf0e10cSrcweir storeFileHandle Handle,
239cdf0e10cSrcweir sal_uInt32 *pnSize
240cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
241cdf0e10cSrcweir {
242cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
243cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle));
244cdf0e10cSrcweir if (!xManager.is())
245cdf0e10cSrcweir return store_E_InvalidHandle;
246cdf0e10cSrcweir
247cdf0e10cSrcweir if (!pnSize)
248cdf0e10cSrcweir return store_E_InvalidParameter;
249cdf0e10cSrcweir
250cdf0e10cSrcweir return xManager->size (*pnSize);
251cdf0e10cSrcweir }
252cdf0e10cSrcweir
253cdf0e10cSrcweir /*
254cdf0e10cSrcweir * store_rebuildFile.
255cdf0e10cSrcweir */
store_rebuildFile(rtl_uString * pSrcFilename,rtl_uString * pDstFilename)256*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_rebuildFile (
257cdf0e10cSrcweir rtl_uString *pSrcFilename,
258cdf0e10cSrcweir rtl_uString *pDstFilename
259cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
260cdf0e10cSrcweir {
261cdf0e10cSrcweir storeError eErrCode = store_E_None;
262cdf0e10cSrcweir
263cdf0e10cSrcweir if (!(pSrcFilename && pDstFilename))
264cdf0e10cSrcweir return store_E_InvalidParameter;
265cdf0e10cSrcweir
266cdf0e10cSrcweir Reference<OStorePageManager> xManager (new OStorePageManager());
267cdf0e10cSrcweir if (!xManager.is())
268cdf0e10cSrcweir return store_E_OutOfMemory;
269cdf0e10cSrcweir
270cdf0e10cSrcweir Reference<ILockBytes> xSrcLB;
271cdf0e10cSrcweir eErrCode = FileLockBytes_createInstance (xSrcLB, pSrcFilename, store_AccessReadOnly);
272cdf0e10cSrcweir if (eErrCode != store_E_None)
273cdf0e10cSrcweir return eErrCode;
274cdf0e10cSrcweir OSL_ASSERT(xSrcLB.is());
275cdf0e10cSrcweir
276cdf0e10cSrcweir Reference<ILockBytes> xDstLB;
277cdf0e10cSrcweir eErrCode = FileLockBytes_createInstance (xDstLB, pDstFilename, store_AccessCreate);
278cdf0e10cSrcweir if (eErrCode != store_E_None)
279cdf0e10cSrcweir return eErrCode;
280cdf0e10cSrcweir OSL_ASSERT(xDstLB.is());
281cdf0e10cSrcweir
282cdf0e10cSrcweir return xManager->rebuild (&*xSrcLB, &*xDstLB);
283cdf0e10cSrcweir }
284cdf0e10cSrcweir
285cdf0e10cSrcweir /*========================================================================
286cdf0e10cSrcweir *
287cdf0e10cSrcweir * storeDirectoryHandle implementation.
288cdf0e10cSrcweir *
289cdf0e10cSrcweir *======================================================================*/
290cdf0e10cSrcweir /*
291cdf0e10cSrcweir * store_openDirectory.
292cdf0e10cSrcweir */
store_openDirectory(storeFileHandle hFile,rtl_uString * pPath,rtl_uString * pName,storeAccessMode eAccessMode,storeDirectoryHandle * phDirectory)293*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_openDirectory (
294cdf0e10cSrcweir storeFileHandle hFile,
295cdf0e10cSrcweir rtl_uString *pPath,
296cdf0e10cSrcweir rtl_uString *pName,
297cdf0e10cSrcweir storeAccessMode eAccessMode,
298cdf0e10cSrcweir storeDirectoryHandle *phDirectory
299cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
300cdf0e10cSrcweir {
301cdf0e10cSrcweir storeError eErrCode = store_E_None;
302cdf0e10cSrcweir if (phDirectory)
303cdf0e10cSrcweir *phDirectory = NULL;
304cdf0e10cSrcweir
305cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
306cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (hFile));
307cdf0e10cSrcweir if (!xManager.is())
308cdf0e10cSrcweir return store_E_InvalidHandle;
309cdf0e10cSrcweir
310cdf0e10cSrcweir if (!(pPath && pName && phDirectory))
311cdf0e10cSrcweir return store_E_InvalidParameter;
312cdf0e10cSrcweir
313cdf0e10cSrcweir Reference<OStoreDirectory_Impl> xDirectory (new OStoreDirectory_Impl());
314cdf0e10cSrcweir if (!xDirectory.is())
315cdf0e10cSrcweir return store_E_OutOfMemory;
316cdf0e10cSrcweir
317cdf0e10cSrcweir OString aPath (pPath->buffer, pPath->length, RTL_TEXTENCODING_UTF8);
318cdf0e10cSrcweir OString aName (pName->buffer, pName->length, RTL_TEXTENCODING_UTF8);
319cdf0e10cSrcweir
320cdf0e10cSrcweir eErrCode = xDirectory->create (&*xManager, aPath.pData, aName.pData, eAccessMode);
321cdf0e10cSrcweir if (eErrCode != store_E_None)
322cdf0e10cSrcweir return eErrCode;
323cdf0e10cSrcweir
324cdf0e10cSrcweir xDirectory->acquire();
325cdf0e10cSrcweir
326cdf0e10cSrcweir *phDirectory = (storeDirectoryHandle)&(*xDirectory);
327cdf0e10cSrcweir return store_E_None;
328cdf0e10cSrcweir }
329cdf0e10cSrcweir
330cdf0e10cSrcweir /*
331cdf0e10cSrcweir * store_closeDirectory.
332cdf0e10cSrcweir */
store_closeDirectory(storeDirectoryHandle Handle)333*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_closeDirectory (
334cdf0e10cSrcweir storeDirectoryHandle Handle
335cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
336cdf0e10cSrcweir {
337cdf0e10cSrcweir OStoreDirectory_Impl *pDirectory =
338cdf0e10cSrcweir OStoreHandle<OStoreDirectory_Impl>::query (Handle);
339cdf0e10cSrcweir if (!pDirectory)
340cdf0e10cSrcweir return store_E_InvalidHandle;
341cdf0e10cSrcweir
342cdf0e10cSrcweir pDirectory->release();
343cdf0e10cSrcweir return store_E_None;
344cdf0e10cSrcweir }
345cdf0e10cSrcweir
346cdf0e10cSrcweir /*
347cdf0e10cSrcweir * store_findFirst.
348cdf0e10cSrcweir */
store_findFirst(storeDirectoryHandle Handle,storeFindData * pFindData)349*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_findFirst (
350cdf0e10cSrcweir storeDirectoryHandle Handle,
351cdf0e10cSrcweir storeFindData *pFindData
352cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
353cdf0e10cSrcweir {
354cdf0e10cSrcweir OStoreHandle<OStoreDirectory_Impl> xDirectory (
355cdf0e10cSrcweir OStoreHandle<OStoreDirectory_Impl>::query (Handle));
356cdf0e10cSrcweir if (!xDirectory.is())
357cdf0e10cSrcweir return store_E_InvalidHandle;
358cdf0e10cSrcweir
359cdf0e10cSrcweir if (!pFindData)
360cdf0e10cSrcweir return store_E_InvalidParameter;
361cdf0e10cSrcweir
362cdf0e10cSrcweir // Initialize FindData.
363cdf0e10cSrcweir rtl_zeroMemory (pFindData, sizeof (storeFindData));
364cdf0e10cSrcweir
365cdf0e10cSrcweir // Find first.
366cdf0e10cSrcweir pFindData->m_nReserved = (sal_uInt32)(~0);
367cdf0e10cSrcweir return xDirectory->iterate (*pFindData);
368cdf0e10cSrcweir }
369cdf0e10cSrcweir
370cdf0e10cSrcweir /*
371cdf0e10cSrcweir * store_findNext.
372cdf0e10cSrcweir */
store_findNext(storeDirectoryHandle Handle,storeFindData * pFindData)373*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_findNext (
374cdf0e10cSrcweir storeDirectoryHandle Handle,
375cdf0e10cSrcweir storeFindData *pFindData
376cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
377cdf0e10cSrcweir {
378cdf0e10cSrcweir OStoreHandle<OStoreDirectory_Impl> xDirectory (
379cdf0e10cSrcweir OStoreHandle<OStoreDirectory_Impl>::query (Handle));
380cdf0e10cSrcweir if (!xDirectory.is())
381cdf0e10cSrcweir return store_E_InvalidHandle;
382cdf0e10cSrcweir
383cdf0e10cSrcweir if (!pFindData)
384cdf0e10cSrcweir return store_E_InvalidParameter;
385cdf0e10cSrcweir
386cdf0e10cSrcweir // Check FindData.
387cdf0e10cSrcweir if (!pFindData->m_nReserved)
388cdf0e10cSrcweir return store_E_NoMoreFiles;
389cdf0e10cSrcweir
390cdf0e10cSrcweir // Find next.
391cdf0e10cSrcweir pFindData->m_nReserved -= 1;
392cdf0e10cSrcweir return xDirectory->iterate (*pFindData);
393cdf0e10cSrcweir }
394cdf0e10cSrcweir
395cdf0e10cSrcweir /*========================================================================
396cdf0e10cSrcweir *
397cdf0e10cSrcweir * storeStreamHandle implementation.
398cdf0e10cSrcweir *
399cdf0e10cSrcweir *======================================================================*/
400cdf0e10cSrcweir /*
401cdf0e10cSrcweir * store_openStream
402cdf0e10cSrcweir */
store_openStream(storeFileHandle hFile,rtl_uString * pPath,rtl_uString * pName,storeAccessMode eAccessMode,storeStreamHandle * phStream)403*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_openStream (
404cdf0e10cSrcweir storeFileHandle hFile,
405cdf0e10cSrcweir rtl_uString *pPath,
406cdf0e10cSrcweir rtl_uString *pName,
407cdf0e10cSrcweir storeAccessMode eAccessMode,
408cdf0e10cSrcweir storeStreamHandle *phStream
409cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
410cdf0e10cSrcweir {
411cdf0e10cSrcweir storeError eErrCode = store_E_None;
412cdf0e10cSrcweir if (phStream)
413cdf0e10cSrcweir *phStream = NULL;
414cdf0e10cSrcweir
415cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
416cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (hFile));
417cdf0e10cSrcweir if (!xManager.is())
418cdf0e10cSrcweir return store_E_InvalidHandle;
419cdf0e10cSrcweir
420cdf0e10cSrcweir if (!(pPath && pName && phStream))
421cdf0e10cSrcweir return store_E_InvalidParameter;
422cdf0e10cSrcweir
423cdf0e10cSrcweir Reference<OStoreLockBytes> xLockBytes (new OStoreLockBytes());
424cdf0e10cSrcweir if (!xLockBytes.is())
425cdf0e10cSrcweir return store_E_OutOfMemory;
426cdf0e10cSrcweir
427cdf0e10cSrcweir OString aPath (pPath->buffer, pPath->length, RTL_TEXTENCODING_UTF8);
428cdf0e10cSrcweir OString aName (pName->buffer, pName->length, RTL_TEXTENCODING_UTF8);
429cdf0e10cSrcweir
430cdf0e10cSrcweir eErrCode = xLockBytes->create (&*xManager, aPath.pData, aName.pData, eAccessMode);
431cdf0e10cSrcweir if (eErrCode != store_E_None)
432cdf0e10cSrcweir return eErrCode;
433cdf0e10cSrcweir
434cdf0e10cSrcweir xLockBytes->acquire();
435cdf0e10cSrcweir
436cdf0e10cSrcweir *phStream = (storeStreamHandle)&(*xLockBytes);
437cdf0e10cSrcweir return store_E_None;
438cdf0e10cSrcweir }
439cdf0e10cSrcweir
440cdf0e10cSrcweir /*
441cdf0e10cSrcweir * store_closeStream.
442cdf0e10cSrcweir */
store_closeStream(storeStreamHandle Handle)443*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_closeStream (
444cdf0e10cSrcweir storeStreamHandle Handle
445cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
446cdf0e10cSrcweir {
447cdf0e10cSrcweir OStoreLockBytes *pLockBytes =
448cdf0e10cSrcweir OStoreHandle<OStoreLockBytes>::query (Handle);
449cdf0e10cSrcweir if (!pLockBytes)
450cdf0e10cSrcweir return store_E_InvalidHandle;
451cdf0e10cSrcweir
452cdf0e10cSrcweir pLockBytes->release();
453cdf0e10cSrcweir return store_E_None;
454cdf0e10cSrcweir }
455cdf0e10cSrcweir
456cdf0e10cSrcweir /*
457cdf0e10cSrcweir * store_readStream.
458cdf0e10cSrcweir */
store_readStream(storeStreamHandle Handle,sal_uInt32 nOffset,void * pBuffer,sal_uInt32 nBytes,sal_uInt32 * pnDone)459*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_readStream (
460cdf0e10cSrcweir storeStreamHandle Handle,
461cdf0e10cSrcweir sal_uInt32 nOffset,
462cdf0e10cSrcweir void *pBuffer,
463cdf0e10cSrcweir sal_uInt32 nBytes,
464cdf0e10cSrcweir sal_uInt32 *pnDone
465cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
466cdf0e10cSrcweir {
467cdf0e10cSrcweir OStoreHandle<OStoreLockBytes> xLockBytes (
468cdf0e10cSrcweir OStoreHandle<OStoreLockBytes>::query (Handle));
469cdf0e10cSrcweir if (!xLockBytes.is())
470cdf0e10cSrcweir return store_E_InvalidHandle;
471cdf0e10cSrcweir
472cdf0e10cSrcweir if (!(pBuffer && pnDone))
473cdf0e10cSrcweir return store_E_InvalidParameter;
474cdf0e10cSrcweir
475cdf0e10cSrcweir return xLockBytes->readAt (nOffset, pBuffer, nBytes, *pnDone);
476cdf0e10cSrcweir }
477cdf0e10cSrcweir
478cdf0e10cSrcweir /*
479cdf0e10cSrcweir * store_writeStream.
480cdf0e10cSrcweir */
store_writeStream(storeStreamHandle Handle,sal_uInt32 nOffset,const void * pBuffer,sal_uInt32 nBytes,sal_uInt32 * pnDone)481*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_writeStream (
482cdf0e10cSrcweir storeStreamHandle Handle,
483cdf0e10cSrcweir sal_uInt32 nOffset,
484cdf0e10cSrcweir const void *pBuffer,
485cdf0e10cSrcweir sal_uInt32 nBytes,
486cdf0e10cSrcweir sal_uInt32 *pnDone
487cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
488cdf0e10cSrcweir {
489cdf0e10cSrcweir OStoreHandle<OStoreLockBytes> xLockBytes (
490cdf0e10cSrcweir OStoreHandle<OStoreLockBytes>::query (Handle));
491cdf0e10cSrcweir if (!xLockBytes.is())
492cdf0e10cSrcweir return store_E_InvalidHandle;
493cdf0e10cSrcweir
494cdf0e10cSrcweir if (!(pBuffer && pnDone))
495cdf0e10cSrcweir return store_E_InvalidParameter;
496cdf0e10cSrcweir
497cdf0e10cSrcweir return xLockBytes->writeAt (nOffset, pBuffer, nBytes, *pnDone);
498cdf0e10cSrcweir }
499cdf0e10cSrcweir
500cdf0e10cSrcweir /*
501cdf0e10cSrcweir * store_flushStream.
502cdf0e10cSrcweir */
store_flushStream(storeStreamHandle Handle)503*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_flushStream (
504cdf0e10cSrcweir storeStreamHandle Handle
505cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
506cdf0e10cSrcweir {
507cdf0e10cSrcweir OStoreHandle<OStoreLockBytes> xLockBytes (
508cdf0e10cSrcweir OStoreHandle<OStoreLockBytes>::query (Handle));
509cdf0e10cSrcweir if (!xLockBytes.is())
510cdf0e10cSrcweir return store_E_InvalidHandle;
511cdf0e10cSrcweir
512cdf0e10cSrcweir return xLockBytes->flush();
513cdf0e10cSrcweir }
514cdf0e10cSrcweir
515cdf0e10cSrcweir /*
516cdf0e10cSrcweir * store_getStreamSize.
517cdf0e10cSrcweir */
store_getStreamSize(storeStreamHandle Handle,sal_uInt32 * pnSize)518*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_getStreamSize (
519cdf0e10cSrcweir storeStreamHandle Handle,
520cdf0e10cSrcweir sal_uInt32 *pnSize
521cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
522cdf0e10cSrcweir {
523cdf0e10cSrcweir OStoreHandle<OStoreLockBytes> xLockBytes (
524cdf0e10cSrcweir OStoreHandle<OStoreLockBytes>::query (Handle));
525cdf0e10cSrcweir if (!xLockBytes.is())
526cdf0e10cSrcweir return store_E_InvalidHandle;
527cdf0e10cSrcweir
528cdf0e10cSrcweir if (!pnSize)
529cdf0e10cSrcweir return store_E_InvalidParameter;
530cdf0e10cSrcweir
531cdf0e10cSrcweir return xLockBytes->stat (*pnSize);
532cdf0e10cSrcweir }
533cdf0e10cSrcweir
534cdf0e10cSrcweir /*
535cdf0e10cSrcweir * store_setStreamSize.
536cdf0e10cSrcweir */
store_setStreamSize(storeStreamHandle Handle,sal_uInt32 nSize)537*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_setStreamSize (
538cdf0e10cSrcweir storeStreamHandle Handle,
539cdf0e10cSrcweir sal_uInt32 nSize
540cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
541cdf0e10cSrcweir {
542cdf0e10cSrcweir OStoreHandle<OStoreLockBytes> xLockBytes (
543cdf0e10cSrcweir OStoreHandle<OStoreLockBytes>::query (Handle));
544cdf0e10cSrcweir if (!xLockBytes.is())
545cdf0e10cSrcweir return store_E_InvalidHandle;
546cdf0e10cSrcweir
547cdf0e10cSrcweir return xLockBytes->setSize (nSize);
548cdf0e10cSrcweir }
549cdf0e10cSrcweir
550cdf0e10cSrcweir /*========================================================================
551cdf0e10cSrcweir *
552cdf0e10cSrcweir * Common storeDirectoryHandle and storeStreamHandle operations.
553cdf0e10cSrcweir *
554cdf0e10cSrcweir *======================================================================*/
555cdf0e10cSrcweir /*
556cdf0e10cSrcweir * store_attrib.
557cdf0e10cSrcweir */
store_attrib(storeFileHandle Handle,rtl_uString * pPath,rtl_uString * pName,sal_uInt32 nMask1,sal_uInt32 nMask2,sal_uInt32 * pnAttrib)558*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_attrib (
559cdf0e10cSrcweir storeFileHandle Handle,
560cdf0e10cSrcweir rtl_uString *pPath,
561cdf0e10cSrcweir rtl_uString *pName,
562cdf0e10cSrcweir sal_uInt32 nMask1,
563cdf0e10cSrcweir sal_uInt32 nMask2,
564cdf0e10cSrcweir sal_uInt32 *pnAttrib
565cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
566cdf0e10cSrcweir {
567cdf0e10cSrcweir storeError eErrCode = store_E_None;
568cdf0e10cSrcweir if (pnAttrib)
569cdf0e10cSrcweir *pnAttrib = 0;
570cdf0e10cSrcweir
571cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
572cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle));
573cdf0e10cSrcweir if (!xManager.is())
574cdf0e10cSrcweir return store_E_InvalidHandle;
575cdf0e10cSrcweir
576cdf0e10cSrcweir if (!(pPath && pName))
577cdf0e10cSrcweir return store_E_InvalidParameter;
578cdf0e10cSrcweir
579cdf0e10cSrcweir // Setup page key.
580cdf0e10cSrcweir OString aPath (pPath->buffer, pPath->length, RTL_TEXTENCODING_UTF8);
581cdf0e10cSrcweir OString aName (pName->buffer, pName->length, RTL_TEXTENCODING_UTF8);
582cdf0e10cSrcweir OStorePageKey aKey;
583cdf0e10cSrcweir
584cdf0e10cSrcweir eErrCode = OStorePageManager::namei (aPath.pData, aName.pData, aKey);
585cdf0e10cSrcweir if (eErrCode != store_E_None)
586cdf0e10cSrcweir return eErrCode;
587cdf0e10cSrcweir
588cdf0e10cSrcweir // Obtain or modify page attributes.
589cdf0e10cSrcweir sal_uInt32 nAttrib = 0;
590cdf0e10cSrcweir eErrCode = xManager->attrib (aKey, nMask1, nMask2, nAttrib);
591cdf0e10cSrcweir if (pnAttrib)
592cdf0e10cSrcweir *pnAttrib = nAttrib;
593cdf0e10cSrcweir return eErrCode;
594cdf0e10cSrcweir }
595cdf0e10cSrcweir
596cdf0e10cSrcweir /*
597cdf0e10cSrcweir * store_link.
598cdf0e10cSrcweir */
store_link(storeFileHandle Handle,rtl_uString * pSrcPath,rtl_uString * pSrcName,rtl_uString * pDstPath,rtl_uString * pDstName)599*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_link (
600cdf0e10cSrcweir storeFileHandle Handle,
601cdf0e10cSrcweir rtl_uString *pSrcPath, rtl_uString *pSrcName,
602cdf0e10cSrcweir rtl_uString *pDstPath, rtl_uString *pDstName
603cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
604cdf0e10cSrcweir {
605cdf0e10cSrcweir storeError eErrCode = store_E_None;
606cdf0e10cSrcweir
607cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
608cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle));
609cdf0e10cSrcweir if (!xManager.is())
610cdf0e10cSrcweir return store_E_InvalidHandle;
611cdf0e10cSrcweir
612cdf0e10cSrcweir if (!(pSrcPath && pSrcName))
613cdf0e10cSrcweir return store_E_InvalidParameter;
614cdf0e10cSrcweir
615cdf0e10cSrcweir if (!(pDstPath && pDstName))
616cdf0e10cSrcweir return store_E_InvalidParameter;
617cdf0e10cSrcweir
618cdf0e10cSrcweir // Setup 'Source' page key.
619cdf0e10cSrcweir OString aSrcPath (
620cdf0e10cSrcweir pSrcPath->buffer, pSrcPath->length, RTL_TEXTENCODING_UTF8);
621cdf0e10cSrcweir OString aSrcName (
622cdf0e10cSrcweir pSrcName->buffer, pSrcName->length, RTL_TEXTENCODING_UTF8);
623cdf0e10cSrcweir OStorePageKey aSrcKey;
624cdf0e10cSrcweir
625cdf0e10cSrcweir eErrCode = OStorePageManager::namei (
626cdf0e10cSrcweir aSrcPath.pData, aSrcName.pData, aSrcKey);
627cdf0e10cSrcweir if (eErrCode != store_E_None)
628cdf0e10cSrcweir return eErrCode;
629cdf0e10cSrcweir
630cdf0e10cSrcweir // Setup 'Destination' page key.
631cdf0e10cSrcweir OString aDstPath (
632cdf0e10cSrcweir pDstPath->buffer, pDstPath->length, RTL_TEXTENCODING_UTF8);
633cdf0e10cSrcweir OString aDstName (
634cdf0e10cSrcweir pDstName->buffer, pDstName->length, RTL_TEXTENCODING_UTF8);
635cdf0e10cSrcweir OStorePageKey aDstKey;
636cdf0e10cSrcweir
637cdf0e10cSrcweir eErrCode = OStorePageManager::namei (
638cdf0e10cSrcweir aDstPath.pData, aDstName.pData, aDstKey);
639cdf0e10cSrcweir if (eErrCode != store_E_None)
640cdf0e10cSrcweir return eErrCode;
641cdf0e10cSrcweir
642cdf0e10cSrcweir // Link 'Source' hard to 'Destination'.
643cdf0e10cSrcweir return xManager->link (aSrcKey, aDstKey);
644cdf0e10cSrcweir }
645cdf0e10cSrcweir
646cdf0e10cSrcweir /*
647cdf0e10cSrcweir * store_symlink.
648cdf0e10cSrcweir */
store_symlink(storeFileHandle Handle,rtl_uString * pSrcPath,rtl_uString * pSrcName,rtl_uString * pDstPath,rtl_uString * pDstName)649*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_symlink (
650cdf0e10cSrcweir storeFileHandle Handle,
651cdf0e10cSrcweir rtl_uString *pSrcPath, rtl_uString *pSrcName,
652cdf0e10cSrcweir rtl_uString *pDstPath, rtl_uString *pDstName
653cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
654cdf0e10cSrcweir {
655cdf0e10cSrcweir storeError eErrCode = store_E_None;
656cdf0e10cSrcweir
657cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
658cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle));
659cdf0e10cSrcweir if (!xManager.is())
660cdf0e10cSrcweir return store_E_InvalidHandle;
661cdf0e10cSrcweir
662cdf0e10cSrcweir if (!(pSrcPath && pSrcName))
663cdf0e10cSrcweir return store_E_InvalidParameter;
664cdf0e10cSrcweir
665cdf0e10cSrcweir if (!(pDstPath && pDstName))
666cdf0e10cSrcweir return store_E_InvalidParameter;
667cdf0e10cSrcweir
668cdf0e10cSrcweir // Setup 'Destination' page key.
669cdf0e10cSrcweir OString aDstPath (
670cdf0e10cSrcweir pDstPath->buffer, pDstPath->length, RTL_TEXTENCODING_UTF8);
671cdf0e10cSrcweir OString aDstName (
672cdf0e10cSrcweir pDstName->buffer, pDstName->length, RTL_TEXTENCODING_UTF8);
673cdf0e10cSrcweir OStorePageKey aDstKey;
674cdf0e10cSrcweir
675cdf0e10cSrcweir eErrCode = OStorePageManager::namei (
676cdf0e10cSrcweir aDstPath.pData, aDstName.pData, aDstKey);
677cdf0e10cSrcweir if (eErrCode != store_E_None)
678cdf0e10cSrcweir return eErrCode;
679cdf0e10cSrcweir
680cdf0e10cSrcweir // Insert 'Source' as symlink to 'Destination'.
681cdf0e10cSrcweir OString aSrcPath (
682cdf0e10cSrcweir pSrcPath->buffer, pSrcPath->length, RTL_TEXTENCODING_UTF8);
683cdf0e10cSrcweir OString aSrcName (
684cdf0e10cSrcweir pSrcName->buffer, pSrcName->length, RTL_TEXTENCODING_UTF8);
685cdf0e10cSrcweir
686cdf0e10cSrcweir return xManager->symlink (aSrcPath.pData, aSrcName.pData, aDstKey);
687cdf0e10cSrcweir }
688cdf0e10cSrcweir
689cdf0e10cSrcweir /*
690cdf0e10cSrcweir * store_rename.
691cdf0e10cSrcweir */
store_rename(storeFileHandle Handle,rtl_uString * pSrcPath,rtl_uString * pSrcName,rtl_uString * pDstPath,rtl_uString * pDstName)692*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_rename (
693cdf0e10cSrcweir storeFileHandle Handle,
694cdf0e10cSrcweir rtl_uString *pSrcPath, rtl_uString *pSrcName,
695cdf0e10cSrcweir rtl_uString *pDstPath, rtl_uString *pDstName
696cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
697cdf0e10cSrcweir {
698cdf0e10cSrcweir storeError eErrCode = store_E_None;
699cdf0e10cSrcweir
700cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
701cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle));
702cdf0e10cSrcweir if (!xManager.is())
703cdf0e10cSrcweir return store_E_InvalidHandle;
704cdf0e10cSrcweir
705cdf0e10cSrcweir if (!(pSrcPath && pSrcName))
706cdf0e10cSrcweir return store_E_InvalidParameter;
707cdf0e10cSrcweir
708cdf0e10cSrcweir if (!(pDstPath && pDstName))
709cdf0e10cSrcweir return store_E_InvalidParameter;
710cdf0e10cSrcweir
711cdf0e10cSrcweir // Setup 'Source' page key.
712cdf0e10cSrcweir OString aSrcPath (
713cdf0e10cSrcweir pSrcPath->buffer, pSrcPath->length, RTL_TEXTENCODING_UTF8);
714cdf0e10cSrcweir OString aSrcName (
715cdf0e10cSrcweir pSrcName->buffer, pSrcName->length, RTL_TEXTENCODING_UTF8);
716cdf0e10cSrcweir OStorePageKey aSrcKey;
717cdf0e10cSrcweir
718cdf0e10cSrcweir eErrCode = OStorePageManager::namei (
719cdf0e10cSrcweir aSrcPath.pData, aSrcName.pData, aSrcKey);
720cdf0e10cSrcweir if (eErrCode != store_E_None)
721cdf0e10cSrcweir return eErrCode;
722cdf0e10cSrcweir
723cdf0e10cSrcweir // Rename 'Source' into 'Destination'.
724cdf0e10cSrcweir OString aDstPath (
725cdf0e10cSrcweir pDstPath->buffer, pDstPath->length, RTL_TEXTENCODING_UTF8);
726cdf0e10cSrcweir OString aDstName (
727cdf0e10cSrcweir pDstName->buffer, pDstName->length, RTL_TEXTENCODING_UTF8);
728cdf0e10cSrcweir
729cdf0e10cSrcweir return xManager->rename (aSrcKey, aDstPath.pData, aDstName.pData);
730cdf0e10cSrcweir }
731cdf0e10cSrcweir
732cdf0e10cSrcweir /*
733cdf0e10cSrcweir * store_remove.
734cdf0e10cSrcweir */
store_remove(storeFileHandle Handle,rtl_uString * pPath,rtl_uString * pName)735*e4baec4cSDamjan Jovanovic storeError SAL_CALL store_remove (
736cdf0e10cSrcweir storeFileHandle Handle,
737cdf0e10cSrcweir rtl_uString *pPath,
738cdf0e10cSrcweir rtl_uString *pName
739cdf0e10cSrcweir ) SAL_THROW_EXTERN_C()
740cdf0e10cSrcweir {
741cdf0e10cSrcweir storeError eErrCode = store_E_None;
742cdf0e10cSrcweir
743cdf0e10cSrcweir OStoreHandle<OStorePageManager> xManager (
744cdf0e10cSrcweir OStoreHandle<OStorePageManager>::query (Handle));
745cdf0e10cSrcweir if (!xManager.is())
746cdf0e10cSrcweir return store_E_InvalidHandle;
747cdf0e10cSrcweir
748cdf0e10cSrcweir if (!(pPath && pName))
749cdf0e10cSrcweir return store_E_InvalidParameter;
750cdf0e10cSrcweir
751cdf0e10cSrcweir // Setup page key.
752cdf0e10cSrcweir OString aPath (pPath->buffer, pPath->length, RTL_TEXTENCODING_UTF8);
753cdf0e10cSrcweir OString aName (pName->buffer, pName->length, RTL_TEXTENCODING_UTF8);
754cdf0e10cSrcweir OStorePageKey aKey;
755cdf0e10cSrcweir
756cdf0e10cSrcweir eErrCode = OStorePageManager::namei (aPath.pData, aName.pData, aKey);
757cdf0e10cSrcweir if (eErrCode != store_E_None)
758cdf0e10cSrcweir return eErrCode;
759cdf0e10cSrcweir
760cdf0e10cSrcweir // Remove.
761cdf0e10cSrcweir return xManager->remove (aKey);
762cdf0e10cSrcweir }
763