Skip to content

Commit

Permalink
Follow up fixes after review.
Browse files Browse the repository at this point in the history
  • Loading branch information
maxsharabayko committed Aug 8, 2024
1 parent bd001c6 commit 0c3ab9e
Showing 1 changed file with 3 additions and 9 deletions.
12 changes: 3 additions & 9 deletions srtcore/queue.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -504,11 +504,9 @@ void* srt::CSndQueue::worker(void* param)
{
CSndQueue* self = (CSndQueue*)param;

#if ENABLE_LOGGING
THREAD_STATE_INIT(("SRT:SndQ:w" + Sprint(m_counter)).c_str());
#else
THREAD_STATE_INIT("SRT:SndQ:worker");
#endif
std::string thname;
ThreadName::get(thname);
THREAD_STATE_INIT(thname.c_str());

#if defined(SRT_DEBUG_SNDQ_HIGHRATE)
#define IF_DEBUG_HIGHRATE(statement) statement
Expand Down Expand Up @@ -1206,13 +1204,9 @@ void* srt::CRcvQueue::worker(void* param)
sockaddr_any sa(self->getIPversion());
int32_t id = 0;

#if ENABLE_LOGGING
std::string thname;
ThreadName::get(thname);
THREAD_STATE_INIT(thname.c_str());
#else
THREAD_STATE_INIT("SRT:RcvQ:worker");
#endif

CUnit* unit = 0;
EConnectStatus cst = CONN_AGAIN;
Expand Down

0 comments on commit 0c3ab9e

Please sign in to comment.