Skip to content

Commit

Permalink
[core] Added a trailing space in CONID()
Browse files Browse the repository at this point in the history
  • Loading branch information
gou4shi1 authored and maxsharabayko committed Sep 28, 2022
1 parent 43a7c32 commit 229192c
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 10 deletions.
8 changes: 4 additions & 4 deletions srtcore/api.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1946,9 +1946,9 @@ void srt::CUDTUnited::deleteGroup_LOCKED(CUDTGroup* g)

int srt::CUDTUnited::close(CUDTSocket* s)
{
HLOGC(smlog.Debug, log << s->core().CONID() << " CLOSE. Acquiring control lock");
HLOGC(smlog.Debug, log << s->core().CONID() << "CLOSE. Acquiring control lock");
ScopedLock socket_cg(s->m_ControlLock);
HLOGC(smlog.Debug, log << s->core().CONID() << " CLOSING (removing from listening, closing CUDT)");
HLOGC(smlog.Debug, log << s->core().CONID() << "CLOSING (removing from listening, closing CUDT)");

const bool synch_close_snd = s->core().m_config.bSynSending;

Expand All @@ -1971,7 +1971,7 @@ int srt::CUDTUnited::close(CUDTSocket* s)
// be unable to bind to this port that the about-to-delete listener
// is currently occupying (due to blocked slot in the RcvQueue).

HLOGC(smlog.Debug, log << s->core().CONID() << " CLOSING (removing listener immediately)");
HLOGC(smlog.Debug, log << s->core().CONID() << "CLOSING (removing listener immediately)");
s->core().notListening();

// broadcast all "accept" waiting
Expand All @@ -1989,7 +1989,7 @@ int srt::CUDTUnited::close(CUDTSocket* s)
// synchronize with garbage collection.
HLOGC(smlog.Debug,
log << "@" << u << "U::close done. GLOBAL CLOSE: " << s->core().CONID()
<< ". Acquiring GLOBAL control lock");
<< "Acquiring GLOBAL control lock");
ScopedLock manager_cg(m_GlobControlLock);
// since "s" is located before m_GlobControlLock, locate it again in case
// it became invalid
Expand Down
10 changes: 5 additions & 5 deletions srtcore/core.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -6094,13 +6094,13 @@ bool srt::CUDT::closeInternal()
// that has m_bBroken == false or m_bConnected == true.
// If it is intended to forcefully close the socket, make sure
// that it's in response to a broken connection.
HLOGC(smlog.Debug, log << CONID() << " - closing socket:");
HLOGC(smlog.Debug, log << CONID() << "closing socket");

if (m_config.Linger.l_onoff != 0)
{
const steady_clock::time_point entertime = steady_clock::now();

HLOGC(smlog.Debug, log << CONID() << " ... (linger)");
HLOGC(smlog.Debug, log << CONID() << "... (linger)");
while (!m_bBroken && m_bConnected && (m_pSndBuffer->getCurrBufSize() > 0) &&
(steady_clock::now() - entertime < seconds_from(m_config.Linger.l_linger)))
{
Expand Down Expand Up @@ -7726,7 +7726,7 @@ void srt::CUDT::ackDataUpTo(int32_t ack)
if (acksize < 0)
{
LOGC(xtlog.Error,
log << CONID() << " ackDataUpTo: IPE: invalid ACK from %" << m_iRcvLastSkipAck << " to %" << ack << " ("
log << CONID() << "ackDataUpTo: IPE: invalid ACK from %" << m_iRcvLastSkipAck << " to %" << ack << " ("
<< acksize << " packets)");
return;
}
Expand Down Expand Up @@ -7772,7 +7772,7 @@ void srt::CUDT::dropToGroupRecvBase() {
if (cnt > 0)
{
HLOGC(grlog.Debug,
log << "dropToGroupRecvBase: " << CONID() << " dropped " << cnt << " packets before ACK: group_recv_base="
log << "dropToGroupRecvBase: " << CONID() << "dropped " << cnt << " packets before ACK: group_recv_base="
<< group_recv_base << " m_iRcvLastSkipAck=" << m_iRcvLastSkipAck
<< " m_iRcvCurrSeqNo=" << m_iRcvCurrSeqNo << " m_bTsbPd=" << m_bTsbPd);
}
Expand Down Expand Up @@ -8008,7 +8008,7 @@ int srt::CUDT::sendCtrlAck(CPacket& ctrlpkt, int size)
ctrlpkt.pack(UMSG_ACK, NULL, &ack, size);
ctrlpkt.m_iID = m_PeerID;
nbsent = m_pSndQueue->sendto(m_PeerAddr, ctrlpkt);
DebugAck("sendCtrl(lite):" + CONID(), local_prevack, ack);
DebugAck("sendCtrl(lite): " + CONID(), local_prevack, ack);
return nbsent;
}

Expand Down
2 changes: 1 addition & 1 deletion srtcore/core.h
Original file line number Diff line number Diff line change
Expand Up @@ -288,7 +288,7 @@ class CUDT
{
#if ENABLE_LOGGING
std::ostringstream os;
os << "@" << m_SocketID << ":";
os << "@" << m_SocketID << ": ";
return os.str();
#else
return "";
Expand Down

0 comments on commit 229192c

Please sign in to comment.