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
00aeaddf
Commit
00aeaddf
authored
Jan 18, 2014
by
Matt Arsenault
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Fix unused parameter and variable warnings.
parent
5a230f7d
Hide whitespace changes
Inline
Side-by-side
Showing
11 changed files
with
16 additions
and
18 deletions
+16
-18
mechanism.cpp
src/mechanism.cpp
+2
-2
mechanism.hpp
src/mechanism.hpp
+2
-2
stream.cpp
src/stream.cpp
+1
-4
stream_engine.cpp
src/stream_engine.cpp
+1
-1
ypipe_conflate.hpp
src/ypipe_conflate.hpp
+1
-1
zmq_utils.cpp
src/zmq_utils.cpp
+3
-2
test_conflate.cpp
tests/test_conflate.cpp
+1
-1
test_disconnect_inproc.cpp
tests/test_disconnect_inproc.cpp
+1
-1
test_hwm.cpp
tests/test_hwm.cpp
+1
-1
test_stream.cpp
tests/test_stream.cpp
+2
-2
test_stream_disconnect_notifications.cpp
tests/test_stream_disconnect_notifications.cpp
+1
-1
No files found.
src/mechanism.cpp
View file @
00aeaddf
...
...
@@ -133,8 +133,8 @@ int zmq::mechanism_t::parse_metadata (const unsigned char *ptr_,
return
0
;
}
int
zmq
::
mechanism_t
::
property
(
const
std
::
string
name_
,
const
void
*
value_
,
size_t
length_
)
int
zmq
::
mechanism_t
::
property
(
const
std
::
string
/* name_ */
,
const
void
*
/* value_ */
,
size_t
/* length_ */
)
{
// Default implementation does not check
// property values and returns 0 to signal success.
...
...
src/mechanism.hpp
View file @
00aeaddf
...
...
@@ -46,9 +46,9 @@ namespace zmq
// Process the handshake command received from the peer.
virtual
int
process_handshake_command
(
msg_t
*
msg_
)
=
0
;
virtual
int
encode
(
msg_t
*
msg_
)
{
return
0
;
}
virtual
int
encode
(
msg_t
*
)
{
return
0
;
}
virtual
int
decode
(
msg_t
*
msg_
)
{
return
0
;
}
virtual
int
decode
(
msg_t
*
)
{
return
0
;
}
// Notifies mechanism about availability of ZAP message.
virtual
int
zap_msg_available
()
{
return
0
;
}
...
...
src/stream.cpp
View file @
00aeaddf
...
...
@@ -166,9 +166,6 @@ int zmq::stream_t::xsend (msg_t *msg_)
int
zmq
::
stream_t
::
xsetsockopt
(
int
option_
,
const
void
*
optval_
,
size_t
optvallen_
)
{
bool
is_int
=
(
optvallen_
==
sizeof
(
int
));
int
value
=
is_int
?
*
((
int
*
)
optval_
)
:
0
;
switch
(
option_
)
{
case
ZMQ_NEXT_IDENTITY
:
if
(
optval_
&&
optvallen_
)
{
...
...
@@ -268,7 +265,7 @@ void zmq::stream_t::identify_peer (pipe_t *pipe_)
next_identity
.
length
());
next_identity
.
clear
();
}
else
{
else
{
put_uint32
(
buffer
+
1
,
next_peer_id
++
);
blob_t
identity
=
blob_t
(
buffer
,
sizeof
buffer
);
memcpy
(
options
.
identity
,
identity
.
data
(),
identity
.
size
());
...
...
src/stream_engine.cpp
View file @
00aeaddf
...
...
@@ -182,7 +182,7 @@ void zmq::stream_engine_t::plug (io_thread_t *io_thread_,
// application so that it knows a peer has connected.
msg_t
connector
;
connector
.
init
();
int
rc
=
(
this
->*
write_msg
)
(
&
connector
);
(
this
->*
write_msg
)
(
&
connector
);
connector
.
close
();
session
->
flush
();
}
...
...
src/ypipe_conflate.hpp
View file @
00aeaddf
...
...
@@ -70,7 +70,7 @@ namespace zmq
#endif
// There are no incomplete items for conflate ypipe
inline
bool
unwrite
(
T
*
value_
)
inline
bool
unwrite
(
T
*
)
{
return
false
;
}
...
...
src/zmq_utils.cpp
View file @
00aeaddf
...
...
@@ -188,12 +188,13 @@ int zmq_curve_keypair (char *z85_public_key, char *z85_secret_key)
// Is there a sensible errno to set here?
if
(
rc
)
return
rc
;
zmq_z85_encode
(
z85_public_key
,
public_key
,
32
);
zmq_z85_encode
(
z85_secret_key
,
secret_key
,
32
);
return
0
;
#else // requires libsodium
(
void
)
z85_public_key
,
(
void
)
z85_secret_key
;
errno
=
ENOTSUP
;
return
-
1
;
#endif
...
...
tests/test_conflate.cpp
View file @
00aeaddf
...
...
@@ -19,7 +19,7 @@
#include "testutil.hpp"
int
main
(
int
argc
,
char
*
argv
[])
int
main
(
int
,
char
*
[])
{
const
char
*
bind_to
=
"tcp://127.0.0.1:5555"
;
...
...
tests/test_disconnect_inproc.cpp
View file @
00aeaddf
...
...
@@ -28,7 +28,7 @@ memcpy(zmq_msg_data(&msg), data, size + 1);
int
publicationsReceived
=
0
;
bool
isSubscribed
=
false
;
int
main
(
int
argc
,
char
**
argv
)
{
int
main
(
int
,
char
**
)
{
setup_test_environment
();
void
*
context
=
zmq_ctx_new
();
void
*
pubSocket
;
...
...
tests/test_hwm.cpp
View file @
00aeaddf
...
...
@@ -202,7 +202,7 @@ int test_inproc_connect_and_close_first (int send_hwm, int recv_hwm)
return
send_count
;
}
int
test_inproc_bind_and_close_first
(
int
send_hwm
,
int
recv_hwm
)
int
test_inproc_bind_and_close_first
(
int
send_hwm
,
int
/* recv_hwm */
)
{
void
*
ctx
=
zmq_ctx_new
();
assert
(
ctx
);
...
...
tests/test_stream.cpp
View file @
00aeaddf
...
...
@@ -36,10 +36,10 @@ typedef struct {
// 8-byte size is set to 1 for backwards compatibility
static
zmtp_greeting_t
greeting
=
{
{
0xFF
,
0
,
0
,
0
,
0
,
0
,
0
,
0
,
1
,
0x7F
},
{
3
,
0
},
{
'N'
,
'U'
,
'L'
,
'L'
}
};
=
{
{
0xFF
,
0
,
0
,
0
,
0
,
0
,
0
,
0
,
1
,
0x7F
},
{
3
,
0
},
{
'N'
,
'U'
,
'L'
,
'L'
},
0
,
{
0
}
};
static
void
test_stream_to_dealer
(
void
)
test_stream_to_dealer
(
void
)
{
int
rc
;
...
...
tests/test_stream_disconnect_notifications.cpp
View file @
00aeaddf
...
...
@@ -52,7 +52,7 @@ bool get_identity (void* socket, char* data, size_t* size)
return
rc
==
0
;
}
int
main
(
int
argc
,
char
**
argv
)
int
main
(
int
,
char
**
)
{
setup_test_environment
();
...
...
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