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

add backend

This commit is contained in:
yihaoDeng 2023-03-29 04:18:16 +00:00
parent e6e9828d5a
commit 1cf96cdbf1
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
source/libs/stream/src/streamStateRocksdb.c
View File

@ -398,17 +398,11 @@ int streamGetInit(const char* funcName) {
return -1; return -1;
} }
bool streamStateIterSeekAndValid(rocksdb_iterator_t* iter, char* buf, size_t len) { bool streamStateIterSeekAndValid(rocksdb_iterator_t* iter, char* buf, size_t len) {
bool valid = false; rocksdb_iter_seek_for_prev(iter, buf, len);
// opt later
rocksdb_iter_seek(iter, buf, len);
if (!rocksdb_iter_valid(iter)) { if (!rocksdb_iter_valid(iter)) {
rocksdb_iter_seek_for_prev(iter, buf, len); return false;
if (!rocksdb_iter_valid(iter)) {
return valid;
}
} }
valid = true; return true;
return valid;
} }
rocksdb_iterator_t* streamStateIterCreate(SStreamState* pState, const char* cfName, rocksdb_snapshot_t** snapshot, rocksdb_iterator_t* streamStateIterCreate(SStreamState* pState, const char* cfName, rocksdb_snapshot_t** snapshot,
rocksdb_readoptions_t** readOpt) { rocksdb_readoptions_t** readOpt) {