aboutsummaryrefslogtreecommitdiff
path: root/src/util/test_mq_client.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/util/test_mq_client.c')
-rw-r--r--src/util/test_mq_client.c12
1 files changed, 11 insertions, 1 deletions
diff --git a/src/util/test_mq_client.c b/src/util/test_mq_client.c
index 1c1bcee86..88113ffd0 100644
--- a/src/util/test_mq_client.c
+++ b/src/util/test_mq_client.c
@@ -102,6 +102,12 @@ send_cb (void *cls)
102 notify = GNUNET_YES; 102 notify = GNUNET_YES;
103} 103}
104 104
105static void
106send_trap_cb (void *cls)
107{
108 GNUNET_abort ();
109}
110
105 111
106static void 112static void
107test_mq (struct GNUNET_CLIENT_Connection *client) 113test_mq (struct GNUNET_CLIENT_Connection *client)
@@ -116,10 +122,14 @@ test_mq (struct GNUNET_CLIENT_Connection *client)
116 GNUNET_MQ_send (mq, mqm); 122 GNUNET_MQ_send (mq, mqm);
117 123
118 mqm = GNUNET_MQ_msg_header (MY_TYPE); 124 mqm = GNUNET_MQ_msg_header (MY_TYPE);
125 GNUNET_MQ_notify_sent (mqm, send_trap_cb, NULL);
126 GNUNET_MQ_send (mq, mqm);
127 GNUNET_MQ_send_cancel (mqm);
128
129 mqm = GNUNET_MQ_msg_header (MY_TYPE);
119 GNUNET_MQ_notify_sent (mqm, send_cb, NULL); 130 GNUNET_MQ_notify_sent (mqm, send_cb, NULL);
120 GNUNET_MQ_send (mq, mqm); 131 GNUNET_MQ_send (mq, mqm);
121 132
122 /* FIXME: add a message that will be canceled */
123} 133}
124 134
125 135