This commit is contained in:
Hongze Cheng 2022-02-28 06:55:04 +00:00
parent b4a2bed4dd
commit 7ca2cf2e18
1 changed files with 5 additions and 0 deletions

View File

@ -48,14 +48,18 @@ int tdbPFileOpen(SPCache *pCache, const char *fileName, SPFile **ppFile) {
pFile = (SPFile *)pPtr; pFile = (SPFile *)pPtr;
pPtr += sizeof(*pFile); pPtr += sizeof(*pFile);
// pFile->dbFileName
pFile->dbFileName = (char *)pPtr; pFile->dbFileName = (char *)pPtr;
memcpy(pFile->dbFileName, fileName, fsize); memcpy(pFile->dbFileName, fileName, fsize);
pFile->dbFileName[fsize] = '\0'; pFile->dbFileName[fsize] = '\0';
pPtr += fsize + 1; pPtr += fsize + 1;
// pFile->jFileName
pFile->jFileName = (char *)pPtr; pFile->jFileName = (char *)pPtr;
memcpy(pFile->jFileName, fileName, fsize); memcpy(pFile->jFileName, fileName, fsize);
memcpy(pFile->jFileName + fsize, "-journal", 8); memcpy(pFile->jFileName + fsize, "-journal", 8);
pFile->jFileName[fsize + 8] = '\0'; pFile->jFileName[fsize + 8] = '\0';
// pFile->pCache
pFile->pCache = pCache;
pFile->fd = open(pFile->dbFileName, O_RDWR | O_CREAT, 0755); pFile->fd = open(pFile->dbFileName, O_RDWR | O_CREAT, 0755);
if (pFile->fd < 0) { if (pFile->fd < 0) {
@ -103,6 +107,7 @@ SPage *tdbPFileGet(SPFile *pFile, SPgno pgno) {
ASSERT(pPage->isLoad); ASSERT(pPage->isLoad);
return pPage; return pPage;
}
int tdbPFileWrite(SPFile *pFile, SPage *pPage) { int tdbPFileWrite(SPFile *pFile, SPage *pPage) {