| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| rpc_rendezvous_mgr.cc | 48 DoneCallback done) override;
63 const Rendezvous::Args& recv_args, Rendezvous::DoneCallback done) {
68 done_ = std::move(done);
131 const Rendezvous::DoneCallback& done() const { return done_; } function in class:tensorflow::__anon44940::RpcRecvTensorCall
218 DoneCallback done) {
249 done(s, Args(), recv_args, Tensor{}, false);
254 recv_args, std::move(done));
262 // `call->done()(...)`, so we must release the worker before calling the
265 call->done()(call->status(), Args(), Args(), Tensor(), false);
279 // `call->done()(...)`, so we must release the worker before calling th
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| sendrecv_ops.cc | 147 AsyncOpKernel::DoneCallback done) {
150 [ctx](AsyncOpKernel::DoneCallback done,
164 done();
166 std::move(done), _1, _2, _3, _4, _5);
170 void RecvOp::ComputeAsync(OpKernelContext* ctx, DoneCallback done) {
174 done);
184 make_recv_callback(ctx, std::move(done)));
190 ctx, Rendezvous::ParseKey(in_loop_parsed.buf_, &in_loop_parsed), done);
192 make_recv_callback(ctx, std::move(done)));
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| collective_param_resolver_local.cc | 50 CancellationManager* cancel_mgr, const StatusCallback& done) {
51 done(
58 const string& device, CollectiveParams* cp, const GroupRecCallback& done) {
131 gr->waiting.push_back(std::bind(done, std::placeholders::_1, gr));
140 done(status, gr);
402 const StatusCallback& done) {
436 [this, gr, cp, ir, localities, done](const Status& s)
447 done(Status::OK());
449 done(s);
491 const InstanceRecCallback& done, InstanceRec* irec)
[all...] |
| copy_tensor.cc | 53 DeviceContext* recv_dev_context, StatusCallback done) {
56 auto* status_cb = new ReffedStatusCallback(std::move(done));
111 std::move(done));
118 DeviceContext* send_dev_context, StatusCallback done) {
121 auto* status_cb = new ReffedStatusCallback(std::move(done));
176 std::move(done));
187 int dev_to_dev_stream_index, StatusCallback done) {
190 auto* status_cb = new ReffedStatusCallback(std::move(done));
242 std::move(done));
254 int dev_to_dev_stream_index, StatusCallback done) {
[all...] |
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| picker_wrapper.go | 41 done bool
98 if bp.done {
109 func doneChannelzWrapper(acw *acBalancerWrapper, done func(balancer.DoneInfo)) func(balancer.DoneInfo) {
120 if done != nil {
121 done(b)
150 // Done function returned is always nil.
162 if bp.done {
176 case <-ctx.Done():
187 subConn, done, err := p.Pick(ctx, opts)
214 return t, doneChannelzWrapper(acw, done), ni
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| collective_rma_distributed_test.cc | 76 StatusCallback done) override {
82 done(Status::OK());
86 RecvBufResponse* response, StatusCallback done) override {
100 [this, opts, request, response, done](const Status& s,
113 done(s);
135 StatusCallback done) override {
139 done(errors::Internal("failed to parse device name"));
144 done(errors::Internal("failed to find worker ", task_name));
152 done(status);
158 done(Status::OK())
[all...] |
| /external/virglrenderer/ |
| git.mk | 96 ; do echo "$$AUX_DIR/$$x"; done` \
98 head -n 1 | while read f; do echo "$(srcdir)/$$f.in"; done`
107 done`
120 ; do echo "$$MACRO_DIR/$$x"; done; \
151 fi; done; test -z "$$any_failed"
174 ; do echo "/$$x"; done; \
184 ; do echo "/$$lc/$$x"; done; \
185 done; \
194 ; do echo /$$x; done; \
202 ; do echo "/$$lc/$$x"; done; \
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| stunport_unittest.cc | 55 bool done() const { return done_; } function in class:StunPortTest
166 EXPECT_TRUE_WAIT(done(), kTimeoutMs);
178 EXPECT_TRUE_WAIT(done(), kTimeoutMs);
187 EXPECT_TRUE_WAIT(done(), kTimeoutMs);
197 EXPECT_TRUE_WAIT(done(), kTimeoutMs);
208 EXPECT_TRUE_WAIT(done(), kTimeoutMs);
221 EXPECT_TRUE_WAIT(done(), kTimeoutMs);
232 EXPECT_TRUE_WAIT(done(), kTimeoutMs);
251 EXPECT_TRUE_WAIT(done(), kTimeoutMs);
265 EXPECT_TRUE_WAIT(done(), kTimeoutMs)
[all...] |
| /external/tensorflow/tensorflow/core/kernels/data/ |
| iterator_ops.cc | 570 void ComputeAsync(OpKernelContext* ctx, DoneCallback done) override {
574 background_worker_.Schedule([ctx, done]() {
577 ctx, GetDatasetFromVariantTensor(ctx->input(0), &dataset), done);
591 done);
593 // NOTE(jsimsa): We must destroy the iterator before calling `done()`, to
596 auto cleanup = gtl::MakeCleanup([raw_iterator, done] {
598 done();
650 void ComputeAsync(OpKernelContext* ctx, DoneCallback done) override {
654 background_worker_.Schedule([this, ctx, done]() {
657 ctx, GetDatasetFromVariantTensor(ctx->input(0), &dataset), done);
[all...] |
| /device/linaro/hikey/l-loader/ |
| hikey960.mk | 15 done
|
| /external/clang/test/SemaCXX/ |
| goto.cpp | 112 goto done; // expected-error {{cannot jump}}
114 done:
|
| /external/curl/docs/cmdline-opts/ |
| retry-max-time.d | 7 done as usual (see --retry) as long as the timer hasn't reached this given
|
| /external/dng_sdk/source/ |
| dng_abort_sniffer.h | 213 /// \param done Amount of task completed in arbitrary integer units.
214 /// \param total Total size of task in same arbitrary integer units as done.
216 void UpdateProgress (uint32 done,
219 UpdateProgress ((real64) done /
|
| /external/grpc-grpc/src/core/lib/surface/ |
| completion_queue.h | 43 /** done callback - called when this queue element is no longer
45 void (*done)(void* done_arg, struct grpc_cq_completion* c); member in struct:grpc_cq_completion
79 void (*done)(void* done_arg, grpc_cq_completion* storage),
|
| /external/grpc-grpc/src/objective-c/tests/Connectivity/ConnectivityTestingApp/ |
| ViewController.m | 65 writeableWithEventHandler:^(BOOL done, id value, NSError *error) {
66 if (!done) {
91 writeableWithEventHandler:^(BOOL done, id value, NSError *error) {
92 if (!done) {
|
| /external/grpc-grpc/test/cpp/qps/ |
| server_sync.cc | 95 std::atomic_bool done; variable
97 std::thread t([context, stream, &response, &done, &sp]() {
98 sp = ServerPush(context, stream, response, [&done]() {
99 return done.load(std::memory_order_relaxed);
104 done.store(true, std::memory_order_relaxed); // can be lazy
133 const std::function<bool()>& done) {
134 while ((done == nullptr) || !done()) {
|
| /external/libcxx/test/support/ |
| coroutine_types.h | 34 iterator(std::experimental::coroutine_handle<promise_type> Coro, bool Done)
35 : _Coro(Coro), _Done(Done) {}
39 _Done = _Coro.done();
56 return {p, p.done()};
|
| /external/libevent/ |
| buffer_iocp.c | 188 goto done;
192 goto done;
233 goto done;
239 done:
262 goto done;
269 goto done;
299 goto done;
305 done:
|
| /external/libjpeg-turbo/ |
| jcstest.c | 83 goto done;
93 done:
|
| /external/linux-kselftest/tools/testing/selftests/kvm/x86_64/ |
| cr4_cpuid_sync_test.c | 102 goto done;
111 done:
|
| /external/ltp/testcases/kernel/mem/mmapstress/ |
| mmapstress04.c | 114 goto done;
118 done:
|
| /external/ltp/testcases/kernel/syscalls/getcwd/ |
| getcwd02.c | 62 goto done;
75 done:
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigqueue/ |
| 9-1.c | 78 goto done;
97 done:
|
| /external/protobuf/src/google/protobuf/ |
| service.h | 67 // Closure* done) {
69 // done->Run();
152 // response must not be accessed at all until "done" is called.
160 // * "done" will be called when the method is complete. This may be
171 Closure* done) = 0;
228 // canceled, the "done" callback will still be called and the RpcController
245 // final "done" callback.
283 Closure* done) = 0;
|
| /external/skia/src/pathops/ |
| SkPathOpsSimplify.cpp | 27 if (!unsortable && current->done()) {
30 SkASSERT(unsortable || !current->done());
49 } while (!writer->isClosed() && (!unsortable || !start->starter(end)->done()));
52 if (!spanStart->done()) {
104 if (!unsortable && current->done()) {
107 SkASSERT(unsortable || !current->done());
126 } while (!writer->isClosed() && (!unsortable || !start->starter(end)->done()));
129 if (!spanStart->done()) {
|
