You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@couchdb.apache.org by fd...@apache.org on 2011/08/29 23:08:36 UTC

svn commit: r1163005 - /couchdb/trunk/src/couchdb/couch_replicator.erl

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.