diff options
| author | Magnus Ahltorp <map@kth.se> | 2014-11-14 23:21:04 +0100 |
|---|---|---|
| committer | Magnus Ahltorp <map@kth.se> | 2014-11-19 05:03:19 +0100 |
| commit | c224989af3216b92c668c2f979b83551d49760cc (patch) | |
| tree | 50905eee20f0861c2fe2bf7d80dbf2255d4d0f44 /src/storage.erl | |
| parent | f8902f7899b4d76cabbf65763866d1a28fbcf743 (diff) | |
Seralize writes to new entries index
Diffstat (limited to 'src/storage.erl')
| -rw-r--r-- | src/storage.erl | 13 |
1 files changed, 3 insertions, 10 deletions
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"}], |