pub(super) fn start_run(&mut self, run_info: RunInfo) {
        if run_info.nonce != self.run_nonce {
            error!(
                "Received unexpected test run info! Got {}, expected: {}",
                self.run_nonce, run_info.nonce
            );
            return;
        }

        // notify about malformed nodes:
        for malformed_mix in run_info.malformed_mixes {
            debug!(
                target: "test-run",
                "{} is malformed", malformed_mix.clone()
            );
            self.test_report.malformed.push(malformed_mix);
        }

        for old_mix in run_info.incompatible_mixes {
            debug!(
                target: "test-run",
                "{} is outdated! It's on {} version",
                old_mix.0.clone(),
                old_mix.1
            );
            self.test_report.outdated.push(old_mix);
        }

        self.test_report.total_sent = run_info.test_packets.len();

        // store information about packets that are currently being sent
        self.expected_run_packets
            .reserve(run_info.test_packets.len());
        for test_packet in run_info.test_packets {
            self.expected_run_packets.insert(test_packet);
        }
    }
/// Update state of self based on the received `RunInfo`
Update state of self based on the received `RunInfo`
Update state of self based on the received ` RunInfo `
pub(super) fn start_run(&mut self, run_info: RunInfo) {
        if run_info.nonce != self.run_nonce {
            error!(
                "Received unexpected test run info! Got {}, expected: {}",
                self.run_nonce, run_info.nonce
            );
            return;
        }
        // notify about malformed nodes:
        for malformed_mix in run_info.malformed_mixes {
            debug!(
                target: "test-run",
                "{} is malformed", malformed_mix.clone()
            );
            self.test_report.malformed.push(malformed_mix);
        }
        for old_mix in run_info.incompatible_mixes {
            debug!(
                target: "test-run",
                "{} is outdated! It's on {} version",
                old_mix.0.clone(),
                old_mix.1
            );
            self.test_report.outdated.push(old_mix);
        }
        self.test_report.total_sent = run_info.test_packets.len();
        // store information about packets that are currently being sent
        self.expected_run_packets
            .reserve(run_info.test_packets.len());
        for test_packet in run_info.test_packets {
            self.expected_run_packets.insert(test_packet);
        }
    }
pub ( super ) fn start_run ( & mut self , run_info : RunInfo ) { if run_info . nonce != self . run_nonce { error ! ( " " self run_nonce run_info nonce ) ; return ; } // notify about malformed nodes: for malformed_mix in run_info . malformed_mixes { debug ! ( target " " " " malformed_mix clone ( ) ) ; self . test_report . malformed . push ( malformed_mix ) ; } for old_mix in run_info . incompatible_mixes { debug ! ( target " " " " old_mix 0 clone ( ) old_mix 1 ) ; self . test_report . outdated . push ( old_mix ) ; } self . test_report . total_sent = run_info . test_packets . len ( ) ; // store information about packets that are currently being sent self . expected_run_packets . reserve ( run_info . test_packets . len ( ) ) ; for test_packet in run_info . test_packets { self . expected_run_packets . insert ( test_packet ) ; } }
Update state of self based on the received `RunInfo`
Update state of self based on the received ` RunInfo `
&mut self
run_info
RunInfo