Non-blocking nanomsg send.

diff --git a/src/lib/nanomsg.cc b/src/lib/nanomsg.cc
index b98c3931a551d51e1ed50f3b5e9e000e6bb544a2..591ff4bf8ce132d6dd875930dd4a2a2e6e886db8 100644 (file)
--- a/src/lib/nanomsg.cc
+++ b/src/lib/nanomsg.cc
@@ -51,7 +51,7 @@ Nanomsg::Nanomsg (bool server)
 void
 Nanomsg::send (string s)
 {
-       int const r = nn_send (_socket, s.c_str(), s.length(), 0);
+       int const r = nn_send (_socket, s.c_str(), s.length(), NN_DONTWAIT);
        if (r < 0) {
                throw runtime_error(String::compose("Could not send to nanomsg socket (%1)", errno));
        } else if (r != int(s.length())) {