chaos/NTP-Timeturner
1
0
Fork 0
mirror of https://github.com/cjfranko/NTP-Timeturner.git synced 2025-11-08 18:32:02 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: update statime API method calls with correct signatures

Browse source 
Co-authored-by: aider (openrouter/anthropic/claude-sonnet-4) <aider@aider.chat>
This commit is contained in:
Chaos Rogers 2025-07-10 18:03:12 +01:00
parent b2aa3c3d07
commit 59c61a8976
1 changed files with 11 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

18
src/ptp.rs
View file

@ -7,8 +7,8 @@ use statime::{
PtpMinorVersion, TimePropertiesDS, TimeSource, PtpMinorVersion, TimePropertiesDS, TimeSource,
}, },
filters::BasicFilter, filters::BasicFilter,
port::PortAction, port::{NoForwardedTLVs, PortAction},
time::{Duration as PtpDuration, Interval}, time::{Duration as PtpDuration, Interval, Time},
OverlayClock, PtpInstance, SharedClock, OverlayClock, PtpInstance, SharedClock,
}; };
use socket2::{Domain, Protocol, Socket, Type}; use socket2::{Domain, Protocol, Socket, Type};
@ -165,14 +165,18 @@ async fn run_ptp_session(
_ = tokio::time::sleep(Duration::from_millis(100)) => { _ = tokio::time::sleep(Duration::from_millis(100)) => {
// Handle periodic timer events // Handle periodic timer events
actions.extend(running_port.handle_sync_timer()); actions.extend(running_port.handle_sync_timer());
actions.extend(running_port.handle_announce_timer()); actions.extend(running_port.handle_announce_timer(&mut NoForwardedTLVs));
actions.extend(running_port.handle_delay_request_timer()); actions.extend(running_port.handle_delay_request_timer());
} }
Ok((len, source_address)) = event_socket.recv_from(&mut event_buf) => { Ok((len, _source_address)) = event_socket.recv_from(&mut event_buf) => {
actions.extend(running_port.handle_event_receive(&event_buf[..len], source_address)); let receive_time = Time::from_nanos(std::time::SystemTime::now()
.duration_since(std::time::UNIX_EPOCH)
.unwrap()
.as_nanos() as i64);
actions.extend(running_port.handle_event_receive(&event_buf[..len], receive_time));
} }
Ok((len, source_address)) = general_socket.recv_from(&mut general_buf) => { Ok((len, _source_address)) = general_socket.recv_from(&mut general_buf) => {
actions.extend(running_port.handle_general_receive(&general_buf[..len], source_address)); actions.extend(running_port.handle_general_receive(&general_buf[..len]));
} }
} }