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
84267e73
Commit
84267e73
authored
Dec 08, 2019
by
Simon Giesecke
Committed by
Simon Giesecke
Dec 08, 2019
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Problem: inconsistent parameter names on definition/declaration
Solution: align them
parent
cd954e20
Hide whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
11 additions
and
11 deletions
+11
-11
curve_client.hpp
src/curve_client.hpp
+3
-3
decoder_allocators.hpp
src/decoder_allocators.hpp
+1
-1
radix_tree.hpp
src/radix_tree.hpp
+1
-1
socket_poller.hpp
src/socket_poller.hpp
+1
-1
udp_address.hpp
src/udp_address.hpp
+1
-1
udp_engine.hpp
src/udp_engine.hpp
+1
-1
ws_engine.cpp
src/ws_engine.cpp
+1
-1
xpub.hpp
src/xpub.hpp
+2
-2
No files found.
src/curve_client.hpp
View file @
84267e73
...
...
@@ -72,10 +72,10 @@ class curve_client_t : public curve_mechanism_base_t
curve_client_tools_t
_tools
;
int
produce_hello
(
msg_t
*
msg_
);
int
process_welcome
(
const
uint8_t
*
cmd_data_
,
size_t
data
_size_
);
int
process_welcome
(
const
uint8_t
*
msg_data_
,
size_t
msg
_size_
);
int
produce_initiate
(
msg_t
*
msg_
);
int
process_ready
(
const
uint8_t
*
cmd_data_
,
size_t
data
_size_
);
int
process_error
(
const
uint8_t
*
cmd_data_
,
size_t
data
_size_
);
int
process_ready
(
const
uint8_t
*
msg_data_
,
size_t
msg
_size_
);
int
process_error
(
const
uint8_t
*
msg_data_
,
size_t
msg
_size_
);
};
}
...
...
src/decoder_allocators.hpp
View file @
84267e73
...
...
@@ -103,7 +103,7 @@ class shared_message_memory_allocator
void
inc_ref
();
static
void
call_dec_ref
(
void
*
,
void
*
buffer
_
);
static
void
call_dec_ref
(
void
*
,
void
*
hint
_
);
std
::
size_t
size
()
const
;
...
...
src/radix_tree.hpp
View file @
84267e73
...
...
@@ -78,7 +78,7 @@ struct node_t
inline
void
set_refcount
(
uint32_t
value_
);
inline
void
set_prefix_length
(
uint32_t
value_
);
inline
void
set_edgecount
(
uint32_t
value_
);
inline
void
set_prefix
(
const
unsigned
char
*
prefix
_
);
inline
void
set_prefix
(
const
unsigned
char
*
bytes
_
);
inline
void
set_first_bytes
(
const
unsigned
char
*
bytes_
);
inline
void
set_first_byte_at
(
size_t
index_
,
unsigned
char
byte_
);
inline
void
set_node_pointers
(
const
unsigned
char
*
pointers_
);
...
...
src/socket_poller.hpp
View file @
84267e73
...
...
@@ -78,7 +78,7 @@ class socket_poller_t
// Returns the signaler's fd if there is one, otherwise errors.
int
signaler_fd
(
fd_t
*
fd_
);
int
wait
(
event_t
*
event_
,
int
n_events_
,
long
timeout_
);
int
wait
(
event_t
*
event
s
_
,
int
n_events_
,
long
timeout_
);
inline
int
size
()
{
return
static_cast
<
int
>
(
_items
.
size
());
};
...
...
src/udp_address.hpp
View file @
84267e73
...
...
@@ -47,7 +47,7 @@ class udp_address_t
udp_address_t
();
virtual
~
udp_address_t
();
int
resolve
(
const
char
*
name_
,
bool
receiver
_
,
bool
ipv6_
);
int
resolve
(
const
char
*
name_
,
bool
bind
_
,
bool
ipv6_
);
// The opposite to resolve()
virtual
int
to_string
(
std
::
string
&
addr_
);
...
...
src/udp_engine.hpp
View file @
84267e73
...
...
@@ -46,7 +46,7 @@ class udp_engine_t : public io_object_t, public i_engine
const
endpoint_uri_pair_t
&
get_endpoint
()
const
;
private
:
int
resolve_raw_address
(
char
*
addr
_
,
size_t
length_
);
int
resolve_raw_address
(
char
*
name
_
,
size_t
length_
);
void
sockaddr_to_msg
(
zmq
::
msg_t
*
msg_
,
sockaddr_in
*
addr_
);
int
set_udp_reuse_address
(
fd_t
s_
,
bool
on_
);
...
...
src/ws_engine.cpp
View file @
84267e73
...
...
@@ -86,7 +86,7 @@ static int
encode_base64
(
const
unsigned
char
*
in_
,
int
in_len_
,
char
*
out_
,
int
out_len_
);
static
void
compute_accept_key
(
char
*
key_
,
unsigned
char
output
_
[
SHA_DIGEST_LENGTH
]);
unsigned
char
hash
_
[
SHA_DIGEST_LENGTH
]);
zmq
::
ws_engine_t
::
ws_engine_t
(
fd_t
fd_
,
const
options_t
&
options_
,
...
...
src/xpub.hpp
View file @
84267e73
...
...
@@ -71,7 +71,7 @@ class xpub_t : public socket_base_t
xpub_t
*
self_
);
// Function to be applied to each matching pipes.
static
void
mark_as_matching
(
zmq
::
pipe_t
*
pipe_
,
xpub_t
*
arg
_
);
static
void
mark_as_matching
(
zmq
::
pipe_t
*
pipe_
,
xpub_t
*
self
_
);
// List of all subscriptions mapped to corresponding pipes.
mtrie_t
_subscriptions
;
...
...
@@ -115,7 +115,7 @@ class xpub_t : public socket_base_t
bool
_send_last_pipe
;
// Function to be applied to match the last pipe.
static
void
mark_last_pipe_as_matching
(
zmq
::
pipe_t
*
pipe_
,
xpub_t
*
arg
_
);
static
void
mark_last_pipe_as_matching
(
zmq
::
pipe_t
*
pipe_
,
xpub_t
*
self
_
);
// Last pipe that sent subscription message, only used if xpub is on manual
pipe_t
*
_last_pipe
;
...
...
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