Home
last modified time | relevance | path

Searched refs:io (Results 1 – 25 of 54) sorted by relevance

123

/tonic/tonic/src/transport/server/service/
H A Dio.rs2 use std::io;
3 use std::io::IoSlice;
92 Self::Io(io) => Self::Io(io.clone()), in clone()
94 Self::TlsIo(io) => Self::TlsIo(io.clone()), in clone()
131 Self::Io(io) => Pin::new(io).poll_read(cx, buf), in poll_read()
148 Self::Io(io) => Pin::new(io).poll_write(cx, buf), in poll_write()
156 Self::Io(io) => Pin::new(io).poll_flush(cx), in poll_flush()
158 Self::TlsIo(io) => Pin::new(io).poll_flush(cx), in poll_flush()
164 Self::Io(io) => Pin::new(io).poll_shutdown(cx), in poll_shutdown()
184 Self::Io(io) => io.is_write_vectored(), in is_write_vectored()
[all …]
H A Dmod.rs1 mod io; module
2 pub(crate) use self::io::{ConnectInfoLayer, ServerIo};
H A Dtls.rs3 use tokio::io::{AsyncRead, AsyncWrite};
59 pub(crate) async fn accept<IO>(&self, io: IO) -> Result<TlsStream<IO>, crate::BoxError> in accept()
64 acceptor.accept(io).await.map_err(Into::into) in accept()
/tonic/tests/integration_tests/src/
H A Dlib.rs8 io::IoSlice,
13 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
17 pub struct MockStream(pub tokio::io::DuplexStream);
31 ) -> Poll<std::io::Result<()>> { in poll_read()
41 ) -> Poll<std::io::Result<usize>> { in poll_write()
45 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
52 ) -> Poll<std::io::Result<()>> { in poll_shutdown()
60 ) -> Poll<Result<usize, std::io::Error>> { in poll_write_vectored()
/tonic/tonic/src/transport/channel/service/
H A Dio.rs1 use std::io::{self, IoSlice};
18 pub(in crate::transport) fn new<I: Io>(io: I) -> Self { in new()
19 BoxedIo(Box::pin(io)) in new()
34 ) -> Poll<io::Result<()>> { in poll_read()
44 ) -> Poll<io::Result<usize>> { in poll_write()
48 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
52 fn poll_shutdown(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown()
60 ) -> Poll<Result<usize, io::Error>> { in poll_write_vectored()
H A Dtls.rs5 use tokio::io::{AsyncRead, AsyncWrite};
15 use super::io::BoxedIo;
104 pub(crate) async fn connect<I>(&self, io: I) -> Result<BoxedIo, crate::BoxError> in connect()
108 let io = RustlsConnector::from(self.config.clone()) in connect() localVariable
109 .connect(self.domain.as_ref().to_owned(), io) in connect()
114 let (_, session) = io.get_ref(); in connect()
119 Ok(BoxedIo::new(TokioIo::new(io))) in connect()
H A Dconnector.rs60 let io = connect.await?; in call() localVariable
65 let io = tls.connect(TokioIo::new(io)).await?; in call() localVariable
66 Ok(io) in call()
72 Ok::<_, crate::BoxError>(BoxedIo::new(io)) in call()
H A Dmod.rs17 mod io; module
18 use self::io::BoxedIo;
/tonic/tonic/src/transport/server/
H A Dio_stream.rs4 io,
11 use tokio::io::{AsyncRead, AsyncWrite};
56 Some(Ok(io)) => Poll::Ready(Some(Ok(ServerIo::new_io(io)))), in poll_next_without_tls()
97 Ok(ServerIo::new_tls_io(io)) in poll_next()
103 SelectOutput::Io(io) => Poll::Ready(Some(Ok(io))), in poll_next()
130 io::ErrorKind::ConnectionAborted in handle_tcp_accept_error()
132 | io::ErrorKind::BrokenPipe in handle_tcp_accept_error()
133 | io::ErrorKind::Interrupted in handle_tcp_accept_error()
134 | io::ErrorKind::WouldBlock in handle_tcp_accept_error()
135 | io::ErrorKind::TimedOut in handle_tcp_accept_error()
[all …]
H A Dincoming.rs56 pub fn bind(addr: SocketAddr) -> std::io::Result<Self> { in bind()
86 type Item = std::io::Result<TcpStream>;
/tonic/tests/compression/src/
H A Dcompressing_response.rs13 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
78 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_enabled()
111 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
152 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled_multi_encoding()
174 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_disabled_multi_encoding()
202 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled()
273 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in server_replying_with_unsupported_encoding()
292 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in server_replying_with_unsupported_encoding()
317 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in disabling_compression_on_single_response()
375 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in disabling_compression_on_response_but_keeping_compression_on_stream()
[all …]
H A Dcompressing_request.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
61 .serve_with_incoming(tokio_stream::iter(vec![Ok::<_, std::io::Error>(server)])) in client_enabled_server_enabled()
91 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled_multi_encoding()
123 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_enabled_multi_encoding()
153 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
160 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_disabled()
204 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_mark_compressed_without_header_server_enabled()
212 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_mark_compressed_without_header_server_enabled()
H A Dserver_stream.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
35 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_enabled()
79 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled_server_enabled()
100 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_disabled_server_enabled()
131 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
152 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_disabled()
H A Dclient_stream.rs14 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_enabled()
59 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_enabled()
87 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_disabled_server_enabled()
111 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_disabled_server_enabled()
138 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in client_enabled_server_disabled()
145 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in client_enabled_server_disabled()
184 let (client, server) = tokio::io::duplex(UNCOMPRESSED_MIN_BODY_SIZE * 10); in compressing_response_from_client_stream()
205 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in compressing_response_from_client_stream()
/tonic/tonic/src/codec/
H A Dmod.rs14 use std::io;
129 type Error: From<io::Error>;
146 type Error: From<io::Error>;
H A Dcompression.rs217 ) -> Result<(), std::io::Error> { in compress()
233 std::io::copy(&mut gzip_encoder, &mut out_writer)?; in compress()
242 std::io::copy(&mut deflate_encoder, &mut out_writer)?; in compress()
251 std::io::copy(&mut zstd_encoder, &mut out_writer)?; in compress()
267 ) -> Result<(), std::io::Error> { in decompress()
281 std::io::copy(&mut gzip_decoder, &mut out_writer)?; in decompress()
286 std::io::copy(&mut deflate_decoder, &mut out_writer)?; in decompress()
291 std::io::copy(&mut zstd_decoder, &mut out_writer)?; in decompress()
/tonic/examples/src/mock/
H A Dmock.rs20 let (client, server) = tokio::io::duplex(1024); in main()
27 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in main()
42 Err(std::io::Error::other("Client already taken")) in main()
/tonic/
H A DREADME.md8 [![Crates.io](https://img.shields.io/crates/v/tonic)](https://crates.io/crates/tonic)
10 [![Crates.io](https://img.shields.io/crates/l/tonic)](LICENSE)
26 - High performance async io
92 [gRPC]: https://grpc.io
112 [healthcheck]: https://grpc.io/docs/guides/health-checking/
/tonic/examples/
H A DREADME.md148 * [bytes](https://crates.io/crates/bytes)
149 * [prost](https://crates.io/crates/prost)
150 * [prost-derive](https://crates.io/crates/prost-derive)
154 * [systemfd](https://crates.io/crates/systemfd)
155 * [cargo-watch](https://crates.io/crates/cargo-watch)
/tonic/tests/integration_tests/tests/
H A Dmax_message_size.rs121 let (client, server) = tokio::io::duplex(1024); in response_stream_limit()
152 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in response_stream_limit()
169 Err(std::io::Error::other("Client already taken")) in response_stream_limit()
278 let (client, server) = tokio::io::duplex(1024); in max_message_run()
318 .serve_with_incoming(tokio_stream::once(Ok::<_, std::io::Error>(server))) in max_message_run()
335 Err(std::io::Error::other("Client already taken")) in max_message_run()
/tonic/tests/extern_path/my_application/
H A Dbuild.rs1 fn main() -> Result<(), std::io::Error> { in main()
/tonic/examples/src/streaming/
H A Dserver.rs5 use std::{error::Error, io::ErrorKind, net::ToSocketAddrs, pin::Pin, time::Duration};
15 fn match_for_io_error(err_status: &Status) -> Option<&std::io::Error> { in match_for_io_error()
19 if let Some(io_err) = err.downcast_ref::<std::io::Error>() { in match_for_io_error()
/tonic/tests/extern_path/uuid/
H A DCargo.toml2 authors = ["Danny Hua <danny@42layers.io>"]
/tonic/tests/stream_conflict/
H A DCargo.toml2 authors = ["Ben Sully <ben@bsull.io>"]
/tonic/tests/skip_debug/
H A DCargo.toml2 authors = ["Andrew Yuan <Andrew.Yuan@temporal.io>"]

123