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

__construct(Container $container)

No description

bool
isEnabled(Server $server)

Determine if the process should start.

void
bind(Server $server)

Create process objects and bind them to the server.

void
listen(Channel $quit)

Listen for data from worker/task processes via IPC pipe.

Socket|false
getListenSocket()

Get the socket for the IPC pipe listener.

void
logThrowable(Throwable $throwable)

Log a throwable via the exception handler.

Details

at line 50
__construct(Container $container)

No description

Parameters

Container $container

at line 60
bool isEnabled(Server $server)

Determine if the process should start.

Parameters

Server $server

Return Value

bool

at line 68
void bind(Server $server)

Create process objects and bind them to the server.

Parameters

Server $server

Return Value

void

at line 154
protected void listen(Channel $quit)

Listen for data from worker/task processes via IPC pipe.

Parameters

Channel $quit

Return Value

void

at line 221
protected Socket|false getListenSocket()

Get the socket for the IPC pipe listener.

Return Value

Socket|false

at line 229
protected void logThrowable(Throwable $throwable)

Log a throwable via the exception handler.

Parameters

Throwable $throwable

Return Value

void