Lines Matching refs:actions_

60     if (actions_.find(hint_type) == actions_.end()) {  in IsHintSupported()
68 std::lock_guard<std::mutex> lock(actions_.at(hint_type).hint_lock); in IsHintEnabled()
69 return actions_.at(hint_type).mask_requesters.empty(); in IsHintEnabled()
76 for (auto &a : hm->actions_) { in InitHintStatus()
95 std::lock_guard<std::mutex> lock(actions_.at(hint_type).hint_lock); in DoHintStatus()
96 actions_.at(hint_type).status->stats.count.fetch_add(1); in DoHintStatus()
100 if (now > actions_.at(hint_type).status->end_time) { in DoHintStatus()
101 actions_.at(hint_type).status->stats.duration_ms.fetch_add( in DoHintStatus()
103 actions_.at(hint_type).status->end_time - in DoHintStatus()
104 actions_.at(hint_type).status->start_time) in DoHintStatus()
106 actions_.at(hint_type).status->start_time = now; in DoHintStatus()
108 actions_.at(hint_type).status->end_time = in DoHintStatus()
113 std::lock_guard<std::mutex> lock(actions_.at(hint_type).hint_lock); in EndHintStatus()
117 if (now < actions_.at(hint_type).status->end_time) { in EndHintStatus()
118 actions_.at(hint_type).status->stats.duration_ms.fetch_add( in EndHintStatus()
120 now - actions_.at(hint_type).status->start_time) in EndHintStatus()
122 actions_.at(hint_type).status->end_time = now; in EndHintStatus()
127 for (auto &action : actions_.at(hint_type).hint_actions) { in DoHintAction()
141 if (actions_.find(action.value) == actions_.end()) { in DoHintAction()
144 std::lock_guard<std::mutex> lock(actions_.at(hint_type).hint_lock); in DoHintAction()
145 actions_.at(action.value).mask_requesters.insert(hint_type); in DoHintAction()
158 for (auto &action : actions_.at(hint_type).hint_actions) { in EndHintAction()
160 actions_.find(action.value) != actions_.end()) { in EndHintAction()
161 std::lock_guard<std::mutex> lock(actions_.at(hint_type).hint_lock); in EndHintAction()
162 actions_.at(action.value).mask_requesters.erase(hint_type); in EndHintAction()
170 !nm_->Request(actions_.at(hint_type).node_actions, hint_type)) { in DoHint()
173 DoHintStatus(hint_type, actions_.at(hint_type).status->max_timeout); in DoHint()
185 std::vector<NodeAction> actions_override = actions_.at(hint_type).node_actions; in DoHint()
199 if (!ValidateHint(hint_type) || !nm_->Cancel(actions_.at(hint_type).node_actions, hint_type)) { in EndHint()
213 for (auto const& action : actions_) { in GetHints()
222 std::lock_guard<std::mutex> lock(actions_.at(hint_type).hint_lock); in GetHintStats()
224 actions_.at(hint_type).status->stats.count.load(std::memory_order_relaxed); in GetHintStats()
226 actions_.at(hint_type).status->stats.duration_ms.load(std::memory_order_relaxed); in GetHintStats()