Author: fdmanana Date: Mon Aug 29 21:08:36 2011 New Revision: 1163005 URL: http://svn.apache.org/viewvc?rev=1163005&view=rev Log: Add byte size limit to work queue
Modified: couchdb/trunk/src/couchdb/couch_replicator.erl Modified: couchdb/trunk/src/couchdb/couch_replicator.erl URL: http://svn.apache.org/viewvc/couchdb/trunk/src/couchdb/couch_replicator.erl?rev=1163005&r1=1163004&r2=1163005&view=diff ============================================================================== --- couchdb/trunk/src/couchdb/couch_replicator.erl (original) +++ couchdb/trunk/src/couchdb/couch_replicator.erl Mon Aug 29 21:08:36 2011 @@ -219,7 +219,8 @@ do_init(#rep{options = Options, id = {Ba NumWorkers = get_value(worker_processes, Options), BatchSize = get_value(worker_batch_size, Options), {ok, ChangesQueue} = couch_work_queue:new([ - {max_items, trunc(BatchSize * NumWorkers * 2.0)} + {max_items, BatchSize * NumWorkers * 2}, + {max_size, 100 * 1024 * NumWorkers} ]), % This starts the _changes reader process. It adds the changes from % the source db to the ChangesQueue.