Send #doc{} instead of #group{} to remote nodes
I realized after the fact that I'm still doing the evil thing of sending
records between nodes, so in a later two-phase upgrade we should fix
that. Nevertheless, the RPC workers are now configured to match on the
doc record, and this gets us to CommonJS faster.
BugzID: 13487
Project: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/commit/244bfa65
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/tree/244bfa65
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/diff/244bfa65
Branch: refs/heads/import
Commit: 244bfa65e9f8a390f46885724bf6ca66cc985aab
Parents: 88b2474
Author: Adam Kocoloski <a...@cloudant.com>
Authored: Tue Mar 5 10:51:41 2013 -0500
Committer: Adam Kocoloski <a...@cloudant.com>
Committed: Tue Mar 5 10:51:41 2013 -0500
----------------------------------------------------------------------
src/fabric_view_reduce.erl | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/couchdb-fabric/blob/244bfa65/src/fabric_view_reduce.erl
----------------------------------------------------------------------
diff --git a/src/fabric_view_reduce.erl b/src/fabric_view_reduce.erl
index e2c786b..a55e8cf 100644
--- a/src/fabric_view_reduce.erl
+++ b/src/fabric_view_reduce.erl
@@ -31,7 +31,7 @@ go(DbName, DDoc, VName, Args, Callback, Acc0) ->
{NthRed, View} = fabric_view:extract_view(nil, VName, Views, reduce),
{VName, RedSrc} = lists:nth(NthRed, View#view.reduce_funs),
Workers = lists:map(fun(#shard{name=Name, node=N} = Shard) ->
- Ref = rexi:cast(N, {fabric_rpc, reduce_view, [Name,Group,VName,Args]}),
+ Ref = rexi:cast(N, {fabric_rpc, reduce_view, [Name,DDoc,VName,Args]}),
Shard#shard{ref = Ref}
end, fabric_view:get_shards(DbName, Args)),
RexiMon = fabric_util:create_monitors(Workers),
