| Server IP : 167.235.224.122 / Your IP : 216.73.216.110 Web Server : Apache/2.4.58 (Ubuntu) System : Linux newplayground 6.8.0-136-generic #136-Ubuntu SMP PREEMPT_DYNAMIC Wed Jul 1 21:33:11 UTC 2026 aarch64 User : deploy ( 1000) PHP Version : 8.4.23 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /var/www/html/wiki/includes/libs/objectcache/ |
Upload File : |
<?php
/**
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License along
* with this program; if not, write to the Free Software Foundation, Inc.,
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
* http://www.gnu.org/copyleft/gpl.html
*
* @file
*/
namespace Wikimedia\ObjectCache;
use MemcachedClient;
/**
* Store data on memcached servers(s) via a pure-PHP memcached client.
*
* In configuration, the CACHE_MEMCACHED will activate the MemcachedPhpBagOStuff
* class. This works out of the box without any PHP extension or other PECL
* dependencies. If you can install the php-memcached PECL extension,
* it is recommended to use MemcachedPeclBagOStuff instead.
*
* @ingroup Cache
*/
class MemcachedPhpBagOStuff extends MemcachedBagOStuff {
/** @var MemcachedClient */
protected $client;
/**
* Available parameters are:
* - servers: The list of IP:port combinations holding the memcached servers.
* - persistent: Whether to use a persistent connection
* - compress_threshold: The minimum size an object must be before it is compressed
* - timeout: The read timeout in microseconds
* - connect_timeout: The connect timeout in seconds
*
* @param array $params
*/
public function __construct( $params ) {
parent::__construct( $params );
// Default class-specific parameters
$params += [
'compress_threshold' => 1500,
'connect_timeout' => 0.5,
'timeout' => 500000,
];
$this->client = new MemcachedClient( $params );
$this->client->set_servers( $params['servers'] );
$this->client->set_debug( true );
}
protected function doGet( $key, $flags = 0, &$casToken = null ) {
$getToken = ( $casToken === self::PASS_BY_REF );
$casToken = null;
$routeKey = $this->validateKeyAndPrependRoute( $key );
// T257003: only require "gets" (instead of "get") when a CAS token is needed
$res = $getToken // @phan-suppress-next-line PhanTypeMismatchArgument False positive
? $this->client->get( $routeKey, $casToken ) : $this->client->get( $routeKey );
if ( $this->client->_last_cmd_status !== BagOStuff::ERR_NONE ) {
$this->setLastError( $this->client->_last_cmd_status );
}
return $res;
}
protected function doSet( $key, $value, $exptime = 0, $flags = 0 ) {
$routeKey = $this->validateKeyAndPrependRoute( $key );
$res = $this->client->set( $routeKey, $value, $this->fixExpiry( $exptime ) );
if ( $this->client->_last_cmd_status !== BagOStuff::ERR_NONE ) {
$this->setLastError( $this->client->_last_cmd_status );
}
return $res;
}
protected function doDelete( $key, $flags = 0 ) {
$routeKey = $this->validateKeyAndPrependRoute( $key );
$res = $this->client->delete( $routeKey );
if ( $this->client->_last_cmd_status !== BagOStuff::ERR_NONE ) {
$this->setLastError( $this->client->_last_cmd_status );
}
return $res;
}
protected function doAdd( $key, $value, $exptime = 0, $flags = 0 ) {
$routeKey = $this->validateKeyAndPrependRoute( $key );
$res = $this->client->add( $routeKey, $value, $this->fixExpiry( $exptime ) );
if ( $this->client->_last_cmd_status !== BagOStuff::ERR_NONE ) {
$this->setLastError( $this->client->_last_cmd_status );
}
return $res;
}
protected function doCas( $casToken, $key, $value, $exptime = 0, $flags = 0 ) {
$routeKey = $this->validateKeyAndPrependRoute( $key );
$res = $this->client->cas( $casToken, $routeKey, $value, $this->fixExpiry( $exptime ) );
if ( $this->client->_last_cmd_status !== BagOStuff::ERR_NONE ) {
$this->setLastError( $this->client->_last_cmd_status );
}
return $res;
}
protected function doIncrWithInitAsync( $key, $exptime, $step, $init ) {
$routeKey = $this->validateKeyAndPrependRoute( $key );
$watchPoint = $this->watchErrors();
$this->client->add( $routeKey, $init - $step, $this->fixExpiry( $exptime ) );
$this->client->incr( $routeKey, $step );
return !$this->getLastError( $watchPoint );
}
protected function doIncrWithInitSync( $key, $exptime, $step, $init ) {
$routeKey = $this->validateKeyAndPrependRoute( $key );
$watchPoint = $this->watchErrors();
$newValue = $this->client->incr( $routeKey, $step ) ?? false;
if ( $newValue === false && !$this->getLastError( $watchPoint ) ) {
// No key set; initialize
$success = $this->client->add( $routeKey, $init, $this->fixExpiry( $exptime ) );
$newValue = $success ? $init : false;
if ( $newValue === false && !$this->getLastError( $watchPoint ) ) {
// Raced out initializing; increment
$newValue = $this->client->incr( $routeKey, $step ) ?? false;
}
}
return $newValue;
}
protected function doChangeTTL( $key, $exptime, $flags ) {
$routeKey = $this->validateKeyAndPrependRoute( $key );
$res = $this->client->touch( $routeKey, $this->fixExpiry( $exptime ) );
if ( $this->client->_last_cmd_status !== BagOStuff::ERR_NONE ) {
$this->setLastError( $this->client->_last_cmd_status );
}
return $res;
}
protected function doGetMulti( array $keys, $flags = 0 ) {
$routeKeys = [];
foreach ( $keys as $key ) {
$routeKeys[] = $this->validateKeyAndPrependRoute( $key );
}
$resByRouteKey = $this->client->get_multi( $routeKeys );
$res = [];
foreach ( $resByRouteKey as $routeKey => $value ) {
$res[$this->stripRouteFromKey( $routeKey )] = $value;
}
if ( $this->client->_last_cmd_status !== BagOStuff::ERR_NONE ) {
$this->setLastError( $this->client->_last_cmd_status );
}
return $res;
}
protected function serialize( $value ) {
return is_int( $value ) ? $value : $this->client->serialize( $value );
}
protected function unserialize( $value ) {
return $this->isInteger( $value ) ? (int)$value : $this->client->unserialize( $value );
}
}
/** @deprecated class alias since 1.43 */
class_alias( MemcachedPhpBagOStuff::class, 'MemcachedPhpBagOStuff' );