# HG changeset patch # User Sebastien Jodogne # Date 1598962935 -7200 # Node ID e8005a58de166e8ee66951faf7cd4b911b536b0e # Parent 88d704264d647dd0215932a61c48414f5e0fffbe SharedMessageQueue::GetSize() diff -r 88d704264d64 -r e8005a58de16 OrthancFramework/Sources/MultiThreading/SharedMessageQueue.cpp --- a/OrthancFramework/Sources/MultiThreading/SharedMessageQueue.cpp Tue Sep 01 10:19:29 2020 +0200 +++ b/OrthancFramework/Sources/MultiThreading/SharedMessageQueue.cpp Tue Sep 01 14:22:15 2020 +0200 @@ -197,4 +197,10 @@ emptied_.notify_all(); } } + + size_t SharedMessageQueue::GetSize() + { + boost::mutex::scoped_lock lock(mutex_); + return queue_.size(); + } } diff -r 88d704264d64 -r e8005a58de16 OrthancFramework/Sources/MultiThreading/SharedMessageQueue.h --- a/OrthancFramework/Sources/MultiThreading/SharedMessageQueue.h Tue Sep 01 10:19:29 2020 +0200 +++ b/OrthancFramework/Sources/MultiThreading/SharedMessageQueue.h Tue Sep 01 14:22:15 2020 +0200 @@ -70,5 +70,7 @@ void SetLifoPolicy(); void Clear(); + + size_t GetSize(); }; }