| 19 | #define dout_prefix *_dout << "mgr[ThreadMonitor] " << __func__ << " " |
| 20 | |
| 21 | void ThreadMonitor::start_monitoring() { |
| 22 | if (running.exchange(true)) { |
| 23 | return; |
| 24 | } |
| 25 | |
| 26 | dout(20) << "Starting monitoring thread." << dendl; |
| 27 | monitor_thread = std::make_unique<std::thread>(&ThreadMonitor::monitoring_loop, this); |
| 28 | } |
| 29 | |
| 30 | void ThreadMonitor::stop_monitoring() { |
| 31 | if (!running.exchange(false)) { |