Searched refs:non_blocking (Results 1 – 10 of 10) sorted by relevance
| /third_party/rust/crates/tracing/tracing-appender/src/ |
| D | non_blocking.rs | 362 let (mut non_blocking, _guard) = self::NonBlockingBuilder::default() in backpressure_exerted()
367 let error_count = non_blocking.error_counter(); in backpressure_exerted()
369 non_blocking.write_all(b"Hello").expect("Failed to write"); in backpressure_exerted()
373 non_blocking.write_all(b", World").expect("Failed to write"); in backpressure_exerted()
393 fn write_non_blocking(non_blocking: &mut NonBlocking, msg: &[u8]) { in write_non_blocking()
394 non_blocking.write_all(msg).expect("Failed to write"); in write_non_blocking()
405 let (mut non_blocking, _guard) = self::NonBlockingBuilder::default() in logs_dropped_if_lossy()
410 let error_count = non_blocking.error_counter(); in logs_dropped_if_lossy()
413 write_non_blocking(&mut non_blocking, b"Hello"); in logs_dropped_if_lossy()
419 write_non_blocking(&mut non_blocking, b", World"); in logs_dropped_if_lossy()
[all …]
|
| D | lib.rs | 152 use crate::non_blocking::{NonBlocking, WorkerGuard};
156 pub mod non_blocking; module
181 pub fn non_blocking<T: Write + Send + Sync + 'static>(writer: T) -> (NonBlocking, WorkerGuard) { in non_blocking() function
|
| /third_party/rust/crates/tracing/tracing-appender/ |
| D | README.md | 55 - Using [`NonBlocking`][non_blocking] and [`RollingFileAppender`][file_appender]
78 The example below demonstrates the construction of a `non_blocking` writer
100 let (non_blocking, _guard) = tracing_appender::non_blocking(TestWriter);
101 tracing_subscriber::fmt().with_writer(non_blocking).init();
105 `tracing_appender::non_blocking` to ensure buffered logs are flushed to
110 [`tracing_appender::non_blocking`][non_blocking] writer constructed with
115 let (non_blocking, _guard) = tracing_appender::non_blocking(std::io::stdout());
117 .with_writer(non_blocking)
122 The [non_blocking] module's documentation provides more detail on how to
123 use `non_blocking`.
[all …]
|
| D | CHANGELOG.md | 77 - **non_blocking**: Updated `crossbeam-channel` dependency to 0.5 (#1031)
81 - **non_blocking**: Fixed a race condition when logging on shutdown (#1125)
|
| /third_party/rust/crates/tracing/tracing-appender/benches/ |
| D | bench.rs | 7 use tracing_appender::non_blocking;
88 let (non_blocking, _guard) = non_blocking(NoOpWriter::new()); in non_blocking_benchmark()
89 let subscriber = tracing_subscriber::fmt().with_writer(non_blocking); in non_blocking_benchmark()
98 let (non_blocking, _guard) = non_blocking(NoOpWriter::new()); in non_blocking_benchmark()
104 let cloned_make_writer = non_blocking.clone(); in non_blocking_benchmark()
107 let subscriber = tracing_subscriber::fmt().with_writer(non_blocking); in non_blocking_benchmark()
|
| /third_party/rust/crates/tracing/examples/examples/ |
| D | fmt-multiple-writers.rs | 14 let (non_blocking, _guard) = tracing_appender::non_blocking(file_appender); in main()
19 .with(fmt::Layer::new().with_writer(non_blocking)); in main()
|
| /third_party/ffmpeg/fftools/ |
| D | ffmpeg.h | 427 int non_blocking; /* reading packets from the thread should not block */ member
|
| D | ffmpeg.c | 4098 unsigned flags = f->non_blocking ? AV_THREAD_MESSAGE_NONBLOCK : 0; in input_thread()
4178 f->non_blocking = 1; in init_input_thread()
4208 f->non_blocking ? in get_input_packet_mt()
|
| /third_party/lwip/src/api/ |
| D | api_msg.c | 1441 u8_t non_blocking = netconn_is_nonblocking(msg->conn); local
1443 SET_NONBLOCKING_CONNECT(msg->conn, non_blocking);
1444 if (non_blocking) {
|
| /third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/ |
| D | sctp_output.c | 13475 int non_blocking = 0; local
13823 non_blocking = 1;
13831 non_blocking = 1;
13834 if (non_blocking) {
14076 if (non_blocking) {
14348 if (non_blocking) {
|