diff options
Diffstat (limited to 'src/util/service.c')
-rw-r--r-- | src/util/service.c | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/util/service.c b/src/util/service.c index b4eb33caa..1156093f4 100644 --- a/src/util/service.c +++ b/src/util/service.c | |||
@@ -1978,7 +1978,7 @@ do_send (void *cls) | |||
1978 | GNUNET_MQ_impl_send_in_flight (client->mq); | 1978 | GNUNET_MQ_impl_send_in_flight (client->mq); |
1979 | } | 1979 | } |
1980 | client->msg_pos += ret; | 1980 | client->msg_pos += ret; |
1981 | if (left > ret) | 1981 | if (left > (size_t) ret) |
1982 | { | 1982 | { |
1983 | GNUNET_assert (NULL == client->drop_task); | 1983 | GNUNET_assert (NULL == client->drop_task); |
1984 | client->send_task | 1984 | client->send_task |
@@ -2007,6 +2007,7 @@ service_mq_send (struct GNUNET_MQ_Handle *mq, | |||
2007 | { | 2007 | { |
2008 | struct GNUNET_SERVICE_Client *client = impl_state; | 2008 | struct GNUNET_SERVICE_Client *client = impl_state; |
2009 | 2009 | ||
2010 | (void) mq; | ||
2010 | if (NULL != client->drop_task) | 2011 | if (NULL != client->drop_task) |
2011 | return; /* we're going down right now, do not try to send */ | 2012 | return; /* we're going down right now, do not try to send */ |
2012 | GNUNET_assert (NULL == client->send_task); | 2013 | GNUNET_assert (NULL == client->send_task); |
@@ -2036,6 +2037,7 @@ service_mq_cancel (struct GNUNET_MQ_Handle *mq, | |||
2036 | { | 2037 | { |
2037 | struct GNUNET_SERVICE_Client *client = impl_state; | 2038 | struct GNUNET_SERVICE_Client *client = impl_state; |
2038 | 2039 | ||
2040 | (void) mq; | ||
2039 | GNUNET_assert (0 == client->msg_pos); | 2041 | GNUNET_assert (0 == client->msg_pos); |
2040 | client->msg = NULL; | 2042 | client->msg = NULL; |
2041 | GNUNET_SCHEDULER_cancel (client->send_task); | 2043 | GNUNET_SCHEDULER_cancel (client->send_task); |