mirror of
https://github.com/zeromq/libzmq.git
synced 2024-12-12 10:33:52 +01:00
Fix typos
This commit is contained in:
parent
ca6dc86178
commit
6b8dd84a63
2
INSTALL
2
INSTALL
@ -145,7 +145,7 @@ error can be resolved by adding environment variable for shell.
|
|||||||
|
|
||||||
export XML_CATALOG_FILES=/usr/local/etc/xml/catalog
|
export XML_CATALOG_FILES=/usr/local/etc/xml/catalog
|
||||||
|
|
||||||
Write comamnd above in shell for instant resolve, or append command into
|
Write command above in shell for instant resolve, or append command into
|
||||||
shell profile file and reload for permanent resolve.
|
shell profile file and reload for permanent resolve.
|
||||||
|
|
||||||
Compilers and Options
|
Compilers and Options
|
||||||
|
@ -14,7 +14,7 @@ Supported platforms with primary CI
|
|||||||
- it is a precondition for merging a pull request that no builds or tests of these platforms are broken
|
- it is a precondition for merging a pull request that no builds or tests of these platforms are broken
|
||||||
- contributors can easily enable these builds and tests for their branches in their fork
|
- contributors can easily enable these builds and tests for their branches in their fork
|
||||||
|
|
||||||
Suported platforms with secondary CI
|
Supported platforms with secondary CI
|
||||||
- have builds and tests run for the master branch
|
- have builds and tests run for the master branch
|
||||||
- these are monitored periodically by the project maintainers, and efforts are made to fix any broken builds or tests in a timely manner
|
- these are monitored periodically by the project maintainers, and efforts are made to fix any broken builds or tests in a timely manner
|
||||||
- it is a precondition for a release that no builds or tests of these platforms are broken
|
- it is a precondition for a release that no builds or tests of these platforms are broken
|
||||||
|
@ -52,7 +52,7 @@ mkdir -p "${cache}"
|
|||||||
|
|
||||||
# Check for environment variable to clear the prefix and do a clean build
|
# Check for environment variable to clear the prefix and do a clean build
|
||||||
if [[ $ANDROID_BUILD_CLEAN ]]; then
|
if [[ $ANDROID_BUILD_CLEAN ]]; then
|
||||||
echo "Doing a clean build (removing previous build and depedencies)..."
|
echo "Doing a clean build (removing previous build and dependencies)..."
|
||||||
rm -rf "${ANDROID_BUILD_PREFIX}"/*
|
rm -rf "${ANDROID_BUILD_PREFIX}"/*
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
@ -851,7 +851,7 @@ Section "Uninstall"
|
|||||||
@CPACK_NSIS_DELETE_ICONS@
|
@CPACK_NSIS_DELETE_ICONS@
|
||||||
@CPACK_NSIS_DELETE_ICONS_EXTRA@
|
@CPACK_NSIS_DELETE_ICONS_EXTRA@
|
||||||
|
|
||||||
;Delete empty start menu parent diretories
|
;Delete empty start menu parent directories
|
||||||
StrCpy $MUI_TEMP "$SMPROGRAMS\$MUI_TEMP"
|
StrCpy $MUI_TEMP "$SMPROGRAMS\$MUI_TEMP"
|
||||||
|
|
||||||
startMenuDeleteLoop:
|
startMenuDeleteLoop:
|
||||||
@ -870,7 +870,7 @@ Section "Uninstall"
|
|||||||
Delete "$SMPROGRAMS\$MUI_TEMP\Uninstall.lnk"
|
Delete "$SMPROGRAMS\$MUI_TEMP\Uninstall.lnk"
|
||||||
@CPACK_NSIS_DELETE_ICONS_EXTRA@
|
@CPACK_NSIS_DELETE_ICONS_EXTRA@
|
||||||
|
|
||||||
;Delete empty start menu parent diretories
|
;Delete empty start menu parent directories
|
||||||
StrCpy $MUI_TEMP "$SMPROGRAMS\$MUI_TEMP"
|
StrCpy $MUI_TEMP "$SMPROGRAMS\$MUI_TEMP"
|
||||||
|
|
||||||
secondStartMenuDeleteLoop:
|
secondStartMenuDeleteLoop:
|
||||||
|
@ -854,7 +854,7 @@ Section "Uninstall"
|
|||||||
@CPACK_NSIS_DELETE_ICONS@
|
@CPACK_NSIS_DELETE_ICONS@
|
||||||
@CPACK_NSIS_DELETE_ICONS_EXTRA@
|
@CPACK_NSIS_DELETE_ICONS_EXTRA@
|
||||||
|
|
||||||
;Delete empty start menu parent diretories
|
;Delete empty start menu parent directories
|
||||||
StrCpy $MUI_TEMP "$SMPROGRAMS\$MUI_TEMP"
|
StrCpy $MUI_TEMP "$SMPROGRAMS\$MUI_TEMP"
|
||||||
|
|
||||||
startMenuDeleteLoop:
|
startMenuDeleteLoop:
|
||||||
@ -873,7 +873,7 @@ Section "Uninstall"
|
|||||||
Delete "$SMPROGRAMS\$MUI_TEMP\Uninstall.lnk"
|
Delete "$SMPROGRAMS\$MUI_TEMP\Uninstall.lnk"
|
||||||
@CPACK_NSIS_DELETE_ICONS_EXTRA@
|
@CPACK_NSIS_DELETE_ICONS_EXTRA@
|
||||||
|
|
||||||
;Delete empty start menu parent diretories
|
;Delete empty start menu parent directories
|
||||||
StrCpy $MUI_TEMP "$SMPROGRAMS\$MUI_TEMP"
|
StrCpy $MUI_TEMP "$SMPROGRAMS\$MUI_TEMP"
|
||||||
|
|
||||||
secondStartMenuDeleteLoop:
|
secondStartMenuDeleteLoop:
|
||||||
|
@ -22,7 +22,7 @@ send random size message to each socket and check server answer
|
|||||||
|
|
||||||
#define CLIENT_COUNT 5 // client threads count
|
#define CLIENT_COUNT 5 // client threads count
|
||||||
#define CLIENT_CONNECTION 100 // ZMQ_CLIENT sockets at each client
|
#define CLIENT_CONNECTION 100 // ZMQ_CLIENT sockets at each client
|
||||||
#define CLIENT_RECCONECT 1000 // reconnect one socket after messages
|
#define CLIENT_RECONNECT 1000 // reconnect one socket after messages
|
||||||
|
|
||||||
#define MESSAGE_MAX_SIZE 1024
|
#define MESSAGE_MAX_SIZE 1024
|
||||||
|
|
||||||
@ -157,7 +157,7 @@ void client(int num)
|
|||||||
client_ready++;
|
client_ready++;
|
||||||
while (client_ready < CLIENT_COUNT) Sleep(10); // wait while all clients open sockets
|
while (client_ready < CLIENT_COUNT) Sleep(10); // wait while all clients open sockets
|
||||||
|
|
||||||
int recconect = 0;
|
int reconnect = 0;
|
||||||
while(1) {
|
while(1) {
|
||||||
int val[CLIENT_CONNECTION];
|
int val[CLIENT_CONNECTION];
|
||||||
zmq_msg_t msg;
|
zmq_msg_t msg;
|
||||||
@ -179,8 +179,8 @@ void client(int num)
|
|||||||
client_cnt[num]++;
|
client_cnt[num]++;
|
||||||
}
|
}
|
||||||
// reconnect one
|
// reconnect one
|
||||||
recconect++;
|
reconnect++;
|
||||||
if(recconect == CLIENT_RECCONECT) {
|
if(reconnect == CLIENT_RECONNECT) {
|
||||||
int n = rand() % CLIENT_CONNECTION;
|
int n = rand() % CLIENT_CONNECTION;
|
||||||
zmq_close(sock[n]);
|
zmq_close(sock[n]);
|
||||||
sock[n] = zmq_socket(ctx, ZMQ_CLIENT); assert(sock[n]);
|
sock[n] = zmq_socket(ctx, ZMQ_CLIENT); assert(sock[n]);
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
NuGet is a package management system for MS-Windows.
|
NuGet is a package management system for MS-Windows.
|
||||||
It is similar in spirit to tools like Maven or Gradle.
|
It is similar in spirit to tools like Maven or Gradle.
|
||||||
|
|
||||||
It was originaly for .Net only packages but it has
|
It was originally for .Net only packages but it has
|
||||||
recently been augmented to working with native packages.
|
recently been augmented to working with native packages.
|
||||||
http://docs.nuget.org/docs/reference/support-for-native-projects
|
http://docs.nuget.org/docs/reference/support-for-native-projects
|
||||||
|
|
||||||
|
@ -33,7 +33,7 @@ installed, ZeroMQ can be built as follows:
|
|||||||
* Download and extract ZeroMQ tar file
|
* Download and extract ZeroMQ tar file
|
||||||
|
|
||||||
* Ensure contents of this directory are present at `builds/zos`
|
* Ensure contents of this directory are present at `builds/zos`
|
||||||
within that extracted diretory (eg, `zeromq-VERSION/builds/zos/`;
|
within that extracted directory (eg, `zeromq-VERSION/builds/zos/`;
|
||||||
copy these files in, if not already present, and make sure the
|
copy these files in, if not already present, and make sure the
|
||||||
shell scripts are executable)
|
shell scripts are executable)
|
||||||
|
|
||||||
@ -238,7 +238,7 @@ them, and it would be non-trivial to track them by hand.)
|
|||||||
The source code in ZeroMQ is a combination of a C++ core library
|
The source code in ZeroMQ is a combination of a C++ core library
|
||||||
(in `*.cpp` and `*.hpp` files), and a C wrapper (also in `*.cpp`
|
(in `*.cpp` and `*.hpp` files), and a C wrapper (also in `*.cpp`
|
||||||
files). It is all compiled with the C++ compiler. The IBM XL C/C++
|
files). It is all compiled with the C++ compiler. The IBM XL C/C++
|
||||||
complier (at least the version used for initial porting) insists
|
compiler (at least the version used for initial porting) insists
|
||||||
that C++ source be in `*.C` files (note capital C). To work around
|
that C++ source be in `*.C` files (note capital C). To work around
|
||||||
this issue the compile flag `-+` is used (specified in the `zc++`
|
this issue the compile flag `-+` is used (specified in the `zc++`
|
||||||
compiler wrapper), which tells the compiler the file should be
|
compiler wrapper), which tells the compiler the file should be
|
||||||
@ -359,7 +359,7 @@ syntax):
|
|||||||
setenv CXXFLAGS "-Wc,xplink -Wl,xplink -+"
|
setenv CXXFLAGS "-Wc,xplink -Wl,xplink -+"
|
||||||
|
|
||||||
* run configure script with `--disable-eventfd` (`sys/eventfd.h` does
|
* run configure script with `--disable-eventfd` (`sys/eventfd.h` does
|
||||||
not exist, but the test for its existance has a false positive on
|
not exist, but the test for its existence has a false positive on
|
||||||
z/OS UNIX System Services, apparently due to the way the `c++`
|
z/OS UNIX System Services, apparently due to the way the `c++`
|
||||||
compiler wrapper passes errors back from the IBM XL C/C++ compiler),
|
compiler wrapper passes errors back from the IBM XL C/C++ compiler),
|
||||||
and with `--with-poller=poll` because `poll` is the most advanced
|
and with `--with-poller=poll` because `poll` is the most advanced
|
||||||
|
@ -85,7 +85,7 @@ verbose() {
|
|||||||
TESTS_ENVIRONMENT=
|
TESTS_ENVIRONMENT=
|
||||||
|
|
||||||
#---------------------------------------------------------------------------
|
#---------------------------------------------------------------------------
|
||||||
# Explicitly add SRCDIR into library serach path, to make sure we
|
# Explicitly add SRCDIR into library search path, to make sure we
|
||||||
# use our just-built version
|
# use our just-built version
|
||||||
LIBPATH="${SRCDIR}:/lib:/usr/lib"
|
LIBPATH="${SRCDIR}:/lib:/usr/lib"
|
||||||
export LIBPATH
|
export LIBPATH
|
||||||
|
@ -5,7 +5,7 @@
|
|||||||
# to get through both ./configure arguments _and_ Makefile/shell expansion
|
# to get through both ./configure arguments _and_ Makefile/shell expansion
|
||||||
# safely so more easily added in this wrapper.
|
# safely so more easily added in this wrapper.
|
||||||
#
|
#
|
||||||
# Finally, by default will enable xplink for C++ compatibilty and performance
|
# Finally, by default will enable xplink for C++ compatibility and performance
|
||||||
# (c++ standard library requires xplink enabled).
|
# (c++ standard library requires xplink enabled).
|
||||||
#
|
#
|
||||||
# Additional compile/link flags can be passed in as ZCXXFLAGS, eg:
|
# Additional compile/link flags can be passed in as ZCXXFLAGS, eg:
|
||||||
|
@ -599,7 +599,7 @@ elif test "x$with_libsodium" = "xyes"; then
|
|||||||
if test "x$enable_libsodium_randombytes_close" = "xyes"; then
|
if test "x$enable_libsodium_randombytes_close" = "xyes"; then
|
||||||
AC_DEFINE(ZMQ_LIBSODIUM_RANDOMBYTES_CLOSE, [1], [Automatically close libsodium randombytes. Not threadsafe without getrandom()])
|
AC_DEFINE(ZMQ_LIBSODIUM_RANDOMBYTES_CLOSE, [1], [Automatically close libsodium randombytes. Not threadsafe without getrandom()])
|
||||||
else
|
else
|
||||||
AC_MSG_NOTICE([Disabling libsodium randombytes_close(). randombytes_close() may need to be called in applcation code.])
|
AC_MSG_NOTICE([Disabling libsodium randombytes_close(). randombytes_close() may need to be called in application code.])
|
||||||
fi
|
fi
|
||||||
|
|
||||||
curve_library="libsodium"
|
curve_library="libsodium"
|
||||||
|
@ -19,7 +19,7 @@ by the 'socket' argument from the endpoint specified by the 'endpoint'
|
|||||||
argument. Note the actual disconnect system call might occur at a later time.
|
argument. Note the actual disconnect system call might occur at a later time.
|
||||||
|
|
||||||
Upon disconnection the will also stop receiving messages originating from
|
Upon disconnection the will also stop receiving messages originating from
|
||||||
this endpoint. Moreover, the socket will no longuer be able
|
this endpoint. Moreover, the socket will no longer be able
|
||||||
to queue outgoing messages to this endpoint. The outgoing message queue
|
to queue outgoing messages to this endpoint. The outgoing message queue
|
||||||
associated with the endpoint will be discarded. However, if the socket's linger
|
associated with the endpoint will be discarded. However, if the socket's linger
|
||||||
period is non-zero, libzmq will still attempt to transmit these discarded messages,
|
period is non-zero, libzmq will still attempt to transmit these discarded messages,
|
||||||
|
@ -624,7 +624,7 @@ ZMQ_RECONNECT_IVL_MAX: Retrieve maximum reconnection interval
|
|||||||
The 'ZMQ_RECONNECT_IVL_MAX' option shall retrieve the maximum reconnection
|
The 'ZMQ_RECONNECT_IVL_MAX' option shall retrieve the maximum reconnection
|
||||||
interval for the specified 'socket'. This is the maximum period 0MQ shall wait
|
interval for the specified 'socket'. This is the maximum period 0MQ shall wait
|
||||||
between attempts to reconnect. On each reconnect attempt, the previous interval
|
between attempts to reconnect. On each reconnect attempt, the previous interval
|
||||||
shall be doubled untill ZMQ_RECONNECT_IVL_MAX is reached. This allows for
|
shall be doubled until ZMQ_RECONNECT_IVL_MAX is reached. This allows for
|
||||||
exponential backoff strategy. Default value means no exponential backoff is
|
exponential backoff strategy. Default value means no exponential backoff is
|
||||||
performed and reconnect interval calculations are only based on
|
performed and reconnect interval calculations are only based on
|
||||||
ZMQ_RECONNECT_IVL.
|
ZMQ_RECONNECT_IVL.
|
||||||
|
@ -134,7 +134,7 @@ CONFIGURATION
|
|||||||
-------------
|
-------------
|
||||||
|
|
||||||
The PGM is protocol is capable of multicasting data at high rates (500Mbps+)
|
The PGM is protocol is capable of multicasting data at high rates (500Mbps+)
|
||||||
with large messages (1MB+), however it requires setting the relevent ZMQ socket
|
with large messages (1MB+), however it requires setting the relevant ZMQ socket
|
||||||
options that are documented in linkzmq:zmq_setsockopt[3]:
|
options that are documented in linkzmq:zmq_setsockopt[3]:
|
||||||
|
|
||||||
* The 'ZMQ_RATE' should be set sufficiently high, e.g. 1Gbps
|
* The 'ZMQ_RATE' should be set sufficiently high, e.g. 1Gbps
|
||||||
|
@ -71,7 +71,7 @@ _zmq_poll()_.
|
|||||||
|
|
||||||
*ZMQ_POLLPRI*::
|
*ZMQ_POLLPRI*::
|
||||||
For 0MQ sockets this flags is of no use. For standard sockets this means there
|
For 0MQ sockets this flags is of no use. For standard sockets this means there
|
||||||
is urgent data to read. Refer to the POLLPRI flag for more informations.
|
is urgent data to read. Refer to the POLLPRI flag for more information.
|
||||||
For file descriptor, refer to your use case: as an example, GPIO interrupts
|
For file descriptor, refer to your use case: as an example, GPIO interrupts
|
||||||
are signaled through a POLLPRI event.
|
are signaled through a POLLPRI event.
|
||||||
This flag has no effect on Windows.
|
This flag has no effect on Windows.
|
||||||
@ -86,7 +86,7 @@ The *zmq_pollitem_t* array must only be used by the thread which
|
|||||||
will/is calling _zmq_poll_.
|
will/is calling _zmq_poll_.
|
||||||
|
|
||||||
If a socket is contained in multiple *zmq_pollitem_t* arrays, each owned by a
|
If a socket is contained in multiple *zmq_pollitem_t* arrays, each owned by a
|
||||||
different thread, the socket itself needs to be thead-safe (Server, Client, ...).
|
different thread, the socket itself needs to be thread-safe (Server, Client, ...).
|
||||||
Otherwise, behaviour is undefined.
|
Otherwise, behaviour is undefined.
|
||||||
|
|
||||||
|
|
||||||
|
@ -91,7 +91,7 @@ associated with the socket registration, and requires that the _socket_
|
|||||||
remains valid.
|
remains valid.
|
||||||
|
|
||||||
_zmq_poller_add_fd_, _zmq_poller_modify_fd_ and _zmq_poller_remove_fd_ are
|
_zmq_poller_add_fd_, _zmq_poller_modify_fd_ and _zmq_poller_remove_fd_ are
|
||||||
analogous to the previous functions but manage regular file descriptiors
|
analogous to the previous functions but manage regular file descriptors
|
||||||
registered with a poller. On Windows, these functions can only be used with
|
registered with a poller. On Windows, these functions can only be used with
|
||||||
WinSock sockets.
|
WinSock sockets.
|
||||||
|
|
||||||
@ -185,7 +185,7 @@ For 0MQ sockets this flag has no effect on the _zmq_poller_add_ and
|
|||||||
_zmq_poller_modify_ functions, and is never set in the
|
_zmq_poller_modify_ functions, and is never set in the
|
||||||
'events' member of the zmq_poller_event_t structure.
|
'events' member of the zmq_poller_event_t structure.
|
||||||
For standard sockets this means there
|
For standard sockets this means there
|
||||||
is urgent data to read. Refer to the POLLPRI flag for more informations.
|
is urgent data to read. Refer to the POLLPRI flag for more information.
|
||||||
For a file descriptor, refer to your OS documentation: as an example, GPIO
|
For a file descriptor, refer to your OS documentation: as an example, GPIO
|
||||||
interrupts are signaled through a POLLPRI event.
|
interrupts are signaled through a POLLPRI event.
|
||||||
This flag has no effect on Windows.
|
This flag has no effect on Windows.
|
||||||
|
@ -257,7 +257,7 @@ Default value:: NULL
|
|||||||
Applicable socket types:: ZMQ_ROUTER, ZMQ_SERVER and ZMQ_PEER
|
Applicable socket types:: ZMQ_ROUTER, ZMQ_SERVER and ZMQ_PEER
|
||||||
|
|
||||||
|
|
||||||
ZMQ_HICCUP_MSG: set a hiccup message that the socket will generate when connected peer temporarly disconnect
|
ZMQ_HICCUP_MSG: set a hiccup message that the socket will generate when connected peer temporarily disconnect
|
||||||
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
||||||
When set, the socket will generate a hiccup message when connect peer has been disconnected.
|
When set, the socket will generate a hiccup message when connect peer has been disconnected.
|
||||||
You may set this on DEALER, CLIENT and PEER sockets.
|
You may set this on DEALER, CLIENT and PEER sockets.
|
||||||
@ -527,9 +527,9 @@ ZMQ_METADATA: Add application metadata properties to a socket
|
|||||||
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
||||||
The _ZMQ_METADATA_ option shall add application metadata to the specified _socket_,
|
The _ZMQ_METADATA_ option shall add application metadata to the specified _socket_,
|
||||||
the metadata is exchanged with peers during connection setup. A metadata property is
|
the metadata is exchanged with peers during connection setup. A metadata property is
|
||||||
specfied as a string, delimited by a colon, starting with the metadata _property_
|
specified as a string, delimited by a colon, starting with the metadata _property_
|
||||||
followed by the metadata value, for example "X-key:value".
|
followed by the metadata value, for example "X-key:value".
|
||||||
_Property_ names are restrited to maximum 255 characters and must be prefixed by "X-".
|
_Property_ names are restricted to maximum 255 characters and must be prefixed by "X-".
|
||||||
Multiple application metadata properties can be added to a socket by executing zmq_setsockopt()
|
Multiple application metadata properties can be added to a socket by executing zmq_setsockopt()
|
||||||
multiple times. As the argument is a null-terminated string, binary data must be encoded
|
multiple times. As the argument is a null-terminated string, binary data must be encoded
|
||||||
before it is added e.g. using Z85 (linkzmq:zmq_z85_encode[3]).
|
before it is added e.g. using Z85 (linkzmq:zmq_z85_encode[3]).
|
||||||
@ -755,7 +755,7 @@ ZMQ_RECONNECT_IVL_MAX: Set maximum reconnection interval
|
|||||||
The 'ZMQ_RECONNECT_IVL_MAX' option shall set the maximum reconnection interval
|
The 'ZMQ_RECONNECT_IVL_MAX' option shall set the maximum reconnection interval
|
||||||
for the specified 'socket'. This is the maximum period 0MQ shall wait between
|
for the specified 'socket'. This is the maximum period 0MQ shall wait between
|
||||||
attempts to reconnect. On each reconnect attempt, the previous interval shall be
|
attempts to reconnect. On each reconnect attempt, the previous interval shall be
|
||||||
doubled untill ZMQ_RECONNECT_IVL_MAX is reached. This allows for exponential
|
doubled until ZMQ_RECONNECT_IVL_MAX is reached. This allows for exponential
|
||||||
backoff strategy. Default value means no exponential backoff is performed and
|
backoff strategy. Default value means no exponential backoff is performed and
|
||||||
reconnect interval calculations are only based on ZMQ_RECONNECT_IVL.
|
reconnect interval calculations are only based on ZMQ_RECONNECT_IVL.
|
||||||
|
|
||||||
@ -1238,7 +1238,7 @@ Applicable socket types:: ZMQ_XPUB, ZMQ_PUB
|
|||||||
|
|
||||||
ZMQ_XPUB_WELCOME_MSG: set welcome message that will be received by subscriber when connecting
|
ZMQ_XPUB_WELCOME_MSG: set welcome message that will be received by subscriber when connecting
|
||||||
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
||||||
Sets a welcome message the will be recieved by subscriber when connecting.
|
Sets a welcome message the will be received by subscriber when connecting.
|
||||||
Subscriber must subscribe to the Welcome message before connecting.
|
Subscriber must subscribe to the Welcome message before connecting.
|
||||||
Welcome message will also be sent on reconnecting.
|
Welcome message will also be sent on reconnecting.
|
||||||
For welcome message to work well user must poll on incoming subscription messages on the XPUB socket and handle them.
|
For welcome message to work well user must poll on incoming subscription messages on the XPUB socket and handle them.
|
||||||
|
@ -76,7 +76,7 @@ HWM
|
|||||||
For the TCP transport, the high water mark (HWM) mechanism works in conjunction
|
For the TCP transport, the high water mark (HWM) mechanism works in conjunction
|
||||||
with the TCP socket buffers handled at OS level.
|
with the TCP socket buffers handled at OS level.
|
||||||
Depending on the OS and several other factors the size of such TCP buffers will
|
Depending on the OS and several other factors the size of such TCP buffers will
|
||||||
be different. Moreover TCP buffers provided by the OS will accomodate a varying
|
be different. Moreover TCP buffers provided by the OS will accommodate a varying
|
||||||
number of messages depending on the size of messages (unlike ZMQ HWM settings
|
number of messages depending on the size of messages (unlike ZMQ HWM settings
|
||||||
the TCP socket buffers are measured in bytes and not messages).
|
the TCP socket buffers are measured in bytes and not messages).
|
||||||
|
|
||||||
|
@ -18,7 +18,7 @@ The _zmq_unbind()_ function shall unbind a socket specified
|
|||||||
by the 'socket' argument from the endpoint specified by the 'endpoint'
|
by the 'socket' argument from the endpoint specified by the 'endpoint'
|
||||||
argument.
|
argument.
|
||||||
|
|
||||||
Addionally the incoming message queue associated with the endpoint will be
|
Additionally the incoming message queue associated with the endpoint will be
|
||||||
discarded. This means that after unbinding an endpoint it is possible to
|
discarded. This means that after unbinding an endpoint it is possible to
|
||||||
received messages originating from that same endpoint if they were already
|
received messages originating from that same endpoint if they were already
|
||||||
present in the incoming message queue before unbinding.
|
present in the incoming message queue before unbinding.
|
||||||
|
@ -159,12 +159,12 @@ void generic_mtrie_t<T>::rm (value_t *pipe_,
|
|||||||
Arg arg_,
|
Arg arg_,
|
||||||
bool call_on_uniq_)
|
bool call_on_uniq_)
|
||||||
{
|
{
|
||||||
// This used to be implemented as a non-tail recursive travesal of the trie,
|
// This used to be implemented as a non-tail recursive traversal of the trie,
|
||||||
// which means remote clients controlled the depth of the recursion and the
|
// which means remote clients controlled the depth of the recursion and the
|
||||||
// stack size.
|
// stack size.
|
||||||
// To simulate the non-tail recursion, with post-recursion changes depending on
|
// To simulate the non-tail recursion, with post-recursion changes depending on
|
||||||
// the result of the recursive call, a stack is used to re-visit the same node
|
// the result of the recursive call, a stack is used to re-visit the same node
|
||||||
// and operate on it again after children have been visisted.
|
// and operate on it again after children have been visited.
|
||||||
// A boolean is used to record whether the node had already been visited and to
|
// A boolean is used to record whether the node had already been visited and to
|
||||||
// determine if the pre- or post- children visit actions have to be taken.
|
// determine if the pre- or post- children visit actions have to be taken.
|
||||||
// In the case of a node with (N > 1) children, the node has to be re-visited
|
// In the case of a node with (N > 1) children, the node has to be re-visited
|
||||||
@ -401,12 +401,12 @@ template <typename T>
|
|||||||
typename generic_mtrie_t<T>::rm_result
|
typename generic_mtrie_t<T>::rm_result
|
||||||
generic_mtrie_t<T>::rm (prefix_t prefix_, size_t size_, value_t *pipe_)
|
generic_mtrie_t<T>::rm (prefix_t prefix_, size_t size_, value_t *pipe_)
|
||||||
{
|
{
|
||||||
// This used to be implemented as a non-tail recursive travesal of the trie,
|
// This used to be implemented as a non-tail recursive traversal of the trie,
|
||||||
// which means remote clients controlled the depth of the recursion and the
|
// which means remote clients controlled the depth of the recursion and the
|
||||||
// stack size.
|
// stack size.
|
||||||
// To simulate the non-tail recursion, with post-recursion changes depending on
|
// To simulate the non-tail recursion, with post-recursion changes depending on
|
||||||
// the result of the recursive call, a stack is used to re-visit the same node
|
// the result of the recursive call, a stack is used to re-visit the same node
|
||||||
// and operate on it again after children have been visisted.
|
// and operate on it again after children have been visited.
|
||||||
// A boolean is used to record whether the node had already been visited and to
|
// A boolean is used to record whether the node had already been visited and to
|
||||||
// determine if the pre- or post- children visit actions have to be taken.
|
// determine if the pre- or post- children visit actions have to be taken.
|
||||||
rm_result ret = not_found;
|
rm_result ret = not_found;
|
||||||
|
@ -307,7 +307,7 @@ bool zmq::initialize_network ()
|
|||||||
#endif
|
#endif
|
||||||
|
|
||||||
#ifdef ZMQ_HAVE_WINDOWS
|
#ifdef ZMQ_HAVE_WINDOWS
|
||||||
// Intialise Windows sockets. Note that WSAStartup can be called multiple
|
// Initialise Windows sockets. Note that WSAStartup can be called multiple
|
||||||
// times given that WSACleanup will be called for each WSAStartup.
|
// times given that WSACleanup will be called for each WSAStartup.
|
||||||
|
|
||||||
const WORD version_requested = MAKEWORD (2, 2);
|
const WORD version_requested = MAKEWORD (2, 2);
|
||||||
|
@ -77,7 +77,7 @@ void make_socket_noninheritable (fd_t sock_);
|
|||||||
|
|
||||||
// Asserts that:
|
// Asserts that:
|
||||||
// - an internal 0MQ error did not occur,
|
// - an internal 0MQ error did not occur,
|
||||||
// - and, if a socket error occured, it can be recovered from.
|
// - and, if a socket error occurred, it can be recovered from.
|
||||||
void assert_success_or_recoverable (fd_t s_, int rc_);
|
void assert_success_or_recoverable (fd_t s_, int rc_);
|
||||||
|
|
||||||
#ifdef ZMQ_HAVE_IPC
|
#ifdef ZMQ_HAVE_IPC
|
||||||
|
@ -167,7 +167,7 @@ struct options_t
|
|||||||
std::string socks_proxy_address;
|
std::string socks_proxy_address;
|
||||||
|
|
||||||
// Credentials for SOCKS proxy.
|
// Credentials for SOCKS proxy.
|
||||||
// Conneciton method will be basic auth if username
|
// Connection method will be basic auth if username
|
||||||
// is not empty, no auth otherwise.
|
// is not empty, no auth otherwise.
|
||||||
std::string socks_proxy_username;
|
std::string socks_proxy_username;
|
||||||
std::string socks_proxy_password;
|
std::string socks_proxy_password;
|
||||||
|
@ -74,7 +74,7 @@ void zmq::own_t::process_seqnum ()
|
|||||||
// Catch up with counter of processed commands.
|
// Catch up with counter of processed commands.
|
||||||
_processed_seqnum++;
|
_processed_seqnum++;
|
||||||
|
|
||||||
// We may have catched up and still have pending terms acks.
|
// We may have caught up and still have pending terms acks.
|
||||||
check_term_acks ();
|
check_term_acks ();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -96,7 +96,7 @@ void zmq::pgm_sender_t::plug (io_thread_t *io_thread_, session_base_t *session_)
|
|||||||
rdata_notify_handle = add_fd (rdata_notify_fd);
|
rdata_notify_handle = add_fd (rdata_notify_fd);
|
||||||
pending_notify_handle = add_fd (pending_notify_fd);
|
pending_notify_handle = add_fd (pending_notify_fd);
|
||||||
|
|
||||||
// Set POLLIN. We wont never want to stop polling for uplink = we never
|
// Set POLLIN. We will never want to stop polling for uplink = we never
|
||||||
// want to stop processing NAKs.
|
// want to stop processing NAKs.
|
||||||
set_pollin (uplink_handle);
|
set_pollin (uplink_handle);
|
||||||
set_pollin (rdata_notify_handle);
|
set_pollin (rdata_notify_handle);
|
||||||
|
@ -281,7 +281,7 @@ int zmq::req_session_t::push_msg (msg_t *msg_)
|
|||||||
case bottom:
|
case bottom:
|
||||||
if (msg_->flags () == msg_t::more) {
|
if (msg_->flags () == msg_t::more) {
|
||||||
// In case option ZMQ_CORRELATE is on, allow request_id to be
|
// In case option ZMQ_CORRELATE is on, allow request_id to be
|
||||||
// transfered as first frame (would be too cumbersome to check
|
// transferred as first frame (would be too cumbersome to check
|
||||||
// whether the option is actually on or not).
|
// whether the option is actually on or not).
|
||||||
if (msg_->size () == sizeof (uint32_t)) {
|
if (msg_->size () == sizeof (uint32_t)) {
|
||||||
_state = request_id;
|
_state = request_id;
|
||||||
|
@ -420,7 +420,7 @@ bool zmq::router_t::xhas_out ()
|
|||||||
{
|
{
|
||||||
// In theory, ROUTER socket is always ready for writing (except when
|
// In theory, ROUTER socket is always ready for writing (except when
|
||||||
// MANDATORY is set). Whether actual attempt to write succeeds depends
|
// MANDATORY is set). Whether actual attempt to write succeeds depends
|
||||||
// on whitch pipe the message is going to be routed to.
|
// on which pipe the message is going to be routed to.
|
||||||
|
|
||||||
if (!_mandatory)
|
if (!_mandatory)
|
||||||
return true;
|
return true;
|
||||||
|
@ -575,7 +575,7 @@ void zmq::udp_engine_t::in_event ()
|
|||||||
msg.set_flags (msg_t::more);
|
msg.set_flags (msg_t::more);
|
||||||
memcpy (msg.data (), group_buffer, group_size);
|
memcpy (msg.data (), group_buffer, group_size);
|
||||||
|
|
||||||
// This doesn't fit, just ingore
|
// This doesn't fit, just ignore
|
||||||
if (nbytes - 1 < group_size)
|
if (nbytes - 1 < group_size)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
|
@ -136,7 +136,7 @@ void zmq::ws_engine_t::start_ws_handshake ()
|
|||||||
protocol = "ZWS2.0/CURVE";
|
protocol = "ZWS2.0/CURVE";
|
||||||
#endif
|
#endif
|
||||||
else {
|
else {
|
||||||
// Avoid unitialized variable error breaking UWP build
|
// Avoid uninitialized variable error breaking UWP build
|
||||||
protocol = "";
|
protocol = "";
|
||||||
assert (false);
|
assert (false);
|
||||||
}
|
}
|
||||||
|
@ -139,7 +139,7 @@ int zmq::xsub_t::xsend (msg_t *msg_)
|
|||||||
if (msg_->is_subscribe () || (size > 0 && *data == 1)) {
|
if (msg_->is_subscribe () || (size > 0 && *data == 1)) {
|
||||||
// Process subscribe message
|
// Process subscribe message
|
||||||
// This used to filter out duplicate subscriptions,
|
// This used to filter out duplicate subscriptions,
|
||||||
// however this is alread done on the XPUB side and
|
// however this is already done on the XPUB side and
|
||||||
// doing it here as well breaks ZMQ_XPUB_VERBOSE
|
// doing it here as well breaks ZMQ_XPUB_VERBOSE
|
||||||
// when there are forwarding devices involved.
|
// when there are forwarding devices involved.
|
||||||
if (!msg_->is_subscribe ()) {
|
if (!msg_->is_subscribe ()) {
|
||||||
|
@ -77,7 +77,7 @@ template <typename T, int N> class ypipe_t ZMQ_FINAL : public ypipe_base_t<T>
|
|||||||
_queue.back () = value_;
|
_queue.back () = value_;
|
||||||
_queue.push ();
|
_queue.push ();
|
||||||
|
|
||||||
// Move the "flush up to here" poiter.
|
// Move the "flush up to here" pointer.
|
||||||
if (!incomplete_)
|
if (!incomplete_)
|
||||||
_f = &_queue.back ();
|
_f = &_queue.back ();
|
||||||
}
|
}
|
||||||
@ -108,7 +108,7 @@ template <typename T, int N> class ypipe_t ZMQ_FINAL : public ypipe_base_t<T>
|
|||||||
|
|
||||||
// Try to set 'c' to 'f'.
|
// Try to set 'c' to 'f'.
|
||||||
if (_c.cas (_w, _f) != _w) {
|
if (_c.cas (_w, _f) != _w) {
|
||||||
// Compare-and-swap was unseccessful because 'c' is NULL.
|
// Compare-and-swap was unsuccessful because 'c' is NULL.
|
||||||
// This means that the reader is asleep. Therefore we don't
|
// This means that the reader is asleep. Therefore we don't
|
||||||
// care about thread-safeness and update c in non-atomic
|
// care about thread-safeness and update c in non-atomic
|
||||||
// manner. We'll return false to let the caller know
|
// manner. We'll return false to let the caller know
|
||||||
@ -163,7 +163,7 @@ template <typename T, int N> class ypipe_t ZMQ_FINAL : public ypipe_base_t<T>
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Applies the function fn to the first elemenent in the pipe
|
// Applies the function fn to the first element in the pipe
|
||||||
// and returns the value returned by the fn.
|
// and returns the value returned by the fn.
|
||||||
// The pipe mustn't be empty or the function crashes.
|
// The pipe mustn't be empty or the function crashes.
|
||||||
bool probe (bool (*fn_) (const T &))
|
bool probe (bool (*fn_) (const T &))
|
||||||
|
@ -97,7 +97,7 @@ template <typename T> class ypipe_conflate_t ZMQ_FINAL : public ypipe_base_t<T>
|
|||||||
return dbuffer.read (value_);
|
return dbuffer.read (value_);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Applies the function fn to the first elemenent in the pipe
|
// Applies the function fn to the first element in the pipe
|
||||||
// and returns the value returned by the fn.
|
// and returns the value returned by the fn.
|
||||||
// The pipe mustn't be empty or the function crashes.
|
// The pipe mustn't be empty or the function crashes.
|
||||||
bool probe (bool (*fn_) (const T &)) { return dbuffer.probe (fn_); }
|
bool probe (bool (*fn_) (const T &)) { return dbuffer.probe (fn_); }
|
||||||
|
@ -35,7 +35,7 @@ SETUP_TEARDOWN_TESTCONTEXT
|
|||||||
// DEBUG shouldn't be defined in sources as it will cause a redefined symbol
|
// DEBUG shouldn't be defined in sources as it will cause a redefined symbol
|
||||||
// error when it is defined in the build configuration. It appears that the
|
// error when it is defined in the build configuration. It appears that the
|
||||||
// intent here is to semi-permanently disable DEBUG tracing statements, so the
|
// intent here is to semi-permanently disable DEBUG tracing statements, so the
|
||||||
// implementation is changed to accomodate that intent.
|
// implementation is changed to accommodate that intent.
|
||||||
//#define DEBUG 0
|
//#define DEBUG 0
|
||||||
#define TRACE_ENABLED 0
|
#define TRACE_ENABLED 0
|
||||||
|
|
||||||
|
@ -50,7 +50,7 @@ const char *name = "zmqtest2";
|
|||||||
static volatile int zap_deny_all = 0;
|
static volatile int zap_deny_all = 0;
|
||||||
|
|
||||||
// --------------------------------------------------------------------------
|
// --------------------------------------------------------------------------
|
||||||
// This methods receives and validates ZAP requestes (allowing or denying
|
// This methods receives and validates ZAP requests (allowing or denying
|
||||||
// each client connection).
|
// each client connection).
|
||||||
// N.B. on failure, each crypto type in keytab will be tried
|
// N.B. on failure, each crypto type in keytab will be tried
|
||||||
|
|
||||||
|
@ -266,7 +266,7 @@ void test_push_multipart_atomic_drop (const char *bind_address_,
|
|||||||
size_t zmq_events_size = sizeof (int);
|
size_t zmq_events_size = sizeof (int);
|
||||||
int zmq_events;
|
int zmq_events;
|
||||||
|
|
||||||
// Normal case - excercise the queues
|
// Normal case - exercise the queues
|
||||||
send_string_expect_success (push, "0", ZMQ_SNDMORE);
|
send_string_expect_success (push, "0", ZMQ_SNDMORE);
|
||||||
send_string_expect_success (push, "0", ZMQ_SNDMORE);
|
send_string_expect_success (push, "0", ZMQ_SNDMORE);
|
||||||
TEST_ASSERT_SUCCESS_ERRNO (zmq_msg_init_size (&msg_data, len));
|
TEST_ASSERT_SUCCESS_ERRNO (zmq_msg_init_size (&msg_data, len));
|
||||||
|
Loading…
Reference in New Issue
Block a user