From 885c44e472843e1646687c071e9277da92d991e8 Mon Sep 17 00:00:00 2001
From: Magnus Ahltorp <map@kth.se>
Date: Tue, 22 Nov 2016 14:35:36 +0100
Subject: Make certain operations parallel

---
 test/permdbtest.erl | 27 ++++++++++++++++++++++++++-
 1 file changed, 26 insertions(+), 1 deletion(-)

(limited to 'test/permdbtest.erl')

diff --git a/test/permdbtest.erl b/test/permdbtest.erl
index 1c43861..a36ae85 100755
--- a/test/permdbtest.erl
+++ b/test/permdbtest.erl
@@ -53,6 +53,19 @@ addvalue_loop([{K, VSeed}|Rest], Port, Datasize) ->
             exit(mismatch)
     end.
 
+addvalues(TestData, Port, Datasize) ->
+    KeyValues = lists:map(fun ({K, VSeed}) ->
+		      V = constructdata(VSeed, Datasize),
+		      {K, V}
+		end, TestData),
+    case permdb:addvalues(testdb, KeyValues) of
+        ok ->
+    	   none;
+        Other ->
+            io:format("expected: 0 or 1 got: ~p~n", [Other]),
+            exit(mismatch)
+    end.
+
 testget(_Filename, TestData, Datasize) ->
     getvalue_loop(TestData, none, Datasize),
     ok.
@@ -67,6 +80,16 @@ testadd(_Filename, TestData, Datasize) ->
             exit(mismatch)
     end.
 
+testaddmulti(_Filename, TestData, Datasize) ->
+    addvalues(TestData, none, Datasize),
+    case permdb:commit(testdb) of
+        <<0>> ->
+            ok;
+        Other ->
+            io:format("commit expected: 0 got: ~p~n", [Other]),
+            exit(mismatch)
+    end.
+
 stop() ->
     teststop(),
     receive
@@ -76,6 +99,8 @@ stop() ->
     end.
 
 main([]) ->
+    application:set_env(lager, handlers, [{lager_console_backend, debug}]),
+lager:start(),
     {ok, Cwd} = file:get_cwd(),
     code:add_path(Cwd ++ "/ebin"),
     Size = 10,
@@ -133,7 +158,7 @@ main([]) ->
     testadd(Filename, gentestdata(1), 99),
     testadd(Filename, gentestdata(1+2), 99),
     testadd(Filename, gentestdata(1+2+3), 99),
-    testadd(Filename, gentestdata(1+2+3+4), 99),
+    testaddmulti(Filename, gentestdata(1+2+3+4), 99),
     testget(Filename, gentestdata(1+2+3+4), 99),
     stop(),
 
-- 
cgit v1.1