async_dirty

src/kvs.erl

@@ -59,6 +59,9 @@ add(Record) when is_tuple(Record) ->
 
     Id = element(#iterator.id, Record),
 
+    Res = kvs:get(element(1,Record), Id),
+    io:format("BREAK: ~p~n",[Res]),
+
     case kvs:get(element(1,Record), Id) of
         {error, not_found} ->
 

src/store_mnesia.erl

@@ -54,6 +54,9 @@ just_one(Fun) ->
         {atomic, []} -> {error, not_found};
         {atomic, [R]} -> {ok, R};
         {atomic, [_|_]} -> {error, duplicated};
+        [] -> {error, not_found};
+        [R] -> {ok,R};
+        [_|_] -> {error, duplicated};
         Error -> Error end.
 
-context() -> kvs:config(kvs,mnesia_context,transaction).
+context() -> kvs:config(kvs,mnesia_context,async_dirty).