Home
last modified time | relevance | path

Searched refs:CallOptions (Results 1 – 25 of 187) sorted by relevance

12345678

/external/grpc-grpc-java/core/src/main/java/io/grpc/
DCallOptions.java40 public final class CallOptions { class
44 public static final CallOptions DEFAULT = new CallOptions();
87 public CallOptions withAuthority(@Nullable String authority) { in withAuthority()
88 CallOptions newOptions = new CallOptions(this); in withAuthority()
96 public CallOptions withCallCredentials(@Nullable CallCredentials credentials) { in withCallCredentials()
97 CallOptions newOptions = new CallOptions(this); in withCallCredentials()
107 public CallOptions withCompression(@Nullable String compressorName) { in withCompression()
108 CallOptions newOptions = new CallOptions(this); in withCompression()
121 public CallOptions withDeadline(@Nullable Deadline deadline) { in withDeadline()
122 CallOptions newOptions = new CallOptions(this); in withDeadline()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DCallOptionsTest.java41 private static final CallOptions.Key<String> OPTION_1
42 = CallOptions.Key.createWithDefault("option1", "default");
43 private static final CallOptions.Key<String> OPTION_2
44 = CallOptions.Key.createWithDefault("option2", "default");
52 private final CallOptions allSet = CallOptions.DEFAULT
66 assertThat(CallOptions.DEFAULT.getDeadline()).isNull(); in defaultsAreAllNull()
67 assertThat(CallOptions.DEFAULT.getAuthority()).isNull(); in defaultsAreAllNull()
68 assertThat(CallOptions.DEFAULT.getExecutor()).isNull(); in defaultsAreAllNull()
69 assertThat(CallOptions.DEFAULT.getCredentials()).isNull(); in defaultsAreAllNull()
70 assertThat(CallOptions.DEFAULT.getCompressor()).isNull(); in defaultsAreAllNull()
[all …]
DClientInterceptorsTest.java69 Mockito.<MethodDescriptor<String, Integer>>any(), any(CallOptions.class))) in setUp()
98 CallOptions callOptions = CallOptions.DEFAULT; in channelAndInterceptorCalled()
118 CallOptions callOptions, in callNextTwice()
126 assertSame(call, intercepted.newCall(method, CallOptions.DEFAULT)); in callNextTwice()
127 verify(channel, times(2)).newCall(same(method), same(CallOptions.DEFAULT)); in callNextTwice()
138 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions) { in ordered()
152 CallOptions callOptions, in ordered()
162 CallOptions callOptions, in ordered()
169 assertSame(call, intercepted.newCall(method, CallOptions.DEFAULT)); in ordered()
180 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions) { in orderedForward()
[all …]
/external/grpc-grpc-java/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/
DSafeMethodCachingInterceptorTest.java10 import io.grpc.CallOptions;
136 channelToUse, safeGreeterSayHelloMethod, CallOptions.DEFAULT, message); in safeCallsAreCached()
139 channelToUse, safeGreeterSayHelloMethod, CallOptions.DEFAULT, message); in safeCallsAreCached()
148 channelToUse, safeGreeterSayHelloMethod, CallOptions.DEFAULT, message); in safeCallsAreCachedWithCopiedMethodDescriptor()
153 CallOptions.DEFAULT, in safeCallsAreCachedWithCopiedMethodDescriptor()
163 channelToUse, safeGreeterSayHelloMethod, CallOptions.DEFAULT, message); in requestWithNoCacheOptionSkipsCache()
168 CallOptions.DEFAULT.withOption(SafeMethodCachingInterceptor.NO_CACHE_CALL_OPTION, true), in requestWithNoCacheOptionSkipsCache()
172 channelToUse, safeGreeterSayHelloMethod, CallOptions.DEFAULT, message); in requestWithNoCacheOptionSkipsCache()
184 CallOptions.DEFAULT.withOption( in requestWithOnlyIfCachedOption_unavailableIfNotInCache()
200 channelToUse, safeGreeterSayHelloMethod, CallOptions.DEFAULT, message); in requestWithOnlyIfCachedOption_usesCache()
[all …]
/external/grpc-grpc-java/core/src/jmh/java/io/grpc/
DCallOptionsBenchmark.java42 private List<CallOptions.Key<String>> customOptions;
44 private CallOptions allOpts;
45 private List<CallOptions.Key<String>> shuffledCustomOptions;
52 customOptions = new ArrayList<CallOptions.Key<String>>(customOptionsCount); in setUp()
54 customOptions.add(CallOptions.Key.createWithDefault("name " + i, "defaultvalue")); in setUp()
57 allOpts = CallOptions.DEFAULT; in setUp()
62 shuffledCustomOptions = new ArrayList<CallOptions.Key<String>>(customOptions); in setUp()
73 public CallOptions withOption() { in withOption()
74 CallOptions opts = CallOptions.DEFAULT; in withOption()
87 public CallOptions withOptionDuplicates() { in withOptionDuplicates()
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/
Dmaster_interface.h36 virtual Status CreateSession(CallOptions* call_options,
40 virtual Status ExtendSession(CallOptions* call_options,
44 virtual Status PartialRunSetup(CallOptions* call_options, in PartialRunSetup()
50 virtual Status RunStep(CallOptions* call_options,
54 virtual Status RunStep(CallOptions* call_options, in RunStep()
84 virtual Status CloseSession(CallOptions* call_options,
88 virtual Status ListDevices(CallOptions* call_options,
92 virtual Status Reset(CallOptions* call_options, const ResetRequest* request,
95 virtual Status MakeCallable(CallOptions* call_options,
98 virtual Status RunCallable(CallOptions* call_options,
[all …]
Dlocal_master.h43 Status CreateSession(CallOptions* call_options,
47 Status ExtendSession(CallOptions* call_options,
51 Status PartialRunSetup(CallOptions* call_options,
55 Status RunStep(CallOptions* call_options, RunStepRequestWrapper* request,
62 Status CloseSession(CallOptions* call_options,
66 Status ListDevices(CallOptions* call_options,
71 Status Reset(CallOptions* call_options, const ResetRequest* request,
74 Status MakeCallable(CallOptions* call_options,
77 Status RunCallable(CallOptions* call_options,
80 Status ReleaseCallable(CallOptions* call_options,
Dcall_options.cc22 CallOptions::CallOptions() {} in CallOptions() function in tensorflow::CallOptions
24 void CallOptions::StartCancel() { in StartCancel()
34 void CallOptions::SetCancelCallback(CancelFunction cancel_func) { in SetCancelCallback()
39 void CallOptions::ClearCancelCallback() { in ClearCancelCallback()
44 int64 CallOptions::GetTimeout() { in GetTimeout()
49 void CallOptions::SetTimeout(int64 ms) { in SetTimeout()
Dworker.h55 void DeleteWorkerSessionAsync(CallOptions* opts,
68 void RunGraphAsync(CallOptions* opts, RunGraphRequestWrapper* request,
84 void RecvTensorAsync(CallOptions* opts, const RecvTensorRequest* request,
93 void RecvBufAsync(CallOptions* opts, const RecvBufRequest* request,
96 void CompleteGroupAsync(CallOptions* opts,
101 void CompleteInstanceAsync(CallOptions* opts,
127 void DoRunGraph(CallOptions* opts, RunGraphRequestWrapper* request,
131 void DoPartialRunGraph(CallOptions* opts, RunGraphRequestWrapper* request,
Dlocal_master.cc26 Status WaitForNotification(CallOptions* call_options, in WaitForNotification()
53 Status LocalMaster::CreateSession(CallOptions* call_options, in CreateSession()
67 Status LocalMaster::ExtendSession(CallOptions* call_options, in ExtendSession()
81 Status LocalMaster::PartialRunSetup(CallOptions* call_options, in PartialRunSetup()
95 Status LocalMaster::RunStep(CallOptions* call_options, in RunStep()
118 Status LocalMaster::CloseSession(CallOptions* call_options, in CloseSession()
132 Status LocalMaster::ListDevices(CallOptions* call_options, in ListDevices()
146 Status LocalMaster::Reset(CallOptions* call_options, in Reset()
160 Status LocalMaster::MakeCallable(CallOptions* call_options, in MakeCallable()
173 Status LocalMaster::RunCallable(CallOptions* call_options, in RunCallable()
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core/
DCallOptions.cs30 public struct CallOptions struct
49 …public CallOptions(Metadata headers = null, DateTime? deadline = null, CancellationToken cancellat… in CallOptions() method
138 public CallOptions WithHeaders(Metadata headers) in WithHeaders() argument
150 public CallOptions WithDeadline(DateTime deadline) in WithDeadline() argument
162 public CallOptions WithCancellationToken(CancellationToken cancellationToken) in WithCancellationToken() argument
174 public CallOptions WithWriteOptions(WriteOptions writeOptions) in WithWriteOptions() argument
186 public CallOptions WithPropagationToken(ContextPropagationToken propagationToken) in WithPropagationToken() argument
198 public CallOptions WithCredentials(CallCredentials credentials) in WithCredentials() argument
210 public CallOptions WithWaitForReady(bool waitForReady = true) in WithWaitForReady() argument
224 internal CallOptions WithFlags(CallFlags flags) in WithFlags() argument
[all …]
DCallInvocationDetails.cs37 CallOptions options;
45 …c CallInvocationDetails(Channel channel, Method<TRequest, TResponse> method, CallOptions options) : in CallInvocationDetails()
57 …ionDetails(Channel channel, Method<TRequest, TResponse> method, string host, CallOptions options) : in CallInvocationDetails()
71 …shaller<TRequest> requestMarshaller, Marshaller<TResponse> responseMarshaller, CallOptions options) in CallInvocationDetails()
139 public CallOptions Options
151 public CallInvocationDetails<TRequest, TResponse> WithOptions(CallOptions options) in WithOptions()
DDefaultCallInvoker.cs44 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque… in BlockingUnaryCall()
53 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque… in AsyncUnaryCall()
63 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque… in AsyncServerStreamingCall()
73 …mingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options) in AsyncClientStreamingCall()
84 …mingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options) in AsyncDuplexStreamingCall()
91 …eateCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options)
DCallInvoker.cs33 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque…
40 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque…
48 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque…
56 …mingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options)
65 …mingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options)
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetCallOptions.java19 import io.grpc.CallOptions;
38 public static final CallOptions.Key<Object> CRONET_ANNOTATION_KEY =
39 CallOptions.Key.create("cronet-annotation");
50 public static CallOptions withAnnotation(CallOptions callOptions, Object annotation) { in withAnnotation()
63 static final CallOptions.Key<Collection<Object>> CRONET_ANNOTATIONS_KEY =
64 CallOptions.Key.create("cronet-annotations");
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_remote_master.cc44 Status CreateSession(CallOptions* call_options, in CreateSession()
51 Status ExtendSession(CallOptions* call_options, in ExtendSession()
58 Status PartialRunSetup(CallOptions* call_options, in PartialRunSetup()
65 Status RunStep(CallOptions* call_options, RunStepRequestWrapper* request, in RunStep()
72 Status CloseSession(CallOptions* call_options, in CloseSession()
79 Status ListDevices(CallOptions* call_options, in ListDevices()
86 Status Reset(CallOptions* call_options, const ResetRequest* request, in Reset()
92 Status MakeCallable(CallOptions* call_options, in MakeCallable()
98 Status RunCallable(CallOptions* call_options, in RunCallable()
104 Status ReleaseCallable(CallOptions* call_options, in ReleaseCallable()
[all …]
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DTestGrpc.cs246 return EmptyCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCall()
254 …global::Grpc.Testing.Empty EmptyCall(global::Grpc.Testing.Empty request, grpc::CallOptions options) in EmptyCall()
268 return EmptyCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCallAsync()
276 …::Grpc.Testing.Empty> EmptyCallAsync(global::Grpc.Testing.Empty request, grpc::CallOptions options) in EmptyCallAsync()
290 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCall()
298 …ing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) in UnaryCall()
312 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCallAsync()
320 …mpleResponse> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) in UnaryCallAsync()
336 … return CacheableUnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CacheableUnaryCall()
346 …eResponse CacheableUnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) in CacheableUnaryCall()
[all …]
DBenchmarkServiceGrpc.cs179 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCall()
188 …ing.SimpleResponse UnaryCall(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) in UnaryCall()
203 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCallAsync()
212 …mpleResponse> UnaryCallAsync(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) in UnaryCallAsync()
227 return StreamingCall(new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingCall()
236 …esting.SimpleRequest, global::Grpc.Testing.SimpleResponse> StreamingCall(grpc::CallOptions options) in StreamingCall()
250 return StreamingFromClient(new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingFromClient()
258 ….SimpleRequest, global::Grpc.Testing.SimpleResponse> StreamingFromClient(grpc::CallOptions options) in StreamingFromClient()
273 … return StreamingFromServer(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingFromServer()
282 …esponse> StreamingFromServer(global::Grpc.Testing.SimpleRequest request, grpc::CallOptions options) in StreamingFromServer()
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DCallOptionsTest.cs34 var options = new CallOptions(); in WithMethods()
71 Assert.AreSame(Metadata.Empty, new CallOptions().Normalize().Headers); in Normalize()
72 Assert.AreEqual(DateTime.MaxValue, new CallOptions().Normalize().Deadline.Value); in Normalize()
77 …Assert.AreEqual(deadline, new CallOptions(propagationToken: propagationToken1).Normalize().Deadlin… in Normalize()
78 …Assert.Throws(typeof(ArgumentException), () => new CallOptions(deadline: deadline, propagationToke… in Normalize()
83 …Assert.AreEqual(token, new CallOptions(propagationToken: propagationToken2).Normalize().Cancellati… in Normalize()
84 …Assert.Throws(typeof(ArgumentException), () => new CallOptions(cancellationToken: token, propagati… in Normalize()
90 var callOptions = new CallOptions(); in WaitForReady()
DMockServiceHelper.cs152 …c CallInvocationDetails<string, string> CreateUnaryCall(CallOptions options = default(CallOptions)) in CreateUnaryCall()
157 …cationDetails<string, string> CreateClientStreamingCall(CallOptions options = default(CallOptions)) in CreateClientStreamingCall()
162 …cationDetails<string, string> CreateServerStreamingCall(CallOptions options = default(CallOptions)) in CreateServerStreamingCall()
167 …cationDetails<string, string> CreateDuplexStreamingCall(CallOptions options = default(CallOptions)) in CreateDuplexStreamingCall()
DContextPropagationTest.cs77 var callOptions = new CallOptions(propagationToken: propagationToken); in PropagateCancellation()
90 … = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(cancellationTok… in PropagateCancellation()
122 new CallOptions(deadline: DateTime.UtcNow.AddDays(8), in PropagateDeadline()
126 … var callOptions = new CallOptions(propagationToken: context.CreatePropagationToken()); in PropagateDeadline()
130 … = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(deadline: deadl… in PropagateDeadline()
148 …var callOptions = new CallOptions(propagationToken: context.CreatePropagationToken(new ContextProp… in SuppressDeadlinePropagation()
153 … = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(deadline: DateT… in SuppressDeadlinePropagation()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java36 import io.grpc.CallOptions;
81 private static final CallOptions.Key<Integer> SHARD_ID
82 = CallOptions.Key.createWithDefault("shard-id", -1);
98 private final CallOptions callOptions = CallOptions.DEFAULT.withAuthority("dummy_value");
99 private final CallOptions callOptions2 = CallOptions.DEFAULT.withAuthority("dummy_value2");
174 any(MethodDescriptor.class), any(Metadata.class), any(CallOptions.class)); in assignTransportThenShutdownThenNewStream()
186 any(MethodDescriptor.class), any(Metadata.class), any(CallOptions.class)); in assignTransportThenShutdownNowThenNewStream()
190 ClientStream stream = delayedTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in cancelStreamWithoutSetTransport()
199 ClientStream stream = delayedTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in startThenCancelStreamWithoutSetTransport()
230 stream = delayedTransport.newStream(method, new Metadata(), CallOptions.DEFAULT); in newStreamThenShutdownTransportThenAssignTransport()
[all …]
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DAbstractStub.java22 import io.grpc.CallOptions;
53 private final CallOptions callOptions;
62 this(channel, CallOptions.DEFAULT); in AbstractStub()
72 protected AbstractStub(Channel channel, CallOptions callOptions) { in AbstractStub()
91 public final CallOptions getCallOptions() { in getCallOptions()
102 protected abstract S build(Channel channel, CallOptions callOptions); in build()
175 public final <T> S withOption(CallOptions.Key<T> key, T value) { in withOption()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DAbstractStubTest.java25 import io.grpc.CallOptions;
58 new NoopStub(null, CallOptions.DEFAULT); in channelMustNotBeNull2()
64 CallOptions callOptions = stub.getCallOptions(); in withWaitForReady()
78 NoopStub(Channel channel, CallOptions options) { in NoopStub()
83 protected NoopStub build(Channel channel, CallOptions callOptions) { in build()
91 CallOptions callOptions = stub.getCallOptions(); in withExecutor()
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DUnimplementedCallInvoker.cs35 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque… in BlockingUnaryCall()
40 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque… in AsyncUnaryCall()
45 …<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options, TReque… in AsyncServerStreamingCall()
50 …mingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options) in AsyncClientStreamingCall()
55 …mingCall<TRequest, TResponse>(Method<TRequest, TResponse> method, string host, CallOptions options) in AsyncDuplexStreamingCall()

12345678