Home
last modified time | relevance | path

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

12

/third_party/grpc/src/csharp/Grpc.Core.Tests/
DTimeoutsTest.cs67 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc")); in InfiniteDeadline()
70 …Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(new CallOptions(deadline: D… in InfiniteDeadline()
86 … Calls.BlockingUnaryCall(helper.CreateUnaryCall(new CallOptions(deadline: clientDeadline)), "abc"); in DeadlineTransferredToServer()
98 …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()
DClientServerTest.cs65 Assert.AreEqual("ABC", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "ABC")); in UnaryCall()
78 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerThrows()
93 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerThrowsRpcException()
111 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerThrowsRpcExceptionWithTrailers()
133 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerSetsStatus()
151 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_StatusDebugErrorStringNotTransmittedFromServer()
172 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerSetsStatusAndTrailers()
341 var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(callDetails, "abc")); in UnknownMethodHandler()
356 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in StatusDetailIsUtf8()
369 string peer = Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"); in ServerCallContext_PeerInfoPresent()
[all …]
DContextualMarshallerTest.cs94 Assert.AreEqual("ABC", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "ABC")); in UnaryCall()
105 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "REQU… in ResponseParsingError_UnaryResponse()
112 …Assert.Throws<IOException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "UNSERIALIZABLE… in RequestSerializationError_BlockingUnary()
118 …Assert.Throws<NullReferenceException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "SER… in SerializationResultIsNull_BlockingUnary()
DThreadingModelTest.cs59 … var response = Calls.BlockingUnaryCall(helper.CreateUnaryCall(), (recursionDepth - 1).ToString()); in BlockingCallInServerHandlerDoesNotDeadlock()
64 …Assert.AreEqual("SUCCESS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), maxRecursionDepth.ToS… in BlockingCallInServerHandlerDoesNotDeadlock()
78 Assert.AreEqual("ABC", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "ABC")); in HandlerDoesNotRunOnGrpcThread()
DCompressionTest.cs65 Calls.BlockingUnaryCall(helper.CreateUnaryCall(callOptions), "abc"); in WriteOptions_Unary()
128 …var response = Calls.BlockingUnaryCall(helper.CreateUnaryCall(new CallOptions(compressionMetadata)… in CanReadCompressedMessages()
148 …var response = Calls.BlockingUnaryCall(helper.CreateUnaryCall(new CallOptions(compressionMetadata)… in CanReadCompressedMessages_EmptyPayload()
DMarshallingErrorsTest.cs86 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "REQU… in ResponseParsingError_UnaryResponse()
112 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "UNPA… in RequestParsingError_UnaryRequest()
143 …Assert.Throws<IOException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "UNSERIALIZABLE… in RequestSerializationError_BlockingUnary()
DPerformanceTest.cs72 Calls.BlockingUnaryCall(callDetails, "ABC"); in UnaryCallPerformance()
79 Calls.BlockingUnaryCall(callDetails, "ABC"); in UnaryCallPerformance()
DUserAgentStringTest.cs64 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in DefaultUserAgentString()
84 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in ApplicationUserAgentString()
DResponseHeadersTest.cs147 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in WriteResponseHeaders_NullNotAllowed()
167 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in WriteResponseHeaders_AllowedOnlyOnce()
/third_party/grpc/src/csharp/Grpc.Core.Api/Interceptors/
DInterceptingCallInvoker.cs46 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho… in BlockingUnaryCall() method in Grpc.Core.Interceptors.InterceptingCallInvoker
48 return interceptor.BlockingUnaryCall( in BlockingUnaryCall()
51 (req, ctx) => invoker.BlockingUnaryCall(ctx.Method, ctx.Host, ctx.Options, req)); in BlockingUnaryCall()
DCallInvokerExtensions.cs117 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(TRequest request, ClientIntercept… in BlockingUnaryCall() method in Grpc.Core.Interceptors.CallInvokerExtensions.MetadataInterceptor
DInterceptor.cs176 …public virtual TResponse BlockingUnaryCall<TRequest, TResponse>(TRequest request, ClientIntercepto…
/third_party/grpc/src/csharp/Grpc.Core/
DDefaultCallInvoker.cs44 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho… in BlockingUnaryCall() method in Grpc.Core.DefaultCallInvoker
47 return Calls.BlockingUnaryCall(call, request); in BlockingUnaryCall()
DCalls.cs41 …public static TResponse BlockingUnaryCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRe…
/third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DServerInterceptorTest.cs55 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in AddRequestHeaderInServerInterceptor()
76 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in VerifyInterceptorOrdering()
124 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in UserStateVisibleToAllInterceptors()
DClientInterceptorTest.cs58 …Assert.AreEqual("PASS", callInvoker.BlockingUnaryCall(new Method<string, string>(MethodType.Unary,… in AddRequestHeaderInClientInterceptor()
87 …Assert.AreEqual("PASS", callInvoker.BlockingUnaryCall(new Method<string, string>(MethodType.Unary,… in CheckInterceptorOrderInClientInterceptors()
142 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(TRequest request, ClientIntercept… in BlockingUnaryCall() method in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.CallbackInterceptor
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DTestGrpc.cs287 return CallInvoker.BlockingUnaryCall(__Method_EmptyCall, null, options, request); in EmptyCall()
331 return CallInvoker.BlockingUnaryCall(__Method_UnaryCall, null, options, request); in UnaryCall()
379 return CallInvoker.BlockingUnaryCall(__Method_CacheableUnaryCall, null, options, request); in CacheableUnaryCall()
525 return CallInvoker.BlockingUnaryCall(__Method_UnimplementedCall, null, options, request); in UnimplementedCall()
703 return CallInvoker.BlockingUnaryCall(__Method_UnimplementedCall, null, options, request); in UnimplementedCall()
858 return CallInvoker.BlockingUnaryCall(__Method_Start, null, options, request); in Start()
874 return CallInvoker.BlockingUnaryCall(__Method_Stop, null, options, request); in Stop()
1044 return CallInvoker.BlockingUnaryCall(__Method_GetClientStats, null, options, request); in GetClientStats()
1088 … return CallInvoker.BlockingUnaryCall(__Method_GetClientAccumulatedStats, null, options, request); in GetClientAccumulatedStats()
1243 return CallInvoker.BlockingUnaryCall(__Method_SetServing, null, options, request); in SetServing()
[all …]
/third_party/grpc/src/csharp/Grpc.Core.Api/
DCallInvoker.cs31 …public abstract TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho…
/third_party/grpc/src/csharp/Grpc.Core/Internal/
DUnimplementedCallInvoker.cs35 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho… in BlockingUnaryCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/third_party/grpc/src/csharp/Grpc.Core.Api/Internal/
DUnimplementedCallInvoker.cs35 …public override TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho… in BlockingUnaryCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/third_party/grpc/src/csharp/Grpc.Microbenchmarks/
DPingBenchmark.cs98 return CallInvoker.BlockingUnaryCall(PingMethod, null, options, request); in Ping()
DUnaryCallOverheadBenchmark.cs100 return CallInvoker.BlockingUnaryCall(PingMethod, null, options, request); in Ping()
/third_party/grpc/include/grpcpp/impl/codegen/
Dclient_unary_call.h43 Status BlockingUnaryCall(ChannelInterface* channel, const RpcMethod& method, in BlockingUnaryCall() function
/third_party/grpc/examples/csharp/HelloworldUnity/Assets/Scripts/
DHelloworldGrpc.cs109 return CallInvoker.BlockingUnaryCall(__Method_SayHello, null, options, request); in SayHello()
/third_party/grpc/examples/csharp/HelloworldXamarin/HelloworldXamarin/
DHelloworldGrpc.cs109 return CallInvoker.BlockingUnaryCall(__Method_SayHello, null, options, request); in SayHello()

12