Lines Matching refs:self
225 def __init__(self, sock=None, map=None):
227 self._map = socket_map
229 self._map = map
231 self._fileno = None
237 self.set_socket(sock, map)
238 self.connected = True
242 self.addr = sock.getpeername()
247 self.connected = False
252 self.del_channel(map)
255 self.socket = None
257 def __repr__(self):
258 status = [self.__class__.__module__+"."+self.__class__.__qualname__]
259 if self.accepting and self.addr:
261 elif self.connected:
263 if self.addr is not None:
265 status.append('%s:%d' % self.addr)
267 status.append(repr(self.addr))
268 return '<%s at %#x>' % (' '.join(status), id(self))
270 def add_channel(self, map=None):
271 #self.log_info('adding channel %s' % self)
273 map = self._map
274 map[self._fileno] = self
276 def del_channel(self, map=None):
277 fd = self._fileno
279 map = self._map
281 #self.log_info('closing channel %d:%s' % (fd, self))
283 self._fileno = None
285 def create_socket(self, family=socket.AF_INET, type=socket.SOCK_STREAM):
286 self.family_and_type = family, type
289 self.set_socket(sock)
291 def set_socket(self, sock, map=None):
292 self.socket = sock
293 self._fileno = sock.fileno()
294 self.add_channel(map)
296 def set_reuse_addr(self):
299 self.socket.setsockopt(
301 self.socket.getsockopt(socket.SOL_SOCKET,
313 def readable(self):
316 def writable(self):
323 def listen(self, num):
324 self.accepting = True
327 return self.socket.listen(num)
329 def bind(self, addr):
330 self.addr = addr
331 return self.socket.bind(addr)
333 def connect(self, address):
334 self.connected = False
335 self.connecting = True
336 err = self.socket.connect_ex(address)
339 self.addr = address
342 self.addr = address
343 self.handle_connect_event()
347 def accept(self):
350 conn, addr = self.socket.accept()
361 def send(self, data):
363 result = self.socket.send(data)
369 self.handle_close()
374 def recv(self, buffer_size):
376 data = self.socket.recv(buffer_size)
380 self.handle_close()
387 self.handle_close()
392 def close(self):
393 self.connected = False
394 self.accepting = False
395 self.connecting = False
396 self.del_channel()
397 if self.socket is not None:
399 self.socket.close()
408 def log(self, message):
411 def log_info(self, message, type='info'):
412 if type not in self.ignore_log_types:
415 def handle_read_event(self):
416 if self.accepting:
419 self.handle_accept()
420 elif not self.connected:
421 if self.connecting:
422 self.handle_connect_event()
423 self.handle_read()
425 self.handle_read()
427 def handle_connect_event(self):
428 err = self.socket.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR)
431 self.handle_connect()
432 self.connected = True
433 self.connecting = False
435 def handle_write_event(self):
436 if self.accepting:
441 if not self.connected:
442 if self.connecting:
443 self.handle_connect_event()
444 self.handle_write()
446 def handle_expt_event(self):
450 err = self.socket.getsockopt(socket.SOL_SOCKET, socket.SO_ERROR)
457 self.handle_close()
459 self.handle_expt()
461 def handle_error(self):
466 self_repr = repr(self)
468 self_repr = '<__repr__(self) failed for object at %0x>' % id(self)
470 self.log_info(
479 self.handle_close()
481 def handle_expt(self):
482 self.log_info('unhandled incoming priority event', 'warning')
484 def handle_read(self):
485 self.log_info('unhandled read event', 'warning')
487 def handle_write(self):
488 self.log_info('unhandled write event', 'warning')
490 def handle_connect(self):
491 self.log_info('unhandled connect event', 'warning')
493 def handle_accept(self):
494 pair = self.accept()
496 self.handle_accepted(*pair)
498 def handle_accepted(self, sock, addr):
500 self.log_info('unhandled accepted event', 'warning')
502 def handle_close(self):
503 self.log_info('unhandled close event', 'warning')
504 self.close()
513 def __init__(self, sock=None, map=None):
514 dispatcher.__init__(self, sock, map)
515 self.out_buffer = b''
517 def initiate_send(self):
519 num_sent = dispatcher.send(self, self.out_buffer[:65536])
520 self.out_buffer = self.out_buffer[num_sent:]
522 def handle_write(self):
523 self.initiate_send()
525 def writable(self):
526 return (not self.connected) or len(self.out_buffer)
528 def send(self, data):
529 if self.debug:
530 self.log_info('sending %s' % repr(data))
531 self.out_buffer = self.out_buffer + data
532 self.initiate_send()
595 def __init__(self, fd):
596 self.fd = os.dup(fd)
598 def __del__(self):
599 if self.fd >= 0:
600 warnings.warn("unclosed file %r" % self, ResourceWarning,
601 source=self)
602 self.close()
604 def recv(self, *args):
605 return os.read(self.fd, *args)
607 def send(self, *args):
608 return os.write(self.fd, *args)
610 def getsockopt(self, level, optname, buflen=None):
621 def close(self):
622 if self.fd < 0:
624 fd = self.fd
625 self.fd = -1
628 def fileno(self):
629 return self.fd
633 def __init__(self, fd, map=None):
634 dispatcher.__init__(self, None, map)
635 self.connected = True
640 self.set_file(fd)
644 def set_file(self, fd):
645 self.socket = file_wrapper(fd)
646 self._fileno = self.socket.fileno()
647 self.add_channel()