From 8c1638b8fb155753f756a51f7c69c74e764a0e75 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Mon, 29 Nov 2021 18:25:00 +0800 Subject: [PATCH] more --- include/dnode/vnode/vnode.h | 4 ---- source/dnode/vnode/impl/src/vnodeRequest.c | 7 +++++-- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/include/dnode/vnode/vnode.h b/include/dnode/vnode/vnode.h index 4e5829a403..fcb77a4967 100644 --- a/include/dnode/vnode/vnode.h +++ b/include/dnode/vnode/vnode.h @@ -174,10 +174,6 @@ typedef struct { int vnodeBuildReq(void **buf, const SVnodeReq *pReq, uint8_t type); void *vnodeParseReq(void *buf, SVnodeReq *pReq, uint8_t type); -// TODO -int vnodeBuildCreateTableReq(void **buf, const SVCreateTableReq *pReq); -void *vnodeParseCreateTableReq(void *buf, SVCreateTableReq *pReq); - /* ------------------------ FOR COMPILE ------------------------ */ #if 1 diff --git a/source/dnode/vnode/impl/src/vnodeRequest.c b/source/dnode/vnode/impl/src/vnodeRequest.c index 59031fd530..5b17bf0ffb 100644 --- a/source/dnode/vnode/impl/src/vnodeRequest.c +++ b/source/dnode/vnode/impl/src/vnodeRequest.c @@ -15,6 +15,9 @@ #include "vnodeDef.h" +static int vnodeBuildCreateTableReq(void **buf, const SVCreateTableReq *pReq); +static void *vnodeParseCreateTableReq(void *buf, SVCreateTableReq *pReq); + int vnodeBuildReq(void **buf, const SVnodeReq *pReq, uint8_t type) { int tsize = 0; @@ -48,7 +51,7 @@ void *vnodeParseReq(void *buf, SVnodeReq *pReq, uint8_t type) { return buf; } -int vnodeBuildCreateTableReq(void **buf, const SVCreateTableReq *pReq) { +static int vnodeBuildCreateTableReq(void **buf, const SVCreateTableReq *pReq) { int tsize = 0; tsize += taosEncodeString(buf, pReq->name); @@ -76,7 +79,7 @@ int vnodeBuildCreateTableReq(void **buf, const SVCreateTableReq *pReq) { return tsize; } -void *vnodeParseCreateTableReq(void *buf, SVCreateTableReq *pReq) { +static void *vnodeParseCreateTableReq(void *buf, SVCreateTableReq *pReq) { buf = taosDecodeString(buf, &(pReq->name)); buf = taosDecodeFixedU32(buf, &(pReq->ttl)); buf = taosDecodeFixedU32(buf, &(pReq->keep));