Ensure fetch still works when delete_pending
This commit is contained in:
parent
cf6a1eb513
commit
1537334fbd
1 changed files with 7 additions and 1 deletions
|
@ -402,7 +402,13 @@ reader(close, _From, State) ->
|
||||||
{stop, normal, ok, State}.
|
{stop, normal, ok, State}.
|
||||||
|
|
||||||
delete_pending({get_kv, Key}, _From, State) ->
|
delete_pending({get_kv, Key}, _From, State) ->
|
||||||
Reply = fetch_keyvalue(State#state.handle, State, Key),
|
Reply =
|
||||||
|
case leveled_tinybloom:check({hash, Hash}, State#state.bloom) of
|
||||||
|
false ->
|
||||||
|
not_present;
|
||||||
|
true ->
|
||||||
|
fetch_keyvalue(State#state.handle, State, Key)
|
||||||
|
end,
|
||||||
{reply, Reply, delete_pending, State, ?DELETE_TIMEOUT};
|
{reply, Reply, delete_pending, State, ?DELETE_TIMEOUT};
|
||||||
delete_pending({get_kvrange, StartKey, EndKey, ScanWidth}, _From, State) ->
|
delete_pending({get_kvrange, StartKey, EndKey, ScanWidth}, _From, State) ->
|
||||||
Reply = pointer_append_queryresults(fetch_range_kv(State#state.handle,
|
Reply = pointer_append_queryresults(fetch_range_kv(State#state.handle,
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue