global_ctrl.py 文件源码

def install_update(self, old_flows, new_flows):
        self.no_of_received_msgs = 0
        self.current_start_time = time() * 1000
        new_msgs = self.handler.do_install_update(old_flows, new_flows, self.test_number, self.skip_deadlock)
        # self.log.info(new_msgs)
        self.current_sending_time = time() * 1000
        self.current_computation_time = self.current_sending_time - self.current_start_time
        self.log.debug("delay from ctrl to sw: %s" % global_vars.sw_to_ctrl_delays)

        pickled_msgs = []
        for new_msg in new_msgs:
            new_msg.computation_time_in_ctrl = self.current_computation_time
            str_message = pickle.dumps(new_msg, pickle.HIGHEST_PROTOCOL)
            pickled_msgs.append(str_message)

        c = 0
        for new_msg in new_msgs:
            # self.send_to_switch(new_msg, pickled_msgs[c])
            # latency = global_vars.sw_to_ctrl_delays[new_msg.dst_id]/1000
            eventlet.spawn_after(0, self.send_to_switch, new_msg, pickled_msgs[c])
            c += 1