Searched refs:isInjectThreadCreated_ (Results 1 – 3 of 3) sorted by relevance
38 DistributedInputNodeManager::DistributedInputNodeManager() : isInjectThreadCreated_(false), in DistributedInputNodeManager()49 isInjectThreadCreated_.store(false); in ~DistributedInputNodeManager()459 if (isInjectThreadCreated_.load()) { in StartInjectThread()464 isInjectThreadCreated_.store(true); in StartInjectThread()471 if (!isInjectThreadCreated_.load()) { in StopInjectThread()476 isInjectThreadCreated_.store(false); in StopInjectThread()
120 std::atomic<bool> isInjectThreadCreated_; variable
457 DistributedInputInject::GetInstance().inputNodeManager_->isInjectThreadCreated_.store(true);459 DistributedInputInject::GetInstance().inputNodeManager_->isInjectThreadCreated_.store(false);