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
7b7d4042
Commit
7b7d4042
authored
Feb 10, 2012
by
niXman
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix warn unused
parent
40052c12
Hide whitespace changes
Inline
Side-by-side
Showing
22 changed files
with
48 additions
and
2 deletions
+48
-2
blob.hpp
src/blob.hpp
+3
-2
ctx.cpp
src/ctx.cpp
+1
-0
dist.cpp
src/dist.cpp
+1
-0
err.cpp
src/err.cpp
+1
-0
fq.cpp
src/fq.cpp
+1
-0
io_object.cpp
src/io_object.cpp
+2
-0
io_thread.cpp
src/io_thread.cpp
+1
-0
lb.cpp
src/lb.cpp
+1
-0
object.cpp
src/object.cpp
+8
-0
pair.cpp
src/pair.cpp
+4
-0
pipe.cpp
src/pipe.cpp
+1
-0
pub.cpp
src/pub.cpp
+2
-0
pull.cpp
src/pull.cpp
+1
-0
push.cpp
src/push.cpp
+1
-0
reaper.cpp
src/reaper.cpp
+1
-0
session_base.cpp
src/session_base.cpp
+1
-0
socket_base.cpp
src/socket_base.cpp
+11
-0
sub.cpp
src/sub.cpp
+2
-0
xpub.cpp
src/xpub.cpp
+1
-0
xrep.cpp
src/xrep.cpp
+2
-0
xreq.cpp
src/xreq.cpp
+1
-0
xsub.cpp
src/xsub.cpp
+1
-0
No files found.
src/blob.hpp
View file @
7b7d4042
...
...
@@ -96,10 +96,11 @@ namespace std
static
char_type
to_char_type
(
const
int_type
&
__c
)
{
return
char_type
();
}
{
((
void
)
__c
);
return
char_type
();
}
static
int_type
to_int_type
(
const
char_type
&
__c
)
{
return
int_type
();
}
to_int_type
(
const
char_type
&
__c
)
{
((
void
)
__c
);
return
int_type
();
}
static
bool
eq_int_type
(
const
int_type
&
__c1
,
const
int_type
&
__c2
)
...
...
src/ctx.cpp
View file @
7b7d4042
...
...
@@ -315,6 +315,7 @@ zmq::endpoint_t zmq::ctx_t::find_endpoint (const char *addr_)
void
zmq
::
ctx_t
::
log
(
const
char
*
format_
,
va_list
args_
)
{
((
void
)
args_
);
// Create the log message.
msg_t
msg
;
int
rc
=
msg
.
init_size
(
strlen
(
format_
)
+
1
);
...
...
src/dist.cpp
View file @
7b7d4042
...
...
@@ -128,6 +128,7 @@ int zmq::dist_t::send_to_matching (msg_t *msg_, int flags_)
void
zmq
::
dist_t
::
distribute
(
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
flags_
);
// If there are no matching pipes available, simply drop the message.
if
(
matching
==
0
)
{
int
rc
=
msg_
->
close
();
...
...
src/err.cpp
View file @
7b7d4042
...
...
@@ -65,6 +65,7 @@ const char *zmq::errno_to_string (int errno_)
void
zmq
::
zmq_abort
(
const
char
*
errmsg_
)
{
((
void
)
errmsg_
);
#if defined ZMQ_HAVE_WINDOWS
// Raise STATUS_FATAL_APP_EXIT.
...
...
src/fq.cpp
View file @
7b7d4042
...
...
@@ -70,6 +70,7 @@ int zmq::fq_t::recv (msg_t *msg_, int flags_)
int
zmq
::
fq_t
::
recvpipe
(
msg_t
*
msg_
,
int
flags_
,
pipe_t
**
pipe_
)
{
((
void
)
flags_
);
// Deallocate old content of the message.
int
rc
=
msg_
->
close
();
errno_assert
(
rc
==
0
);
...
...
src/io_object.cpp
View file @
7b7d4042
...
...
@@ -89,6 +89,7 @@ void zmq::io_object_t::add_timer (int timeout_, int id_)
void
zmq
::
io_object_t
::
cancel_timer
(
int
id_
)
{
((
void
)
id_
);
poller
->
cancel_timer
(
this
,
id_
);
}
...
...
@@ -104,5 +105,6 @@ void zmq::io_object_t::out_event ()
void
zmq
::
io_object_t
::
timer_event
(
int
id_
)
{
((
void
)
id_
);
zmq_assert
(
false
);
}
src/io_thread.cpp
View file @
7b7d4042
...
...
@@ -91,6 +91,7 @@ void zmq::io_thread_t::out_event ()
void
zmq
::
io_thread_t
::
timer_event
(
int
id_
)
{
((
void
)
id_
);
// No timers here. This function is never called.
zmq_assert
(
false
);
}
...
...
src/lb.cpp
View file @
7b7d4042
...
...
@@ -73,6 +73,7 @@ void zmq::lb_t::activated (pipe_t *pipe_)
int
zmq
::
lb_t
::
send
(
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
flags_
);
// Drop the message if required. If we are at the end of the message
// switch back to non-dropping mode.
if
(
dropping
)
{
...
...
src/object.cpp
View file @
7b7d4042
...
...
@@ -374,16 +374,19 @@ void zmq::object_t::process_plug ()
void
zmq
::
object_t
::
process_own
(
own_t
*
object_
)
{
((
void
)
object_
);
zmq_assert
(
false
);
}
void
zmq
::
object_t
::
process_attach
(
i_engine
*
engine_
)
{
((
void
)
engine_
);
zmq_assert
(
false
);
}
void
zmq
::
object_t
::
process_bind
(
pipe_t
*
pipe_
)
{
((
void
)
pipe_
);
zmq_assert
(
false
);
}
...
...
@@ -394,11 +397,13 @@ void zmq::object_t::process_activate_read ()
void
zmq
::
object_t
::
process_activate_write
(
uint64_t
msgs_read_
)
{
((
void
)
msgs_read_
);
zmq_assert
(
false
);
}
void
zmq
::
object_t
::
process_hiccup
(
void
*
pipe_
)
{
((
void
)
pipe_
);
zmq_assert
(
false
);
}
...
...
@@ -414,11 +419,13 @@ void zmq::object_t::process_pipe_term_ack ()
void
zmq
::
object_t
::
process_term_req
(
own_t
*
object_
)
{
((
void
)
object_
);
zmq_assert
(
false
);
}
void
zmq
::
object_t
::
process_term
(
int
linger_
)
{
((
void
)
linger_
);
zmq_assert
(
false
);
}
...
...
@@ -429,6 +436,7 @@ void zmq::object_t::process_term_ack ()
void
zmq
::
object_t
::
process_reap
(
class
socket_base_t
*
socket_
)
{
((
void
)
socket_
);
zmq_assert
(
false
);
}
...
...
src/pair.cpp
View file @
7b7d4042
...
...
@@ -38,6 +38,7 @@ zmq::pair_t::~pair_t ()
void
zmq
::
pair_t
::
xattach_pipe
(
pipe_t
*
pipe_
,
bool
icanhasall_
)
{
((
void
)
icanhasall_
);
zmq_assert
(
!
pipe
);
pipe
=
pipe_
;
}
...
...
@@ -50,12 +51,14 @@ void zmq::pair_t::xterminated (pipe_t *pipe_)
void
zmq
::
pair_t
::
xread_activated
(
pipe_t
*
pipe_
)
{
((
void
)
pipe_
);
// There's just one pipe. No lists of active and inactive pipes.
// There's nothing to do here.
}
void
zmq
::
pair_t
::
xwrite_activated
(
pipe_t
*
pipe_
)
{
((
void
)
pipe_
);
// There's just one pipe. No lists of active and inactive pipes.
// There's nothing to do here.
}
...
...
@@ -79,6 +82,7 @@ int zmq::pair_t::xsend (msg_t *msg_, int flags_)
int
zmq
::
pair_t
::
xrecv
(
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
flags_
);
// Deallocate old content of the message.
int
rc
=
msg_
->
close
();
errno_assert
(
rc
==
0
);
...
...
src/pipe.cpp
View file @
7b7d4042
...
...
@@ -148,6 +148,7 @@ bool zmq::pipe_t::read (msg_t *msg_)
bool
zmq
::
pipe_t
::
check_write
(
msg_t
*
msg_
)
{
((
void
)
msg_
);
if
(
unlikely
(
!
out_active
||
state
!=
active
))
return
false
;
...
...
src/pub.cpp
View file @
7b7d4042
...
...
@@ -34,6 +34,8 @@ zmq::pub_t::~pub_t ()
int
zmq
::
pub_t
::
xrecv
(
class
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
msg_
);
((
void
)
flags_
);
// Messages cannot be received from PUB socket.
errno
=
ENOTSUP
;
return
-
1
;
...
...
src/pull.cpp
View file @
7b7d4042
...
...
@@ -36,6 +36,7 @@ zmq::pull_t::~pull_t ()
void
zmq
::
pull_t
::
xattach_pipe
(
pipe_t
*
pipe_
,
bool
icanhasall_
)
{
((
void
)
icanhasall_
);
zmq_assert
(
pipe_
);
fq
.
attach
(
pipe_
);
}
...
...
src/push.cpp
View file @
7b7d4042
...
...
@@ -36,6 +36,7 @@ zmq::push_t::~push_t ()
void
zmq
::
push_t
::
xattach_pipe
(
pipe_t
*
pipe_
,
bool
icanhasall_
)
{
((
void
)
icanhasall_
);
zmq_assert
(
pipe_
);
lb
.
attach
(
pipe_
);
}
...
...
src/reaper.cpp
View file @
7b7d4042
...
...
@@ -80,6 +80,7 @@ void zmq::reaper_t::out_event ()
void
zmq
::
reaper_t
::
timer_event
(
int
id_
)
{
((
void
)
id_
);
zmq_assert
(
false
);
}
...
...
src/session_base.cpp
View file @
7b7d4042
...
...
@@ -248,6 +248,7 @@ void zmq::session_base_t::write_activated (pipe_t *pipe_)
void
zmq
::
session_base_t
::
hiccuped
(
pipe_t
*
pipe_
)
{
((
void
)
pipe_
);
// Hiccups are always sent from session to socket, not the other
// way round.
zmq_assert
(
false
);
...
...
src/socket_base.cpp
View file @
7b7d4042
...
...
@@ -758,6 +758,9 @@ void zmq::socket_base_t::process_destroy ()
int
zmq
::
socket_base_t
::
xsetsockopt
(
int
option_
,
const
void
*
optval_
,
size_t
optvallen_
)
{
((
void
)
option_
);
((
void
)
optval_
);
((
void
)
optvallen_
);
errno
=
EINVAL
;
return
-
1
;
}
...
...
@@ -769,6 +772,8 @@ bool zmq::socket_base_t::xhas_out ()
int
zmq
::
socket_base_t
::
xsend
(
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
msg_
);
((
void
)
flags_
);
errno
=
ENOTSUP
;
return
-
1
;
}
...
...
@@ -780,21 +785,26 @@ bool zmq::socket_base_t::xhas_in ()
int
zmq
::
socket_base_t
::
xrecv
(
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
msg_
);
((
void
)
flags_
);
errno
=
ENOTSUP
;
return
-
1
;
}
void
zmq
::
socket_base_t
::
xread_activated
(
pipe_t
*
pipe_
)
{
((
void
)
pipe_
);
zmq_assert
(
false
);
}
void
zmq
::
socket_base_t
::
xwrite_activated
(
pipe_t
*
pipe_
)
{
((
void
)
pipe_
);
zmq_assert
(
false
);
}
void
zmq
::
socket_base_t
::
xhiccuped
(
pipe_t
*
pipe_
)
{
((
void
)
pipe_
);
zmq_assert
(
false
);
}
...
...
@@ -815,6 +825,7 @@ void zmq::socket_base_t::out_event ()
void
zmq
::
socket_base_t
::
timer_event
(
int
id_
)
{
((
void
)
id_
);
zmq_assert
(
false
);
}
...
...
src/sub.cpp
View file @
7b7d4042
...
...
@@ -69,6 +69,8 @@ int zmq::sub_t::xsetsockopt (int option_, const void *optval_,
int
zmq
::
sub_t
::
xsend
(
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
msg_
);
((
void
)
flags_
);
// Overload the XSUB's send.
errno
=
ENOTSUP
;
return
-
1
;
...
...
src/xpub.cpp
View file @
7b7d4042
...
...
@@ -136,6 +136,7 @@ bool zmq::xpub_t::xhas_out ()
int
zmq
::
xpub_t
::
xrecv
(
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
flags_
);
// If there is at least one
if
(
pending
.
empty
())
{
errno
=
EAGAIN
;
...
...
src/xrep.cpp
View file @
7b7d4042
...
...
@@ -57,6 +57,7 @@ zmq::xrep_t::~xrep_t ()
void
zmq
::
xrep_t
::
xattach_pipe
(
pipe_t
*
pipe_
,
bool
icanhasall_
)
{
((
void
)
icanhasall_
);
zmq_assert
(
pipe_
);
// Generate a new unique peer identity.
...
...
@@ -113,6 +114,7 @@ void zmq::xrep_t::xwrite_activated (pipe_t *pipe_)
int
zmq
::
xrep_t
::
xsend
(
msg_t
*
msg_
,
int
flags_
)
{
((
void
)
flags_
);
// If this is the first part of the message it's the ID of the
// peer to send the message to.
if
(
!
more_out
)
{
...
...
src/xreq.cpp
View file @
7b7d4042
...
...
@@ -48,6 +48,7 @@ zmq::xreq_t::~xreq_t ()
void
zmq
::
xreq_t
::
xattach_pipe
(
pipe_t
*
pipe_
,
bool
icanhasall_
)
{
((
void
)
icanhasall_
);
zmq_assert
(
pipe_
);
fq
.
attach
(
pipe_
);
lb
.
attach
(
pipe_
);
...
...
src/xsub.cpp
View file @
7b7d4042
...
...
@@ -47,6 +47,7 @@ zmq::xsub_t::~xsub_t ()
void
zmq
::
xsub_t
::
xattach_pipe
(
pipe_t
*
pipe_
,
bool
icanhasall_
)
{
((
void
)
icanhasall_
);
zmq_assert
(
pipe_
);
fq
.
attach
(
pipe_
);
dist
.
attach
(
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