PHPSocialNetwork / phpfastcache

examples/files.php

Indentation +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
 
 // Setup File Path on your config files
 CacheManager::setup(array(
-   // "path" => sys_get_temp_dir(), // or in windows "C:/tmp/"
+    // "path" => sys_get_temp_dir(), // or in windows "C:/tmp/"
 ));
 // our unique method of caching, faster than traditional caching which shared everywhere on internet like 7-10 times
 // reduce high load CPU, reduce I/O from files open

examples/autoload.Problem.And.Legacy.php

Indentation +1 added lines, -1 removed lines

@@ -7,7 +7,7 @@
      * All you need is put this line on your config.
      */
 
-     // In your Setting / Config.php or Index.php
+        // In your Setting / Config.php or Index.php
     define("PHPFASTCACHE_LEGACY",true);
 
     // If you use composer, then it auto included our "src/phpFastCache/phpFastCache.php" on vendor folder already, you don't need to do anything else

examples/legacy_examples/2.example.php

Indentation +3 added lines, -3 removed lines

@@ -6,12 +6,12 @@
  * @author Khoa Bui (khoaofgod)  <khoaofgod@gmail.com> http://www.phpfastcache.com
  */
 
-	// In your config files
+    // In your config files
 require_once("../../src/autoload.php");
 
-	// now it's time to call the cache "anywhere" on your project
+    // now it's time to call the cache "anywhere" on your project
 
-	$cache = phpFastCache("redis");
+    $cache = phpFastCache("redis");
 
 if ($cache->fallback === true) {
     echo " USE BACK UP DRIVER = " . phpFastCache::$config[ 'fallback' ] . " <br>";

examples/legacy_examples/readme_legacy.php

Indentation +19 added lines, -19 removed lines

@@ -1,38 +1,38 @@
 <?php
 
-	/*
+    /*
 	 * For Legacy Coding
 	 * You can do require_once ("phpFastCache/phpFastCache.php");
 	 * and call it right away
 	 */
 
-	// In your config files
+    // In your config files
 require_once("../../src/autoload.php");
 
-	// now it's time to call the cache "anywhere" on your project
+    // now it's time to call the cache "anywhere" on your project
 
-	$cache = phpFastCache();
-	/* phpFastCache support more drivers
+    $cache = phpFastCache();
+    /* phpFastCache support more drivers
 	$files_cache = phpFastCache("files");
 	$memcache_cache = phpFastCache("memcache");
 	*/
 
-	/**
-	 * Try to get $products from Caching First
-	 * product_page is "identity keyword";
-	 */
-	$key = "product_page";
-	$CachedString = $cache->get($key);
+    /**
+     * Try to get $products from Caching First
+     * product_page is "identity keyword";
+     */
+    $key = "product_page";
+    $CachedString = $cache->get($key);
 
-	if (is_null($CachedString)) {
-		$CachedString = "Files Cache --> Cache Enabled --> Well done !";
-		// Write products to Cache in 10 minutes with same keyword
-		$InstanceCache->set($key, $CachedString, 600);
+    if (is_null($CachedString)) {
+        $CachedString = "Files Cache --> Cache Enabled --> Well done !";
+        // Write products to Cache in 10 minutes with same keyword
+        $InstanceCache->set($key, $CachedString, 600);
 
-		echo "Files Cache --> Cached not enabled --> Reload page !";
+        echo "Files Cache --> Cached not enabled --> Reload page !";
 
-	} else {
-		echo $CachedString;
-	}
+    } else {
+        echo $CachedString;
+    }
 
 

examples/legacy_examples/3.setup.php

Indentation +13 added lines, -13 removed lines

@@ -11,8 +11,8 @@ 
  */
 
 $config = array(
-  "storage" => "auto", // auto, files, sqlite, apc, cookie, memcache, memcached, predis, redis, wincache, xcache
-  "default_chmod" => 0777, // For security, please use 0666 for module and 0644 for cgi.
+    "storage" => "auto", // auto, files, sqlite, apc, cookie, memcache, memcached, predis, redis, wincache, xcache
+    "default_chmod" => 0777, // For security, please use 0666 for module and 0644 for cgi.
 
 
     /*
@@ -22,35 +22,35 @@ 
     // create .htaccess to protect cache folder
     // By default the cache folder will try to create itself outside your public_html.
     // However an htaccess also created in case.
-  "htaccess" => true,
+    "htaccess" => true,
 
     // path to cache folder, leave it blank for auto detect
-  "path" => "",
-  "securityKey" => "auto", // auto will use domain name, set it to 1 string if you use alias domain name
+    "path" => "",
+    "securityKey" => "auto", // auto will use domain name, set it to 1 string if you use alias domain name
 
     // MEMCACHE
 
-  "memcache" => array(
+    "memcache" => array(
     array("127.0.0.1", 11211, 1),
-      //  array("new.host.ip",11211,1),
-  ),
+        //  array("new.host.ip",11211,1),
+    ),
 
     // REDIS
-  "redis" => array(
+    "redis" => array(
     "host" => "127.0.0.1",
     "port" => "",
     "password" => "",
     "database" => "",
     "timeout" => "",
-  ),
+    ),
 
-  "extensions" => array(),
+    "extensions" => array(),
 
 
     /*
      * Fall back when old driver is not support
      */
-  "fallback" => "files",
+    "fallback" => "files",
 );
 
 phpFastCache::setup($config);
@@ -77,6 +77,6 @@ 
 
 $cache2 = CacheManager::getInstance("memcache"); // this will use memcache
 $server = array(
-  array("127.0.0.1", 11211, 1),
+    array("127.0.0.1", 11211, 1),
 );
 $cache2->setup("memcache", $server);
\ No newline at end of file

examples/legacy_examples/5.functions.php

Indentation +8 added lines, -8 removed lines

@@ -44,26 +44,26 @@
 $list = $cache->getInfoMulti(array("key1", "key2", "key3"));
 
 $cache->setMulti(array("key1", "value1", 300),
-  array("key2", "value2", 600),
-  array("key3", "value3", 1800));
+    array("key2", "value2", 600),
+    array("key3", "value3", 1800));
 
 $cache->deleteMulti(array("key1", "key2", "key3"));
 
 $cache->isExistingMulti(array("key1", "key2", "key3"));
 
 $cache->touchMulti(array(
-  array("key", 300),
-  array("key2", 400),
+    array("key", 300),
+    array("key2", 400),
 ));
 
 $cache->incrementMulti(array(
-  array("key", 1),
-  array("key2", 2),
+    array("key", 1),
+    array("key2", 2),
 ));
 
 $cache->decrementMulti(array(
-  array("key", 1),
-  array("key2", 2),
+    array("key", 1),
+    array("key2", 2),
 ));
 
 

src/phpFastCache/_extensions/SSDB.php

Indentation +541 added lines, -541 removed lines

@@ -19,558 +19,558 @@
  */
 class SimpleSSDB extends SSDB
 {
-	function __construct($host, $port, $timeout_ms=2000){
-		parent::__construct($host, $port, $timeout_ms);
-		$this->easy();
-	}
+    function __construct($host, $port, $timeout_ms=2000){
+        parent::__construct($host, $port, $timeout_ms);
+        $this->easy();
+    }
 }
 class SSDB_Response
 {
-	public $cmd;
-	public $code;
-	public $data = null;
-	public $message;
-	function __construct($code='ok', $data_or_message=null){
-		$this->code = $code;
-		if($code == 'ok'){
-			$this->data = $data_or_message;
-		}else{
-			$this->message = $data_or_message;
-		}
-	}
-	function __toString(){
-		if($this->code == 'ok'){
-			$s = $this->data === null? '' : json_encode($this->data);
-		}else{
-			$s = $this->message;
-		}
-		return sprintf('%-13s %12s %s', $this->cmd, $this->code, $s);
-	}
-	function ok(){
-		return $this->code == 'ok';
-	}
-	function not_found(){
-		return $this->code == 'not_found';
-	}
+    public $cmd;
+    public $code;
+    public $data = null;
+    public $message;
+    function __construct($code='ok', $data_or_message=null){
+        $this->code = $code;
+        if($code == 'ok'){
+            $this->data = $data_or_message;
+        }else{
+            $this->message = $data_or_message;
+        }
+    }
+    function __toString(){
+        if($this->code == 'ok'){
+            $s = $this->data === null? '' : json_encode($this->data);
+        }else{
+            $s = $this->message;
+        }
+        return sprintf('%-13s %12s %s', $this->cmd, $this->code, $s);
+    }
+    function ok(){
+        return $this->code == 'ok';
+    }
+    function not_found(){
+        return $this->code == 'not_found';
+    }
 }
 class SSDB
 {
-	private $debug = false;
-	public $sock = null;
-	private $_closed = false;
-	private $recv_buf = '';
-	private $_easy = false;
-	public $last_resp = null;
-	function __construct($host, $port, $timeout_ms=2000){
-		$timeout_f = (float)$timeout_ms/1000;
-		$this->sock = @stream_socket_client("$host:$port", $errno, $errstr, $timeout_f);
-		if(!$this->sock){
-			throw new SSDBException("$errno: $errstr");
-		}
-		$timeout_sec = intval($timeout_ms/1000);
-		$timeout_usec = ($timeout_ms - $timeout_sec * 1000) * 1000;
-		@stream_set_timeout($this->sock, $timeout_sec, $timeout_usec);
-		if(function_exists('stream_set_chunk_size')){
-			@stream_set_chunk_size($this->sock, 1024 * 1024);
-		}
-	}
+    private $debug = false;
+    public $sock = null;
+    private $_closed = false;
+    private $recv_buf = '';
+    private $_easy = false;
+    public $last_resp = null;
+    function __construct($host, $port, $timeout_ms=2000){
+        $timeout_f = (float)$timeout_ms/1000;
+        $this->sock = @stream_socket_client("$host:$port", $errno, $errstr, $timeout_f);
+        if(!$this->sock){
+            throw new SSDBException("$errno: $errstr");
+        }
+        $timeout_sec = intval($timeout_ms/1000);
+        $timeout_usec = ($timeout_ms - $timeout_sec * 1000) * 1000;
+        @stream_set_timeout($this->sock, $timeout_sec, $timeout_usec);
+        if(function_exists('stream_set_chunk_size')){
+            @stream_set_chunk_size($this->sock, 1024 * 1024);
+        }
+    }
 	
-	function set_timeout($timeout_ms){
-		$timeout_sec = intval($timeout_ms/1000);
-		$timeout_usec = ($timeout_ms - $timeout_sec * 1000) * 1000;
-		@stream_set_timeout($this->sock, $timeout_sec, $timeout_usec);
-	}
+    function set_timeout($timeout_ms){
+        $timeout_sec = intval($timeout_ms/1000);
+        $timeout_usec = ($timeout_ms - $timeout_sec * 1000) * 1000;
+        @stream_set_timeout($this->sock, $timeout_sec, $timeout_usec);
+    }
 	
-	/**
-	 * After this method invoked with yesno=true, all requesting methods
-	 * will not return a SSDB_Response object.
-	 * And some certain methods like get/zget will return false
-	 * when response is not ok(not_found, etc)
-	 */
-	function easy(){
-		$this->_easy = true;
-	}
-	function close(){
-		if(!$this->_closed){
-			@fclose($this->sock);
-			$this->_closed = true;
-			$this->sock = null;
-		}
-	}
-	function closed(){
-		return $this->_closed;
-	}
-	private $batch_mode = false;
-	private $batch_cmds = array();
-	function batch(){
-		$this->batch_mode = true;
-		$this->batch_cmds = array();
-		return $this;
-	}
-	function multi(){
-		return $this->batch();
-	}
-	function exec(){
-		$ret = array();
-		foreach($this->batch_cmds as $op){
-			list($cmd, $params) = $op;
-			$this->send_req($cmd, $params);
-		}
-		foreach($this->batch_cmds as $op){
-			list($cmd, $params) = $op;
-			$resp = $this->recv_resp($cmd, $params);
-			$resp = $this->check_easy_resp($cmd, $resp);
-			$ret[] = $resp;
-		}
-		$this->batch_mode = false;
-		$this->batch_cmds = array();
-		return $ret;
-	}
+    /**
+     * After this method invoked with yesno=true, all requesting methods
+     * will not return a SSDB_Response object.
+     * And some certain methods like get/zget will return false
+     * when response is not ok(not_found, etc)
+     */
+    function easy(){
+        $this->_easy = true;
+    }
+    function close(){
+        if(!$this->_closed){
+            @fclose($this->sock);
+            $this->_closed = true;
+            $this->sock = null;
+        }
+    }
+    function closed(){
+        return $this->_closed;
+    }
+    private $batch_mode = false;
+    private $batch_cmds = array();
+    function batch(){
+        $this->batch_mode = true;
+        $this->batch_cmds = array();
+        return $this;
+    }
+    function multi(){
+        return $this->batch();
+    }
+    function exec(){
+        $ret = array();
+        foreach($this->batch_cmds as $op){
+            list($cmd, $params) = $op;
+            $this->send_req($cmd, $params);
+        }
+        foreach($this->batch_cmds as $op){
+            list($cmd, $params) = $op;
+            $resp = $this->recv_resp($cmd, $params);
+            $resp = $this->check_easy_resp($cmd, $resp);
+            $ret[] = $resp;
+        }
+        $this->batch_mode = false;
+        $this->batch_cmds = array();
+        return $ret;
+    }
 	
-	function request(){
-		$args = func_get_args();
-		$cmd = array_shift($args);
-		return $this->__call($cmd, $args);
-	}
+    function request(){
+        $args = func_get_args();
+        $cmd = array_shift($args);
+        return $this->__call($cmd, $args);
+    }
 	
-	private $async_auth_password = null;
+    private $async_auth_password = null;
 	
-	function auth($password){
-		$this->async_auth_password = $password;
-		return null;
-	}
-	function __call($cmd, $params=array()){
-		$cmd = strtolower($cmd);
-		if($this->async_auth_password !== null){
-			$pass = $this->async_auth_password;
-			$this->async_auth_password = null;
-			$auth = $this->__call('auth', array($pass));
-			if($auth !== true){
-				throw new Exception("Authentication failed");
-			}
-		}
-		if($this->batch_mode){
-			$this->batch_cmds[] = array($cmd, $params);
-			return $this;
-		}
-		try{
-			if($this->send_req($cmd, $params) === false){
-				$resp = new SSDB_Response('error', 'send error');
-			}else{
-				$resp = $this->recv_resp($cmd, $params);
-			}
-		}catch(SSDBException $e){
-			if($this->_easy){
-				throw $e;
-			}else{
-				$resp = new SSDB_Response('error', $e->getMessage());
-			}
-		}
-		if($resp->code == 'noauth'){
-			$msg = $resp->message;
-			throw new Exception($msg);
-		}
+    function auth($password){
+        $this->async_auth_password = $password;
+        return null;
+    }
+    function __call($cmd, $params=array()){
+        $cmd = strtolower($cmd);
+        if($this->async_auth_password !== null){
+            $pass = $this->async_auth_password;
+            $this->async_auth_password = null;
+            $auth = $this->__call('auth', array($pass));
+            if($auth !== true){
+                throw new Exception("Authentication failed");
+            }
+        }
+        if($this->batch_mode){
+            $this->batch_cmds[] = array($cmd, $params);
+            return $this;
+        }
+        try{
+            if($this->send_req($cmd, $params) === false){
+                $resp = new SSDB_Response('error', 'send error');
+            }else{
+                $resp = $this->recv_resp($cmd, $params);
+            }
+        }catch(SSDBException $e){
+            if($this->_easy){
+                throw $e;
+            }else{
+                $resp = new SSDB_Response('error', $e->getMessage());
+            }
+        }
+        if($resp->code == 'noauth'){
+            $msg = $resp->message;
+            throw new Exception($msg);
+        }
 		
-		$resp = $this->check_easy_resp($cmd, $resp);
-		return $resp;
-	}
-	private function check_easy_resp($cmd, $resp){
-		$this->last_resp = $resp;
-		if($this->_easy){
-			if($resp->not_found()){
-				return NULL;
-			}else if(!$resp->ok() && !is_array($resp->data)){
-				return false;
-			}else{
-				return $resp->data;
-			}
-		}else{
-			$resp->cmd = $cmd;
-			return $resp;
-		}
-	}
-	function multi_set($kvs=array()){
-		$args = array();
-		foreach($kvs as $k=>$v){
-			$args[] = $k;
-			$args[] = $v;
-		}
-		return $this->__call(__FUNCTION__, $args);
-	}
-	function multi_hset($name, $kvs=array()){
-		$args = array($name);
-		foreach($kvs as $k=>$v){
-			$args[] = $k;
-			$args[] = $v;
-		}
-		return $this->__call(__FUNCTION__, $args);
-	}
-	function multi_zset($name, $kvs=array()){
-		$args = array($name);
-		foreach($kvs as $k=>$v){
-			$args[] = $k;
-			$args[] = $v;
-		}
-		return $this->__call(__FUNCTION__, $args);
-	}
-	function incr($key, $val=1){
-		$args = func_get_args();
-		return $this->__call(__FUNCTION__, $args);
-	}
-	function decr($key, $val=1){
-		$args = func_get_args();
-		return $this->__call(__FUNCTION__, $args);
-	}
-	function zincr($name, $key, $score=1){
-		$args = func_get_args();
-		return $this->__call(__FUNCTION__, $args);
-	}
-	function zdecr($name, $key, $score=1){
-		$args = func_get_args();
-		return $this->__call(__FUNCTION__, $args);
-	}
-	function zadd($key, $score, $value){
-		$args = array($key, $value, $score);
-		return $this->__call('zset', $args);
-	}
-	function zRevRank($name, $key){
-		$args = func_get_args();
-		return $this->__call("zrrank", $args);
-	}
-	function zRevRange($name, $offset, $limit){
-		$args = func_get_args();
-		return $this->__call("zrrange", $args);
-	}
-	function hincr($name, $key, $val=1){
-		$args = func_get_args();
-		return $this->__call(__FUNCTION__, $args);
-	}
-	function hdecr($name, $key, $val=1){
-		$args = func_get_args();
-		return $this->__call(__FUNCTION__, $args);
-	}
-	private function send_req($cmd, $params){
-		$req = array($cmd);
-		foreach($params as $p){
-			if(is_array($p)){
-				$req = array_merge($req, $p);
-			}else{
-				$req[] = $p;
-			}
-		}
-		return $this->send($req);
-	}
-	private function recv_resp($cmd, $params){
-		$resp = $this->recv();
-		if($resp === false){
-			return new SSDB_Response('error', 'Unknown error');
-		}else if(!$resp){
-			return new SSDB_Response('disconnected', 'Connection closed');
-		}
-		if($resp[0] == 'noauth'){
-			$errmsg = isset($resp[1])? $resp[1] : '';
-			return new SSDB_Response($resp[0], $errmsg);
-		}
-		switch($cmd){
-			case 'dbsize':
-			case 'ping':
-			case 'qset':
-			case 'getbit':
-			case 'setbit':
-			case 'countbit':
-			case 'strlen':
-			case 'set':
-			case 'setx':
-			case 'setnx':
-			case 'zset':
-			case 'hset':
-			case 'qpush':
-			case 'qpush_front':
-			case 'qpush_back':
-			case 'qtrim_front':
-			case 'qtrim_back':
-			case 'del':
-			case 'zdel':
-			case 'hdel':
-			case 'hsize':
-			case 'zsize':
-			case 'qsize':
-			case 'hclear':
-			case 'zclear':
-			case 'qclear':
-			case 'multi_set':
-			case 'multi_del':
-			case 'multi_hset':
-			case 'multi_hdel':
-			case 'multi_zset':
-			case 'multi_zdel':
-			case 'incr':
-			case 'decr':
-			case 'zincr':
-			case 'zdecr':
-			case 'hincr':
-			case 'hdecr':
-			case 'zget':
-			case 'zrank':
-			case 'zrrank':
-			case 'zcount':
-			case 'zsum':
-			case 'zremrangebyrank':
-			case 'zremrangebyscore':
-			case 'ttl':
-			case 'expire':
-				if($resp[0] == 'ok'){
-					$val = isset($resp[1])? intval($resp[1]) : 0;
-					return new SSDB_Response($resp[0], $val);
-				}else{
-					$errmsg = isset($resp[1])? $resp[1] : '';
-					return new SSDB_Response($resp[0], $errmsg);
-				}
-			case 'zavg':
-				if($resp[0] == 'ok'){
-					$val = isset($resp[1])? floatval($resp[1]) : (float)0;
-					return new SSDB_Response($resp[0], $val);
-				}else{
-					$errmsg = isset($resp[1])? $resp[1] : '';
-					return new SSDB_Response($resp[0], $errmsg);
-				}
-			case 'get':
-			case 'substr':
-			case 'getset':
-			case 'hget':
-			case 'qget':
-			case 'qfront':
-			case 'qback':
-				if($resp[0] == 'ok'){
-					if(count($resp) == 2){
-						return new SSDB_Response('ok', $resp[1]);
-					}else{
-						return new SSDB_Response('server_error', 'Invalid response');
-					}
-				}else{
-					$errmsg = isset($resp[1])? $resp[1] : '';
-					return new SSDB_Response($resp[0], $errmsg);
-				}
-				break;
-			case 'qpop':
-			case 'qpop_front':
-			case 'qpop_back':
-				if($resp[0] == 'ok'){
-					$size = 1;
-					if(isset($params[1])){
-						$size = intval($params[1]);
-					}
-					if($size <= 1){
-						if(count($resp) == 2){
-							return new SSDB_Response('ok', $resp[1]);
-						}else{
-							return new SSDB_Response('server_error', 'Invalid response');
-						}
-					}else{
-						$data = array_slice($resp, 1);
-						return new SSDB_Response('ok', $data);
-					}
-				}else{
-					$errmsg = isset($resp[1])? $resp[1] : '';
-					return new SSDB_Response($resp[0], $errmsg);
-				}
-				break;
-			case 'keys':
-			case 'zkeys':
-			case 'hkeys':
-			case 'hlist':
-			case 'zlist':
-			case 'qslice':
-				if($resp[0] == 'ok'){
-					$data = array();
-					if($resp[0] == 'ok'){
-						$data = array_slice($resp, 1);
-					}
-					return new SSDB_Response($resp[0], $data);
-				}else{
-					$errmsg = isset($resp[1])? $resp[1] : '';
-					return new SSDB_Response($resp[0], $errmsg);
-				}
-			case 'auth':
-			case 'exists':
-			case 'hexists':
-			case 'zexists':
-				if($resp[0] == 'ok'){
-					if(count($resp) == 2){
-						return new SSDB_Response('ok', (bool)$resp[1]);
-					}else{
-						return new SSDB_Response('server_error', 'Invalid response');
-					}
-				}else{
-					$errmsg = isset($resp[1])? $resp[1] : '';
-					return new SSDB_Response($resp[0], $errmsg);
-				}
-				break;
-			case 'multi_exists':
-			case 'multi_hexists':
-			case 'multi_zexists':
-				if($resp[0] == 'ok'){
-					if(count($resp) % 2 == 1){
-						$data = array();
-						for($i=1; $i<count($resp); $i+=2){
-							$data[$resp[$i]] = (bool)$resp[$i + 1];
-						}
-						return new SSDB_Response('ok', $data);
-					}else{
-						return new SSDB_Response('server_error', 'Invalid response');
-					}
-				}else{
-					$errmsg = isset($resp[1])? $resp[1] : '';
-					return new SSDB_Response($resp[0], $errmsg);
-				}
-				break;
-			case 'scan':
-			case 'rscan':
-			case 'zscan':
-			case 'zrscan':
-			case 'zrange':
-			case 'zrrange':
-			case 'hscan':
-			case 'hrscan':
-			case 'hgetall':
-			case 'multi_hsize':
-			case 'multi_zsize':
-			case 'multi_get':
-			case 'multi_hget':
-			case 'multi_zget':
-			case 'zpop_front':
-			case 'zpop_back':
-				if($resp[0] == 'ok'){
-					if(count($resp) % 2 == 1){
-						$data = array();
-						for($i=1; $i<count($resp); $i+=2){
-							if($cmd[0] == 'z'){
-								$data[$resp[$i]] = intval($resp[$i + 1]);
-							}else{
-								$data[$resp[$i]] = $resp[$i + 1];
-							}
-						}
-						return new SSDB_Response('ok', $data);
-					}else{
-						return new SSDB_Response('server_error', 'Invalid response');
-					}
-				}else{
-					$errmsg = isset($resp[1])? $resp[1] : '';
-					return new SSDB_Response($resp[0], $errmsg);
-				}
-				break;
-			default:
-				return new SSDB_Response($resp[0], array_slice($resp, 1));
-		}
-		return new SSDB_Response('error', 'Unknown command: $cmd');
-	}
-	private function send($data){
-		$ps = array();
-		foreach($data as $p){
-			$ps[] = strlen($p);
-			$ps[] = $p;
-		}
-		$s = join("\n", $ps) . "\n\n";
-		if($this->debug){
-			echo '> ' . str_replace(array("\r", "\n"), array('\r', '\n'), $s) . "\n";
-		}
-		try{
-			while(true){
-				$ret = @fwrite($this->sock, $s);
-				if($ret === false || $ret === 0){
-					$this->close();
-					throw new SSDBException('Connection lost');
-				}
-				$s = substr($s, $ret);
-				if(strlen($s) == 0){
-					break;
-				}
-				@fflush($this->sock);
-			}
-		}catch(Exception $e){
-			$this->close();
-			throw new SSDBException($e->getMessage());
-		}
-		return $ret;
-	}
-	private function recv(){
-		$this->step = self::STEP_SIZE;
-		while(true){
-			$ret = $this->parse();
-			if($ret === null){
-				try{
-					$data = @fread($this->sock, 1024 * 1024);
-					if($this->debug){
-						echo '< ' . str_replace(array("\r", "\n"), array('\r', '\n'), $data) . "\n";
-					}
-				}catch(Exception $e){
-					$data = '';
-				}
-				if($data === false || $data === ''){
-					if(feof($this->sock)){
-						$this->close();
-						throw new SSDBException('Connection lost');
-					}else{
-						throw new SSDBTimeoutException('Connection timeout');
-					}
-				}
-				$this->recv_buf .= $data;
+        $resp = $this->check_easy_resp($cmd, $resp);
+        return $resp;
+    }
+    private function check_easy_resp($cmd, $resp){
+        $this->last_resp = $resp;
+        if($this->_easy){
+            if($resp->not_found()){
+                return NULL;
+            }else if(!$resp->ok() && !is_array($resp->data)){
+                return false;
+            }else{
+                return $resp->data;
+            }
+        }else{
+            $resp->cmd = $cmd;
+            return $resp;
+        }
+    }
+    function multi_set($kvs=array()){
+        $args = array();
+        foreach($kvs as $k=>$v){
+            $args[] = $k;
+            $args[] = $v;
+        }
+        return $this->__call(__FUNCTION__, $args);
+    }
+    function multi_hset($name, $kvs=array()){
+        $args = array($name);
+        foreach($kvs as $k=>$v){
+            $args[] = $k;
+            $args[] = $v;
+        }
+        return $this->__call(__FUNCTION__, $args);
+    }
+    function multi_zset($name, $kvs=array()){
+        $args = array($name);
+        foreach($kvs as $k=>$v){
+            $args[] = $k;
+            $args[] = $v;
+        }
+        return $this->__call(__FUNCTION__, $args);
+    }
+    function incr($key, $val=1){
+        $args = func_get_args();
+        return $this->__call(__FUNCTION__, $args);
+    }
+    function decr($key, $val=1){
+        $args = func_get_args();
+        return $this->__call(__FUNCTION__, $args);
+    }
+    function zincr($name, $key, $score=1){
+        $args = func_get_args();
+        return $this->__call(__FUNCTION__, $args);
+    }
+    function zdecr($name, $key, $score=1){
+        $args = func_get_args();
+        return $this->__call(__FUNCTION__, $args);
+    }
+    function zadd($key, $score, $value){
+        $args = array($key, $value, $score);
+        return $this->__call('zset', $args);
+    }
+    function zRevRank($name, $key){
+        $args = func_get_args();
+        return $this->__call("zrrank", $args);
+    }
+    function zRevRange($name, $offset, $limit){
+        $args = func_get_args();
+        return $this->__call("zrrange", $args);
+    }
+    function hincr($name, $key, $val=1){
+        $args = func_get_args();
+        return $this->__call(__FUNCTION__, $args);
+    }
+    function hdecr($name, $key, $val=1){
+        $args = func_get_args();
+        return $this->__call(__FUNCTION__, $args);
+    }
+    private function send_req($cmd, $params){
+        $req = array($cmd);
+        foreach($params as $p){
+            if(is_array($p)){
+                $req = array_merge($req, $p);
+            }else{
+                $req[] = $p;
+            }
+        }
+        return $this->send($req);
+    }
+    private function recv_resp($cmd, $params){
+        $resp = $this->recv();
+        if($resp === false){
+            return new SSDB_Response('error', 'Unknown error');
+        }else if(!$resp){
+            return new SSDB_Response('disconnected', 'Connection closed');
+        }
+        if($resp[0] == 'noauth'){
+            $errmsg = isset($resp[1])? $resp[1] : '';
+            return new SSDB_Response($resp[0], $errmsg);
+        }
+        switch($cmd){
+            case 'dbsize':
+            case 'ping':
+            case 'qset':
+            case 'getbit':
+            case 'setbit':
+            case 'countbit':
+            case 'strlen':
+            case 'set':
+            case 'setx':
+            case 'setnx':
+            case 'zset':
+            case 'hset':
+            case 'qpush':
+            case 'qpush_front':
+            case 'qpush_back':
+            case 'qtrim_front':
+            case 'qtrim_back':
+            case 'del':
+            case 'zdel':
+            case 'hdel':
+            case 'hsize':
+            case 'zsize':
+            case 'qsize':
+            case 'hclear':
+            case 'zclear':
+            case 'qclear':
+            case 'multi_set':
+            case 'multi_del':
+            case 'multi_hset':
+            case 'multi_hdel':
+            case 'multi_zset':
+            case 'multi_zdel':
+            case 'incr':
+            case 'decr':
+            case 'zincr':
+            case 'zdecr':
+            case 'hincr':
+            case 'hdecr':
+            case 'zget':
+            case 'zrank':
+            case 'zrrank':
+            case 'zcount':
+            case 'zsum':
+            case 'zremrangebyrank':
+            case 'zremrangebyscore':
+            case 'ttl':
+            case 'expire':
+                if($resp[0] == 'ok'){
+                    $val = isset($resp[1])? intval($resp[1]) : 0;
+                    return new SSDB_Response($resp[0], $val);
+                }else{
+                    $errmsg = isset($resp[1])? $resp[1] : '';
+                    return new SSDB_Response($resp[0], $errmsg);
+                }
+            case 'zavg':
+                if($resp[0] == 'ok'){
+                    $val = isset($resp[1])? floatval($resp[1]) : (float)0;
+                    return new SSDB_Response($resp[0], $val);
+                }else{
+                    $errmsg = isset($resp[1])? $resp[1] : '';
+                    return new SSDB_Response($resp[0], $errmsg);
+                }
+            case 'get':
+            case 'substr':
+            case 'getset':
+            case 'hget':
+            case 'qget':
+            case 'qfront':
+            case 'qback':
+                if($resp[0] == 'ok'){
+                    if(count($resp) == 2){
+                        return new SSDB_Response('ok', $resp[1]);
+                    }else{
+                        return new SSDB_Response('server_error', 'Invalid response');
+                    }
+                }else{
+                    $errmsg = isset($resp[1])? $resp[1] : '';
+                    return new SSDB_Response($resp[0], $errmsg);
+                }
+                break;
+            case 'qpop':
+            case 'qpop_front':
+            case 'qpop_back':
+                if($resp[0] == 'ok'){
+                    $size = 1;
+                    if(isset($params[1])){
+                        $size = intval($params[1]);
+                    }
+                    if($size <= 1){
+                        if(count($resp) == 2){
+                            return new SSDB_Response('ok', $resp[1]);
+                        }else{
+                            return new SSDB_Response('server_error', 'Invalid response');
+                        }
+                    }else{
+                        $data = array_slice($resp, 1);
+                        return new SSDB_Response('ok', $data);
+                    }
+                }else{
+                    $errmsg = isset($resp[1])? $resp[1] : '';
+                    return new SSDB_Response($resp[0], $errmsg);
+                }
+                break;
+            case 'keys':
+            case 'zkeys':
+            case 'hkeys':
+            case 'hlist':
+            case 'zlist':
+            case 'qslice':
+                if($resp[0] == 'ok'){
+                    $data = array();
+                    if($resp[0] == 'ok'){
+                        $data = array_slice($resp, 1);
+                    }
+                    return new SSDB_Response($resp[0], $data);
+                }else{
+                    $errmsg = isset($resp[1])? $resp[1] : '';
+                    return new SSDB_Response($resp[0], $errmsg);
+                }
+            case 'auth':
+            case 'exists':
+            case 'hexists':
+            case 'zexists':
+                if($resp[0] == 'ok'){
+                    if(count($resp) == 2){
+                        return new SSDB_Response('ok', (bool)$resp[1]);
+                    }else{
+                        return new SSDB_Response('server_error', 'Invalid response');
+                    }
+                }else{
+                    $errmsg = isset($resp[1])? $resp[1] : '';
+                    return new SSDB_Response($resp[0], $errmsg);
+                }
+                break;
+            case 'multi_exists':
+            case 'multi_hexists':
+            case 'multi_zexists':
+                if($resp[0] == 'ok'){
+                    if(count($resp) % 2 == 1){
+                        $data = array();
+                        for($i=1; $i<count($resp); $i+=2){
+                            $data[$resp[$i]] = (bool)$resp[$i + 1];
+                        }
+                        return new SSDB_Response('ok', $data);
+                    }else{
+                        return new SSDB_Response('server_error', 'Invalid response');
+                    }
+                }else{
+                    $errmsg = isset($resp[1])? $resp[1] : '';
+                    return new SSDB_Response($resp[0], $errmsg);
+                }
+                break;
+            case 'scan':
+            case 'rscan':
+            case 'zscan':
+            case 'zrscan':
+            case 'zrange':
+            case 'zrrange':
+            case 'hscan':
+            case 'hrscan':
+            case 'hgetall':
+            case 'multi_hsize':
+            case 'multi_zsize':
+            case 'multi_get':
+            case 'multi_hget':
+            case 'multi_zget':
+            case 'zpop_front':
+            case 'zpop_back':
+                if($resp[0] == 'ok'){
+                    if(count($resp) % 2 == 1){
+                        $data = array();
+                        for($i=1; $i<count($resp); $i+=2){
+                            if($cmd[0] == 'z'){
+                                $data[$resp[$i]] = intval($resp[$i + 1]);
+                            }else{
+                                $data[$resp[$i]] = $resp[$i + 1];
+                            }
+                        }
+                        return new SSDB_Response('ok', $data);
+                    }else{
+                        return new SSDB_Response('server_error', 'Invalid response');
+                    }
+                }else{
+                    $errmsg = isset($resp[1])? $resp[1] : '';
+                    return new SSDB_Response($resp[0], $errmsg);
+                }
+                break;
+            default:
+                return new SSDB_Response($resp[0], array_slice($resp, 1));
+        }
+        return new SSDB_Response('error', 'Unknown command: $cmd');
+    }
+    private function send($data){
+        $ps = array();
+        foreach($data as $p){
+            $ps[] = strlen($p);
+            $ps[] = $p;
+        }
+        $s = join("\n", $ps) . "\n\n";
+        if($this->debug){
+            echo '> ' . str_replace(array("\r", "\n"), array('\r', '\n'), $s) . "\n";
+        }
+        try{
+            while(true){
+                $ret = @fwrite($this->sock, $s);
+                if($ret === false || $ret === 0){
+                    $this->close();
+                    throw new SSDBException('Connection lost');
+                }
+                $s = substr($s, $ret);
+                if(strlen($s) == 0){
+                    break;
+                }
+                @fflush($this->sock);
+            }
+        }catch(Exception $e){
+            $this->close();
+            throw new SSDBException($e->getMessage());
+        }
+        return $ret;
+    }
+    private function recv(){
+        $this->step = self::STEP_SIZE;
+        while(true){
+            $ret = $this->parse();
+            if($ret === null){
+                try{
+                    $data = @fread($this->sock, 1024 * 1024);
+                    if($this->debug){
+                        echo '< ' . str_replace(array("\r", "\n"), array('\r', '\n'), $data) . "\n";
+                    }
+                }catch(Exception $e){
+                    $data = '';
+                }
+                if($data === false || $data === ''){
+                    if(feof($this->sock)){
+                        $this->close();
+                        throw new SSDBException('Connection lost');
+                    }else{
+                        throw new SSDBTimeoutException('Connection timeout');
+                    }
+                }
+                $this->recv_buf .= $data;
 #				echo "read " . strlen($data) . " total: " . strlen($this->recv_buf) . "\n";
-			}else{
-				return $ret;
-			}
-		}
-	}
-	const STEP_SIZE = 0;
-	const STEP_DATA = 1;
-	public $resp = array();
-	public $step;
-	public $block_size;
-	private function parse(){
-		$spos = 0;
-		$epos = 0;
-		$buf_size = strlen($this->recv_buf);
-		// performance issue for large reponse
-		//$this->recv_buf = ltrim($this->recv_buf);
-		while(true){
-			$spos = $epos;
-			if($this->step === self::STEP_SIZE){
-				$epos = strpos($this->recv_buf, "\n", $spos);
-				if($epos === false){
-					break;
-				}
-				$epos += 1;
-				$line = substr($this->recv_buf, $spos, $epos - $spos);
-				$spos = $epos;
-				$line = trim($line);
-				if(strlen($line) == 0){ // head end
-					$this->recv_buf = substr($this->recv_buf, $spos);
-					$ret = $this->resp;
-					$this->resp = array();
-					return $ret;
-				}
-				$this->block_size = intval($line);
-				$this->step = self::STEP_DATA;
-			}
-			if($this->step === self::STEP_DATA){
-				$epos = $spos + $this->block_size;
-				if($epos <= $buf_size){
-					$n = strpos($this->recv_buf, "\n", $epos);
-					if($n !== false){
-						$data = substr($this->recv_buf, $spos, $epos - $spos);
-						$this->resp[] = $data;
-						$epos = $n + 1;
-						$this->step = self::STEP_SIZE;
-						continue;
-					}
-				}
-				break;
-			}
-		}
-		// packet not ready
-		if($spos > 0){
-			$this->recv_buf = substr($this->recv_buf, $spos);
-		}
-		return null;
-	}
+            }else{
+                return $ret;
+            }
+        }
+    }
+    const STEP_SIZE = 0;
+    const STEP_DATA = 1;
+    public $resp = array();
+    public $step;
+    public $block_size;
+    private function parse(){
+        $spos = 0;
+        $epos = 0;
+        $buf_size = strlen($this->recv_buf);
+        // performance issue for large reponse
+        //$this->recv_buf = ltrim($this->recv_buf);
+        while(true){
+            $spos = $epos;
+            if($this->step === self::STEP_SIZE){
+                $epos = strpos($this->recv_buf, "\n", $spos);
+                if($epos === false){
+                    break;
+                }
+                $epos += 1;
+                $line = substr($this->recv_buf, $spos, $epos - $spos);
+                $spos = $epos;
+                $line = trim($line);
+                if(strlen($line) == 0){ // head end
+                    $this->recv_buf = substr($this->recv_buf, $spos);
+                    $ret = $this->resp;
+                    $this->resp = array();
+                    return $ret;
+                }
+                $this->block_size = intval($line);
+                $this->step = self::STEP_DATA;
+            }
+            if($this->step === self::STEP_DATA){
+                $epos = $spos + $this->block_size;
+                if($epos <= $buf_size){
+                    $n = strpos($this->recv_buf, "\n", $epos);
+                    if($n !== false){
+                        $data = substr($this->recv_buf, $spos, $epos - $spos);
+                        $this->resp[] = $data;
+                        $epos = $n + 1;
+                        $this->step = self::STEP_SIZE;
+                        continue;
+                    }
+                }
+                break;
+            }
+        }
+        // packet not ready
+        if($spos > 0){
+            $this->recv_buf = substr($this->recv_buf, $spos);
+        }
+        return null;
+    }
 }
\ No newline at end of file

src/phpFastCache/_extensions/predis-1.0/examples/pubsub_consumer.php

Indentation +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
                 }
             } else {
                 echo "Received the following message from {$message->channel}:",
-                     PHP_EOL, "  {$message->payload}", PHP_EOL, PHP_EOL;
+                        PHP_EOL, "  {$message->payload}", PHP_EOL, PHP_EOL;
             }
             break;
     }

src/phpFastCache/_extensions/predis-1.0/examples/shared.php

Indentation +8 added lines, -8 removed lines

@@ -30,15 +30,15 @@
 
 $multiple_servers = array(
     array(
-       'host'     => '127.0.0.1',
-       'port'     => 6379,
-       'database' => 15,
-       'alias'    => 'first',
+        'host'     => '127.0.0.1',
+        'port'     => 6379,
+        'database' => 15,
+        'alias'    => 'first',
     ),
     array(
-       'host'     => '127.0.0.1',
-       'port'     => 6380,
-       'database' => 15,
-       'alias'    => 'second',
+        'host'     => '127.0.0.1',
+        'port'     => 6380,
+        'database' => 15,
+        'alias'    => 'second',
     ),
 );