libxs.git/include, branch udp

Implement SP wire protocol

2012-05-20T05:40:11+00:00

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

Preparation for 1.1.0 release

2012-05-12T12:53:49+00:00

- version bump
- ABI version bump
- NEWS updated

Signed-off-by: Martin Sustrik

C prototype for xs_init fixed

2012-05-06T02:30:05+00:00

The function was erroneously declared as xs_init()
instead of xs_init(void).

Signed-off-by: Martin Sustrik

xs_shutdown implemented

2012-04-21T05:07:57+00:00

This patch allows for partial shutdown of the socket.

Signed-off-by: Martin Sustrik

XS_SURVEY_TIMEOUT socket option added.

2012-04-17T05:34:37+00:00

It can be used to timeout the survey. Value is in milliseconds
and -1 means infinite (default).

Signed-off-by: Martin Sustrik

"Survey" pattern implemented

2012-04-17T05:30:52+00:00

Survey pattern is "multicast with reply". There are two roles:
surveyor and respondent. Surveyor publishes a survey which gets
delivered to all connected respondents. Each repondent can send
a response to the survey. All the responses are delivered to
the original surveyor. Once the surveyor decides that the survey
is over (e.g. deadline was reached) it can send initiate survey.
Late responses from old surveys are automatically discarded by
the surveyor socket.

Socket types: SURVEYOR, XSURVEYOR, RESPONDENT, XRESPONDENT

Patch also includes a test program with surveoyr, two respondents
and an intermediary device.

Signed-off-by: Martin Sustrik

Separate subscription forwarding from SUB-side filtering

2012-04-14T03:21:09+00:00

- subscription forwarding is handled by XSUB socket
- filtering is handled by SUB sockets
- subscriptions are decoupled from filter engines
- filter doesn't have to be able to enumarate the subscriptions
  (no sf_enumerate function)

Signed-off-by: Martin Sustrik

EMTHREAD error code removed

2012-04-06T10:56:24+00:00

libxs (as opposed to libzmq) requires at least one I/O thread per
context. Thus, "no I/O thread available" error doesn't make sense
anyome.

This patch removes the code and the documentation.

It keeps the definition of EMTHREAD itself for backward compatibility.

Signed-off-by: Martin Sustrik

XS_PLUGIN and XS_FILTER implementation

2012-04-05T05:32:58+00:00

This patch introduces following features:
- XS_PLUGIN context option to add plugins to libxs
- XS_FILTER option to switch between different filter types
- Automatic loading of plug-ins is *not* implemented.

From the implementation point of view:
- standard prefix filter is implemented as a pluggable filter
- trie_t and mtrie_t are joined into a single class
- the code for 0MQ/3.1 compatibility is left in in the form of comments
- new test for testing re-subscriptions is added
Signed-off-by: Martin Sustrik

0MQ/2.1 wire format compatibility implemented

2012-04-04T02:35:19+00:00

- XS_PROTOCOL option added
- libxs ignores when unused flags are set to 1 (0MQ/2.1 bug)
- compatibility tests added

Signed-off-by: Martin Sustrik