asyncore/asynchat

[F.G.Testa]

Hi!
Is there a way to access a specific connected socket when using a derived
asyncore.dispatcher and derived asynchat.async_chat?

class AcmeServer(asyncore.dispatcher):
def __init__(self, port):
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.bind(("", port))
self.listen(5)

def handle_accept(self):
conn, addr = self.accept()
AcmeChannel(self, conn, addr)

def handle_close(self):
print 'Server closed'

def handle_error(self):
print 'Server error'

How do I access the underlying list/map/array of AcmeChannel?
Thank you.

 

[Jeremy Fincher]

How do I access the underlying list/map/array of AcmeChannel?
Thank you.

There is none, but feel free to keep one yourself; I've done that, for
instance, when I want to limit the number of connections to a server
that should (barring malicious clients) have very fast sessions.

Jeremy

 

[F.G.Testa]

But how do you keep it updated since we don't receive any notifications of
closing/removing channels from asyncore/asynchat?
I've found this: asyncore.socket_map (asyncore.py:62). It is a map of your
inherited asynchat class and I'm using it to search for a specific channel
and send data to it, but having my own dictionary would be more elegant, I
think.

 

[Jeremy Fincher]

But how do you keep it updated since we don't receive any notifications of
closing/removing channels from asyncore/asynchat?
I've found this: asyncore.socket_map (asyncore.py:62). It is a map of your
inherited asynchat class and I'm using it to search for a specific channel
and send data to it, but having my own dictionary would be more elegant, I
think.

For my purposes I didn't need to keep it updated. Why why do you need
access to such a dictionary? Is the channel itself unable to decide
when it needs to send information?

Jeremy

 

[MetalOne]

A map argument may be passed to asyncore.loop()
asyncore.socket_map constains either a reference to the argument
passed to asyncore.loop() or a global map object.
asyncore.socket_map contains all the connections.

You may also keep track of connections yourself by handling the
callback functions
asyncore.handle_accept()
asyncore.handle_connect()
aysncore.handle_close()