Mirrors
/
monero
mirror of https://github.com/monero-project/monero.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #9052 

4acae11 Fix EAGAIN bug in ZMQ-RPC/ZMQ-PUB (Lee *!* Clagett)
This commit is contained in:
luigi1111 2024-01-18 17:57:30 -05:00
parent 2a6f7efca6 4acae11327
commit 9d7b253263
No known key found for this signature in database
GPG Key ID: F4ACA0183641E010
1 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/rpc/zmq_server.cpp
View File

@ -158,9 +158,17 @@ void ZmqServer::serve()
if (!pub || sockets[2].revents) if (!pub || sockets[2].revents)
{ {
std::string message = MONERO_UNWRAP(net::zmq::receive(rep.get(), read_flags)); expect<std::string> message = net::zmq::receive(rep.get(), read_flags);
MDEBUG("Received RPC request: \"" << message << "\""); if (!message)
epee::byte_slice response = handler.handle(std::move(message)); {
// EAGAIN can occur when using `zmq_poll`, which doesn't inspect for message validity
if (message != net::zmq::make_error_code(EAGAIN))
MONERO_THROW(message.error(), "Read failure on ZMQ-RPC");
}
else // no errors
{
MDEBUG("Received RPC request: \"" << *message << "\"");
epee::byte_slice response = handler.handle(std::move(*message));
const boost::string_ref response_view{reinterpret_cast<const char*>(response.data()), response.size()}; const boost::string_ref response_view{reinterpret_cast<const char*>(response.data()), response.size()};
MDEBUG("Sending RPC reply: \"" << response_view << "\""); MDEBUG("Sending RPC reply: \"" << response_view << "\"");
@ -168,6 +176,7 @@ void ZmqServer::serve()
} }
} }
} }
}
catch (const std::system_error& e) catch (const std::system_error& e)
{ {
if (e.code() != net::zmq::make_error_code(ETERM)) if (e.code() != net::zmq::make_error_code(ETERM))