florian/mesytec-mnode
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

better logging

Browse source
This commit is contained in:
Florian Lüke 2024-11-22 13:05:49 +01:00
parent a0857b203b
commit 8497488cb3
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/mnode_proto_test1.cc
View file

@ -25,7 +25,7 @@ void requester(nng_socket socket, unsigned id)
auto reqMsg = nng::make_message(ping.SerializeAsString()); auto reqMsg = nng::make_message(ping.SerializeAsString());
if (int rc = nng_sendmsg(socket, reqMsg.release(), 0)) if (int rc = nng_sendmsg(socket, reqMsg.release(), 0))
{ {
nng::mesy_nng_error("nng_sendmsg", rc); nng::mesy_nng_error("req: nng_sendmsg", rc);
if (rc != NNG_ETIMEDOUT) if (rc != NNG_ETIMEDOUT)
return; return;
continue; continue;
@ -34,7 +34,7 @@ void requester(nng_socket socket, unsigned id)
auto [repMsg, rc] = nng::receive_message(socket); auto [repMsg, rc] = nng::receive_message(socket);
if (rc) if (rc)
{ {
nng::mesy_nng_error("nng_recvmsg", rc); nng::mesy_nng_error("requester: nng_recvmsg", rc);
if (rc != NNG_ETIMEDOUT) if (rc != NNG_ETIMEDOUT)
return; return;
continue; continue;
@ -61,7 +61,7 @@ void responder(nng_socket socket, unsigned id)
auto [reqMsg, rc] = nng::receive_message(socket); auto [reqMsg, rc] = nng::receive_message(socket);
if (rc) if (rc)
{ {
nng::mesy_nng_error("nng_recvmsg", rc); nng::mesy_nng_error("responder: nng_recvmsg", rc);
if (rc != NNG_ETIMEDOUT) if (rc != NNG_ETIMEDOUT)
return; return;
continue; continue;
@ -74,7 +74,7 @@ void responder(nng_socket socket, unsigned id)
auto repMsg = nng::make_message(pong.SerializeAsString()); auto repMsg = nng::make_message(pong.SerializeAsString());
if (int rc = nng_sendmsg(socket, repMsg.release(), 0)) if (int rc = nng_sendmsg(socket, repMsg.release(), 0))
{ {
nng::mesy_nng_error("nng_sendmsg", rc); nng::mesy_nng_error("responder: nng_sendmsg", rc);
if (rc != NNG_ETIMEDOUT) if (rc != NNG_ETIMEDOUT)
return; return;
continue; continue;