From: Bart Polot <bart.polot+voyager@gmail.com>
Date: Tue, 31 Jan 2017 04:06:36 +0000 (+0100)
Subject: Implement incoming traffic handling on MQ
X-Git-Tag: taler-0.2.1~227
X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=0e73a014339a41d6385f7049dea33a0e47bbe66c;p=oweals%2Fgnunet.git

Implement incoming traffic handling on MQ
---

diff --git a/src/cadet/cadet_api.c b/src/cadet/cadet_api.c
index a1c7e8461..7640a924a 100644
--- a/src/cadet/cadet_api.c
+++ b/src/cadet/cadet_api.c
@@ -975,6 +975,12 @@ handle_local_data (void *cls,
        ntohl (message->ccn.channel_of_client),
        GC_m2s (type),
        type);
+  if (NULL != ch->mq)
+  {
+    GNUNET_MQ_inject_message (ch->mq, payload);
+    return;
+  }
+  /** @a deprecated */
   for (unsigned i=0;i<h->n_handlers;i++)
   {
     handler = &h->message_handlers[i];
@@ -1006,6 +1012,8 @@ handle_local_data (void *cls,
  *
  * @param h Cadet handle.
  * @param message Message itself.
+ *
+ * FIXME either delete or port to MQ
  */
 static void
 handle_local_ack (void *cls,