3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-01-21 15:12:03 +08:00
Code Issues Projects Releases Wiki Activity
libzmq/src
History
Martin Hurton a53d703160 Resolve issue #939 
This bug is caused by fq which can terminate pipe before sending all
frames of a message first. So sometimes two messages were mixed and this
confused ZAP handler.

This patch just modifies one pipe parameter so that socket consumes all
messages before dropping the pipe.
2014-04-03 19:52:42 +02:00
..
address.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
address.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
array.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
atomic_counter.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
atomic_ptr.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
blob.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
clock.cpp
Fix timestamp counter on s390/s390x
2014-01-12 12:31:40 +01:00
clock.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
command.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
config.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
ctx.cpp
Rename ZMQ_MAX_SOCKETS_MAX to ZMQ_SOCKET_LIMIT
2014-02-14 10:09:19 +01:00
ctx.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
curve_client.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
curve_client.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
curve_server.cpp
Added temporary CURVE debugging support
2014-02-16 20:19:46 +01:00
curve_server.hpp
Added temporary CURVE debugging support
2014-02-16 20:19:46 +01:00
dbuffer.hpp
Make it explicit that the probe function doesn't modify passed message
2014-01-08 08:21:13 +01:00
dealer.cpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
dealer.hpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
decoder.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
devpoll.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
devpoll.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
dist.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
dist.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
encoder.hpp
added uncommitted norm_engine changes
2014-03-16 09:15:31 -04:00
epoll.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
epoll.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
err.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
err.hpp
Include zmq.h after platform.hpp
2014-03-21 01:24:25 -05:00
fd.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
fq.cpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
fq.hpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
i_decoder.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
i_encoder.hpp
Fix LIBZMQ-576 - Revert "Merge pull request #510 from miniway/master"
2014-01-02 11:05:39 -06:00
i_engine.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
i_poll_events.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
io_object.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
io_object.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
io_thread.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
io_thread.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
ip.cpp
Fix a strict-aliasing with type-punning
2014-02-13 12:06:10 -05:00
ip.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
ipc_address.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
ipc_address.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
ipc_connecter.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
ipc_connecter.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
ipc_listener.cpp
sockets created by accept are leaked to child processes (ticket #956)
2014-04-02 12:25:40 -04:00
ipc_listener.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
kqueue.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
kqueue.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
lb.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
lb.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
libzmq.pc.cmake.in
fix libzmq.pc generation under cmake
2014-02-11 15:46:38 -08:00
libzmq.pc.in
added libzmq.pc.in file
2009-09-08 15:06:08 +02:00
libzmq.vers
Only export zmq_* symbols
2014-01-12 12:30:45 +01:00
likely.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
mailbox.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
mailbox.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
Makefile.am
added norm_engine
2014-03-15 10:48:12 -04:00
mechanism.cpp
[libzmq] const string p -> const string& p (#860)
2014-01-29 15:58:53 +04:00
mechanism.hpp
[libzmq] const string p -> const string& p (#860)
2014-01-29 15:58:53 +04:00
msg.cpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
msg.hpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
mtrie.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
mtrie.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
mutex.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
norm_engine.cpp
removed norm_engine dependency on deprecated encoder_base::has_data() method
2014-03-19 15:02:06 -04:00
norm_engine.hpp
removed dependency on deprecated encoder_base::has_data() method
2014-03-19 15:00:03 -04:00
null_mechanism.cpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
null_mechanism.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
object.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
object.hpp
Fix some comments regarding method overriding
2014-01-08 18:29:35 +01:00
options.cpp
Fixed issue #865 - validation on ZMQ_TCP_KEEPALIVE
2014-01-31 12:03:15 +01:00
options.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
own.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
own.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pair.cpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
pair.hpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
pgm_receiver.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pgm_receiver.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pgm_sender.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pgm_sender.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pgm_socket.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pgm_socket.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pipe.cpp
Fix identity handling for inproc transport
2014-02-09 21:02:00 +01:00
pipe.hpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
plain_mechanism.cpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
plain_mechanism.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
poll.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
poll.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
poller_base.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
poller_base.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
poller.hpp
Remove duplicate poller decision making
2014-02-17 14:08:11 +01:00
precompiled.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
precompiled.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
proxy.cpp
Remove duplicate poller decision making
2014-02-17 14:08:11 +01:00
proxy.hpp
Revert "add a proxy hook"
2014-02-13 18:35:09 +01:00
pub.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pub.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
pull.cpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
pull.hpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
push.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
push.hpp
Fix some comments regarding method overriding
2014-01-08 18:29:35 +01:00
random.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
random.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
raw_decoder.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
raw_decoder.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
raw_encoder.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
raw_encoder.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
reaper.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
reaper.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
rep.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
rep.hpp
Fix some comments regarding method overriding
2014-01-08 18:29:35 +01:00
req.cpp
Allow TCP addresses to be re-resolved whenever there is a reconnection attempt
2014-03-12 13:28:37 -04:00
req.hpp
Allow TCP addresses to be re-resolved whenever there is a reconnection attempt
2014-03-12 13:28:37 -04:00
router.cpp
Added assert on duplicate id in ROUTER and STREAM sockets. Updated man to reflect this change. Modified test case to match.
2014-01-21 11:43:34 -08:00
router.hpp
Cleaned up option to force identity on outgoing connection
2014-01-19 09:27:57 +01:00
select.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
select.hpp
Fix build with ZMQ_HAVE_WINDOWS (typedef UINT_PTR fd_t; -> unsigned type)
2014-02-21 13:22:53 +04:00
session_base.cpp
Resolve issue #939
2014-04-03 19:52:42 +02:00
session_base.hpp
Allow TCP addresses to be re-resolved whenever there is a reconnection attempt
2014-03-12 13:28:37 -04:00
signaler.cpp
Reorganize and clean up visual studio build configurations.
2014-03-29 23:13:00 -07:00
signaler.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
socket_base.cpp
added norm_engine
2014-03-15 10:48:12 -04:00
socket_base.hpp
Cleaned up option to force identity on outgoing connection
2014-01-19 09:27:57 +01:00
stdint.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
stream_engine.cpp
Fix unused parameter and variable warnings.
2014-01-18 13:17:29 -08:00
stream_engine.hpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
stream.cpp
Added assert on duplicate id in ROUTER and STREAM sockets. Updated man to reflect this change. Modified test case to match.
2014-01-21 11:43:34 -08:00
stream.hpp
Cleaned up option to force identity on outgoing connection
2014-01-19 09:27:57 +01:00
sub.cpp
Fix some comments regarding method overriding
2014-01-08 18:29:35 +01:00
sub.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tcp_address.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tcp_address.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tcp_connecter.cpp
Allow TCP addresses to be re-resolved whenever there is a reconnection attempt
2014-03-12 13:28:37 -04:00
tcp_connecter.hpp
Allow TCP addresses to be re-resolved whenever there is a reconnection attempt
2014-03-12 13:28:37 -04:00
tcp_listener.cpp
sockets created by accept are leaked to child processes (ticket #956)
2014-04-02 12:25:40 -04:00
tcp_listener.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tcp.cpp
fix: win32 tcp_keepalive gets set even when option is -1
2014-02-18 14:17:32 +08:00
tcp.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
thread.cpp
Whitespace fix
2014-02-03 11:03:59 +01:00
thread.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tipc_address.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tipc_address.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tipc_connecter.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tipc_connecter.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tipc_listener.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
tipc_listener.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
trie.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
trie.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v1_decoder.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v1_decoder.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v1_encoder.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v1_encoder.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v2_decoder.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v2_decoder.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v2_encoder.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v2_encoder.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
v2_protocol.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
version.rc.in
Add ZeroMQ branding.
2012-06-12 21:30:24 -04:00
windows.hpp
Fix building on MinGW64 Windows
2014-03-20 12:22:15 -04:00
wire.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
xpub.cpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
xpub.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
xsub.cpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
xsub.hpp
Implement socket_base_t::get_credential member function
2014-01-13 00:40:27 +01:00
ypipe_base.hpp
Make it explicit that the probe function doesn't modify passed message
2014-01-08 08:21:13 +01:00
ypipe_conflate.hpp
Fix unused parameter and variable warnings.
2014-01-18 13:17:29 -08:00
ypipe.hpp
Make it explicit that the probe function doesn't modify passed message
2014-01-08 08:21:13 +01:00
yqueue.hpp
Updated copyright statements for 2014
2014-01-02 12:00:57 +01:00
zmq_utils.cpp
Fix unused parameter and variable warnings.
2014-01-18 13:17:29 -08:00
zmq.cpp
Allow iov_base as char * on Solaris 8/9/10.
2014-03-21 01:32:01 -05:00