4429964531

Build Type

push

github

Committed by GitHub

Commit Message

Raise test coverage

Run Details

478 of 528 relevant lines covered (90.53%)

2.98 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

96.3

/src/ping_data_buffer.rs

use crate::icmp::v4::SequenceNumber;
use crate::ping_error::PingError;
use crate::records::PingReceiveRecordData;
use crate::records::PingSendRecord;
use crate::records::PingSendRecordReceiver;
use crate::PingReceiveData;
use crate::PingResult;
use std::collections::HashMap;
use std::net::IpAddr;
use std::time::Instant;

pub(crate) struct PingDataBuffer {
    ping_send_record_rx: PingSendRecordReceiver,
    send_records: HashMap<(SequenceNumber, IpAddr), (usize, Instant)>,
}

impl PingDataBuffer {
    pub(crate) fn new(ping_send_record_rx: PingSendRecordReceiver) -> Self {
        Self { ping_send_record_rx, send_records: HashMap::new() }
    }

    pub(crate) fn process_send_records(&mut self) -> usize {
        let mut n_send_records: usize = 0;
        while let Ok(send_record) = self.ping_send_record_rx.try_recv() {
            let PingSendRecord { payload_size, ip_addr, sequence_number, send_time } = send_record;
            self.send_records
                .insert((sequence_number, ip_addr), (payload_size, send_time));
            n_send_records += 1;
        }
        n_send_records
    }

    pub(crate) fn process_receive_record(&mut self, data: &PingReceiveRecordData) -> PingResult<PingReceiveData> {
        let PingReceiveRecordData { package_size, ip_addr, ttl, sequence_number, receive_time } = *data;
        match self.send_records.get(&(sequence_number, ip_addr)) {
            None => Err(PingError { message: "could not find matching data in send-records buffer".to_owned() }.into()),
            Some(&(_payload_size, send_time)) => {
                self.send_records.remove(&(sequence_number, ip_addr));
                Ok(PingReceiveData {
                    package_size,
                    ip_addr,
                    ttl: ttl.into(),
                    sequence_number: sequence_number.into(),
                    ping_duration: receive_time - send_time,
                })
            }
        }
    }
}

1	use crate::icmp::v4::SequenceNumber;
2	use crate::ping_error::PingError;
3	use crate::records::PingReceiveRecordData;
4	use crate::records::PingSendRecord;
5	use crate::records::PingSendRecordReceiver;
6	use crate::PingReceiveData;
7	use crate::PingResult;
8	use std::collections::HashMap;
9	use std::net::IpAddr;
10	use std::time::Instant;
11
12	pub(crate) struct PingDataBuffer {
13	ping_send_record_rx: PingSendRecordReceiver,
14	send_records: HashMap<(SequenceNumber, IpAddr), (usize, Instant)>,
15	}
16
17	impl PingDataBuffer {
18	pub(crate) fn new(ping_send_record_rx: PingSendRecordReceiver) -> Self {	5✔
19	Self { ping_send_record_rx, send_records: HashMap::new() }	5✔
20	}	5✔
21
22	pub(crate) fn process_send_records(&mut self) -> usize {	3✔
23	let mut n_send_records: usize = 0;	3✔
24	while let Ok(send_record) = self.ping_send_record_rx.try_recv() {	6✔
25	let PingSendRecord { payload_size, ip_addr, sequence_number, send_time } = send_record;	3✔
26	self.send_records	3✔
27	.insert((sequence_number, ip_addr), (payload_size, send_time));	3✔
28	n_send_records += 1;	3✔
29	}	3✔
30	n_send_records	3✔
31	}	3✔
32
33	pub(crate) fn process_receive_record(&mut self, data: &PingReceiveRecordData) -> PingResult<PingReceiveData> {	3✔
34	let PingReceiveRecordData { package_size, ip_addr, ttl, sequence_number, receive_time } = *data;	3✔
35	match self.send_records.get(&(sequence_number, ip_addr)) {	3✔
36	None => Err(PingError { message: "could not find matching data in send-records buffer".to_owned() }.into()),	×
37	Some(&(_payload_size, send_time)) => {	3✔
38	self.send_records.remove(&(sequence_number, ip_addr));	3✔
39	Ok(PingReceiveData {	3✔
40	package_size,	3✔
41	ip_addr,	3✔
42	ttl: ttl.into(),	3✔
43	sequence_number: sequence_number.into(),	3✔
44	ping_duration: receive_time - send_time,	3✔
45	})	3✔
46	}
47	}
48	}	3✔
49	}

rng-dynamics / ping-fox / 4429964531

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous