\ Sleep until PIPE is readable or we timeout. A readable PIPE means a signal occurred.

\ Stop workers :attr graceful: boolean, If True (the default) workers will be killed gracefully (ie. trying to wait for the

delete pidfile

Measure request duration request_time is a datetime.timedelta

\ Your worker subclass must arrange to have this method called once every ``self.timeout`` seconds. If you fail in accomplishing

\ Initialize the arbiter. Start listening and set pidfile if needed.

Validate pidfile and make it stale if needed

Gets atoms for log formating.

return date in Apache Common Log Format

\ Relaunch the master and workers.

\ Kill a worker :attr pid: int, worker pid :attr sig: `signal.SIG*` value

\ Maintain the number of workers by spawning or killing as required.

\ If you override this method in a subclass, the last statement in the function should be to call this method with super().ini

\ Kill all workers with the signal `sig` :attr sig: `signal.SIG*` value

\ Wake up the arbiter by writing to the PIPE

A context manager that asserts post-conditions of ``listen_fds`` at exit. This helper is used to ease checking of the test post-conditions f

Loads the configuration

Encode a HyBi style WebSocket frame. Optional opcode: 0x0 - continuation 0x1 - text frame (base64 encode buf)

Encode a HyBi style WebSocket frame. Optional opcode: 0x0 - continuation 0x1 - text frame (base64 encode buf)

Log a given statistic if metric, value and type are present

get list of all loggers