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
bde18f3e
Commit
bde18f3e
authored
May 18, 2019
by
Luca Boccassi
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Problem: comments before ifdefs are wrongly formatted
Solution: now that clang-format 6+ is used in the CI, fix it
parent
5de3aa15
Hide whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
21 additions
and
21 deletions
+21
-21
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
udp_engine.cpp
src/udp_engine.cpp
+2
-2
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/options.cpp
View file @
bde18f3e
...
...
@@ -761,10 +761,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 @
bde18f3e
...
...
@@ -353,9 +353,9 @@ int zmq::socket_base_t::check_protocol (const std::string &protocol_) const
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
...
...
@@ -896,7 +896,7 @@ int zmq::socket_base_t::connect (const char *endpoint_uri_)
}
}
// 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 @
bde18f3e
...
...
@@ -255,7 +255,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 @
bde18f3e
...
...
@@ -219,7 +219,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
...
...
@@ -230,8 +230,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/udp_engine.cpp
View file @
bde18f3e
...
...
@@ -222,8 +222,8 @@ void zmq::udp_engine_t::plug (io_thread_t *io_thread_, session_base_t *session_)
bool
multicast
=
udp_addr
->
is_mcast
();
if
(
multicast
)
{
// Multicast addresses should be allowed to bind to more than
// one port as all ports should receive the message
// Multicast addresses should be allowed to bind to more than
// one port as all ports should receive the message
#ifdef SO_REUSEPORT
rc
=
setsockopt
(
_fd
,
SOL_SOCKET
,
SO_REUSEPORT
,
reinterpret_cast
<
char
*>
(
&
on
),
sizeof
(
on
));
...
...
src/ypipe.hpp
View file @
bde18f3e
...
...
@@ -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 @
bde18f3e
...
...
@@ -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 @
bde18f3e
...
...
@@ -712,7 +712,7 @@ const char *zmq_msg_gets (const zmq_msg_t *msg_, const char *property_)
return
NULL
;
}
// 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