more TDB

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"
 )

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 <http://www.gnu.org/licenses/>.
- */
+ */
+
+#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;
+}

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