diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 7f6fb4eb9aa494cc71f652c03ff1a1de67789a48..e1e54d5b69df2cd8b1d1ac0e1b7c72634ce664de 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -42,9 +42,7 @@ static void tscCheckpSql(SSqlObj* pSql) { assert(parent->metaSubPtr == pSql && parent->self == pSql->parentRid && parent->metaSubRid == pSql->self); } -static void tscCheckpSql2(SSqlObj* pSql, SSqlObj* parent) { - assert(parent->metaSubPtr == pSql && parent->self == pSql->parentRid && parent->metaSubRid == pSql->self); -} + static int32_t minMsgSize() { return tsRpcHeadSize + 100; } diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c index ee744962557140fe4379f11fdea1a386bcbda72d..1512b036093216b04b83deb7a97fa9abf4469bef 100644 --- a/src/client/src/tscSubquery.c +++ b/src/client/src/tscSubquery.c @@ -44,6 +44,11 @@ static int32_t tsCompare(int32_t order, int64_t left, int64_t right) { } } + +static void tscCheckpSql2(SSqlObj* pSql, SSqlObj* parent) { + assert(parent->metaSubPtr == pSql && parent->self == pSql->parentRid && parent->metaSubRid == pSql->self); +} + static void skipRemainValue(STSBuf* pTSBuf, tVariant* tag1) { while (tsBufNextPos(pTSBuf)) { STSElem el1 = tsBufGetElem(pTSBuf);