[couchdb] 17/33: WIP - read repair fabric_doc_open_revs

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davisp pushed a commit to branch COUCHDB-3326-clustered-purge-davisp-refactor
in repository https://gitbox.apache.org/repos/asf/couchdb.git

commit 6b62e0ebd4434d3c6b4d6d9f95ad4f1e2689c6b5
Author: Paul J. Davis <pa...@gmail.com>
AuthorDate: Mon Mar 26 13:06:32 2018 -0500

    WIP - read repair fabric_doc_open_revs
---
 src/fabric/src/fabric_doc_open_revs.erl | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/fabric/src/fabric_doc_open_revs.erl b/src/fabric/src/fabric_doc_open_revs.erl
index a020ba6..bb93568 100644
--- a/src/fabric/src/fabric_doc_open_revs.erl
+++ b/src/fabric/src/fabric_doc_open_revs.erl
@@ -30,7 +30,7 @@
     latest,
     replies = [],
     node_id_revs = [],
-    repair = false,
+    repair = false
 }).
 
 go(DbName, Id, Revs, Options) ->
@@ -109,14 +109,14 @@ handle_message({ok, RawReplies}, Worker, State) ->
             {NewReplies0, MinCount} = dict_replies(PrevReplies, RawReplies),
             {NewReplies0, MinCount >= R, false}
     end,
-    NewNodeIdRevs = if Woker == nil -> PrevNodeIdRevs; true ->
+    NewNodeIdRevs = if Worker == nil -> PrevNodeIdRevs; true ->
         IdRevs = lists:foldl(fun
             ({ok, #doc{id = Id, revs = {Pos, [Rev | _]}}}, Acc) ->
                 [{Id, {Pos, Rev}} | Acc];
             (_, Acc) ->
                 Acc
         end, [], RawReplies),
-        [{Worker#worker.shard, IdRevs} | PrevNodeIdRevs]
+        [{Worker#shard.node, IdRevs} | PrevNodeIdRevs]
     end,
 
     Complete = (ReplyCount =:= (WorkerCount - 1)),

-- 
To stop receiving notification emails like this one, please contact
davisp@apache.org.