(api_socket: &str)
| 746 | } |
| 747 | |
| 748 | pub(crate) fn get_counters(api_socket: &str) -> Counters { |
| 749 | // Get counters |
| 750 | let (cmd_success, cmd_output, _) = remote_command_w_output(api_socket, "counters", None); |
| 751 | assert!(cmd_success); |
| 752 | |
| 753 | let counters: HashMap<&str, HashMap<&str, u64>> = |
| 754 | serde_json::from_slice(&cmd_output).unwrap_or_default(); |
| 755 | |
| 756 | let rx_bytes = *counters.get("_net2").unwrap().get("rx_bytes").unwrap(); |
| 757 | let rx_frames = *counters.get("_net2").unwrap().get("rx_frames").unwrap(); |
| 758 | let tx_bytes = *counters.get("_net2").unwrap().get("tx_bytes").unwrap(); |
| 759 | let tx_frames = *counters.get("_net2").unwrap().get("tx_frames").unwrap(); |
| 760 | |
| 761 | let read_bytes = *counters.get("_disk0").unwrap().get("read_bytes").unwrap(); |
| 762 | let write_bytes = *counters.get("_disk0").unwrap().get("write_bytes").unwrap(); |
| 763 | let read_ops = *counters.get("_disk0").unwrap().get("read_ops").unwrap(); |
| 764 | let write_ops = *counters.get("_disk0").unwrap().get("write_ops").unwrap(); |
| 765 | |
| 766 | Counters { |
| 767 | rx_bytes, |
| 768 | rx_frames, |
| 769 | tx_bytes, |
| 770 | tx_frames, |
| 771 | read_bytes, |
| 772 | write_bytes, |
| 773 | read_ops, |
| 774 | write_ops, |
| 775 | } |
| 776 | } |
| 777 | |
| 778 | pub(super) fn pty_read(mut pty: std::fs::File) -> Receiver<String> { |
| 779 | let (tx, rx) = mpsc::channel::<String>(); |
no test coverage detected