diff options
Diffstat (limited to 'src/transport/gnunet-service-tng.c')
| -rw-r--r-- | src/transport/gnunet-service-tng.c | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/transport/gnunet-service-tng.c b/src/transport/gnunet-service-tng.c index c30d2dd19..f030944bb 100644 --- a/src/transport/gnunet-service-tng.c +++ b/src/transport/gnunet-service-tng.c @@ -10899,6 +10899,7 @@ handle_add_queue_message (void *cls, struct TransportClient *tc = cls; struct Queue *queue; struct Neighbour *neighbour; + struct GNUNET_TIME_Absolute validated_until = GNUNET_TIME_UNIT_ZERO_ABS; const char *addr; uint16_t addr_len; @@ -10915,6 +10916,7 @@ handle_add_queue_message (void *cls, NULL != queue; queue = queue->next_client) { + validated_until = queue->validated_until; if (queue->qid != ntohl (aqm->qid)) continue; break; @@ -10956,6 +10958,13 @@ handle_add_queue_message (void *cls, ntohl (aqm->mtu)); queue = GNUNET_malloc (sizeof(struct Queue) + addr_len); queue->tc = tc; + if (GNUNET_TIME_UNIT_ZERO_ABS.abs_value_us != validated_until.abs_value_us) + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "New queue with QID %lu inherit validated until\n", + ntohl (aqm->qid)); + queue->validated_until = validated_until; + } queue->address = (const char *) &queue[1]; queue->pd.aged_rtt = GNUNET_TIME_UNIT_FOREVER_REL; queue->qid = ntohl (aqm->qid); |