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 51
__construct(Container $container)
No description
at line 61
bool
isEnabled(Server $server)
Determine if the process should start.
at line 72
void
bind(Server $server)
Create process objects and bind them to the server.
Swoole only accepts processes added before the server starts, and coroutine-enabled processes persist in the process-wide collector.
at line 163
protected void
listen(Channel $quit)
Listen for data from worker/task processes via IPC pipe.
at line 231
protected Socket|false
getListenSocket()
Get the socket for the IPC pipe listener.
at line 239
protected void
logThrowable(Throwable $throwable)
Log a throwable via the exception handler.