aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-12-19 16:31:33 +0000
committerChristian Grothoff <christian@grothoff.org>2011-12-19 16:31:33 +0000
commit2088429445cccbb5b5ac8d696e5544853bb60396 (patch)
tree3eb05d297d461d01aaddec28b106ce754317acc4 /src
parent755a4c63b24f08f40e459fbd90a15d8af9467435 (diff)
downloadgnunet-2088429445cccbb5b5ac8d696e5544853bb60396.tar.gz
gnunet-2088429445cccbb5b5ac8d696e5544853bb60396.zip
fixing #2014
Diffstat (limited to 'src')
-rw-r--r--src/transport/gnunet-service-transport_neighbours.c8
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);