fix(tmq): revoke the fix, it will definitly cause the deadlock.
This commit is contained in:
parent
134c0528ae
commit
7e9432606d
|
@ -170,7 +170,7 @@ class TMQCom:
|
||||||
if tdSql.getData(i, 1) == 1:
|
if tdSql.getData(i, 1) == 1:
|
||||||
loopFlag = 0
|
loopFlag = 0
|
||||||
break
|
break
|
||||||
time.sleep(0.02)
|
time.sleep(0.10)
|
||||||
return
|
return
|
||||||
|
|
||||||
def create_database(self,tsql, dbName,dropFlag=1,vgroups=4,replica=1):
|
def create_database(self,tsql, dbName,dropFlag=1,vgroups=4,replica=1):
|
||||||
|
|
|
@ -690,12 +690,11 @@ int32_t notifyMainScript(SThreadInfo* pInfo, int32_t cmdId) {
|
||||||
}
|
}
|
||||||
|
|
||||||
static int32_t g_once_commit_flag = 0;
|
static int32_t g_once_commit_flag = 0;
|
||||||
static int32_t g_once_consume_flag = 0;
|
|
||||||
|
|
||||||
static void tmq_commit_cb_print(tmq_t* tmq, int32_t code, void* param) {
|
static void tmq_commit_cb_print(tmq_t* tmq, int32_t code, void* param) {
|
||||||
taosFprintfFile(g_fp, "tmq_commit_cb_print() commit %d\n", code);
|
taosFprintfFile(g_fp, "tmq_commit_cb_print() commit %d\n", code);
|
||||||
|
|
||||||
if (g_once_consume_flag == 1 && 0 == g_once_commit_flag) {
|
if (0 == g_once_commit_flag) {
|
||||||
g_once_commit_flag = 1;
|
g_once_commit_flag = 1;
|
||||||
notifyMainScript((SThreadInfo*)param, (int32_t)NOTIFY_CMD_START_COMMIT);
|
notifyMainScript((SThreadInfo*)param, (int32_t)NOTIFY_CMD_START_COMMIT);
|
||||||
}
|
}
|
||||||
|
@ -774,6 +773,8 @@ int32_t saveConsumeResult(SThreadInfo* pInfo) {
|
||||||
void loop_consume(SThreadInfo* pInfo) {
|
void loop_consume(SThreadInfo* pInfo) {
|
||||||
int32_t code;
|
int32_t code;
|
||||||
|
|
||||||
|
int32_t once_flag = 0;
|
||||||
|
|
||||||
int64_t totalMsgs = 0;
|
int64_t totalMsgs = 0;
|
||||||
int64_t totalRows = 0;
|
int64_t totalRows = 0;
|
||||||
|
|
||||||
|
@ -833,8 +834,8 @@ void loop_consume(SThreadInfo* pInfo) {
|
||||||
lastTotalMsgs = totalMsgs;
|
lastTotalMsgs = totalMsgs;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (0 == g_once_consume_flag) {
|
if (0 == once_flag) {
|
||||||
g_once_consume_flag = 1;
|
once_flag = 1;
|
||||||
notifyMainScript(pInfo, NOTIFY_CMD_START_CONSUM);
|
notifyMainScript(pInfo, NOTIFY_CMD_START_CONSUM);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue