1*cdf0e10cSrcweir /************************************************************************* 2*cdf0e10cSrcweir * 3*cdf0e10cSrcweir * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4*cdf0e10cSrcweir * 5*cdf0e10cSrcweir * Copyright 2000, 2010 Oracle and/or its affiliates. 6*cdf0e10cSrcweir * 7*cdf0e10cSrcweir * OpenOffice.org - a multi-platform office productivity suite 8*cdf0e10cSrcweir * 9*cdf0e10cSrcweir * This file is part of OpenOffice.org. 10*cdf0e10cSrcweir * 11*cdf0e10cSrcweir * OpenOffice.org is free software: you can redistribute it and/or modify 12*cdf0e10cSrcweir * it under the terms of the GNU Lesser General Public License version 3 13*cdf0e10cSrcweir * only, as published by the Free Software Foundation. 14*cdf0e10cSrcweir * 15*cdf0e10cSrcweir * OpenOffice.org is distributed in the hope that it will be useful, 16*cdf0e10cSrcweir * but WITHOUT ANY WARRANTY; without even the implied warranty of 17*cdf0e10cSrcweir * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 18*cdf0e10cSrcweir * GNU Lesser General Public License version 3 for more details 19*cdf0e10cSrcweir * (a copy is included in the LICENSE file that accompanied this code). 20*cdf0e10cSrcweir * 21*cdf0e10cSrcweir * You should have received a copy of the GNU Lesser General Public License 22*cdf0e10cSrcweir * version 3 along with OpenOffice.org. If not, see 23*cdf0e10cSrcweir * <http://www.openoffice.org/license.html> 24*cdf0e10cSrcweir * for a copy of the LGPLv3 License. 25*cdf0e10cSrcweir * 26*cdf0e10cSrcweir ************************************************************************/ 27*cdf0e10cSrcweir 28*cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove 29*cdf0e10cSrcweir #include "precompiled_store.hxx" 30*cdf0e10cSrcweir 31*cdf0e10cSrcweir #include "storcach.hxx" 32*cdf0e10cSrcweir 33*cdf0e10cSrcweir #include "sal/types.h" 34*cdf0e10cSrcweir #include "rtl/alloc.h" 35*cdf0e10cSrcweir #include "osl/diagnose.h" 36*cdf0e10cSrcweir 37*cdf0e10cSrcweir #include "store/types.h" 38*cdf0e10cSrcweir #include "object.hxx" 39*cdf0e10cSrcweir #include "storbase.hxx" 40*cdf0e10cSrcweir 41*cdf0e10cSrcweir #ifndef INCLUDED_STDDEF_H 42*cdf0e10cSrcweir #include <stddef.h> 43*cdf0e10cSrcweir #define INCLUDED_STDDEF_H 44*cdf0e10cSrcweir #endif 45*cdf0e10cSrcweir 46*cdf0e10cSrcweir using namespace store; 47*cdf0e10cSrcweir 48*cdf0e10cSrcweir /*======================================================================== 49*cdf0e10cSrcweir * 50*cdf0e10cSrcweir * PageCache (non-virtual interface) implementation. 51*cdf0e10cSrcweir * 52*cdf0e10cSrcweir *======================================================================*/ 53*cdf0e10cSrcweir 54*cdf0e10cSrcweir storeError PageCache::lookupPageAt (PageHolder & rxPage, sal_uInt32 nOffset) 55*cdf0e10cSrcweir { 56*cdf0e10cSrcweir OSL_PRECOND(!(nOffset == STORE_PAGE_NULL), "store::PageCache::lookupPageAt(): invalid Offset"); 57*cdf0e10cSrcweir if (nOffset == STORE_PAGE_NULL) 58*cdf0e10cSrcweir return store_E_CantSeek; 59*cdf0e10cSrcweir 60*cdf0e10cSrcweir return lookupPageAt_Impl (rxPage, nOffset); 61*cdf0e10cSrcweir } 62*cdf0e10cSrcweir 63*cdf0e10cSrcweir storeError PageCache::insertPageAt (PageHolder const & rxPage, sal_uInt32 nOffset) 64*cdf0e10cSrcweir { 65*cdf0e10cSrcweir // [SECURITY:ValInput] 66*cdf0e10cSrcweir PageData const * pagedata = rxPage.get(); 67*cdf0e10cSrcweir OSL_PRECOND(!(pagedata == 0), "store::PageCache::insertPageAt(): invalid Page"); 68*cdf0e10cSrcweir if (pagedata == 0) 69*cdf0e10cSrcweir return store_E_InvalidParameter; 70*cdf0e10cSrcweir 71*cdf0e10cSrcweir sal_uInt32 const offset = pagedata->location(); 72*cdf0e10cSrcweir OSL_PRECOND(!(nOffset != offset), "store::PageCache::insertPageAt(): inconsistent Offset"); 73*cdf0e10cSrcweir if (nOffset != offset) 74*cdf0e10cSrcweir return store_E_InvalidParameter; 75*cdf0e10cSrcweir 76*cdf0e10cSrcweir OSL_PRECOND(!(nOffset == STORE_PAGE_NULL), "store::PageCache::insertPageAt(): invalid Offset"); 77*cdf0e10cSrcweir if (nOffset == STORE_PAGE_NULL) 78*cdf0e10cSrcweir return store_E_CantSeek; 79*cdf0e10cSrcweir 80*cdf0e10cSrcweir return insertPageAt_Impl (rxPage, nOffset); 81*cdf0e10cSrcweir } 82*cdf0e10cSrcweir 83*cdf0e10cSrcweir storeError PageCache::updatePageAt (PageHolder const & rxPage, sal_uInt32 nOffset) 84*cdf0e10cSrcweir { 85*cdf0e10cSrcweir // [SECURITY:ValInput] 86*cdf0e10cSrcweir PageData const * pagedata = rxPage.get(); 87*cdf0e10cSrcweir OSL_PRECOND(!(pagedata == 0), "store::PageCache::updatePageAt(): invalid Page"); 88*cdf0e10cSrcweir if (pagedata == 0) 89*cdf0e10cSrcweir return store_E_InvalidParameter; 90*cdf0e10cSrcweir 91*cdf0e10cSrcweir sal_uInt32 const offset = pagedata->location(); 92*cdf0e10cSrcweir OSL_PRECOND(!(nOffset != offset), "store::PageCache::updatePageAt(): inconsistent Offset"); 93*cdf0e10cSrcweir if (nOffset != offset) 94*cdf0e10cSrcweir return store_E_InvalidParameter; 95*cdf0e10cSrcweir 96*cdf0e10cSrcweir OSL_PRECOND(!(nOffset == STORE_PAGE_NULL), "store::PageCache::updatePageAt(): invalid Offset"); 97*cdf0e10cSrcweir if (nOffset == STORE_PAGE_NULL) 98*cdf0e10cSrcweir return store_E_CantSeek; 99*cdf0e10cSrcweir 100*cdf0e10cSrcweir return updatePageAt_Impl (rxPage, nOffset); 101*cdf0e10cSrcweir } 102*cdf0e10cSrcweir 103*cdf0e10cSrcweir storeError PageCache::removePageAt (sal_uInt32 nOffset) 104*cdf0e10cSrcweir { 105*cdf0e10cSrcweir OSL_PRECOND(!(nOffset == STORE_PAGE_NULL), "store::PageCache::removePageAt(): invalid Offset"); 106*cdf0e10cSrcweir if (nOffset == STORE_PAGE_NULL) 107*cdf0e10cSrcweir return store_E_CantSeek; 108*cdf0e10cSrcweir 109*cdf0e10cSrcweir return removePageAt_Impl (nOffset); 110*cdf0e10cSrcweir } 111*cdf0e10cSrcweir 112*cdf0e10cSrcweir /*======================================================================== 113*cdf0e10cSrcweir * 114*cdf0e10cSrcweir * Entry. 115*cdf0e10cSrcweir * 116*cdf0e10cSrcweir *======================================================================*/ 117*cdf0e10cSrcweir namespace 118*cdf0e10cSrcweir { 119*cdf0e10cSrcweir 120*cdf0e10cSrcweir struct Entry 121*cdf0e10cSrcweir { 122*cdf0e10cSrcweir /** Representation. 123*cdf0e10cSrcweir */ 124*cdf0e10cSrcweir PageHolder m_xPage; 125*cdf0e10cSrcweir sal_uInt32 m_nOffset; 126*cdf0e10cSrcweir Entry * m_pNext; 127*cdf0e10cSrcweir 128*cdf0e10cSrcweir /** Allocation. 129*cdf0e10cSrcweir */ 130*cdf0e10cSrcweir static void * operator new (size_t, void * p) { return p; } 131*cdf0e10cSrcweir static void operator delete (void *, void *) {} 132*cdf0e10cSrcweir 133*cdf0e10cSrcweir /** Construction. 134*cdf0e10cSrcweir */ 135*cdf0e10cSrcweir explicit Entry (PageHolder const & rxPage = PageHolder(), sal_uInt32 nOffset = STORE_PAGE_NULL) 136*cdf0e10cSrcweir : m_xPage(rxPage), m_nOffset(nOffset), m_pNext(0) 137*cdf0e10cSrcweir {} 138*cdf0e10cSrcweir 139*cdf0e10cSrcweir /** Destruction. 140*cdf0e10cSrcweir */ 141*cdf0e10cSrcweir ~Entry() {} 142*cdf0e10cSrcweir }; 143*cdf0e10cSrcweir 144*cdf0e10cSrcweir } // namespace 145*cdf0e10cSrcweir 146*cdf0e10cSrcweir /*======================================================================== 147*cdf0e10cSrcweir * 148*cdf0e10cSrcweir * EntryCache interface. 149*cdf0e10cSrcweir * 150*cdf0e10cSrcweir *======================================================================*/ 151*cdf0e10cSrcweir namespace 152*cdf0e10cSrcweir { 153*cdf0e10cSrcweir 154*cdf0e10cSrcweir class EntryCache 155*cdf0e10cSrcweir { 156*cdf0e10cSrcweir rtl_cache_type * m_entry_cache; 157*cdf0e10cSrcweir 158*cdf0e10cSrcweir public: 159*cdf0e10cSrcweir static EntryCache & get(); 160*cdf0e10cSrcweir 161*cdf0e10cSrcweir Entry * create (PageHolder const & rxPage, sal_uInt32 nOffset); 162*cdf0e10cSrcweir 163*cdf0e10cSrcweir void destroy (Entry * entry); 164*cdf0e10cSrcweir 165*cdf0e10cSrcweir protected: 166*cdf0e10cSrcweir EntryCache(); 167*cdf0e10cSrcweir ~EntryCache(); 168*cdf0e10cSrcweir }; 169*cdf0e10cSrcweir 170*cdf0e10cSrcweir } // namespace 171*cdf0e10cSrcweir 172*cdf0e10cSrcweir /*======================================================================== 173*cdf0e10cSrcweir * 174*cdf0e10cSrcweir * EntryCache implementation. 175*cdf0e10cSrcweir * 176*cdf0e10cSrcweir *======================================================================*/ 177*cdf0e10cSrcweir 178*cdf0e10cSrcweir EntryCache & EntryCache::get() 179*cdf0e10cSrcweir { 180*cdf0e10cSrcweir static EntryCache g_entry_cache; 181*cdf0e10cSrcweir return g_entry_cache; 182*cdf0e10cSrcweir } 183*cdf0e10cSrcweir 184*cdf0e10cSrcweir EntryCache::EntryCache() 185*cdf0e10cSrcweir { 186*cdf0e10cSrcweir m_entry_cache = rtl_cache_create ( 187*cdf0e10cSrcweir "store_cache_entry_cache", 188*cdf0e10cSrcweir sizeof(Entry), 189*cdf0e10cSrcweir 0, // objalign 190*cdf0e10cSrcweir 0, // constructor 191*cdf0e10cSrcweir 0, // destructor 192*cdf0e10cSrcweir 0, // reclaim 193*cdf0e10cSrcweir 0, // userarg 194*cdf0e10cSrcweir 0, // default source 195*cdf0e10cSrcweir 0 // flags 196*cdf0e10cSrcweir ); 197*cdf0e10cSrcweir } 198*cdf0e10cSrcweir 199*cdf0e10cSrcweir EntryCache::~EntryCache() 200*cdf0e10cSrcweir { 201*cdf0e10cSrcweir rtl_cache_destroy (m_entry_cache), m_entry_cache = 0; 202*cdf0e10cSrcweir } 203*cdf0e10cSrcweir 204*cdf0e10cSrcweir Entry * EntryCache::create (PageHolder const & rxPage, sal_uInt32 nOffset) 205*cdf0e10cSrcweir { 206*cdf0e10cSrcweir void * pAddr = rtl_cache_alloc (m_entry_cache); 207*cdf0e10cSrcweir if (pAddr != 0) 208*cdf0e10cSrcweir { 209*cdf0e10cSrcweir // construct. 210*cdf0e10cSrcweir return new(pAddr) Entry (rxPage, nOffset); 211*cdf0e10cSrcweir } 212*cdf0e10cSrcweir return 0; 213*cdf0e10cSrcweir } 214*cdf0e10cSrcweir 215*cdf0e10cSrcweir void EntryCache::destroy (Entry * entry) 216*cdf0e10cSrcweir { 217*cdf0e10cSrcweir if (entry != 0) 218*cdf0e10cSrcweir { 219*cdf0e10cSrcweir // destruct. 220*cdf0e10cSrcweir entry->~Entry(); 221*cdf0e10cSrcweir 222*cdf0e10cSrcweir // return to cache. 223*cdf0e10cSrcweir rtl_cache_free (m_entry_cache, entry); 224*cdf0e10cSrcweir } 225*cdf0e10cSrcweir } 226*cdf0e10cSrcweir 227*cdf0e10cSrcweir /*======================================================================== 228*cdf0e10cSrcweir * 229*cdf0e10cSrcweir * highbit():= log2() + 1 (complexity O(1)) 230*cdf0e10cSrcweir * 231*cdf0e10cSrcweir *======================================================================*/ 232*cdf0e10cSrcweir static int highbit(sal_Size n) 233*cdf0e10cSrcweir { 234*cdf0e10cSrcweir register int k = 1; 235*cdf0e10cSrcweir 236*cdf0e10cSrcweir if (n == 0) 237*cdf0e10cSrcweir return (0); 238*cdf0e10cSrcweir #if SAL_TYPES_SIZEOFLONG == 8 239*cdf0e10cSrcweir if (n & 0xffffffff00000000ul) 240*cdf0e10cSrcweir k |= 32, n >>= 32; 241*cdf0e10cSrcweir #endif 242*cdf0e10cSrcweir if (n & 0xffff0000) 243*cdf0e10cSrcweir k |= 16, n >>= 16; 244*cdf0e10cSrcweir if (n & 0xff00) 245*cdf0e10cSrcweir k |= 8, n >>= 8; 246*cdf0e10cSrcweir if (n & 0xf0) 247*cdf0e10cSrcweir k |= 4, n >>= 4; 248*cdf0e10cSrcweir if (n & 0x0c) 249*cdf0e10cSrcweir k |= 2, n >>= 2; 250*cdf0e10cSrcweir if (n & 0x02) 251*cdf0e10cSrcweir k++; 252*cdf0e10cSrcweir 253*cdf0e10cSrcweir return (k); 254*cdf0e10cSrcweir } 255*cdf0e10cSrcweir 256*cdf0e10cSrcweir /*======================================================================== 257*cdf0e10cSrcweir * 258*cdf0e10cSrcweir * PageCache_Impl implementation. 259*cdf0e10cSrcweir * 260*cdf0e10cSrcweir *======================================================================*/ 261*cdf0e10cSrcweir namespace store 262*cdf0e10cSrcweir { 263*cdf0e10cSrcweir 264*cdf0e10cSrcweir class PageCache_Impl : 265*cdf0e10cSrcweir public store::OStoreObject, 266*cdf0e10cSrcweir public store::PageCache 267*cdf0e10cSrcweir { 268*cdf0e10cSrcweir /** Representation. 269*cdf0e10cSrcweir */ 270*cdf0e10cSrcweir static size_t const theTableSize = 32; 271*cdf0e10cSrcweir STORE_STATIC_ASSERT(STORE_IMPL_ISP2(theTableSize)); 272*cdf0e10cSrcweir 273*cdf0e10cSrcweir Entry ** m_hash_table; 274*cdf0e10cSrcweir Entry * m_hash_table_0[theTableSize]; 275*cdf0e10cSrcweir size_t m_hash_size; 276*cdf0e10cSrcweir size_t m_hash_shift; 277*cdf0e10cSrcweir size_t const m_page_shift; 278*cdf0e10cSrcweir 279*cdf0e10cSrcweir size_t m_hash_entries; // total number of entries in table. 280*cdf0e10cSrcweir size_t m_nHit; 281*cdf0e10cSrcweir size_t m_nMissed; 282*cdf0e10cSrcweir 283*cdf0e10cSrcweir inline int hash_Impl(sal_uInt32 a, size_t s, size_t q, size_t m) 284*cdf0e10cSrcweir { 285*cdf0e10cSrcweir return ((((a) + ((a) >> (s)) + ((a) >> ((s) << 1))) >> (q)) & (m)); 286*cdf0e10cSrcweir } 287*cdf0e10cSrcweir inline int hash_index_Impl (sal_uInt32 nOffset) 288*cdf0e10cSrcweir { 289*cdf0e10cSrcweir return hash_Impl(nOffset, m_hash_shift, m_page_shift, m_hash_size - 1); 290*cdf0e10cSrcweir } 291*cdf0e10cSrcweir 292*cdf0e10cSrcweir Entry * lookup_Impl (Entry * entry, sal_uInt32 nOffset); 293*cdf0e10cSrcweir void rescale_Impl (sal_Size new_size); 294*cdf0e10cSrcweir 295*cdf0e10cSrcweir /** PageCache Implementation. 296*cdf0e10cSrcweir */ 297*cdf0e10cSrcweir virtual storeError lookupPageAt_Impl ( 298*cdf0e10cSrcweir PageHolder & rxPage, 299*cdf0e10cSrcweir sal_uInt32 nOffset); 300*cdf0e10cSrcweir 301*cdf0e10cSrcweir virtual storeError insertPageAt_Impl ( 302*cdf0e10cSrcweir PageHolder const & rxPage, 303*cdf0e10cSrcweir sal_uInt32 nOffset); 304*cdf0e10cSrcweir 305*cdf0e10cSrcweir virtual storeError updatePageAt_Impl ( 306*cdf0e10cSrcweir PageHolder const & rxPage, 307*cdf0e10cSrcweir sal_uInt32 nOffset); 308*cdf0e10cSrcweir 309*cdf0e10cSrcweir virtual storeError removePageAt_Impl ( 310*cdf0e10cSrcweir sal_uInt32 nOffset); 311*cdf0e10cSrcweir 312*cdf0e10cSrcweir /** Not implemented. 313*cdf0e10cSrcweir */ 314*cdf0e10cSrcweir PageCache_Impl (PageCache_Impl const &); 315*cdf0e10cSrcweir PageCache_Impl & operator= (PageCache_Impl const &); 316*cdf0e10cSrcweir 317*cdf0e10cSrcweir public: 318*cdf0e10cSrcweir /** Construction. 319*cdf0e10cSrcweir */ 320*cdf0e10cSrcweir explicit PageCache_Impl (sal_uInt16 nPageSize); 321*cdf0e10cSrcweir 322*cdf0e10cSrcweir /** Delegate multiple inherited IReference. 323*cdf0e10cSrcweir */ 324*cdf0e10cSrcweir virtual oslInterlockedCount SAL_CALL acquire(); 325*cdf0e10cSrcweir virtual oslInterlockedCount SAL_CALL release(); 326*cdf0e10cSrcweir 327*cdf0e10cSrcweir protected: 328*cdf0e10cSrcweir /** Destruction. 329*cdf0e10cSrcweir */ 330*cdf0e10cSrcweir virtual ~PageCache_Impl (void); 331*cdf0e10cSrcweir }; 332*cdf0e10cSrcweir 333*cdf0e10cSrcweir } // namespace store 334*cdf0e10cSrcweir 335*cdf0e10cSrcweir PageCache_Impl::PageCache_Impl (sal_uInt16 nPageSize) 336*cdf0e10cSrcweir : m_hash_table (m_hash_table_0), 337*cdf0e10cSrcweir m_hash_size (theTableSize), 338*cdf0e10cSrcweir m_hash_shift (highbit(m_hash_size) - 1), 339*cdf0e10cSrcweir m_page_shift (highbit(nPageSize) - 1), 340*cdf0e10cSrcweir m_hash_entries (0), 341*cdf0e10cSrcweir m_nHit (0), 342*cdf0e10cSrcweir m_nMissed (0) 343*cdf0e10cSrcweir { 344*cdf0e10cSrcweir static size_t const theSize = sizeof(m_hash_table_0) / sizeof(m_hash_table_0[0]); 345*cdf0e10cSrcweir STORE_STATIC_ASSERT(theSize == theTableSize); 346*cdf0e10cSrcweir memset(m_hash_table_0, 0, sizeof(m_hash_table_0)); 347*cdf0e10cSrcweir } 348*cdf0e10cSrcweir 349*cdf0e10cSrcweir PageCache_Impl::~PageCache_Impl() 350*cdf0e10cSrcweir { 351*cdf0e10cSrcweir double s_x = 0.0, s_xx = 0.0; 352*cdf0e10cSrcweir sal_Size i, n = m_hash_size; 353*cdf0e10cSrcweir for (i = 0; i < n; i++) 354*cdf0e10cSrcweir { 355*cdf0e10cSrcweir int x = 0; 356*cdf0e10cSrcweir Entry * entry = m_hash_table[i]; 357*cdf0e10cSrcweir while (entry != 0) 358*cdf0e10cSrcweir { 359*cdf0e10cSrcweir m_hash_table[i] = entry->m_pNext, entry->m_pNext = 0; 360*cdf0e10cSrcweir EntryCache::get().destroy (entry); 361*cdf0e10cSrcweir entry = m_hash_table[i]; 362*cdf0e10cSrcweir x += 1; 363*cdf0e10cSrcweir } 364*cdf0e10cSrcweir s_x += double(x); 365*cdf0e10cSrcweir s_xx += double(x) * double(x); 366*cdf0e10cSrcweir } 367*cdf0e10cSrcweir double ave = s_x / double(n); 368*cdf0e10cSrcweir OSL_TRACE("ave hash chain length: %g", ave); 369*cdf0e10cSrcweir (void) ave; 370*cdf0e10cSrcweir 371*cdf0e10cSrcweir if (m_hash_table != m_hash_table_0) 372*cdf0e10cSrcweir { 373*cdf0e10cSrcweir rtl_freeMemory (m_hash_table); 374*cdf0e10cSrcweir m_hash_table = m_hash_table_0; 375*cdf0e10cSrcweir m_hash_size = theTableSize; 376*cdf0e10cSrcweir m_hash_shift = highbit(m_hash_size) - 1; 377*cdf0e10cSrcweir } 378*cdf0e10cSrcweir OSL_TRACE("Hits: %u, Misses: %u", m_nHit, m_nMissed); 379*cdf0e10cSrcweir } 380*cdf0e10cSrcweir 381*cdf0e10cSrcweir oslInterlockedCount PageCache_Impl::acquire() 382*cdf0e10cSrcweir { 383*cdf0e10cSrcweir return OStoreObject::acquire(); 384*cdf0e10cSrcweir } 385*cdf0e10cSrcweir 386*cdf0e10cSrcweir oslInterlockedCount PageCache_Impl::release() 387*cdf0e10cSrcweir { 388*cdf0e10cSrcweir return OStoreObject::release(); 389*cdf0e10cSrcweir } 390*cdf0e10cSrcweir 391*cdf0e10cSrcweir void PageCache_Impl::rescale_Impl (sal_Size new_size) 392*cdf0e10cSrcweir { 393*cdf0e10cSrcweir sal_Size new_bytes = new_size * sizeof(Entry*); 394*cdf0e10cSrcweir Entry ** new_table = (Entry**)(rtl_allocateMemory(new_bytes)); 395*cdf0e10cSrcweir 396*cdf0e10cSrcweir if (new_table != 0) 397*cdf0e10cSrcweir { 398*cdf0e10cSrcweir Entry ** old_table = m_hash_table; 399*cdf0e10cSrcweir sal_Size old_size = m_hash_size; 400*cdf0e10cSrcweir 401*cdf0e10cSrcweir OSL_TRACE("ave chain length: %u, total entries: %u [old_size: %u, new_size: %u]", 402*cdf0e10cSrcweir m_hash_entries >> m_hash_shift, m_hash_entries, old_size, new_size); 403*cdf0e10cSrcweir 404*cdf0e10cSrcweir memset (new_table, 0, new_bytes); 405*cdf0e10cSrcweir 406*cdf0e10cSrcweir m_hash_table = new_table; 407*cdf0e10cSrcweir m_hash_size = new_size; 408*cdf0e10cSrcweir m_hash_shift = highbit(m_hash_size) - 1; 409*cdf0e10cSrcweir 410*cdf0e10cSrcweir sal_Size i; 411*cdf0e10cSrcweir for (i = 0; i < old_size; i++) 412*cdf0e10cSrcweir { 413*cdf0e10cSrcweir Entry * curr = old_table[i]; 414*cdf0e10cSrcweir while (curr != 0) 415*cdf0e10cSrcweir { 416*cdf0e10cSrcweir Entry * next = curr->m_pNext; 417*cdf0e10cSrcweir int index = hash_index_Impl(curr->m_nOffset); 418*cdf0e10cSrcweir curr->m_pNext = m_hash_table[index], m_hash_table[index] = curr; 419*cdf0e10cSrcweir curr = next; 420*cdf0e10cSrcweir } 421*cdf0e10cSrcweir old_table[i] = 0; 422*cdf0e10cSrcweir } 423*cdf0e10cSrcweir if (old_table != m_hash_table_0) 424*cdf0e10cSrcweir { 425*cdf0e10cSrcweir // 426*cdf0e10cSrcweir rtl_freeMemory (old_table); 427*cdf0e10cSrcweir } 428*cdf0e10cSrcweir } 429*cdf0e10cSrcweir } 430*cdf0e10cSrcweir 431*cdf0e10cSrcweir Entry * PageCache_Impl::lookup_Impl (Entry * entry, sal_uInt32 nOffset) 432*cdf0e10cSrcweir { 433*cdf0e10cSrcweir register int lookups = 0; 434*cdf0e10cSrcweir while (entry != 0) 435*cdf0e10cSrcweir { 436*cdf0e10cSrcweir if (entry->m_nOffset == nOffset) 437*cdf0e10cSrcweir break; 438*cdf0e10cSrcweir 439*cdf0e10cSrcweir lookups += 1; 440*cdf0e10cSrcweir entry = entry->m_pNext; 441*cdf0e10cSrcweir } 442*cdf0e10cSrcweir if (lookups > 2) 443*cdf0e10cSrcweir { 444*cdf0e10cSrcweir sal_Size new_size = m_hash_size, ave = m_hash_entries >> m_hash_shift; 445*cdf0e10cSrcweir for (; ave > 4; new_size *= 2, ave /= 2) 446*cdf0e10cSrcweir continue; 447*cdf0e10cSrcweir if (new_size != m_hash_size) 448*cdf0e10cSrcweir rescale_Impl (new_size); 449*cdf0e10cSrcweir } 450*cdf0e10cSrcweir return entry; 451*cdf0e10cSrcweir } 452*cdf0e10cSrcweir 453*cdf0e10cSrcweir storeError PageCache_Impl::lookupPageAt_Impl ( 454*cdf0e10cSrcweir PageHolder & rxPage, 455*cdf0e10cSrcweir sal_uInt32 nOffset) 456*cdf0e10cSrcweir { 457*cdf0e10cSrcweir int index = hash_index_Impl(nOffset); 458*cdf0e10cSrcweir Entry const * entry = lookup_Impl (m_hash_table[index], nOffset); 459*cdf0e10cSrcweir if (entry != 0) 460*cdf0e10cSrcweir { 461*cdf0e10cSrcweir // Existing entry. 462*cdf0e10cSrcweir rxPage = entry->m_xPage; 463*cdf0e10cSrcweir 464*cdf0e10cSrcweir // Update stats and leave. 465*cdf0e10cSrcweir m_nHit += 1; 466*cdf0e10cSrcweir return store_E_None; 467*cdf0e10cSrcweir } 468*cdf0e10cSrcweir 469*cdf0e10cSrcweir // Cache miss. Update stats and leave. 470*cdf0e10cSrcweir m_nMissed += 1; 471*cdf0e10cSrcweir return store_E_NotExists; 472*cdf0e10cSrcweir } 473*cdf0e10cSrcweir 474*cdf0e10cSrcweir storeError PageCache_Impl::insertPageAt_Impl ( 475*cdf0e10cSrcweir PageHolder const & rxPage, 476*cdf0e10cSrcweir sal_uInt32 nOffset) 477*cdf0e10cSrcweir { 478*cdf0e10cSrcweir Entry * entry = EntryCache::get().create (rxPage, nOffset); 479*cdf0e10cSrcweir if (entry != 0) 480*cdf0e10cSrcweir { 481*cdf0e10cSrcweir // Insert new entry. 482*cdf0e10cSrcweir int index = hash_index_Impl(nOffset); 483*cdf0e10cSrcweir entry->m_pNext = m_hash_table[index], m_hash_table[index] = entry; 484*cdf0e10cSrcweir 485*cdf0e10cSrcweir // Update stats and leave. 486*cdf0e10cSrcweir m_hash_entries += 1; 487*cdf0e10cSrcweir return store_E_None; 488*cdf0e10cSrcweir } 489*cdf0e10cSrcweir return store_E_OutOfMemory; 490*cdf0e10cSrcweir } 491*cdf0e10cSrcweir 492*cdf0e10cSrcweir storeError PageCache_Impl::updatePageAt_Impl ( 493*cdf0e10cSrcweir PageHolder const & rxPage, 494*cdf0e10cSrcweir sal_uInt32 nOffset) 495*cdf0e10cSrcweir { 496*cdf0e10cSrcweir int index = hash_index_Impl(nOffset); 497*cdf0e10cSrcweir Entry * entry = lookup_Impl (m_hash_table[index], nOffset); 498*cdf0e10cSrcweir if (entry != 0) 499*cdf0e10cSrcweir { 500*cdf0e10cSrcweir // Update existing entry. 501*cdf0e10cSrcweir entry->m_xPage = rxPage; 502*cdf0e10cSrcweir 503*cdf0e10cSrcweir // Update stats and leave. // m_nUpdHit += 1; 504*cdf0e10cSrcweir return store_E_None; 505*cdf0e10cSrcweir } 506*cdf0e10cSrcweir return insertPageAt_Impl (rxPage, nOffset); 507*cdf0e10cSrcweir } 508*cdf0e10cSrcweir 509*cdf0e10cSrcweir storeError PageCache_Impl::removePageAt_Impl ( 510*cdf0e10cSrcweir sal_uInt32 nOffset) 511*cdf0e10cSrcweir { 512*cdf0e10cSrcweir Entry ** ppEntry = &(m_hash_table[hash_index_Impl(nOffset)]); 513*cdf0e10cSrcweir while (*ppEntry != 0) 514*cdf0e10cSrcweir { 515*cdf0e10cSrcweir if ((*ppEntry)->m_nOffset == nOffset) 516*cdf0e10cSrcweir { 517*cdf0e10cSrcweir // Existing entry. 518*cdf0e10cSrcweir Entry * entry = (*ppEntry); 519*cdf0e10cSrcweir 520*cdf0e10cSrcweir // Dequeue and destroy entry. 521*cdf0e10cSrcweir (*ppEntry) = entry->m_pNext, entry->m_pNext = 0; 522*cdf0e10cSrcweir EntryCache::get().destroy (entry); 523*cdf0e10cSrcweir 524*cdf0e10cSrcweir // Update stats and leave. 525*cdf0e10cSrcweir m_hash_entries -= 1; 526*cdf0e10cSrcweir return store_E_None; 527*cdf0e10cSrcweir } 528*cdf0e10cSrcweir ppEntry = &((*ppEntry)->m_pNext); 529*cdf0e10cSrcweir } 530*cdf0e10cSrcweir return store_E_NotExists; 531*cdf0e10cSrcweir } 532*cdf0e10cSrcweir 533*cdf0e10cSrcweir /*======================================================================== 534*cdf0e10cSrcweir * 535*cdf0e10cSrcweir * Old OStorePageCache implementation. 536*cdf0e10cSrcweir * 537*cdf0e10cSrcweir * (two-way association (sorted address array, LRU chain)). 538*cdf0e10cSrcweir * (external OStorePageData representation). 539*cdf0e10cSrcweir * 540*cdf0e10cSrcweir *======================================================================*/ 541*cdf0e10cSrcweir 542*cdf0e10cSrcweir /*======================================================================== 543*cdf0e10cSrcweir * 544*cdf0e10cSrcweir * PageCache factory implementation. 545*cdf0e10cSrcweir * 546*cdf0e10cSrcweir *======================================================================*/ 547*cdf0e10cSrcweir namespace store { 548*cdf0e10cSrcweir 549*cdf0e10cSrcweir storeError 550*cdf0e10cSrcweir PageCache_createInstance ( 551*cdf0e10cSrcweir rtl::Reference< store::PageCache > & rxCache, 552*cdf0e10cSrcweir sal_uInt16 nPageSize) 553*cdf0e10cSrcweir { 554*cdf0e10cSrcweir rxCache = new PageCache_Impl (nPageSize); 555*cdf0e10cSrcweir if (!rxCache.is()) 556*cdf0e10cSrcweir return store_E_OutOfMemory; 557*cdf0e10cSrcweir 558*cdf0e10cSrcweir return store_E_None; 559*cdf0e10cSrcweir } 560*cdf0e10cSrcweir 561*cdf0e10cSrcweir } // namespace store 562