dxt 4 years ago
parent
commit
8611ad053f
2 changed files with 2 additions and 2 deletions
  1. 1 1
      src/stores/kvs_rocks.erl
  2. 1 1
      src/stores/kvs_st.erl

+ 1 - 1
src/stores/kvs_rocks.erl

@@ -33,7 +33,7 @@ key(Tab,R) when is_tuple(R) andalso tuple_size(R) > 1 -> key(Tab, e(2,R));
 key(Tab,R) ->
 key(Tab,R) ->
   iolist_to_binary([lists:join(<<"/">>, lists:flatten([<<>>, tb(Tab), fmt(R)]))]).
   iolist_to_binary([lists:join(<<"/">>, lists:flatten([<<>>, tb(Tab), fmt(R)]))]).
 
 
-fd(Key) ->
+fd(K) -> Key = tb(K),
   End = byte_size(Key),
   End = byte_size(Key),
   {S,_} = case binary:matches(Key,[<<"/">>],[]) of
   {S,_} = case binary:matches(Key,[<<"/">>],[]) of
     [{0,1}]         -> {End,End};
     [{0,1}]         -> {End,End};

+ 1 - 1
src/stores/kvs_st.erl

@@ -56,7 +56,7 @@ save(C) -> NC = c4(C,[]), kvs:put(NC), NC.
 add(#writer{args=M}=C) when element(2,M) == [] -> add(si(M,kvs:seq([],[])),C);
 add(#writer{args=M}=C) when element(2,M) == [] -> add(si(M,kvs:seq([],[])),C);
 add(#writer{args=M}=C) -> add(M,C).
 add(#writer{args=M}=C) -> add(M,C).
 
 
-add(M,#writer{id=Feed,count=S}=C) -> NS=S+1, raw_append(M,Feed), C#writer{cache={e(1,M),e(2,M),key(Feed)},count=NS}.
+add(M,#writer{id=Feed,count=S}=C) -> NS=S+1, raw_append(M,Feed), C#writer{cache={e(1,M),e(2,M),fd(Feed)},count=NS}.
 
 
 remove(Rec,Feed) ->
 remove(Rec,Feed) ->
    kvs:ensure(#writer{id=Feed}),
    kvs:ensure(#writer{id=Feed}),