blob: b654a615fb252c89ae71bde170ec40004d3de4da (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
# Copyright 1999-2009 Gentoo Foundation
# Distributed under the terms of the GNU General Public License v2
from _emerge.AsynchronousTask import AsynchronousTask
from _emerge.PollConstants import PollConstants
class AbstractPollTask(AsynchronousTask):
__slots__ = ("scheduler",) + \
("_registered",)
_bufsize = 4096
_exceptional_events = PollConstants.POLLERR | PollConstants.POLLNVAL
_registered_events = PollConstants.POLLIN | \
_exceptional_events
def _unregister(self):
raise NotImplementedError(self)
def _unregister_if_appropriate(self, event):
if self._registered:
if event & self._exceptional_events:
self._unregister()
self.cancel()
|
