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

refine heartbeat interface

This commit is contained in:
Liu Jicong 2022-01-06 19:58:54 +08:00
parent 5c73c1ffd8
commit 11449f3d98
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
source/client/inc/clientHb.h
View File

@ -38,7 +38,7 @@ typedef struct SClientHbKey {
} SClientHbKey; } SClientHbKey;
typedef struct SClientHbReq { typedef struct SClientHbReq {
SClientHbKey hbKey; SClientHbKey connKey;
SHashObj* info; // hash<Slv.key, Sklv> SHashObj* info; // hash<Slv.key, Sklv>
} SClientHbReq; } SClientHbReq;
@ -51,8 +51,10 @@ typedef struct SClientHbHandleResult {
} SClientHbHandleResult; } SClientHbHandleResult;
typedef struct SClientHbRsp { typedef struct SClientHbRsp {
int32_t connId; SClientHbKey connKey;
int32_t hbType; int32_t status;
int32_t bodyLen;
void* body;
} SClientHbRsp; } SClientHbRsp;
typedef struct SClientHbBatchRsp { typedef struct SClientHbBatchRsp {
@ -118,7 +120,7 @@ static FORCE_INLINE void* taosDecodeSClientHbKey(void* buf, SClientHbKey* pKey)
static FORCE_INLINE int tSerializeSClientHbReq(void** buf, const SClientHbReq* pReq) { static FORCE_INLINE int tSerializeSClientHbReq(void** buf, const SClientHbReq* pReq) {
int tlen = 0; int tlen = 0;
tlen += taosEncodeSClientHbKey(buf, &pReq->hbKey); tlen += taosEncodeSClientHbKey(buf, &pReq->connKey);
void* pIter = NULL; void* pIter = NULL;
void* data; void* data;
@ -137,7 +139,7 @@ static FORCE_INLINE int tSerializeSClientHbReq(void** buf, const SClientHbReq* p
static FORCE_INLINE void* tDeserializeClientHbReq(void* buf, SClientHbReq* pReq) { static FORCE_INLINE void* tDeserializeClientHbReq(void* buf, SClientHbReq* pReq) {
ASSERT(pReq->info != NULL); ASSERT(pReq->info != NULL);
buf = taosDecodeSClientHbKey(buf, &pReq->hbKey); buf = taosDecodeSClientHbKey(buf, &pReq->connKey);
// TODO: error handling // TODO: error handling
if (pReq->info == NULL) { if (pReq->info == NULL) {