Implement CSPTP source functionality.

Author: davidv1992

Cargo.lock

@@ -36,7 +36,7 @@ clock-steering = "0.2.1"
 hickory-resolver = { version = "0.26.0", features = ["dnssec-aws-lc-rs"] }
 libc = "0.2.154"
 pps-time = "0.2.3"
-rand = "0.8.0"
+rand = { version = "0.8.0", default-features = false }
 serde = { version = "1.0.166", features = ["derive"] }
 serde_json = "1.0"
 timestamped-socket = "0.2.2"

Cargo.toml

@@ -7,5 +7,9 @@ publish = false
 [workspace]
 members = ["."]
 
+[features]
+std = []
+std_rng = []
+
 [dependencies]
 real_rand = { git = "https://github.com/rust-random/rand.git", tag="0.8.5", package="rand" }

fuzz/fuzz_rand_shim/Cargo.toml

@@ -21,7 +21,7 @@ __internal-api = []
 [dependencies]
 # Note: md5 is needed to calculate ReferenceIDs for IPv6 addresses per RFC5905
 md-5.workspace = true
-rand.workspace = true
+rand = { workspace = true, features = ["std", "std_rng"] }
 tracing.workspace = true
 tokio = { workspace = true, features = ["io-util", "time"] }
 tokio-rustls.workspace = true

ntp-proto/Cargo.toml

@@ -17,3 +17,4 @@ std = ["statime-wire/std"]
 [dependencies]
 statime-wire = { workspace = true }
 ntp-proto = { workspace = true }
+rand = { workspace = true, default-features = false }

statime-csptp/Cargo.toml

@@ -142,10 +142,12 @@ mod manager;
 mod messages;
 mod platform;
 mod server;
+mod source;
 
 pub use manager::{CsptpConfig, CsptpManager};
 pub use platform::{InternalState, StateMutex};
 pub use server::{ServerRecvResult, ServerSocket, serve};
+pub use source::{ClientRecvResult, ClientSocket, CsptpSource, CsptpSourceConfig};
 
 /// Observable CSPTP state
 #[derive(Debug, Copy, Clone)]

statime-csptp/src/lib.rs

@@ -6,13 +6,12 @@ use statime_wire::{
     SyncMessage, TimeInterval, Timestamp, TlvSetBuilder, TlvType,
 };
 
-use crate::{
-    CsptpState,
-    messages::tlvs::{CsptpRequestTlv, CsptpResponseTlv, CsptpStatusTlv},
-};
+use crate::CsptpState;
 
 mod tlvs;
 
+pub(crate) use tlvs::{CsptpRequestTlv, CsptpResponseTlv, CsptpStatusTlv};
+
 pub(crate) const MAX_MESSAGE_SIZE: usize = 512;
 
 /// A message with additional restrictions to ensure it is a valid CSPTP Message.
@@ -116,7 +115,6 @@ impl<'a> CsptpMessage<'a> {
     }
 
     /// Generate a new request message. The buffer must be at least 8 bytes long
-    #[expect(unused)]
     pub(crate) fn new_request(
         buffer: &'a mut [u8],
         domain_number: u8,

statime-csptp/src/messages.rs

@@ -77,7 +77,6 @@ pub(crate) struct CsptpStatusTlv {
 }
 
 impl CsptpStatusTlv {
-    #[expect(unused)]
     pub(crate) fn try_from(tlv: &Tlv<'_>) -> Option<Self> {
         (tlv.tlv_type == TlvType::CsptpStatus)
             .then(|| {