#include <status_monitor.h>

Public Member Functions | |
| void | addStatusMonitor (std::shared_ptr< StatusMonitor > &status_monitor) |
| MultiStatusConditionMonitor () | |
| ~MultiStatusConditionMonitor () override=default | |
Public Member Functions inherited from Aws::DataFlow::ThreadMonitor | |
| void | notify () |
| void | waitForWork () |
| std::cv_status | waitForWork (const std::chrono::microseconds &duration) |
| virtual | ~ThreadMonitor ()=default |
Protected Member Functions | |
| bool | hasWork () override |
| virtual void | setStatus (const Status &status, StatusMonitor *status_monitor) |
Protected Attributes | |
| std::atomic< uint64_t > | mask_ {} |
| MaskFactory | mask_factory_ |
| std::unordered_map< StatusMonitor *, uint64_t > | status_monitors_ |
| friend | StatusMonitor |
Multi Status Condition Monitor listens to N StatusMonitors and determines whether to trigger wait for work based on the hasWork() function.
Definition at line 116 of file status_monitor.h.
|
inline |
Definition at line 118 of file status_monitor.h.
|
overridedefault |
| void Aws::DataFlow::MultiStatusConditionMonitor::addStatusMonitor | ( | std::shared_ptr< StatusMonitor > & | status_monitor | ) |
Definition at line 53 of file status_monitor.cpp.
|
overrideprotectedvirtual |
Implements Aws::DataFlow::ThreadMonitor.
Definition at line 73 of file status_monitor.cpp.
|
protectedvirtual |
Definition at line 63 of file status_monitor.cpp.
|
protected |
Definition at line 128 of file status_monitor.h.
|
protected |
Definition at line 127 of file status_monitor.h.
|
protected |
Definition at line 129 of file status_monitor.h.
|
protected |
Definition at line 124 of file status_monitor.h.