From 5c9c9695e5700b5e9fbadf1921163d9f59dc19e5 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Mon, 28 Mar 2022 03:41:27 +0000 Subject: [PATCH] more TDB --- source/libs/tdb/CMakeLists.txt | 1 + source/libs/tdb/src/db/tdbOs.c | 25 ++++++++++++++++++++++++- source/libs/tdb/src/inc/tdbOs.h | 8 +++++--- 3 files changed, 30 insertions(+), 4 deletions(-) diff --git a/source/libs/tdb/CMakeLists.txt b/source/libs/tdb/CMakeLists.txt index 8612c9dc8f..0b1378dc5a 100644 --- a/source/libs/tdb/CMakeLists.txt +++ b/source/libs/tdb/CMakeLists.txt @@ -9,6 +9,7 @@ target_sources(tdb "src/db/tdbDb.c" "src/db/tdbEnv.c" "src/db/tdbTxn.c" + "src/db/tdbOs.c" "src/page/tdbPage.c" "src/page/tdbPageL.c" ) diff --git a/source/libs/tdb/src/db/tdbOs.c b/source/libs/tdb/src/db/tdbOs.c index 6dea4a4e57..d8df761069 100644 --- a/source/libs/tdb/src/db/tdbOs.c +++ b/source/libs/tdb/src/db/tdbOs.c @@ -11,4 +11,27 @@ * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . - */ \ No newline at end of file + */ + +#include "tdbInt.h" + +// tdbOsRead +i64 tdbOsRead(tdb_fd_t fd, void *pBuf, i64 nBytes) { + // TODO + ASSERT(0); + return 0; +} + +// tdbOsPRead +i64 tdbOsPRead(tdb_fd_t fd, void *pBuf, i64 nBytes, i64 offset) { + // TODO + ASSERT(0); + return 0; +} + +// tdbOsWrite +i64 taosWriteFile(tdb_fd_t fd, const void *pBuf, i64 nBytes) { + // TODO + ASSERT(0); + return 0; +} \ No newline at end of file diff --git a/source/libs/tdb/src/inc/tdbOs.h b/source/libs/tdb/src/inc/tdbOs.h index fd51136957..851dd69c29 100644 --- a/source/libs/tdb/src/inc/tdbOs.h +++ b/source/libs/tdb/src/inc/tdbOs.h @@ -65,9 +65,11 @@ typedef int tdb_fd_t; #define tdbOsOpen open #define tdbOsClose close -#define tdbOsRead read // TODO -#define tdbOsPRead pread // TODO -#define tdbOsWrite write // TODO + +i64 tdbOsRead(tdb_fd_t fd, void *pBuf, i64 nBytes); +i64 tdbOsPRead(tdb_fd_t fd, void *pBuf, i64 nBytes, i64 offset); +i64 taosWriteFile(tdb_fd_t fd, const void *pBuf, i64 nBytes); + #define tdbOsFSync fsync #define tdbOsLSeek lseek