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

more TDB

This commit is contained in:
Hongze Cheng 2022-03-09 07:48:45 +00:00
parent c41db68c6a
commit 737497d8b6
3 changed files with 21 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/tdb/src/inc/tdbInt.h
View File

@ -136,11 +136,10 @@ typedef int (*FKeyComparator)(const void *pKey1, int kLen1, const void *pKey2, i
typedef struct SPager SPager; typedef struct SPager SPager;
typedef struct SPCache SPCache; typedef struct SPCache SPCache;
typedef struct SPage SPage;
#include "tdbUtil.h" #include "tdbUtil.h"
#include "tdbPage.h"
#include "tdbPCache.h" #include "tdbPCache.h"
#include "tdbPager.h" #include "tdbPager.h"
@ -151,6 +150,8 @@ typedef struct SPCache SPCache;
#include "tdbDb.h" #include "tdbDb.h"
#include "tdbPage.h"
#ifdef __cplusplus #ifdef __cplusplus
} }
#endif #endif

13
source/libs/tdb/src/inc/tdbPCache.h
View File

@ -20,7 +20,18 @@
extern "C" { extern "C" {
#endif #endif
#define TDB_PCACHE_PAGE #define TDB_PCACHE_PAGE \
u8 isAnchor; \
u8 isLocalPage; \
u8 isDirty; \
i32 nRef; \
SPCache *pCache; \
SPage *pFreeNext; \
SPage *pHashNext; \
SPage *pLruNext; \
SPage *pLruPrev; \
SPage *pDirtyNext; \
SPager *pPager;
int tdbPCacheOpen(int pageSize, int cacheSize, int extraSize, SPCache **ppCache); int tdbPCacheOpen(int pageSize, int cacheSize, int extraSize, SPCache **ppCache);
int tdbPCacheClose(SPCache *pCache); int tdbPCacheClose(SPCache *pCache);

21
source/libs/tdb/src/inc/tdbPage.h
View File

@ -29,23 +29,14 @@ typedef struct __attribute__((__packed__)) {
SPgno rChild; SPgno rChild;
} SPageHdr; } SPageHdr;
typedef struct SPage SPage;
struct SPage { struct SPage {
pthread_spinlock_t lock; pthread_spinlock_t lock;
// Fields below used by page cache void *pData;
void *pData; SPgid pgid;
SPgid pgid;
u8 isAnchor; // Fields used by SPCache
u8 isLocalPage; TDB_PCACHE_PAGE
u8 isDirty;
i32 nRef;
SPCache *pCache;
SPage *pFreeNext;
SPage *pHashNext;
SPage *pLruNext;
SPage *pLruPrev;
SPage *pDirtyNext;
SPager *pPager;
// Fields below used by pager and am // Fields below used by pager and am
SPageHdr *pPageHdr; SPageHdr *pPageHdr;
u16 *aCellIdx; u16 *aCellIdx;