Thijs/wiki.techinc.nl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Lower the amount of jobs pushed into redis at once

Browse source 
This further limits how long the server can be tied up by push().

Change-Id: I02d242578dadc19912c9fccfdcf5e15c5eb78e9e
This commit is contained in:
Aaron Schulz 2017-04-19 15:38:32 -07:00
parent edda29d73a
commit 0b58cdc7f2
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
includes/jobqueue/JobQueueRedis.php
View file

@ -75,6 +75,8 @@ class JobQueueRedis extends JobQueue {
/** @var string Compression method to use */
protected $compression;
const MAX_PUSH_SIZE = 25; // avoid tying up the server
/**
* @param array $params Possible keys:
* - redisConfig : An array of parameters to RedisConnectionPool::__construct().
@ -212,7 +214,7 @@ class JobQueueRedis extends JobQueue {
if ( $flags & self::QOS_ATOMIC ) {
$batches = [ $items ]; // all or nothing
} else {
$batches = array_chunk( $items, 100 ); // avoid tying up the server
$batches = array_chunk( $items, self::MAX_PUSH_SIZE );
}
$failed = 0;
$pushed = 0;