LCOV - code coverage report
Current view: top level - store/source - stordata.cxx (source / functions) Hit Total Coverage
Test: commit 10e77ab3ff6f4314137acd6e2702a6e5c1ce1fae Lines: 87 449 19.4 %
Date: 2014-11-03 Functions: 10 24 41.7 %
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 "stordata.hxx"
      21             : 
      22             : #include "sal/types.h"
      23             : #include "sal/log.hxx"
      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         238 : storeError OStoreDataPageObject::guard (sal_uInt32 nAddr)
      41             : {
      42         238 :     return PageHolderObject< page >::guard (m_xPage, nAddr);
      43             : }
      44             : 
      45             : /*
      46             :  * verify.
      47             :  */
      48           0 : storeError OStoreDataPageObject::verify (sal_uInt32 nAddr) const
      49             : {
      50           0 :     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          16 : static storeError store_truncate_Impl (
      62             :     sal_uInt32      nAddr,
      63             :     sal_uInt16      nSingle,
      64             :     OStorePageBIOS &rBIOS)
      65             : {
      66          16 :     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          16 :     return store_E_None;
      94             : }
      95             : 
      96             : /*
      97             :  * store_truncate_Impl (double indirect page).
      98             :  */
      99           2 : static storeError store_truncate_Impl (
     100             :     sal_uInt32       nAddr,
     101             :     sal_uInt16       nDouble,
     102             :     sal_uInt16       nSingle,
     103             :     OStorePageBIOS  &rBIOS)
     104             : {
     105           2 :     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           2 :     return store_E_None;
     133             : }
     134             : 
     135             : /*
     136             :  * store_truncate_Impl (triple indirect page).
     137             :  */
     138           2 : 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           2 :     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           2 :     return store_E_None;
     168             : }
     169             : 
     170             : /*
     171             :  * loadOrCreate.
     172             :  */
     173           0 : storeError OStoreIndirectionPageObject::loadOrCreate (
     174             :     sal_uInt32       nAddr,
     175             :     OStorePageBIOS & rBIOS)
     176             : {
     177           0 :     if (nAddr == STORE_PAGE_NULL)
     178             :     {
     179           0 :         storeError eErrCode = construct<page>(rBIOS.allocator());
     180           0 :         if (eErrCode != store_E_None)
     181           0 :             return eErrCode;
     182             : 
     183           0 :         eErrCode = rBIOS.allocate (*this);
     184           0 :         if (eErrCode != store_E_None)
     185           0 :             return eErrCode;
     186             : 
     187             :         // Save location pending at caller.
     188           0 :         return store_E_Pending;
     189             :     }
     190           0 :     return rBIOS.loadObjectAt (*this, nAddr);
     191             : }
     192             : 
     193             : /*
     194             :  * guard.
     195             :  */
     196           0 : storeError OStoreIndirectionPageObject::guard (sal_uInt32 nAddr)
     197             : {
     198           0 :     return PageHolderObject< page >::guard (m_xPage, nAddr);
     199             : }
     200             : 
     201             : /*
     202             :  * verify.
     203             :  */
     204           0 : storeError OStoreIndirectionPageObject::verify (sal_uInt32 nAddr) const
     205             : {
     206           0 :     return PageHolderObject< page >::verify (m_xPage, nAddr);
     207             : }
     208             : 
     209             : /*
     210             :  * read (single indirect).
     211             :  */
     212           0 : storeError OStoreIndirectionPageObject::read (
     213             :     sal_uInt16             nSingle,
     214             :     OStoreDataPageObject  &rData,
     215             :     OStorePageBIOS        &rBIOS)
     216             : {
     217           0 :     PageHolderObject< page > xImpl (m_xPage);
     218           0 :     page const & rPage = (*xImpl);
     219             : 
     220             :     // Check arguments.
     221           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     222           0 :     if (!(nSingle < nLimit))
     223           0 :         return store_E_InvalidAccess;
     224             : 
     225             :     // Obtain data page location.
     226           0 :     sal_uInt32 const nAddr = store::ntohl(rPage.m_pData[nSingle]);
     227           0 :     if (nAddr == STORE_PAGE_NULL)
     228           0 :         return store_E_NotExists;
     229             : 
     230             :     // Load data page and leave.
     231           0 :     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           0 : storeError OStoreIndirectionPageObject::write (
     303             :     sal_uInt16             nSingle,
     304             :     OStoreDataPageObject  &rData,
     305             :     OStorePageBIOS        &rBIOS)
     306             : {
     307           0 :     PageHolderObject< page > xImpl (m_xPage);
     308           0 :     page & rPage = (*xImpl);
     309             : 
     310             :     // Check arguments.
     311           0 :     sal_uInt16 const nLimit = rPage.capacityCount();
     312           0 :     if (!(nSingle < nLimit))
     313           0 :         return store_E_InvalidAccess;
     314             : 
     315             :     // Obtain data page location.
     316           0 :     sal_uInt32 const nAddr = store::ntohl(rPage.m_pData[nSingle]);
     317           0 :     if (nAddr == STORE_PAGE_NULL)
     318             :     {
     319             :         // Allocate data page.
     320           0 :         storeError eErrCode = rBIOS.allocate (rData);
     321           0 :         if (eErrCode != store_E_None)
     322           0 :             return eErrCode;
     323             : 
     324             :         // Store data page location.
     325           0 :         rPage.m_pData[nSingle] = store::htonl(rData.location());
     326             : 
     327             :         // Save this page.
     328           0 :         return rBIOS.saveObjectAt (*this, location());
     329             :     }
     330             :     else
     331             :     {
     332             :         // Save data page.
     333           0 :         return rBIOS.saveObjectAt (rData, nAddr);
     334           0 :     }
     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        2714 : storeError OStoreDirectoryPageObject::guard (sal_uInt32 nAddr)
     571             : {
     572        2714 :     return PageHolderObject< page >::guard (m_xPage, nAddr);
     573             : }
     574             : 
     575             : /*
     576             :  * verify.
     577             :  */
     578           0 : storeError OStoreDirectoryPageObject::verify (sal_uInt32 nAddr) const
     579             : {
     580           0 :     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         474 : OStoreDirectoryPageObject::scope (
     589             :     sal_uInt32                       nPage,
     590             :     page::DataBlock::LinkDescriptor &rDescr) const
     591             : {
     592         474 :     page const & rPage = PAGE();
     593             : 
     594             :     sal_uInt32 index0, index1, index2, index3;
     595             : 
     596             :     // direct.
     597         474 :     sal_uInt32 nCount = OStoreDirectoryDataBlock::directCount();
     598         474 :     sal_uInt32 nLimit = nCount;
     599         474 :     if (nPage < nLimit)
     600             :     {
     601             :         // Page to index reduction.
     602         474 :         index0 = nPage;
     603             : 
     604             :         // Setup LinkDescriptor indices.
     605         474 :         rDescr.m_nIndex0 = (sal_uInt16)(index0 & 0xffff);
     606             : 
     607             :         // Done.
     608         474 :         return page::SCOPE_DIRECT;
     609             :     }
     610           0 :     nPage -= nLimit;
     611             : 
     612             :     // single indirect.
     613           0 :     sal_uInt32 const nCapacity = indirect::capacityCount(rPage.m_aDescr);
     614           0 :     nCount = OStoreDirectoryDataBlock::singleCount();
     615           0 :     nLimit = nCount * nCapacity;
     616           0 :     if (nPage < nLimit)
     617             :     {
     618             :         // Page to index reduction.
     619           0 :         sal_uInt32 n = nPage;
     620             : 
     621             :         // Reduce to single indirect i(1), direct n = i(0).
     622           0 :         index1 = n / nCapacity;
     623           0 :         index0 = n % nCapacity;
     624             : 
     625             :         // Verify reduction.
     626           0 :         n = index1 * nCapacity + index0;
     627           0 :         if (n != nPage)
     628             :         {
     629             :             SAL_WARN("store", "wrong math on indirect indices");
     630           0 :             return page::SCOPE_UNKNOWN;
     631             :         }
     632             : 
     633             :         // Setup LinkDescriptor indices.
     634           0 :         rDescr.m_nIndex0 = (sal_uInt16)(index0 & 0xffff);
     635           0 :         rDescr.m_nIndex1 = (sal_uInt16)(index1 & 0xffff);
     636             : 
     637             :         // Done.
     638           0 :         return page::SCOPE_SINGLE;
     639             :     }
     640           0 :     nPage -= nLimit;
     641             : 
     642             :     // double indirect.
     643           0 :     nCount = OStoreDirectoryDataBlock::doubleCount();
     644           0 :     nLimit = nCount * nCapacity * nCapacity;
     645           0 :     if (nPage < nLimit)
     646             :     {
     647             :         // Page to index reduction.
     648           0 :         sal_uInt32 n = nPage;
     649             : 
     650             :         // Reduce to double indirect i(2), single indirect n = i(0).
     651           0 :         index2 = n / (nCapacity * nCapacity);
     652           0 :         n      = n % (nCapacity * nCapacity);
     653             : 
     654             :         // Reduce to single indirect i(1), direct n = i(0).
     655           0 :         index1 = n / nCapacity;
     656           0 :         index0 = n % nCapacity;
     657             : 
     658             :         // Verify reduction.
     659           0 :         n = index2 * nCapacity * nCapacity +
     660           0 :             index1 * nCapacity + index0;
     661           0 :         if (n != nPage)
     662             :         {
     663             :             SAL_WARN("store", "wrong math on double indirect indices");
     664           0 :             return page::SCOPE_UNKNOWN;
     665             :         }
     666             : 
     667             :         // Setup LinkDescriptor indices.
     668           0 :         rDescr.m_nIndex0 = (sal_uInt16)(index0 & 0xffff);
     669           0 :         rDescr.m_nIndex1 = (sal_uInt16)(index1 & 0xffff);
     670           0 :         rDescr.m_nIndex2 = (sal_uInt16)(index2 & 0xffff);
     671             : 
     672             :         // Done.
     673           0 :         return page::SCOPE_DOUBLE;
     674             :     }
     675           0 :     nPage -= nLimit;
     676             : 
     677             :     // triple indirect.
     678           0 :     nCount = OStoreDirectoryDataBlock::tripleCount();
     679           0 :     nLimit = nCount * nCapacity * nCapacity * nCapacity;
     680           0 :     if (nPage < nLimit)
     681             :     {
     682             :         // Page to index reduction.
     683           0 :         sal_uInt32 n = nPage;
     684             : 
     685             :         // Reduce to triple indirect i(3), double indirect n.
     686           0 :         index3 = n / (nCapacity * nCapacity * nCapacity);
     687           0 :         n      = n % (nCapacity * nCapacity * nCapacity);
     688             : 
     689             :         // Reduce to double indirect i(2), single indirect n.
     690           0 :         index2 = n / (nCapacity * nCapacity);
     691           0 :         n      = n % (nCapacity * nCapacity);
     692             : 
     693             :         // Reduce to single indirect i(1), direct n = i(0).
     694           0 :         index1 = n / nCapacity;
     695           0 :         index0 = n % nCapacity;
     696             : 
     697             :         // Verify reduction.
     698           0 :         n = index3 * nCapacity * nCapacity * nCapacity +
     699           0 :             index2 * nCapacity * nCapacity +
     700           0 :             index1 * nCapacity + index0;
     701           0 :         if (n != nPage)
     702             :         {
     703             :             SAL_WARN("store", "wrong math on triple indirect indices");
     704           0 :             return page::SCOPE_UNKNOWN;
     705             :         }
     706             : 
     707             :         // Setup LinkDescriptor indices.
     708           0 :         rDescr.m_nIndex0 = (sal_uInt16)(index0 & 0xffff);
     709           0 :         rDescr.m_nIndex1 = (sal_uInt16)(index1 & 0xffff);
     710           0 :         rDescr.m_nIndex2 = (sal_uInt16)(index2 & 0xffff);
     711           0 :         rDescr.m_nIndex3 = (sal_uInt16)(index3 & 0xffff);
     712             : 
     713             :         // Done.
     714           0 :         return page::SCOPE_TRIPLE;
     715             :     }
     716             : 
     717             :     // Unreachable (more than triple indirect).
     718           0 :     return page::SCOPE_UNREACHABLE;
     719             : }
     720             : 
     721             : /*
     722             :  * read (external data page).
     723             :  */
     724         234 : storeError OStoreDirectoryPageObject::read (
     725             :     sal_uInt32             nPage,
     726             :     OStoreDataPageObject  &rData,
     727             :     OStorePageBIOS        &rBIOS)
     728             : {
     729             :     // Determine scope and link indices.
     730         234 :     page::DataBlock::LinkDescriptor aLink;
     731         234 :     page::ChunkScope eScope = scope (nPage, aLink);
     732             : 
     733         234 :     storeError eErrCode = store_E_None;
     734         234 :     if (eScope == page::SCOPE_DIRECT)
     735             :     {
     736         234 :         sal_uInt32 const nAddr = directLink (aLink.m_nIndex0);
     737         234 :         if (nAddr == STORE_PAGE_NULL)
     738         232 :             return store_E_NotExists;
     739             : 
     740           2 :         eErrCode = rBIOS.loadObjectAt (rData, nAddr);
     741             :     }
     742           0 :     else if (eScope == page::SCOPE_SINGLE)
     743             :     {
     744           0 :         sal_uInt32 const nAddr = singleLink (aLink.m_nIndex1);
     745           0 :         if (nAddr == STORE_PAGE_NULL)
     746           0 :             return store_E_NotExists;
     747             : 
     748           0 :         OStoreIndirectionPageObject aSingle;
     749           0 :         eErrCode = rBIOS.loadObjectAt (aSingle, nAddr);
     750           0 :         if (eErrCode != store_E_None)
     751           0 :             return eErrCode;
     752             : 
     753           0 :         eErrCode = aSingle.read (aLink.m_nIndex0, rData, rBIOS);
     754             :     }
     755           0 :     else if (eScope == page::SCOPE_DOUBLE)
     756             :     {
     757           0 :         sal_uInt32 const nAddr = doubleLink (aLink.m_nIndex2);
     758           0 :         if (nAddr == STORE_PAGE_NULL)
     759           0 :             return store_E_NotExists;
     760             : 
     761           0 :         OStoreIndirectionPageObject aDouble;
     762           0 :         eErrCode = rBIOS.loadObjectAt (aDouble, nAddr);
     763           0 :         if (eErrCode != store_E_None)
     764           0 :             return eErrCode;
     765             : 
     766           0 :         eErrCode = aDouble.read (aLink.m_nIndex1, aLink.m_nIndex0, rData, rBIOS);
     767             :     }
     768           0 :     else if (eScope == page::SCOPE_TRIPLE)
     769             :     {
     770           0 :         sal_uInt32 const nAddr = tripleLink (aLink.m_nIndex3);
     771           0 :         if (nAddr == STORE_PAGE_NULL)
     772           0 :             return store_E_NotExists;
     773             : 
     774           0 :         OStoreIndirectionPageObject aTriple;
     775           0 :         eErrCode = rBIOS.loadObjectAt (aTriple, nAddr);
     776           0 :         if (eErrCode != store_E_None)
     777           0 :             return eErrCode;
     778             : 
     779           0 :         eErrCode = aTriple.read (aLink.m_nIndex2, aLink.m_nIndex1, aLink.m_nIndex0, rData, rBIOS);
     780             :     }
     781           0 :     else if (eScope == page::SCOPE_UNREACHABLE)
     782             :     {
     783             :         // Out of scope.
     784           0 :         eErrCode = store_E_CantSeek;
     785             :     }
     786             :     else
     787             :     {
     788             :         // Unknown scope.
     789             :         OSL_TRACE("OStoreDirectoryPageObject::get(): scope failed");
     790           0 :         eErrCode = store_E_Unknown;
     791             :     }
     792             : 
     793             :     // Leave.
     794           2 :     return eErrCode;
     795             : }
     796             : 
     797             : /*
     798             :  * write (external data page).
     799             :  */
     800         238 : storeError OStoreDirectoryPageObject::write (
     801             :     sal_uInt32             nPage,
     802             :     OStoreDataPageObject  &rData,
     803             :     OStorePageBIOS        &rBIOS)
     804             : {
     805             :     // Determine scope and link indices.
     806         238 :     page::DataBlock::LinkDescriptor aLink;
     807         238 :     page::ChunkScope eScope = scope (nPage, aLink);
     808             : 
     809         238 :     storeError eErrCode = store_E_None;
     810         238 :     if (eScope == page::SCOPE_DIRECT)
     811             :     {
     812         238 :         sal_uInt32 const nAddr = directLink (aLink.m_nIndex0);
     813         238 :         if (nAddr == STORE_PAGE_NULL)
     814             :         {
     815             :             // Allocate data page.
     816         238 :             eErrCode = rBIOS.allocate (rData);
     817         238 :             if (eErrCode != store_E_None)
     818           0 :                 return eErrCode;
     819             : 
     820             :             // Store data page location.
     821         238 :             directLink (aLink.m_nIndex0, rData.location());
     822             :         }
     823             :         else
     824             :         {
     825             :             // Save data page.
     826           0 :             eErrCode = rBIOS.saveObjectAt (rData, nAddr);
     827             :         }
     828             :     }
     829           0 :     else if (eScope == page::SCOPE_SINGLE)
     830             :     {
     831           0 :         OStoreIndirectionPageObject aSingle;
     832           0 :         eErrCode = aSingle.loadOrCreate (singleLink (aLink.m_nIndex1), rBIOS);
     833           0 :         if (eErrCode != store_E_None)
     834             :         {
     835           0 :             if (eErrCode != store_E_Pending)
     836           0 :                 return eErrCode;
     837           0 :             singleLink (aLink.m_nIndex1, aSingle.location());
     838             :         }
     839             : 
     840           0 :         eErrCode = aSingle.write (aLink.m_nIndex0, rData, rBIOS);
     841             :     }
     842           0 :     else if (eScope == page::SCOPE_DOUBLE)
     843             :     {
     844           0 :         OStoreIndirectionPageObject aDouble;
     845           0 :         eErrCode = aDouble.loadOrCreate (doubleLink (aLink.m_nIndex2), rBIOS);
     846           0 :         if (eErrCode != store_E_None)
     847             :         {
     848           0 :             if (eErrCode != store_E_Pending)
     849           0 :                 return eErrCode;
     850           0 :             doubleLink (aLink.m_nIndex2, aDouble.location());
     851             :         }
     852             : 
     853           0 :         eErrCode = aDouble.write (aLink.m_nIndex1, aLink.m_nIndex0, rData, rBIOS);
     854             :     }
     855           0 :     else if (eScope == page::SCOPE_TRIPLE)
     856             :     {
     857           0 :         OStoreIndirectionPageObject aTriple;
     858           0 :         eErrCode = aTriple.loadOrCreate (tripleLink (aLink.m_nIndex3), rBIOS);
     859           0 :         if (eErrCode != store_E_None)
     860             :         {
     861           0 :             if (eErrCode != store_E_Pending)
     862           0 :                 return eErrCode;
     863           0 :             tripleLink (aLink.m_nIndex3, aTriple.location());
     864             :         }
     865             : 
     866           0 :         eErrCode = aTriple.write (aLink.m_nIndex2, aLink.m_nIndex1, aLink.m_nIndex0, rData, rBIOS);
     867             :     }
     868           0 :     else if (eScope == page::SCOPE_UNREACHABLE)
     869             :     {
     870             :         // Out of scope.
     871           0 :         eErrCode = store_E_CantSeek;
     872             :     }
     873             :     else
     874             :     {
     875             :         // Unknown scope.
     876             :         OSL_TRACE("OStoreDirectoryPageObject::put(): scope failed");
     877           0 :         eErrCode = store_E_Unknown;
     878             :     }
     879             : 
     880             :     // Leave.
     881         238 :     return eErrCode;
     882             : }
     883             : 
     884             : /*
     885             :  * truncate (external data page).
     886             :  */
     887           2 : storeError OStoreDirectoryPageObject::truncate (
     888             :     sal_uInt32             nPage,
     889             :     OStorePageBIOS        &rBIOS)
     890             : {
     891             :     // Determine scope and link indices.
     892           2 :     page::DataBlock::LinkDescriptor aLink;
     893           2 :     page::ChunkScope eScope = scope (nPage, aLink);
     894             : 
     895           2 :     storeError eErrCode = store_E_None;
     896           2 :     if (eScope == page::SCOPE_DIRECT)
     897             :     {
     898             :         // Truncate all triple indirect pages.
     899           2 :         eErrCode = truncate (page::SCOPE_TRIPLE, 0, rBIOS);
     900           2 :         if (eErrCode != store_E_None)
     901           0 :             return eErrCode;
     902             : 
     903             :         // Truncate all double indirect pages.
     904           2 :         eErrCode = truncate (page::SCOPE_DOUBLE, 0, rBIOS);
     905           2 :         if (eErrCode != store_E_None)
     906           0 :             return eErrCode;
     907             : 
     908             :         // Truncate all single indirect pages.
     909           2 :         eErrCode = truncate (page::SCOPE_SINGLE, 0, rBIOS);
     910           2 :         if (eErrCode != store_E_None)
     911           0 :             return eErrCode;
     912             : 
     913             :         // Truncate direct pages, including 'aLink.m_nIndex0'.
     914           2 :         eErrCode = truncate (eScope, aLink.m_nIndex0, rBIOS);
     915             :     }
     916           0 :     else if (eScope == page::SCOPE_SINGLE)
     917             :     {
     918             :         // Truncate all triple indirect pages.
     919           0 :         eErrCode = truncate (page::SCOPE_TRIPLE, 0, rBIOS);
     920           0 :         if (eErrCode != store_E_None)
     921           0 :             return eErrCode;
     922             : 
     923             :         // Truncate all double indirect pages.
     924           0 :         eErrCode = truncate (page::SCOPE_DOUBLE, 0, rBIOS);
     925           0 :         if (eErrCode != store_E_None)
     926           0 :             return eErrCode;
     927             : 
     928             :         // Truncate single indirect pages, downto 'aLink.m_nIndex1'.
     929           0 :         eErrCode = truncate (eScope, aLink.m_nIndex1 + 1, rBIOS);
     930           0 :         if (eErrCode != store_E_None)
     931           0 :             return eErrCode;
     932             : 
     933             :         // Truncate last single indirect page to ... pages.
     934           0 :         eErrCode = store_truncate_Impl (singleLink (aLink.m_nIndex1), aLink.m_nIndex0, rBIOS);
     935           0 :         if (eErrCode != store_E_None)
     936           0 :             return eErrCode;
     937             : 
     938             :         // Check for complete truncation.
     939           0 :         if (aLink.m_nIndex0 == 0)
     940             :         {
     941             :             // Clear pointer to last single indirect page.
     942           0 :             singleLink (aLink.m_nIndex1, STORE_PAGE_NULL);
     943             :         }
     944             :     }
     945           0 :     else if (eScope == page::SCOPE_DOUBLE)
     946             :     {
     947             :         // Truncate all triple indirect pages.
     948           0 :         eErrCode = truncate (page::SCOPE_TRIPLE, 0, rBIOS);
     949           0 :         if (eErrCode != store_E_None)
     950           0 :             return eErrCode;
     951             : 
     952             :         // Truncate double indirect pages, downto 'aLink.m_nIndex2'.
     953           0 :         eErrCode = truncate (eScope, aLink.m_nIndex2 + 1, rBIOS);
     954           0 :         if (eErrCode != store_E_None)
     955           0 :             return eErrCode;
     956             : 
     957             :         // Truncate last double indirect page to ... pages.
     958             :         eErrCode = store_truncate_Impl (
     959           0 :             doubleLink (aLink.m_nIndex2), aLink.m_nIndex1, aLink.m_nIndex0, rBIOS);
     960           0 :         if (eErrCode != store_E_None)
     961           0 :             return eErrCode;
     962             : 
     963             :         // Check for complete truncation.
     964           0 :         if ((aLink.m_nIndex1 + aLink.m_nIndex0) == 0)
     965             :         {
     966             :             // Clear pointer to last double indirect page.
     967           0 :             doubleLink (aLink.m_nIndex2, STORE_PAGE_NULL);
     968             :         }
     969             :     }
     970           0 :     else if (eScope == page::SCOPE_TRIPLE)
     971             :     {
     972             :         // Truncate triple indirect pages, downto 'aLink.m_nIndex3'.
     973           0 :         eErrCode = truncate (eScope, aLink.m_nIndex3 + 1, rBIOS);
     974           0 :         if (eErrCode != store_E_None)
     975           0 :             return eErrCode;
     976             : 
     977             :         // Truncate last triple indirect page to ... pages.
     978             :         eErrCode = store_truncate_Impl (
     979           0 :             tripleLink (aLink.m_nIndex3), aLink.m_nIndex2, aLink.m_nIndex1, aLink.m_nIndex0, rBIOS);
     980           0 :         if (eErrCode != store_E_None)
     981           0 :             return eErrCode;
     982             : 
     983             :         // Check for complete truncation.
     984           0 :         if ((aLink.m_nIndex2 + aLink.m_nIndex1 + aLink.m_nIndex0) == 0)
     985             :         {
     986             :             // Clear pointer to last triple indirect page.
     987           0 :             tripleLink (aLink.m_nIndex3, STORE_PAGE_NULL);
     988             :         }
     989             :     }
     990           0 :     else if (eScope == page::SCOPE_UNREACHABLE)
     991             :     {
     992             :         // Out of scope.
     993           0 :         eErrCode = store_E_CantSeek;
     994             :     }
     995             :     else
     996             :     {
     997             :         // Unknown scope.
     998             :         OSL_TRACE("OStoreDirectoryPageObject::put(): scope failed");
     999           0 :         eErrCode = store_E_Unknown;
    1000             :     }
    1001             : 
    1002             :     // Leave.
    1003           2 :     return eErrCode;
    1004             : }
    1005             : 
    1006             : /*
    1007             :  * truncate (external data page scope; private).
    1008             :  */
    1009           8 : storeError OStoreDirectoryPageObject::truncate (
    1010             :     page::ChunkScope       eScope,
    1011             :     sal_uInt16             nRemain,
    1012             :     OStorePageBIOS        &rBIOS)
    1013             : {
    1014             :     // Enter.
    1015           8 :     storeError eErrCode = store_E_None;
    1016           8 :     if (eScope == page::SCOPE_DIRECT)
    1017             :     {
    1018             :         // Truncate direct data pages.
    1019           2 :         sal_uInt16 i, n = OStoreDirectoryDataBlock::directCount();
    1020          34 :         for (i = n; i > nRemain; i--)
    1021             :         {
    1022             :             // Obtain data page location.
    1023          32 :             sal_uInt32 nAddr = directLink (i - 1);
    1024          32 :             if (nAddr == STORE_PAGE_NULL) continue;
    1025             : 
    1026             :             // Free data page.
    1027           2 :             eErrCode = rBIOS.free (nAddr);
    1028           2 :             if (eErrCode != store_E_None)
    1029           0 :                 break;
    1030             : 
    1031             :             // Clear pointer to data page.
    1032           2 :             directLink (i - 1, STORE_PAGE_NULL);
    1033             :         }
    1034             : 
    1035             :         // Done.
    1036           2 :         return eErrCode;
    1037             :     }
    1038             : 
    1039           6 :     if (eScope == page::SCOPE_SINGLE)
    1040             :     {
    1041             :         // Truncate single indirect pages.
    1042           2 :         sal_uInt16 i, n = OStoreDirectoryDataBlock::singleCount();
    1043          18 :         for (i = n; i > nRemain; i--)
    1044             :         {
    1045             :             // Truncate single indirect page to zero data pages.
    1046          16 :             eErrCode = store_truncate_Impl (singleLink (i - 1), 0, rBIOS);
    1047          16 :             if (eErrCode != store_E_None)
    1048           0 :                 break;
    1049             : 
    1050             :             // Clear pointer to single indirect page.
    1051          16 :             singleLink (i - 1, STORE_PAGE_NULL);
    1052             :         }
    1053             : 
    1054             :         // Done.
    1055           2 :         return eErrCode;
    1056             :     }
    1057             : 
    1058           4 :     if (eScope == page::SCOPE_DOUBLE)
    1059             :     {
    1060             :         // Truncate double indirect pages.
    1061           2 :         sal_uInt16 i, n = OStoreDirectoryDataBlock::doubleCount();
    1062           4 :         for (i = n; i > nRemain; i--)
    1063             :         {
    1064             :             // Truncate double indirect page to zero single indirect pages.
    1065           2 :             eErrCode = store_truncate_Impl (doubleLink (i - 1), 0, 0, rBIOS);
    1066           2 :             if (eErrCode != store_E_None)
    1067           0 :                 break;
    1068             : 
    1069             :             // Clear pointer to double indirect page.
    1070           2 :             doubleLink (i - 1, STORE_PAGE_NULL);
    1071             :         }
    1072             : 
    1073             :         // Done.
    1074           2 :         return eErrCode;
    1075             :     }
    1076             : 
    1077           2 :     if (eScope == page::SCOPE_TRIPLE)
    1078             :     {
    1079             :         // Truncate triple indirect pages.
    1080           2 :         sal_uInt16 i, n = OStoreDirectoryDataBlock::tripleCount();
    1081           4 :         for (i = n; i > nRemain; i--)
    1082             :         {
    1083             :             // Truncate to zero double indirect pages.
    1084           2 :             eErrCode = store_truncate_Impl (tripleLink (i - 1), 0, 0, 0, rBIOS);
    1085           2 :             if (eErrCode != store_E_None)
    1086           0 :                 break;
    1087             : 
    1088             :             // Clear pointer to triple indirect page.
    1089           2 :             tripleLink (i - 1, STORE_PAGE_NULL);
    1090             :         }
    1091             : 
    1092             :         // Done.
    1093           2 :         return eErrCode;
    1094             :     }
    1095             : 
    1096             :     // Invalid scope.
    1097           0 :     return store_E_InvalidAccess;
    1098             : }
    1099             : 
    1100             : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.10