diff options
| author | Joel Galenson <jgalenson@google.com> | 2021-06-21 12:42:49 -0700 |
|---|---|---|
| committer | Joel Galenson <jgalenson@google.com> | 2021-06-21 12:42:49 -0700 |
| commit | 8e8acbd61c224df38a367a9cdd30075966860bf9 (patch) | |
| tree | 657ca28347ca6d074f482a3191123b68375bce20 /src/call/server.rs | |
| parent | 3adce0c03a69c88fc538ff74a98a8a74019819d5 (diff) | |
| download | grpcio-8e8acbd61c224df38a367a9cdd30075966860bf9.tar.gz | |
Upgrade rust/crates/grpcio to 0.9.0android-s-beta-5android-s-beta-4android-s-beta-3android-s-beta-5android-s-beta-4
Test: make
Change-Id: I05fd19472fbf556926a0145466f45235e089ab9f
Diffstat (limited to 'src/call/server.rs')
| -rw-r--r-- | src/call/server.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/call/server.rs b/src/call/server.rs index 0fed656..58c63bf 100644 --- a/src/call/server.rs +++ b/src/call/server.rs @@ -252,7 +252,7 @@ impl UnaryRequestContext { return execute(self.request, cq, reader, handler, checker); } - let status = RpcStatus::new(RpcStatusCode::INTERNAL, Some("No payload".to_owned())); + let status = RpcStatus::with_message(RpcStatusCode::INTERNAL, "No payload".to_owned()); self.request.call(cq.clone()).abort(&status) } } @@ -703,9 +703,9 @@ pub fn execute_unary<P, Q, F>( let request = match de(payload) { Ok(f) => f, Err(e) => { - let status = RpcStatus::new( + let status = RpcStatus::with_message( RpcStatusCode::INTERNAL, - Some(format!("Failed to deserialize response message: {:?}", e)), + format!("Failed to deserialize response message: {:?}", e), ); call.abort(&status); return; @@ -749,9 +749,9 @@ pub fn execute_server_streaming<P, Q, F>( let request = match de(payload) { Ok(t) => t, Err(e) => { - let status = RpcStatus::new( + let status = RpcStatus::with_message( RpcStatusCode::INTERNAL, - Some(format!("Failed to deserialize response message: {:?}", e)), + format!("Failed to deserialize response message: {:?}", e), ); call.abort(&status); return; @@ -786,7 +786,7 @@ pub fn execute_unimplemented(ctx: RequestContext, cq: CompletionQueue) { let ctx = ctx; let mut call = ctx.call(cq); accept_call!(call); - call.abort(&RpcStatus::new(RpcStatusCode::UNIMPLEMENTED, None)) + call.abort(&RpcStatus::new(RpcStatusCode::UNIMPLEMENTED)) } // Helper function to call handler. |