LCOV - code coverage report
Current view: top level - libreoffice/store/source - stordata.cxx (source / functions) Hit Total Coverage
Test: libreoffice_filtered.info Lines: 153 448 34.2 %
Date: 2012-12-27 Functions: 17 24 70.8 %
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             : 
      21             : #include "stordata.hxx"
      22             : 
      23             : #include "sal/types.h"
      24             : #include "osl/diagnose.h"
      25             : 
      26             : #include "store/types.h"
      27             : #include "storbase.hxx"
      28             : #include "storbios.hxx"
      29             : 
      30             : using namespace store;
      31             : 
      32             : /*========================================================================
      33             :  *
      34             :  * OStoreDataPageObject implementation.
      35             :  *
      36             :  *======================================================================*/
      37             : /*
      38             :  * guard.
      39             :  */
      40       22117 : storeError OStoreDataPageObject::guard (sal_uInt32 nAddr)
      41             : {
      42       22117 :     return PageHolderObject< page >::guard (m_xPage, nAddr);
      43             : }
      44             : 
      45             : /*
      46             :  * verify.
      47             :  */
      48       50948 : storeError OStoreDataPageObject::verify (sal_uInt32 nAddr) const
      49             : {
      50       50948 :     return PageHolderObject< page >::verify (m_xPage, nAddr);
      51             : }
      52             : 
      53             : /*========================================================================
      54             :  *
      55             :  * OStoreIndirectionPageObject implementation.
      56             :  *
      57             :  *======================================================================*/
      58             : /*
      59             :   * store_truncate_Impl (single indirect page).
      60             :   */
      61          32 : static storeError store_truncate_Impl (
      62             :     sal_uInt32      nAddr,
      63             :     sal_uInt16      nSingle,
      64             :     OStorePageBIOS &rBIOS)
      65             : {
      66          32 :     if (nAddr != STORE_PAGE_NULL)
      67             :     {
      68             :         // Load single indirect page.
      69           0 :         OStoreIndirectionPageObject aSingle;
      70           0 :         storeError eErrCode = rBIOS.loadObjectAt (aSingle, nAddr);
      71           0 :         if (eErrCode == store_E_None)
      72             :         {
      73             :             // Truncate to 'nSingle' direct pages.
      74           0 :             eErrCode = aSingle.truncate (nSingle, rBIOS);
      75           0 :             if (eErrCode != store_E_None)
      76           0 :                 return eErrCode;
      77             :         }
      78             :         else
      79             :         {
      80           0 :             if (eErrCode != store_E_InvalidChecksum)
      81           0 :                 return eErrCode;
      82             :         }
      83             : 
      84             :         // Check for complete truncation.
      85           0 :         if (nSingle == 0)
      86             :         {
      87             :             // Free single indirect page.
      88           0 :             eErrCode = rBIOS.free (nAddr);
      89           0 :             if (eErrCode != store_E_None)
      90           0 :                 return eErrCode;
      91           0 :         }
      92             :     }
      93          32 :     return store_E_None;
      94             : }
      95             : 
      96             : /*
      97             :  * store_truncate_Impl (double indirect page).
      98             :  */
      99           4 : static storeError store_truncate_Impl (
     100             :     sal_uInt32       nAddr,
     101             :     sal_uInt16       nDouble,
     102             :     sal_uInt16       nSingle,
     103             :     OStorePageBIOS  &rBIOS)
     104             : {
     105           4 :     if (nAddr != STORE_PAGE_NULL)
     106             :     {
     107             :         // Load double indirect page.
     108           0 :         OStoreIndirectionPageObject aDouble;
     109           0 :         storeError eErrCode = rBIOS.loadObjectAt (aDouble, nAddr);
     110           0 :         if (eErrCode == store_E_None)
     111             :         {
     112             :             // Truncate to 'nDouble', 'nSingle' pages.
     113           0 :             eErrCode = aDouble.truncate (nDouble, nSingle, rBIOS);
     114           0 :             if (eErrCode != store_E_None)
     115           0 :                 return eErrCode;
     116             :         }
     117             :         else
     118             :         {
     119           0 :             if (eErrCode != store_E_InvalidChecksum)
     120           0 :                 return eErrCode;
     121             :         }
     122             : 
     123             :         // Check for complete truncation.
     124           0 :         if ((nDouble + nSingle) == 0)
     125             :         {
     126             :             // Free double indirect page.
     127           0 :             eErrCode = rBIOS.free (nAddr);
     128           0 :             if (eErrCode != store_E_None)
     129           0 :                 return eErrCode;
     130           0 :         }
     131             :     }
     132           4 :     return store_E_None;
     133             : }
     134             : 
     135             : /*
     136             :  * store_truncate_Impl (triple indirect page).
     137             :  */
     138           4 : static storeError store_truncate_Impl (
     139             :     sal_uInt32       nAddr,
     140             :     sal_uInt16       nTriple,
     141             :     sal_uInt16       nDouble,
     142             :     sal_uInt16       nSingle,
     143             :     OStorePageBIOS  &rBIOS)
     144             : {
     145           4 :     if (nAddr != STORE_PAGE_NULL)
     146             :     {
     147             :         // Load triple indirect page.
     148           0 :         OStoreIndirectionPageObject aTriple;
     149           0 :         storeError eErrCode = rBIOS.loadObjectAt (aTriple, nAddr);
     150           0 :         if (eErrCode != store_E_None)
     151           0 :             return eErrCode;
     152             : 
     153             :         // Truncate to 'nTriple', 'nDouble', 'nSingle' pages.
     154           0 :         eErrCode = aTriple.truncate (nTriple, nDouble, nSingle, rBIOS);
     155           0 :         if (eErrCode != store_E_None)
     156           0 :             return eErrCode;
     157             : 
     158             :         // Check for complete truncation.
     159           0 :         if ((nTriple + nDouble + nSingle) == 0)
     160             :         {
     161             :             // Free triple indirect page.
     162           0 :             eErrCode = rBIOS.free (nAddr);
     163           0 :             if (eErrCode != store_E_None)
     164           0 :                 return eErrCode;
     165           0 :         }
     166             :     }
     167           4 :     return store_E_None;
     168             : }
     169             : 
     170             : /*
     171             :  * loadOrCreate.
     172             :  */
     173         516 : storeError OStoreIndirectionPageObject::loadOrCreate (
     174             :     sal_uInt32       nAddr,
     175             :     OStorePageBIOS & rBIOS)
     176             : {
     177         516 :     if (nAddr == STORE_PAGE_NULL)
     178             :     {
     179          31 :         storeError eErrCode = construct<page>(rBIOS.allocator());
     180          31 :         if (eErrCode != store_E_None)
     181           0 :             return eErrCode;
     182             : 
     183          31 :         eErrCode = rBIOS.allocate (*this);
     184          31 :         if (eErrCode != store_E_None)
     185           0 :             return eErrCode;
     186             : 
     187             :         // Save location pending at caller.
     188          31 :         return store_E_Pending;
     189             :     }
     190         485 :     return rBIOS.loadObjectAt (*this, nAddr);
     191             : }
     192             : 
     193             : /*
     194             :  * guard.
     195             :  */
     196         547 : storeError OStoreIndirectionPageObject::guard (sal_uInt32 nAddr)
     197             : {
     198         547 :     return PageHolderObject< page >::guard (m_xPage, nAddr);
     199             : }
     200             : 
     201             : /*
     202             :  * verify.
     203             :  */
     204          40 : storeError OStoreIndirectionPageObject::verify (sal_uInt32 nAddr) const
     205             : {
     206          40 :     return PageHolderObject< page >::verify (m_xPage, nAddr);
     207             : }
     208             : 
     209             : /*
     210             :  * read (single indirect).
     211             :  */
     212        1718 : storeError OStoreIndirectionPageObject::read (
     213             :     sal_uInt16             nSingle,
     214             :     OStoreDataPageObject  &rData,
     215             :     OStorePageBIOS        &rBIOS)
     216             : {
     217        1718 :     PageHolderObject< page > xImpl (m_xPage);
     218        1718 :     page const & rPage = (*xImpl);
     219             : 
     220             :     // Check arguments.
     221        1718 :     sal_uInt16 const nLimit = rPage.capacityCount();
     222        1718 :     if (!(nSingle < nLimit))
     223           0 :         return store_E_InvalidAccess;
     224             : 
     225             :     // Obtain data page location.
     226        1718 :     sal_uInt32 const nAddr = store::ntohl(rPage.m_pData[nSingle]);
     227        1718 :     if (nAddr == STORE_PAGE_NULL)
     228          31 :         return store_E_NotExists;
     229             : 
     230             :     // Load data page and leave.
     231        1687 :     return rBIOS.loadObjectAt (rData, nAddr);
     232             : }
     233             : 
     234             : /*
     235             :  * read (double indirect).
     236             :  */
     237           0 : storeError OStoreIndirectionPageObject::read (
     238             :     sal_uInt16             nDouble,
     239             :     sal_uInt16             nSingle,
     240             :     OStoreDataPageObject  &rData,
     241             :     OStorePageBIOS        &rBIOS)
     242             : {
     243           0 :     PageHolderObject< page > xImpl (m_xPage);
     244           0 :     page const & rPage = (*xImpl);
     245             : 
     246             :     // Check arguments.
     247           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     248           0 :     if (!((nDouble < nLimit) && (nSingle < nLimit)))
     249           0 :         return store_E_InvalidAccess;
     250             : 
     251             :     // Check single indirect page location.
     252           0 :     sal_uInt32 const nAddr = store::ntohl(rPage.m_pData[nDouble]);
     253           0 :     if (nAddr == STORE_PAGE_NULL)
     254           0 :         return store_E_NotExists;
     255             : 
     256             :     // Load single indirect page.
     257           0 :     OStoreIndirectionPageObject aSingle;
     258           0 :     storeError eErrCode = rBIOS.loadObjectAt (aSingle, nAddr);
     259           0 :     if (eErrCode != store_E_None)
     260           0 :         return eErrCode;
     261             : 
     262             :     // Read single indirect and leave.
     263           0 :     return aSingle.read (nSingle, rData, rBIOS);
     264             : }
     265             : 
     266             : /*
     267             :  * read (triple indirect).
     268             :  */
     269           0 : storeError OStoreIndirectionPageObject::read (
     270             :     sal_uInt16             nTriple,
     271             :     sal_uInt16             nDouble,
     272             :     sal_uInt16             nSingle,
     273             :     OStoreDataPageObject  &rData,
     274             :     OStorePageBIOS        &rBIOS)
     275             : {
     276           0 :     PageHolderObject< page > xImpl (m_xPage);
     277           0 :     page const & rPage = (*xImpl);
     278             : 
     279             :     // Check arguments.
     280           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     281           0 :     if (!((nTriple < nLimit) && (nDouble < nLimit) && (nSingle < nLimit)))
     282           0 :         return store_E_InvalidAccess;
     283             : 
     284             :     // Check double indirect page location.
     285           0 :     sal_uInt32 const nAddr = store::ntohl(rPage.m_pData[nTriple]);
     286           0 :     if (nAddr == STORE_PAGE_NULL)
     287           0 :         return store_E_NotExists;
     288             : 
     289             :     // Load double indirect page.
     290           0 :     OStoreIndirectionPageObject aDouble;
     291           0 :     storeError eErrCode = rBIOS.loadObjectAt (aDouble, nAddr);
     292           0 :     if (eErrCode != store_E_None)
     293           0 :         return eErrCode;
     294             : 
     295             :     // Read double indirect and leave.
     296           0 :     return aDouble.read (nDouble, nSingle, rData, rBIOS);
     297             : }
     298             : 
     299             : /*
     300             :  * write (single indirect).
     301             :  */
     302         516 : storeError OStoreIndirectionPageObject::write (
     303             :     sal_uInt16             nSingle,
     304             :     OStoreDataPageObject  &rData,
     305             :     OStorePageBIOS        &rBIOS)
     306             : {
     307         516 :     PageHolderObject< page > xImpl (m_xPage);
     308         516 :     page & rPage = (*xImpl);
     309             : 
     310             :     // Check arguments.
     311         516 :     sal_uInt16 const nLimit = rPage.capacityCount();
     312         516 :     if (!(nSingle < nLimit))
     313           0 :         return store_E_InvalidAccess;
     314             : 
     315             :     // Obtain data page location.
     316         516 :     sal_uInt32 const nAddr = store::ntohl(rPage.m_pData[nSingle]);
     317         516 :     if (nAddr == STORE_PAGE_NULL)
     318             :     {
     319             :         // Allocate data page.
     320         516 :         storeError eErrCode = rBIOS.allocate (rData);
     321         516 :         if (eErrCode != store_E_None)
     322           0 :             return eErrCode;
     323             : 
     324             :         // Store data page location.
     325         516 :         rPage.m_pData[nSingle] = store::htonl(rData.location());
     326             : 
     327             :         // Save this page.
     328         516 :         return rBIOS.saveObjectAt (*this, location());
     329             :     }
     330             :     else
     331             :     {
     332             :         // Save data page.
     333           0 :         return rBIOS.saveObjectAt (rData, nAddr);
     334         516 :     }
     335             : }
     336             : 
     337             : /*
     338             :  * write (double indirect).
     339             :  */
     340           0 : storeError OStoreIndirectionPageObject::write (
     341             :     sal_uInt16             nDouble,
     342             :     sal_uInt16             nSingle,
     343             :     OStoreDataPageObject  &rData,
     344             :     OStorePageBIOS        &rBIOS)
     345             : {
     346           0 :     PageHolderObject< page > xImpl (m_xPage);
     347           0 :     page & rPage = (*xImpl);
     348             : 
     349             :     // Check arguments.
     350           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     351           0 :     if (!((nDouble < nLimit) && (nSingle < nLimit)))
     352           0 :         return store_E_InvalidAccess;
     353             : 
     354             :     // Load or create single indirect page.
     355           0 :     OStoreIndirectionPageObject aSingle;
     356           0 :     storeError eErrCode = aSingle.loadOrCreate (store::ntohl(rPage.m_pData[nDouble]), rBIOS);
     357           0 :     if (eErrCode != store_E_None)
     358             :     {
     359           0 :         if (eErrCode != store_E_Pending)
     360           0 :             return eErrCode;
     361           0 :         rPage.m_pData[nDouble] = store::htonl(aSingle.location());
     362             : 
     363           0 :         eErrCode = rBIOS.saveObjectAt (*this, location());
     364           0 :         if (eErrCode != store_E_None)
     365           0 :             return eErrCode;
     366             :     }
     367             : 
     368             :     // Write single indirect and leave.
     369           0 :     return aSingle.write (nSingle, rData, rBIOS);
     370             : }
     371             : 
     372             : /*
     373             :  * write (triple indirect).
     374             :  */
     375           0 : storeError OStoreIndirectionPageObject::write (
     376             :     sal_uInt16             nTriple,
     377             :     sal_uInt16             nDouble,
     378             :     sal_uInt16             nSingle,
     379             :     OStoreDataPageObject  &rData,
     380             :     OStorePageBIOS        &rBIOS)
     381             : {
     382           0 :     PageHolderObject< page > xImpl (m_xPage);
     383           0 :     page & rPage = (*xImpl);
     384             : 
     385             :     // Check arguments.
     386           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     387           0 :     if (!((nTriple < nLimit) && (nDouble < nLimit) && (nSingle < nLimit)))
     388           0 :         return store_E_InvalidAccess;
     389             : 
     390             :     // Load or create double indirect page.
     391           0 :     OStoreIndirectionPageObject aDouble;
     392           0 :     storeError eErrCode = aDouble.loadOrCreate (store::ntohl(rPage.m_pData[nTriple]), rBIOS);
     393           0 :     if (eErrCode != store_E_None)
     394             :     {
     395           0 :         if (eErrCode != store_E_Pending)
     396           0 :             return eErrCode;
     397           0 :         rPage.m_pData[nTriple] = store::htonl(aDouble.location());
     398             : 
     399           0 :         eErrCode = rBIOS.saveObjectAt (*this, location());
     400           0 :         if (eErrCode != store_E_None)
     401           0 :             return eErrCode;
     402             :     }
     403             : 
     404             :     // Write double indirect and leave.
     405           0 :     return aDouble.write (nDouble, nSingle, rData, rBIOS);
     406             : }
     407             : 
     408             : /*
     409             :  * truncate (single indirect).
     410             :  */
     411           0 : storeError OStoreIndirectionPageObject::truncate (
     412             :     sal_uInt16       nSingle,
     413             :     OStorePageBIOS & rBIOS)
     414             : {
     415           0 :     PageHolderObject< page > xImpl (m_xPage);
     416           0 :     page & rPage = (*xImpl);
     417             : 
     418             :     // Check arguments.
     419           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     420           0 :     if (!(nSingle < nLimit))
     421           0 :         return store_E_InvalidAccess;
     422             : 
     423             :     // Truncate.
     424           0 :     storeError eErrCode = store_E_None;
     425           0 :     for (sal_uInt16 i = nLimit; i > nSingle; i--)
     426             :     {
     427             :         // Obtain data page location.
     428           0 :         sal_uInt32 const nAddr = store::ntohl(rPage.m_pData[i - 1]);
     429           0 :         if (nAddr != STORE_PAGE_NULL)
     430             :         {
     431             :             // Free data page.
     432           0 :             eErrCode = rBIOS.free (nAddr);
     433           0 :             if (eErrCode != store_E_None)
     434           0 :                 return eErrCode;
     435             : 
     436             :             // Clear pointer to data page.
     437           0 :             rPage.m_pData[i - 1] = STORE_PAGE_NULL;
     438           0 :             touch();
     439             :         }
     440             :     }
     441             : 
     442             :     // Check for modified page.
     443           0 :     if (dirty())
     444             :     {
     445             :         // Save this page.
     446           0 :         eErrCode = rBIOS.saveObjectAt (*this, location());
     447             :     }
     448             : 
     449             :     // Done.
     450           0 :     return eErrCode;
     451             : }
     452             : 
     453             : /*
     454             :  * truncate (double indirect).
     455             :  */
     456           0 : storeError OStoreIndirectionPageObject::truncate (
     457             :     sal_uInt16             nDouble,
     458             :     sal_uInt16             nSingle,
     459             :     OStorePageBIOS        &rBIOS)
     460             : {
     461           0 :     PageHolderObject< page > xImpl (m_xPage);
     462           0 :     page & rPage = (*xImpl);
     463             : 
     464             :     // Check arguments.
     465           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     466           0 :     if (!((nDouble < nLimit) && (nSingle < nLimit)))
     467           0 :         return store_E_InvalidAccess;
     468             : 
     469             :     // Truncate.
     470           0 :     storeError eErrCode = store_E_None;
     471           0 :     for (sal_uInt16 i = nLimit; i > nDouble + 1; i--)
     472             :     {
     473             :         // Truncate single indirect page to zero direct pages.
     474           0 :         eErrCode = store_truncate_Impl (store::ntohl(rPage.m_pData[i - 1]), 0, rBIOS);
     475           0 :         if (eErrCode != store_E_None)
     476           0 :             return eErrCode;
     477             : 
     478             :         // Clear pointer to single indirect page.
     479           0 :         rPage.m_pData[i - 1] = STORE_PAGE_NULL;
     480           0 :         touch();
     481             :     }
     482             : 
     483             :     // Truncate last single indirect page to 'nSingle' direct pages.
     484           0 :     eErrCode = store_truncate_Impl (store::ntohl(rPage.m_pData[nDouble]), nSingle, rBIOS);
     485           0 :     if (eErrCode != store_E_None)
     486           0 :         return eErrCode;
     487             : 
     488             :     // Check for complete truncation.
     489           0 :     if (nSingle == 0)
     490             :     {
     491             :         // Clear pointer to last single indirect page.
     492           0 :         rPage.m_pData[nDouble] = STORE_PAGE_NULL;
     493           0 :         touch();
     494             :     }
     495             : 
     496             :     // Check for modified page.
     497           0 :     if (dirty())
     498             :     {
     499             :         // Save this page.
     500           0 :         eErrCode = rBIOS.saveObjectAt (*this, location());
     501             :     }
     502             : 
     503             :     // Done.
     504           0 :     return eErrCode;
     505             : }
     506             : 
     507             : /*
     508             :  * truncate (triple indirect).
     509             :  */
     510           0 : storeError OStoreIndirectionPageObject::truncate (
     511             :     sal_uInt16             nTriple,
     512             :     sal_uInt16             nDouble,
     513             :     sal_uInt16             nSingle,
     514             :     OStorePageBIOS        &rBIOS)
     515             : {
     516           0 :     PageHolderObject< page > xImpl (m_xPage);
     517           0 :     page & rPage = (*xImpl);
     518             : 
     519             :     // Check arguments.
     520           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     521           0 :     if (!((nTriple < nLimit) && (nDouble < nLimit) && (nSingle < nLimit)))
     522           0 :         return store_E_InvalidAccess;
     523             : 
     524             :     // Truncate.
     525           0 :     storeError eErrCode = store_E_None;
     526           0 :     for (sal_uInt16 i = nLimit; i > nTriple + 1; i--)
     527             :     {
     528             :         // Truncate double indirect page to zero single indirect pages.
     529           0 :         eErrCode = store_truncate_Impl (store::ntohl(rPage.m_pData[i - 1]), 0, 0, rBIOS);
     530           0 :         if (eErrCode != store_E_None)
     531           0 :             return eErrCode;
     532             : 
     533             :         // Clear pointer to double indirect page.
     534           0 :         rPage.m_pData[i - 1] = STORE_PAGE_NULL;
     535           0 :         touch();
     536             :     }
     537             : 
     538             :     // Truncate last double indirect page to 'nDouble', 'nSingle' pages.
     539           0 :     eErrCode = store_truncate_Impl (store::ntohl(rPage.m_pData[nTriple]), nDouble, nSingle, rBIOS);
     540           0 :     if (eErrCode != store_E_None)
     541           0 :         return eErrCode;
     542             : 
     543             :     // Check for complete truncation.
     544           0 :     if ((nDouble + nSingle) == 0)
     545             :     {
     546             :         // Clear pointer to last double indirect page.
     547           0 :         rPage.m_pData[nTriple] = STORE_PAGE_NULL;
     548           0 :         touch();
     549             :     }
     550             : 
     551             :     // Check for modified page.
     552           0 :     if (dirty())
     553             :     {
     554             :         // Save this page.
     555           0 :         eErrCode = rBIOS.saveObjectAt (*this, location());
     556             :     }
     557             : 
     558             :     // Done.
     559           0 :     return eErrCode;
     560             : }
     561             : 
     562             : /*========================================================================
     563             :  *
     564             :  * OStoreDirectoryPageObject implementation.
     565             :  *
     566             :  *======================================================================*/
     567             : /*
     568             :  * guard.
     569             :  */
     570      156975 : storeError OStoreDirectoryPageObject::guard (sal_uInt32 nAddr)
     571             : {
     572      156975 :     return PageHolderObject< page >::guard (m_xPage, nAddr);
     573             : }
     574             : 
     575             : /*
     576             :  * verify.
     577             :  */
     578      123938 : storeError OStoreDirectoryPageObject::verify (sal_uInt32 nAddr) const
     579             : {
     580      123938 :     return PageHolderObject< page >::verify (m_xPage, nAddr);
     581             :     // OLD: m_rPage.verifyVersion (STORE_MAGIC_DIRECTORYPAGE);
     582             : }
     583             : 
     584             : /*
     585             :  * scope (external data page; private).
     586             :  */
     587             : OStoreDirectoryPageData::ChunkScope
     588      133670 : OStoreDirectoryPageObject::scope (
     589             :     sal_uInt32                       nPage,
     590             :     page::DataBlock::LinkDescriptor &rDescr) const
     591             : {
     592      133670 :     page const & rPage = PAGE();
     593      133670 :     OStoreDirectoryDataBlock const & rDataBlock = rPage.m_aDataBlock;
     594             : 
     595             :     sal_uInt32 index0, index1, index2, index3;
     596             : 
     597             :     // direct.
     598      133670 :     sal_uInt32 nCount = rDataBlock.directCount();
     599      133670 :     sal_uInt32 nLimit = nCount;
     600      133670 :     if (nPage < nLimit)
     601             :     {
     602             :         // Page to index reduction.
     603      131436 :         index0 = nPage;
     604             : 
     605             :         // Setup LinkDescriptor indices.
     606      131436 :         rDescr.m_nIndex0 = (sal_uInt16)(index0 & 0xffff);
     607             : 
     608             :         // Done.
     609      131436 :         return page::SCOPE_DIRECT;
     610             :     }
     611        2234 :     nPage -= nLimit;
     612             : 
     613             :     // single indirect.
     614        2234 :     sal_uInt32 const nCapacity = indirect::capacityCount(rPage.m_aDescr);
     615        2234 :     nCount = rDataBlock.singleCount();
     616        2234 :     nLimit = nCount * nCapacity;
     617        2234 :     if (nPage < nLimit)
     618             :     {
     619             :         // Page to index reduction.
     620        2234 :         sal_uInt32 n = nPage;
     621             : 
     622             :         // Reduce to single indirect i(1), direct n = i(0).
     623        2234 :         index1 = n / nCapacity;
     624        2234 :         index0 = n % nCapacity;
     625             : 
     626             :         // Verify reduction.
     627        2234 :         n = index1 * nCapacity + index0;
     628             :         OSL_POSTCOND(n == nPage, "wrong math on indirect indices");
     629        2234 :         if (n != nPage)
     630           0 :             return page::SCOPE_UNKNOWN;
     631             : 
     632             :         // Setup LinkDescriptor indices.
     633        2234 :         rDescr.m_nIndex0 = (sal_uInt16)(index0 & 0xffff);
     634        2234 :         rDescr.m_nIndex1 = (sal_uInt16)(index1 & 0xffff);
     635             : 
     636             :         // Done.
     637        2234 :         return page::SCOPE_SINGLE;
     638             :     }
     639           0 :     nPage -= nLimit;
     640             : 
     641             :     // double indirect.
     642           0 :     nCount = rDataBlock.doubleCount();
     643           0 :     nLimit = nCount * nCapacity * nCapacity;
     644           0 :     if (nPage < nLimit)
     645             :     {
     646             :         // Page to index reduction.
     647           0 :         sal_uInt32 n = nPage;
     648             : 
     649             :         // Reduce to double indirect i(2), single indirect n = i(0).
     650           0 :         index2 = n / (nCapacity * nCapacity);
     651           0 :         n      = n % (nCapacity * nCapacity);
     652             : 
     653             :         // Reduce to single indirect i(1), direct n = i(0).
     654           0 :         index1 = n / nCapacity;
     655           0 :         index0 = n % nCapacity;
     656             : 
     657             :         // Verify reduction.
     658             :         n = index2 * nCapacity * nCapacity +
     659           0 :             index1 * nCapacity + index0;
     660             :         OSL_POSTCOND(n == nPage, "wrong math on double indirect indices");
     661           0 :         if (n != nPage)
     662           0 :             return page::SCOPE_UNKNOWN;
     663             : 
     664             :         // Setup LinkDescriptor indices.
     665           0 :         rDescr.m_nIndex0 = (sal_uInt16)(index0 & 0xffff);
     666           0 :         rDescr.m_nIndex1 = (sal_uInt16)(index1 & 0xffff);
     667           0 :         rDescr.m_nIndex2 = (sal_uInt16)(index2 & 0xffff);
     668             : 
     669             :         // Done.
     670           0 :         return page::SCOPE_DOUBLE;
     671             :     }
     672           0 :     nPage -= nLimit;
     673             : 
     674             :     // triple indirect.
     675           0 :     nCount = rDataBlock.tripleCount();
     676           0 :     nLimit = nCount * nCapacity * nCapacity * nCapacity;
     677           0 :     if (nPage < nLimit)
     678             :     {
     679             :         // Page to index reduction.
     680           0 :         sal_uInt32 n = nPage;
     681             : 
     682             :         // Reduce to triple indirect i(3), double indirect n.
     683           0 :         index3 = n / (nCapacity * nCapacity * nCapacity);
     684           0 :         n      = n % (nCapacity * nCapacity * nCapacity);
     685             : 
     686             :         // Reduce to double indirect i(2), single indirect n.
     687           0 :         index2 = n / (nCapacity * nCapacity);
     688           0 :         n      = n % (nCapacity * nCapacity);
     689             : 
     690             :         // Reduce to single indirect i(1), direct n = i(0).
     691           0 :         index1 = n / nCapacity;
     692           0 :         index0 = n % nCapacity;
     693             : 
     694             :         // Verify reduction.
     695             :         n = index3 * nCapacity * nCapacity * nCapacity +
     696             :             index2 * nCapacity * nCapacity +
     697           0 :             index1 * nCapacity + index0;
     698             :         OSL_POSTCOND(n == nPage, "wrong math on triple indirect indices");
     699           0 :         if (n != nPage)
     700           0 :             return page::SCOPE_UNKNOWN;
     701             : 
     702             :         // Setup LinkDescriptor indices.
     703           0 :         rDescr.m_nIndex0 = (sal_uInt16)(index0 & 0xffff);
     704           0 :         rDescr.m_nIndex1 = (sal_uInt16)(index1 & 0xffff);
     705           0 :         rDescr.m_nIndex2 = (sal_uInt16)(index2 & 0xffff);
     706           0 :         rDescr.m_nIndex3 = (sal_uInt16)(index3 & 0xffff);
     707             : 
     708             :         // Done.
     709           0 :         return page::SCOPE_TRIPLE;
     710             :     }
     711             : 
     712             :     // Unreachable (more than triple indirect).
     713           0 :     return page::SCOPE_UNREACHABLE;
     714             : }
     715             : 
     716             : /*
     717             :  * read (external data page).
     718             :  */
     719      111549 : storeError OStoreDirectoryPageObject::read (
     720             :     sal_uInt32             nPage,
     721             :     OStoreDataPageObject  &rData,
     722             :     OStorePageBIOS        &rBIOS)
     723             : {
     724             :     // Determine scope and link indices.
     725      111549 :     page::DataBlock::LinkDescriptor aLink;
     726      111549 :     page::ChunkScope eScope = scope (nPage, aLink);
     727             : 
     728      111549 :     storeError eErrCode = store_E_None;
     729      111549 :     if (eScope == page::SCOPE_DIRECT)
     730             :     {
     731      109831 :         sal_uInt32 const nAddr = directLink (aLink.m_nIndex0);
     732      109831 :         if (nAddr == STORE_PAGE_NULL)
     733       15966 :             return store_E_NotExists;
     734             : 
     735       93865 :         eErrCode = rBIOS.loadObjectAt (rData, nAddr);
     736             :     }
     737        1718 :     else if (eScope == page::SCOPE_SINGLE)
     738             :     {
     739        1718 :         sal_uInt32 const nAddr = singleLink (aLink.m_nIndex1);
     740        1718 :         if (nAddr == STORE_PAGE_NULL)
     741           0 :             return store_E_NotExists;
     742             : 
     743        1718 :         OStoreIndirectionPageObject aSingle;
     744        1718 :         eErrCode = rBIOS.loadObjectAt (aSingle, nAddr);
     745        1718 :         if (eErrCode != store_E_None)
     746           0 :             return eErrCode;
     747             : 
     748        1718 :         eErrCode = aSingle.read (aLink.m_nIndex0, rData, rBIOS);
     749             :     }
     750           0 :     else if (eScope == page::SCOPE_DOUBLE)
     751             :     {
     752           0 :         sal_uInt32 const nAddr = doubleLink (aLink.m_nIndex2);
     753           0 :         if (nAddr == STORE_PAGE_NULL)
     754           0 :             return store_E_NotExists;
     755             : 
     756           0 :         OStoreIndirectionPageObject aDouble;
     757           0 :         eErrCode = rBIOS.loadObjectAt (aDouble, nAddr);
     758           0 :         if (eErrCode != store_E_None)
     759           0 :             return eErrCode;
     760             : 
     761           0 :         eErrCode = aDouble.read (aLink.m_nIndex1, aLink.m_nIndex0, rData, rBIOS);
     762             :     }
     763           0 :     else if (eScope == page::SCOPE_TRIPLE)
     764             :     {
     765           0 :         sal_uInt32 const nAddr = tripleLink (aLink.m_nIndex3);
     766           0 :         if (nAddr == STORE_PAGE_NULL)
     767           0 :             return store_E_NotExists;
     768             : 
     769           0 :         OStoreIndirectionPageObject aTriple;
     770           0 :         eErrCode = rBIOS.loadObjectAt (aTriple, nAddr);
     771           0 :         if (eErrCode != store_E_None)
     772           0 :             return eErrCode;
     773             : 
     774           0 :         eErrCode = aTriple.read (aLink.m_nIndex2, aLink.m_nIndex1, aLink.m_nIndex0, rData, rBIOS);
     775             :     }
     776           0 :     else if (eScope == page::SCOPE_UNREACHABLE)
     777             :     {
     778             :         // Out of scope.
     779           0 :         eErrCode = store_E_CantSeek;
     780             :     }
     781             :     else
     782             :     {
     783             :         // Unknown scope.
     784             :         OSL_TRACE("OStoreDirectoryPageObject::get(): scope failed");
     785           0 :         eErrCode = store_E_Unknown;
     786             :     }
     787             : 
     788             :     // Leave.
     789       95583 :     return eErrCode;
     790             : }
     791             : 
     792             : /*
     793             :  * write (external data page).
     794             :  */
     795       22117 : storeError OStoreDirectoryPageObject::write (
     796             :     sal_uInt32             nPage,
     797             :     OStoreDataPageObject  &rData,
     798             :     OStorePageBIOS        &rBIOS)
     799             : {
     800             :     // Determine scope and link indices.
     801       22117 :     page::DataBlock::LinkDescriptor aLink;
     802       22117 :     page::ChunkScope eScope = scope (nPage, aLink);
     803             : 
     804       22117 :     storeError eErrCode = store_E_None;
     805       22117 :     if (eScope == page::SCOPE_DIRECT)
     806             :     {
     807       21601 :         sal_uInt32 const nAddr = directLink (aLink.m_nIndex0);
     808       21601 :         if (nAddr == STORE_PAGE_NULL)
     809             :         {
     810             :             // Allocate data page.
     811       21601 :             eErrCode = rBIOS.allocate (rData);
     812       21601 :             if (eErrCode != store_E_None)
     813           0 :                 return eErrCode;
     814             : 
     815             :             // Store data page location.
     816       21601 :             directLink (aLink.m_nIndex0, rData.location());
     817             :         }
     818             :         else
     819             :         {
     820             :             // Save data page.
     821           0 :             eErrCode = rBIOS.saveObjectAt (rData, nAddr);
     822             :         }
     823             :     }
     824         516 :     else if (eScope == page::SCOPE_SINGLE)
     825             :     {
     826         516 :         OStoreIndirectionPageObject aSingle;
     827         516 :         eErrCode = aSingle.loadOrCreate (singleLink (aLink.m_nIndex1), rBIOS);
     828         516 :         if (eErrCode != store_E_None)
     829             :         {
     830          31 :             if (eErrCode != store_E_Pending)
     831           0 :                 return eErrCode;
     832          31 :             singleLink (aLink.m_nIndex1, aSingle.location());
     833             :         }
     834             : 
     835         516 :         eErrCode = aSingle.write (aLink.m_nIndex0, rData, rBIOS);
     836             :     }
     837           0 :     else if (eScope == page::SCOPE_DOUBLE)
     838             :     {
     839           0 :         OStoreIndirectionPageObject aDouble;
     840           0 :         eErrCode = aDouble.loadOrCreate (doubleLink (aLink.m_nIndex2), rBIOS);
     841           0 :         if (eErrCode != store_E_None)
     842             :         {
     843           0 :             if (eErrCode != store_E_Pending)
     844           0 :                 return eErrCode;
     845           0 :             doubleLink (aLink.m_nIndex2, aDouble.location());
     846             :         }
     847             : 
     848           0 :         eErrCode = aDouble.write (aLink.m_nIndex1, aLink.m_nIndex0, rData, rBIOS);
     849             :     }
     850           0 :     else if (eScope == page::SCOPE_TRIPLE)
     851             :     {
     852           0 :         OStoreIndirectionPageObject aTriple;
     853           0 :         eErrCode = aTriple.loadOrCreate (tripleLink (aLink.m_nIndex3), rBIOS);
     854           0 :         if (eErrCode != store_E_None)
     855             :         {
     856           0 :             if (eErrCode != store_E_Pending)
     857           0 :                 return eErrCode;
     858           0 :             tripleLink (aLink.m_nIndex3, aTriple.location());
     859             :         }
     860             : 
     861           0 :         eErrCode = aTriple.write (aLink.m_nIndex2, aLink.m_nIndex1, aLink.m_nIndex0, rData, rBIOS);
     862             :     }
     863           0 :     else if (eScope == page::SCOPE_UNREACHABLE)
     864             :     {
     865             :         // Out of scope.
     866           0 :         eErrCode = store_E_CantSeek;
     867             :     }
     868             :     else
     869             :     {
     870             :         // Unknown scope.
     871             :         OSL_TRACE("OStoreDirectoryPageObject::put(): scope failed");
     872           0 :         eErrCode = store_E_Unknown;
     873             :     }
     874             : 
     875             :     // Leave.
     876       22117 :     return eErrCode;
     877             : }
     878             : 
     879             : /*
     880             :  * truncate (external data page).
     881             :  */
     882           4 : storeError OStoreDirectoryPageObject::truncate (
     883             :     sal_uInt32             nPage,
     884             :     OStorePageBIOS        &rBIOS)
     885             : {
     886             :     // Determine scope and link indices.
     887           4 :     page::DataBlock::LinkDescriptor aLink;
     888           4 :     page::ChunkScope eScope = scope (nPage, aLink);
     889             : 
     890           4 :     storeError eErrCode = store_E_None;
     891           4 :     if (eScope == page::SCOPE_DIRECT)
     892             :     {
     893             :         // Truncate all triple indirect pages.
     894           4 :         eErrCode = truncate (page::SCOPE_TRIPLE, 0, rBIOS);
     895           4 :         if (eErrCode != store_E_None)
     896           0 :             return eErrCode;
     897             : 
     898             :         // Truncate all double indirect pages.
     899           4 :         eErrCode = truncate (page::SCOPE_DOUBLE, 0, rBIOS);
     900           4 :         if (eErrCode != store_E_None)
     901           0 :             return eErrCode;
     902             : 
     903             :         // Truncate all single indirect pages.
     904           4 :         eErrCode = truncate (page::SCOPE_SINGLE, 0, rBIOS);
     905           4 :         if (eErrCode != store_E_None)
     906           0 :             return eErrCode;
     907             : 
     908             :         // Truncate direct pages, including 'aLink.m_nIndex0'.
     909           4 :         eErrCode = truncate (eScope, aLink.m_nIndex0, rBIOS);
     910             :     }
     911           0 :     else if (eScope == page::SCOPE_SINGLE)
     912             :     {
     913             :         // Truncate all triple indirect pages.
     914           0 :         eErrCode = truncate (page::SCOPE_TRIPLE, 0, rBIOS);
     915           0 :         if (eErrCode != store_E_None)
     916           0 :             return eErrCode;
     917             : 
     918             :         // Truncate all double indirect pages.
     919           0 :         eErrCode = truncate (page::SCOPE_DOUBLE, 0, rBIOS);
     920           0 :         if (eErrCode != store_E_None)
     921           0 :             return eErrCode;
     922             : 
     923             :         // Truncate single indirect pages, downto 'aLink.m_nIndex1'.
     924           0 :         eErrCode = truncate (eScope, aLink.m_nIndex1 + 1, rBIOS);
     925           0 :         if (eErrCode != store_E_None)
     926           0 :             return eErrCode;
     927             : 
     928             :         // Truncate last single indirect page to ... pages.
     929           0 :         eErrCode = store_truncate_Impl (singleLink (aLink.m_nIndex1), aLink.m_nIndex0, rBIOS);
     930           0 :         if (eErrCode != store_E_None)
     931           0 :             return eErrCode;
     932             : 
     933             :         // Check for complete truncation.
     934           0 :         if (aLink.m_nIndex0 == 0)
     935             :         {
     936             :             // Clear pointer to last single indirect page.
     937           0 :             singleLink (aLink.m_nIndex1, STORE_PAGE_NULL);
     938             :         }
     939             :     }
     940           0 :     else if (eScope == page::SCOPE_DOUBLE)
     941             :     {
     942             :         // Truncate all triple indirect pages.
     943           0 :         eErrCode = truncate (page::SCOPE_TRIPLE, 0, rBIOS);
     944           0 :         if (eErrCode != store_E_None)
     945           0 :             return eErrCode;
     946             : 
     947             :         // Truncate double indirect pages, downto 'aLink.m_nIndex2'.
     948           0 :         eErrCode = truncate (eScope, aLink.m_nIndex2 + 1, rBIOS);
     949           0 :         if (eErrCode != store_E_None)
     950           0 :             return eErrCode;
     951             : 
     952             :         // Truncate last double indirect page to ... pages.
     953             :         eErrCode = store_truncate_Impl (
     954           0 :             doubleLink (aLink.m_nIndex2), aLink.m_nIndex1, aLink.m_nIndex0, rBIOS);
     955           0 :         if (eErrCode != store_E_None)
     956           0 :             return eErrCode;
     957             : 
     958             :         // Check for complete truncation.
     959           0 :         if ((aLink.m_nIndex1 + aLink.m_nIndex0) == 0)
     960             :         {
     961             :             // Clear pointer to last double indirect page.
     962           0 :             doubleLink (aLink.m_nIndex2, STORE_PAGE_NULL);
     963             :         }
     964             :     }
     965           0 :     else if (eScope == page::SCOPE_TRIPLE)
     966             :     {
     967             :         // Truncate triple indirect pages, downto 'aLink.m_nIndex3'.
     968           0 :         eErrCode = truncate (eScope, aLink.m_nIndex3 + 1, rBIOS);
     969           0 :         if (eErrCode != store_E_None)
     970           0 :             return eErrCode;
     971             : 
     972             :         // Truncate last triple indirect page to ... pages.
     973             :         eErrCode = store_truncate_Impl (
     974           0 :             tripleLink (aLink.m_nIndex3), aLink.m_nIndex2, aLink.m_nIndex1, aLink.m_nIndex0, rBIOS);
     975           0 :         if (eErrCode != store_E_None)
     976           0 :             return eErrCode;
     977             : 
     978             :         // Check for complete truncation.
     979           0 :         if ((aLink.m_nIndex2 + aLink.m_nIndex1 + aLink.m_nIndex0) == 0)
     980             :         {
     981             :             // Clear pointer to last triple indirect page.
     982           0 :             tripleLink (aLink.m_nIndex3, STORE_PAGE_NULL);
     983             :         }
     984             :     }
     985           0 :     else if (eScope == page::SCOPE_UNREACHABLE)
     986             :     {
     987             :         // Out of scope.
     988           0 :         eErrCode = store_E_CantSeek;
     989             :     }
     990             :     else
     991             :     {
     992             :         // Unknown scope.
     993             :         OSL_TRACE("OStoreDirectoryPageObject::put(): scope failed");
     994           0 :         eErrCode = store_E_Unknown;
     995             :     }
     996             : 
     997             :     // Leave.
     998           4 :     return eErrCode;
     999             : }
    1000             : 
    1001             : /*
    1002             :  * truncate (external data page scope; private).
    1003             :  */
    1004          16 : storeError OStoreDirectoryPageObject::truncate (
    1005             :     page::ChunkScope       eScope,
    1006             :     sal_uInt16             nRemain,
    1007             :     OStorePageBIOS        &rBIOS)
    1008             : {
    1009          16 :     OStoreDirectoryDataBlock const & rDataBlock = PAGE().m_aDataBlock;
    1010             : 
    1011             :     // Enter.
    1012          16 :     storeError eErrCode = store_E_None;
    1013          16 :     if (eScope == page::SCOPE_DIRECT)
    1014             :     {
    1015             :         // Truncate direct data pages.
    1016           4 :         sal_uInt16 i, n = rDataBlock.directCount();
    1017          68 :         for (i = n; i > nRemain; i--)
    1018             :         {
    1019             :             // Obtain data page location.
    1020          64 :             sal_uInt32 nAddr = directLink (i - 1);
    1021          64 :             if (nAddr == STORE_PAGE_NULL) continue;
    1022             : 
    1023             :             // Free data page.
    1024           8 :             eErrCode = rBIOS.free (nAddr);
    1025           8 :             if (eErrCode != store_E_None)
    1026           0 :                 break;
    1027             : 
    1028             :             // Clear pointer to data page.
    1029           8 :             directLink (i - 1, STORE_PAGE_NULL);
    1030             :         }
    1031             : 
    1032             :         // Done.
    1033           4 :         return eErrCode;
    1034             :     }
    1035             : 
    1036          12 :     if (eScope == page::SCOPE_SINGLE)
    1037             :     {
    1038             :         // Truncate single indirect pages.
    1039           4 :         sal_uInt16 i, n = rDataBlock.singleCount();
    1040          36 :         for (i = n; i > nRemain; i--)
    1041             :         {
    1042             :             // Truncate single indirect page to zero data pages.
    1043          32 :             eErrCode = store_truncate_Impl (singleLink (i - 1), 0, rBIOS);
    1044          32 :             if (eErrCode != store_E_None)
    1045           0 :                 break;
    1046             : 
    1047             :             // Clear pointer to single indirect page.
    1048          32 :             singleLink (i - 1, STORE_PAGE_NULL);
    1049             :         }
    1050             : 
    1051             :         // Done.
    1052           4 :         return eErrCode;
    1053             :     }
    1054             : 
    1055           8 :     if (eScope == page::SCOPE_DOUBLE)
    1056             :     {
    1057             :         // Truncate double indirect pages.
    1058           4 :         sal_uInt16 i, n = rDataBlock.doubleCount();
    1059           8 :         for (i = n; i > nRemain; i--)
    1060             :         {
    1061             :             // Truncate double indirect page to zero single indirect pages.
    1062           4 :             eErrCode = store_truncate_Impl (doubleLink (i - 1), 0, 0, rBIOS);
    1063           4 :             if (eErrCode != store_E_None)
    1064           0 :                 break;
    1065             : 
    1066             :             // Clear pointer to double indirect page.
    1067           4 :             doubleLink (i - 1, STORE_PAGE_NULL);
    1068             :         }
    1069             : 
    1070             :         // Done.
    1071           4 :         return eErrCode;
    1072             :     }
    1073             : 
    1074           4 :     if (eScope == page::SCOPE_TRIPLE)
    1075             :     {
    1076             :         // Truncate triple indirect pages.
    1077           4 :         sal_uInt16 i, n = rDataBlock.tripleCount();
    1078           8 :         for (i = n; i > nRemain; i--)
    1079             :         {
    1080             :             // Truncate to zero double indirect pages.
    1081           4 :             eErrCode = store_truncate_Impl (tripleLink (i - 1), 0, 0, 0, rBIOS);
    1082           4 :             if (eErrCode != store_E_None)
    1083           0 :                 break;
    1084             : 
    1085             :             // Clear pointer to triple indirect page.
    1086           4 :             tripleLink (i - 1, STORE_PAGE_NULL);
    1087             :         }
    1088             : 
    1089             :         // Done.
    1090           4 :         return eErrCode;
    1091             :     }
    1092             : 
    1093             :     // Invalid scope.
    1094           0 :     return store_E_InvalidAccess;
    1095             : }
    1096             : 
    1097             : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.10