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

rocksdb_iter_value

This commit is contained in:
yihaoDeng 2023-04-25 09:39:57 +00:00
parent c64a7d3e5f
commit 84cae91f9f
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -45,8 +45,9 @@ int streamStateValueIsStale(char* vv) {
return ts < taosGetTimestampSec() ? 1 : 0; return ts < taosGetTimestampSec() ? 1 : 0;
} }
int iterValueIsStale(rocksdb_iterator_t* iter) { int iterValueIsStale(rocksdb_iterator_t* iter) {
char* vv = (char*)rocksdb_iter_value(iter, NULL); size_t len;
return streamStateValueIsStale(vv); char* v = (char*)rocksdb_iter_value(iter, &len);
return streamStateValueIsStale(v);
} }
int defaultKeyEncode(void* k, char* buf) { int defaultKeyEncode(void* k, char* buf) {
int len = strlen((char*)k); int len = strlen((char*)k);
@ -997,7 +998,8 @@ SStreamStateCur* streamStateGetCur_rocksdb(SStreamState* pState, const SWinKey*
rocksdb_iter_seek(pCur->iter, buf, len); rocksdb_iter_seek(pCur->iter, buf, len);
if (rocksdb_iter_valid(pCur->iter) && !iterValueIsStale(pCur->iter)) { if (rocksdb_iter_valid(pCur->iter) && !iterValueIsStale(pCur->iter)) {
char* val = (char*)rocksdb_iter_value(pCur->iter, NULL); size_t vlen;
char* val = (char*)rocksdb_iter_value(pCur->iter, &vlen);
if (!streamStateValueIsStale(val)) { if (!streamStateValueIsStale(val)) {
SStateKey curKey; SStateKey curKey;
size_t kLen = 0; size_t kLen = 0;