()
| 537 | const READ_TIMEOUT_MS: i32 = 500; |
| 538 | |
| 539 | fn read_packet() -> Option<[u8; 64]> { |
| 540 | let mut buffer = [0u8; 64]; |
| 541 | match DEVICE_CONNECTION |
| 542 | .get() |
| 543 | .expect("Device connection must be initialized") |
| 544 | .lock() |
| 545 | .unwrap() |
| 546 | .read_timeout(&mut buffer, READ_TIMEOUT_MS) |
| 547 | { |
| 548 | Ok(0) => None, |
| 549 | Ok(_) => Some(buffer), |
| 550 | Err(error) => { |
| 551 | error!("Failed to read packet: {:?}", error); |
| 552 | None |
| 553 | } |
| 554 | } |
| 555 | } |
| 556 | |
| 557 | fn read_ack() { |
| 558 | for attempt in 0..MAX_READ_ATTEMPTS { |
no outgoing calls
no test coverage detected