Home
last modified time | relevance | path

Searched defs:cancellation_manager (Results 1 – 25 of 46) sorted by relevance

12

/external/tensorflow/tensorflow/core/distributed_runtime/
Dpartial_run_mgr_test.cc28 CancellationManager* cancellation_manager; in TEST() local
37 CancellationManager* cancellation_manager; in TEST() local
49 CancellationManager* cancellation_manager; in TEST() local
63 CancellationManager* cancellation_manager; in TEST() local
111 CancellationManager* cancellation_manager; in TEST_P() local
127 CancellationManager* cancellation_manager; in TEST_P() local
Dpartial_run_mgr.h72 std::unique_ptr<CancellationManager> cancellation_manager; member
Dpartial_run_mgr.cc23 CancellationManager** cancellation_manager) { in FindOrCreate()
/external/tensorflow/tensorflow/core/common_runtime/eager/
Dkernel_and_device.cc238 CancellationManager cancellation_manager; member
245 CancellationManager* cancellation_manager, in Run()
324 CancellationManager* cancellation_manager, in Run()
341 CancellationManager* cancellation_manager, in RunAsync()
Dexecute_node.h99 CancellationManager* cancellation_manager, in ExecuteNode()
155 CancellationManager* cancellation_manager, in AsyncExecuteNode()
Deager_operation.h180 void SetCancellationManager(CancellationManager* cancellation_manager) { in SetCancellationManager()
/external/tensorflow/tensorflow/core/common_runtime/
Dbuf_rendezvous.cc90 CancellationManager* cancellation_manager) { in ProvideBuf()
152 CancellationManager* cancellation_manager) { in ConsumeBuf()
Dcollective_rma_local.cc31 CancellationManager* cancellation_manager, const StatusCallback& done) { in RecvFromPeer()
102 CancellationManager* cancellation_manager, const StatusCallback& done) { in PostToPeer()
Dbuf_rendezvous.h70 CancellationManager* cancellation_manager; member
Dexecutor.h100 CancellationManager* cancellation_manager = nullptr; member
Dgraph_runner.cc185 CancellationManager cancellation_manager; in Run() local
Dpermuter_test.cc80 CancellationManager* cancellation_manager, in RecvFromPeer()
95 CancellationManager* cancellation_manager, in PostToPeer()
/external/tensorflow/tensorflow/core/tpu/
Dtpu_execute.cc321 OpKernelContext* ctx, CancellationManager* cancellation_manager, in RegisterCancellation()
359 OpKernelContext* ctx, CancellationManager* cancellation_manager, in UnregisterCancellation()
419 CancellationManager* cancellation_manager, OpKernelContext* ctx, in TPUExecute()
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Dto_tf_record_op.cc82 CancellationManager cancellation_manager(ctx->cancellation_manager()); in DoCompute() local
/external/tensorflow/tensorflow/core/kernels/
Dconditional_accumulator_base.cc111 CancellationManager* cancellation_manager, CancellationToken token) { in Cancel()
Dconditional_accumulator_base.h96 CancellationManager* cancellation_manager; // not owned member
Dqueue_base.h158 CancellationManager* cancellation_manager; // not owned member
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dremote_execute_node.h43 CancellationManager* cancellation_manager, in RemoteExecuteNode()
/external/tensorflow/tensorflow/core/framework/
Dcancellation.cc209 Status RegisterCancellationCallback(CancellationManager* cancellation_manager, in RegisterCancellationCallback()
Drendezvous.h54 CancellationManager* cancellation_manager = nullptr; // not owned. member
/external/tensorflow/tensorflow/core/kernels/data/
Diterator_ops.h108 CancellationManager* cancellation_manager() { in cancellation_manager() function
Dcaptured_function.cc849 CancellationManager cancellation_manager(ctx->cancellation_manager()); in Run() local
912 CancellationManager cancellation_manager(ctx->cancellation_manager()); in RunWithBorrowedArgs() local
967 CancellationManager cancellation_manager; in RunInstantiated() local
1013 auto cancellation_manager = in RunAsync() local
/external/tensorflow/tensorflow/c/eager/
Dc_api_experimental.cc494 TFE_CancellationManager* cancellation_manager) { in TFE_CancellationManagerStartCancel()
499 TFE_CancellationManager* cancellation_manager) { in TFE_CancellationManagerIsCancelled()
504 TFE_CancellationManager* cancellation_manager) { in TFE_DeleteCancellationManager()
509 TFE_CancellationManager* cancellation_manager, in TFE_OpSetCancellationManager()
/external/tensorflow/tensorflow/python/eager/
Dexecute.py85 cancellation_manager, argument
Dfunction.py537 def call(self, ctx, args, cancellation_manager=None): argument
1695 def _call_impl(self, args, kwargs, cancellation_manager=None): argument
1713 def _call_with_flat_signature(self, args, kwargs, cancellation_manager): argument
1762 def _call_with_structured_signature(self, args, kwargs, cancellation_manager): argument
1868 def _call_flat(self, args, captured_inputs, cancellation_manager=None): argument
1960 def _experimental_with_cancellation_manager(self, cancellation_manager): argument

12