couchdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fdman...@apache.org
Subject svn commit: r1163005 - /couchdb/trunk/src/couchdb/couch_replicator.erl
Date Mon, 29 Aug 2011 21:08:36 GMT
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.



Mime
View raw message