mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2026-05-03 06:47:04 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

milan-avb: gptp: track request timing on CLOCK_MONOTONIC

Browse source
This commit is contained in:
hackerman-kl 2026-04-29 07:55:51 +02:00
parent 4da6e39281
commit 7a826b1580
1 changed files with 10 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/modules/module-avb/gptp.c
View file

@ -663,8 +663,12 @@ static uint16_t next_management_id(uint32_t tick_count)
static void gptp_periodic(void *data, uint64_t now) static void gptp_periodic(void *data, uint64_t now)
{ {
struct gptp *gptp = data; struct gptp *gptp = data;
struct timespec mono_ts;
uint64_t mono_now;
int err; int err;
(void)now;
if (!gptp->ptp_mgmt_socket_path) { if (!gptp->ptp_mgmt_socket_path) {
return; return;
} }
@ -673,7 +677,10 @@ static void gptp_periodic(void *data, uint64_t now)
return; return;
} }
if (gptp->req_in_flight && (now - gptp->req_sent_ns) > PTP_REQUEST_TIMEOUT_NS) { clock_gettime(CLOCK_MONOTONIC, &mono_ts);
mono_now = SPA_TIMESPEC_TO_NSEC(&mono_ts);
if (gptp->req_in_flight && (mono_now - gptp->req_sent_ns) > PTP_REQUEST_TIMEOUT_NS) {
pw_log_debug("PTP management request seq=%u timed out", pw_log_debug("PTP management request seq=%u timed out",
gptp->req_sequence_id); gptp->req_sequence_id);
gptp->req_in_flight = false; gptp->req_in_flight = false;
@ -688,11 +695,11 @@ static void gptp_periodic(void *data, uint64_t now)
} }
if (gptp->req_sent_ns != 0 && if (gptp->req_sent_ns != 0 &&
(now - gptp->req_sent_ns) < PTP_REQUEST_INTERVAL_NS) { (mono_now - gptp->req_sent_ns) < PTP_REQUEST_INTERVAL_NS) {
return; return;
} }
err = send_management_request(gptp, next_management_id(gptp->tick_count), now); err = send_management_request(gptp, next_management_id(gptp->tick_count), mono_now);
if (err == 0) { if (err == 0) {
gptp->tick_count++; gptp->tick_count++;
} else if (err == -ENOTCONN) { } else if (err == -ENOTCONN) {