Only serialize the actual write on storagedb, not the fsync

1 files changed, 9 insertions, 5 deletions

diff --git a/src/index.erl b/src/index.erl
index c0e344a..9d0df96 100644
--- a/src/index.erl
+++ b/src/index.erl
@@ -12,7 +12,7 @@
 %% TODO: Checksums
 
 -module(index).
--export([get/2, getrange/3, add/3, add_nosync/3, addlast/2, indexsize/1]).
+-export([get/2, getrange/3, add/3, add_nosync/3, addlast_nosync/2, indexsize/1, sync/1]).
 
 -define(ENTRYSIZE, 32).
 -define(ENTRYSIZEINFILE, (?ENTRYSIZE*2+1)).
@@ -64,7 +64,7 @@ add(Basepath, Index, Entry, Syncflag) when is_binary(Entry), size(Entry) == ?ENT
             ok = file:close(File),
             case Syncflag of
                 sync ->
-                    util:fsync([Basepath, filename:dirname(Basepath)]);
+                    sync(Basepath);
                 nosync ->
                     ok
             end;
@@ -74,9 +74,13 @@ add(Basepath, Index, Entry, Syncflag) when is_binary(Entry), size(Entry) == ?ENT
     end.
 
 
--spec addlast(string(), integer()) -> ok.
-addlast(Basepath, Entry) ->
-    add(Basepath, last, Entry).
+-spec sync(string()) -> ok.
+sync(Basepath) ->
+    util:fsync([Basepath, filename:dirname(Basepath)]).
+
+-spec addlast_nosync(string(), integer()) -> ok.
+addlast_nosync(Basepath, Entry) ->
+    add_nosync(Basepath, last, Entry).
 
 decodedata(Binary) ->
     lists:reverse(decodedata(Binary, [])).