aboutsummaryrefslogtreecommitdiff
path: root/src/core
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2017-01-09 08:32:21 +0100
committerChristian Grothoff <christian@grothoff.org>2017-01-09 21:17:25 +0100
commitfa960b4f0d98235888fbaf5edfca2858ee102a34 (patch)
tree193874d645e05ed9a92595fb206f8df738b8c8ad /src/core
parent2024b175d543b5a36dab4e5a616a11e5ab284d29 (diff)
downloadgnunet-fa960b4f0d98235888fbaf5edfca2858ee102a34.tar.gz
gnunet-fa960b4f0d98235888fbaf5edfca2858ee102a34.zip
handle transmissions initiated during disconnect callbacks by dropping
Diffstat (limited to 'src/core')
-rw-r--r--src/core/core_api_2.c6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/core/core_api_2.c b/src/core/core_api_2.c
index d810bf2ec..7826cd03e 100644
--- a/src/core/core_api_2.c
+++ b/src/core/core_api_2.c
@@ -299,6 +299,12 @@ core_mq_send_impl (struct GNUNET_MQ_Handle *mq,
299 int cork; 299 int cork;
300 enum GNUNET_CORE_Priority priority; 300 enum GNUNET_CORE_Priority priority;
301 301
302 if (NULL == h->mq)
303 {
304 /* We're currently reconnecting, pretend this worked */
305 GNUNET_MQ_impl_send_continue (mq);
306 return;
307 }
302 GNUNET_assert (NULL == pr->env); 308 GNUNET_assert (NULL == pr->env);
303 /* extract options from envelope */ 309 /* extract options from envelope */
304 env = GNUNET_MQ_get_current_envelope (mq); 310 env = GNUNET_MQ_get_current_envelope (mq);