Searched refs:running_ (Results 1 – 16 of 16) sorted by relevance
32 SnapshotMergeStats::SnapshotMergeStats(const std::string& path) : path_(path), running_(false) {} in SnapshotMergeStats()70 if (running_) { in Start()71 LOG(ERROR) << "SnapshotMergeStats running_ == " << running_; in Start()74 running_ = true; in Start()114 if (!running_) { in Finish()115 LOG(ERROR) << "SnapshotMergeStats running_ == " << running_; in Finish()118 running_ = false; in Finish()
54 running_ = true; in RunLoop()62 running_ = false; in RunLoop()72 if (!running_) { in OnIncomingEvent()82 std::atomic<bool> running_ = false; variable
65 running_(false), in CleanupPreviousUpdateAction()83 running_ = true; in ResumeAction()89 running_ = false; in SuspendAction()93 running_ = false; in ActionCompleted()122 TEST_AND_RETURN(running_); in ScheduleWaitBootCompleted()131 TEST_AND_RETURN(running_); in WaitBootCompletedOrSchedule()144 TEST_AND_RETURN(running_); in ScheduleWaitMarkBootSuccessful()154 TEST_AND_RETURN(running_); in CheckSlotMarkedSuccessfulOrSchedule()214 TEST_AND_RETURN(running_); in ScheduleWaitForMerge()223 TEST_AND_RETURN(running_); in WaitForMergeOrSchedule()[all …]
73 bool running_{false};
34 running_(false), in IPCHandlerLinux()45 CHECK(!running_); in Run()102 running_ = true; // Set this here before launching the thread. in Run()108 running_ = false; in Run()138 CHECK(running_); in StartListeningOnThread()178 running_ = false; in ShutDownOnOriginThread()
63 bool running_ ATTRIBUTE_UNUSED;65 bool running_; variable
128 if (!std::atomic_exchange(&running_, false)) { in stopThread()152 if (std::atomic_exchange(&running_, true)) { in tryStartThread()231 while (running_) { in ThreadRoutine()249 if (!running_) { in ThreadRoutine()257 std::atomic_bool running_{false}; member in test_vendor_lib::AsyncManager::AsyncFdWatcher323 if (!running_) { in stopThread()326 running_ = false; in stopThread()420 if (running_) { in tryStartThread()424 running_ = true; in tryStartThread()434 while (running_) { in ThreadRoutine()[all …]
72 if (std::atomic_exchange(&running_, true)) return 0; in tryStartThread()88 if (!std::atomic_exchange(&running_, false)) return 0; in stopThread()126 while (running_) { in ThreadRoutine()
51 std::atomic_bool running_{false};
54 running_ = value; in SetRunning()59 return running_; in IsRunning()223 bool running_ GUARDED_BY(run_mutex_);
137 bool running_ GUARDED_BY(reconnect_mutex_) = true;154 running_ = false; in Stop()172 if (!running_) return; in TrackTransport()202 if (!running_) return; in Run()
69 bool running_{false};
100 std::vector<Test*> running_; variable
253 running_[run_index] = test; in LaunchTests()273 Test* test = running_[i]; in ReadTestsOutput()379 running_[run_index] = nullptr; in CheckTestsFinished()441 running_.clear(); in RunAllTests()442 running_.resize(job_count); in RunAllTests()
53 pending_requests_cond_var_.wait(lock, [this] { return !running_; }); in ~Worker()57 bool start_thread = !running_; in addRequest()58 running_ = true; in addRequest()65 while (running_) { in addRequest()77 running_ = false; in addRequest()
109 bool running_ = false; variable