more

include/libs/tkv/tkv.h

@@ -34,6 +34,7 @@ STkvDb *tkvOpen(const STkvOpts *options, const char *path);
 void    tkvClose(STkvDb *db);
 void    tkvPut(STkvDb *db, const STkvWriteOpts *, const char *key, size_t keylen, const char *val, size_t vallen);
 char *  tkvGet(STkvDb *db, const STkvReadOpts *, const char *key, size_t keylen, size_t *vallen);
+void    tkvCommit(STkvDb *db);
 
 // DB options
 STkvOpts *tkvOptsCreate();

source/libs/tkv/inc/tkvRocksdb.h

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * 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/>.
+ */
+
+#ifndef _TD_TVK_ROCKSDB_H_
+#define _TD_TVK_ROCKSDB_H_
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /*_TD_TVK_ROCKSDB_H_*/
\ No newline at end of file

source/libs/tkv/src/tkvRocksdb.c

+/*
+ * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
+ *
+ * This program is free software: you can use, redistribute, and/or modify
+ * it under the terms of the GNU Affero General Public License, version 3
+ * or later ("AGPL"), as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * 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/>.
+ */
\ No newline at end of file

source/server/vnode/tsdb/src/tsdbMemTable.c

@@ -14,3 +14,23 @@
  */
 
 #include "tsdbMemTable.h"
+
+STsdbMemTable *tsdbMemTableCreate(void *mallocator) {
+  STsdbMemTable *pTsdbMemTable = NULL;
+
+  pTsdbMemTable = (STsdbMemTable *)malloc(sizeof(*pTsdbMemTable));
+  if (pTsdbMemTable == NULL) {
+    return NULL;
+  }
+
+  // TODO
+
+  return pTsdbMemTable;
+}
+
+void tsdbMemTableDestroy(STsdbMemTable *pTsdbMemTable) {
+  if (pTsdbMemTable) {
+    // TODO
+    free(pTsdbMemTable);
+  }
+}
\ No newline at end of file