Skip to content
Projects
Groups
Snippets
Help
Loading...
Sign in / Register
Toggle navigation
L
libzmq
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Packages
Packages
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
submodule
libzmq
Commits
7bce4ffb
Unverified
Commit
7bce4ffb
authored
Mar 11, 2018
by
Constantin Rack
Committed by
GitHub
Mar 11, 2018
Browse files
Options
Browse Files
Download
Plain Diff
Merge pull request #2982 from bluca/formattweetnacl
Problem: formatting issues in CI
parents
4726f726
8d544ef1
Hide whitespace changes
Inline
Side-by-side
Showing
9 changed files
with
31 additions
and
26 deletions
+31
-26
ip.cpp
src/ip.cpp
+3
-3
options.cpp
src/options.cpp
+4
-4
socket_base.cpp
src/socket_base.cpp
+4
-4
socks_connecter.cpp
src/socks_connecter.cpp
+1
-1
tcp_connecter.cpp
src/tcp_connecter.cpp
+3
-3
tweetnacl.c
src/tweetnacl.c
+9
-4
ypipe.hpp
src/ypipe.hpp
+3
-3
ypipe_conflate.hpp
src/ypipe_conflate.hpp
+3
-3
zmq.cpp
src/zmq.cpp
+1
-1
No files found.
src/ip.cpp
View file @
7bce4ffb
...
...
@@ -641,9 +641,9 @@ int zmq::make_fdpair (fd_t *r_, fd_t *w_)
*
w_
=
*
r_
=
-
1
;
return
-
1
;
}
else
{
// If there's no SOCK_CLOEXEC, let's try the second best option. Note that
// race condition can cause socket not to be closed (if fork happens
// between socket creation and this point).
// If there's no SOCK_CLOEXEC, let's try the second best option. Note that
// race condition can cause socket not to be closed (if fork happens
// between socket creation and this point).
#if !defined ZMQ_HAVE_SOCK_CLOEXEC && defined FD_CLOEXEC
rc
=
fcntl
(
sv
[
0
],
F_SETFD
,
FD_CLOEXEC
);
errno_assert
(
rc
!=
-
1
);
...
...
src/options.cpp
View file @
7bce4ffb
...
...
@@ -717,10 +717,10 @@ int zmq::options_t::setsockopt (int option_,
break
;
}
// TODO mechanism should either be set explicitly, or determined when
// connecting. currently, it depends on the order of setsockopt calls
// if there is some inconsistency, which is confusing. in addition,
// the assumed or set mechanism should be queryable (as a socket option)
// TODO mechanism should either be set explicitly, or determined when
// connecting. currently, it depends on the order of setsockopt calls
// if there is some inconsistency, which is confusing. in addition,
// the assumed or set mechanism should be queryable (as a socket option)
#if defined(ZMQ_ACT_MILITANT)
// There is no valid use case for passing an error back to the application
...
...
src/socket_base.cpp
View file @
7bce4ffb
...
...
@@ -313,9 +313,9 @@ int zmq::socket_base_t::check_protocol (const std::string &protocol_)
return
-
1
;
}
// Check whether socket type and transport protocol match.
// Specifically, multicast protocols can't be combined with
// bi-directional messaging patterns (socket types).
// Check whether socket type and transport protocol match.
// Specifically, multicast protocols can't be combined with
// bi-directional messaging patterns (socket types).
#if defined ZMQ_HAVE_OPENPGM || defined ZMQ_HAVE_NORM
if
((
protocol_
==
"pgm"
||
protocol_
==
"epgm"
||
protocol_
==
"norm"
)
&&
options
.
type
!=
ZMQ_PUB
&&
options
.
type
!=
ZMQ_SUB
...
...
@@ -878,7 +878,7 @@ int zmq::socket_base_t::connect (const char *addr_)
}
}
// TBD - Should we check address for ZMQ_HAVE_NORM???
// TBD - Should we check address for ZMQ_HAVE_NORM???
#ifdef ZMQ_HAVE_OPENPGM
if
(
protocol
==
"pgm"
||
protocol
==
"epgm"
)
{
...
...
src/socks_connecter.cpp
View file @
7bce4ffb
...
...
@@ -357,7 +357,7 @@ int zmq::socks_connecter_t::connect_to_proxy ()
}
}
// Connect to the remote peer.
// Connect to the remote peer.
#if defined ZMQ_HAVE_VXWORKS
rc
=
::
connect
(
s
,
(
sockaddr
*
)
tcp_addr
->
addr
(),
tcp_addr
->
addrlen
());
#else
...
...
src/tcp_connecter.cpp
View file @
7bce4ffb
...
...
@@ -347,7 +347,7 @@ int zmq::tcp_connecter_t::open ()
return
-
1
;
}
// Connect to the remote peer.
// Connect to the remote peer.
#if defined ZMQ_HAVE_VXWORKS
rc
=
::
connect
(
s
,
(
sockaddr
*
)
tcp_addr
->
addr
(),
tcp_addr
->
addrlen
());
#else
...
...
@@ -358,8 +358,8 @@ int zmq::tcp_connecter_t::open ()
return
0
;
}
// Translate error codes indicating asynchronous connect has been
// launched to a uniform EINPROGRESS.
// Translate error codes indicating asynchronous connect has been
// launched to a uniform EINPROGRESS.
#ifdef ZMQ_HAVE_WINDOWS
const
int
last_error
=
WSAGetLastError
();
if
(
last_error
==
WSAEINPROGRESS
||
last_error
==
WSAEWOULDBLOCK
)
...
...
src/tweetnacl.c
View file @
7bce4ffb
...
...
@@ -32,18 +32,22 @@
*/
#include "platform.hpp"
#if defined
(ZMQ_USE_TWEETNACL)
#if defined(ZMQ_USE_TWEETNACL)
/*
Disable warnings for this source only, rather than for the whole
codebase when building with C99 (gcc >= 4.2) or with Microsoft's compiler
*/
#if defined __GNUC__ && (__GNUC__ > 4 || (__GNUC__ == 4 && __GNUC_MINOR__ >= 2)) && __STDC_VERSION__ < 201112L
# pragma GCC diagnostic ignored "-Wsign-compare"
#if defined __GNUC__ \
&& (__GNUC__ > 4 || (__GNUC__ == 4 && __GNUC_MINOR__ >= 2)) \
&& __STDC_VERSION__ < 201112L
#pragma GCC diagnostic ignored "-Wsign-compare"
#elif defined _MSC_VER
#
pragma warning (disable:
4018 4244 4146)
#
pragma warning(disable :
4018 4244 4146)
#endif
// clang-format off
#include "tweetnacl.h"
#define FOR(i,n) for (i = 0;i < n;++i)
...
...
@@ -986,3 +990,4 @@ int sodium_init (void)
#endif
#endif
// clang-format on
src/ypipe.hpp
View file @
7bce4ffb
...
...
@@ -62,9 +62,9 @@ template <typename T, int N> class ypipe_t : public ypipe_base_t<T>
// just to keep ICC and code checking tools from complaining.
inline
virtual
~
ypipe_t
()
{}
// Following function (write) deliberately copies uninitialised data
// when used with zmq_msg. Initialising the VSM body for
// non-VSM messages won't be good for performance.
// Following function (write) deliberately copies uninitialised data
// when used with zmq_msg. Initialising the VSM body for
// non-VSM messages won't be good for performance.
#ifdef ZMQ_HAVE_OPENVMS
#pragma message save
...
...
src/ypipe_conflate.hpp
View file @
7bce4ffb
...
...
@@ -53,9 +53,9 @@ template <typename T> class ypipe_conflate_t : public ypipe_base_t<T>
// just to keep ICC and code checking tools from complaining.
inline
virtual
~
ypipe_conflate_t
()
{}
// Following function (write) deliberately copies uninitialised data
// when used with zmq_msg. Initialising the VSM body for
// non-VSM messages won't be good for performance.
// Following function (write) deliberately copies uninitialised data
// when used with zmq_msg. Initialising the VSM body for
// non-VSM messages won't be good for performance.
#ifdef ZMQ_HAVE_OPENVMS
#pragma message save
...
...
src/zmq.cpp
View file @
7bce4ffb
...
...
@@ -685,7 +685,7 @@ const char *zmq_msg_gets (const zmq_msg_t *msg_, const char *property_)
}
}
// Polling.
// Polling.
#if defined ZMQ_HAVE_POLLER
inline
int
zmq_poller_poll
(
zmq_pollitem_t
*
items_
,
int
nitems_
,
long
timeout_
)
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment