diff options
author | Magnus Ahltorp <map@kth.se> | 2015-10-01 12:39:28 +0200 |
---|---|---|
committer | Linus Nordberg <linus@nordu.net> | 2015-11-11 13:32:37 +0100 |
commit | 0a3e6aafee314eaf9e5343c4cad89a9e2ae1d913 (patch) | |
tree | 2ceb97ebf656a26ac384e0e550dc2070d1b7ec72 /src/storagedb.erl | |
parent | 55820add0bda7ac926f11ee49b232dc11d6fe39c (diff) |
Change index.erl to use gen_server and named databases.
Prefetch indices in frontend:fetchmissingentries/2.
Diffstat (limited to 'src/storagedb.erl')
-rw-r--r-- | src/storagedb.erl | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/storagedb.erl b/src/storagedb.erl index d781033..9f7da37 100644 --- a/src/storagedb.erl +++ b/src/storagedb.erl @@ -31,11 +31,11 @@ lastverifiednewentry_path() -> %% Public API. fetchnewhashes(Index) -> - case index:indexsize(newentries_path()) of + case index:indexsize(newentries_db) of 0 -> []; Size -> - index:getrange(newentries_path(), Index, Size - 1) + index:getrange(newentries_db, Index, Size - 1) end. lastverifiednewentry() -> @@ -52,7 +52,7 @@ lastverifiednewentry() -> -spec add(binary()) -> ok. add(LeafHash) -> ok = call(?MODULE, {add_nosync, LeafHash}), - ok = index:sync(newentries_path()), + ok = index:sync(newentries_db), ok. %%%%%%%%%%%%%%%%%%%% @@ -73,13 +73,9 @@ terminate(_Reason, _State) -> %%%%%%%%%%%%%%%%%%%% -newentries_path() -> - {ok, Value} = application:get_env(plop, newentries_path), - Value. - handle_call(stop, _From, State) -> {stop, normal, stopped, State}; handle_call({add_nosync, LeafHash}, _From, State) -> - ok = index:addlast_nosync(newentries_path(), LeafHash), + ok = index:addlast_nosync(newentries_db, LeafHash), {reply, ok, State}. |