| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | CallOptions.cs | 34 CancellationToken cancellationToken; field
49 …tadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Ca… in CallOptions()
54 this.cancellationToken = cancellationToken; in CallOptions()
88 get { return cancellationToken; }
162 public CallOptions WithCancellationToken(CancellationToken cancellationToken) in WithCancellationToken()
165 newOptions.cancellationToken = cancellationToken; in WithCancellationToken()
249 GrpcPreconditions.CheckArgument(!newOptions.cancellationToken.CanBeCanceled, in Normalize()
251 newOptions.cancellationToken = propagationToken.ParentCancellationToken; in Normalize()
|
| D | ServerCallContext.cs | 37 private readonly CancellationToken cancellationToken; field in Grpc.Core.ServerCallContext
48 …thod, string host, DateTime deadline, Metadata requestHeaders, CancellationToken cancellationToken, in ServerCallContext() argument
50 …: this(callHandle, method, host, deadline, requestHeaders, cancellationToken, writeHeadersFunc, wr… in ServerCallContext()
55 …thod, string host, DateTime deadline, Metadata requestHeaders, CancellationToken cancellationToken, in ServerCallContext() argument
64 this.cancellationToken = cancellationToken; in ServerCallContext()
94 return new ContextPropagationToken(callHandle, deadline, cancellationToken, options); in CreatePropagationToken()
154 return this.cancellationToken;
|
| D | ContextPropagationToken.cs | 51 readonly CancellationToken cancellationToken; field in Grpc.Core.ContextPropagationToken
54 …ken(CallSafeHandle parentCall, DateTime deadline, CancellationToken cancellationToken, ContextProp… in ContextPropagationToken() argument
58 this.cancellationToken = cancellationToken; in ContextPropagationToken()
91 return this.cancellationToken;
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | TestGrpc.cs | 244 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in EmptyCall() argument
246 return EmptyCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCall()
266 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in EmptyCallAsync() argument
268 return EmptyCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCallAsync()
288 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in UnaryCall() argument
290 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCall()
310 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in UnaryCallAsync() argument
312 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCallAsync()
334 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in CacheableUnaryCall() argument
336 … return CacheableUnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CacheableUnaryCall()
[all …]
|
| D | BenchmarkServiceGrpc.cs | 177 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in UnaryCall() argument
179 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCall()
201 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in UnaryCallAsync() argument
203 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCallAsync()
225 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in StreamingCall() argument
227 return StreamingCall(new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingCall()
248 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in StreamingFromClient() argument
250 return StreamingFromClient(new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingFromClient()
271 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in StreamingFromServer() argument
273 … return StreamingFromServer(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingFromServer()
[all …]
|
| D | WorkerServiceGrpc.cs | 170 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in RunServer() argument
172 return RunServer(new grpc::CallOptions(headers, deadline, cancellationToken)); in RunServer()
200 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in RunClient() argument
202 return RunClient(new grpc::CallOptions(headers, deadline, cancellationToken)); in RunClient()
226 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in CoreCount() argument
228 return CoreCount(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CoreCount()
248 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in CoreCountAsync() argument
250 return CoreCountAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CoreCountAsync()
270 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in QuitWorker() argument
272 return QuitWorker(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in QuitWorker()
[all …]
|
| D | MetricsGrpc.cs | 121 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in GetAllGauges() argument
123 return GetAllGauges(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in GetAllGauges()
144 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in GetGauge() argument
146 return GetGauge(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in GetGauge()
166 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in GetGaugeAsync() argument
168 return GetGaugeAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in GetGaugeAsync()
|
| D | ReportQpsScenarioServiceGrpc.cs | 95 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in ReportScenario() argument
97 return ReportScenario(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in ReportScenario()
117 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in ReportScenarioAsync() argument
119 … return ReportScenarioAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in ReportScenarioAsync()
|
| D | InteropClient.cs | 405 using (var call = client.StreamingInputCall(cancellationToken: cts.Token)) in RunCancelAfterBeginAsync()
422 using (var call = client.FullDuplexCall(cancellationToken: cts.Token)) in RunCancelAfterFirstResponseAsync()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples/ |
| D | MathGrpc.cs | 159 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Div() argument
161 return Div(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in Div()
183 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in DivAsync() argument
185 return DivAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in DivAsync()
208 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in DivMany() argument
210 return DivMany(new grpc::CallOptions(headers, deadline, cancellationToken)); in DivMany()
234 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Fib() argument
236 return Fib(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in Fib()
258 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Sum() argument
260 return Sum(new grpc::CallOptions(headers, deadline, cancellationToken)); in Sum()
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/ |
| D | RouteGuideGrpc.cs | 176 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in GetFeature() argument
178 return GetFeature(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in GetFeature()
208 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in GetFeatureAsync() argument
210 … return GetFeatureAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in GetFeatureAsync()
240 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in ListFeatures() argument
242 return ListFeatures(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in ListFeatures()
269 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in RecordRoute() argument
271 return RecordRoute(new grpc::CallOptions(headers, deadline, cancellationToken)); in RecordRoute()
295 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in RouteChat() argument
297 return RouteChat(new grpc::CallOptions(headers, deadline, cancellationToken)); in RouteChat()
|
| /external/grpc-grpc/examples/csharp/HelloworldXamarin/HelloworldXamarin/ |
| D | HelloworldGrpc.cs | 97 …tadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Ca… in SayHello() argument
99 return SayHello(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHello()
119 …tadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Ca… in SayHelloAsync() argument
121 return SayHelloAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHelloAsync()
|
| /external/grpc-grpc/examples/csharp/HelloworldLegacyCsproj/Greeter/ |
| D | HelloworldGrpc.cs | 96 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in SayHello() argument
98 return SayHello(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHello()
118 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in SayHelloAsync() argument
120 return SayHelloAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHelloAsync()
|
| /external/grpc-grpc/examples/csharp/Helloworld/Greeter/ |
| D | HelloworldGrpc.cs | 96 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in SayHello() argument
98 return SayHello(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHello()
118 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in SayHelloAsync() argument
120 return SayHelloAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHelloAsync()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | CallOptionsTest.cs | 42 var cancellationToken = new CancellationTokenSource().Token; in WithMethods()
43 …Assert.AreEqual(cancellationToken, options.WithCancellationToken(cancellationToken).CancellationTo… in WithMethods()
84 …Assert.Throws(typeof(ArgumentException), () => new CallOptions(cancellationToken: token, propagati… in Normalize()
|
| D | CallCancellationTest.cs | 70 …lientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(cancellationToken: cts.Token))… in ClientStreamingCall_CancelAfterBegin()
108 …lientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(cancellationToken: cts.Token))… in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
|
| D | ContextPropagationTest.cs | 90 …lientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(cancellationToken: cts.Token))… in PropagateCancellation()
|
| /external/grpc-grpc/src/csharp/Grpc.HealthCheck/ |
| D | HealthGrpc.cs | 82 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Check() argument
84 return Check(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in Check()
90 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in CheckAsync() argument
92 return CheckAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CheckAsync()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestServerCallContext.cs | 35 …thod, string host, DateTime deadline, Metadata requestHeaders, CancellationToken cancellationToken, in Create() argument
39 … return new ServerCallContext(null, method, host, deadline, requestHeaders, cancellationToken, in Create()
|
| /external/grpc-grpc/src/csharp/Grpc.Reflection/ |
| D | ReflectionGrpc.cs | 97 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in ServerReflectionInfo() argument
99 return ServerReflectionInfo(new grpc::CallOptions(headers, deadline, cancellationToken)); in ServerReflectionInfo()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 348 …erverResponseStream<TRequest, TResponse> serverResponseStream, CancellationToken cancellationToken)
355 …newRpc.RequestMetadata, cancellationToken, serverResponseStream.WriteResponseHeadersAsync, serverR…
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.Tests/ |
| D | MathClientServerTests.cs | 108 using (var call = client.Fib(new FibArgs { Limit = 0 }, cancellationToken: cts.Token)) in FibWithCancel()
|