diff options
Diffstat (limited to 'src/transport/gnunet-service-transport_neighbours.c')
-rw-r--r-- | src/transport/gnunet-service-transport_neighbours.c | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/src/transport/gnunet-service-transport_neighbours.c b/src/transport/gnunet-service-transport_neighbours.c index 3dc707923..9676366a6 100644 --- a/src/transport/gnunet-service-transport_neighbours.c +++ b/src/transport/gnunet-service-transport_neighbours.c | |||
@@ -798,9 +798,6 @@ GST_neighbours_session_terminated (const struct GNUNET_PeerIdentity *peer, | |||
798 | 798 | ||
799 | if (GNUNET_YES != n->is_connected) | 799 | if (GNUNET_YES != n->is_connected) |
800 | return; /* not connected anymore anyway, shouldn't matter */ | 800 | return; /* not connected anymore anyway, shouldn't matter */ |
801 | |||
802 | //n->is_connected = GNUNET_NO; | ||
803 | |||
804 | /* fast disconnect unless ATS suggests a new address */ | 801 | /* fast disconnect unless ATS suggests a new address */ |
805 | GNUNET_SCHEDULER_cancel (n->timeout_task); | 802 | GNUNET_SCHEDULER_cancel (n->timeout_task); |
806 | n->timeout_task = | 803 | n->timeout_task = |
@@ -869,8 +866,6 @@ GST_neighbours_send (const struct GNUNET_PeerIdentity *target, const void *msg, | |||
869 | cont (cont_cls, GNUNET_SYSERR); | 866 | cont (cont_cls, GNUNET_SYSERR); |
870 | return; | 867 | return; |
871 | } | 868 | } |
872 | |||
873 | |||
874 | GNUNET_assert (msg_size >= sizeof (struct GNUNET_MessageHeader)); | 869 | GNUNET_assert (msg_size >= sizeof (struct GNUNET_MessageHeader)); |
875 | GNUNET_STATISTICS_update (GST_stats, | 870 | GNUNET_STATISTICS_update (GST_stats, |
876 | gettext_noop | 871 | gettext_noop |
@@ -917,6 +912,14 @@ GST_neighbours_calculate_receive_delay (const struct GNUNET_PeerIdentity | |||
917 | *do_forward = GNUNET_NO; | 912 | *do_forward = GNUNET_NO; |
918 | return GNUNET_TIME_UNIT_ZERO; | 913 | return GNUNET_TIME_UNIT_ZERO; |
919 | } | 914 | } |
915 | if (GNUNET_YES != n->is_connected) | ||
916 | { | ||
917 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | ||
918 | _("Plugin gave us %d bytes of data but somehow the session is not marked as UP yet!\n"), | ||
919 | (int) size); | ||
920 | *do_forward = GNUNET_NO; | ||
921 | return GNUNET_TIME_UNIT_ZERO; | ||
922 | } | ||
920 | if (GNUNET_YES == GNUNET_BANDWIDTH_tracker_consume (&n->in_tracker, size)) | 923 | if (GNUNET_YES == GNUNET_BANDWIDTH_tracker_consume (&n->in_tracker, size)) |
921 | { | 924 | { |
922 | n->quota_violation_count++; | 925 | n->quota_violation_count++; |