Home
last modified time | relevance | path

Searched refs:write (Results 1 - 25 of 69) sorted by relevance

123

/commonlibrary/rust/ylong_json/src/
H A Derror.rs85 write!( in fmt()
96 write!(f, "{s}.") in fmt()
98 write!(f, "{unexpected:?}.") in fmt()
102 write!(f, "[line]: {line}, [Error]: Invalid UTF-8 byte.") in fmt()
105 write!(f, "[Line]: {line}, [Error]: Unexpected end of json.") in fmt()
108 write!(f, "[Line]: {line}, [Error]: Expected end of json but not.") in fmt()
111 write!(f, "[Error]: Value has not been fully deserialized.") in fmt()
114 write!( in fmt()
120 write!(f, "[Line]: {line}, [Pos]: {pos}, [Error]: A colon is missing between key and value.") in fmt()
123 write!( in fmt()
[all...]
H A Dencoder.rs274 write!(writer, "{number}")?;
306 x => write!(writer, "\\u{number:0>width$x}", number = x, width = 4)?,
351 write!(writer, "\\u{number:0>width$x}", number = bytes, width = 4)?;
358 write!(writer, "\\u{number:0>width$x}", number = bytes, width = 4)?;
384 fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> { in write() functions
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
H A Derror.rs147 write!(f, "error:{:08X}", self.code())?; in fmt()
152 write!(f, "lib: ({}), ", str::from_utf8(bytes).unwrap_or_default())?;
154 write!(f, "lib: ({}), ", error_get_lib(self.code))?;
163 write!(f, "func: ({}), ", str::from_utf8(bytes).unwrap_or_default())?;
165 write!(f, "func: ({}), ", error_get_func(self.code))?;
173 Some(s) => write!(f, ":{s}")?,
174 None => write!(f, ":func({})", error_get_func(self.code))?,
182 write!(
188 write!(f, "reason: ({}), ", error_get_reason(self.code))?;
191 write!(
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/
H A Derror.rs71 SslErrorCode::ZERO_RETURN => write!(f, "SSL session has been closed"), in fmt()
74 write!(f, "SslCode[{}], IO Error: {}", self.code, e) in fmt()
76 write!(f, "SslCode[{}], Unexpected EOF", self.code) in fmt()
81 write!(f, "ErrorStack: {e}") in fmt()
83 write!(f, "SslCode: [{}]", self.code) in fmt()
88 write!(f, "SslCode[{}], IO Error: {}", self.code, e) in fmt()
90 write!( in fmt()
99 write!(f, "SslCode[{}], IO Error: {}", self.code, e) in fmt()
101 write!( in fmt()
109 write!( in fmt()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/
H A Dopen_options.rs30 /// .write(true)
83 /// Sets the option for file write access.
86 /// `write`-able if opened.
88 /// If the file already exists, any write calls on it will overwrite its
91 /// This method's behavior is the same as [`std::fs::OpenOptions::write`].
99 /// let file = OpenOptions::new().write(true).open("foo.txt").await;
102 pub fn write(&mut self, write: bool) -> &mut OpenOptions { in write() functions
103 self.0.write(write); in write()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Derror.rs25 write!(f, "channel is closed") in fmt()
37 write!(f, "channel is closed") in fmt()
55 TrySendError::Full(_) => write!(f, "channel is full"), in fmt()
56 TrySendError::Closed(_) => write!(f, "channel is closed"), in fmt()
75 TryRecvError::Empty => write!(f, "channel is empty"), in fmt()
76 TryRecvError::Closed => write!(f, "channel is closed"), in fmt()
97 SendTimeoutError::Closed(_) => write!(f, "channel is closed"), in fmt()
98 SendTimeoutError::TimeOut(_) => write!(f, "channel sending timeout"), in fmt()
116 RecvTimeoutError::Closed => write!(f, "channel is closed"), in fmt()
117 RecvTimeoutError::Timeout => write!( in fmt()
[all...]
H A Drwlock.rs50 /// // Only one write lock at a time
51 /// let mut w = lock.write().await;
95 /// If there is a writer holding the write lock, then this method will wait
96 /// asynchronously for the write lock to get released.
98 /// But if the write lock is not held, it's ok for multiple readers to hold
123 /// Attempts to get the read lock. If another writer is holding the write
152 /// Asynchronously acquires the write lock.
164 /// let mut r1 = lock.write().await;
169 pub async fn write(&self) -> RwLockWriteGuard<'_, T> {
183 /// Attempts to acquire the write loc
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dssl_stream.rs42 fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> { in write() functions
44 MixStream::Http(s) => s.write(buf), in write()
45 MixStream::Https(s) => s.write(buf), in write()
H A Dreader.rs40 /// fn write(&mut self, data: &[u8]) -> Result<(), BodyProcessError> {
101 /// [`BodyProcessor::write`] and [`BodyProcessor::progress`] will be
104 /// [`BodyProcessor::write`]: BodyProcessor::write
136 .write(&buf[..read_len]) in read_all()
165 fn write(&mut self, data: &[u8]) -> Result<(), BodyProcessError>; in write() functions
185 /// A default body processor that write data to console directly.
204 fn write(&mut self, data: &[u8]) -> Result<(), BodyProcessError> { in write() functions
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dtcp_test.rs20 /// SDV for TcpStream read and write
41 let mut ret = stream.write(b"hello"); in sdv_tcp_server()
49 ret = stream.write(b"hello"); in sdv_tcp_server()
51 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server()
67 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server()
84 let ret = client.write(&buf).unwrap(); in sdv_tcp_server()
121 ret = stream.write(b"hello"); in sdv_tcp_server_vectored()
124 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server_vectored()
141 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server_vectored()
158 let ret = client.write( in sdv_tcp_server_vectored()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dstream.rs50 /// let _ = stream.write(b"hello client").await?;
211 /// match stream.try_write(b"write message") { in fmt()
226 /// Attempts to write data to the stream, returning the number of bytes in fmt()
244 /// match stream.try_write(b"write message") { in fmt()
256 .try_io(Interest::WRITABLE, || (&*self.source).write(buf)) in fmt()
454 /// Splits a TcpStream into a read half and a write half with reference, in fmt()
455 /// which can be used to read and write the stream concurrently. in fmt()
469 /// let (read, write) = stream.split(); in fmt()
475 let write = BorrowWriteHalf(self); in fmt()
476 (read, write) in fmt()
[all...]
H A Dsplit.rs26 /// Borrowed write half of a TcpStream
129 /// 3. Split TcpStream into read half and write half with borrowed. in poll_flush()
130 /// 4. Write with write half and read with read half. in poll_flush()
146 write_half.write(b"I am write half.").await.unwrap(); in poll_flush()
162 "I am write half." in poll_flush()
164 stream.write(b"hello read half.").await.unwrap(); in poll_flush()
175 /// 3. Split TcpStream into read half and write half with owned. in poll_flush()
176 /// 4. Write with write half and read with read half. in poll_flush()
193 write_half.write( in poll_flush()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/quic/
H A Dmod.rs132 let (write, _send_info) = self.send(&mut out).expect("initial send failed");
135 .write_all(&out[..write])
164 let (write, _send_info) = match self.send(&mut out) {
178 .write_all(&out[..write])
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_tokio_tcp_perf.rs40 match client.write(b"hello server").await { in ylong_create_client()
76 match client.write(b"hello server").await { in tokio_create_client()
104 println!("ylong tcp read()+write() Loops: {}", LOOP_NUMS); in main()
135 let _ = socket.write(b"hello client").await.unwrap(); in main()
142 "ylong tcp read()+write() cost: {:.6} ms", in main()
146 println!("tokio tcp read()+write() Loops: {}", LOOP_NUMS); in main()
179 let _ = socket.write(b"hello client").await.unwrap(); in main()
186 "tokio tcp read()+write() cost: {:.6} ms", in main()
H A Dylong_runtime_async_benchmark.rs30 let n = client.write(&buf).await.unwrap();
48 let n = server.write(&buf).await.unwrap();
H A Dylong_sync_rwlock_perf.rs38 let mut writer = mutex.write().await; in main()
42 println!("write : {:?}", end - start); in main()
H A Dylong_runtime_tcp_client_perf.rs32 match stream.write(&recv_buf).await { in main()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/
H A Dpty.rs82 /// Splits a `Pty` into a read half and a write half with reference,
83 /// which can be used to read and write the stream concurrently.
100 let write = BorrowWritePty(self); in split()
101 (read, write) in split()
104 /// Splits a `Pty` into a read half and a write half,
105 /// which can be used to read and write the stream concurrently.
123 let write = SplitWritePty(Arc::clone(&arc)); in into_split()
124 (read, write) in into_split()
238 /// Borrowed write half of a `Pty`
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Darray.rs105 pub(crate) fn write(&self, index: usize, value: T) {
108 node.value.borrow_mut().write(value);
122 self.write(index, value);
133 self.write(index, value);
153 // corresponding tail node to write in.
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/
H A Dpipe.rs41 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write() functions
42 (&self.fd).write(buf) in write()
107 .write(true) in ut_process_pipe_test()
/commonlibrary/rust/ylong_http/ylong_http/src/h1/request/
H A Dencoder.rs202 /// If the length of buf is not enough to write all the output results,
431 WriteData::new(method, &mut self.src_idx, buf).write() in encode()
465 WriteData::new(uri, &mut self.src_idx, buf).write() in encode()
485 task.write() in encode()
546 match task.write()? { in encode_name()
561 match task.write()? { in encode_colon()
576 match task.write()? { in encode_value()
625 task.write() in encode()
641 task.write() in encode()
656 fn write( functions
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dregistry.rs141 pub(crate) fn write(&self, buf: &[u8]) -> io::Result<usize> {
143 sender.write(buf)
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/
H A Dstream.rs108 /// Shuts down the read, write, or both halves of this connection.
281 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in fmt() functions
282 self.state.try_io(|mut inner| inner.write(buf), &self.inner) in fmt()
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H A Dylong_io_tcp_client.rs47 match stream.write(b"Hello World") { in main()
/commonlibrary/utils_lite/hals/file/
H A Dhal_file.c39 return write(fd, buf, len); in HalFileWrite()

Completed in 10 milliseconds

123