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

minor changes

This commit is contained in:
Shengliang Guan 2021-11-04 18:39:12 +08:00
parent dd3281c9d2
commit da1bf2a2a8
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -53,7 +53,7 @@ typedef enum {
VN_MSG_TYPE_SYNC, VN_MSG_TYPE_SYNC,
VN_MSG_TYPE_QUERY, VN_MSG_TYPE_QUERY,
VN_MSG_TYPE_FETCH VN_MSG_TYPE_FETCH
} EVMType; } EVnMsgType;
typedef struct { typedef struct {
int32_t curNum; int32_t curNum;
@ -83,7 +83,7 @@ int32_t vnodeGetLoad(SVnode *pVnode, SVnodeLoad *pLoad);
SVnodeMsg *vnodeInitMsg(int32_t msgNum); SVnodeMsg *vnodeInitMsg(int32_t msgNum);
int32_t vnodeAppendMsg(SVnodeMsg *pMsg, SRpcMsg *pRpcMsg); int32_t vnodeAppendMsg(SVnodeMsg *pMsg, SRpcMsg *pRpcMsg);
void vnodeCleanupMsg(SVnodeMsg *pMsg); void vnodeCleanupMsg(SVnodeMsg *pMsg);
void vnodeProcessMsg(SVnode *pVnode, SVnodeMsg *pMsg, EVMType msgType); void vnodeProcessMsg(SVnode *pVnode, SVnodeMsg *pMsg, EVnMsgType msgType);
#ifdef __cplusplus #ifdef __cplusplus
} }

2
source/dnode/vnode/impl/src/vnodeInt.c
View File

@ -56,7 +56,7 @@ void vnodeCleanupMsg(SVnodeMsg *pMsg) {
taosFreeQitem(pMsg); taosFreeQitem(pMsg);
} }
void vnodeProcessMsg(SVnode *pVnode, SVnodeMsg *pMsg, EVMType msgType) { void vnodeProcessMsg(SVnode *pVnode, SVnodeMsg *pMsg, EVnMsgType msgType) {
switch (msgType) { switch (msgType) {
case VN_MSG_TYPE_WRITE: case VN_MSG_TYPE_WRITE:
break; break;