/* * Copyright (c) 2019 TAOS Data, Inc. * * 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 . */ #ifndef _TD_VNODE_H_ #define _TD_VNODE_H_ #include "os.h" #include "trpc.h" #include "meta.h" #include "tarray.h" #include "tq.h" #include "tsdb.h" #include "wal.h" #ifdef __cplusplus extern "C" { #endif /* ------------------------ TYPES EXPOSED ------------------------ */ typedef struct SVnode SVnode; typedef struct SVnodeCfg { /** vnode buffer pool options */ struct { /** write buffer size */ uint64_t wsize; uint64_t ssize; uint64_t lsize; /** use heap allocator or arena allocator */ bool isHeapAllocator; }; /** time to live of tables in this vnode */ uint32_t ttl; /** data to keep in this vnode */ uint32_t keep; /** if TS data is eventually consistency */ bool isWeak; /** TSDB config */ STsdbCfg tsdbCfg; /** META config */ SMetaCfg metaCfg; /** TQ config */ STqCfg tqCfg; /** WAL config */ SWalCfg walCfg; } SVnodeCfg; /* ------------------------ SVnode ------------------------ */ /** * @brief Initialize the vnode module * * @param nthreads number of commit threads. 0 for no threads and * a schedule queue should be given (TODO) * @return int 0 for success and -1 for failure */ int vnodeInit(uint16_t nthreads); /** * @brief clear a vnode * */ void vnodeClear(); /** * @brief Open a VNODE. * * @param path path of the vnode * @param pVnodeCfg options of the vnode * @return SVnode* The vnode object */ SVnode *vnodeOpen(const char *path, const SVnodeCfg *pVnodeCfg); /** * @brief Close a VNODE * * @param pVnode The vnode object to close */ void vnodeClose(SVnode *pVnode); /** * @brief Destroy a VNODE. * * @param path Path of the VNODE. */ void vnodeDestroy(const char *path); /** * @brief Process an array of write messages. * * @param pVnode The vnode object. * @param pMsgs The array of SRpcMsg * @return int 0 for success, -1 for failure */ int vnodeProcessWMsgs(SVnode *pVnode, SArray *pMsgs); /** * @brief Apply a write request message. * * @param pVnode The vnode object. * @param pMsg The request message * @param pRsp The response message * @return int 0 for success, -1 for failure */ int vnodeApplyWMsg(SVnode *pVnode, SRpcMsg *pMsg, SRpcMsg **pRsp); /** * @brief Process the sync request * * @param pVnode * @param pMsg * @param pRsp * @return int */ int vnodeProcessSyncReq(SVnode *pVnode, SRpcMsg *pMsg, SRpcMsg **pRsp); /* ------------------------ SVnodeCfg ------------------------ */ /** * @brief Initialize VNODE options. * * @param pOptions The options object to be initialized. It should not be NULL. */ void vnodeOptionsInit(SVnodeCfg *pOptions); /** * @brief Clear VNODE options. * * @param pOptions Options to clear. */ void vnodeOptionsClear(SVnodeCfg *pOptions); /* ------------------------ REQUESTS ------------------------ */ typedef STbCfg SVCreateTableReq; typedef struct { tb_uid_t uid; } SVDropTableReq; typedef struct { // TODO } SVSubmitReq; typedef struct { uint64_t ver; union { SVCreateTableReq ctReq; SVDropTableReq dtReq; }; } SVnodeReq; typedef struct { int err; char info[]; } SVnodeRsp; #define VNODE_INIT_CREATE_STB_REQ(NAME, TTL, KEEP, SUID, PSCHEMA, PTAGSCHEMA) \ { .ver = 0, .ctReq = META_INIT_STB_CFG(NAME, TTL, KEEP, SUID, PSCHEMA, PTAGSCHEMA) } #define VNODE_INIT_CREATE_CTB_REQ(NAME, TTL, KEEP, SUID, PTAG) \ { .ver = 0, .ctReq = META_INIT_CTB_CFG(NAME, TTL, KEEP, SUID, PTAG) } #define VNODE_INIT_CREATE_NTB_REQ(NAME, TTL, KEEP, SUID, PSCHEMA) \ { .ver = 0, .ctReq = META_INIT_NTB_CFG(NAME, TTL, KEEP, SUID, PSCHEMA) } int vnodeBuildReq(void **buf, const SVnodeReq *pReq, uint8_t type); void *vnodeParseReq(void *buf, SVnodeReq *pReq, uint8_t type); /* ------------------------ FOR COMPILE ------------------------ */ #if 1 #include "taosmsg.h" #include "trpc.h" // typedef struct { // char db[TSDB_FULL_DB_NAME_LEN]; // int32_t cacheBlockSize; // MB // int32_t totalBlocks; // int32_t daysPerFile; // int32_t daysToKeep0; // int32_t daysToKeep1; // int32_t daysToKeep2; // int32_t minRowsPerFileBlock; // int32_t maxRowsPerFileBlock; // int8_t precision; // time resolution // int8_t compression; // int8_t cacheLastRow; // int8_t update; // int8_t quorum; // int8_t replica; // int8_t selfIndex; // int8_t walLevel; // int32_t fsyncPeriod; // millisecond // SReplica replicas[TSDB_MAX_REPLICA]; // } SVnodeCfg; typedef enum { VN_MSG_TYPE_WRITE = 1, VN_MSG_TYPE_APPLY, VN_MSG_TYPE_SYNC, VN_MSG_TYPE_QUERY, VN_MSG_TYPE_FETCH } EVnMsgType; typedef struct { int32_t curNum; int32_t allocNum; SRpcMsg rpcMsg[]; } SVnodeMsg; int32_t vnodeAlter(SVnode *pVnode, const SVnodeCfg *pCfg); int32_t vnodeCompact(SVnode *pVnode); int32_t vnodeSync(SVnode *pVnode); int32_t vnodeGetLoad(SVnode *pVnode, SVnodeLoad *pLoad); SVnodeMsg *vnodeInitMsg(int32_t msgNum); int32_t vnodeAppendMsg(SVnodeMsg *pMsg, SRpcMsg *pRpcMsg); void vnodeCleanupMsg(SVnodeMsg *pMsg); void vnodeProcessMsg(SVnode *pVnode, SVnodeMsg *pMsg, EVnMsgType msgType); #endif #ifdef __cplusplus } #endif #endif /*_TD_VNODE_H_*/