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

fix issue in single meter subscription.

This commit is contained in:
localvar 2020-01-06 10:43:15 +08:00
parent 592f210983
commit 23527898e7
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/system/detail/src/vnodeShell.c
View File

@ -494,7 +494,11 @@ void vnodeExecuteRetrieveReq(SSchedMsg *pSched) {
pMsg += sizeof(int32_t); pMsg += sizeof(int32_t);
*((int64_t*)pMsg) = htobe64(pQInfo->pObj->uid); *((int64_t*)pMsg) = htobe64(pQInfo->pObj->uid);
pMsg += sizeof(int64_t); pMsg += sizeof(int64_t);
*((TSKEY*)pMsg) = htobe64(pQInfo->query.lastKey); if (pQInfo->pointsRead > 0) {
*((TSKEY*)pMsg) = htobe64(pQInfo->query.lastKey + 1);
} else {
*((TSKEY*)pMsg) = htobe64(pQInfo->query.lastKey);
}
pMsg += sizeof(TSKEY); pMsg += sizeof(TSKEY);
} }

5
tests/examples/c/subscribe.c
View File

@ -63,6 +63,11 @@ int main(int argc, char *argv[]) {
keep = 0; keep = 0;
continue; continue;
} }
if (strncmp(argv[i], "-sql=", 5) == 0) {
sql = argv[i] + 5;
topic = "test-custom";
continue;
}
} }
// init TAOS // init TAOS