libxs.git/src, branch sp mato's libxs tree Implement SP wire protocol 2012-05-20T05:40:11+00:00 Martin Lucina martin@lucina.net 2012-05-20T05:40:11+00:00 1d76284dee8e9b0735a26ee98a3edcd9f5208f09 Implements the SP wire protocol, and infrastructure for legacy wire protocol support. Also added an XS_SERVICE_ID socket option to set the service id and renamed the XS_PROTOCOL option to XS_PATTERN_VERSION. The following pattern versions are supported: PAIR: v3 PUBSUB: v1 (legacy), v4 REQREP: v2 PIPELINE: v3 SURVEY: v2 Note that all existing pattern versions have been bumped by 1 to allow for use of legacy protocols (otherwise there would be no way to distinguish between e.g. PUBSUB v3 and PUBSUB v3 using SP). Signed-off-by: Martin Lucina <martin@lucina.net> 
Implements the SP wire protocol, and infrastructure for legacy wire
protocol support.

Also added an XS_SERVICE_ID socket option to set the service id and renamed
the XS_PROTOCOL option to XS_PATTERN_VERSION.

The following pattern versions are supported:

PAIR:     v3
PUBSUB:   v1 (legacy), v4
REQREP:   v2
PIPELINE: v3
SURVEY:   v2

Note that all existing pattern versions have been bumped by 1 to allow for
use of legacy protocols (otherwise there would be no way to distinguish
between e.g. PUBSUB v3 and PUBSUB v3 using SP).

Signed-off-by: Martin Lucina <martin@lucina.net>
Opening plug-in directory made more robust 2012-05-18T04:35:24+00:00 Martin Sustrik sustrik@250bpm.com 2012-05-17T17:44:22+00:00 8c23de9f2abc2ec21d4b74785fd175050909176e If plugin directory doesn't exist, is a file or user has no permissions to access it, the plugins are not loaded. Signed-off-by: Martin Sustrik <sustrik@250bpm.com> 
If plugin directory doesn't exist, is a file or
user has no permissions to access it, the plugins
are not loaded.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Do not crash when multiple peers connect to PAIR socket 2012-05-15T10:51:54+00:00 Martin Hurton hurtonm@gmail.com 2012-05-15T10:51:54+00:00 adbd29bfa16ae4d58c767d4b03e28841c7cd7fc5 When more then one peer connected to a PAIR socket, an application aborted due to assertion failure. This patch changes the PAIR socket behaviour so that it rejects any further connection requests. 
    When more then one peer connected to a PAIR socket,
    an application aborted due to assertion failure.
    This patch changes the PAIR socket behaviour so that
    it rejects any further connection requests.
Move inclusion of select() and poll() headers to a single place 2012-05-13T16:12:24+00:00 Gabriele Svelto gabriele.svelto@gmail.com 2012-05-08T17:11:29+00:00 a03730632e73d7809b352eb43007036f11deb746 Signed-off-by: Gabriele Svelto <gabriele.svelto@gmail.com> 
Signed-off-by: Gabriele Svelto <gabriele.svelto@gmail.com>
Enabled plug-in loading on all hosts with support for dlopen() 2012-05-12T10:13:19+00:00 Gabriele Svelto gabriele.svelto@gmail.com 2012-05-08T18:17:01+00:00 e1dff473a625cdbecbaddb89d48fc675efea09f0 Previously the code used for loading plug-ins would be built only on Linux hosts. Now the required functions are checked for and plug-in loading code is enabled if those are present on all platforms. Using lstat() to check for file types also increases portability to hosts that do not have the dirent.d_type field. If shared libraries support is disabled plug-ins will also be automatically disabled. Signed-off-by: Gabriele Svelto <gabriele.svelto@gmail.com> 
Previously the code used for loading plug-ins would be built only on
Linux hosts. Now the required functions are checked for and plug-in
loading code is enabled if those are present on all platforms. Using
lstat() to check for file types also increases portability to hosts that
do not have the dirent.d_type field. If shared libraries support is
disabled plug-ins will also be automatically disabled.

Signed-off-by: Gabriele Svelto <gabriele.svelto@gmail.com>
Inheritance on signaler's socket on Windows switched off 2012-05-12T10:09:27+00:00 Martin Sustrik sustrik@250bpm.com 2012-05-12T05:54:33+00:00 0b1bfac99a01db54396875ca49987f4117061990 Accidentally, one of the sockets in Windows signaler_t was opened usign WSASocket instead of xs::open_socket. That skipped the standard XS socket initialisation and caused the socket to be inheritable to the child processes. Signed-off-by: Martin Sustrik <sustrik@250bpm.com> 
Accidentally, one of the sockets in Windows signaler_t
was opened usign WSASocket instead of xs::open_socket.
That skipped the standard XS socket initialisation
and caused the socket to be inheritable to the child
processes.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Fix decoder to properly handle large messages 2012-05-12T09:28:15+00:00 Martin Hurton hurtonm@gmail.com 2012-05-12T09:28:15+00:00 17e89e90ce48989cd9454a8a3dcf04532fc50237 The decoder did not properly decode large messages on systems where sizeof (size_t) < sizeof (uint64_t). 
The decoder did not properly decode large messages
on systems where sizeof (size_t) < sizeof (uint64_t).
Command throttling breaking HWM algorithms -- fixed. 2012-05-11T14:23:06+00:00 Martin Sustrik sustrik@250bpm.com 2012-05-11T14:23:06+00:00 e924381bae58ca828c9691b9d4d772a20a91c717 When HWM was set to small value it may have happened that command indicating that pipe is ready for writing wasn't processed because of command throttling. Signed-off-by: Martin Sustrik <sustrik@250bpm.com> 
When HWM was set to small value it may have happened that command
indicating that pipe is ready for writing wasn't processed
because of command throttling.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Improve command processing efficiency 2012-05-11T10:01:53+00:00 Martin Sustrik sustrik@250bpm.com 2012-05-10T04:40:18+00:00 f7f7eb1613b405026410299f6ca6a4e340bf47c8 When processing commands with throttling switched off, RDTSC instruction was executed, but the result was never used. This patch eliminates the unneeded instruction. Signed-off-by: Martin Sustrik <sustrik@250bpm.com> 
When processing commands with throttling switched off, RDTSC
instruction was executed, but the result was never used. This
patch eliminates the unneeded instruction.

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Fix issue #268 2012-05-11T10:01:14+00:00 Martin Hurton hurtonm@gmail.com 2012-05-08T07:28:17+00:00 b4e7f84704b0bb8ed8834d307d24a4c5487619de This patch fixes a bug in the message encoder which was responsible for computing incorrect message offset. The bug affected PGM receiver making it unable to decode inital messages. 
This patch fixes a bug in the message encoder which was
responsible for computing incorrect message offset.
The bug affected PGM receiver making it unable to
decode inital messages.