diff options
Diffstat (limited to 'src/util/mq.c')
-rw-r--r-- | src/util/mq.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/util/mq.c b/src/util/mq.c index 733329a2c..c4f9e0d0b 100644 --- a/src/util/mq.c +++ b/src/util/mq.c | |||
@@ -192,7 +192,7 @@ GNUNET_MQ_inject_message (struct GNUNET_MQ_Handle *mq, const struct GNUNET_Messa | |||
192 | handled = GNUNET_YES; | 192 | handled = GNUNET_YES; |
193 | } | 193 | } |
194 | } | 194 | } |
195 | 195 | ||
196 | if (GNUNET_NO == handled) | 196 | if (GNUNET_NO == handled) |
197 | LOG (GNUNET_ERROR_TYPE_WARNING, "no handler for message of type %d\n", ntohs (mh->type)); | 197 | LOG (GNUNET_ERROR_TYPE_WARNING, "no handler for message of type %d\n", ntohs (mh->type)); |
198 | } | 198 | } |
@@ -233,7 +233,7 @@ GNUNET_MQ_discard (struct GNUNET_MQ_Envelope *mqm) | |||
233 | /** | 233 | /** |
234 | * Send a message with the give message queue. | 234 | * Send a message with the give message queue. |
235 | * May only be called once per message. | 235 | * May only be called once per message. |
236 | * | 236 | * |
237 | * @param mq message queue | 237 | * @param mq message queue |
238 | * @param ev the envelope with the message to send. | 238 | * @param ev the envelope with the message to send. |
239 | */ | 239 | */ |
@@ -242,7 +242,7 @@ GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq, struct GNUNET_MQ_Envelope *ev) | |||
242 | { | 242 | { |
243 | GNUNET_assert (NULL != mq); | 243 | GNUNET_assert (NULL != mq); |
244 | GNUNET_assert (NULL == ev->parent_queue); | 244 | GNUNET_assert (NULL == ev->parent_queue); |
245 | 245 | ||
246 | /* is the implementation busy? queue it! */ | 246 | /* is the implementation busy? queue it! */ |
247 | if (NULL != mq->current_envelope) | 247 | if (NULL != mq->current_envelope) |
248 | { | 248 | { |
@@ -465,7 +465,7 @@ server_client_destroy_impl (struct GNUNET_MQ_Handle *mq, | |||
465 | void *impl_state) | 465 | void *impl_state) |
466 | { | 466 | { |
467 | struct ServerClientSocketState *state = impl_state; | 467 | struct ServerClientSocketState *state = impl_state; |
468 | 468 | ||
469 | GNUNET_assert (NULL != mq); | 469 | GNUNET_assert (NULL != mq); |
470 | GNUNET_assert (NULL != state); | 470 | GNUNET_assert (NULL != state); |
471 | GNUNET_SERVER_client_drop (state->client); | 471 | GNUNET_SERVER_client_drop (state->client); |
@@ -483,7 +483,7 @@ server_client_send_impl (struct GNUNET_MQ_Handle *mq, | |||
483 | 483 | ||
484 | GNUNET_MQ_impl_send_commit (mq); | 484 | GNUNET_MQ_impl_send_commit (mq); |
485 | 485 | ||
486 | state->th = | 486 | state->th = |
487 | GNUNET_SERVER_notify_transmit_ready (state->client, ntohs (msg->size), | 487 | GNUNET_SERVER_notify_transmit_ready (state->client, ntohs (msg->size), |
488 | GNUNET_TIME_UNIT_FOREVER_REL, | 488 | GNUNET_TIME_UNIT_FOREVER_REL, |
489 | &transmit_queued, mq); | 489 | &transmit_queued, mq); |
@@ -522,7 +522,7 @@ handle_client_message (void *cls, | |||
522 | struct ClientConnectionState *state; | 522 | struct ClientConnectionState *state; |
523 | 523 | ||
524 | state = mq->impl_state; | 524 | state = mq->impl_state; |
525 | 525 | ||
526 | if (NULL == msg) | 526 | if (NULL == msg) |
527 | { | 527 | { |
528 | GNUNET_MQ_inject_error (mq, GNUNET_MQ_ERROR_READ); | 528 | GNUNET_MQ_inject_error (mq, GNUNET_MQ_ERROR_READ); |
@@ -600,8 +600,8 @@ connection_client_send_impl (struct GNUNET_MQ_Handle *mq, | |||
600 | 600 | ||
601 | GNUNET_MQ_impl_send_commit (mq); | 601 | GNUNET_MQ_impl_send_commit (mq); |
602 | 602 | ||
603 | state->th = | 603 | state->th = |
604 | GNUNET_CLIENT_notify_transmit_ready (state->connection, ntohs (msg->size), | 604 | GNUNET_CLIENT_notify_transmit_ready (state->connection, ntohs (msg->size), |
605 | GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_NO, | 605 | GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_NO, |
606 | &connection_client_transmit_queued, mq); | 606 | &connection_client_transmit_queued, mq); |
607 | } | 607 | } |