Searched refs:RpcStatus (Results 1 – 5 of 5) sorted by relevance
| /external/rust/crates/grpcio/src/ |
| D | error.rs | 5 use crate::call::RpcStatus;
21 RpcFailure(RpcStatus),
23 RpcFinished(Option<RpcStatus>),
41 Error::RpcFailure(RpcStatus { status, details }) => match details { in fmt()
|
| D | lib.rs | 56 pub use crate::call::{MessageReader, Method, MethodType, RpcStatus, RpcStatusCode, WriteFlags};
|
| D | server.rs | 25 use crate::RpcStatus;
275 Abort(RpcStatus),
|
| /external/rust/crates/grpcio/src/call/ |
| D | mod.rs | 157 pub struct RpcStatus { struct
165 impl Display for RpcStatus { implementation
171 impl RpcStatus { impl
173 pub fn new<T: Into<RpcStatusCode>>(code: T, details: Option<String>) -> RpcStatus { in new() argument
174 RpcStatus { in new()
181 pub fn ok() -> RpcStatus { in ok()
182 RpcStatus::new(RpcStatusCode::OK, None) in ok()
214 pub fn rpc_status(&self) -> RpcStatus { in rpc_status() argument
233 RpcStatus::new(status, details) in rpc_status()
347 status: &RpcStatus, in start_send_status_from_server() argument
[all …]
|
| D | server.rs | 19 use super::{RpcStatus, ShareCall, ShareCallHolder, WriteFlags};
255 let status = RpcStatus::new(RpcStatusCode::INTERNAL, Some("No payload".to_owned())); in handle()
353 self.complete(RpcStatus::ok(), Some(t))
356 pub fn fail(self, status: RpcStatus) -> $rt {
360 fn complete(mut self, status: RpcStatus, t: Option<T>) -> $rt {
431 status: RpcStatus,
443 status: RpcStatus::ok(),
463 pub fn set_status(&mut self, status: RpcStatus) {
468 pub fn fail(mut self, status: RpcStatus) -> $ft {
706 let status = RpcStatus::new( in execute_unary()
[all …]
|