Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-09 10:08:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

cluster/websocket: Debug output fixes

Browse source
This commit is contained in:
Arne Welzel 2025-04-16 14:39:20 +02:00
parent b8382a126c
commit ba5dcb1d84
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/cluster/websocket/WebSocket.cc
View file

@ -358,7 +358,8 @@ void WebSocketEventDispatcher::Process(const WebSocketSubscribeFinished& fin) {
entry.wsc->SendAck(entry.backend->NodeId(), zeek::zeek_version()); entry.wsc->SendAck(entry.backend->NodeId(), zeek::zeek_version());
WS_DEBUG("Sent Ack to %s %s\n", fin.id.c_str(), entry.backend->NodeId().c_str()); WS_DEBUG("Sent Ack to client %s (%s:%d) %s\n", fin.id.c_str(), wsc->getRemoteIp().c_str(), wsc->getRemotePort(),
entry.backend->NodeId().c_str());
// Process any queued messages now. // Process any queued messages now.
for ( auto& msg : entry.queue ) { for ( auto& msg : entry.queue ) {
@ -485,13 +486,12 @@ void WebSocketEventDispatcher::Process(const WebSocketMessage& msg) {
const auto& wsc = entry.wsc; const auto& wsc = entry.wsc;
entry.msg_count++; entry.msg_count++;
WS_DEBUG("Message %" PRIu64 " size=%zu from %s (%s:%d) backend=%p", entry.msg_count, msg.msg.size(), WS_DEBUG("Message %" PRIu64 " size=%zu from client %s (%s:%d) backend=%p", entry.msg_count, msg.msg.size(),
wsc->getId().c_str(), wsc->getRemoteIp().c_str(), wsc->getRemotePort(), entry.backend.get()); wsc->getId().c_str(), wsc->getRemoteIp().c_str(), wsc->getRemotePort(), entry.backend.get());
// First message is the subscription message. // First message is the subscription message.
if ( entry.msg_count == 1 ) { if ( entry.msg_count == 1 ) {
WS_DEBUG("Subscriptions from client: %s: (%s:%d)\n", id.c_str(), wsc->getRemoteIp().c_str(), WS_DEBUG("Subscriptions from client %s: (%s:%d)", id.c_str(), wsc->getRemoteIp().c_str(), wsc->getRemotePort());
wsc->getRemotePort());
HandleSubscriptions(entry, msg.msg); HandleSubscriptions(entry, msg.msg);
} }
else { else {