store/source/stordir.cxx

   1 /*************************************************************************
   2  *
   3  *  OpenOffice.org - a multi-platform office productivity suite
   4  *
   5  *  $RCSfile: stordir.cxx,v $
   6  *
   7  *  $Revision: 1.1.2.2 $
   8  *
   9  *  last change: $Author: mhu $ $Date: 2008/10/17 16:30:17 $
  10  *
  11  *  The Contents of this file are made available subject to
  12  *  the terms of GNU Lesser General Public License Version 2.1.
  13  *
  14  *
  15  *    GNU Lesser General Public License Version 2.1
  16  *    =============================================
  17  *    Copyright 2005 by Sun Microsystems, Inc.
  18  *    901 San Antonio Road, Palo Alto, CA 94303, USA
  19  *
  20  *    This library is free software; you can redistribute it and/or
  21  *    modify it under the terms of the GNU Lesser General Public
  22  *    License version 2.1, as published by the Free Software Foundation.
  23  *
  24  *    This library is distributed in the hope that it will be useful,
  25  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
  26  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  27  *    Lesser General Public License for more details.
  28  *
  29  *    You should have received a copy of the GNU Lesser General Public
  30  *    License along with this library; if not, write to the Free Software
  31  *    Foundation, Inc., 59 Temple Place, Suite 330, Boston,
  32  *    MA  02111-1307  USA
  33  *
  34  ************************************************************************/
  35
  36 // MARKER(update_precomp.py): autogen include statement, do not remove
  37 #include "precompiled_store.hxx"
  38
  39 #include "stordir.hxx"
  40
  41 #ifndef _SAL_TYPES_H_
  42 #include <sal/types.h>
  43 #endif
  44
  45 #ifndef _RTL_TEXTCVT_H_
  46 #include <rtl/textcvt.h>
  47 #endif
  48 #ifndef _RTL_REF_HXX_
  49 #include <rtl/ref.hxx>
  50 #endif
  51
  52 #ifndef _OSL_MUTEX_HXX_
  53 #include <osl/mutex.hxx>
  54 #endif
  55
  56 #ifndef _STORE_TYPES_H_
  57 #include "store/types.h"
  58 #endif
  59 #ifndef _STORE_OBJECT_HXX_
  60 #include "object.hxx"
  61 #endif
  62
  63 #ifndef _STORE_STORBASE_HXX_
  64 #include "storbase.hxx"
  65 #endif
  66 #ifndef _STORE_STORDATA_HXX_
  67 #include "stordata.hxx"
  68 #endif
  69 #ifndef _STORE_STORPAGE_HXX_
  70 #include "storpage.hxx"
  71 #endif
  72
  73 using namespace store;
  74
  75 /*========================================================================
  76  *
  77  * OStore... internals.
  78  *
  79  *======================================================================*/
  80 /*
  81  * __store_convertTextToUnicode.
  82  */
  83 inline sal_Size __store_convertTextToUnicode (
  84     rtl_TextToUnicodeConverter  hConverter,
  85     const sal_Char *pSrcBuffer, sal_Size nSrcLength,
  86     sal_Unicode    *pDstBuffer, sal_Size nDstLength)
  87 {
  88     sal_uInt32 nCvtInfo = 0;
  89     sal_Size nCvtBytes = 0;
  90     return rtl_convertTextToUnicode (
  91         hConverter, 0,
  92         pSrcBuffer, nSrcLength,
  93         pDstBuffer, nDstLength,
  94         OSTRING_TO_OUSTRING_CVTFLAGS,
  95         &nCvtInfo, &nCvtBytes);
  96 }
  97
  98 /*========================================================================
  99  *
 100  * OStoreDirectory_Impl implementation.
 101  *
 102  *======================================================================*/
 103 const sal_uInt32 OStoreDirectory_Impl::m_nTypeId = sal_uInt32(0x89191107);
 104
 105 /*
 106  * OStoreDirectory_Impl.
 107  */
 108 OStoreDirectory_Impl::OStoreDirectory_Impl (void)
 109     : m_xManager (),
 110       m_aDescr   (0, 0, 0),
 111       m_nPath    (0),
 112       m_hTextCvt (NULL)
 113 {}
 114
 115 /*
 116  * ~OStoreDirectory_Impl.
 117  */
 118 OStoreDirectory_Impl::~OStoreDirectory_Impl (void)
 119 {
 120     if (m_xManager.is())
 121     {
 122         if (m_aDescr.m_nAddr != STORE_PAGE_NULL)
 123             m_xManager->releasePage (m_aDescr, store_AccessReadOnly);
 124     }
 125     rtl_destroyTextToUnicodeConverter (m_hTextCvt);
 126 }
 127
 128 /*
 129  * isKindOf.
 130  */
 131 sal_Bool SAL_CALL OStoreDirectory_Impl::isKindOf (sal_uInt32 nTypeId)
 132 {
 133     return (nTypeId == m_nTypeId);
 134 }
 135
 136 /*
 137  * create.
 138  */
 139 storeError OStoreDirectory_Impl::create (
 140     OStorePageManager *pManager,
 141     rtl_String        *pPath,
 142     rtl_String        *pName,
 143     storeAccessMode    eMode)
 144 {
 145     rtl::Reference<OStorePageManager> xManager (pManager);
 146     if (!xManager.is())
 147         return store_E_InvalidAccess;
 148
 149     if (!(pPath && pName))
 150         return store_E_InvalidParameter;
 151
 152     OStoreDirectoryPageObject aPage;
 153     storeError eErrCode = xManager->iget (
 154         aPage, STORE_ATTRIB_ISDIR,
 155         pPath, pName, eMode);
 156     if (eErrCode != store_E_None)
 157         return eErrCode;
 158
 159     if (!(aPage.attrib() & STORE_ATTRIB_ISDIR))
 160         return store_E_NotDirectory;
 161
 162     inode_holder_type xNode (aPage.get());
 163     eErrCode = xManager->acquirePage (xNode->m_aDescr, store_AccessReadOnly);
 164     if (eErrCode != store_E_None)
 165         return eErrCode;
 166
 167     // Evaluate iteration path.
 168     m_nPath = aPage.path();
 169     m_nPath = rtl_crc32 (m_nPath, "/", 1);
 170
 171     // Save page manager, and descriptor.
 172     m_xManager = xManager;
 173     m_aDescr   = xNode->m_aDescr;
 174
 175     return store_E_None;
 176 }
 177
 178 /*
 179  * iterate.
 180  */
 181 storeError OStoreDirectory_Impl::iterate (storeFindData &rFindData)
 182 {
 183     if (!m_xManager.is())
 184         return store_E_InvalidAccess;
 185
 186     storeError eErrCode = store_E_NoMoreFiles;
 187     if (!rFindData.m_nReserved)
 188         return eErrCode;
 189
 190     // Acquire exclusive access.
 191     osl::MutexGuard aGuard (*m_xManager);
 192
 193     // Check TextConverter.
 194     if (m_hTextCvt == NULL)
 195         m_hTextCvt = rtl_createTextToUnicodeConverter(RTL_TEXTENCODING_UTF8);
 196
 197     // Setup iteration key.
 198     OStorePageKey aKey (rFindData.m_nReserved, m_nPath);
 199
 200     // Iterate.
 201     for (;;)
 202     {
 203         OStorePageLink aLink;
 204         eErrCode = m_xManager->iterate (aKey, aLink, rFindData.m_nAttrib);
 205         if (!((eErrCode == store_E_None) && (aKey.m_nHigh == store::htonl(m_nPath))))
 206             break;
 207
 208         if (!(rFindData.m_nAttrib & STORE_ATTRIB_ISLINK))
 209         {
 210             // Load page.
 211             OStoreDirectoryPageObject aPage;
 212             eErrCode = m_xManager->loadObjectAt (aPage, aLink.location());
 213             if (eErrCode == store_E_None)
 214             {
 215                 inode_holder_type xNode (aPage.get());
 216
 217                 // Setup FindData.
 218                 sal_Char *p = xNode->m_aNameBlock.m_pData;
 219                 sal_Size  n = rtl_str_getLength (p);
 220                 sal_Size  k = rFindData.m_nLength;
 221
 222                 n = __store_convertTextToUnicode (
 223                     m_hTextCvt, p, n,
 224                     rFindData.m_pszName, STORE_MAXIMUM_NAMESIZE - 1);
 225                 if (k > n)
 226                 {
 227                     k = (k - n) * sizeof(sal_Unicode);
 228                     memset (&rFindData.m_pszName[n], 0, k);
 229                 }
 230
 231                 rFindData.m_nLength  = n;
 232                 rFindData.m_nAttrib |= aPage.attrib();
 233                 rFindData.m_nSize    = aPage.dataLength();
 234
 235                 // Leave.
 236                 rFindData.m_nReserved = store::ntohl(aKey.m_nLow);
 237                 return store_E_None;
 238             }
 239         }
 240
 241         if (aKey.m_nLow == 0)
 242             break;
 243         aKey.m_nLow = store::htonl(store::ntohl(aKey.m_nLow) - 1);
 244     }
 245
 246     // Finished.
 247     memset (&rFindData, 0, sizeof (storeFindData));
 248     return store_E_NoMoreFiles;
 249 }