fix:[TD-31017]process return value in client for tmq
This commit is contained in:
parent
37fd3d4fa8
commit
b873356d80
|
@ -29,22 +29,6 @@
|
||||||
#define DEFAULT_HEARTBEAT_INTERVAL 3000
|
#define DEFAULT_HEARTBEAT_INTERVAL 3000
|
||||||
#define DEFAULT_ASKEP_INTERVAL 1000
|
#define DEFAULT_ASKEP_INTERVAL 1000
|
||||||
|
|
||||||
#define CLIENT_TMQ_NULL_CHECK(c) \
|
|
||||||
do { \
|
|
||||||
if (c == NULL) { \
|
|
||||||
code = TSDB_CODE_OUT_OF_MEMORY; \
|
|
||||||
goto END; \
|
|
||||||
} \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
#define CLIENT_TMQ_RETURN_CHECK(c) \
|
|
||||||
do { \
|
|
||||||
code = c; \
|
|
||||||
if (code != 0) { \
|
|
||||||
goto END; \
|
|
||||||
} \
|
|
||||||
} while (0)
|
|
||||||
|
|
||||||
struct SMqMgmt {
|
struct SMqMgmt {
|
||||||
tmr_h timer;
|
tmr_h timer;
|
||||||
int32_t rsetId;
|
int32_t rsetId;
|
||||||
|
|
Loading…
Reference in New Issue