chat example added

3 files changed, 113 insertions, 1 deletions

diff --git a/examples/chat/display.cpp b/examples/chat/display.cpp
new file mode 100755
index 0000000..d04e90b
--- /dev/null
+++ b/examples/chat/display.cpp
@@ -0,0 +1,50 @@
+/*
+    Copyright (c) 2007-2009 FastMQ Inc.
+
+    This file is part of 0MQ.
+
+    0MQ is free software; you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation; either version 3 of the License, or
+    (at your option) any later version.
+
+    0MQ is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#include <zmq.hpp>
+#include <stdio.h>
+#include <string.h>
+#include <assert.h>
+
+int main (int argc, const char *argv [])
+{
+    //  Check the command line syntax.
+    if (argc != 2) {
+        fprintf (stderr, "usage: display <address>\n");
+        return 1;
+    }
+
+    //  Retrieve command line arguments
+    const char *address = argv [1];
+
+    //  Initialise 0MQ infrastructure.
+    zmq::context_t ctx (1, 1);
+    zmq::socket_t s (ctx, ZMQ_SUB);
+    s.setsockopt (ZMQ_SUBSCRIBE, "*", 1);
+    s.connect (address);
+    
+    while (true) {
+
+        //  Get a message and print it to the console.
+        zmq::message_t msg;
+        s.recv (&msg);
+        fprintf (stdout, "%s", (char*) msg.data ());
+        fflush (stdout);
+    }
+}
diff --git a/examples/chat/prompt.cpp b/examples/chat/prompt.cpp
new file mode 100644
index 0000000..6132d63
--- /dev/null
+++ b/examples/chat/prompt.cpp
@@ -0,0 +1,62 @@
+/*
+    Copyright (c) 2007-2009 FastMQ Inc.
+
+    This file is part of 0MQ.
+
+    0MQ is free software; you can redistribute it and/or modify
+    it under the terms of the GNU General Public License as published by
+    the Free Software Foundation; either version 3 of the License, or
+    (at your option) any later version.
+
+    0MQ is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program.  If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#include <zmq.hpp>
+#include <stdio.h>
+#include <string.h>
+#include <assert.h>
+
+int main (int argc, const char *argv [])
+{
+    //  Check the command line syntax.
+    if (argc != 3) {
+        fprintf (stderr, "usage: prompt <address> <username>\n");
+        return 1;
+    }
+
+    //  Retrieve command line arguments
+    const char *address = argv [1];
+    const char *username = argv [2];
+
+    //  Initialise 0MQ infrastructure.
+    zmq::context_t ctx (1, 1);
+    zmq::socket_t s (ctx, ZMQ_PUB);
+    s.connect (address);
+
+    //  Prepare a message buffer. Place username at the beginning
+    //  of the message.
+    char textbuf [1024];
+    snprintf (textbuf, sizeof (textbuf), "%s: ", username);
+    size_t prefixsz = strlen (textbuf);
+    char *text = textbuf + prefixsz;
+    
+    while (true) {
+
+        //  Let user type the enter the message text.
+        char *rcc = fgets (text, sizeof (textbuf) - prefixsz, stdin);
+        assert (rcc);
+
+        //  Create the message (terminating zero is part of the message).
+        zmq::message_t msg (strlen (textbuf) + 1);
+        memcpy (msg.data (), textbuf, msg.size ());
+
+        //  Send the message
+        s.send (msg);
+    }
+}
diff --git a/src/fd_signaler.cpp b/src/fd_signaler.cpp
index a10872d..5a8dcc1 100644
--- a/src/fd_signaler.cpp
+++ b/src/fd_signaler.cpp
@@ -81,7 +81,7 @@ uint64_t zmq::fd_signaler_t::poll ()
         if (sz == -1) {
             if (errno == EAGAIN || errno == EINTR)
                 continue;
-            zmq_assert (false);
+            errno_assert (false);
         }
         break;
     }