diff options
Diffstat (limited to 'src/fabric/src/fabric_rpc.erl')
| -rw-r--r-- | src/fabric/src/fabric_rpc.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/fabric/src/fabric_rpc.erl b/src/fabric/src/fabric_rpc.erl index 4a69e7ea1..60526f495 100644 --- a/src/fabric/src/fabric_rpc.erl +++ b/src/fabric/src/fabric_rpc.erl @@ -142,8 +142,9 @@ reduce_view(DbName, DDoc, ViewName, Args0, DbOptions) -> couch_mrview:query_view(Db, DDoc, ViewName, Args, fun reduce_cb/2, VAcc0). fix_skip_and_limit(Args) -> - #mrargs{skip=Skip, limit=Limit}=Args, - Args#mrargs{skip=0, limit=Skip+Limit}. + #mrargs{skip=Skip, limit=Limit, extra=Extra}=Args, + % the coordinator needs to finalize each row, so make sure the shards don't + Args#mrargs{skip=0, limit=Skip+Limit, extra=[{finalizer,null} | Extra]}. create_db(DbName) -> create_db(DbName, []). @@ -439,6 +440,8 @@ make_att_reader({follows, Parser, Ref}) -> throw({mp_parser_died, Reason}) end end; +make_att_reader({fabric_attachment_receiver, Middleman, Length}) -> + fabric_doc_atts:receiver_callback(Middleman, Length); make_att_reader(Else) -> Else. |