Skip to content

Commit 0ff6804

Browse files
committed
upgrade clause for fabric_doc_update
acc record introduced in d3eb273 add a clause so an upgraded node can receive a message from a not-yet-upgraded node during a cluster upgrade
1 parent a2ba5e2 commit 0ff6804

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

src/fabric/src/fabric_doc_update.erl

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,15 @@ go(DbName, AllDocs0, Opts) ->
7272
rexi_monitor:stop(RexiMon)
7373
end.
7474

75+
% upgrade clause
76+
handle_message(Msg, Worker, {WaitingCount, DocCount, W, GroupedDocs, Reply}) ->
77+
handle_message(Msg, Worker, #acc{
78+
waiting_count = WaitingCount,
79+
DocCount = DocCount,
80+
w = W,
81+
grouped_docs = GroupedDocs,
82+
reply = Reply
83+
});
7584
handle_message({rexi_DOWN, _, {_, NodeRef}, _}, _Worker, #acc{} = Acc0) ->
7685
#acc{grouped_docs = GroupedDocs} = Acc0,
7786
NewGrpDocs = [X || {#shard{node = N}, _} = X <- GroupedDocs, N =/= NodeRef],

0 commit comments

Comments
 (0)