LCOV - code coverage report
Current view: top level - store/source - storpage.cxx (source / functions) Hit Total Coverage
Test: commit e02a6cb2c3e2b23b203b422e4e0680877f232636 Lines: 0 400 0.0 %
Date: 2014-04-14 Functions: 0 23 0.0 %
Legend: Lines: hit not hit

          Line data    Source code
       1             : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
       2             : /*
       3             :  * This file is part of the LibreOffice project.
       4             :  *
       5             :  * This Source Code Form is subject to the terms of the Mozilla Public
       6             :  * License, v. 2.0. If a copy of the MPL was not distributed with this
       7             :  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
       8             :  *
       9             :  * This file incorporates work covered by the following license notice:
      10             :  *
      11             :  *   Licensed to the Apache Software Foundation (ASF) under one or more
      12             :  *   contributor license agreements. See the NOTICE file distributed
      13             :  *   with this work for additional information regarding copyright
      14             :  *   ownership. The ASF licenses this file to you under the Apache
      15             :  *   License, Version 2.0 (the "License"); you may not use this file
      16             :  *   except in compliance with the License. You may obtain a copy of
      17             :  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
      18             :  */
      19             : 
      20             : #include "storpage.hxx"
      21             : 
      22             : #include "sal/types.h"
      23             : #include "rtl/string.h"
      24             : #include "rtl/ref.hxx"
      25             : #include "osl/diagnose.h"
      26             : #include "osl/mutex.hxx"
      27             : 
      28             : #include "store/types.h"
      29             : 
      30             : #include "object.hxx"
      31             : #include "lockbyte.hxx"
      32             : 
      33             : #include "storbase.hxx"
      34             : #include "stordata.hxx"
      35             : #include "stortree.hxx"
      36             : 
      37             : using namespace store;
      38             : 
      39             : /*========================================================================
      40             :  *
      41             :  * OStorePageManager implementation.
      42             :  *
      43             :  *======================================================================*/
      44             : const sal_uInt32 OStorePageManager::m_nTypeId = sal_uInt32(0x62190120);
      45             : 
      46             : /*
      47             :  * OStorePageManager.
      48             :  */
      49           0 : OStorePageManager::OStorePageManager (void)
      50             : {
      51           0 : }
      52             : 
      53             : /*
      54             :  * ~OStorePageManager.
      55             :  */
      56           0 : OStorePageManager::~OStorePageManager (void)
      57             : {
      58           0 : }
      59             : 
      60             : /*
      61             :  * isKindOf.
      62             :  */
      63           0 : bool OStorePageManager::isKindOf (sal_uInt32 nTypeId)
      64             : {
      65           0 :     return (nTypeId == m_nTypeId);
      66             : }
      67             : 
      68             : /*
      69             :  * initialize (two-phase construction).
      70             :  * Precond: none.
      71             :  */
      72           0 : storeError OStorePageManager::initialize (
      73             :     ILockBytes *    pLockBytes,
      74             :     storeAccessMode eAccessMode,
      75             :     sal_uInt16 &    rnPageSize)
      76             : {
      77             :     // Acquire exclusive access.
      78           0 :     osl::MutexGuard aGuard(*this);
      79             : 
      80             :     // Check arguments.
      81           0 :     if (!pLockBytes)
      82           0 :         return store_E_InvalidParameter;
      83             : 
      84             :     // Initialize base.
      85           0 :     storeError eErrCode = base::initialize (pLockBytes, eAccessMode, rnPageSize);
      86           0 :     if (eErrCode != store_E_None)
      87           0 :         return eErrCode;
      88             : 
      89             :     // Check for (not) writeable.
      90           0 :     if (!base::isWriteable())
      91             :     {
      92             :         // Readonly. Load RootNode.
      93           0 :         return base::loadObjectAt (m_aRoot, rnPageSize);
      94             :     }
      95             : 
      96             :     // Writeable. Load or Create RootNode.
      97           0 :     eErrCode = m_aRoot.loadOrCreate (rnPageSize, *this);
      98           0 :     if (eErrCode == store_E_Pending)
      99             :     {
     100             :         // Creation notification.
     101           0 :         PageHolderObject< page > xRoot (m_aRoot.get());
     102             : 
     103             :         // Pre-allocate left most entry (ugly, but we can't insert to left).
     104           0 :         OStorePageKey aKey (rtl_crc32 (0, "/", 1), 0);
     105           0 :         xRoot->insert (0, entry(aKey));
     106             : 
     107             :         // Save RootNode.
     108           0 :         eErrCode = base::saveObjectAt (m_aRoot, rnPageSize);
     109             :     }
     110             : 
     111             :     // Done.
     112           0 :     return eErrCode;
     113             : }
     114             : 
     115             : /*
     116             :  * find_lookup (w/o split()).
     117             :  * Internal: Precond: initialized, readable, exclusive access.
     118             :  */
     119           0 : storeError OStorePageManager::find_lookup (
     120             :     OStoreBTreeNodeObject & rNode,
     121             :     sal_uInt16 &            rIndex,
     122             :     OStorePageKey const &   rKey)
     123             : {
     124             :     // Find Node and Index.
     125           0 :     storeError eErrCode = m_aRoot.find_lookup (rNode, rIndex, rKey, *this);
     126           0 :     if (eErrCode != store_E_None)
     127           0 :         return eErrCode;
     128             : 
     129             :     // Greater or Equal.
     130           0 :     PageHolderObject< page > xPage (rNode.get());
     131             :     OSL_POSTCOND(rIndex < xPage->usageCount(), "store::PageManager::find_lookup(): logic error");
     132           0 :     entry e (xPage->m_pData[rIndex]);
     133             : 
     134             :     // Check for exact match.
     135           0 :     if (e.compare(entry(rKey)) != entry::COMPARE_EQUAL)
     136             :     {
     137             :         // Page not present.
     138           0 :         return store_E_NotExists;
     139             :     }
     140             : 
     141             :     // Check address.
     142           0 :     if (e.m_aLink.location() == STORE_PAGE_NULL)
     143             :     {
     144             :         // Page not present.
     145           0 :         return store_E_NotExists;
     146             :     }
     147             : 
     148           0 :     return store_E_None;
     149             : }
     150             : 
     151             : /*
     152             :  * remove_Impl (possibly down from root).
     153             :  * Internal: Precond: initialized, writeable, exclusive access.
     154             :  */
     155             : 
     156           0 : storeError OStorePageManager::remove_Impl (entry & rEntry)
     157             : {
     158           0 :     OStoreBTreeNodeObject aNode (m_aRoot.get());
     159             : 
     160             :     // Check current page index.
     161           0 :     PageHolderObject< page > xPage (aNode.get());
     162           0 :     sal_uInt16 i = xPage->find (rEntry), n = xPage->usageCount();
     163           0 :     if (!(i < n))
     164             :     {
     165             :         // Path to entry not exists (Must not happen(?)).
     166           0 :         return store_E_NotExists;
     167             :     }
     168             : 
     169             :     // Compare entry.
     170           0 :     entry::CompareResult result = rEntry.compare (xPage->m_pData[i]);
     171             : 
     172             :     // Iterate down until equal match.
     173           0 :     while ((result == entry::COMPARE_GREATER) && (xPage->depth() > 0))
     174             :     {
     175             :         // Check link address.
     176           0 :         sal_uInt32 const nAddr = xPage->m_pData[i].m_aLink.location();
     177           0 :         if (nAddr == STORE_PAGE_NULL)
     178             :         {
     179             :             // Path to entry not exists (Must not happen(?)).
     180           0 :             return store_E_NotExists;
     181             :         }
     182             : 
     183             :         // Load link page.
     184           0 :         storeError eErrCode = loadObjectAt (aNode, nAddr);
     185           0 :         if (eErrCode != store_E_None)
     186           0 :             return eErrCode;
     187             : 
     188           0 :         PageHolderObject< page > xNext (aNode.get());
     189           0 :         xNext.swap (xPage);
     190             : 
     191             :         // Check index.
     192           0 :         i = xPage->find (rEntry), n = xPage->usageCount();
     193           0 :         if (!(i < n))
     194             :         {
     195             :             // Path to entry not exists (Must not happen(?)).
     196           0 :             return store_E_NotExists;
     197             :         }
     198             : 
     199             :         // Compare entry.
     200           0 :         result = rEntry.compare (xPage->m_pData[i]);
     201           0 :     }
     202             : 
     203             :     OSL_POSTCOND(
     204             :         result != entry::COMPARE_LESS,
     205             :         "OStorePageManager::remove(): find failed");
     206             : 
     207             :     // Check entry comparison.
     208           0 :     if (result == entry::COMPARE_LESS)
     209             :     {
     210             :         // Must not happen.
     211           0 :         return store_E_Unknown;
     212             :     }
     213             : 
     214             :     // Remove down from current page (recursive).
     215           0 :     return aNode.remove (i, rEntry, *this);
     216             : }
     217             : 
     218             : /*
     219             :  * namei.
     220             :  * Precond: none (static).
     221             :  */
     222           0 : storeError OStorePageManager::namei (
     223             :     const rtl_String *pPath, const rtl_String *pName, OStorePageKey &rKey)
     224             : {
     225             :     // Check parameter.
     226           0 :     if (!(pPath && pName))
     227           0 :         return store_E_InvalidParameter;
     228             : 
     229             :     // Check name length.
     230           0 :     if (!(pName->length < STORE_MAXIMUM_NAMESIZE))
     231           0 :         return store_E_NameTooLong;
     232             : 
     233             :     // Transform pathname into key.
     234           0 :     rKey.m_nLow  = store::htonl(rtl_crc32 (0, pName->buffer, pName->length));
     235           0 :     rKey.m_nHigh = store::htonl(rtl_crc32 (0, pPath->buffer, pPath->length));
     236             : 
     237             :     // Done.
     238           0 :     return store_E_None;
     239             : }
     240             : 
     241             : /*
     242             :  * iget.
     243             :  * Precond: initialized.
     244             :  */
     245           0 : storeError OStorePageManager::iget (
     246             :     OStoreDirectoryPageObject & rPage,
     247             :     sal_uInt32                  nAttrib,
     248             :     const rtl_String          * pPath,
     249             :     const rtl_String          * pName,
     250             :     storeAccessMode             eMode)
     251             : {
     252             :     // Acquire exclusive access.
     253           0 :     osl::MutexGuard aGuard(*this);
     254             : 
     255             :     // Check precond.
     256           0 :     if (!self::isValid())
     257           0 :         return store_E_InvalidAccess;
     258             : 
     259             :     // Setup inode page key.
     260           0 :     OStorePageKey aKey;
     261           0 :     storeError eErrCode = namei (pPath, pName, aKey);
     262           0 :     if (eErrCode != store_E_None)
     263           0 :         return eErrCode;
     264             : 
     265             :     // Check for directory.
     266           0 :     if (nAttrib & STORE_ATTRIB_ISDIR)
     267             :     {
     268             :         // Ugly, but necessary (backward compatibility).
     269           0 :         aKey.m_nLow = store::htonl(rtl_crc32 (store::ntohl(aKey.m_nLow), "/", 1));
     270             :     }
     271             : 
     272             :     // Load inode page.
     273           0 :     eErrCode = load_dirpage_Impl (aKey, rPage);
     274           0 :     if (eErrCode != store_E_None)
     275             :     {
     276             :         // Check mode and reason.
     277           0 :         if (eErrCode != store_E_NotExists)
     278           0 :             return eErrCode;
     279             : 
     280           0 :         if (eMode == store_AccessReadWrite)
     281           0 :             return store_E_NotExists;
     282           0 :         if (eMode == store_AccessReadOnly)
     283           0 :             return store_E_NotExists;
     284             : 
     285           0 :         if (!base::isWriteable())
     286           0 :             return store_E_AccessViolation;
     287             : 
     288             :         // Create inode page.
     289           0 :         eErrCode = rPage.construct< inode >(base::allocator());
     290           0 :         if (eErrCode != store_E_None)
     291           0 :             return eErrCode;
     292             : 
     293             :         // Setup inode nameblock.
     294           0 :         PageHolderObject< inode > xPage (rPage.get());
     295             : 
     296           0 :         rPage.key (aKey);
     297           0 :         rPage.attrib (nAttrib);
     298             : 
     299             :         memcpy (
     300           0 :             &(xPage->m_aNameBlock.m_pData[0]),
     301           0 :             pName->buffer, pName->length);
     302             : 
     303             :         // Save inode page.
     304           0 :         eErrCode = save_dirpage_Impl (aKey, rPage);
     305           0 :         if (eErrCode != store_E_None)
     306           0 :             return eErrCode;
     307             :     }
     308             : 
     309             :     // Check for symbolic link.
     310           0 :     if (rPage.attrib() & STORE_ATTRIB_ISLINK)
     311             :     {
     312             :         // Obtain 'Destination' page key.
     313           0 :         PageHolderObject< inode > xPage (rPage.get());
     314           0 :         OStorePageKey aDstKey;
     315           0 :         memcpy (&aDstKey, &(xPage->m_pData[0]), sizeof(aDstKey));
     316             : 
     317             :         // Load 'Destination' inode.
     318           0 :         eErrCode = load_dirpage_Impl (aDstKey, rPage);
     319           0 :         if (eErrCode != store_E_None)
     320           0 :             return eErrCode;
     321             :     }
     322             : 
     323             :     // Done.
     324           0 :     return store_E_None;
     325             : }
     326             : 
     327             : /*
     328             :  * iterate.
     329             :  * Precond: initialized.
     330             :  * ToDo: skip hardlink entries.
     331             :  */
     332           0 : storeError OStorePageManager::iterate (
     333             :     OStorePageKey &  rKey,
     334             :     OStorePageLink & rLink,
     335             :     sal_uInt32 &     rAttrib)
     336             : {
     337             :     // Acquire exclusive access.
     338           0 :     osl::MutexGuard aGuard(*this);
     339             : 
     340             :     // Check precond.
     341           0 :     if (!self::isValid())
     342           0 :         return store_E_InvalidAccess;
     343             : 
     344             :     // Find NodePage and Index.
     345           0 :     OStoreBTreeNodeObject aNode;
     346           0 :     sal_uInt16 i = 0;
     347           0 :     storeError eErrCode = m_aRoot.find_lookup (aNode, i, rKey, *this);
     348           0 :     if (eErrCode != store_E_None)
     349           0 :         return eErrCode;
     350             : 
     351             :     // GreaterEqual. Found next entry.
     352           0 :     PageHolderObject< page > xNode (aNode.get());
     353           0 :     entry e (xNode->m_pData[i]);
     354             : 
     355             :     // Setup result.
     356           0 :     rKey    = e.m_aKey;
     357           0 :     rLink   = e.m_aLink;
     358           0 :     rAttrib = store::ntohl(e.m_nAttrib);
     359             : 
     360             :     // Done.
     361           0 :     return store_E_None;
     362             : }
     363             : 
     364             : /*
     365             :  * load => private: iget() @@@
     366             :  * Internal: Precond: initialized, exclusive access.
     367             :  */
     368           0 : storeError OStorePageManager::load_dirpage_Impl (
     369             :     const OStorePageKey       &rKey,
     370             :     OStoreDirectoryPageObject &rPage)
     371             : {
     372             :     // Find Node and Index.
     373           0 :     OStoreBTreeNodeObject aNode;
     374           0 :     sal_uInt16 i = 0;
     375           0 :     storeError eErrCode = find_lookup (aNode, i, rKey);
     376           0 :     if (eErrCode != store_E_None)
     377           0 :         return eErrCode;
     378             : 
     379             :     // Existing entry. Load page.
     380           0 :     PageHolderObject< page > xNode (aNode.get());
     381           0 :     entry e (xNode->m_pData[i]);
     382           0 :     return loadObjectAt (rPage, e.m_aLink.location());
     383             : }
     384             : 
     385             : /*
     386             :  * save => private: iget(), rebuild() @@@
     387             :  * Internal: Precond: initialized, writeable, exclusive access.
     388             :  */
     389           0 : storeError OStorePageManager::save_dirpage_Impl (
     390             :     const OStorePageKey       &rKey,
     391             :     OStoreDirectoryPageObject &rPage)
     392             : {
     393             :     // Find NodePage and Index.
     394           0 :     node aNode;
     395           0 :     sal_uInt16 i = 0;
     396             : 
     397           0 :     storeError eErrCode = m_aRoot.find_insert (aNode, i, rKey, *this);
     398           0 :     PageHolderObject< page > xNode (aNode.get());
     399           0 :     if (eErrCode != store_E_None)
     400             :     {
     401           0 :         if (eErrCode != store_E_AlreadyExists)
     402           0 :             return eErrCode;
     403             : 
     404             :         // Existing entry.
     405           0 :         entry e (xNode->m_pData[i]);
     406           0 :         if (e.m_aLink.location() != STORE_PAGE_NULL)
     407             :         {
     408             :             // Save page to existing location.
     409           0 :             return saveObjectAt (rPage, e.m_aLink.location());
     410             :         }
     411             : 
     412             :         // Allocate page.
     413           0 :         eErrCode = base::allocate (rPage);
     414           0 :         if (eErrCode != store_E_None)
     415           0 :             return eErrCode;
     416             : 
     417             :         // Update page location.
     418           0 :         xNode->m_pData[i].m_aLink = rPage.location();
     419             : 
     420             :         // Save modified NodePage.
     421           0 :         return saveObjectAt (aNode, aNode.location());
     422             :     }
     423             : 
     424             :     // Allocate page.
     425           0 :     eErrCode = base::allocate (rPage);
     426           0 :     if (eErrCode != store_E_None)
     427           0 :         return eErrCode;
     428             : 
     429             :     // Insert.
     430           0 :     OStorePageLink aLink (rPage.location());
     431           0 :     xNode->insert (i + 1, entry (rKey, aLink));
     432             : 
     433             :     // Save modified NodePage.
     434           0 :     return saveObjectAt (aNode, aNode.location());
     435             : }
     436             : 
     437             : /*
     438             :  * attrib [nAttrib = ((nAttrib & ~nMask1) | nMask2)].
     439             :  * Precond: initialized.
     440             :  */
     441           0 : storeError OStorePageManager::attrib (
     442             :     const OStorePageKey &rKey,
     443             :     sal_uInt32           nMask1,
     444             :     sal_uInt32           nMask2,
     445             :     sal_uInt32          &rAttrib)
     446             : {
     447             :     // Acquire exclusive access.
     448           0 :     osl::MutexGuard aGuard(*this);
     449             : 
     450             :     // Check precond.
     451           0 :     if (!self::isValid())
     452           0 :         return store_E_InvalidAccess;
     453             : 
     454             :     // Find NodePage and index.
     455           0 :     OStoreBTreeNodeObject aNode;
     456           0 :     sal_uInt16 i = 0;
     457           0 :     storeError eErrCode = find_lookup (aNode, i, rKey);
     458           0 :     if (eErrCode != store_E_None)
     459           0 :         return eErrCode;
     460             : 
     461             :     // Existing entry.
     462           0 :     PageHolderObject< page > xNode (aNode.get());
     463           0 :     entry e (xNode->m_pData[i]);
     464           0 :     if (nMask1 != nMask2)
     465             :     {
     466             :         // Evaluate new attributes.
     467           0 :         sal_uInt32 nAttrib = store::ntohl(e.m_nAttrib);
     468             : 
     469           0 :         nAttrib &= ~nMask1;
     470           0 :         nAttrib |=  nMask2;
     471             : 
     472           0 :         if (store::htonl(nAttrib) != e.m_nAttrib)
     473             :         {
     474             :             // Check access mode.
     475           0 :             if (base::isWriteable())
     476             :             {
     477             :                 // Set new attributes.
     478           0 :                 e.m_nAttrib = store::htonl(nAttrib);
     479           0 :                 xNode->m_pData[i] = e;
     480             : 
     481             :                 // Save modified NodePage.
     482           0 :                 eErrCode = saveObjectAt (aNode, aNode.location());
     483             :             }
     484             :             else
     485             :             {
     486             :                 // Access denied.
     487           0 :                 eErrCode = store_E_AccessViolation;
     488             :             }
     489             :         }
     490             :     }
     491             : 
     492             :     // Obtain current attributes.
     493           0 :     rAttrib = store::ntohl(e.m_nAttrib);
     494           0 :     return eErrCode;
     495             : }
     496             : 
     497             : /*
     498             :  * link (insert 'Source' as hardlink to 'Destination').
     499             :  * Precond: initialized, writeable.
     500             :  */
     501           0 : storeError OStorePageManager::link (
     502             :     const OStorePageKey &rSrcKey,
     503             :     const OStorePageKey &rDstKey)
     504             : {
     505             :     // Acquire exclusive access.
     506           0 :     osl::MutexGuard aGuard(*this);
     507             : 
     508             :     // Check precond.
     509           0 :     if (!self::isValid())
     510           0 :         return store_E_InvalidAccess;
     511             : 
     512           0 :     if (!base::isWriteable())
     513           0 :         return store_E_AccessViolation;
     514             : 
     515             :     // Find 'Destination' NodePage and Index.
     516           0 :     OStoreBTreeNodeObject aDstNode;
     517           0 :     sal_uInt16 i = 0;
     518           0 :     storeError eErrCode = find_lookup (aDstNode, i, rDstKey);
     519           0 :     if (eErrCode != store_E_None)
     520           0 :         return eErrCode;
     521             : 
     522             :     // Existing 'Destination' entry.
     523           0 :     PageHolderObject< page > xDstNode (aDstNode.get());
     524           0 :     entry e (xDstNode->m_pData[i]);
     525           0 :     OStorePageLink aDstLink (e.m_aLink);
     526             : 
     527             :     // Find 'Source' NodePage and Index.
     528           0 :     OStoreBTreeNodeObject aSrcNode;
     529           0 :     eErrCode = m_aRoot.find_insert (aSrcNode, i, rSrcKey, *this);
     530           0 :     if (eErrCode != store_E_None)
     531           0 :         return eErrCode;
     532             : 
     533             :     // Insert 'Source' entry.
     534           0 :     PageHolderObject< page > xSrcNode (aSrcNode.get());
     535           0 :     xSrcNode->insert (i + 1, entry (rSrcKey, aDstLink, STORE_ATTRIB_ISLINK));
     536           0 :     return saveObjectAt (aSrcNode, aSrcNode.location());
     537             : }
     538             : 
     539             : /*
     540             :  * symlink (insert 'Source' DirectoryPage as symlink to 'Destination').
     541             :  * Precond: initialized, writeable.
     542             :  */
     543           0 : storeError OStorePageManager::symlink (
     544             :     const rtl_String    *pSrcPath,
     545             :     const rtl_String    *pSrcName,
     546             :     const OStorePageKey &rDstKey)
     547             : {
     548             :     // Acquire exclusive access.
     549           0 :     osl::MutexGuard aGuard(*this);
     550             : 
     551             :     // Check precond.
     552           0 :     if (!self::isValid())
     553           0 :         return store_E_InvalidAccess;
     554             : 
     555           0 :     if (!base::isWriteable())
     556           0 :         return store_E_AccessViolation;
     557             : 
     558             :     // Check 'Source' parameter.
     559           0 :     storeError eErrCode = store_E_InvalidParameter;
     560           0 :     if (!(pSrcPath && pSrcName))
     561           0 :         return eErrCode;
     562             : 
     563             :     // Setup 'Source' page key.
     564           0 :     OStorePageKey aSrcKey;
     565           0 :     eErrCode = namei (pSrcPath, pSrcName, aSrcKey);
     566           0 :     if (eErrCode != store_E_None)
     567           0 :         return eErrCode;
     568             : 
     569             :     // Find 'Source' NodePage and Index.
     570           0 :     OStoreBTreeNodeObject aSrcNode;
     571           0 :     sal_uInt16 i = 0;
     572           0 :     eErrCode = m_aRoot.find_insert (aSrcNode, i, aSrcKey, *this);
     573           0 :     if (eErrCode != store_E_None)
     574           0 :         return eErrCode;
     575             : 
     576             :     // Initialize directory page.
     577           0 :     OStoreDirectoryPageObject aPage;
     578           0 :     eErrCode = aPage.construct< inode >(base::allocator());
     579           0 :     if (eErrCode != store_E_None)
     580           0 :         return eErrCode;
     581             : 
     582             :     // Setup as 'Source' directory page.
     583           0 :     inode_holder_type xNode (aPage.get());
     584           0 :     aPage.key (aSrcKey);
     585             :     memcpy (
     586           0 :         &(xNode->m_aNameBlock.m_pData[0]),
     587           0 :         pSrcName->buffer, pSrcName->length);
     588             : 
     589             :     // Store 'Destination' page key.
     590           0 :     OStorePageKey aDstKey (rDstKey);
     591           0 :     memcpy (&(xNode->m_pData[0]), &aDstKey, sizeof(aDstKey));
     592             : 
     593             :     // Mark 'Source' as symbolic link to 'Destination'.
     594           0 :     aPage.attrib (STORE_ATTRIB_ISLINK);
     595           0 :     aPage.dataLength (sal_uInt32(sizeof(aDstKey)));
     596             : 
     597             :     // Allocate and save 'Source' directory page.
     598           0 :     eErrCode = base::allocate (aPage);
     599           0 :     if (eErrCode != store_E_None)
     600           0 :         return eErrCode;
     601             : 
     602             :     // Insert 'Source' entry.
     603           0 :     PageHolderObject< page > xSrcNode (aSrcNode.get());
     604           0 :     OStorePageLink aSrcLink (aPage.location());
     605           0 :     xSrcNode->insert (i + 1, entry(aSrcKey, aSrcLink));
     606             : 
     607             :     // Save modified NodePage.
     608           0 :     return saveObjectAt (aSrcNode, aSrcNode.location());
     609             : }
     610             : 
     611             : /*
     612             :  * rename.
     613             :  * Precond: initialized, writeable.
     614             :  */
     615           0 : storeError OStorePageManager::rename (
     616             :     const OStorePageKey &rSrcKey,
     617             :     const rtl_String    *pDstPath,
     618             :     const rtl_String    *pDstName)
     619             : {
     620             :     // Acquire exclusive access.
     621           0 :     osl::MutexGuard aGuard(*this);
     622             : 
     623             :     // Check precond.
     624           0 :     if (!self::isValid())
     625           0 :         return store_E_InvalidAccess;
     626             : 
     627           0 :     if (!base::isWriteable())
     628           0 :         return store_E_AccessViolation;
     629             : 
     630             :     // Check 'Destination' parameter.
     631           0 :     storeError eErrCode = store_E_InvalidParameter;
     632           0 :     if (!(pDstPath && pDstName))
     633           0 :         return eErrCode;
     634             : 
     635             :     // Setup 'Destination' page key.
     636           0 :     OStorePageKey aDstKey;
     637           0 :     eErrCode = namei (pDstPath, pDstName, aDstKey);
     638           0 :     if (eErrCode != store_E_None)
     639           0 :         return eErrCode;
     640             : 
     641             :     // Find 'Source' NodePage and Index.
     642           0 :     OStoreBTreeNodeObject aSrcNode;
     643           0 :     sal_uInt16 i = 0;
     644           0 :     eErrCode = find_lookup (aSrcNode, i, rSrcKey);
     645           0 :     if (eErrCode != store_E_None)
     646           0 :         return eErrCode;
     647             : 
     648             :     // Existing 'Source' entry.
     649           0 :     PageHolderObject< page > xSrcNode (aSrcNode.get());
     650           0 :     entry e (xSrcNode->m_pData[i]);
     651             : 
     652             :     // Check for (not a) hardlink.
     653           0 :     OStoreDirectoryPageObject aPage;
     654           0 :     if (!(store::ntohl(e.m_nAttrib) & STORE_ATTRIB_ISLINK))
     655             :     {
     656             :         // Load directory page.
     657           0 :         eErrCode = base::loadObjectAt (aPage, e.m_aLink.location());
     658           0 :         if (eErrCode != store_E_None)
     659           0 :             return eErrCode;
     660             : 
     661             :         // Check for directory.
     662           0 :         if (aPage.attrib() & STORE_ATTRIB_ISDIR)
     663             :         {
     664             :             // Ugly, but necessary (backward compatibility).
     665           0 :             aDstKey.m_nLow = store::htonl(rtl_crc32 (store::ntohl(aDstKey.m_nLow), "/", 1));
     666             :         }
     667             :     }
     668             : 
     669             :     // Let 'Source' entry be 'Destination' entry.
     670           0 :     e.m_aKey = aDstKey;
     671             : 
     672             :     // Find 'Destination' NodePage and Index.
     673           0 :     OStoreBTreeNodeObject aDstNode;
     674           0 :     eErrCode = m_aRoot.find_insert (aDstNode, i, e.m_aKey, *this);
     675           0 :     if (eErrCode != store_E_None)
     676           0 :         return eErrCode;
     677             : 
     678             :     // Insert 'Destination' entry.
     679           0 :     PageHolderObject< page > xDstNode (aDstNode.get());
     680           0 :     xDstNode->insert (i + 1, e);
     681             : 
     682           0 :     eErrCode = saveObjectAt (aDstNode, aDstNode.location());
     683           0 :     if (eErrCode != store_E_None)
     684           0 :         return eErrCode;
     685             : 
     686             :     // Check for (not a) hardlink.
     687           0 :     if (!(store::ntohl(e.m_nAttrib) & STORE_ATTRIB_ISLINK))
     688             :     {
     689             :         // Modify 'Source' directory page.
     690           0 :         inode_holder_type xNode (aPage.get());
     691             : 
     692             :         // Setup 'Destination' NameBlock.
     693           0 :         sal_Int32 nDstLen = pDstName->length;
     694             :         memcpy (
     695           0 :             &(xNode->m_aNameBlock.m_pData[0]),
     696           0 :             pDstName->buffer, pDstName->length);
     697             :         memset (
     698           0 :             &(xNode->m_aNameBlock.m_pData[nDstLen]),
     699           0 :             0, STORE_MAXIMUM_NAMESIZE - nDstLen);
     700           0 :         aPage.key (e.m_aKey);
     701             : 
     702             :         // Save directory page.
     703           0 :         eErrCode = base::saveObjectAt (aPage, e.m_aLink.location());
     704           0 :         if (eErrCode != store_E_None)
     705           0 :             return eErrCode;
     706             :     }
     707             : 
     708             :     // Remove 'Source' entry.
     709           0 :     e.m_aKey = rSrcKey;
     710           0 :     return remove_Impl (e);
     711             : }
     712             : 
     713             : /*
     714             :  * remove.
     715             :  * Precond: initialized, writeable.
     716             :  */
     717           0 : storeError OStorePageManager::remove (const OStorePageKey &rKey)
     718             : {
     719             :     // Acquire exclusive access.
     720           0 :     osl::MutexGuard aGuard(*this);
     721             : 
     722             :     // Check precond.
     723           0 :     if (!self::isValid())
     724           0 :         return store_E_InvalidAccess;
     725             : 
     726           0 :     if (!base::isWriteable())
     727           0 :         return store_E_AccessViolation;
     728             : 
     729             :     // Find NodePage and index.
     730           0 :     OStoreBTreeNodeObject aNodePage;
     731           0 :     sal_uInt16 i = 0;
     732           0 :     storeError eErrCode = find_lookup (aNodePage, i, rKey);
     733           0 :     if (eErrCode != store_E_None)
     734           0 :         return eErrCode;
     735             : 
     736             :     // Existing entry.
     737           0 :     PageHolderObject< page > xNodePage (aNodePage.get());
     738           0 :     entry e (xNodePage->m_pData[i]);
     739             : 
     740             :     // Check for (not a) hardlink.
     741           0 :     if (!(store::ntohl(e.m_nAttrib) & STORE_ATTRIB_ISLINK))
     742             :     {
     743             :         // Load directory page.
     744           0 :         OStoreDirectoryPageObject aPage;
     745           0 :         eErrCode = base::loadObjectAt (aPage, e.m_aLink.location());
     746           0 :         if (eErrCode != store_E_None)
     747           0 :             return eErrCode;
     748             : 
     749           0 :         inode_holder_type xNode (aPage.get());
     750             : 
     751             :         // Acquire page write access.
     752           0 :         OStorePageDescriptor aDescr (xNode->m_aDescr);
     753           0 :         eErrCode = base::acquirePage (aDescr, store_AccessReadWrite);
     754           0 :         if (eErrCode != store_E_None)
     755           0 :             return eErrCode;
     756             : 
     757             :         // Check for symbolic link.
     758           0 :         if (!(aPage.attrib() & STORE_ATTRIB_ISLINK))
     759             :         {
     760             :             // Ordinary inode. Determine 'Data' scope.
     761           0 :             inode::ChunkScope eScope = xNode->scope (aPage.dataLength());
     762           0 :             if (eScope == inode::SCOPE_EXTERNAL)
     763             :             {
     764             :                 // External 'Data' scope. Truncate all external data pages.
     765           0 :                 eErrCode = aPage.truncate (0, *this);
     766           0 :                 if (eErrCode != store_E_None)
     767           0 :                     return eErrCode;
     768             :             }
     769             : 
     770             :             // Truncate internal data page.
     771           0 :             memset (&(xNode->m_pData[0]), 0, xNode->capacity());
     772           0 :             aPage.dataLength (0);
     773             :         }
     774             : 
     775             :         // Release page write access.
     776           0 :         eErrCode = base::releasePage (aDescr);
     777             : 
     778             :         // Release and free directory page.
     779           0 :         eErrCode = base::free (aPage.location());
     780             :     }
     781             : 
     782             :     // Remove entry.
     783           0 :     return remove_Impl (e);
     784             : }
     785             : 
     786             : /*
     787             :  * RebuildContext.
     788             :  */
     789           0 : struct RebuildContext
     790             : {
     791             :     /** Representation.
     792             :     */
     793             :     rtl::Reference<OStorePageBIOS> m_xBIOS;
     794             :     OStorePageBIOS::ScanContext    m_aCtx;
     795             :     sal_uInt16                     m_nPageSize;
     796             : 
     797             :     /** Construction.
     798             :      */
     799           0 :     RebuildContext (void)
     800           0 :         : m_xBIOS     (new OStorePageBIOS()),
     801           0 :           m_nPageSize (0)
     802           0 :     {}
     803             : 
     804             :     /** initialize (PageBIOS and ScanContext).
     805             :     */
     806           0 :     storeError initialize (ILockBytes *pLockBytes, sal_uInt32 nMagic = 0)
     807             :     {
     808           0 :         storeError eErrCode = store_E_InvalidParameter;
     809           0 :         if (pLockBytes)
     810             :         {
     811           0 :             m_xBIOS->initialize (pLockBytes, store_AccessReadOnly, m_nPageSize);
     812           0 :             eErrCode = m_xBIOS->scanBegin (m_aCtx, nMagic);
     813             :         }
     814           0 :         return eErrCode;
     815             :     }
     816             : 
     817             :     /** initialize (ScanContext).
     818             :     */
     819           0 :     storeError initialize (sal_uInt32 nMagic = 0)
     820             :     {
     821           0 :         return m_xBIOS->scanBegin (m_aCtx, nMagic);
     822             :     }
     823             : 
     824             :     /** load (next ScanContext matching page).
     825             :     */
     826           0 :     storeError load (OStorePageObject &rPage)
     827             :     {
     828           0 :         if (m_aCtx.isValid())
     829           0 :             return m_xBIOS->scanNext (m_aCtx, rPage);
     830             :         else
     831           0 :             return store_E_CantSeek;
     832             :     }
     833             : };
     834             : 
     835             : /*
     836             :  * rebuild.
     837             :  * Precond: none.
     838             :  */
     839           0 : storeError OStorePageManager::rebuild (
     840             :     ILockBytes *pSrcLB, ILockBytes *pDstLB)
     841             : {
     842             :     // Acquire exclusive access.
     843           0 :     osl::MutexGuard aGuard(*this);
     844             : 
     845             :     // Check arguments.
     846           0 :     storeError eErrCode = store_E_InvalidParameter;
     847           0 :     if (!(pSrcLB && pDstLB))
     848           0 :         return eErrCode;
     849             : 
     850             :     // Initialize 'Source' rebuild context.
     851           0 :     RebuildContext aCtx;
     852           0 :     eErrCode = aCtx.initialize (pSrcLB, STORE_MAGIC_DIRECTORYPAGE);
     853           0 :     if (eErrCode != store_E_None)
     854           0 :         return eErrCode;
     855           0 :     rtl::Reference<OStorePageBIOS> xSrcBIOS (aCtx.m_xBIOS);
     856             : 
     857             :     // Initialize as 'Destination' with 'Source' page size.
     858           0 :     eErrCode = self::initialize (pDstLB, store_AccessCreate, aCtx.m_nPageSize);
     859           0 :     if (eErrCode != store_E_None)
     860           0 :         return eErrCode;
     861             : 
     862             :     // Pass One: Scan 'Source' directory pages.
     863             :     {
     864             :         // Scan 'Source' directory pages.
     865           0 :         OStoreDirectoryPageObject aSrcPage;
     866           0 :         while ((eErrCode = aCtx.load(aSrcPage)) == store_E_None)
     867             :         {
     868           0 :             OStoreDirectoryPageObject aDstPage;
     869           0 :             eErrCode = aDstPage.construct< inode >(base::allocator());
     870           0 :             if (eErrCode != store_E_None)
     871           0 :                 break;
     872             : 
     873           0 :             inode_holder_type xSrcDir (aSrcPage.get());
     874           0 :             inode_holder_type xDstDir (aDstPage.get());
     875             : 
     876             :             // Copy NameBlock @@@ OLD @@@
     877           0 :             memcpy (&(xDstDir->m_aNameBlock), &(xSrcDir->m_aNameBlock), sizeof(xSrcDir->m_aNameBlock));
     878             : 
     879             :             // Obtain 'Source' data length.
     880           0 :             sal_uInt32 nDataLen = aSrcPage.dataLength();
     881           0 :             if (nDataLen > 0)
     882             :             {
     883             :                 // Copy internal data area @@@ OLD @@@
     884           0 :                 memcpy (&(xDstDir->m_pData[0]), &(xSrcDir->m_pData[0]), xSrcDir->capacity());
     885             :             }
     886             : 
     887             :             // Insert 'Destination' directory page.
     888           0 :             eErrCode = save_dirpage_Impl (aDstPage.key(), aDstPage);
     889           0 :             if (eErrCode != store_E_None)
     890           0 :                 break;
     891             : 
     892             :             // Check for external data page scope.
     893           0 :             if (xSrcDir->scope(nDataLen) != inode::SCOPE_INTERNAL)
     894             :             {
     895             :                 // Initialize 'Destination' data page.
     896             :                 typedef OStoreDataPageData data;
     897           0 :                 PageHolderObject< data > xData;
     898           0 :                 if (!xData.construct(base::allocator()))
     899           0 :                     return store_E_OutOfMemory;
     900             : 
     901             :                 // Determine data page count.
     902             :                 inode::ChunkDescriptor aDescr (
     903           0 :                     nDataLen - xDstDir->capacity(), xData->capacity());
     904             : 
     905           0 :                 sal_uInt32 i, n = aDescr.m_nPage;
     906           0 :                 if (aDescr.m_nOffset) n += 1;
     907             : 
     908             :                 // Copy data pages.
     909           0 :                 OStoreDataPageObject aData;
     910           0 :                 for (i = 0; i < n; i++)
     911             :                 {
     912             :                     // Read 'Source' data page.
     913           0 :                     osl::MutexGuard aSrcGuard (*xSrcBIOS);
     914             : 
     915           0 :                     eErrCode = aSrcPage.read (i, aData, *xSrcBIOS);
     916           0 :                     if (eErrCode != store_E_None)
     917           0 :                         continue;
     918             : 
     919             :                     // Write 'Destination' data page. @@@ READONLY @@@
     920           0 :                     eErrCode = aDstPage.write (i, aData, *this);
     921           0 :                 }
     922             :             }
     923             : 
     924             :             // Update 'Destination' directory page.
     925           0 :             aDstPage.dataLength (nDataLen);
     926           0 :             eErrCode = base::saveObjectAt (aDstPage, aDstPage.location());
     927           0 :         }
     928             : 
     929             :         // Save directory scan results.
     930           0 :         flush();
     931             :     }
     932             : 
     933             :     // Pass Two: Scan 'Source' BTree nodes.
     934             :     {
     935             :         // Re-start 'Source' rebuild context.
     936           0 :         aCtx.initialize (STORE_MAGIC_BTREENODE);
     937             : 
     938             :         // Scan 'Source' BTree nodes.
     939           0 :         OStoreBTreeNodeObject aNode;
     940           0 :         while ((eErrCode = aCtx.load(aNode)) == store_E_None)
     941             :         {
     942             :             // Check for leaf node.
     943           0 :             PageHolderObject< page > xNode (aNode.get());
     944           0 :             if (xNode->depth() == 0)
     945             :             {
     946           0 :                 sal_uInt16 i, n = xNode->usageCount();
     947           0 :                 for (i = 0; i < n; i++)
     948             :                 {
     949           0 :                     entry e (xNode->m_pData[i]);
     950             : 
     951             :                     // Check for Hard link.
     952           0 :                     if (e.m_nAttrib & STORE_ATTRIB_ISLINK)
     953             :                     {
     954             :                         // Load the hard link destination.
     955           0 :                         OStoreDirectoryPageObject aSrcPage;
     956           0 :                         eErrCode = xSrcBIOS->loadObjectAt (aSrcPage, e.m_aLink.location());
     957           0 :                         if (eErrCode == store_E_None)
     958             :                         {
     959           0 :                             OStorePageKey aDstKey (aSrcPage.key());
     960           0 :                             eErrCode = link (e.m_aKey, aDstKey);
     961             :                         }
     962           0 :                         e.m_nAttrib &= ~STORE_ATTRIB_ISLINK;
     963             :                     }
     964             : 
     965           0 :                     if (e.m_nAttrib)
     966             :                     {
     967             :                         // Ordinary attributes.
     968           0 :                         sal_uInt32 nAttrib = 0;
     969           0 :                         eErrCode = attrib (e.m_aKey, 0, e.m_nAttrib, nAttrib);
     970             :                     }
     971             :                 }
     972             :             }
     973           0 :         }
     974             : 
     975             :         // Save BTree node scan results.
     976           0 :         flush();
     977             :     }
     978             : 
     979             :     // Done.
     980           0 :     return store_E_None;
     981             : }
     982             : 
     983             : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.10