| 990 | } |
| 991 | |
| 992 | std::size_t Logger::GetThreadLocalQueueCapacity() noexcept |
| 993 | { |
| 994 | using namespace Implementation; |
| 995 | |
| 996 | if constexpr (DefaultQueueType == QueueType::UnboundedDropping || DefaultQueueType == QueueType::UnboundedBlocking) { |
| 997 | if (_threadContext != nullptr) { |
| 998 | return _threadContext->GetSpscQueue<DefaultQueueType>().producerCapacity(); |
| 999 | } |
| 1000 | } else { |
| 1001 | if (_threadContext != nullptr) { |
| 1002 | return _threadContext->GetSpscQueue<DefaultQueueType>().capacity(); |
| 1003 | } |
| 1004 | } |
| 1005 | |
| 1006 | return 0; |
| 1007 | } |
| 1008 | |
| 1009 | ThreadContext* Logger::GetLocalThreadContext() noexcept |
| 1010 | { |
no test coverage detected