MemcachedPhpBagOStuff.php

Go to the documentation of this file.

<?php
class MemcachedPhpBagOStuff extends MemcachedBagOStuff {
    protected $client;
 
    public function __construct( $params ) {
        parent::__construct( $params );
 
        // Default class-specific parameters
        $params += [
            'compress_threshold' => 1500,
            'connect_timeout' => 0.5
        ];
 
        $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
        return $getToken
            ? $this->client->get( $routeKey, $casToken )
            : $this->client->get( $routeKey );
    }
 
    protected function doSet( $key, $value, $exptime = 0, $flags = 0 ) {
        $routeKey = $this->validateKeyAndPrependRoute( $key );
 
        return $this->client->set( $routeKey, $value, $this->fixExpiry( $exptime ) );
    }
 
    protected function doDelete( $key, $flags = 0 ) {
        $routeKey = $this->validateKeyAndPrependRoute( $key );
 
        return $this->client->delete( $routeKey );
    }
 
    protected function doAdd( $key, $value, $exptime = 0, $flags = 0 ) {
        $routeKey = $this->validateKeyAndPrependRoute( $key );
 
        return $this->client->add( $routeKey, $value, $this->fixExpiry( $exptime ) );
    }
 
    protected function doCas( $casToken, $key, $value, $exptime = 0, $flags = 0 ) {
        $routeKey = $this->validateKeyAndPrependRoute( $key );
 
        return $this->client->cas( $casToken, $routeKey, $value, $this->fixExpiry( $exptime ) );
    }
 
    public function incr( $key, $value = 1, $flags = 0 ) {
        $routeKey = $this->validateKeyAndPrependRoute( $key );
        $n = $this->client->incr( $routeKey, $value );
 
        return ( $n !== false && $n !== null ) ? $n : false;
    }
 
    public function decr( $key, $value = 1, $flags = 0 ) {
        $routeKey = $this->validateKeyAndPrependRoute( $key );
        $n = $this->client->decr( $routeKey, $value );
 
        return ( $n !== false && $n !== null ) ? $n : false;
    }
 
    protected function doChangeTTL( $key, $exptime, $flags ) {
        $routeKey = $this->validateKeyAndPrependRoute( $key );
 
        return $this->client->touch( $routeKey, $this->fixExpiry( $exptime ) );
    }
 
    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;
        }
 
        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 );
    }
}