From fe5fe72e630f057eff88a00be0b0c4438f046fbc Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sun, 26 Mar 2023 05:50:18 +0000 Subject: [PATCH] add backend --- source/libs/stream/src/streamStateRocksdb.c | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c index 2a26a9d648..3f703a5f46 100644 --- a/source/libs/stream/src/streamStateRocksdb.c +++ b/source/libs/stream/src/streamStateRocksdb.c @@ -538,9 +538,10 @@ SStreamStateCur* streamStateSessionSeekKeyCurrentPrev_rocksdb(SStreamState* pSta char buf[128] = {0}; SStateSessionKey sKey = {.key = *key, .opNum = pState->number}; int len = stateSessionKeyEncode(&sKey, buf); - char toString[128] = {0}; - stateSessionKeyToString(&sKey, toString); - // qWarn("streamState seek key %s", toString); + + // char toString[128] = {0}; + // stateSessionKeyToString(&sKey, toString); + // qWarn("streamState seek key %s", toString); rocksdb_iter_seek(pCur->iter, buf, len); if (!rocksdb_iter_valid(pCur->iter)) { @@ -659,8 +660,9 @@ SStreamStateCur* streamStateGetCur_rocksdb(SStreamState* pState, const SWinKey* SStateKey sKey = {.key = *key, .opNum = pState->number}; char buf[128] = {0}; int len = stateKeyEncode((void*)&sKey, buf); - char sKeyStr[128] = {0}; - stateKeyToString(&sKey, sKeyStr); + + // char sKeyStr[128] = {0}; + // stateKeyToString(&sKey, sKeyStr); rocksdb_iter_seek(pCur->iter, buf, len); if (rocksdb_iter_valid(pCur->iter)) { SStateKey curKey; -- GitLab