Fixed shared memory writing and fork losing received messages

kriswallsmith · Mar 17, 2016 · b01c68f · b01c68f
1 parent 530fcf5
commit b01c68f
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/Spork/Fork.php b/src/Spork/Fork.php
@@ -26,6 +26,7 @@ class Fork implements DeferredInterface
     private $name;
     private $status;
     private $message;
+    private $messages = array();
 
     public function __construct($pid, SharedMemory $shm, $debug = false)
     {
@@ -92,17 +93,15 @@ public function processWaitStatus($status)
 
     public function receive()
     {
-        $messages = array();
-
         foreach ($this->shm->receive() as $message) {
             if ($message instanceof ExitMessage) {
                 $this->message = $message;
             } else {
-                $messages[] = $message;
+                $this->messages[] = $message;
             }
         }
 
-        return $messages;
+        return $this->messages;
     }
 
     public function kill($signal = SIGINT)
@@ -135,6 +134,11 @@ public function getError()
         }
     }
 
+    public function getMessages()
+    {
+        return $this->messages;
+    }
+
     public function isSuccessful()
     {
         return 0 === $this->getExitStatus();