aboutsummaryrefslogtreecommitdiff
path: root/src/util/service.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/util/service.c')
-rw-r--r--src/util/service.c4
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);