Home
last modified time | relevance | path

Searched refs:callOptions (Results 1 – 25 of 92) sorted by relevance

1234

/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DAbstractStub.java53 private final CallOptions callOptions; field in AbstractStub
72 protected AbstractStub(Channel channel, CallOptions callOptions) { in AbstractStub() argument
74 this.callOptions = checkNotNull(callOptions, "callOptions"); in AbstractStub()
92 return callOptions; in getCallOptions()
102 protected abstract S build(Channel channel, CallOptions callOptions); in build() argument
114 return build(channel, callOptions.withDeadline(deadline)); in withDeadline()
124 return build(channel, callOptions.withDeadlineAfter(duration, unit)); in withDeadlineAfter()
135 return build(channel, callOptions.withExecutor(executor)); in withExecutor()
150 return build(channel, callOptions.withCompression(compressorName)); in withCompression()
163 return build(newChannel, callOptions); in withChannel()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DPickSubchannelArgsImpl.java28 private final CallOptions callOptions; field in PickSubchannelArgsImpl
35 PickSubchannelArgsImpl(MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions) { in PickSubchannelArgsImpl() argument
38 this.callOptions = checkNotNull(callOptions, "callOptions"); in PickSubchannelArgsImpl()
48 return callOptions; in getCallOptions()
65 return Objects.equal(callOptions, that.callOptions) in equals()
72 return Objects.hashCode(callOptions, headers, method); in hashCode()
77 return "[method=" + method + " headers=" + headers + " callOptions=" + callOptions + "]"; in toString()
DServiceConfigInterceptor.java290 final MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall() argument
313 callOptions = callOptions in interceptCall()
354 callOptions = callOptions in interceptCall()
362 return next.newCall(method, callOptions); in interceptCall()
367 Deadline existingDeadline = callOptions.getDeadline(); in interceptCall()
370 callOptions = callOptions.withDeadline(newDeadline); in interceptCall()
374 callOptions = in interceptCall()
375 info.waitForReady ? callOptions.withWaitForReady() : callOptions.withoutWaitForReady(); in interceptCall()
378 Integer existingLimit = callOptions.getMaxInboundMessageSize(); in interceptCall()
380 callOptions = callOptions.withMaxInboundMessageSize( in interceptCall()
[all …]
DCallCredentialsApplyingTransportFactory.java77 MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions) { in newStream() argument
78 CallCredentials creds = callOptions.getCredentials(); in newStream()
81 delegate, method, headers, callOptions); in newStream()
86 if (callOptions.getAuthority() != null) { in newStream()
87 effectiveAttrsBuilder.set(CallCredentials.ATTR_AUTHORITY, callOptions.getAuthority()); in newStream()
91 firstNonNull(callOptions.getExecutor(), appExecutor), applier); in newStream()
99 return delegate.newStream(method, headers, callOptions); in newStream()
DClientCallImpl.java75 private final CallOptions callOptions; field in ClientCallImpl
89 MethodDescriptor<ReqT, RespT> method, Executor executor, CallOptions callOptions, in ClientCallImpl() argument
106 this.callOptions = callOptions; in ClientCallImpl()
133 CallOptions callOptions, in newRetriableStream() argument
204 final String compressorName = callOptions.getCompressor(); in start()
237 effectiveDeadline, callOptions.getDeadline(), context.getDeadline()); in start()
239 stream = clientTransportProvider.newRetriableStream(method, callOptions, headers, context); in start()
242 new PickSubchannelArgsImpl(method, headers, callOptions)); in start()
245 stream = transport.newStream(method, headers, callOptions); in start()
255 if (callOptions.getAuthority() != null) { in start()
[all …]
DMetadataApplierImpl.java36 private final CallOptions callOptions; field in MetadataApplierImpl
54 CallOptions callOptions) { in MetadataApplierImpl() argument
58 this.callOptions = callOptions; in MetadataApplierImpl()
70 realStream = transport.newStream(method, origHeaders, callOptions); in apply()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DClientInterceptorsTest.java98 CallOptions callOptions = CallOptions.DEFAULT; in channelAndInterceptorCalled() local
100 assertSame(call, intercepted.newCall(method, callOptions)); in channelAndInterceptorCalled()
101 verify(channel).newCall(same(method), same(callOptions)); in channelAndInterceptorCalled()
102 verify(interceptor).interceptCall(same(method), same(callOptions), Mockito.<Channel>any()); in channelAndInterceptorCalled()
105 assertSame(call, intercepted.newCall(method, callOptions)); in channelAndInterceptorCalled()
106 verify(channel, times(2)).newCall(same(method), same(callOptions)); in channelAndInterceptorCalled()
108 .interceptCall(same(method), same(callOptions), Mockito.<Channel>any()); in channelAndInterceptorCalled()
118 CallOptions callOptions, in callNextTwice()
121 assertSame(call, next.newCall(method, callOptions)); in callNextTwice()
122 return next.newCall(method, callOptions); in callNextTwice()
[all …]
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DAbstractStubTest.java64 CallOptions callOptions = stub.getCallOptions(); in withWaitForReady() local
65 assertFalse(callOptions.isWaitForReady()); in withWaitForReady()
68 callOptions = stub.getCallOptions(); in withWaitForReady()
69 assertTrue(callOptions.isWaitForReady()); in withWaitForReady()
83 protected NoopStub build(Channel channel, CallOptions callOptions) { in build() argument
84 return new NoopStub(channel, callOptions); in build()
91 CallOptions callOptions = stub.getCallOptions(); in withExecutor() local
93 assertNull(callOptions.getExecutor()); in withExecutor()
97 callOptions = stub.getCallOptions(); in withExecutor()
99 assertEquals(callOptions.getExecutor(), executor); in withExecutor()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DCallCredentials2ApplyingTest.java98 private CallOptions callOptions; field in CallCredentials2ApplyingTest
117 callOptions = CallOptions.DEFAULT.withCallCredentials(mockCreds); in setUp()
127 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_base()
148 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_transportSetSecurityLevel()
169 callOptions.withAuthority("calloptions-authority").withExecutor(anotherExecutor)); in parameterPropagation_callOptionsSetAuthority()
189 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in credentialThrows()
191 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in credentialThrows()
211 ClientStream stream = transport.newStream(method, origHeaders, callOptions); in applyMetadata_inline()
213 verify(mockTransport).newStream(method, origHeaders, callOptions); in applyMetadata_inline()
234 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in fail_inline()
[all …]
DCallCredentialsApplyingTest.java97 private CallOptions callOptions; field in CallCredentialsApplyingTest
116 callOptions = CallOptions.DEFAULT.withCallCredentials(mockCreds); in setUp()
126 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_base()
146 transport.newStream(method, origHeaders, callOptions); in parameterPropagation_overrideByTransport()
168 callOptions.withAuthority("calloptions-authority").withExecutor(anotherExecutor)); in parameterPropagation_overrideByCallOptions()
188 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in credentialThrows()
190 verify(mockTransport, never()).newStream(method, origHeaders, callOptions); in credentialThrows()
211 ClientStream stream = transport.newStream(method, origHeaders, callOptions); in applyMetadata_inline()
213 verify(mockTransport).newStream(method, origHeaders, callOptions); in applyMetadata_inline()
235 (FailingClientStream) transport.newStream(method, origHeaders, callOptions); in fail_inline()
[all …]
/external/flatbuffers/tests/FlatBuffers.GRPC.Swift/Sources/Model/
Dgreeter.grpc.swift24 …func SayHello(_ request: Message<HelloRequest>, callOptions: CallOptions?) -> UnaryCall<Message<He… in SayHello()
25 …func SayManyHellos(_ request: Message<ManyHellosRequest>, callOptions: CallOptions?, handler: @esc… in SayHello()
37 …public func SayHello(_ request: Message<HelloRequest>, callOptions: CallOptions? = nil) -> UnaryCa… in SayHello()
38 …return self.makeUnaryCall(path: "/Greeter/SayHello", request: request, callOptions: callOptions ??… in SayHello()
41 …public func SayManyHellos(_ request: Message<ManyHellosRequest>, callOptions: CallOptions? = nil, … in SayHello()
42 …StreamingCall(path: "/Greeter/SayManyHellos", request: request, callOptions: callOptions ?? self.d… in SayHello()
/external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/
DHandshakerServiceGrpc.java125 io.grpc.CallOptions callOptions) { in HandshakerServiceStub() argument
126 super(channel, callOptions); in HandshakerServiceStub()
131 io.grpc.CallOptions callOptions) { in build() argument
132 return new HandshakerServiceStub(channel, callOptions); in build()
160 io.grpc.CallOptions callOptions) { in HandshakerServiceBlockingStub() argument
161 super(channel, callOptions); in HandshakerServiceBlockingStub()
166 io.grpc.CallOptions callOptions) { in build() argument
167 return new HandshakerServiceBlockingStub(channel, callOptions); in build()
179 io.grpc.CallOptions callOptions) { in HandshakerServiceFutureStub() argument
180 super(channel, callOptions); in HandshakerServiceFutureStub()
[all …]
/external/grpc-grpc-java/grpclb/src/generated/main/grpc/io/grpc/lb/v1/
DLoadBalancerGrpc.java120 io.grpc.CallOptions callOptions) { in LoadBalancerStub() argument
121 super(channel, callOptions); in LoadBalancerStub()
126 io.grpc.CallOptions callOptions) { in build() argument
127 return new LoadBalancerStub(channel, callOptions); in build()
150 io.grpc.CallOptions callOptions) { in LoadBalancerBlockingStub() argument
151 super(channel, callOptions); in LoadBalancerBlockingStub()
156 io.grpc.CallOptions callOptions) { in build() argument
157 return new LoadBalancerBlockingStub(channel, callOptions); in build()
169 io.grpc.CallOptions callOptions) { in LoadBalancerFutureStub() argument
170 super(channel, callOptions); in LoadBalancerFutureStub()
[all …]
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/reflection/v1alpha/
DServerReflectionGrpc.java121 io.grpc.CallOptions callOptions) { in ServerReflectionStub() argument
122 super(channel, callOptions); in ServerReflectionStub()
127 io.grpc.CallOptions callOptions) { in build() argument
128 return new ServerReflectionStub(channel, callOptions); in build()
152 io.grpc.CallOptions callOptions) { in ServerReflectionBlockingStub() argument
153 super(channel, callOptions); in ServerReflectionBlockingStub()
158 io.grpc.CallOptions callOptions) { in build() argument
159 return new ServerReflectionBlockingStub(channel, callOptions); in build()
171 io.grpc.CallOptions callOptions) { in ServerReflectionFutureStub() argument
172 super(channel, callOptions); in ServerReflectionFutureStub()
[all …]
/external/grpc-grpc-java/services/src/generated/test/grpc/io/grpc/reflection/testing/
DReflectableServiceGrpc.java117 io.grpc.CallOptions callOptions) { in ReflectableServiceStub() argument
118 super(channel, callOptions); in ReflectableServiceStub()
123 io.grpc.CallOptions callOptions) { in build() argument
124 return new ReflectableServiceStub(channel, callOptions); in build()
144 io.grpc.CallOptions callOptions) { in ReflectableServiceBlockingStub() argument
145 super(channel, callOptions); in ReflectableServiceBlockingStub()
150 io.grpc.CallOptions callOptions) { in build() argument
151 return new ReflectableServiceBlockingStub(channel, callOptions); in build()
170 io.grpc.CallOptions callOptions) { in ReflectableServiceFutureStub() argument
171 super(channel, callOptions); in ReflectableServiceFutureStub()
[all …]
DDynamicServiceGrpc.java129 io.grpc.CallOptions callOptions) { in DynamicServiceStub() argument
130 super(channel, callOptions); in DynamicServiceStub()
135 io.grpc.CallOptions callOptions) { in build() argument
136 return new DynamicServiceStub(channel, callOptions); in build()
162 io.grpc.CallOptions callOptions) { in DynamicServiceBlockingStub() argument
163 super(channel, callOptions); in DynamicServiceBlockingStub()
168 io.grpc.CallOptions callOptions) { in build() argument
169 return new DynamicServiceBlockingStub(channel, callOptions); in build()
194 io.grpc.CallOptions callOptions) { in DynamicServiceFutureStub() argument
195 super(channel, callOptions); in DynamicServiceFutureStub()
[all …]
DAnotherDynamicServiceGrpc.java129 io.grpc.CallOptions callOptions) { in AnotherDynamicServiceStub() argument
130 super(channel, callOptions); in AnotherDynamicServiceStub()
135 io.grpc.CallOptions callOptions) { in build() argument
136 return new AnotherDynamicServiceStub(channel, callOptions); in build()
162 io.grpc.CallOptions callOptions) { in AnotherDynamicServiceBlockingStub() argument
163 super(channel, callOptions); in AnotherDynamicServiceBlockingStub()
168 io.grpc.CallOptions callOptions) { in build() argument
169 return new AnotherDynamicServiceBlockingStub(channel, callOptions); in build()
194 io.grpc.CallOptions callOptions) { in AnotherDynamicServiceFutureStub() argument
195 super(channel, callOptions); in AnotherDynamicServiceFutureStub()
[all …]
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DReportQpsScenarioServiceGrpc.java120 io.grpc.CallOptions callOptions) { in ReportQpsScenarioServiceStub() argument
121 super(channel, callOptions); in ReportQpsScenarioServiceStub()
126 io.grpc.CallOptions callOptions) { in build() argument
127 return new ReportQpsScenarioServiceStub(channel, callOptions); in build()
150 io.grpc.CallOptions callOptions) { in ReportQpsScenarioServiceBlockingStub() argument
151 super(channel, callOptions); in ReportQpsScenarioServiceBlockingStub()
156 io.grpc.CallOptions callOptions) { in build() argument
157 return new ReportQpsScenarioServiceBlockingStub(channel, callOptions); in build()
179 io.grpc.CallOptions callOptions) { in ReportQpsScenarioServiceFutureStub() argument
180 super(channel, callOptions); in ReportQpsScenarioServiceFutureStub()
[all …]
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DUnimplementedServiceGrpc.java132 io.grpc.CallOptions callOptions) { in UnimplementedServiceStub() argument
133 super(channel, callOptions); in UnimplementedServiceStub()
138 io.grpc.CallOptions callOptions) { in build() argument
139 return new UnimplementedServiceStub(channel, callOptions); in build()
166 io.grpc.CallOptions callOptions) { in UnimplementedServiceBlockingStub() argument
167 super(channel, callOptions); in UnimplementedServiceBlockingStub()
172 io.grpc.CallOptions callOptions) { in build() argument
173 return new UnimplementedServiceBlockingStub(channel, callOptions); in build()
199 io.grpc.CallOptions callOptions) { in UnimplementedServiceFutureStub() argument
200 super(channel, callOptions); in UnimplementedServiceFutureStub()
[all …]
DReconnectServiceGrpc.java172 io.grpc.CallOptions callOptions) { in ReconnectServiceStub() argument
173 super(channel, callOptions); in ReconnectServiceStub()
178 io.grpc.CallOptions callOptions) { in build() argument
179 return new ReconnectServiceStub(channel, callOptions); in build()
210 io.grpc.CallOptions callOptions) { in ReconnectServiceBlockingStub() argument
211 super(channel, callOptions); in ReconnectServiceBlockingStub()
216 io.grpc.CallOptions callOptions) { in build() argument
217 return new ReconnectServiceBlockingStub(channel, callOptions); in build()
246 io.grpc.CallOptions callOptions) { in ReconnectServiceFutureStub() argument
247 super(channel, callOptions); in ReconnectServiceFutureStub()
[all …]
DMetricsServiceGrpc.java170 io.grpc.CallOptions callOptions) { in MetricsServiceStub() argument
171 super(channel, callOptions); in MetricsServiceStub()
176 io.grpc.CallOptions callOptions) { in build() argument
177 return new MetricsServiceStub(channel, callOptions); in build()
212 io.grpc.CallOptions callOptions) { in MetricsServiceBlockingStub() argument
213 super(channel, callOptions); in MetricsServiceBlockingStub()
218 io.grpc.CallOptions callOptions) { in build() argument
219 return new MetricsServiceBlockingStub(channel, callOptions); in build()
253 io.grpc.CallOptions callOptions) { in MetricsServiceFutureStub() argument
254 super(channel, callOptions); in MetricsServiceFutureStub()
[all …]
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DContextPropagationTest.cs77 var callOptions = new CallOptions(propagationToken: propagationToken); in PropagateCancellation()
80 await Calls.AsyncUnaryCall(helper.CreateUnaryCall(callOptions), "xyz"); in PropagateCancellation()
126 … var callOptions = new CallOptions(propagationToken: context.CreatePropagationToken()); in PropagateDeadline()
127 return await Calls.AsyncUnaryCall(helper.CreateUnaryCall(callOptions), "xyz"); in PropagateDeadline()
148 …var callOptions = new CallOptions(propagationToken: context.CreatePropagationToken(new ContextProp… in SuppressDeadlinePropagation()
149 return await Calls.AsyncUnaryCall(helper.CreateUnaryCall(callOptions), "xyz"); in SuppressDeadlinePropagation()
DCallOptionsTest.cs90 var callOptions = new CallOptions(); in WaitForReady()
91 Assert.IsFalse(callOptions.IsWaitForReady); in WaitForReady()
93 Assert.AreEqual(CallFlags.WaitForReady, callOptions.WithWaitForReady().Flags); in WaitForReady()
94 Assert.IsTrue(callOptions.WithWaitForReady().IsWaitForReady); in WaitForReady()
95 … Assert.IsFalse(callOptions.WithWaitForReady(true).WithWaitForReady(false).IsWaitForReady); in WaitForReady()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/health/v1/
DHealthGrpc.java182 io.grpc.CallOptions callOptions) { in HealthStub() argument
183 super(channel, callOptions); in HealthStub()
188 io.grpc.CallOptions callOptions) { in build() argument
189 return new HealthStub(channel, callOptions); in build()
236 io.grpc.CallOptions callOptions) { in HealthBlockingStub() argument
237 super(channel, callOptions); in HealthBlockingStub()
242 io.grpc.CallOptions callOptions) { in build() argument
243 return new HealthBlockingStub(channel, callOptions); in build()
289 io.grpc.CallOptions callOptions) { in HealthFutureStub() argument
290 super(channel, callOptions); in HealthFutureStub()
[all …]
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetCallOptions.java50 public static CallOptions withAnnotation(CallOptions callOptions, Object annotation) { in withAnnotation() argument
51 Collection<Object> existingAnnotations = callOptions.getOption(CRONET_ANNOTATIONS_KEY); in withAnnotation()
59 return callOptions.withOption( in withAnnotation()

1234