xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

more

This commit is contained in:
Hongze Cheng 2021-11-29 18:25:00 +08:00
parent fbf47592fc
commit 8c1638b8fb
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
include/dnode/vnode/vnode.h
View File

@ -174,10 +174,6 @@ typedef struct {
int vnodeBuildReq(void **buf, const SVnodeReq *pReq, uint8_t type); int vnodeBuildReq(void **buf, const SVnodeReq *pReq, uint8_t type);
void *vnodeParseReq(void *buf, 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 ------------------------ */ /* ------------------------ FOR COMPILE ------------------------ */
#if 1 #if 1

7
source/dnode/vnode/impl/src/vnodeRequest.c
View File

@ -15,6 +15,9 @@
#include "vnodeDef.h" #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 vnodeBuildReq(void **buf, const SVnodeReq *pReq, uint8_t type) {
int tsize = 0; int tsize = 0;
@ -48,7 +51,7 @@ void *vnodeParseReq(void *buf, SVnodeReq *pReq, uint8_t type) {
return buf; return buf;
} }
int vnodeBuildCreateTableReq(void **buf, const SVCreateTableReq *pReq) { static int vnodeBuildCreateTableReq(void **buf, const SVCreateTableReq *pReq) {
int tsize = 0; int tsize = 0;
tsize += taosEncodeString(buf, pReq->name); tsize += taosEncodeString(buf, pReq->name);
@ -76,7 +79,7 @@ int vnodeBuildCreateTableReq(void **buf, const SVCreateTableReq *pReq) {
return tsize; return tsize;
} }
void *vnodeParseCreateTableReq(void *buf, SVCreateTableReq *pReq) { static void *vnodeParseCreateTableReq(void *buf, SVCreateTableReq *pReq) {
buf = taosDecodeString(buf, &(pReq->name)); buf = taosDecodeString(buf, &(pReq->name));
buf = taosDecodeFixedU32(buf, &(pReq->ttl)); buf = taosDecodeFixedU32(buf, &(pReq->ttl));
buf = taosDecodeFixedU32(buf, &(pReq->keep)); buf = taosDecodeFixedU32(buf, &(pReq->keep));