diff options
| author | Bart Polot <bart.polot+voyager@gmail.com> | 2017-01-31 05:06:36 +0100 |
|---|---|---|
| committer | Bart Polot <bart.polot+voyager@gmail.com> | 2017-01-31 05:08:53 +0100 |
| commit | 0e73a014339a41d6385f7049dea33a0e47bbe66c (patch) | |
| tree | 5de006f5b8cc0cfe73076a10914f461b27ab5bb2 /src/cadet/cadet_api.c | |
| parent | 9112c6ee1b16a1aea0d7e3ed96ad8587ee64f86f (diff) | |
Implement incoming traffic handling on MQ
Diffstat (limited to 'src/cadet/cadet_api.c')
| -rw-r--r-- | src/cadet/cadet_api.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/cadet/cadet_api.c b/src/cadet/cadet_api.c index a1c7e8461c..7640a924a1 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, |