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

fix(test): fix syntax error.

This commit is contained in:
Haojun Liao 2024-05-08 10:18:19 +08:00
parent 64ae35affe
commit 5ee1cba173
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
include/libs/stream/streammsg.h
View File

@ -16,6 +16,10 @@
#ifndef TDENGINE_STREAMMSG_H #ifndef TDENGINE_STREAMMSG_H
#define TDENGINE_STREAMMSG_H #define TDENGINE_STREAMMSG_H
#ifdef __cplusplus
extern "C" {
#endif
typedef struct SStreamChildEpInfo { typedef struct SStreamChildEpInfo {
int32_t nodeId; int32_t nodeId;
int32_t childId; int32_t childId;
@ -143,7 +147,7 @@ struct SStreamRetrieveReq {
int32_t tEncodeStreamRetrieveReq(SEncoder* pEncoder, const struct SStreamRetrieveReq* pReq); int32_t tEncodeStreamRetrieveReq(SEncoder* pEncoder, const struct SStreamRetrieveReq* pReq);
int32_t tDecodeStreamRetrieveReq(SDecoder* pDecoder, struct SStreamRetrieveReq* pReq); int32_t tDecodeStreamRetrieveReq(SDecoder* pDecoder, struct SStreamRetrieveReq* pReq);
void tCleanupStreamRetrieveReq(struct SStreamRetrieveReq* pReq); void tCleanupStreamRetrieveReq(struct SStreamRetrieveReq* pReq);
typedef struct SStreamTaskCheckpointReq { typedef struct SStreamTaskCheckpointReq {
int64_t streamId; int64_t streamId;
@ -172,4 +176,8 @@ typedef struct {
int32_t reqType; int32_t reqType;
} SStreamTaskRunReq; } SStreamTaskRunReq;
#ifdef __cplusplus
}
#endif
#endif // TDENGINE_STREAMMSG_H #endif // TDENGINE_STREAMMSG_H