Message-related functionality factored out into msg_t class.

This patch addresses serveral issues:
1. It gathers message related functionality scattered over whole
   codebase into a single class.
2. It makes zmq_msg_t an opaque datatype. Internals of the class
   don't pollute zmq.h header file.
3. zmq_msg_t size decreases from 48 to 32 bytes. That saves ~33%
   of memory in scenarios with large amount of small messages.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

1 files changed, 4 insertions, 3 deletions

diff --git a/src/xrep.hpp b/src/xrep.hpp
index d7fbe9f..1c45655 100644
--- a/src/xrep.hpp
+++ b/src/xrep.hpp
@@ -27,6 +27,7 @@
 #include "socket_base.hpp"
 #include "blob.hpp"
 #include "pipe.hpp"
+#include "msg.hpp"
 
 namespace zmq
 {
@@ -45,8 +46,8 @@ namespace zmq
         //  Overloads of functions from socket_base_t.
         void xattach_pipes (reader_t *inpipe_, writer_t *outpipe_,
             const blob_t &peer_identity_);
-        int xsend (zmq_msg_t *msg_, int flags_);
-        int xrecv (zmq_msg_t *msg_, int flags_);
+        int xsend (class msg_t *msg_, int flags_);
+        int xrecv (class msg_t *msg_, int flags_);
         bool xhas_in ();
         bool xhas_out ();
 
@@ -82,7 +83,7 @@ namespace zmq
         bool prefetched;
 
         //  Holds the prefetched message.
-        zmq_msg_t prefetched_msg;
+        msg_t prefetched_msg;
 
         //  If true, more incoming message parts are expected.
         bool more_in;