Embedded Python Real-Time FrameWork : API  Build 20250616.1
 All Classes Namespaces Files Functions Variables Pages
pyRT.gatea.sys.asyncore Namespace Reference

Vanilla asyncore with 2 lines of code so that dispatchers don't spin uncontrollably after handle_close. More...

Classes

class  dispatcher
 
class  dispatcher_with_send
 
class  ExitNow
 
class  file_dispatcher
 
class  file_wrapper
 

Functions

def __getattr__
 
def accept
 
def bind
 
def close
 
def close_all
 
def compact_traceback
 
def connect
 
def handle_accept
 
def handle_close
 
def handle_connect
 
def handle_error
 
def handle_expt
 
def handle_expt_event
 
def handle_read
 
def handle_read_event
 
def handle_write
 
def handle_write_event
 
def listen
 
def log
 
def log_info
 
def loop
 
def poll
 
def poll2
 
def read
 
def readable
 
def readwrite
 
def recv
 
def send
 
def set_reuse_addr
 self.__dict__['socket'] = sock More...
 
def writable
 
def write
 

Variables

 accepting
 
 addr
 
 connected
 
 poll3 = poll2
 
dictionary socket_map = {}
 

Detailed Description

Vanilla asyncore with 2 lines of code so that dispatchers don't spin uncontrollably after handle_close.

Still don't know why we need this, but it works ... since 2008

Function Documentation

def pyRT.gatea.sys.asyncore.__getattr__ (   self,
  attr 
)
def pyRT.gatea.sys.asyncore.accept (   self)
def pyRT.gatea.sys.asyncore.bind (   self,
  addr 
)
def pyRT.gatea.sys.asyncore.close (   self)
def pyRT.gatea.sys.asyncore.close_all (   map = None)
def pyRT.gatea.sys.asyncore.compact_traceback ( )
def pyRT.gatea.sys.asyncore.connect (   self,
  address 
)
def pyRT.gatea.sys.asyncore.handle_accept (   self)
def pyRT.gatea.sys.asyncore.handle_close (   self)
def pyRT.gatea.sys.asyncore.handle_connect (   self)
def pyRT.gatea.sys.asyncore.handle_error (   self)
def pyRT.gatea.sys.asyncore.handle_expt (   self)
def pyRT.gatea.sys.asyncore.handle_expt_event (   self)
def pyRT.gatea.sys.asyncore.handle_read (   self)
def pyRT.gatea.sys.asyncore.handle_read_event (   self)
def pyRT.gatea.sys.asyncore.handle_write (   self)
def pyRT.gatea.sys.asyncore.handle_write_event (   self)
def pyRT.gatea.sys.asyncore.listen (   self,
  num 
)
def pyRT.gatea.sys.asyncore.log (   self,
  message 
)
def pyRT.gatea.sys.asyncore.log_info (   self,
  message,
  type = 'info' 
)
def pyRT.gatea.sys.asyncore.loop (   timeout = 30.0,
  use_poll = False,
  map = None,
  count = None 
)
def pyRT.gatea.sys.asyncore.poll (   timeout = 0.0,
  map = None 
)
def pyRT.gatea.sys.asyncore.poll2 (   timeout = 0.0,
  map = None 
)
def pyRT.gatea.sys.asyncore.read (   obj)
def pyRT.gatea.sys.asyncore.readable (   self)
def pyRT.gatea.sys.asyncore.readwrite (   obj,
  flags 
)
def pyRT.gatea.sys.asyncore.recv (   self,
  buffer_size 
)
def pyRT.gatea.sys.asyncore.send (   self,
  data 
)
def pyRT.gatea.sys.asyncore.set_reuse_addr (   self)

self.__dict__['socket'] = sock

def pyRT.gatea.sys.asyncore.writable (   self)
def pyRT.gatea.sys.asyncore.write (   obj)

Variable Documentation

pyRT.gatea.sys.asyncore.accepting
pyRT.gatea.sys.asyncore.addr
pyRT.gatea.sys.asyncore.connected
pyRT.gatea.sys.asyncore.poll3 = poll2
dictionary pyRT.gatea.sys.asyncore.socket_map = {}