From c224989af3216b92c668c2f979b83551d49760cc Mon Sep 17 00:00:00 2001
From: Magnus Ahltorp <map@kth.se>
Date: Fri, 14 Nov 2014 23:21:04 +0100
Subject: Seralize writes to new entries index

---
 src/storage.erl | 13 +++----------
 1 file changed, 3 insertions(+), 10 deletions(-)

(limited to 'src/storage.erl')

diff --git a/src/storage.erl b/src/storage.erl
index 8136308..e632a8e 100644
--- a/src/storage.erl
+++ b/src/storage.erl
@@ -20,7 +20,7 @@ request(post, "ct/storage/sendentry", Input) ->
             TreeLeafHash = base64:decode(proplists:get_value(<<"treeleafhash">>, PropList)),
 
             ok = db:add(TreeLeafHash, LogEntry),
-            ok = index:addlast(newentries_path(), TreeLeafHash),
+            ok = storagedb:add(TreeLeafHash),
             success({[{result, <<"ok">>}]})
     end;
 request(post, "ct/storage/entrycommitted", Input) ->
@@ -34,7 +34,8 @@ request(post, "ct/storage/entrycommitted", Input) ->
             success({[{result, <<"ok">>}]})
     end;
 request(get, "ct/storage/fetchnewentries", _Input) ->
-    NewHashes = fetchnewhashes(0),
+    NewHashes = storagedb:fetchnewhashes(0),
+    % XXX send only hashes, implement getentry
     Entries = lists:map(fun(LeafHash) ->
                                 {[{hash, base64:encode(LeafHash)},
                                   {entry, base64:encode(db:entry_for_leafhash(LeafHash))}]}
@@ -42,14 +43,6 @@ request(get, "ct/storage/fetchnewentries", _Input) ->
     success({[{result, <<"ok">>},
               {entries, Entries}]}).
 
-fetchnewhashes(Index) ->
-    case index:indexsize(newentries_path()) of
-        0 ->
-            [];
-        Size ->
-            index:getrange(newentries_path(), Index, Size - 1)
-    end.
-
 %% Private functions.
 html(Text, Input) ->
     {400, [{"Content-Type", "text/html"}],
-- 
cgit v1.1