We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent afc47db commit 2479ee4Copy full SHA for 2479ee4
src/logging.rs
@@ -313,11 +313,11 @@ pub fn to_tcp_socket() -> (Logging, LogHandle) {
313
writer.send((ts, setup, event));
314
}
315
if writer.size() >= 1024 || timely_logging::get_precise_time_ns() - cur_time > 1_000_000_000 {
316
- eprint!("f");
+ let next_new_time = timely_logging::get_precise_time_ns() - 1_000_000;
317
writer.flush();
318
writer.advance_by(RootTimestamp::new(new_time));
319
cur_time = new_time;
320
- new_time = timely_logging::get_precise_time_ns() - 1_000_000;
+ new_time = next_new_time;
321
322
323
});
0 commit comments