From 81121469814e363988c650992759e21f04271ae8 Mon Sep 17 00:00:00 2001 From: Adam Kocoloski Date: Thu, 12 Aug 2010 09:03:46 -0400 Subject: resume reducers after the row is sent, BugzID 10683 --- apps/fabric/src/fabric_view.erl | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'apps') diff --git a/apps/fabric/src/fabric_view.erl b/apps/fabric/src/fabric_view.erl index 1558d301..e5f19b73 100644 --- a/apps/fabric/src/fabric_view.erl +++ b/apps/fabric/src/fabric_view.erl @@ -161,7 +161,10 @@ get_next_row(#collector{reducer = RedSrc} = St) when RedSrc =/= undefined -> Wrapped = [[V] || #view_row{value=V} <- Records], {ok, [Reduced]} = couch_query_servers:rereduce(Proc, [RedSrc], Wrapped), NewSt = St#collector{keys=RestKeys, rows=NewRowDict, counters=Counters}, - {#view_row{key=Key, id=reduced, value=Reduced}, NewSt}; + NewState = lists:foldl(fun(#view_row{worker=Worker}, StateAcc) -> + maybe_resume_worker(Worker, StateAcc) + end, NewSt, Records), + {#view_row{key=Key, id=reduced, value=Reduced}, NewState}; error -> get_next_row(St#collector{keys=RestKeys}) end; -- cgit v1.2.3