aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/util/mq.c7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/util/mq.c b/src/util/mq.c
index 985e86331..d12f69e5f 100644
--- a/src/util/mq.c
+++ b/src/util/mq.c
@@ -811,12 +811,13 @@ GNUNET_MQ_assoc_remove (struct GNUNET_MQ_Handle *mq,
811 * @param cb_cls closure for the callback 811 * @param cb_cls closure for the callback
812 */ 812 */
813void 813void
814GNUNET_MQ_notify_sent (struct GNUNET_MQ_Envelope *mqm, 814GNUNET_MQ_notify_sent (struct GNUNET_MQ_Envelope *ev,
815 GNUNET_SCHEDULER_TaskCallback cb, 815 GNUNET_SCHEDULER_TaskCallback cb,
816 void *cb_cls) 816 void *cb_cls)
817{ 817{
818 mqm->sent_cb = cb; 818 GNUNET_assert (NULL == ev->sent_cb);
819 mqm->sent_cls = cb_cls; 819 ev->sent_cb = cb;
820 ev->sent_cls = cb_cls;
820} 821}
821 822
822 823