Commit 67ca7dcb authored by Martin Sustrik's avatar Martin Sustrik

obsolete API elements removed - this commit breaks backward compatibility

parent d844a906
...@@ -52,7 +52,7 @@ int main (int argc, char *argv []) ...@@ -52,7 +52,7 @@ int main (int argc, char *argv [])
} }
// TODO: make the number of I/O threads configurable. // TODO: make the number of I/O threads configurable.
zmq::context_t ctx (1, 1); zmq::context_t ctx (1);
zmq::socket_t in_socket (ctx, ZMQ_SUB); zmq::socket_t in_socket (ctx, ZMQ_SUB);
in_socket.setsockopt (ZMQ_SUBSCRIBE, "", 0); in_socket.setsockopt (ZMQ_SUBSCRIBE, "", 0);
zmq::socket_t out_socket (ctx, ZMQ_PUB); zmq::socket_t out_socket (ctx, ZMQ_PUB);
......
...@@ -52,7 +52,7 @@ int main (int argc, char *argv []) ...@@ -52,7 +52,7 @@ int main (int argc, char *argv [])
} }
// TODO: make the number of I/O threads configurable. // TODO: make the number of I/O threads configurable.
zmq::context_t ctx (1, 1, ZMQ_POLL); zmq::context_t ctx (1);
zmq::socket_t in_socket (ctx, ZMQ_XREP); zmq::socket_t in_socket (ctx, ZMQ_XREP);
zmq::socket_t out_socket (ctx, ZMQ_XREQ); zmq::socket_t out_socket (ctx, ZMQ_XREQ);
......
...@@ -52,7 +52,7 @@ int main (int argc, char *argv []) ...@@ -52,7 +52,7 @@ int main (int argc, char *argv [])
} }
// TODO: make the number of I/O threads configurable. // TODO: make the number of I/O threads configurable.
zmq::context_t ctx (1, 1); zmq::context_t ctx (1);
zmq::socket_t in_socket (ctx, ZMQ_UPSTREAM); zmq::socket_t in_socket (ctx, ZMQ_UPSTREAM);
zmq::socket_t out_socket (ctx, ZMQ_DOWNSTREAM); zmq::socket_t out_socket (ctx, ZMQ_DOWNSTREAM);
......
...@@ -144,10 +144,7 @@ ZMQ_EXPORT size_t zmq_msg_size (zmq_msg_t *msg); ...@@ -144,10 +144,7 @@ ZMQ_EXPORT size_t zmq_msg_size (zmq_msg_t *msg);
/* 0MQ infrastructure (a.k.a. context) initialisation & termination. */ /* 0MQ infrastructure (a.k.a. context) initialisation & termination. */
/******************************************************************************/ /******************************************************************************/
/* This flag is obsolete and has no effect. To be removed in next version. */ ZMQ_EXPORT void *zmq_init (int io_threads);
#define ZMQ_POLL 1
ZMQ_EXPORT void *zmq_init (int app_threads, int io_threads, int flags);
ZMQ_EXPORT int zmq_term (void *context); ZMQ_EXPORT int zmq_term (void *context);
/******************************************************************************/ /******************************************************************************/
...@@ -155,9 +152,7 @@ ZMQ_EXPORT int zmq_term (void *context); ...@@ -155,9 +152,7 @@ ZMQ_EXPORT int zmq_term (void *context);
/******************************************************************************/ /******************************************************************************/
/* Socket types. */ /* Socket types. */
/* ZMQ_P2P is obsolete and scheduled to be removed in version 2.0.8 */
#define ZMQ_PAIR 0 #define ZMQ_PAIR 0
#define ZMQ_P2P 0
#define ZMQ_PUB 1 #define ZMQ_PUB 1
#define ZMQ_SUB 2 #define ZMQ_SUB 2
#define ZMQ_REQ 3 #define ZMQ_REQ 3
...@@ -169,8 +164,6 @@ ZMQ_EXPORT int zmq_term (void *context); ...@@ -169,8 +164,6 @@ ZMQ_EXPORT int zmq_term (void *context);
/* Socket options. */ /* Socket options. */
#define ZMQ_HWM 1 #define ZMQ_HWM 1
/* TODO: LWM is obsolete and should be removed in next version. */
#define ZMQ_LWM 2
#define ZMQ_SWAP 3 #define ZMQ_SWAP 3
#define ZMQ_AFFINITY 4 #define ZMQ_AFFINITY 4
#define ZMQ_IDENTITY 5 #define ZMQ_IDENTITY 5
...@@ -186,8 +179,6 @@ ZMQ_EXPORT int zmq_term (void *context); ...@@ -186,8 +179,6 @@ ZMQ_EXPORT int zmq_term (void *context);
/* Send/recv options. */ /* Send/recv options. */
#define ZMQ_NOBLOCK 1 #define ZMQ_NOBLOCK 1
#define ZMQ_SNDMORE 2 #define ZMQ_SNDMORE 2
/* Obsolete. To be removed in 2.0.7 release. */
#define ZMQ_MORE 2
ZMQ_EXPORT void *zmq_socket (void *context, int type); ZMQ_EXPORT void *zmq_socket (void *context, int type);
ZMQ_EXPORT int zmq_close (void *s); ZMQ_EXPORT int zmq_close (void *s);
......
...@@ -167,9 +167,9 @@ namespace zmq ...@@ -167,9 +167,9 @@ namespace zmq
public: public:
inline context_t (int app_threads_, int io_threads_, int flags_ = 0) inline context_t (int io_threads_)
{ {
ptr = zmq_init (app_threads_, io_threads_, flags_); ptr = zmq_init (io_threads_);
if (ptr == NULL) if (ptr == NULL)
throw error_t (); throw error_t ();
} }
......
...@@ -42,7 +42,7 @@ int main (int argc, char *argv []) ...@@ -42,7 +42,7 @@ int main (int argc, char *argv [])
message_size = atoi (argv [2]); message_size = atoi (argv [2]);
roundtrip_count = atoi (argv [3]); roundtrip_count = atoi (argv [3]);
ctx = zmq_init (1, 1, 0); ctx = zmq_init (1);
if (!ctx) { if (!ctx) {
printf ("error in zmq_init: %s\n", zmq_strerror (errno)); printf ("error in zmq_init: %s\n", zmq_strerror (errno));
return -1; return -1;
......
...@@ -45,7 +45,7 @@ int main (int argc, char *argv []) ...@@ -45,7 +45,7 @@ int main (int argc, char *argv [])
message_size = atoi (argv [2]); message_size = atoi (argv [2]);
message_count = atoi (argv [3]); message_count = atoi (argv [3]);
ctx = zmq_init (1, 1, 0); ctx = zmq_init (1);
if (!ctx) { if (!ctx) {
printf ("error in zmq_send: %s\n", zmq_strerror (errno)); printf ("error in zmq_send: %s\n", zmq_strerror (errno));
return -1; return -1;
......
...@@ -46,7 +46,7 @@ int main (int argc, char *argv []) ...@@ -46,7 +46,7 @@ int main (int argc, char *argv [])
message_size = atoi (argv [2]); message_size = atoi (argv [2]);
roundtrip_count = atoi (argv [3]); roundtrip_count = atoi (argv [3]);
ctx = zmq_init (1, 1, 0); ctx = zmq_init (1);
if (!ctx) { if (!ctx) {
printf ("error in zmq_init: %s\n", zmq_strerror (errno)); printf ("error in zmq_init: %s\n", zmq_strerror (errno));
return -1; return -1;
......
...@@ -42,7 +42,7 @@ int main (int argc, char *argv []) ...@@ -42,7 +42,7 @@ int main (int argc, char *argv [])
message_size = atoi (argv [2]); message_size = atoi (argv [2]);
message_count = atoi (argv [3]); message_count = atoi (argv [3]);
ctx = zmq_init (1, 1, 0); ctx = zmq_init (1);
if (!ctx) { if (!ctx) {
printf ("error in zmq_recv: %s\n", zmq_strerror (errno)); printf ("error in zmq_recv: %s\n", zmq_strerror (errno));
return -1; return -1;
......
...@@ -226,9 +226,7 @@ size_t zmq_msg_size (zmq_msg_t *msg_) ...@@ -226,9 +226,7 @@ size_t zmq_msg_size (zmq_msg_t *msg_)
return ((zmq::msg_content_t*) msg_->content)->size; return ((zmq::msg_content_t*) msg_->content)->size;
} }
// TODO: app_threads and flags parameters are not used anymore... void *zmq_init (int io_threads_)
// Reflect this in the API/ABI.
void *zmq_init (int /*app_threads_*/, int io_threads_, int /*flags_*/)
{ {
if (io_threads_ < 0) { if (io_threads_ < 0) {
errno = EINVAL; errno = EINVAL;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment