This commit is contained in:
Hongze Cheng 2022-02-07 10:12:09 +00:00
parent a583407354
commit 73e32ddf77
1 changed files with 24 additions and 1 deletions

View File

@ -106,6 +106,29 @@ int pgFileWrite(SPage *pPage) {
}
static int pgFileRead(SPgFile *pPgFile, pgno_t pgno, uint8_t *pData) {
// TODO
pgsize_t pgSize;
ssize_t rsize;
uint8_t *pTData;
size_t szToRead;
// pgSize = ; (TODO)
pTData = pData;
szToRead = pgSize;
for (; szToRead > 0;) {
rsize = pread(pPgFile->fd, pTData, szToRead, pgno * pgSize);
if (rsize < 0) {
if (errno == EINTR) {
continue;
} else {
return -1;
}
} else if (rsize == 0) {
return -1;
}
szToRead -= rsize;
pTData += rsize;
}
return 0;
}