mirrors/gst-plugins-rs
mirrors/gst-plugins-rs
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git synced 2025-02-22 07:36:20 +00:00
Code Issues Projects Releases Wiki Activity

togglerecord: Improve logging

Browse source
This commit is contained in:
Sebastian Dröge 2020-05-08 15:57:07 +03:00
parent 56962b1273
commit e1c3491915
1 changed files with 41 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
utils/togglerecord/src/togglerecord.rs
View file

@ -521,7 +521,15 @@ impl ToggleRecord {
// Remember the time when we stopped: now, i.e. right before the current buffer! // Remember the time when we stopped: now, i.e. right before the current buffer!
rec_state.last_recording_stop = current_running_time; rec_state.last_recording_stop = current_running_time;
gst_debug!(CAT, obj: pad, "Stopping at {}", current_running_time); gst_debug!(
CAT,
obj: pad,
"Stopping at {}, started at {}, current duration {}, previous accumulated recording duration {}",
rec_state.last_recording_stop,
rec_state.last_recording_start,
rec_state.last_recording_stop - rec_state.last_recording_start,
rec_state.recording_duration
);
// Then unlock and wait for all other streams to reach it or go EOS instead. // Then unlock and wait for all other streams to reach it or go EOS instead.
drop(rec_state); drop(rec_state);
@ -590,7 +598,13 @@ impl ToggleRecord {
// Remember the time when we started: now! // Remember the time when we started: now!
rec_state.last_recording_start = current_running_time; rec_state.last_recording_start = current_running_time;
rec_state.running_time_offset = current_running_time - rec_state.recording_duration; rec_state.running_time_offset = current_running_time - rec_state.recording_duration;
gst_debug!(CAT, obj: pad, "Starting at {}", current_running_time); gst_debug!(
CAT,
obj: pad,
"Starting at {}, previous accumulated recording duration {}",
current_running_time,
rec_state.recording_duration,
);
state.segment_pending = true; state.segment_pending = true;
for other_stream in &self.other_streams.lock().0 { for other_stream in &self.other_streams.lock().0 {
@ -1417,8 +1431,20 @@ impl ToggleRecord {
if rec_state.recording_state == RecordingState::Recording if rec_state.recording_state == RecordingState::Recording
|| rec_state.recording_state == RecordingState::Stopping || rec_state.recording_state == RecordingState::Stopping
{ {
gst_debug!(
CAT,
obj: pad,
"Returning position {} = {} - ({} + {})",
recording_duration
+ (state.current_running_time - rec_state.last_recording_start),
recording_duration,
state.current_running_time,
rec_state.last_recording_start
);
recording_duration += recording_duration +=
state.current_running_time - rec_state.last_recording_start; state.current_running_time - rec_state.last_recording_start;
} else {
gst_debug!(CAT, obj: pad, "Returning position {}", recording_duration,);
} }
q.set(recording_duration); q.set(recording_duration);
true true
@ -1434,8 +1460,20 @@ impl ToggleRecord {
if rec_state.recording_state == RecordingState::Recording if rec_state.recording_state == RecordingState::Recording
|| rec_state.recording_state == RecordingState::Stopping || rec_state.recording_state == RecordingState::Stopping
{ {
gst_debug!(
CAT,
obj: pad,
"Returning duration {} = {} - ({} + {})",
recording_duration
+ (state.current_running_time - rec_state.last_recording_start),
recording_duration,
state.current_running_time,
rec_state.last_recording_start
);
recording_duration += recording_duration +=
state.current_running_time - rec_state.last_recording_start; state.current_running_time - rec_state.last_recording_start;
} else {
gst_debug!(CAT, obj: pad, "Returning duration {}", recording_duration,);
} }
q.set(recording_duration); q.set(recording_duration);
true true
@ -1574,6 +1612,7 @@ impl ObjectImpl for ToggleRecord {
settings.record, settings.record,
record record
); );
settings.record = record; settings.record = record;
} }
_ => unimplemented!(), _ => unimplemented!(),