def __init__(self, core):
self._address = os.environ.get('NOTIFY_SOCKET', None)
if self._address[0] == "@":
self._address = '\0' + self._address[1:]
self._socket = socket.socket(socket.AF_UNIX,
socket.SOCK_DGRAM | socket.SOCK_CLOEXEC)
self._watchdog_task = core.scheduler(self._watchdog, 5000,
single=False)
self._watchdog_task.enable(instant=True)
self._start_task = core.scheduler(self._start, 0, single=True)
self._core = core
评论列表
文章目录