fix #1

README.md

@@ -16,7 +16,7 @@ composer require qmegas/memcache-search
 
 Requirements
 ------------
-* PHP >= 7.0
+* PHP >= 7.1
 * Memcache server should work on unix-like system and be >= 1.4.24
 
 Usage Examples

composer.json

@@ -2,7 +2,7 @@
     "name": "qmegas/memcache-search",
     "type": "library",
     "description": "PHP library to search memcache keys",
-    "version": "0.1.2",
+    "version": "0.1.3",
     "keywords": [
         "memcache",
         "memcached",
@@ -16,7 +16,7 @@
         }
     ],
     "require": {
-        "php": ">=7.0"
+        "php": ">=7.1"
     },
     "autoload": {
         "psr-4": {

src/Exception/BusyException.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace Qmegas\Exception;
+
+class BusyException extends \Exception 
+{
+}

src/MemcacheItem.php

@@ -6,6 +6,8 @@ class MemcacheItem
 {
     private $key = '';
     private $expires = 0;
+    private $lastAccessTime = 0;
+    private $dataSize = 0;
     private $server = '';
     private $rawData = '';
 
@@ -15,6 +17,8 @@ public function __construct(string $data)
         $info = $this->parse($data);
         $this->key = urldecode($info['key']);
         $this->expires = (int)$info['exp'];
+        $this->lastAccessTime = (int)$info['la'];
+        $this->dataSize = (int)$info['size'];
     }
 
     public function setServer(string $server) 
@@ -31,6 +35,16 @@ public function getExpiration(): int
     {
         return $this->expires;
     }
+
+    public function getLastAccessTime(): int 
+    {
+        return $this->lastAccessTime;
+    }
+
+    public function getDataSize(): int 
+    {
+        return $this->dataSize;
+    }
 
     public function getServer(): string 
     {

src/MemcacheSearch.php

@@ -4,12 +4,27 @@
 
 class MemcacheSearch 
 {
+    public const ON_BUSY_IGNORE = 0;
+    public const ON_BUSY_EXCEPTION = 1;
+    public const ON_BUSY_TIMEOUT = 2;
+
     private $servers = [];
+    private $busyStrategy = self::ON_BUSY_EXCEPTION;
+    private $busyTimeout = 5;
 
     public function addServer(string $domain, int $port = 11211) 
     {
         $this->servers[] = [$domain, $port];
     }
+
+    public function onBusyStrategy(int $strategy, int $timeout = 5)
+    {
+        $this->busyStrategy = $strategy;
+
+        if ($strategy === self::ON_BUSY_TIMEOUT) {
+            $this->busyTimeout = $timeout;
+        }
+    }
 
     /**
      * @param string|callable|Finder\FinderInterface $finder
@@ -21,8 +36,9 @@ public function search($finder)
         if (is_string($finder)) {
             $finder = new Finder\Inline($finder);
         }
-
+        
         foreach ($this->servers as list($domain, $port)) {
+            $serverBusy = false;
             $fp = fsockopen($domain, $port);
             if (!$fp) {
                 throw new Exception\ConnectionException("Can not connect to {$domain}:{$port}");
@@ -34,13 +50,32 @@ public function search($finder)
             while (true) {
                 $part .= fgets($fp, 1024);
                 $lines = $this->extractLines($part);
-
+                
                 foreach ($lines as $line) {
                     $line = trim($line);
 
                     if ($line === 'END' || $line === 'ERROR' || $line === '') {
                         break 2;
+                    } elseif (substr($line, 0, 5) === 'BUSY ') {
+                        $excMessage = "Crawler busy for server {$domain}:{$port}";
+                        if ($this->busyStrategy === self::ON_BUSY_IGNORE) {
+                            break 2;
+                        } elseif ($this->busyStrategy === self::ON_BUSY_EXCEPTION) {
+                            fclose($fp);
+                            throw new Exception\BusyException($excMessage);
+                        } elseif ($this->busyStrategy === self::ON_BUSY_TIMEOUT) {
+                            if ($serverBusy) {
+                                fclose($fp);
+                                throw new Exception\BusyException("{$excMessage} after waiting {$this->busyTimeout} seconds");
+                            }
+
+                            $serverBusy = true;
+                            sleep($this->busyTimeout);
+                            continue;
+                        }
                     }
+
+                    $serverBusy = false;
 
                     $key = new MemcacheItem($line);
                     $match = is_callable($finder) ? $finder($key) : $finder->match($key);