| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| master.h | 45 CreateSessionResponse* resp, MyClosure done);
48 ExtendSessionResponse* resp, MyClosure done);
51 PartialRunSetupResponse* resp, MyClosure done);
54 MutableRunStepResponseWrapper* resp, MyClosure done);
57 MyClosure done);
60 MyClosure done);
63 void Reset(const ResetRequest* req, ResetResponse* resp, MyClosure done);
66 MyClosure done);
68 RunCallableResponse* resp, MyClosure done);
70 ReleaseCallableResponse* resp, MyClosure done);
[all...] |
| worker.cc | 34 GetStatusResponse* response, StatusCallback done) {
42 done(Status::OK());
47 StatusCallback done) {
51 done(s);
57 StatusCallback done) {
59 done(s);
64 StatusCallback done) {
80 done(s);
85 StatusCallback done) {
98 done(s)
[all...] |
| device_resolver_distributed.cc | 29 const StatusCallback& done) {
37 done(s);
51 done(Status::OK());
58 device, task, [this, device, task, locality, done](const Status& s) {
60 done(s);
62 GetLocalityAsync(device, task, locality, done);
69 std::vector<DeviceLocality>* localities, const StatusCallback& done) {
71 GetDeviceLocalitiesRecursive(inst_params, localities, done);
76 std::vector<DeviceLocality>* localities, const StatusCallback& done) {
82 [this, &inst_params, localities, done](const Status& s)
[all...] |
| device_resolver_distributed.h | 39 const StatusCallback& done) override;
43 const StatusCallback& done) override;
50 const StatusCallback& done) LOCKS_EXCLUDED(mu_);
57 const StatusCallback& done);
|
| collective_param_resolver_distributed.h | 36 const StatusCallback& done) override;
41 const StatusCallback& done) override;
46 const StatusCallback& done) override;
64 const GroupRecCallback& done);
73 const StatusCallback& done)
82 const StatusCallback& done)
|
| /external/webrtc/webrtc/base/ |
| sharedexclusivelock_unittest.cc | 33 bool* done)
37 done_(done) {
54 ReadTask(SharedExclusiveLock* shared_exclusive_lock, int* value, bool* done)
55 : SharedExclusiveTask(shared_exclusive_lock, value, done) {
87 WriteTask(SharedExclusiveLock* shared_exclusive_lock, int* value, bool* done)
88 : SharedExclusiveTask(shared_exclusive_lock, value, done) {
161 bool done; local
162 WriteTask writer(shared_exclusive_lock_.get(), &value_, &done);
168 done = false;
174 EXPECT_TRUE_WAIT(done, kProcessTimeoutInMs)
181 bool done; local
200 bool done; local
[all...] |
| /external/eigen/unsupported/test/ |
| cxx11_non_blocking_thread_pool.cpp | 34 std::atomic<int> done(0);
45 done++;
69 done++;
76 done++;
80 done++;
92 done++;
98 while (done != 3 * kThreads) {
|
| /external/perfetto/src/traced/service/ |
| lazy_producer_unittest.cc | 50 auto done = task_runner.CreateCheckpoint("done"); local
55 .WillOnce(InvokeWithoutArgs([&done]() {
56 done();
61 task_runner.RunUntilCheckpoint("done");
68 auto done = task_runner.CreateCheckpoint("done"); local
78 .WillOnce(InvokeWithoutArgs([&done]() {
79 done();
83 task_runner.RunUntilCheckpoint("done");
90 auto done = task_runner.CreateCheckpoint("done"); local
[all...] |
| /external/compiler-rt/test/tsan/ |
| signal_errno.cc | 12 volatile int done; variable
16 done = 1;
27 while (done == 0) {
|
| /external/iproute2/tc/ |
| p_ip.c | 45 goto done;
51 goto done;
61 goto done;
67 goto done;
73 goto done;
79 goto done;
86 goto done;
93 goto done;
100 goto done;
106 goto done;
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| nccl_ops.cc | 38 // when the async op kernel's done callback is called.
93 void ComputeAsync(OpKernelContext* c, DoneCallback done) override {
97 done);
99 auto actual_done = [c, done](Status s) {
100 OP_REQUIRES_OK_ASYNC(c, s, done);
101 done();
130 void ComputeAsync(OpKernelContext* c, DoneCallback done) override {
131 auto actual_done = [c, done](Status s) {
132 OP_REQUIRES_OK_ASYNC(c, s, done);
133 done();
[all...] |
| /art/tools/ahat/src/main/com/android/ahat/progress/ |
| Progress.java | 27 * @param description human readable description of the work to be done.
64 void done(); method in interface:Progress
|
| /external/clang/test/PCH/ |
| stmts.h | 37 goto done;
52 done:
81 location = &&done;
89 done:
|
| /external/libyuv/ |
| setup_env.bat | 4 if "%SETUP_ENV_LIBYUV_TOOLS%"=="done" goto :EOF
5 set SETUP_ENV_LIBYUV_TOOLS=done
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_attr_setschedpolicy/ |
| 5-1.c | 60 goto done;
64 goto done;
68 goto done;
72 done:
|
| /external/protobuf/java/core/src/main/java/com/google/protobuf/ |
| RpcChannel.java | 70 RpcCallback<Message> done);
|
| /external/tensorflow/tensorflow/contrib/gdr/ |
| gdr_worker.cc | 50 StatusCallback done) {
54 done(s);
68 done(s);
80 [this, opts, response, done, src_dev, request, dma_ok](
104 on_host, [proto, done, response](const Status& s) {
108 done(Status::OK());
110 done(s);
128 StatusCallback copy_ready = [response, done, copy,
132 done(s);
140 done(Status::OK())
[all...] |
| gdr_worker.h | 39 StatusCallback done) override;
43 StatusCallback done) override;
|
| /external/v8/src/interpreter/ |
| bytecode-array-iterator.cc | 21 bool BytecodeArrayIterator::done() const { function in class:v8::internal::interpreter::BytecodeArrayIterator
|
| bytecode-array-iterator.h | 20 bool done() const;
|
| /external/fec/ |
| init_rs.h | 14 goto done;
18 goto done;
20 goto done;
22 goto done; /* Can't have more roots than symbol values! */
24 goto done; /* Too much padding */
28 goto done;
38 goto done;
45 goto done;
66 goto done;
76 goto done;
[all...] |
| /bionic/libc/upstream-freebsd/lib/libc/string/ |
| wcscspn.c | 50 goto done;
56 done:
|
| wcsspn.c | 54 goto done;
58 done:
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| device_resolver_local.h | 35 const StatusCallback& done) override;
39 const StatusCallback& done) override;
|
| /external/wayland/tests/ |
| client-test.c | 43 int done; member in struct:client_destroy_listener
52 listener->done = 1;
69 a.done = 0;
76 b.done = 0;
83 assert(!a.done);
84 assert(b.done);
|
