| 288 | void processThreadReady(); |
| 289 | void trackAtPriority(TaskPriority priority, double now); |
| 290 | void stopImmediately() { |
| 291 | #ifdef ADDRESS_SANITIZER |
| 292 | // Do leak check before intentionally leaking a bunch of memory |
| 293 | __lsan_do_leak_check(); |
| 294 | #endif |
| 295 | stopped = true; |
| 296 | decltype(ready) _1; |
| 297 | ready.swap(_1); |
| 298 | decltype(timers) _2; |
| 299 | timers.swap(_2); |
| 300 | } |
| 301 | |
| 302 | Future<Void> timeOffsetLogger; |
| 303 | Future<Void> logTimeOffset(); |