Lines Matching refs:self
31 def __init__(self, callback, args, loop, context=None):
34 self._context = context
35 self._loop = loop
36 self._callback = callback
37 self._args = args
38 self._cancelled = False
39 self._repr = None
40 if self._loop.get_debug():
41 self._source_traceback = format_helpers.extract_stack(
44 self._source_traceback = None
46 def _repr_info(self):
47 info = [self.__class__.__name__]
48 if self._cancelled:
50 if self._callback is not None:
52 self._callback, self._args))
53 if self._source_traceback:
54 frame = self._source_traceback[-1]
58 def __repr__(self):
59 if self._repr is not None:
60 return self._repr
61 info = self._repr_info()
64 def cancel(self):
65 if not self._cancelled:
66 self._cancelled = True
67 if self._loop.get_debug():
71 self._repr = repr(self)
72 self._callback = None
73 self._args = None
75 def cancelled(self):
76 return self._cancelled
78 def _run(self):
80 self._context.run(self._callback, *self._args)
85 self._callback, self._args)
90 'handle': self,
92 if self._source_traceback:
93 context['source_traceback'] = self._source_traceback
94 self._loop.call_exception_handler(context)
95 self = None # Needed to break cycles when an exception occurs.
103 def __init__(self, when, callback, args, loop, context=None):
105 if self._source_traceback:
106 del self._source_traceback[-1]
107 self._when = when
108 self._scheduled = False
110 def _repr_info(self):
112 pos = 2 if self._cancelled else 1
113 info.insert(pos, f'when={self._when}')
116 def __hash__(self):
117 return hash(self._when)
119 def __lt__(self, other):
121 return self._when < other._when
124 def __le__(self, other):
126 return self._when < other._when or self.__eq__(other)
129 def __gt__(self, other):
131 return self._when > other._when
134 def __ge__(self, other):
136 return self._when > other._when or self.__eq__(other)
139 def __eq__(self, other):
141 return (self._when == other._when and
142 self._callback == other._callback and
143 self._args == other._args and
144 self._cancelled == other._cancelled)
147 def cancel(self):
148 if not self._cancelled:
149 self._loop._timer_handle_cancelled(self)
152 def when(self):
158 return self._when
164 def close(self):
168 def get_loop(self):
172 def is_serving(self):
176 async def start_serving(self):
184 async def serve_forever(self):
191 async def wait_closed(self):
195 async def __aenter__(self):
196 return self
198 async def __aexit__(self, *exc):
199 self.close()
200 await self.wait_closed()
208 def run_forever(self):
212 def run_until_complete(self, future):
219 def stop(self):
227 def is_running(self):
231 def is_closed(self):
235 def close(self):
246 async def shutdown_asyncgens(self):
250 async def shutdown_default_executor(self):
256 def _timer_handle_cancelled(self, handle):
260 def call_soon(self, callback, *args, context=None):
261 return self.call_later(0, callback, *args, context=context)
263 def call_later(self, delay, callback, *args, context=None):
266 def call_at(self, when, callback, *args, context=None):
269 def time(self):
272 def create_future(self):
277 def create_task(self, coro, *, name=None, context=None):
282 def call_soon_threadsafe(self, callback, *args, context=None):
285 def run_in_executor(self, executor, func, *args):
288 def set_default_executor(self, executor):
293 async def getaddrinfo(self, host, port, *,
297 async def getnameinfo(self, sockaddr, flags=0):
301 self, protocol_factory, host=None, port=None,
311 self, protocol_factory, host=None, port=None,
368 async def sendfile(self, transport, file, offset=0, count=None,
376 async def start_tls(self, transport, protocol, sslcontext, *,
389 self, protocol_factory, path=None, *,
397 self, protocol_factory, path=None, *,
433 self, protocol_factory, sock,
447 async def create_datagram_endpoint(self, protocol_factory,
484 async def connect_read_pipe(self, protocol_factory, pipe):
497 async def connect_write_pipe(self, protocol_factory, pipe):
510 async def subprocess_shell(self, protocol_factory, cmd, *,
517 async def subprocess_exec(self, protocol_factory, *args,
529 def add_reader(self, fd, callback, *args):
532 def remove_reader(self, fd):
535 def add_writer(self, fd, callback, *args):
538 def remove_writer(self, fd):
543 async def sock_recv(self, sock, nbytes):
546 async def sock_recv_into(self, sock, buf):
549 async def sock_recvfrom(self, sock, bufsize):
552 async def sock_recvfrom_into(self, sock, buf, nbytes=0):
555 async def sock_sendall(self, sock, data):
558 async def sock_sendto(self, sock, data, address):
561 async def sock_connect(self, sock, address):
564 async def sock_accept(self, sock):
567 async def sock_sendfile(self, sock, file, offset=0, count=None,
573 def add_signal_handler(self, sig, callback, *args):
576 def remove_signal_handler(self, sig):
581 def set_task_factory(self, factory):
584 def get_task_factory(self):
589 def get_exception_handler(self):
592 def set_exception_handler(self, handler):
595 def default_exception_handler(self, context):
598 def call_exception_handler(self, context):
603 def get_debug(self):
606 def set_debug(self, enabled):
613 def get_event_loop(self):
623 def set_event_loop(self, loop):
627 def new_event_loop(self):
635 def get_child_watcher(self):
639 def set_child_watcher(self, watcher):
663 def __init__(self):
664 self._local = self._Local()
666 def get_event_loop(self):
671 if (self._local._loop is None and
672 not self._local._set_called and
674 self.set_event_loop(self.new_event_loop())
676 if self._local._loop is None:
680 return self._local._loop
682 def set_event_loop(self, loop):
684 self._local._set_called = True
687 self._local._loop = loop
689 def new_event_loop(self):
695 return self._loop_factory()