hpimdm/ReliableMsgTransmission.py
def send_i_am_upstream(self, source, group, rpc):
        """
        Send reliably a new IamUpstream message
        """
        with self._lock:
            self.cancel_all_messages()

            (bt, sn) = self._interface.get_sequence_number()

            metric_preference = rpc.metric_preference
            metric = rpc.route_metric

            self._msg_multicast = self._interface.create_i_am_upstream_msg(my_boot_time=bt, sn=sn,
                                                                           source=source, group=group,
                                                                           metric_preference=metric_preference,
                                                                           metric=metric)

            self.set_retransmission_timer()
            self._interface.send(self._msg_multicast)

        Send reliably a new IamUpstream message
        
Send reliably a new IamUpstream message
Send reliably a new IamUpstream message
def send_i_am_upstream(self, source, group, rpc):
        with self._lock:
            self.cancel_all_messages()
            (bt, sn) = self._interface.get_sequence_number()
            metric_preference = rpc.metric_preference
            metric = rpc.route_metric
            self._msg_multicast = self._interface.create_i_am_upstream_msg(my_boot_time=bt, sn=sn,
                                                                           source=source, group=group,
                                                                           metric_preference=metric_preference,
                                                                           metric=metric)
            self.set_retransmission_timer()
            self._interface.send(self._msg_multicast)
def send_i_am_upstream ( self , source , group , rpc ) : with self . _lock : self . cancel_all_messages ( ) ( bt , sn ) = self . _interface . get_sequence_number ( ) metric_preference = rpc . metric_preference metric = rpc . route_metric self . _msg_multicast = self . _interface . create_i_am_upstream_msg ( my_boot_time = bt , sn = sn , source = source , group = group , metric_preference = metric_preference , metric = metric ) self . set_retransmission_timer ( ) self . _interface . send ( self . _msg_multicast )
Send reliably a new IamUpstream message
Send reliably a new IamUpstream message
"""
        Send reliably a new IamUpstream message
        """
self
source
group
rpc