Fixed shared memory writing and fork losing received messages

kriswallsmith · Mar 17, 2016 · 5151098 · 5151098
1 parent 530fcf5
commit 5151098
Showing 1 changed file with 7 additions and 2 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,8 +93,7 @@ public function processWaitStatus($status)
 
     public function receive()
     {
-        $messages = array();
-
+		$messages = array();
         foreach ($this->shm->receive() as $message) {
             if ($message instanceof ExitMessage) {
                 $this->message = $message;
@@ -135,6 +135,11 @@ public function getError()
         }
     }
 
+    public function getMessages()
+    {
+        return $this->messages;
+    }
+
     public function isSuccessful()
     {
         return 0 === $this->getExitStatus();