diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/fabric_doc_open.erl | 3 | ||||
| -rw-r--r-- | src/fabric_doc_open_revs.erl | 3 |
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}; |