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

refact

This commit is contained in:
Hongze Cheng 2022-01-20 05:13:32 +00:00
parent 0230a529f7
commit 632bb1b4d2
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/libs/tdb/src/db/tdb_mpool.c
View File

@ -70,13 +70,13 @@ int tdbCloseMP(TDB_MPOOL *mp) {
return 0; return 0;
} }
int tdbMPFetchPage(TDB_MPOOL *mp, mp_pgid_t mpgid, void *p) { int tdbMPFetchPage(TDB_MPOOL *mp, pgid_t mpgid, void *p) {
// Search the hash // Search the hash
// TODO // TODO
return 0; return 0;
} }
int tdbMpUnfetchPage(TDB_MPOOL *mp, mp_pgid_t mpgid, void *p) { int tdbMpUnfetchPage(TDB_MPOOL *mp, pgid_t mpgid, void *p) {
// TODO // TODO
return 0; return 0;
} }

10
source/libs/tdb/src/inc/tdb_mpool.h
View File

@ -29,11 +29,11 @@ typedef struct TDB_MPFILE TDB_MPFILE;
typedef struct { typedef struct {
uint8_t fuid[TDB_FILE_UID_LEN]; uint8_t fuid[TDB_FILE_UID_LEN];
pgno_t pgid; pgno_t pgid;
} mp_pgid_t; } pgid_t;
typedef struct MP_PAGE { typedef struct MP_PAGE {
// SRWLatch rwLatch; // SRWLatch rwLatch;
mp_pgid_t mpgid; pgid_t mpgid;
uint8_t dirty; uint8_t dirty;
uint8_t fileid[TDB_FILE_UID_LEN]; uint8_t fileid[TDB_FILE_UID_LEN];
int32_t pinRef; int32_t pinRef;
@ -50,7 +50,7 @@ struct TDB_MPOOL {
int32_t npages; int32_t npages;
MP_PAGE * pages; MP_PAGE * pages;
MP_PAGE_LIST freeList; MP_PAGE_LIST freeList;
// Hash<mp_pgid_t, frame_id_t> // Hash<pgid_t, frame_id_t>
int32_t nbucket; int32_t nbucket;
MP_PAGE_LIST *hashtab; MP_PAGE_LIST *hashtab;
// TODO: TD_DLIST(TD_MPFILE) mpfList; // MPFILE registered on this memory pool // TODO: TD_DLIST(TD_MPFILE) mpfList; // MPFILE registered on this memory pool
@ -69,8 +69,8 @@ struct TDB_MPFILE {
// TDB_MPOOL // TDB_MPOOL
int tdbOpenMP(TDB_MPOOL **mpp, uint64_t cachesize, pgsize_t pgsize); int tdbOpenMP(TDB_MPOOL **mpp, uint64_t cachesize, pgsize_t pgsize);
int tdbCloseMP(TDB_MPOOL *mp); int tdbCloseMP(TDB_MPOOL *mp);
int tdbMPFetchPage(TDB_MPOOL *mp, mp_pgid_t mpgid, void *p); int tdbMPFetchPage(TDB_MPOOL *mp, pgid_t mpgid, void *p);
int tdbMpUnfetchPage(TDB_MPOOL *mp, mp_pgid_t mpgid, void *p); int tdbMpUnfetchPage(TDB_MPOOL *mp, pgid_t mpgid, void *p);
// TDB_MPFILE // TDB_MPFILE
int tdbMPFOpen(TDB_MPFILE **mpfp, const char *fname, TDB_MPOOL *mp); int tdbMPFOpen(TDB_MPFILE **mpfp, const char *fname, TDB_MPOOL *mp);