Home
last modified time | relevance | path

Searched refs:RpcException (Results 1 – 25 of 34) sorted by relevance

12

/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DClientServerTest.cs78 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerThrows()
81 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrows()
90 throw new RpcException(new Status(StatusCode.Unauthenticated, "")); in UnaryCall_ServerHandlerThrowsRpcException()
93 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerThrowsRpcException()
97 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrowsRpcException()
108 throw new RpcException(new Status(StatusCode.Unauthenticated, ""), trailers); in UnaryCall_ServerHandlerThrowsRpcExceptionWithTrailers()
111 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerThrowsRpcExceptionWithTrailers()
117 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerThrowsRpcExceptionWithTrailers()
133 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerSetsStatus()
137 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await Calls.AsyncUnaryCall(helper.CreateUna… in UnaryCall_ServerHandlerSetsStatus()
[all …]
DCallCancellationTest.cs81 catch (RpcException ex) in ClientStreamingCall_CancelAfterBegin()
118 catch (RpcException ex) in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
144 catch (RpcException ex) in ClientStreamingCall_CancelServerSideRead()
176 catch (RpcException ex) in ServerStreamingCall_CancelClientSideRead()
DTimeoutsTest.cs98 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(new Call… in DeadlineInThePast()
112 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(new Call… in DeadlineExceededStatusOnTimeout()
132 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(new Call… in ServerReceivesCancellationOnTimeout()
DMarshallingErrorsTest.cs86 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "REQU… in ResponseParsingError_UnaryResponse()
100 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ResponseParsingError_StreamingResponse()
112 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "UNPA… in RequestParsingError_UnaryRequest()
DContextPropagationTest.cs82 catch(RpcException) in PropagateCancellation()
99 catch (RpcException) in PropagateCancellation()
/external/grpc-grpc/src/csharp/Grpc.Core/
DRpcException.cs27 public class RpcException : Exception class
36 public RpcException(Status status) : this(status, Metadata.Empty, status.ToString()) in RpcException() method in Grpc.Core.RpcException
45 public RpcException(Status status, string message) : this(status, Metadata.Empty, message) in RpcException() method in Grpc.Core.RpcException
54 … public RpcException(Status status, Metadata trailers) : this(status, trailers, status.ToString()) in RpcException() method in Grpc.Core.RpcException
64 public RpcException(Status status, Metadata trailers, string message) : base(message) in RpcException() method in Grpc.Core.RpcException
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DGeneratedServiceBaseTest.cs63 var ex = Assert.Throws<RpcException>(() => client.UnaryCall(new SimpleRequest { })); in UnimplementedByDefault_Unary()
72 var ex = Assert.ThrowsAsync<RpcException>(async () => await call); in UnimplementedByDefault_ClientStreaming()
81 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in UnimplementedByDefault_ServerStreamingCall()
90 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in UnimplementedByDefault_DuplexStreamingCall()
DInteropClient.cs411 var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseAsync); in RunCancelAfterBeginAsync()
441 catch (RpcException ex) in RunCancelAfterFirstResponseAsync()
464 catch (RpcException) in RunTimeoutOnSleepingServerAsync()
474 catch (RpcException ex) in RunTimeoutOnSleepingServerAsync()
541 var e = Assert.Throws<RpcException>(() => client.UnaryCall(request)); in RunStatusCodeAndMessageAsync()
560 catch (RpcException e) in RunStatusCodeAndMessageAsync()
573 var e = Assert.Throws<RpcException>(() => client.UnimplementedCall(new Empty())); in RunUnimplementedService()
582 var e = Assert.Throws<RpcException>(() => client.UnimplementedCall(new Empty())); in RunUnimplementedMethod()
600 …var e = Assert.Throws<RpcException>(() => client.UnaryCall(probeRequest, CreateClientCompressionMe… in RunClientCompressedUnary()
649 catch (RpcException e) in RunClientCompressedStreamingAsync()
DCustomErrorDetailsTest.cs77 catch (RpcException e) in ErrorDetailsFromCallObject()
94 catch (RpcException e) in ErrorDetailsFromRpcException()
124 … throw new RpcException(new Status(StatusCode.Unknown, "The handler threw exception.")); in UnaryCall()
DBenchmarkServiceGrpc.cs88 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in UnaryCall()
102 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingCall()
114 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingFromClient()
127 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingFromServer()
140 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingBothWays()
DTestGrpc.cs118 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in EmptyCall()
129 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in UnaryCall()
142 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in CacheableUnaryCall()
155 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingOutputCall()
167 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingInputCall()
181 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in FullDuplexCall()
196 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in HalfDuplexCall()
208 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in UnimplementedCall()
577 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in UnimplementedCall()
701 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Start()
[all …]
DWorkerServiceGrpc.cs91 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in RunServer()
108 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in RunClient()
119 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in CoreCount()
130 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in QuitWorker()
DMetricsGrpc.cs73 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in GetAllGauges()
84 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in GetGauge()
DMetadataCredentialsTest.cs148 var ex = Assert.Throws<RpcException>(() => client.UnaryCall(new SimpleRequest { })); in MetadataCredentials_InterceptorLeavesMetadataEmpty()
165 var ex = Assert.Throws<RpcException>(() => client.UnaryCall(new SimpleRequest { })); in MetadataCredentials_InterceptorThrows()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/
DAsyncCallTest.cs220 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException()
241 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException2()
265 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException3()
269 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await requestStream.WriteAsync("after call … in ClientStreaming_WriteFailureThrowsRpcException3()
289 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteAfterReceivingStatusThrowsRpcException()
307 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteAfterReceivingStatusThrowsRpcException2()
502 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in DuplexStreaming_WriteAfterReceivingStatusThrowsRpcException()
539 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in DuplexStreaming_WriteFailureThrowsRpcException()
559 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in DuplexStreaming_WriteFailureThrowsRpcException2()
673 var ex = Assert.ThrowsAsync<RpcException>(async () => await resultTask); in AssertUnaryResponseError()
[all …]
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideClient/
DProgram.cs61 catch (RpcException e) in GetFeature()
98 catch (RpcException e) in ListFeatures()
140 catch (RpcException e) in RecordRoute()
189 catch (RpcException e) in RouteChat()
/external/grpc-grpc/src/csharp/Grpc.HealthCheck.Tests/
DHealthServiceImplTest.cs60 var ex = Assert.Throws<RpcException>(() => GetStatusHelper(impl, "")); in ClearStatus()
73 Assert.Throws(typeof(RpcException), () => GetStatusHelper(impl, "")); in ClearAll()
74 … Assert.Throws(typeof(RpcException), () => GetStatusHelper(impl, "grpc.test.TestService")); in ClearAll()
DHealthClientServerTest.cs77 …var ex = Assert.Throws<RpcException>(() => client.Check(new HealthCheckRequest { Service = "nonexi… in ServiceDoesntExist()
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs81 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Div()
96 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in DivMany()
110 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Fib()
122 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Sum()
/external/grpc-grpc/src/csharp/Grpc.Examples.Tests/
DMathClientServerTests.cs80 … var ex = Assert.Throws<RpcException>(() => client.Div(new DivArgs { Dividend = 0, Divisor = 0 })); in DivByZero()
124 catch (RpcException e) in FibWithCancel()
138 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.ToListAsync()); in FibWithDeadline()
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DServerCallHandler.cs77 if (!(e is RpcException)) in HandleCall()
139 if (!(e is RpcException)) in HandleCall()
202 if (!(e is RpcException)) in HandleCall()
263 if (!(e is RpcException)) in HandleCall()
324 var rpcException = e as RpcException; in GetStatusFromExceptionAndMergeTrailers()
DAsyncCall.cs422 return new RpcException(finishedStatus.Value.Status, finishedStatus.Value.Trailers); in GetRpcExceptionClientOnly()
441 … tcs.SetException(new RpcException(finishedStatus.Value.Status, finishedStatus.Value.Trailers)); in CheckSendAllowedOrEarlyResult()
584 unaryResponseTcs.SetException(new RpcException(status, receivedStatus.Trailers)); in HandleUnaryResponse()
628 … streamingResponseCallFinishedTcs.SetException(new RpcException(status, receivedStatus.Trailers)); in HandleFinished()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/
DRouteGuideGrpc.cs89 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in GetFeature()
106 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in ListFeatures()
120 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in RecordRoute()
135 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in RouteChat()
/external/protobuf/python/google/protobuf/
Dservice.py46 class RpcException(Exception): class
/external/grpc-grpc/src/csharp/Grpc.HealthCheck/
DHealthServiceImpl.cs97 throw new RpcException(new Status(StatusCode.NotFound, "")); in Check()

12