| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | ssl_stream.rs | 49 fn flush(&mut self) -> std::io::Result<()> { in flush() functions
51 MixStream::Http(s) => s.flush(), in flush()
52 MixStream::Https(s) => s.flush(), in flush()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | stdio_cargo_test.rs | 37 let res = stdout.flush().await; in sdv_stdio_write()
49 let res = stderr.flush().await; in sdv_stdio_write()
69 let res = buf_writer.flush().await; in sdv_stdio_buf_writer_write()
78 let res = buf_writer.flush().await; in sdv_stdio_buf_writer_write()
|
| H A D | async_buf_write.rs | 52 buf_writer.flush().await.unwrap(); in sdv_buf_writer_write()
94 buf_writer.flush().await.unwrap(); in sdv_buf_writer_write_vectored()
190 buf_writer.flush().await.unwrap(); in sdv_buf_writer_write_vectored_2()
|
| H A D | pty_process.rs | 90 pty.flush().await.unwrap(); in sdv_pty_process_read_and_write_test()
116 write_pty.flush().await.unwrap(); in sdv_pty_split_test()
148 write_pty.flush().await.unwrap(); in sdv_pty_into_split_test()
|
| H A D | tcp_test.rs | 304 write_half.flush().await.unwrap(); in sdv_tcp_split_borrow_half()
374 write_half.flush().await.unwrap(); in sdv_tcp_split_owned_half()
|
| H A D | process.rs | 103 stdin.flush().await.unwrap(); in sdv_process_child_stdio_test()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A D | async_buf_writer.rs | 173 fn flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in flush() functions
212 poll_ready!(self.as_mut().flush(cx))?; in poll_write()
235 poll_ready!(self.as_mut().flush(cx))?; in poll_write_vectored()
256 poll_ready!(self.as_mut().flush(cx))?; in poll_write_vectored()
283 poll_ready!(self.as_mut().flush(cx))?; in poll_flush()
289 poll_ready!(self.as_mut().flush(cx))?; in poll_shutdown()
301 poll_ready!(self.as_mut().flush(cx))?; in poll_seek()
|
| /commonlibrary/ets_utils/js_util_module/util/ |
| H A D | js_stringdecoder.cpp | 29 napi_value StringDecoder::Write(napi_env env, napi_value src, UBool flush) in Write() argument
56 ucnv_toUnicode(conv_, &target, target + len, &source, source + length, nullptr, flush, &codeFlag); in Write()
92 UBool flush = true; in End() local
93 ucnv_toUnicode(conv_, &target, targetEnd, &src, sourceEnd, nullptr, flush, &errorCode); in End()
|
| H A D | js_textdecoder.cpp | 109 UBool flush = ((flags & static_cast<uint8_t>(ConverterFlags::FLUSH_FLG))) == in Decode() local
139 ucnv_toUnicode(GetConverterPtr(), &target, target + len, &source, source + length, nullptr, flush, &codeFlag); in Decode() local
155 if (flush) { in Decode()
194 UBool flush = (flags & static_cast<uint8_t>(ConverterFlags::FLUSH_FLG)) == in DecodeToString() local
218 ucnv_toUnicode(GetConverterPtr(), &target, target + len, &source, source + length, nullptr, flush, &codeFlag); in DecodeToString() local
235 if (flush) { in DecodeToString()
|
| H A D | js_stringdecoder.h | 29 napi_value Write(napi_env env, napi_value src, UBool flush = false);
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | stream.rs | 239 fn flush(&mut self) -> io::Result<()> { in flush() functions
240 self.inner.flush() in flush()
267 fn flush(&mut self) -> io::Result<()> { in flush() functions
269 inner.flush() in flush()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | stream.rs | 181 fn flush(&mut self) -> io::Result<()> { in flush() functions
182 self.inner.flush() in flush()
208 fn flush(&mut self) -> io::Result<()> { in flush() functions
210 inner.flush() in flush()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | async_file.rs | 220 file.flush().await; in fmt()
248 file.flush().await; in fmt()
280 file.flush().await; in fmt()
390 file.flush().await; in fmt()
647 async fn flush(&mut self) { in poll_flush()
936 let ret = file.flush().await; in ut_file_try_into_std()
|
| /commonlibrary/rust/ylong_json/src/ |
| H A D | encoder.rs | 387 self.flush()?; in write()
391 fn flush(&mut self) -> std::io::Result<()> { in flush() functions
|
| H A D | serializer_compact.rs | 38 fn flush(&mut self) -> std::io::Result<()> { in flush() functions
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | split.rs | 244 write_half.flush().await.unwrap(); in poll_flush()
294 write_half.flush().await.unwrap(); in poll_flush()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | stdio.rs | 168 let res = inner.flush().map(|_| 0); in poll_flush()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | pipe.rs | 49 fn flush(&mut self) -> io::Result<()> { in write_vectored() functions
50 (&self.fd).flush() in write_vectored()
119 (&pipe).flush().unwrap(); in ut_process_pipe_test()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | c_ssl_stream.rs | 131 self.with_context(ctx, |s| check_io_to_poll(s.flush())) in poll_flush()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | tcp_test.rs | 122 stream.flush().unwrap(); in sdv_tcp_server_vectored()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| H A D | bio.rs | 192 match catch_unwind(AssertUnwindSafe(|| state.stream.flush())) {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | command.rs | 673 stdin.flush().await.unwrap(); in ut_process_child_stdio_test()
|
| /commonlibrary/c_utils/base/src/ |
| H A D | file_ex.cpp | 348 file.flush(); in SaveBufferToFile()
|