| 90 | } |
| 91 | |
| 92 | void LogQueue::mark_flushing(SThreadID tid) SKR_NOEXCEPT |
| 93 | { |
| 94 | if (auto tok = query_token(tid)) |
| 95 | { |
| 96 | if (tok->query_cnt() != 0) // if there is no log in this thread, we don't need to flush |
| 97 | skr_atomic32_cas_relaxed(&tok->flush_status_, kNoFlush, kFlushing); |
| 98 | else |
| 99 | skr_atomic32_cas_relaxed(&tok->flush_status_, kNoFlush, kFlushed); |
| 100 | } |
| 101 | } |
| 102 | |
| 103 | bool LogQueue::try_dequeue(LogElement& element) SKR_NOEXCEPT |
| 104 | { |
no test coverage detected