Skip to content

Commit 5151098

Browse files
committed
Fixed shared memory writing and fork losing received messages
1 parent 530fcf5 commit 5151098

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/Spork/Fork.php

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ class Fork implements DeferredInterface
2626
private $name;
2727
private $status;
2828
private $message;
29+
private $messages = array();
2930

3031
public function __construct($pid, SharedMemory $shm, $debug = false)
3132
{
@@ -92,8 +93,7 @@ public function processWaitStatus($status)
9293

9394
public function receive()
9495
{
95-
$messages = array();
96-
96+
$messages = array();
9797
foreach ($this->shm->receive() as $message) {
9898
if ($message instanceof ExitMessage) {
9999
$this->message = $message;
@@ -135,6 +135,11 @@ public function getError()
135135
}
136136
}
137137

138+
public function getMessages()
139+
{
140+
return $this->messages;
141+
}
142+
138143
public function isSuccessful()
139144
{
140145
return 0 === $this->getExitStatus();

0 commit comments

Comments
 (0)