From 51510985f4bedb43af729ccc92076db827b7834e Mon Sep 17 00:00:00 2001
From: Alex Farcas <alex.farcas@gmail.com>
Date: Wed, 16 Mar 2016 22:00:09 +0200
Subject: [PATCH] Fixed shared memory writing and fork losing received messages

---
 src/Spork/Fork.php | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/Spork/Fork.php b/src/Spork/Fork.php
index a670b3c..ade7a84 100644
--- 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();