| /tonic/tonic/src/transport/channel/service/ |
| H A D | reconnect.rs | 18 state: State<M::Future, M::Response>, field
40 state: State::Idle, in new()
63 let mut state; in poll_ready() localVariable
70 match self.state { in poll_ready()
82 self.state = State::Connecting(fut); in poll_ready()
89 state = State::Connected(service); in poll_ready()
98 state = State::Idle; in poll_ready()
127 state = State::Idle; in poll_ready()
133 self.state = state; in poll_ready()
136 self.state = state; in poll_ready()
[all …]
|
| /tonic/tonic-reflection/src/server/ |
| H A D | v1alpha.rs | 19 state: Arc<ReflectionServiceState>, field
33 let state = self.state.clone(); in server_reflection_info() localVariable
44 MessageRequest::FileByFilename(s) => state.file_by_filename(&s).map(|fd| { in server_reflection_info()
50 state.symbol_by_name(&s).map(|fd| { in server_reflection_info()
68 service: state in server_reflection_info()
100 fn from(state: ReflectionServiceState) -> Self { in from()
102 state: Arc::new(state), in from()
|
| H A D | v1.rs | 19 state: Arc<ReflectionServiceState>, field
33 let state = self.state.clone(); in server_reflection_info() localVariable
44 MessageRequest::FileByFilename(s) => state.file_by_filename(&s).map(|fd| { in server_reflection_info()
50 state.symbol_by_name(&s).map(|fd| { in server_reflection_info()
68 service: state in server_reflection_info()
100 fn from(state: ReflectionServiceState) -> Self { in from()
102 state: Arc::new(state), in from()
|
| H A D | mod.rs | 132 let mut state = ReflectionServiceState { in new() localVariable
147 if state.files.contains_key(&name) { in new()
152 state.files.insert(name, fd.clone()); in new()
153 state.process_file(fd, use_all_service_names)?; in new()
157 Ok(state) in new()
|
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 28 state: State, field
134 state: State::ReadHeader, in new()
151 if let State::ReadHeader = self.state { in decode_chunk()
200 self.state = State::ReadBody { in decode_chunk()
206 if let State::ReadBody { len, compression } = self.state { in decode_chunk()
256 let _ = std::mem::replace(&mut self.state, State::Error(Some(status.clone()))); in poll_frame()
263 trace!("unexpected EOF decoding stream, state: {:?}", self.state); in poll_frame()
376 self.inner.state = State::ReadHeader; in decode_chunk()
394 if let State::Error(status) = &mut self.inner.state { in poll_next()
|
| H A D | encode.rs | 221 state: EncodeState, field
248 state: EncodeState { in new_client()
273 state: EncodeState { in new_server()
312 self.state.is_end_stream in is_end_stream()
322 Some(Err(status)) => match self_proj.state.role { in poll_frame()
325 self_proj.state.is_end_stream = true; in poll_frame()
330 .state in poll_frame()
|
| /tonic/tonic/src/transport/server/ |
| H A D | io_stream.rs | 33 state: Option<State<IO>>, field
44 state: tls.map(|tls| State(tls, JoinSet::new())), in new()
86 let Some(State(tls, tasks)) = projected.state else { in poll_next()
|
| /tonic/tonic/src/metadata/ |
| H A D | value.rs | 613 fn hash<H: Hasher>(&self, state: &mut H) { in hash()
614 self.inner.hash(state) in hash()
619 fn hash<H: Hasher>(&self, state: &mut H) { in hash()
621 Ok(b) => b.hash(state), in hash()
622 Err(e) => e.hash(state), in hash()
|
| /tonic/examples/proto/googleapis/google/pubsub/v1/ |
| H A D | pubsub.proto | 104 // state captured by a snapshot.
540 // is, you can set the acknowledgment state of messages in an existing
541 // subscription to the state captured by a snapshot.
553 // state captured by a snapshot.
565 // state captured by a snapshot.
589 // acknowledgment state of messages in an existing subscription to the state
602 // state captured by a snapshot.
619 // state captured by a snapshot. Note that both the subscription and the
1116 // to the same value so that state associated with the old stream can be
1199 // is, you can set the acknowledgment state of messages in an existing
[all …]
|
| /tonic/examples/proto/googleapis/google/api/ |
| H A D | field_behavior.proto | 34 // State state = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
|
| H A D | resource.proto | 155 // A description of the historical or future-looking state of the
224 // Optional. The historical or future-looking state of the resource pattern.
|
| /tonic/examples/ |
| H A D | routeguide-tutorial.md | 313 ### Server state
315 deserialize them from a json file and keep them around as our only piece of shared state:
346 fn hash<H>(&self, state: &mut H)
350 self.latitude.hash(state);
351 self.longitude.hash(state);
614 needs to manage internal state.
|
| /tonic/ |
| H A D | README.md | 87 Unless you explicitly state otherwise, any contribution intentionally submitted
|