Home
last modified time | relevance | path

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

12

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service_impl.cc82 return ::grpc::internal::BlockingUnaryCall( in CreateSession()
89 return ::grpc::internal::BlockingUnaryCall( in ExtendSession()
96 return ::grpc::internal::BlockingUnaryCall( in PartialRunSetup()
103 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RunStep_, in RunStep()
110 return ::grpc::internal::BlockingUnaryCall( in CloseSession()
117 return ::grpc::internal::BlockingUnaryCall( in ListDevices()
124 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Reset_, in Reset()
131 return ::grpc::internal::BlockingUnaryCall( in MakeCallable()
138 return ::grpc::internal::BlockingUnaryCall( in RunCallable()
145 return ::grpc::internal::BlockingUnaryCall( in ReleaseCallable()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service.cc73 return ::grpc::internal::BlockingUnaryCall( in CreateContext()
80 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Enqueue_, in Enqueue()
87 return ::grpc::internal::BlockingUnaryCall( in WaitQueueDone()
94 return ::grpc::internal::BlockingUnaryCall( in KeepAlive()
101 return ::grpc::internal::BlockingUnaryCall( in CloseContext()
108 return ::grpc::internal::BlockingUnaryCall( in RegisterFunction()
115 return ::grpc::internal::BlockingUnaryCall( in SendTensor()
/external/grpc-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()
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()
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()
152 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in UnaryCall_ServerHandlerSetsStatusAndTrailers()
321 var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(callDetails, "abc")); in UnknownMethodHandler()
336 …var ex = Assert.Throws<RpcException>(() => Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"… in StatusDetailIsUtf8()
349 string peer = Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc"); in ServerCallContext_PeerInfoPresent()
362 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "abc")); in ServerCallContext_HostAndMethodPresent()
[all …]
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()
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()
DCompressionTest.cs65 Calls.BlockingUnaryCall(helper.CreateUnaryCall(callOptions), "abc"); in WriteOptions_Unary()
128 …var response = Calls.BlockingUnaryCall(helper.CreateUnaryCall(new CallOptions(compressionMetadata)… in CanReadCompressedMessages()
DResponseHeadersTest.cs147 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in WriteResponseHeaders_NullNotAllowed()
167 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in WriteResponseHeaders_AllowedOnlyOnce()
/external/grpc-grpc/src/csharp/Grpc.Core/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
/external/grpc-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()
DCallInvoker.cs33 …public abstract TResponse BlockingUnaryCall<TRequest, TResponse>(Method<TRequest, TResponse> metho…
DCalls.cs40 …public static TResponse BlockingUnaryCall<TRequest, TResponse>(CallInvocationDetails<TRequest, TRe…
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/
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
DServerInterceptorTest.cs55 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in AddRequestHeaderInServerInterceptor()
76 Assert.AreEqual("PASS", Calls.BlockingUnaryCall(helper.CreateUnaryCall(), "")); in VerifyInterceptorOrdering()
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DTestGrpc.cs256 return CallInvoker.BlockingUnaryCall(__Method_EmptyCall, null, options, request); in EmptyCall()
300 return CallInvoker.BlockingUnaryCall(__Method_UnaryCall, null, options, request); in UnaryCall()
348 return CallInvoker.BlockingUnaryCall(__Method_CacheableUnaryCall, null, options, request); in CacheableUnaryCall()
494 return CallInvoker.BlockingUnaryCall(__Method_UnimplementedCall, null, options, request); in UnimplementedCall()
625 return CallInvoker.BlockingUnaryCall(__Method_UnimplementedCall, null, options, request); in UnimplementedCall()
740 return CallInvoker.BlockingUnaryCall(__Method_Start, null, options, request); in Start()
756 return CallInvoker.BlockingUnaryCall(__Method_Stop, null, options, request); in Stop()
DWorkerServiceGrpc.cs238 return CallInvoker.BlockingUnaryCall(__Method_CoreCount, null, options, request); in CoreCount()
282 return CallInvoker.BlockingUnaryCall(__Method_QuitWorker, null, options, request); in QuitWorker()
/external/grpc-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
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service_impl.cc52 return ::grpc::internal::BlockingUnaryCall( in GetRemoteAddress()
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dclient_unary_call.h38 Status BlockingUnaryCall(ChannelInterface* channel, const RpcMethod& method, in BlockingUnaryCall() function
/external/grpc-grpc/examples/csharp/HelloworldLegacyCsproj/Greeter/
DHelloworldGrpc.cs108 return CallInvoker.BlockingUnaryCall(__Method_SayHello, null, options, request); in SayHello()
/external/grpc-grpc/examples/csharp/HelloworldXamarin/HelloworldXamarin/
DHelloworldGrpc.cs109 return CallInvoker.BlockingUnaryCall(__Method_SayHello, null, options, request); in SayHello()
/external/grpc-grpc/examples/csharp/Helloworld/Greeter/
DHelloworldGrpc.cs108 return CallInvoker.BlockingUnaryCall(__Method_SayHello, null, options, request); in SayHello()

12