diff options
Diffstat (limited to 'src/transport/gnunet-service-transport_neighbours.c')
-rw-r--r-- | src/transport/gnunet-service-transport_neighbours.c | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c index 3bddbe013..ca7eb7b08 100644 --- a/src/transport/gnunet-service-transport_neighbours.c +++ b/src/transport/gnunet-service-transport_neighbours.c | |||
@@ -632,6 +632,7 @@ send_with_plugin (const struct GNUNET_PeerIdentity *target, const char *msgbuf, | |||
632 | return ret; | 632 | return ret; |
633 | } | 633 | } |
634 | 634 | ||
635 | |||
635 | /** | 636 | /** |
636 | * Task invoked to start a transmission to another peer. | 637 | * Task invoked to start a transmission to another peer. |
637 | * | 638 | * |
@@ -654,13 +655,11 @@ transmit_send_continuation (void *cls, | |||
654 | const struct GNUNET_PeerIdentity *receiver, | 655 | const struct GNUNET_PeerIdentity *receiver, |
655 | int success) | 656 | int success) |
656 | { | 657 | { |
657 | struct MessageQueue *mq; | 658 | struct MessageQueue *mq = cls; |
658 | struct NeighbourMapEntry *n; | 659 | struct NeighbourMapEntry *n; |
659 | struct NeighbourMapEntry *tmp; | 660 | struct NeighbourMapEntry *tmp; |
660 | 661 | ||
661 | tmp = lookup_neighbour (receiver); | 662 | tmp = lookup_neighbour (receiver); |
662 | |||
663 | mq = cls; | ||
664 | n = mq->n; | 663 | n = mq->n; |
665 | if ((NULL != n) && (tmp != NULL) && (tmp == n)) | 664 | if ((NULL != n) && (tmp != NULL) && (tmp == n)) |
666 | { | 665 | { |
@@ -721,8 +720,11 @@ try_transmission_to_peer (struct NeighbourMapEntry *n) | |||
721 | 720 | ||
722 | if (n->address == NULL) | 721 | if (n->address == NULL) |
723 | { | 722 | { |
723 | #if DEBUG_TRANSPORT | ||
724 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "No address for peer `%s'\n", | 724 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "No address for peer `%s'\n", |
725 | GNUNET_i2s (&n->id)); | 725 | GNUNET_i2s (&n->id)); |
726 | #endif | ||
727 | GNUNET_CONTAINER_DLL_remove (n->messages_head, n->messages_tail, mq); | ||
726 | transmit_send_continuation (mq, &n->id, GNUNET_SYSERR); | 728 | transmit_send_continuation (mq, &n->id, GNUNET_SYSERR); |
727 | GNUNET_assert (n->transmission_task == GNUNET_SCHEDULER_NO_TASK); | 729 | GNUNET_assert (n->transmission_task == GNUNET_SCHEDULER_NO_TASK); |
728 | n->transmission_task = GNUNET_SCHEDULER_add_now (&transmission_task, n); | 730 | n->transmission_task = GNUNET_SCHEDULER_add_now (&transmission_task, n); |