| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker.h | 50 StatusCallback done) override;
54 StatusCallback done) override;
59 StatusCallback done) override;
63 StatusCallback done) override;
67 StatusCallback done) override;
71 StatusCallback done) override;
79 StatusCallback done) override;
83 StatusCallback done) override;
86 TensorResponse* response, StatusCallback done) override;
89 StatusCallback done) override;
[all …]
|
| D | test_utils.h | 35 StatusCallback done) override { in GetStatusAsync()
41 StatusCallback done) override { in CreateWorkerSessionAsync()
48 StatusCallback done) override { in DeleteWorkerSessionAsync()
54 StatusCallback done) override { in RegisterGraphAsync()
60 StatusCallback done) override { in DeregisterGraphAsync()
66 StatusCallback done) override { in RunGraphAsync()
72 StatusCallback done) override { in CleanupGraphAsync()
78 StatusCallback done) override { in CleanupAllAsync()
83 TensorResponse* response, StatusCallback done) override { in RecvTensorAsync()
88 StatusCallback done) override { in LoggingAsync()
[all …]
|
| D | worker_interface.h | 31 typedef std::function<void(const Status&)> StatusCallback; typedef
42 StatusCallback done) = 0;
46 CreateWorkerSessionResponse* response, StatusCallback done) = 0;
50 DeleteWorkerSessionResponse* response, StatusCallback done) = 0;
54 StatusCallback done) = 0;
58 StatusCallback done) = 0;
62 StatusCallback done) = 0;
65 RunGraphResponse* response, StatusCallback done) { in RunGraphAsync()
98 StatusCallback done) = 0;
102 StatusCallback done) = 0;
[all …]
|
| D | worker.cc | 40 StatusCallback done) { in GetStatusAsync()
53 StatusCallback done) { in CreateWorkerSessionAsync()
64 StatusCallback done) { in DeleteWorkerSessionAsync()
71 StatusCallback done) { in RegisterGraphAsync()
92 StatusCallback done) { in DeregisterGraphAsync()
139 StatusCallback done) { in RunGraphAsync()
163 StatusCallback done) { in DoRunGraph()
264 StatusCallback done) { in DoPartialRunGraph()
353 StatusCallback done) { in CleanupGraphAsync()
370 StatusCallback done) { in CleanupAllAsync()
[all …]
|
| D | collective_param_resolver_distributed.h | 39 const StatusCallback& done) override;
44 const StatusCallback& done) override;
49 const StatusCallback& done) override;
88 const StatusCallback& done)
|
| D | graph_mgr.h | 89 typedef std::function<void(const Status&)> StatusCallback; typedef
95 const NamedTensors& in, StatusCallback done);
100 StatusCallback done);
172 WorkerSession* session, StatusCallback done);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_remote_worker.cc | 76 StatusCallback done) override { in GetStatusAsync()
83 StatusCallback done) override { in CreateWorkerSessionAsync()
90 StatusCallback done) override { in DeleteWorkerSessionAsync()
97 StatusCallback done) override { in RegisterGraphAsync()
103 StatusCallback done) override { in DeregisterGraphAsync()
108 RunGraphResponse* response, StatusCallback done) override { in RunGraphAsync()
113 StatusCallback done) override { in RunGraphAsync()
120 StatusCallback done) override { in CleanupGraphAsync()
126 StatusCallback done) override { in CleanupAllAsync()
131 RecvBufResponse* response, StatusCallback done) override { in RecvBufAsync()
[all …]
|
| D | grpc_worker_service.h | 47 StatusCallback done);
50 StatusCallback done) override;
53 RecvBufResponse* response, StatusCallback done) override;
57 StatusCallback done) override;
|
| /external/libchrome/base/files/ |
| D | file_proxy.h | 43 using StatusCallback = OnceCallback<void(File::Error)>;
64 StatusCallback callback);
98 bool Close(StatusCallback callback);
121 StatusCallback callback);
125 bool SetLength(int64_t length, StatusCallback callback);
129 bool Flush(StatusCallback callback);
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | permuter.h | 50 void Run(StatusCallback done) override;
69 StatusCallback done_;
75 const StatusCallback& done);
78 const StatusCallback& done);
83 StatusCallback CheckCounterAndCallDone();
|
| D | hierarchical_tree_broadcaster.h | 55 void Run(StatusCallback done) override;
73 const Tensor* src_tensor, const StatusCallback& done);
79 const StatusCallback& done);
86 StatusCallback done_;
|
| D | test_collective_executor_mgr.h | 41 const StatusCallback& done) override { in CompleteParamsAsync()
48 const StatusCallback& done) override { in CompleteGroupAsync()
55 const StatusCallback& done) override { in CompleteInstanceAsync()
110 const StatusCallback& done) override { in GetStepSequenceAsync()
115 const StatusCallback& done) override { in RefreshStepIdSequenceAsync()
|
| D | collective_param_resolver_local.h | 52 const StatusCallback& done) override;
57 const StatusCallback& done) override;
62 const StatusCallback& done) override;
76 std::vector<StatusCallback> waiting TF_GUARDED_BY(mu);
151 const StatusCallback& done)
160 const StatusCallback& done)
|
| D | collective_rma_local.h | 47 const StatusCallback& done) override;
56 const StatusCallback& done) override;
59 const StatusCallback& done) override;
72 const StatusCallback& done);
|
| D | executor.h | 153 typedef std::function<void(const Status&)> StatusCallback; typedef
163 ExecutorBarrier(size_t num, Rendezvous* r, StatusCallback done) in ExecutorBarrier()
170 StatusCallback Get() { in Get()
176 StatusCallback done_cb_ = nullptr;
184 StatusCallback done = nullptr; in WhenDone()
|
| D | copy_tensor.h | 35 Tensor* output, int dev_to_dev_stream_index, StatusCallback done);
48 int dev_to_dev_stream_index, StatusCallback done,
75 DeviceContext* send_dev_context, StatusCallback done);
|
| D | permuter.cc | 42 StatusCallback Permuter::CheckCounterAndCallDone() { in CheckCounterAndCallDone()
63 void Permuter::Run(StatusCallback done) { in Run()
81 const StatusCallback& done) { in DispatchSend()
97 const StatusCallback& done) { in DispatchRecv()
|
| D | gpu_device_context.h | 63 Tensor* device_tensor, StatusCallback done,
68 StatusCallback done) override;
72 StatusCallback done) const override;
|
| /external/tensorflow/tensorflow/core/tpu/ |
| D | virtual_device.cc | 28 Tensor* device_tensor, StatusCallback done,
32 Tensor* cpu_tensor, StatusCallback done) override;
35 StatusCallback done) const override;
41 StatusCallback done, in CopyCPUTensorToDevice()
51 StatusCallback done) { in CopyDeviceTensorToCPU()
59 StatusCallback done) const { in CopyTensorInSameDevice()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | collective.h | 183 const StatusCallback& done) = 0;
190 const StatusCallback& done) = 0;
197 const StatusCallback& done) = 0;
215 const StatusCallback& done) = 0;
220 const StatusCallback& done) = 0;
272 const StatusCallback& done) = 0;
281 const StatusCallback& done) = 0;
287 const StatusCallback& done) = 0;
302 const string& exec_key, StatusCallback done) { in ExecuteAsync()
311 StatusCallback done) { in CompleteParamsAsync()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_client.cc | 125 method##Response* response, StatusCallback done) \
127 StatusCallback done_wrapped = callback_wrapper(std::move(done)); \
144 method##Response* response, StatusCallback done) \
146 StatusCallback done_wrapped = callback_wrapper(std::move(done)); \
160 StatusCallback done) override { in CloseContextAsync()
161 StatusCallback done_wrapped = callback_wrapper(std::move(done)); in CloseContextAsync()
185 StatusCallback done) override { in StreamingEnqueueAsync()
186 StatusCallback done_wrapped = callback_wrapper(std::move(done)); in StreamingEnqueueAsync()
226 StatusCallback callback_wrapper(StatusCallback done) { in callback_wrapper()
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| D | gpu_util.h | 41 StatusCallback done);
50 StatusCallback done);
91 StatusCallback done, bool sync_dst_compute);
97 int dev_to_dev_stream_index, StatusCallback done);
107 StatusCallback done);
|
| D | gpu_util_platform_specific.cc | 29 StatusCallback done, in CopyCPUTensorToDevice()
38 StatusCallback done) { in CopyDeviceTensorToCPU()
45 StatusCallback done) const { in CopyTensorInSameDevice()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | remote_copy_node.h | 70 void RunAsync(StatusCallback done) override;
104 void StartRecv(StatusCallback done);
112 void RunRemoteRecv(EagerOperation* op, StatusCallback done);
122 void StartRemoteSendTensor(StatusCallback done);
125 void StartSendPackedHandle(StatusCallback done);
|
| D | eager_client.h | 36 StatusCallback done) = 0;
49 method##Response* response, StatusCallback done) = 0;
70 StatusCallback done) = 0;
|