Not sure if someone has noticed that but I for this message when I create a SUB/PUB broker
==6536== Invalid write of size 4 ==6536== at 0x4135C6B: zmq::pipe_t::set_hwms(int, int) (pipe.cpp:483) ==6536== by 0x411FED4: zmq::ctx_t::connect_inproc_sockets(zmq::socket_base_t*, zmq::options_t&, zmq::pending_connection_t&, zmq::ctx_t::side) (ctx.cpp:476) ==6536== by 0x412445C: zmq::ctx_t::connect_pending(char const*, zmq::socket_base_t*) (ctx.cpp:435) ==6536== by 0x413214D: zmq::object_t::connect_pending(char const*, zmq::socket_base_t*) (object.cpp:162) ==6536== by 0x4141D6B: zmq::socket_base_t::bind(char const*) (socket_base.cpp:347) ==6536== by 0x415431F: zmq_bind (zmq.cpp:309) ==6536== by 0x8053A3D: zmqBroker (broker.c:225) ==6536== by 0x8054114: broker (broker.c:592) ==6536== by 0x80587DE: main (ce50.c:468) ==6536== Address 0xa610b94 is 52 bytes inside a block of size 104 free'd ==6536== at 0x402B838: operator delete(void*) (in /usr/lib/valgrind/vgpreload_memcheck-x86-linux.so) ==6536== by 0x41351C3: zmq::pipe_t::~pipe_t() (pipe.cpp:87) ==6536== by 0x4134E72: zmq::pipe_t::process_pipe_term_ack() (pipe.cpp:334) ==6536== by 0x4131F7F: zmq::object_t::process_command(zmq::command_t&) (object.cpp:107) ==6536== by 0x413E65F: zmq::socket_base_t::process_commands(int, bool) (socket_base.cpp:904) ==6536== by 0x4142B4F: zmq::socket_base_t::in_event() (socket_base.cpp:1005) ==6536== by 0x4128A48: zmq::epoll_t::loop() (epoll.cpp:165) ==6536== by 0x414C2BF: thread_routine (thread.cpp:81) ==6536== by 0x409BF6F: start_thread (pthread_create.c:312) ==6536== by 0x426788D: clone (clone.S:129) ==6536== ==6536== Invalid write of size 4 ==6536== at 0x4135C72: zmq::pipe_t::set_hwms(int, int) (pipe.cpp:484) ==6536== by 0x411FED4: zmq::ctx_t::connect_inproc_sockets(zmq::socket_base_t*, zmq::options_t&, zmq::pending_connection_t&, zmq::ctx_t::side) (ctx.cpp:476) ==6536== by 0x412445C: zmq::ctx_t::connect_pending(char const*, zmq::socket_base_t*) (ctx.cpp:435) ==6536== by 0x413214D: zmq::object_t::connect_pending(char const*, zmq::socket_base_t*) (object.cpp:162) ==6536== by 0x4141D6B: zmq::socket_base_t::bind(char const*) (socket_base.cpp:347) ==6536== by 0x415431F: zmq_bind (zmq.cpp:309) ==6536== by 0x8053A3D: zmqBroker (broker.c:225) ==6536== by 0x8054114: broker (broker.c:592) ==6536== by 0x80587DE: main (ce50.c:468) ==6536== Address 0xa610b90 is 48 bytes inside a block of size 104 free'd ==6536== at 0x402B838: operator delete(void*) (in /usr/lib/valgrind/vgpreload_memcheck-x86-linux.so) ==6536== by 0x41351C3: zmq::pipe_t::~pipe_t() (pipe.cpp:87) ==6536== by 0x4134E72: zmq::pipe_t::process_pipe_term_ack() (pipe.cpp:334) ==6536== by 0x4131F7F: zmq::object_t::process_command(zmq::command_t&) (object.cpp:107) ==6536== by 0x413E65F: zmq::socket_base_t::process_commands(int, bool) (socket_base.cpp:904) ==6536== by 0x4142B4F: zmq::socket_base_t::in_event() (socket_base.cpp:1005) ==6536== by 0x4128A48: zmq::epoll_t::loop() (epoll.cpp:165) ==6536== by 0x414C2BF: thread_routine (thread.cpp:81) ==6536== by 0x409BF6F: start_thread (pthread_create.c:312) ==6536== by 0x426788D: clone (clone.S:129) static void zmqBroker(void) { int rc; int linger = 1000; if (gDebug & DEB_ZMQ) log_info("ZMQ thread running"); void *frontend = zmq_socket(zmq_ctx, ZMQ_XSUB); if (frontend == NULL) { log_info ("Bad socket %s", zmq_strerror(errno)); } assert(frontend); zmq_setsockopt(frontend, ZMQ_LINGER, &linger, sizeof (linger)); rc = zmq_bind(frontend, "inproc://localhost:10000"); if (rc) { log_err("Bind error"); assert(rc == 0); } void *backend = zmq_socket(zmq_ctx, ZMQ_XPUB); assert(backend); zmq_setsockopt(backend, ZMQ_LINGER, &linger, sizeof (linger)); rc = zmq_bind(backend, "inproc://localhost:10001”); // this is the line 225! assert(rc == 0); zmq_proxy(frontend, backend, NULL); zmq_close(frontend); zmq_close(backend); log_info("ZMQ thread ended"); } Carlos Tangerino carlos.tanger...@gmail.com
smime.p7s
Description: S/MIME cryptographic signature
_______________________________________________ zeromq-dev mailing list zeromq-dev@lists.zeromq.org http://lists.zeromq.org/mailman/listinfo/zeromq-dev