Lines Matching refs:self
14 def __init__(self, extra=None):
17 self._extra = extra
19 def get_extra_info(self, name, default=None):
21 return self._extra.get(name, default)
23 def is_closing(self):
27 def close(self):
37 def set_protocol(self, protocol):
41 def get_protocol(self):
51 def is_reading(self):
55 def pause_reading(self):
63 def resume_reading(self):
77 def set_write_buffer_limits(self, high=None, low=None):
98 def get_write_buffer_size(self):
102 def get_write_buffer_limits(self):
108 def write(self, data):
116 def writelines(self, list_of_data):
123 self.write(data)
125 def write_eof(self):
134 def can_write_eof(self):
138 def abort(self):
177 def sendto(self, data, addr=None):
187 def abort(self):
201 def get_pid(self):
205 def get_returncode(self):
213 def get_pipe_transport(self, fd):
217 def send_signal(self, signal):
225 def terminate(self):
239 def kill(self):
270 def __init__(self, extra=None, loop=None):
273 self._loop = loop
274 self._protocol_paused = False
275 self._set_write_buffer_limits()
277 def _maybe_pause_protocol(self):
278 size = self.get_write_buffer_size()
279 if size <= self._high_water:
281 if not self._protocol_paused:
282 self._protocol_paused = True
284 self._protocol.pause_writing()
288 self._loop.call_exception_handler({
291 'transport': self,
292 'protocol': self._protocol,
295 def _maybe_resume_protocol(self):
296 if (self._protocol_paused and
297 self.get_write_buffer_size() <= self._low_water):
298 self._protocol_paused = False
300 self._protocol.resume_writing()
304 self._loop.call_exception_handler({
307 'transport': self,
308 'protocol': self._protocol,
311 def get_write_buffer_limits(self):
312 return (self._low_water, self._high_water)
314 def _set_write_buffer_limits(self, high=None, low=None):
327 self._high_water = high
328 self._low_water = low
330 def set_write_buffer_limits(self, high=None, low=None):
331 self._set_write_buffer_limits(high=high, low=low)
332 self._maybe_pause_protocol()
334 def get_write_buffer_size(self):