Searched refs:msg (Results 1 – 10 of 10) sorted by relevance
| /tonic/tonic/src/codec/ |
| H A D | prost.rs | 170 let msg = vec![0u8; LEN]; in decode() localVariable
174 buf.reserve(msg.len() + HEADER_SIZE); in decode()
176 buf.put_u32(msg.len() as u32); in decode()
178 buf.put(&msg[..]); in decode()
196 let msg = vec![0u8; MAX_MESSAGE_SIZE + 1]; in decode_max_message_size_exceeded() localVariable
200 buf.reserve(msg.len() + HEADER_SIZE); in decode_max_message_size_exceeded()
202 buf.put_u32(msg.len() as u32); in decode_max_message_size_exceeded()
204 buf.put(&msg[..]); in decode_max_message_size_exceeded()
214 msg.len(), in decode_max_message_size_exceeded()
226 let msg = Vec::from(&[0u8; 1024][..]); in encode() localVariable
[all …]
|
| H A D | decode.rs | 375 Some(msg) => { in decode_chunk()
377 Ok(Some(msg)) in decode_chunk()
|
| /tonic/tonic/benches/ |
| H A D | decode.rs | 30 while let Some(msg) = stream.message().await.unwrap() {
31 assert_eq!($message_size, msg.len());
117 let msg = vec![97u8; message_length]; in make_payload() localVariable
118 buf.reserve(msg.len() + 5); in make_payload()
120 buf.put_u32(msg.len() as u32); in make_payload()
121 buf.put(&msg[..]); in make_payload()
|
| /tonic/tonic-reflection/src/server/ |
| H A D | mod.rs | 167 for msg in &fd.message_type { in process_file()
168 self.process_message(fd.clone(), prefix, msg)?; in process_file()
195 msg: &DescriptorProto, in process_message()
197 let message_name = extract_name(prefix, "message", msg.name.as_ref())?; in process_message()
200 for nested in &msg.nested_type { in process_message()
204 for en in &msg.enum_type { in process_message()
208 for field in &msg.field { in process_message()
212 for oneof in &msg.oneof_decl { in process_message()
|
| H A D | v1alpha.rs | 43 Some(msg) => match msg { in server_reflection_info()
|
| H A D | v1.rs | 43 Some(msg) => match msg { in server_reflection_info()
|
| /tonic/interop/src/ |
| H A D | server.rs | 93 while let Some(msg) = stream.try_next().await? { in streaming_input_call()
94 aggregated_payload_size += msg.payload.unwrap().body.len() as i32; in streaming_input_call()
122 while let Some(msg) = stream.try_next().await? { in full_duplex_call()
123 if let Some(echo_status) = msg.response_status { in full_duplex_call()
128 for param in msg.response_parameters { in full_duplex_call()
|
| /tonic/tests/web/tests/ |
| H A D | grpc_web.rs | 150 let msg = Output::decode(&mut body.split_to(len as usize)).expect("decode"); in decode_body() localVariable
153 (msg, body) in decode_body()
|
| /tonic/tonic/src/service/ |
| H A D | interceptor.rs | 139 let (metadata, extensions, msg) = req.into_parts(); in call()
147 let req = crate::Request::from_parts(metadata, extensions, msg); in call()
|
| /tonic/tonic/src/ |
| H A D | status.rs | 768 let msg = format!( in infer_grpc_status() localVariable
772 let status = Status::new(code, msg); in infer_grpc_status()
|