- 13 Jun, 2012 1 commit
-
-
Martin Hurton authored
-
- 12 Jun, 2012 2 commits
-
-
Ian Barber authored
This reverts commit dde69fb9.
-
Ian Barber authored
This reverts commit 7b105865, reversing changes made to 33459029.
-
- 11 Jun, 2012 1 commit
-
-
Martin Hurton authored
Once the object has been terminated, it is unsafe for this object to refer to its parent. The bug was responsible for occasional test_shutdown_stress failures.
-
- 05 Jun, 2012 1 commit
-
-
AJ Lewis authored
The socket length variable for getsockname and accept must be an (int *) instead of a (socklen_t *) on HPUX. Signed-off-by:
AJ Lewis <aj.lewis@quantum.com>
-
- 04 May, 2012 1 commit
-
-
Lourens Naudé authored
-
- 21 Apr, 2012 1 commit
-
-
Sergey KHripchenko authored
1. when we call zmq_bind()/zmq_connect() to create endpoint we send ourselfs(through launch_child()) command to process_own(endpoint) (and add it to own_t::owned) in the application thread we could call zmq_unbind() / zmq_disconnect() _BEFORE_ we run process_own() in ZMQ thread and in this situation we will be unable to find it in own_t::owned. in other words own_t::owned.find(endpoint) will not be deleted but it will be deleted from socket_base_t::endpoints. 2. when you zmq_unbind() the lisnening TCP/IPC socket was terminated only in destructor... so the whole ZMQ_LINGER time listening TCP/IPC socket was able to accept() new connections but unable to handle them. this all geting even worse since unfortunately zmq has a bug and '*_listener_t' object not terminated untill the socket's zmq_close(). AT LEAST FOR PUSH SOCKETS. Everything is ok for SUB sockets. Easy to reproduce without my fix: zmq_socket(PUSH) zmq_bind(tcp); // connect to it from PULL socket zmq_unbind(tcp); sleep(forever) // netstat -anp | grep 'tcp listening socket' With my fix you could see that after zmq_unbind(tcp) all previously connected tcp sessions will not be finished untill the zmq_close(socket) regardless of ZMQ_LINGER value. (*_listener_t terminates all owned session_base_t(connect=false) and they call pipe_t::terminate() which in turn should call session_base_t::terminated() but this never happens)
-
- 18 Apr, 2012 1 commit
-
-
Sergey KHripchenko authored
-
- 01 Mar, 2012 1 commit
-
-
Rob Gagnon authored
-
- 18 Feb, 2012 1 commit
-
-
Mikko Koppanen authored
-
- 17 Feb, 2012 1 commit
-
-
Mikko Koppanen authored
-
- 16 Feb, 2012 1 commit
-
-
Staffan Gimåker authored
This allows us to actually report an error to the caller on resolve failure, rather than asserting later on in the io thread. Signed-off-by:
Staffan Gimåker <staffan@spotify.com>
-
- 14 Feb, 2012 1 commit
-
-
Ian Barber authored
-
- 11 Feb, 2012 1 commit
-
-
Ian Barber authored
-
- 08 Feb, 2012 1 commit
-
-
Ian Barber authored
-
- 01 Nov, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 31 Oct, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 15 Sep, 2011 1 commit
-
-
Martin Sustrik authored
This is a preliminary patch allowing for socket-type-specific functionality in the I/O thread. For example, message format can be checked asynchronously and misbehaved connections dropped straight away. Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 02 Sep, 2011 1 commit
-
-
Martin Sustrik authored
When exec is executed to start a different process image old 0MQ file descriptors could stay open, thus blocking TCP ports and alike. This patch should solve the problem. Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 18 Aug, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 16 Aug, 2011 1 commit
-
-
Martin Sustrik authored
The engine was not used exclusively for TCP connections. Rather it was used to handle any socket with SOCK_STREAM semantics. The class was renamed to reflect its true function. Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 28 Jul, 2011 4 commits
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 26 Jul, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 25 Jul, 2011 1 commit
-
-
Martin Sustrik authored
zmq_engine and tcp_socket merged into tcp_engine zmq_connecter and tcp_connecter merged into tcp_connecter zmq_listener and tcp_listener merged into tcp_listener Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 21 Apr, 2011 1 commit
-
-
Martin Sustrik authored
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>
-
- 15 Apr, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 16 Mar, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 02 Mar, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 13 Dec, 2010 1 commit
-
-
Dhammika Pathirana authored
Signed-off-by:
Dhammika Pathirana <dhammika@gmail.com>
-
- 30 Oct, 2010 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 17 Oct, 2010 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 29 Jun, 2010 1 commit
-
-
Pieter Hintjens authored
-
- 12 May, 2010 1 commit
-
-
Brett Cameron authored
-
- 19 Mar, 2010 1 commit
-
-
Martin Sustrik authored
-
- 11 Mar, 2010 1 commit
-
-
Martin Lucina authored
C and C++ headers moved from bindings/ to include/, bindings/ removed --with-c and --with-cpp options to configure removed, C and C++ now built and installed by default
-
- 03 Mar, 2010 1 commit
-
-
unknown authored
-
- 18 Feb, 2010 1 commit
-
-
Martin Lucina authored
-