Fixed bug in MemoryLimit, the parsing was not correct, so the worker died after every check.

Modified readme

Author: dominikmank

README.md

@@ -16,7 +16,7 @@
 
 # Benutzung
 ## Client
-Beispiel Benutzung des Dispatchers
+Beispiel Benutzung des Clients
 
 ```php
 <?php
@@ -32,7 +32,7 @@ $client = new \dmank\gearman\Client($serverCollection);
 ```
 
 ### Asynchrone Abarbeitung
-Methode "executeJobInBrackground", erwartet den Methodennamen der ausgeführt werden soll sowie den Workload.
+Methode "executeInBackground", erwartet den Methodennamen der ausgeführt werden soll sowie den Workload.
 Als Rückgabe bekommt man das zugewiesene Jobhandle zurück um den Status überprüfen zu können.
 
 ### Synchrone Abarbeitung
@@ -119,4 +119,17 @@ Nach erfolgreicher Ausführung
 
 Im Fehlerfall
 
-* FunctionFailureEvent::FUNCTION_ON_FAILURE
+* FunctionFailureEvent::FUNCTION_ON_FAILURE
+
+
+### Mitgelieferte Eventsubscriber
+
+#### Monolog
+Am besten zum Debuggen oder um den Ablauf der Logik zu verfolgen.
+Der übergebene Logger wird auch an den eigentlichen Job weitergegeben sofern er "LoggerAware" ist.
+
+#### MaxRunTime
+Prüft vor Beginn und nach Ende einer Abarbeitung, sowie wenn keine Jobs vorhanden sind, ob die Maximallaufzeit des Workers erreich ist.
+
+#### MemoryLimit
+Prüft vor Beginn und nach Ender einer Abarbeitung ob die angegebene Grenze an Speicher aufgebraucht/überschritten ist. In dem Falle würde der Worker beendet werden.

src/Worker.php

@@ -5,7 +5,6 @@
 use dmank\gearman\event\FunctionEvent;
 use dmank\gearman\event\FunctionFailureEvent;
 use dmank\gearman\event\RegisterFunctionEvent;
-use dmank\gearman\event\subscriber\DefaultWorkerBehaviour;
 use dmank\gearman\event\WorkerEvent;
 use dmank\gearman\event\WorkerExceptionEvent;
 use dmank\gearman\exception\NoFunctionGiven;

src/event/subscriber/MemoryLimit.php

@@ -61,19 +61,6 @@ private function memoryLimitAlmostExceeded()
         );
     }
 
-    private function informLogger()
-    {
-        if (!is_null($this->logger)) {
-            $this->logger->notice(
-                sprintf(
-                    'Memory limit almost exceeded. Max limit is %s, used %s so far.',
-                    $this->maxMemoryLimit,
-                    round((memory_get_usage(true) * 1.2) / 1048576, 2) . 'M'
-                )
-            );
-        }
-    }
-
     /**
      * @param $value
      * @return int
@@ -85,12 +72,26 @@ private function returnBytes($value)
 
         switch ($last) {
             case 'g':
+                $value *= 1024;
             case 'm':
+                $value *= 1024;
             case 'k':
                 $value *= 1024;
-                break;
         }
 
-        return (int)$value;
+        return $value;
+    }
+
+    private function informLogger()
+    {
+        if (!is_null($this->logger)) {
+            $this->logger->notice(
+                sprintf(
+                    'Memory limit almost exceeded. Max limit is %s, used %s so far.',
+                    $this->maxMemoryLimit,
+                    round((memory_get_usage(true) * 1.2) / 1048576, 2) . 'M'
+                )
+            );
+        }
     }
 }

tests/unit/event/subscriber/MemoryLimitTest.php

@@ -20,4 +20,19 @@ public function testMemoryLimitExceededOnAfterRun()
         $workerEvent = new WorkerEvent($worker);
         $subscriber->onAfterRun($workerEvent);
     }
+
+    public function testMemoryLimitNotExceededOnAfterRun()
+    {
+        $subscriber = new MemoryLimit('10g');
+
+        $worker = $this->getMockBuilder('dmank\gearman\Worker')
+            ->disableOriginalConstructor()
+            ->getMock();
+
+        $worker->expects($this->exactly(0))
+            ->method('destroyWorker');
+
+        $workerEvent = new WorkerEvent($worker);
+        $subscriber->onAfterRun($workerEvent);
+    }
 }