|
__init__(self,
(host, port),
client_class=<class congress.node.Peer at 0x9f511dc>,
debug=False,
id=None,
pyev_loop=None,
debug_file=None) |
source code
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
add_peer(self,
conn,
connect=False,
existing_socket=None) |
source code
|
|
|
|
|
|
|
|
|
peer_cleanup(self,
peer)
Stub for subclasses. |
source code
|
|
|
register_handshake(self,
func,
peer=None)
Any time a new incoming connectin is made, the argument will be
executed with the arguments peer and the server itself. |
source code
|
|
|
register_message_callback(self,
message,
func) |
source code
|
|
|
register_message_handler(self,
atype,
func) |
source code
|
|
|
register_message_timeout(self,
message,
func,
peer,
timeout=3) |
source code
|
|
|
|
|
|
|
|