Home
last modified time | relevance | path

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

12

/third_party/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()
111 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(new Call… in DeadlineExceededStatusOnTimeout()
130 …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()
DServerBindFailedTest.cs74 catch (RpcException) in Issue18100()
/third_party/grpc/src/csharp/Grpc.Core.Api/
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
47 public RpcException(Status status, string message) : this(status, Metadata.Empty, message) in RpcException() method in Grpc.Core.RpcException
56 … public RpcException(Status status, Metadata trailers) : this(status, trailers, status.ToString()) in RpcException() method in Grpc.Core.RpcException
68 public RpcException(Status status, Metadata trailers, string message) : base(message) in RpcException() method in Grpc.Core.RpcException
/third_party/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.cs414 var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseAsync); in RunCancelAfterBeginAsync()
444 catch (RpcException ex) in RunCancelAfterFirstResponseAsync()
467 catch (RpcException) in RunTimeoutOnSleepingServerAsync()
477 catch (RpcException ex) in RunTimeoutOnSleepingServerAsync()
543 var e = Assert.Throws<RpcException>(() => client.UnaryCall(request)); in RunStatusCodeAndMessageAsync()
562 catch (RpcException e) in RunStatusCodeAndMessageAsync()
590 catch (RpcException e) in RunSpecialStatusMessageAsync()
602 var e = Assert.Throws<RpcException>(() => client.UnimplementedCall(new Empty())); in RunUnimplementedService()
611 var e = Assert.Throws<RpcException>(() => client.UnimplementedCall(new Empty())); in RunUnimplementedMethod()
629 …var e = Assert.Throws<RpcException>(() => client.UnaryCall(probeRequest, CreateClientCompressionMe… in RunClientCompressedUnary()
[all …]
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.cs119 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in UnaryCall()
133 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingCall()
145 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingFromClient()
158 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingFromServer()
171 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingBothWays()
DTestGrpc.cs149 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in EmptyCall()
160 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in UnaryCall()
173 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in CacheableUnaryCall()
186 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingOutputCall()
198 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in StreamingInputCall()
212 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in FullDuplexCall()
227 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in HalfDuplexCall()
239 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in UnimplementedCall()
655 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in UnimplementedCall()
819 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Start()
[all …]
DWorkerServiceGrpc.cs122 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in RunServer()
139 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in RunClient()
150 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in CoreCount()
161 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in QuitWorker()
DMetricsGrpc.cs104 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in GetAllGauges()
115 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in GetGauge()
/third_party/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()
/third_party/grpc/src/csharp/Grpc.Core.Tests/Internal/
DAsyncCallTest.cs224 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException()
245 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException2()
269 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteFailureThrowsRpcException3()
273 …var ex2 = Assert.ThrowsAsync<RpcException>(async () => await requestStream.WriteAsync("after call … in ClientStreaming_WriteFailureThrowsRpcException3()
293 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteAfterReceivingStatusThrowsRpcException()
311 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in ClientStreaming_WriteAfterReceivingStatusThrowsRpcException2()
506 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in DuplexStreaming_WriteAfterReceivingStatusThrowsRpcException()
543 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in DuplexStreaming_WriteFailureThrowsRpcException()
563 var ex = Assert.ThrowsAsync<RpcException>(async () => await writeTask); in DuplexStreaming_WriteFailureThrowsRpcException2()
682 var ex = Assert.ThrowsAsync<RpcException>(async () => await resultTask); in AssertUnaryResponseError()
[all …]
/third_party/grpc/src/csharp/Grpc.Core/Internal/
DServerCallHandler.cs76 if (!(e is RpcException)) in HandleCall()
133 if (!(e is RpcException)) in HandleCall()
191 if (!(e is RpcException)) in HandleCall()
247 if (!(e is RpcException)) in HandleCall()
298 var rpcException = e as RpcException; in GetStatusFromExceptionAndMergeTrailers()
DAsyncCall.cs426 return new RpcException(finishedStatus.Value.Status, finishedStatus.Value.Trailers); in GetRpcExceptionClientOnly()
445 … tcs.SetException(new RpcException(finishedStatus.Value.Status, finishedStatus.Value.Trailers)); in CheckSendAllowedOrEarlyResult()
584 unaryResponseTcs.SetException(new RpcException(status, receivedStatus.Trailers)); in HandleUnaryResponse()
630 … streamingResponseCallFinishedTcs.SetException(new RpcException(status, receivedStatus.Trailers)); in HandleFinished()
/third_party/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()
/third_party/grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs112 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Div()
127 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in DivMany()
141 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Fib()
153 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Sum()
/third_party/protobuf/python/google/protobuf/
Dservice.py46 class RpcException(Exception): class
/third_party/grpc/src/csharp/Grpc.HealthCheck.Tests/
DHealthServiceImplTest.cs62 var ex = Assert.Throws<RpcException>(() => GetStatusHelper(impl, "")); in ClearStatus()
75 Assert.Throws(typeof(RpcException), () => GetStatusHelper(impl, "")); in ClearAll()
76 … 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()
/third_party/grpc/src/csharp/Grpc.HealthCheck/
DHealthGrpc.cs99 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Check()
125 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, "")); in Watch()
/third_party/flutter/flutter/packages/flutter_tools/lib/src/
Dvmservice.dart124 throw rpc.RpcException.invalidParams('Invalid \'isolateId\': $isolateId');
126 throw rpc.RpcException.invalidParams('Invalid \'force\': $force');
128 throw rpc.RpcException.invalidParams('Invalid \'pause\': $pause');
133 } on rpc.RpcException {
136 throw rpc.RpcException(rpc_error_code.SERVER_ERROR,
154 throw rpc.RpcException.invalidParams('Invalid \'pause\': $pause');
159 } on rpc.RpcException {
162 throw rpc.RpcException(rpc_error_code.SERVER_ERROR,
179 throw rpc.RpcException.invalidParams(
183 throw rpc.RpcException.invalidParams(
[all …]

12