| /tonic/tests/integration_tests/proto/ |
| H A D | test.proto | 19 bytes buf = 1; field
22 bytes buf = 1; field
|
| /tonic/tonic/src/codec/ |
| H A D | buffer.rs | 7 buf: &'a mut BytesMut, field
14 buf: &'a mut BytesMut, field
116 let mut buf = DecodeBuf::new(&mut payload, 20); in decode_buf() localVariable
137 let mut buf = EncodeBuf::new(&mut bytes); in encode_buf() localVariable
|
| H A D | encode.rs | 29 buf: BytesMut, field
43 let buf = BytesMut::with_capacity(buffer_settings.buffer_size); in new() localVariable
201 let mut buf = &mut buf[..HEADER_SIZE]; in finish_encoding() localVariable
|
| H A D | prost.rs | 172 let mut buf = BytesMut::new(); in decode() localVariable
198 let mut buf = BytesMut::new(); in decode_max_message_size_exceeded() localVariable
|
| H A D | decode.rs | 30 buf: BytesMut, field
|
| /tonic/tonic-web/src/ |
| H A D | call.rs | 65 buf: BytesMut, field
292 let buf = me.as_mut().project().decoded; in poll_frame() localVariable
555 let buf = [ in find_trailers_non_buffered() localVariable
568 let buf = [ in find_trailers_buffered() localVariable
589 let buf = vec![ in find_trailers_buffered_incomplete_message() localVariable
626 let buf = std::fs::read("tests/incomplete-buf-bug.bin").unwrap(); in find_trailers_buffered_incomplete_buf_bug() localVariable
634 let buf = b"\x80\0\0\0\x0fgrpc-status:0\r\ngrpc-message:\r\na:1\r\nb:2\r\n"; in decode_multiple_trailers() localVariable
651 let buf = b"\x80\0\0\0\x0fgrpc-status: 0\r\ngrpc-message: \r\n"; in decode_trailers_with_space_after_colon() localVariable
|
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 29 let mut buf = std::io::BufReader::new(&fd); in main() localVariable
34 let mut buf = std::io::BufReader::new(&fd); in main() localVariable
|
| H A D | client.rs | 23 let mut buf = std::io::BufReader::new(&fd); in main() localVariable
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 93 let mut buf = BytesMut::with_capacity(1024); in encode_body() localVariable
103 let mut buf = &mut buf[..5]; in encode_body() localVariable
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | user_agent.rs | 17 let mut buf = Vec::new(); in new() localVariable
|
| /tonic/tonic-types/src/richer_error/std_messages/ |
| H A D | request_info.rs | 63 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | debug_info.rs | 60 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | loc_message.rs | 64 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | retry_info.rs | 75 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | resource_info.rs | 76 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | error_info.rs | 76 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | help.rs | 118 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | bad_request.rs | 122 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | quota_failure.rs | 119 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| H A D | prec_failure.rs | 142 let buf: &[u8] = &any.value; in from_any_ref() localVariable
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 114 let mut buf = BytesMut::new(); in make_payload() localVariable
|
| /tonic/tonic-types/src/richer_error/ |
| H A D | mod.rs | 44 let mut buf = BytesMut::with_capacity(status.encoded_len()); in gen_details_bytes() localVariable
|