Merge pull request #65 from cloudant/13311-improve-view-back-pressure Use rexi:stream/1 for view backpressure
BugzID: 13311 Project: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/repo Commit: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/commit/b73311b8 Tree: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/tree/b73311b8 Diff: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/diff/b73311b8 Branch: refs/heads/import Commit: b73311b880d010d19e8a6bf92980c5391db64de8 Parents: 37b66d3 e1eff10 Author: Adam Kocoloski <[email protected]> Authored: Tue Nov 20 06:12:41 2012 -0800 Committer: Adam Kocoloski <[email protected]> Committed: Tue Nov 20 06:12:41 2012 -0800 ---------------------------------------------------------------------- src/fabric_util.erl | 2 +- src/fabric_view.erl | 45 ++++++++------------------------------- src/fabric_view_all_docs.erl | 7 ++---- src/fabric_view_changes.erl | 4 ++-- src/fabric_view_map.erl | 9 +++----- src/fabric_view_reduce.erl | 9 +++----- 6 files changed, 20 insertions(+), 56 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/couchdb-fabric/blob/b73311b8/src/fabric_view_changes.erl ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/couchdb-fabric/blob/b73311b8/src/fabric_view_reduce.erl ---------------------------------------------------------------------- diff --cc src/fabric_view_reduce.erl index 8ef7908,4487e1d..3792adb --- a/src/fabric_view_reduce.erl +++ b/src/fabric_view_reduce.erl @@@ -34,12 -34,7 +34,11 @@@ go(DbName, DDoc, VName, Args, Callback Shard#shard{ref = Ref} end, fabric_view:get_shards(DbName, Args)), RexiMon = fabric_util:create_monitors(Workers), - BufferSize = couch_config:get("fabric", "reduce_buffer_size", "20"), #view_query_args{limit = Limit, skip = Skip} = Args, + OsProc = case os_proc_needed(RedSrc) of + true -> couch_query_servers:get_os_process(Lang); + _ -> nil + end, State = #collector{ db_name = DbName, query_args = Args,
