generic-library/cppzmq
1
0
Fork 0
mirror of https://github.com/zeromq/cppzmq.git synced 2025-03-01 10:57:59 +01:00
Code Issues Projects Releases Wiki Activity

Create a binding for zmq_msg_gets.

Browse Source 
Additionally, I've changed some tabs to spaces and remove trailing
spaces.
This commit is contained in:
Mateusz Piotrowski 2016-11-15 22:00:15 +01:00
parent 4648ebc964
commit 570ff93ea9
1 changed files with 21 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
zmq.hpp
View File

@ -71,8 +71,8 @@
#define ZMQ_DELETED_FUNCTION
#endif
#elif defined(_MSC_VER) && (_MSC_VER >= 1900)
#define ZMQ_HAS_RVALUE_REFS
#define ZMQ_DELETED_FUNCTION = delete
#define ZMQ_HAS_RVALUE_REFS
#define ZMQ_DELETED_FUNCTION = delete
#elif defined(_MSC_VER) && (_MSC_VER >= 1600)
#define ZMQ_HAS_RVALUE_REFS
#define ZMQ_DELETED_FUNCTION
@ -124,10 +124,10 @@ namespace zmq
return zmq_strerror (errnum);
}
#else
virtual const char *what() const throw ()
{
return zmq_strerror(errnum);
}
virtual const char *what() const throw ()
{
return zmq_strerror(errnum);
}
#endif
int num () const
{
@ -177,7 +177,7 @@ namespace zmq
if (rc != 0)
throw error_t ();
}
#ifdef ZMQ_HAS_PROXY_STEERABLE
inline void proxy_steerable (void *frontend, void *backend, void *capture, void *control)
{
@ -186,7 +186,7 @@ namespace zmq
throw error_t ();
}
#endif
inline void version (int *major_, int *minor_, int *patch_)
{
zmq_version (major_, minor_, patch_);
@ -372,6 +372,14 @@ namespace zmq
return a == b;
}
inline const char* gets(const char *property_) const
{
const char* value = zmq_msg_gets (&msg, property);
if (value == NULL)
throw error_t ();
return value;
}
private:
// The underlying message
zmq_msg_t msg;
@ -611,7 +619,7 @@ namespace zmq
{
return(ptr != NULL);
}
inline size_t send (const void *buf_, size_t len_, int flags_ = 0)
{
int nbytes = zmq_send (ptr, buf_, len_, flags_);
@ -664,7 +672,7 @@ namespace zmq
return false;
throw error_t ();
}
private:
inline void init(context_t& context_, int type_)
{
@ -704,9 +712,9 @@ namespace zmq
rc = zmq_connect (s, addr_);
assert (rc == 0);
on_monitor_started();
while (true) {
zmq_msg_t eventMsg;
zmq_msg_init (&eventMsg);
@ -723,7 +731,7 @@ namespace zmq
#else
zmq_event_t* event = static_cast<zmq_event_t*>(zmq_msg_data(&eventMsg));
#endif
#ifdef ZMQ_NEW_MONITOR_EVENT_LAYOUT
zmq_msg_t addrMsg;
zmq_msg_init (&addrMsg);