transceivers: convert to counted_ringbufs

oxidecomputer · May 10, 2024 · f719f20 · f719f20
1 parent a4fa6f7
commit f719f20
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 8 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/drv/transceivers-server/Cargo.toml b/drv/transceivers-server/Cargo.toml
@@ -5,6 +5,7 @@ authors = ["Aaron Hartwig <aaron@oxide.computer>"]
 edition = "2021"
 
 [dependencies]
+counters = { path = "../../lib/counters" }
 drv-fpga-api = { path = "../fpga-api" }
 drv-i2c-api = { path = "../i2c-api" }
 drv-i2c-devices = { path = "../i2c-devices" }

diff --git a/drv/transceivers-server/src/main.rs b/drv/transceivers-server/src/main.rs
@@ -5,6 +5,10 @@
 #![no_std]
 #![no_main]
 
+use counters::Count;
+use ringbuf::*;
+use userlib::{sys_get_timer, task_slot, units::Celsius};
+
 use drv_fpga_api::FpgaError;
 use drv_i2c_devices::pca9956b::Error;
 use drv_sidecar_front_io::{
@@ -19,14 +23,13 @@ use drv_transceivers_api::{
 use enum_map::Enum;
 use idol_runtime::{NotificationHandler, RequestError};
 use multitimer::{Multitimer, Repeat};
-use ringbuf::*;
 use static_cell::ClaimOnceCell;
 use task_sensor_api::{NoData, Sensor};
 use task_thermal_api::{Thermal, ThermalError, ThermalProperties};
 use transceiver_messages::{
     message::LedState, mgmt::ManagementInterface, MAX_PACKET_SIZE,
 };
-use userlib::{sys_get_timer, task_slot, units::Celsius};
+
 use zerocopy::{AsBytes, FromBytes};
 
 mod udp; // UDP API is implemented in a separate file
@@ -41,7 +44,7 @@ task_slot!(SENSOR, sensor);
 include!(concat!(env!("OUT_DIR"), "/i2c_config.rs"));
 
 #[allow(dead_code)]
-#[derive(Copy, Clone, PartialEq, Eq)]
+#[derive(Copy, Clone, PartialEq, Eq, Count)]
 enum Trace {
     None,
     FrontIOBoardReady(bool),
@@ -70,7 +73,8 @@ enum Trace {
     DisableFailed(usize, LogicalPortMask),
     ClearDisabledPorts(LogicalPortMask),
 }
-ringbuf!(Trace, 16, Trace::None);
+
+counted_ringbuf!(Trace, 16, Trace::None);
 
 ////////////////////////////////////////////////////////////////////////////////
 

diff --git a/drv/transceivers-server/src/udp.rs b/drv/transceivers-server/src/udp.rs
@@ -10,25 +10,28 @@
 //!
 //! All of the API types in `transceiver_messages` operate on **physical**
 //! ports, i.e. an FPGA paired by a physical port index (or mask).
+//!
+use counters::Count;
+use ringbuf::*;
+use userlib::UnwrapLite;
+
 use crate::{FrontIOStatus, ServerImpl};
 use drv_sidecar_front_io::transceivers::{
     FpgaI2CFailure, LogicalPort, LogicalPortFailureTypes, LogicalPortMask,
     ModuleResult, ModuleResultNoFailure, ModuleResultSlim, PortI2CStatus,
 };
 use hubpack::SerializedSize;
-use ringbuf::*;
 use task_net_api::*;
 use transceiver_messages::{
     mac::MacAddrs,
     message::*,
     mgmt::{ManagementInterface, MemoryRead, MemoryWrite, Page},
     ModuleId,
 };
-use userlib::UnwrapLite;
 
 ////////////////////////////////////////////////////////////////////////////////
 
-#[derive(Copy, Clone, PartialEq)]
+#[derive(Copy, Clone, PartialEq, Count)]
 enum Trace {
     None,
     DeserializeError(hubpack::Error),
@@ -63,7 +66,7 @@ enum Trace {
     WriteI2CFailures(LogicalPort, FpgaI2CFailure),
 }
 
-ringbuf!(Trace, 16, Trace::None);
+counted_ringbuf!(Trace, 32, Trace::None);
 
 ////////////////////////////////////////////////////////////////////////////////
 #[derive(Copy, Clone, PartialEq)]