AbstractProcess
abstract class AbstractProcess implements ProcessInterface
Properties
| string | $name | ||
| int | $processCount | ||
| bool | $redirectStdinStdout | ||
| int | $pipeType | ||
| bool | $enableCoroutine | ||
| protected Dispatcher|null | $event | ||
| protected Process|null | $process | ||
| protected int | $receiveLength | ||
| protected float | $receiveTimeout | ||
| protected int | $restartInterval |
Methods
bool
isEnabled(Server $server)
Determine if the process should start.
void
bind(Server $server)
Create process objects and bind them to the server.
Socket|false
getListenSocket()
Get the socket for the IPC pipe listener.
void
Details
at line 50
__construct(Container $container)
No description
at line 60
bool
isEnabled(Server $server)
Determine if the process should start.
at line 68
void
bind(Server $server)
Create process objects and bind them to the server.
at line 154
protected void
listen(Channel $quit)
Listen for data from worker/task processes via IPC pipe.
at line 221
protected Socket|false
getListenSocket()
Get the socket for the IPC pipe listener.
at line 229
protected void
logThrowable(Throwable $throwable)
Log a throwable via the exception handler.