From 1cf96cdbf1348503522f701c6d697689156c21a5 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 29 Mar 2023 04:18:16 +0000 Subject: [PATCH] add backend --- source/libs/stream/src/streamStateRocksdb.c | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/source/libs/stream/src/streamStateRocksdb.c b/source/libs/stream/src/streamStateRocksdb.c index eff7f5d722..837255119b 100644 --- a/source/libs/stream/src/streamStateRocksdb.c +++ b/source/libs/stream/src/streamStateRocksdb.c @@ -398,17 +398,11 @@ int streamGetInit(const char* funcName) { return -1; } bool streamStateIterSeekAndValid(rocksdb_iterator_t* iter, char* buf, size_t len) { - bool valid = false; - // opt later - rocksdb_iter_seek(iter, buf, len); + rocksdb_iter_seek_for_prev(iter, buf, len); if (!rocksdb_iter_valid(iter)) { - rocksdb_iter_seek_for_prev(iter, buf, len); - if (!rocksdb_iter_valid(iter)) { - return valid; - } + return false; } - valid = true; - return valid; + return true; } rocksdb_iterator_t* streamStateIterCreate(SStreamState* pState, const char* cfName, rocksdb_snapshot_t** snapshot, rocksdb_readoptions_t** readOpt) {