xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

more

This commit is contained in:
Hongze Cheng 2022-02-23 05:56:06 +00:00
parent aaab6de403
commit b38e690783
2 changed files with 84 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
source/libs/tdb/src/db/tdbPgCache.c
View File

@ -21,7 +21,7 @@ struct SPCache {
int nRef; int nRef;
pthread_mutex_t mutex; pthread_mutex_t mutex;
int nPage; int nPage;
SPgHdr * lru; SPgHdr lru;
int nRecyclable; int nRecyclable;
int nHash; int nHash;
SPgHdr ** pgHash; SPgHdr ** pgHash;
@ -29,8 +29,8 @@ struct SPCache {
SPgHdr * pFree; SPgHdr * pFree;
}; };
#define PCACHE_PAGE_HASH(pgid) 0 // TODO #define PCACHE_PAGE_HASH(pgid) 0 // TODO
#define PAGE_IS_UNPINNED(pPage) true // TODO #define PAGE_IS_PINNED(pPage) ((pPage)->pLruNext == NULL)
static void tdbPCacheInitLock(SPCache *pCache); static void tdbPCacheInitLock(SPCache *pCache);
static void tdbPCacheClearLock(SPCache *pCache); static void tdbPCacheClearLock(SPCache *pCache);
@ -39,6 +39,8 @@ static void tdbPCacheUnlock(SPCache *pCache);
static bool tdbPCacheLocked(SPCache *pCache); static bool tdbPCacheLocked(SPCache *pCache);
static SPgHdr *tdbPCacheFetchImpl(SPCache *pCache, const SPgid *pPgid, bool alcNewPage); static SPgHdr *tdbPCacheFetchImpl(SPCache *pCache, const SPgid *pPgid, bool alcNewPage);
static void tdbPCachePinPage(SPgHdr *pPage); static void tdbPCachePinPage(SPgHdr *pPage);
static void tdbPCacheRemovePageFromHash(SPgHdr *pPage);
static void tdbPCacheAddPageToHash(SPgHdr *pPage);
int tdbOpenPCache(int pageSize, int cacheSize, int extraSize, SPCache **ppCache) { int tdbOpenPCache(int pageSize, int cacheSize, int extraSize, SPCache **ppCache) {
SPCache *pCache; SPCache *pCache;
@ -87,6 +89,10 @@ SPgHdr *tdbPCacheFetch(SPCache *pCache, const SPgid *pPgid, bool alcNewPage) {
return pPage; return pPage;
} }
void tdbFetchFinish(SPCache *pCache, SPgHdr *pPage) {
// TODO
}
void tdbPCacheRelease(SPgHdr *pHdr) { void tdbPCacheRelease(SPgHdr *pHdr) {
// TODO // TODO
} }
@ -120,11 +126,73 @@ static SPgHdr *tdbPCacheFetchImpl(SPCache *pCache, const SPgid *pPgid, bool alcN
return pPage; return pPage;
} }
// 2. Try to allocate a new page from the free list
if (pCache->pFree) {
pPage = pCache->pFree;
pCache->pFree = pPage->pFreeNext;
pCache->nFree--;
pPage->pLruNext = NULL;
}
// 3. Try to Recycle a page
if (!pPage && !pCache->lru.pLruPrev->isAnchor) {
pPage = pCache->lru.pLruPrev;
tdbPCacheRemovePageFromHash(pPage);
tdbPCachePinPage(pPage);
}
// 4. Try a stress allocation
// 5. Page here are just created from a free list
// or by recycling or allocated streesly,
// need to initialize it
if (pPage) {
memcpy(&pPage->pgid, pPgid, sizeof(*pPgid));
pPage->pCache = pCache;
pPage->pLruNext = NULL;
tdbPCacheAddPageToHash(pPage);
}
return pPage; return pPage;
} }
static void tdbPCachePinPage(SPgHdr *pPage) { static void tdbPCachePinPage(SPgHdr *pPage) {
if (PAGE_IS_UNPINNED(pPage)) { SPCache *pCache;
/* TODO */
pCache = pPage->pCache;
if (!PAGE_IS_PINNED(pPage)) {
pPage->pLruPrev->pLruNext = pPage->pLruNext;
pPage->pLruNext->pLruPrev = pPage->pLruPrev;
pPage->pLruNext = NULL;
pCache->nRecyclable--;
} }
}
static void tdbPCacheRemovePageFromHash(SPgHdr *pPage) {
SPCache *pCache;
SPgHdr **ppPage;
int h;
pCache = pPage->pCache;
h = PCACHE_PAGE_HASH(&(pPage->pgid));
for (ppPage = &(pCache->pgHash[h % pCache->nHash]); *ppPage != pPage; ppPage = &((*ppPage)->pHashNext))
;
ASSERT(*ppPage == pPage);
*ppPage = pPage->pHashNext;
pCache->nPage--;
}
static void tdbPCacheAddPageToHash(SPgHdr *pPage) {
SPCache *pCache;
int h;
pCache = pPage->pCache;
h = PCACHE_PAGE_HASH(&pPage->pgid) % pCache->nHash;
pPage->pHashNext = pCache->pgHash[h];
pCache->pgHash[h] = pPage;
pCache->nPage++;
} }

17
source/libs/tdb/src/inc/tdbPgCache.h
View File

@ -24,17 +24,22 @@ typedef struct SPCache SPCache;
typedef struct SPgHdr SPgHdr; typedef struct SPgHdr SPgHdr;
struct SPgHdr { struct SPgHdr {
void * pData; void * pData;
void * pExtra; void * pExtra;
SPgid pgid; SPgid pgid;
uint8_t isLocalPage; uint8_t isAnchor;
SPgHdr *pFreeNext; uint8_t isLocalPage;
SPgHdr *pHashNext; SPCache *pCache;
SPgHdr * pFreeNext;
SPgHdr * pHashNext;
SPgHdr * pLruNext;
SPgHdr * pLruPrev;
}; };
int tdbOpenPCache(int pageSize, int cacheSize, int extraSize, SPCache **ppCache); int tdbOpenPCache(int pageSize, int cacheSize, int extraSize, SPCache **ppCache);
int tdbPCacheClose(SPCache *pCache); int tdbPCacheClose(SPCache *pCache);
SPgHdr *tdbPCacheFetch(SPCache *pCache, const SPgid *pPgid, bool alcNewPage); SPgHdr *tdbPCacheFetch(SPCache *pCache, const SPgid *pPgid, bool alcNewPage);
void tdbFetchFinish(SPCache *pCache, SPgHdr *pPage);
void tdbPCacheRelease(SPgHdr *pHdr); void tdbPCacheRelease(SPgHdr *pHdr);
#ifdef __cplusplus #ifdef __cplusplus