respect default r quorum in cluster config

2 files changed, 4 insertions, 2 deletions

diff --git a/src/fabric_doc_open.erl b/src/fabric_doc_open.erl
index 96545c55..19509295 100644
--- a/src/fabric_doc_open.erl
+++ b/src/fabric_doc_open.erl
@@ -8,7 +8,8 @@ go(DbName, Id, Options) ->
     Workers = fabric_util:submit_jobs(mem3:shards(DbName,Id), open_doc,
         [Id, Options]),
     SuppressDeletedDoc = not lists:member(deleted, Options),
-    Acc0 = {length(Workers), couch_util:get_value(r, Options, 1), []},
+    R = couch_util:get_value(r, Options, couch_config:get("cluster","r","2")),
+    Acc0 = {length(Workers), list_to_integer(R), []},
     case fabric_util:recv(Workers, #shard.ref, fun handle_message/3, Acc0) of
     {ok, {ok, #doc{deleted=true}}} when SuppressDeletedDoc ->
         {not_found, deleted};
diff --git a/src/fabric_doc_open_revs.erl b/src/fabric_doc_open_revs.erl
index 5bf5499f..9d3dae41 100644
--- a/src/fabric_doc_open_revs.erl
+++ b/src/fabric_doc_open_revs.erl
@@ -7,7 +7,8 @@
 go(DbName, Id, Revs, Options) ->
     Workers = fabric_util:submit_jobs(mem3:shards(DbName,Id), open_revs,
         [Id, Revs, Options]),
-    Acc0 = {length(Workers), couch_util:get_value(r, Options, 1), []},
+    R = couch_util:get_value(r, Options, couch_config:get("cluster","r","2")),
+    Acc0 = {length(Workers), list_to_integer(R), []},
     case fabric_util:recv(Workers, #shard.ref, fun handle_message/3, Acc0) of
     {ok, {ok, Reply}} ->
         {ok, Reply};