Lines Matching refs:event

50     auto event = std::make_unique<MonitoredEvent>(typename MonitoredEventType::EndMonitoring{});  in ~HealthMonitor()  local
53 mEventQueue.push(std::move(event)); in ~HealthMonitor()
73 auto event = std::make_unique<MonitoredEvent>(typename MonitoredEventType::Start{ in startMonitoringTask() local
80 mEventQueue.push(std::move(event)); in startMonitoringTask()
86 auto event = std::make_unique<MonitoredEvent>( in touchMonitoredTask() local
89 mEventQueue.push(std::move(event)); in touchMonitoredTask()
94 auto event = std::make_unique<MonitoredEvent>( in stopMonitoringTask() local
97 mEventQueue.push(std::move(event)); in stopMonitoringTask()
102 auto event = std::make_unique<MonitoredEvent>(typename MonitoredEventType::Poll{}); in poll() local
104 std::get<typename MonitoredEventType::Poll>(*event).complete.get_future(); in poll()
107 mEventQueue.push(std::move(event)); in poll()
135 auto event(std::move(events.front())); in main() local
139 [](std::monostate& event) { in main() argument
144 [this, &events](typename MonitoredEventType::Start& event) { in main() argument
145 auto it = mMonitoredTasks.find(event.id); in main()
147 ERR("Registered multiple start events for task %d", event.id); in main()
150 if (event.parentId && mMonitoredTasks.find(event.parentId.value()) == in main()
153 event.parentId.value()); in main()
154 event.parentId = std::nullopt; in main()
157 .emplace(event.id, in main()
159 .id = event.id, in main()
160 .timeoutTimestamp = event.timeOccurred + in main()
161 event.timeoutThreshold, in main()
162 .timeoutThreshold = event.timeoutThreshold, in main()
164 .metadata = std::move(event.metadata), in main()
166 std::move(event.onHangAnnotationsCallback), in main()
167 .parentId = event.parentId})) in main()
169 updateTaskParent(events, it->second, event.timeOccurred); in main()
171 [this, &events](typename MonitoredEventType::Touch& event) { in main() argument
172 auto it = mMonitoredTasks.find(event.id); in main()
174 ERR("HealthMonitor has no task in progress for id %d", event.id); in main()
179 task.timeoutTimestamp = event.timeOccurred + task.timeoutThreshold; in main()
180 updateTaskParent(events, task, event.timeOccurred); in main()
183 &events](typename MonitoredEventType::Stop& event) { in main() argument
184 auto it = mMonitoredTasks.find(event.id); in main()
186 ERR("HealthMonitor has no task in progress for id %d", event.id); in main()
191 task.timeoutTimestamp = event.timeOccurred + task.timeoutThreshold; in main()
192 updateTaskParent(events, task, event.timeOccurred); in main()
196 tasksToRemove.insert(event.id); in main()
198 [&keepMonitoring](typename MonitoredEventType::EndMonitoring& event) { in main() argument
201 [&pollPromises](typename MonitoredEventType::Poll& event) { in main() argument
202 pollPromises.push_back(std::move(event.complete)); in main()
204 *event); in main()
268 auto event = std::make_unique<MonitoredEvent>(typename MonitoredEventType::Touch{ in updateTaskParent() local
270 events.push(std::move(event)); in updateTaskParent()