Package Anomos :: Module Relayer :: Class Relayer

Class Relayer

                                      object --+        
                                               |        
                         Protocol.AnomosProtocol --+    
                                                   |    
Protocol.AnomosRelayerProtocol.AnomosRelayerProtocol --+
                                                       |
                                                      Relayer

As a tracking code is being sent, each peer it reaches (other than the uploader and downloader) creates a Relayer object to maintain the association between the incoming socket and the outgoing socket (so that the TC only needs to be sent once).

Instance Methods

[hide private]

__init__(self, stream_id, neighbor, outnid, data=None, orelay=None)
x.__init__(...) initializes x; see x.__class__.__doc__ for signature

source code

set_other_relay(self, r)

source code

set_measurer(self, measurer)

source code

_complete_relay_message(self, msg)

source code

relay_message(self, msg)

source code

send_partial(self, bytes)

source code

connection_completed(self)

source code

connection_flushed(self)

source code

should_queue(self)

source code

close(self)

source code

shutdown(self)

source code

ore_closed(self)
Closes the connection when a Break has been received by our other relay (ore).

source code

flush_pre_buffer(self)

source code

is_flushed(self)

source code

got_exception(self, e)

source code

uniq_id(self)

source code

Inherited from Protocol.AnomosRelayerProtocol.AnomosRelayerProtocol: got_ack_break, got_break, got_confirm, got_partial, invalid_message, send_ack_break, send_break, send_confirm, send_relay_message, send_tracking_code

Inherited from Protocol.AnomosProtocol: format_message, got_message, network_ctl_msg

Inherited from Protocol.AnomosProtocol (private): _valid_msg_len

Inherited from object: __delattr__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __str__

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, stream_id, neighbor, outnid, data=None, orelay=None)
(Constructor)

source code

x.__init__(...) initializes x; see x.__class__.__doc__ for signature

Overrides: object.__init__: (inherited documentation)

ore_closed(self)

source code

Closes the connection when a Break has been received by our other relay (ore). Called by this object's ore during shutdown

Class Relayer

__init__(self, stream_id, neighbor, outnid, data=None, orelay=None) (Constructor)

ore_closed(self)

init(self, stream_id, neighbor, outnid, data=None, orelay=None)
(Constructor)