diff options
Diffstat (limited to 'src/util/test_mq_client.c')
-rw-r--r-- | src/util/test_mq_client.c | 12 |
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 | ||
105 | static void | ||
106 | send_trap_cb (void *cls) | ||
107 | { | ||
108 | GNUNET_abort (); | ||
109 | } | ||
110 | |||
105 | 111 | ||
106 | static void | 112 | static void |
107 | test_mq (struct GNUNET_CLIENT_Connection *client) | 113 | test_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 | ||