| /external/tensorflow/tensorflow/core/framework/ |
| D | cancellation.h | 37 typedef int64 CancellationToken; typedef
48 static const CancellationToken kInvalidToken;
64 CancellationToken get_cancellation_token();
115 bool RegisterCallback(CancellationToken token, CancelCallback callback);
126 bool DeregisterCallback(CancellationToken token);
135 bool TryDeregisterCallback(CancellationToken token);
143 CancellationToken next_cancellation_token_ GUARDED_BY(mu_);
144 gtl::FlatMap<CancellationToken, CancelCallback> callbacks_ GUARDED_BY(mu_);
|
| D | cancellation.cc | 23 const CancellationToken CancellationManager::kInvalidToken = -1;
37 gtl::FlatMap<CancellationToken, CancelCallback> callbacks_to_run; in StartCancel()
62 CancellationToken CancellationManager::get_cancellation_token() { in get_cancellation_token()
67 bool CancellationManager::RegisterCallback(CancellationToken token, in RegisterCallback()
78 bool CancellationManager::DeregisterCallback(CancellationToken token) { in DeregisterCallback()
98 bool CancellationManager::TryDeregisterCallback(CancellationToken token) { in TryDeregisterCallback()
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | TestGrpc.cs | 244 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in EmptyCall()
266 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in EmptyCallAsync()
288 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in UnaryCall()
310 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in UnaryCallAsync()
334 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in CacheableUnaryCall()
360 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in CacheableUnaryCallAsync()
385 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in StreamingOutputCall()
408 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in StreamingInputCall()
431 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in FullDuplexCall()
456 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in HalfDuplexCall()
[all …]
|
| D | BenchmarkServiceGrpc.cs | 177 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in UnaryCall()
201 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in UnaryCallAsync()
225 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in StreamingCall()
248 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in StreamingFromClient()
271 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in StreamingFromServer()
294 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in StreamingBothWays()
|
| D | WorkerServiceGrpc.cs | 170 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in RunServer()
200 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in RunClient()
226 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in CoreCount()
248 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in CoreCountAsync()
270 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in QuitWorker()
292 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in QuitWorkerAsync()
|
| D | MetricsGrpc.cs | 121 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in GetAllGauges()
144 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in GetGauge()
166 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in GetGaugeAsync()
|
| D | ReportQpsScenarioServiceGrpc.cs | 95 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in ReportScenario()
117 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in ReportScenarioAsync()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples/ |
| D | MathGrpc.cs | 159 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in Div()
183 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in DivAsync()
208 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in DivMany()
234 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in Fib()
258 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in Sum()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | CallOptions.cs | 34 CancellationToken cancellationToken;
49 …a headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Cancell… in CallOptions()
86 public CancellationToken CancellationToken property
162 public CallOptions WithCancellationToken(CancellationToken cancellationToken) in WithCancellationToken()
|
| D | ServerCallContext.cs | 37 private readonly CancellationToken cancellationToken;
48 …ng method, string host, DateTime deadline, Metadata requestHeaders, CancellationToken cancellation… in ServerCallContext()
55 …ng method, string host, DateTime deadline, Metadata requestHeaders, CancellationToken cancellation… in ServerCallContext()
150 public CancellationToken CancellationToken property in Grpc.Core.ServerCallContext
|
| D | ContextPropagationToken.cs | 51 readonly CancellationToken cancellationToken;
54 …ntextPropagationToken(CallSafeHandle parentCall, DateTime deadline, CancellationToken cancellation… in ContextPropagationToken()
87 internal CancellationToken ParentCancellationToken
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/ |
| D | RouteGuideGrpc.cs | 176 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in GetFeature()
208 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in GetFeatureAsync()
240 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in ListFeatures()
269 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in RecordRoute()
295 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in RouteChat()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | CallOptionsTest.cs | 43 …rt.AreEqual(cancellationToken, options.WithCancellationToken(cancellationToken).CancellationToken); in WithMethods()
49 CancellationToken.None, ContextPropagationOptions.Default); in WithMethods()
61 Assert.AreEqual(CancellationToken.None, options.CancellationToken); in WithMethods()
75 …Token1 = new ContextPropagationToken(CallSafeHandle.NullInstance, deadline, CancellationToken.None, in Normalize()
83 …reEqual(token, new CallOptions(propagationToken: propagationToken2).Normalize().CancellationToken); in Normalize()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | conditional_accumulator_base.h | 97 CancellationToken cancellation_token;
103 CancellationToken cancellation_token, RunCallback run_callback) in Attempt()
116 CleanUp(DoneCallback&& f, CancellationToken ct, CancellationManager* cm) in CleanUp()
119 CancellationToken to_deregister;
139 CancellationToken token);
|
| D | queue_base.h | 102 CleanUp(DoneCallback&& f, CancellationToken ct, CancellationManager* cm) in CleanUp()
105 CancellationToken to_deregister;
126 CancellationToken token);
163 CancellationToken cancellation_token;
172 CancellationToken cancellation_token, RunCallback run_callback) in Attempt()
|
| D | fifo_queue.cc | 53 CancellationToken token = cm->get_cancellation_token(); in TryEnqueue()
111 CancellationToken token = cm->get_cancellation_token(); in TryEnqueueMany()
157 CancellationToken token = cm->get_cancellation_token(); in TryDequeue()
248 CancellationToken token = cm->get_cancellation_token(); in TryDequeueMany()
|
| D | priority_queue.cc | 74 CancellationToken token = cm->get_cancellation_token(); in TryEnqueue()
139 CancellationToken token = cm->get_cancellation_token(); in TryEnqueueMany()
200 CancellationToken token = cm->get_cancellation_token(); in TryDequeue()
291 CancellationToken token = cm->get_cancellation_token(); in TryDequeueMany()
|
| D | conditional_accumulator_base.cc | 73 CancellationToken token = cm->get_cancellation_token(); in TryTakeGrad()
111 CancellationManager* cancellation_manager, CancellationToken token) { in Cancel()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.Tests/ |
| D | MathClientMockableTest.cs | 39 …mockClient.Setup(m => m.Div(Moq.It.IsAny<DivArgs>(), null, null, CancellationToken.None)).Returns(… in ClientBaseBlockingUnaryCallCanBeMocked()
60 …mockClient.Setup(m => m.DivAsync(Moq.It.IsAny<DivArgs>(), null, null, CancellationToken.None)).Ret… in ClientBaseAsyncUnaryCallCanBeMocked()
72 mockClient.Setup(m => m.Sum(null, null, CancellationToken.None)).Returns(fakeCall); in ClientBaseClientStreamingCallCanBeMocked()
84 …mockClient.Setup(m => m.Fib(Moq.It.IsAny<FibArgs>(), null, null, CancellationToken.None)).Returns(… in ClientBaseServerStreamingCallCanBeMocked()
97 mockClient.Setup(m => m.DivMany(null, null, CancellationToken.None)).Returns(fakeCall); in ClientBaseDuplexStreamingCallCanBeMocked()
|
| /external/grpc-grpc/examples/csharp/HelloworldLegacyCsproj/Greeter/ |
| D | HelloworldGrpc.cs | 96 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in SayHello()
118 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in SayHelloAsync()
|
| /external/grpc-grpc/examples/csharp/HelloworldXamarin/HelloworldXamarin/ |
| D | HelloworldGrpc.cs | 97 …a headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Cancell… in SayHello()
119 …a headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Cancell… in SayHelloAsync()
|
| /external/grpc-grpc/examples/csharp/Helloworld/Greeter/ |
| D | HelloworldGrpc.cs | 96 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in SayHello()
118 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in SayHelloAsync()
|
| /external/grpc-grpc/src/csharp/Grpc.HealthCheck/ |
| D | HealthGrpc.cs | 82 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in Check()
90 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in CheckAsync()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 66 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
129 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
193 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
255 … var context = HandlerUtils.NewContext(newRpc, responseStream, asyncCall.CancellationToken); in HandleCall()
348 …pc, ServerResponseStream<TRequest, TResponse> serverResponseStream, CancellationToken cancellation…
|
| /external/grpc-grpc/src/csharp/Grpc.Reflection/ |
| D | ReflectionGrpc.cs | 97 … null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threa… in ServerReflectionInfo()
|