dépôts
/
lhc
/
web
/
wiklou.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Bump and prep 1.31.6
[lhc/web/wiklou.git]
/
includes
/
jobqueue
/
JobQueueRedis.php
diff --git
a/includes/jobqueue/JobQueueRedis.php
b/includes/jobqueue/JobQueueRedis.php
index
eb91680
..
759662d
100644
(file)
--- a/
includes/jobqueue/JobQueueRedis.php
+++ b/
includes/jobqueue/JobQueueRedis.php
@@
-18,7
+18,6
@@
* http://www.gnu.org/copyleft/gpl.html
*
* @file
* http://www.gnu.org/copyleft/gpl.html
*
* @file
- * @author Aaron Schulz
*/
use Psr\Log\LoggerInterface;
*/
use Psr\Log\LoggerInterface;
@@
-133,7
+132,7
@@
class JobQueueRedis extends JobQueue {
protected function doGetSize() {
$conn = $this->getConnection();
try {
protected function doGetSize() {
$conn = $this->getConnection();
try {
- return $conn->l
Size
( $this->getQueueKey( 'l-unclaimed' ) );
+ return $conn->l
Len
( $this->getQueueKey( 'l-unclaimed' ) );
} catch ( RedisException $e ) {
$this->throwRedisException( $conn, $e );
}
} catch ( RedisException $e ) {
$this->throwRedisException( $conn, $e );
}
@@
-503,7
+502,7
@@
LUA;
$keys[] = $this->getQueueKey( $prop );
}
$keys[] = $this->getQueueKey( $prop );
}
- $ok = ( $conn->del
ete
( $keys ) !== false );
+ $ok = ( $conn->del( $keys ) !== false );
$conn->sRem( $this->getGlobalKey( 's-queuesWithJobs' ), $this->encodeQueueName() );
return $ok;
$conn->sRem( $this->getGlobalKey( 's-queuesWithJobs' ), $this->encodeQueueName() );
return $ok;
@@
-608,7
+607,7
@@
LUA;
try {
$conn->multi( Redis::PIPELINE );
foreach ( $types as $type ) {
try {
$conn->multi( Redis::PIPELINE );
foreach ( $types as $type ) {
- $conn->l
Size
( $this->getQueueKey( 'l-unclaimed', $type ) );
+ $conn->l
Len
( $this->getQueueKey( 'l-unclaimed', $type ) );
}
$res = $conn->exec();
if ( is_array( $res ) ) {
}
$res = $conn->exec();
if ( is_array( $res ) ) {