| /tonic/tonic-reflection/src/server/ |
| H A D | mod.rs | 140 let name = match fd.name.clone() { in new()
152 state.files.insert(name, fd.clone()); in new()
165 let prefix = &fd.package.clone().unwrap_or_default(); in process_file()
168 self.process_message(fd.clone(), prefix, msg)?; in process_file()
172 self.process_enum(fd.clone(), prefix, en)?; in process_file()
180 self.symbols.insert(service_name.clone(), fd.clone()); in process_file()
184 self.symbols.insert(method_name, fd.clone()); in process_file()
198 self.symbols.insert(message_name.clone(), fd.clone()); in process_message()
214 self.symbols.insert(oneof_name, fd.clone()); in process_message()
227 self.symbols.insert(enum_name.clone(), fd.clone()); in process_enum()
[all …]
|
| H A D | v1alpha.rs | 33 let state = self.state.clone(); in server_reflection_info()
41 let resp_msg = match req.message_request.clone() { in server_reflection_info()
71 .map(|s| ServiceResponse { name: s.clone() }) in server_reflection_info()
81 valid_host: req.host.clone(), in server_reflection_info()
82 original_request: Some(req.clone()), in server_reflection_info()
|
| H A D | v1.rs | 33 let state = self.state.clone(); in server_reflection_info()
41 let resp_msg = match req.message_request.clone() { in server_reflection_info()
71 .map(|s| ServiceResponse { name: s.clone() }) in server_reflection_info()
81 valid_host: req.host.clone(), in server_reflection_info()
82 original_request: Some(req.clone()), in server_reflection_info()
|
| /tonic/tests/compression/src/ |
| H A D | bidirectional_stream.rs | 48 let request_bytes_counter = request_bytes_counter.clone(); in client_enabled_server_enabled()
49 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_enabled()
55 AssertRightEncoding::new(encoding).clone().call(req) in client_enabled_server_enabled()
58 request_bytes_counter.clone(), in client_enabled_server_enabled()
63 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()
80 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
|
| H A D | client_stream.rs | 45 let request_bytes_counter = request_bytes_counter.clone(); in client_enabled_server_enabled()
51 AssertRightEncoding::new(encoding).clone().call(req) in client_enabled_server_enabled()
54 request_bytes_counter.clone(), in client_enabled_server_enabled()
69 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_enabled()
99 let request_bytes_counter = request_bytes_counter.clone(); in client_disabled_server_enabled()
106 request_bytes_counter.clone(), in client_disabled_server_enabled()
120 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_disabled_server_enabled()
154 let stream = tokio_stream::iter(vec![SomeData { data: data.clone() }, SomeData { data }]); in client_enabled_server_disabled()
191 let response_bytes_counter = response_bytes_counter.clone(); in compressing_response_from_client_stream()
199 counter: response_bytes_counter.clone(), in compressing_response_from_client_stream()
|
| H A D | server_stream.rs | 21 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_enabled()
29 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()
86 let response_bytes_counter = response_bytes_counter.clone(); in client_disabled_server_enabled()
94 counter: response_bytes_counter.clone(), in client_disabled_server_enabled()
138 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled()
146 counter: response_bytes_counter.clone(), in client_enabled_server_disabled()
|
| H A D | compressing_response.rs | 60 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_enabled()
72 counter: response_bytes_counter.clone(), in client_enabled_server_enabled()
118 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled()
127 counter: response_bytes_counter.clone(), in client_enabled_server_disabled()
159 let response_bytes_counter = response_bytes_counter.clone(); in client_enabled_server_disabled_multi_encoding()
168 counter: response_bytes_counter.clone(), in client_enabled_server_disabled_multi_encoding()
233 let response_bytes_counter = response_bytes_counter.clone(); in client_disabled()
242 counter: response_bytes_counter.clone(), in client_disabled()
327 let response_bytes_counter = response_bytes_counter.clone(); in disabling_compression_on_single_response()
385 let response_bytes_counter = response_bytes_counter.clone(); in disabling_compression_on_response_but_keeping_compression_on_stream()
[all …]
|
| /tonic/tonic/src/transport/channel/service/ |
| H A D | connection.rs | 35 let mut settings: Builder<SharedExec> = Builder::new(endpoint.executor.clone()) in new()
40 .clone(); in new()
60 let origin = endpoint.origin.as_ref().unwrap_or(&endpoint.uri).clone(); in new()
64 .layer_fn(|s| UserAgent::new(s, endpoint.user_agent.clone())) in new()
71 MakeSendRequestService::new(connector, endpoint.executor.clone(), settings); in new()
73 let conn = Reconnect::new(make_service, endpoint.uri.clone(), is_lazy); in new()
191 let builder = self.settings.clone(); in call()
192 let executor = self.executor.clone(); in call()
|
| H A D | add_origin.rs | 57 uri.scheme = self.scheme.clone(); in call()
58 uri.authority = self.authority.clone(); in call()
|
| /tonic/tonic/src/transport/server/service/ |
| H A D | io.rs | 30 ConnectInfo::new(inner, self.connect_info.clone()) in layer()
63 match self.connect_info.clone() { in call()
69 req.extensions_mut().insert(inner.get_ref().clone()); in call()
90 fn clone(&self) -> Self { in clone() method
92 Self::Io(io) => Self::Io(io.clone()), in clone()
94 Self::TlsIo(io) => Self::TlsIo(io.clone()), in clone()
|
| /tonic/tonic/benches-disabled/benchmarks/compiled_protos/ |
| H A D | helloworld.rs | 65 fn clone(&self) -> Self { in clone() method
67 inner: self.inner.clone(), in clone()
120 ok(GreeterServerSvc::new(self.inner.clone())) in call()
131 let inner = self.inner.clone(); in call()
142 let inner = Arc::clone(&self.0); in call()
147 let inner = self.inner.clone(); in call()
|
| /tonic/examples/src/tls_rustls/ |
| H A D | server.rs | 61 let http = http.clone(); in main()
62 let tls_acceptor = tls_acceptor.clone(); in main()
63 let svc = svc.clone(); in main()
72 certificates.push(cert.clone()); in main()
|
| /tonic/examples/src/tower/ |
| H A D | client.rs | 72 let clone = self.inner.clone(); in call() localVariable
73 let mut inner = std::mem::replace(&mut self.inner, clone); in call()
|
| H A D | server.rs | 99 let clone = self.inner.clone(); in call() localVariable
100 let mut inner = std::mem::replace(&mut self.inner, clone); in call()
|
| /tonic/tonic/src/transport/channel/ |
| H A D | endpoint.rs | 325 self.tls.clone(), in connector()
351 Channel::connect(self.http_connector(), self.clone()).await in connect()
359 Channel::new(self.http_connector(), self.clone()) in connect_lazy()
381 Channel::connect(connector, self.clone()).await in connect_with_connector()
383 Channel::connect(connector, self.clone()).await in connect_with_connector()
405 Channel::new(connector, self.clone()) in connect_with_connector_lazy()
407 Channel::new(connector, self.clone()) in connect_with_connector_lazy()
|
| /tonic/tonic-build/src/ |
| H A D | server.rs | 40 server_trait.clone(), in generate_internal()
179 fn clone(&self) -> Self { in generate_internal()
399 ident.clone(), in generate_methods()
408 ident.clone(), in generate_methods()
417 ident.clone(), in generate_methods()
464 let inner = Arc::clone(&self.0); in generate_unary()
476 let inner = self.inner.clone(); in generate_unary()
531 let inner = Arc::clone(&self.0); in generate_server_streaming()
543 let inner = self.inner.clone(); in generate_server_streaming()
601 let inner = self.inner.clone(); in generate_client_streaming()
[all …]
|
| H A D | prost.rs | 87 prost_method: prost_method.clone(), in new()
88 settings: settings.clone(), in new()
227 .attributes(self.builder.server_attributes.clone()) in generate()
228 .disable_comments(self.builder.disable_comments.clone()) in generate()
232 &TonicBuildService::new(service.clone(), self.builder.compile_settings.clone()), in generate()
243 .attributes(self.builder.client_attributes.clone()) in generate()
244 .disable_comments(self.builder.disable_comments.clone()) in generate()
247 &TonicBuildService::new(service, self.builder.compile_settings.clone()), in generate()
|
| /tonic/examples/src/routeguide/ |
| H A D | server.rs | 32 return Ok(Response::new(feature.clone())); in get_feature()
48 let features = self.features.clone(); in list_features()
54 tx.send(Ok(feature.clone())).await.unwrap(); in list_features()
125 yield note.clone(); in route_chat()
|
| /tonic/tests/integration_tests/tests/ |
| H A D | max_message_size.rs | 141 let stream = tokio_stream::iter(vec![Ok(blob.clone()), Ok(blob.clone())]); in response_stream_limit()
181 buf: client_blob.clone(), in response_stream_limit()
286 buf: self.0.clone(), in max_message_run()
357 buf: client_blob.clone(), in max_message_run()
|
| H A D | extensions.rs | 143 let clone = self.inner.clone(); in call() localVariable
144 let mut inner = std::mem::replace(&mut self.inner, clone); in call()
|
| /tonic/tests/web/tests/ |
| H A D | grpc.rs | 81 c1.unary_call(boom.clone()), in smoke_error()
82 c2.unary_call(boom.clone()), in smoke_error()
83 c3.unary_call(boom.clone()), in smoke_error()
84 c4.unary_call(boom.clone()), in smoke_error()
|
| /tonic/interop/ |
| H A D | update_binaries.sh | 16 git clone https://github.com/grpc/grpc-go.git
|
| /tonic/tonic-health/src/generated/ |
| H A D | grpc_health_v1.rs | 345 let inner = Arc::clone(&self.0); in call()
356 let inner = self.inner.clone(); in call()
391 let inner = Arc::clone(&self.0); in call()
402 let inner = self.inner.clone(); in call()
443 fn clone(&self) -> Self { in clone() method
444 let inner = self.inner.clone(); in clone()
|
| /tonic/tonic/src/client/ |
| H A D | grpc.rs | 250 status.metadata_mut().merge(parts.clone()); in client_streaming()
373 let mut parts = self.origin.clone().into_parts(); in prepare_request()
430 fn clone(&self) -> Self { in clone() method
432 inner: self.inner.clone(), in clone()
434 origin: self.config.origin.clone(), in clone()
|
| /tonic/tests/ambiguous_methods/proto/ |
| H A D | ambiguous_methods.proto | 8 // The generated stubs can confuse drop and clone
|