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