| /external/webrtc/webrtc/base/ |
| D | task.cc | 23 done_(false), in Task()
39 ASSERT(!done_ || GetRunner()->is_ok_to_delete(this)); in ~Task()
40 ASSERT(state_ == STATE_INIT || done_); in ~Task()
46 if (!done_) { in ~Task()
70 if (done_) { in Step()
84 done_ = true; in Step()
117 done_ = true; in Step()
119 done_ = true; in Step()
123 if (done_) { in Step()
142 if (done_) in Abort()
[all …]
|
| D | autodetectproxy_unittest.cc | 36 AutoDetectProxyTest() : auto_detect_proxy_(NULL), done_(false) {} in AutoDetectProxyTest()
63 EXPECT_TRUE_WAIT(done_, timeout_ms); in Run()
64 return done_; in Run()
95 done_ = true; in OnWorkDone()
99 bool done_; member in rtc::AutoDetectProxyTest
|
| D | sharedexclusivelock_unittest.cc | 37 done_(done) { in SharedExclusiveTask()
49 bool* done_; member in rtc::SharedExclusiveTask
78 *done_ = true; in OnMessage()
111 *done_ = true; in OnMessage()
|
| D | task.h | 105 bool IsDone() const { return done_; } in IsDone()
159 bool done_; variable
|
| /external/tensorflow/tensorflow/compiler/tf2tensorrt/utils/ |
| D | trt_int8_calibrator.cc | 37 done_(false), in TRTInt8Calibrator()
46 done_(true), in TRTInt8Calibrator()
56 while ((calib_running_ || batch_is_set_) && !done_) cond_.wait(lock); in setBatch()
57 if (done_) return false; in setBatch()
96 while ((!batch_is_set_ && !done_)) cond_.wait(lock); in getBatch()
97 if (done_) return false; in getBatch()
117 while ((calib_running_ || batch_is_set_) && !done_) cond_.wait(lock); in waitAndSetDone()
118 if (!done_) { in waitAndSetDone()
119 done_ = true; in waitAndSetDone()
132 done_ = true; in setDone()
|
| /external/v8/src/heap/ |
| D | barrier.h | 34 OneshotBarrier() : tasks_(0), waiting_(0), done_(false) {} in OneshotBarrier()
48 if (done_) return true; in Wait()
53 done_ = true; in Wait()
60 return done_; in Wait()
64 bool DoneForTesting() const { return done_; } in DoneForTesting()
71 bool done_; variable
|
| /external/libcxx/test/std/thread/thread.threads/thread.thread.class/thread.thread.member/ |
| D | detach.pass.cpp | 30 bool done_; member in G
35 G() : alive_(1), done_(false) in G()
40 G(const G& g) : alive_(g.alive_), done_(false) in G()
48 if (done_) done = true; in ~G()
56 done_ = true; in operator ()()
|
| /external/libchrome/base/threading/ |
| D | thread_local_unittest.cc | 21 done_(done) { in ThreadLocalTesterBase()
27 base::WaitableEvent* done_; member in base::__anonb73aca820111::ThreadLocalTesterBase
39 DCHECK(!done_->IsSignaled()); in Run()
41 done_->Signal(); in Run()
57 DCHECK(!done_->IsSignaled()); in Run()
59 done_->Signal(); in Run()
|
| D | simple_thread_unittest.cc | 43 done_(WaitableEvent::ResetPolicy::MANUAL, in ControlledRunner()
52 done_.Wait(); in ReleaseAndWaitUntilDone()
59 done_.Signal(); in Run()
64 WaitableEvent done_; member in base::__anona5157c010111::ControlledRunner
|
| /external/image_io/includes/image_io/jpeg/ |
| D | jpeg_scanner.h | 25 done_(false), in JpegScanner()
35 void SetDone() { done_ = true; } in SetDone()
38 bool IsDone() const { return done_; } in IsDone()
96 bool done_; variable
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_state.h | 58 done_(std::move(done)), in RPCState()
71 done_(FromGrpcStatus(s)); in RPCState()
136 done_(s); in OnCompleted()
146 done_(s); in ParseAndCallDone()
159 StatusCallback done_; variable
|
| D | rpc_rendezvous_mgr.cc | 68 done_ = std::move(done); in Init()
90 done_ = nullptr; in Reset()
131 const Rendezvous::DoneCallback& done() const { return done_; } in done()
163 Rendezvous::DoneCallback done_; member in tensorflow::__anon9a114d310111::RpcRecvTensorCall
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | outfeed_manager.h | 39 void WaitUntilAvailable() { done_.WaitForNotification(); } in WaitUntilAvailable()
48 void Done() { done_.Notify(); } in Done()
53 tensorflow::Notification done_; variable
|
| D | nccl_all_reduce_thunk.cc | 128 done_ = absl::nullopt; in DeinitializeGeneration()
145 absl::optional<tensorflow::BlockingCounter> done_; member in xla::gpu::__anona1934ea30111::GlobalRendezvousManager
207 done_.emplace(participant.replica_count); in SubmitParticipant()
233 done_->DecrementCount(); in SubmitParticipant()
243 done_->Wait(); in SubmitParticipant()
|
| /external/tensorflow/tensorflow/core/util/ |
| D | reffed_status_callback.h | 32 : done_(std::move(done)), status_(Status::OK()) {} in ReffedStatusCallback()
52 ~ReffedStatusCallback() { done_(status_); } in ~ReffedStatusCallback()
55 StatusCallback done_;
|
| /external/freetype/include/freetype/internal/ |
| D | ftobjs.h | 237 done_, \ argument
250 done_, \
1092 done_, \ argument
1103 done_, \
1141 done_, \ argument
1159 done_, \
1210 done_, \ argument
1223 done_, \
1236 done_, \ argument
1251 done_, \
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | jingleinfotask.cc | 24 done_(false) {} in JingleInfoGetTask()
36 if (done_) in ProcessResponse()
54 done_ = true; in HandleStanza()
59 bool done_; member in buzz::JingleInfoTask::JingleInfoGetTask
|
| D | xmppauth.h | 35 virtual bool IsAuthDone() const { return done_; } in IsAuthDone()
57 bool done_; variable
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | functional_ops.cc | 173 done_(std::move(done)), in State()
195 DoneCallback captured_done(std::move(done_)); in Start()
207 DoneCallback done_; member in tensorflow::__anonf4cf7ed10111::IfOp::State
262 done_(std::move(done)), in State()
288 DoneCallback captured_done(std::move(done_)); in Start()
299 DoneCallback done_; member in tensorflow::__anonf4cf7ed10111::CaseOp::State
363 done_(std::move(done)), in State()
380 const DoneCallback done_; member in tensorflow::__anonf4cf7ed10111::WhileOp::State
472 done_(); in Finish()
522 done_(std::move(done)), in State()
[all …]
|
| /external/webrtc/webrtc/test/testsupport/mac/ |
| D | run_threaded_main_mac.mm | 20 bool done_; field
34 done_ = done;
38 return done_;
50 done_ = true;
|
| /external/webrtc/webrtc/p2p/base/ |
| D | stunport_unittest.cc | 51 done_(false), error_(false), stun_keepalive_delay_(0) { in StunPortTest()
55 bool done() const { return done_; } in done()
121 ASSERT_FALSE(done_); in OnPortComplete()
122 done_ = true; in OnPortComplete()
126 done_ = true; in OnPortError()
150 bool done_; member in StunPortTest
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| D | gpu_allocator_retry_test.cc | 77 : num_users_(num_users), next_turn_(0), done_(num_users, false) {} in AlternatingBarrier()
95 done_[user_index] = true; in Done()
107 if (!done_[next_turn_]) return; in IncrementTurn()
116 std::vector<bool> done_ GUARDED_BY(mu_);
|
| /external/protobuf/src/google/protobuf/stubs/ |
| D | once_unittest.cc | 77 : done_(false), joined_(false), callback_(callback) { in TestThread()
90 return done_; in IsDone()
110 bool done_; member in google::protobuf::__anond5aa13950111::OnceInitTest::TestThread
126 done_ = true; in Start()
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | NonBlockingThreadPool.h | 30 done_(false), in env_()
63 done_ = true; in ~NonBlockingThreadPoolTempl()
131 std::atomic<bool> done_; variable
211 if (done_ && blocked_ == threads_.size()) { in WaitForWork()
|
| /external/tensorflow/tensorflow/core/util/rpc/ |
| D | call_container.h | 87 const AsyncOpKernel::DoneCallback done_; variable
104 done_(std::move(done)), in CallContainer()
119 done_(); in CallContainer()
|