Adding upstream version 4:7.4.7.upstream/4%7.4.7upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 424 insertions, 0 deletions

diff --git a/store/source/store.cxx b/store/source/store.cxx
new file mode 100644
index 000000000..566efda73
--- /dev/null
+++ b/store/source/store.cxx
@@ -0,0 +1,424 @@
+/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+/*
+ * This file is part of the LibreOffice project.
+ *
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ *
+ * This file incorporates work covered by the following license notice:
+ *
+ *   Licensed to the Apache Software Foundation (ASF) under one or more
+ *   contributor license agreements. See the NOTICE file distributed
+ *   with this work for additional information regarding copyright
+ *   ownership. The ASF licenses this file to you under the Apache
+ *   License, Version 2.0 (the "License"); you may not use this file
+ *   except in compliance with the License. You may obtain a copy of
+ *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
+ */
+
+#include <store/store.h>
+
+#include <sal/types.h>
+#include <rtl/string.hxx>
+#include <rtl/ref.hxx>
+
+#include "object.hxx"
+#include "lockbyte.hxx"
+
+#include "storbase.hxx"
+#include "storpage.hxx"
+#include "stordir.hxx"
+#include "storlckb.hxx"
+
+using rtl::Reference;
+
+namespace store
+{
+
+namespace {
+
+/** Template helper class as type safe Reference to store_handle_type.
+ */
+template<class store_handle_type>
+class OStoreHandle : public rtl::Reference<store_handle_type>
+{
+public:
+    explicit OStoreHandle (store_handle_type * pHandle)
+        : rtl::Reference<store_handle_type> (pHandle)
+    {}
+
+    static store_handle_type * SAL_CALL query (void * pHandle)
+    {
+        return store::query (
+            static_cast<OStoreObject*>(pHandle),
+            static_cast<store_handle_type*>(nullptr));
+    }
+};
+
+}
+
+}
+
+using namespace store;
+
+/*========================================================================
+ *
+ * storeHandle implementation.
+ *
+ *======================================================================*/
+/*
+ * store_acquireHandle.
+ */
+storeError store_acquireHandle (
+    storeHandle Handle
+) SAL_THROW_EXTERN_C()
+{
+    OStoreObject *pHandle = static_cast<OStoreObject*>(Handle);
+    if (!pHandle)
+        return store_E_InvalidHandle;
+
+    pHandle->acquire();
+    return store_E_None;
+}
+
+/*
+ * store_releaseHandle.
+ */
+storeError store_releaseHandle (
+    storeHandle Handle
+) SAL_THROW_EXTERN_C()
+{
+    OStoreObject *pHandle = static_cast<OStoreObject*>(Handle);
+    if (!pHandle)
+        return store_E_InvalidHandle;
+
+    pHandle->release();
+    return store_E_None;
+}
+
+/*========================================================================
+ *
+ * storeFileHandle implementation.
+ *
+ *======================================================================*/
+/*
+ * store_createMemoryFile.
+ */
+storeError store_createMemoryFile (
+    sal_uInt16       nPageSize,
+    storeFileHandle *phFile
+) SAL_THROW_EXTERN_C()
+{
+    if (!phFile)
+        return store_E_InvalidParameter;
+    *phFile = nullptr;
+
+    Reference<ILockBytes> xLockBytes;
+
+    storeError eErrCode = MemoryLockBytes_createInstance(xLockBytes);
+    if (eErrCode != store_E_None)
+        return eErrCode;
+    OSL_ASSERT(xLockBytes.is());
+
+    Reference<OStorePageManager> xManager (new OStorePageManager());
+    if (!xManager.is())
+        return store_E_OutOfMemory;
+
+    eErrCode = xManager->initialize (
+        &*xLockBytes, storeAccessMode::Create, nPageSize);
+    if (eErrCode != store_E_None)
+        return eErrCode;
+
+    xManager->acquire();
+
+    *phFile = xManager.get();
+    return store_E_None;
+}
+
+/*
+ * store_openFile.
+ */
+storeError store_openFile (
+    rtl_uString     *pFilename,
+    storeAccessMode  eAccessMode,
+    sal_uInt16       nPageSize,
+    storeFileHandle *phFile
+) SAL_THROW_EXTERN_C()
+{
+    if (phFile)
+        *phFile = nullptr;
+
+    if (!(pFilename && phFile))
+        return store_E_InvalidParameter;
+
+    Reference<ILockBytes> xLockBytes;
+
+    storeError eErrCode = FileLockBytes_createInstance (xLockBytes, pFilename, eAccessMode);
+    if (eErrCode != store_E_None)
+        return eErrCode;
+    OSL_ASSERT(xLockBytes.is());
+
+    Reference<OStorePageManager> xManager (new OStorePageManager());
+    if (!xManager.is())
+        return store_E_OutOfMemory;
+
+    eErrCode = xManager->initialize (
+        &*xLockBytes, eAccessMode, nPageSize);
+    if (eErrCode != store_E_None)
+        return eErrCode;
+
+    xManager->acquire();
+
+    *phFile = xManager.get();
+    return store_E_None;
+}
+
+/*
+ * store_closeFile.
+ */
+storeError store_closeFile (
+    storeFileHandle Handle
+) SAL_THROW_EXTERN_C()
+{
+    OStorePageManager *pManager =
+        OStoreHandle<OStorePageManager>::query (Handle);
+    if (!pManager)
+        return store_E_InvalidHandle;
+
+    storeError eErrCode = pManager->close();
+    pManager->release();
+    return eErrCode;
+}
+
+/*
+ * store_flushFile.
+ */
+storeError store_flushFile (
+    storeFileHandle Handle
+) SAL_THROW_EXTERN_C()
+{
+    OStoreHandle<OStorePageManager> xManager (
+        OStoreHandle<OStorePageManager>::query (Handle));
+    if (!xManager.is())
+        return store_E_InvalidHandle;
+
+    return xManager->flush();
+}
+
+/*========================================================================
+ *
+ * storeDirectoryHandle implementation.
+ *
+ *======================================================================*/
+/*
+ * store_openDirectory.
+ */
+storeError store_openDirectory (
+    storeFileHandle       hFile,
+    rtl_uString const    *pPath,
+    rtl_uString const    *pName,
+    storeAccessMode       eAccessMode,
+    storeDirectoryHandle *phDirectory
+) SAL_THROW_EXTERN_C()
+{
+    storeError eErrCode = store_E_None;
+    if (phDirectory)
+        *phDirectory = nullptr;
+
+    OStoreHandle<OStorePageManager> xManager (
+        OStoreHandle<OStorePageManager>::query (hFile));
+    if (!xManager.is())
+        return store_E_InvalidHandle;
+
+    if (!(pPath && pName && phDirectory))
+        return store_E_InvalidParameter;
+
+    Reference<OStoreDirectory_Impl> xDirectory (new OStoreDirectory_Impl());
+    if (!xDirectory.is())
+        return store_E_OutOfMemory;
+
+    OString aPath (pPath->buffer, pPath->length, RTL_TEXTENCODING_UTF8);
+    OString aName (pName->buffer, pName->length, RTL_TEXTENCODING_UTF8);
+
+    eErrCode = xDirectory->create (&*xManager, aPath.pData, aName.pData, eAccessMode);
+    if (eErrCode != store_E_None)
+        return eErrCode;
+
+    xDirectory->acquire();
+
+    *phDirectory = xDirectory.get();
+    return store_E_None;
+}
+
+/*
+ * store_findFirst.
+ */
+storeError store_findFirst (
+    storeDirectoryHandle  Handle,
+    storeFindData        *pFindData
+) SAL_THROW_EXTERN_C()
+{
+    OStoreHandle<OStoreDirectory_Impl> xDirectory (
+        OStoreHandle<OStoreDirectory_Impl>::query (Handle));
+    if (!xDirectory.is())
+        return store_E_InvalidHandle;
+
+    if (!pFindData)
+        return store_E_InvalidParameter;
+
+    // Initialize FindData.
+    memset (pFindData, 0, sizeof (storeFindData));
+
+    // Find first.
+    pFindData->m_nReserved = sal_uInt32(~0);
+    return xDirectory->iterate (*pFindData);
+}
+
+/*
+ * store_findNext.
+ */
+storeError store_findNext (
+    storeDirectoryHandle  Handle,
+    storeFindData        *pFindData
+) SAL_THROW_EXTERN_C()
+{
+    OStoreHandle<OStoreDirectory_Impl> xDirectory (
+        OStoreHandle<OStoreDirectory_Impl>::query (Handle));
+    if (!xDirectory.is())
+        return store_E_InvalidHandle;
+
+    if (!pFindData)
+        return store_E_InvalidParameter;
+
+    // Check FindData.
+    if (!pFindData->m_nReserved)
+        return store_E_NoMoreFiles;
+
+    // Find next.
+    pFindData->m_nReserved -= 1;
+    return xDirectory->iterate (*pFindData);
+}
+
+/*========================================================================
+ *
+ * storeStreamHandle implementation.
+ *
+ *======================================================================*/
+/*
+ * store_openStream
+ */
+storeError store_openStream (
+    storeFileHandle    hFile,
+    rtl_uString const *pPath,
+    rtl_uString const *pName,
+    storeAccessMode    eAccessMode,
+    storeStreamHandle *phStream
+) SAL_THROW_EXTERN_C()
+{
+    storeError eErrCode = store_E_None;
+    if (phStream)
+        *phStream = nullptr;
+
+    OStoreHandle<OStorePageManager> xManager (
+        OStoreHandle<OStorePageManager>::query (hFile));
+    if (!xManager.is())
+        return store_E_InvalidHandle;
+
+    if (!(pPath && pName && phStream))
+        return store_E_InvalidParameter;
+
+    Reference<OStoreLockBytes> xLockBytes (new OStoreLockBytes());
+    if (!xLockBytes.is())
+        return store_E_OutOfMemory;
+
+    OString aPath (pPath->buffer, pPath->length, RTL_TEXTENCODING_UTF8);
+    OString aName (pName->buffer, pName->length, RTL_TEXTENCODING_UTF8);
+
+    eErrCode = xLockBytes->create (&*xManager, aPath.pData, aName.pData, eAccessMode);
+    if (eErrCode != store_E_None)
+        return eErrCode;
+
+    xLockBytes->acquire();
+
+    *phStream = xLockBytes.get();
+    return store_E_None;
+}
+
+/*
+ * store_readStream.
+ */
+storeError store_readStream (
+    storeStreamHandle  Handle,
+    sal_uInt32         nOffset,
+    void              *pBuffer,
+    sal_uInt32         nBytes,
+    sal_uInt32        *pnDone
+) SAL_THROW_EXTERN_C()
+{
+    OStoreHandle<OStoreLockBytes> xLockBytes (
+        OStoreHandle<OStoreLockBytes>::query (Handle));
+    if (!xLockBytes.is())
+        return store_E_InvalidHandle;
+
+    if (!(pBuffer && pnDone))
+        return store_E_InvalidParameter;
+
+    return xLockBytes->readAt (nOffset, pBuffer, nBytes, *pnDone);
+}
+
+/*
+ * store_writeStream.
+ */
+storeError store_writeStream (
+    storeStreamHandle  Handle,
+    sal_uInt32         nOffset,
+    const void        *pBuffer,
+    sal_uInt32         nBytes,
+    sal_uInt32        *pnDone
+) SAL_THROW_EXTERN_C()
+{
+    OStoreHandle<OStoreLockBytes> xLockBytes (
+        OStoreHandle<OStoreLockBytes>::query (Handle));
+    if (!xLockBytes.is())
+        return store_E_InvalidHandle;
+
+    if (!(pBuffer && pnDone))
+        return store_E_InvalidParameter;
+
+    return xLockBytes->writeAt (nOffset, pBuffer, nBytes, *pnDone);
+}
+
+/*
+ * store_remove.
+ */
+storeError store_remove (
+    storeFileHandle Handle,
+    rtl_uString const *pPath,
+    rtl_uString const *pName
+) SAL_THROW_EXTERN_C()
+{
+    storeError eErrCode = store_E_None;
+
+    OStoreHandle<OStorePageManager> xManager (
+        OStoreHandle<OStorePageManager>::query (Handle));
+    if (!xManager.is())
+        return store_E_InvalidHandle;
+
+    if (!(pPath && pName))
+        return store_E_InvalidParameter;
+
+    // Setup page key.
+    OString aPath (pPath->buffer, pPath->length, RTL_TEXTENCODING_UTF8);
+    OString aName (pName->buffer, pName->length, RTL_TEXTENCODING_UTF8);
+    OStorePageKey aKey;
+
+    eErrCode = OStorePageManager::namei (aPath.pData, aName.pData, aKey);
+    if (eErrCode != store_E_None)
+        return eErrCode;
+
+    // Remove.
+    return xManager->remove (aKey);
+}
+
+/* vim:set shiftwidth=4 softtabstop=4 expandtab: */