Namdak Tonpa 4 years ago
parent
commit
6f1a6db9f1
1 changed files with 3 additions and 3 deletions
  1. 3 3
      src/stores/kvs_rocks.erl

+ 3 - 3
src/stores/kvs_rocks.erl

@@ -49,9 +49,9 @@ o(Key,FK,Dir,Fx) ->
   end end,
   end end,
 
 
   It = fun(F,{ok,H})            -> {F(H,{seek,Key}),H};
   It = fun(F,{ok,H})            -> {F(H,{seek,Key}),H};
-          (F,{{ok,K,V},H}) when Dir =:= prev -> RangeCheckRun(F,K,V,H);
-          (F,{{ok,K,V},H})      -> Run(F,K,H,V,[]);
-          (F,{{ok,K,V},H,A})    -> Run(F,K,H,V,A);
+          (F,{{ok,K,V},H}) when Dir =:= prev -> RangeCheckRun(F,K,V,H); % first move
+          (F,{{ok,K,V},H})      -> Run(F,K,H,V,[]); % first move
+          (F,{{ok,K,V},H,A})    -> Run(F,K,H,V,A); % CPS continuator
           (_,{{error,_},H,Acc}) -> {{ok,[],[]},H,Acc};
           (_,{{error,_},H,Acc}) -> {{ok,[],[]},H,Acc};
           (F,{R,O})             -> F(R,O);
           (F,{R,O})             -> F(R,O);
           (F,H)                 -> F(H) end,
           (F,H)                 -> F(H) end,