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

fix:compile error in windows & wait for heatbeat in case

This commit is contained in:
wangmm0220 2024-04-19 15:27:56 +08:00
parent 1695824c73
commit 32f6d525e6
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/client/src/clientRawBlockWrite.c
View File

@ -1630,7 +1630,7 @@ static int32_t tmqWriteRawDataImpl(TAOS* taos, void* data, int32_t dataLen) {
int8_t dataVersion = *(int8_t*)data;
if (dataVersion >= MQ_DATA_RSP_VERSION){
data += sizeof(int8_t) + sizeof(int32_t);
data = POINTER_SHIFT(data, sizeof(int8_t) + sizeof(int32_t));
dataLen -= sizeof(int8_t) + sizeof(int32_t);
}
tDecoderInit(&decoder, data, dataLen);
@ -1764,7 +1764,7 @@ static int32_t tmqWriteRawMetaDataImpl(TAOS* taos, void* data, int32_t dataLen)
int8_t dataVersion = *(int8_t*)data;
if (dataVersion >= MQ_DATA_RSP_VERSION){
data += sizeof(int8_t) + sizeof(int32_t);
data = POINTER_SHIFT(data, sizeof(int8_t) + sizeof(int32_t));
dataLen -= sizeof(int8_t) + sizeof(int32_t);
}

5
tests/system-test/7-tmq/tmq_primary_key.py
View File

@ -81,6 +81,8 @@ class TDTestCase:
finally:
consumer.close()
time.sleep(4) # wait for heart beat
tdSql.query(f'show subscriptions;')
sub = tdSql.getData(0, 4);
print(sub)
@ -190,6 +192,7 @@ class TDTestCase:
finally:
consumer.close()
time.sleep(4) # wait for heart beat
tdSql.query(f'show subscriptions;')
sub = tdSql.getData(0, 4);
print(sub)
@ -298,6 +301,7 @@ class TDTestCase:
finally:
consumer.close()
time.sleep(4) # wait for heart beat
tdSql.query(f'show subscriptions;')
sub = tdSql.getData(0, 4);
print(sub)
@ -406,6 +410,7 @@ class TDTestCase:
finally:
consumer.close()
time.sleep(4) # wait for heart beat
tdSql.query(f'show subscriptions;')
sub = tdSql.getData(0, 4);
print(sub)