Skip to content

Commit 133c554

Browse files
committed
revert rewriting abs capture time
1 parent a641c67 commit 133c554

1 file changed

Lines changed: 6 additions & 7 deletions

File tree

pulsebeam-agent/src/actor.rs

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1004,13 +1004,12 @@ impl AgentDriver {
10041004
if let Some(rid) = rid {
10051005
writer = writer.rid(rid);
10061006
}
1007-
// Re-stamp at wire-send time (not encode time) so that
1008-
// receive_time - abs_capture_time measures network +
1009-
// server forwarding latency only.
1010-
writer = writer.abs_capture_time(AbsCaptureTime {
1011-
capture_time: crate::clock::capture_wallclock(),
1012-
clock_offset: None,
1013-
});
1007+
if let Some(abs_capture_time) = frame.abs_capture_time {
1008+
writer = writer.abs_capture_time(AbsCaptureTime {
1009+
capture_time: abs_capture_time,
1010+
clock_offset: None,
1011+
});
1012+
}
10141013
let _ = writer.write(pt, frame.capture_time.into(), frame.ts, frame.data);
10151014
} else {
10161015
tracing::warn!(?mid, "no writer found for mid");

0 commit comments

Comments
 (0)