aboutsummaryrefslogtreecommitdiff
path: root/src/cadet/gnunet-service-cadet_channel.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/cadet/gnunet-service-cadet_channel.c')
-rw-r--r--src/cadet/gnunet-service-cadet_channel.c14
1 files changed, 2 insertions, 12 deletions
diff --git a/src/cadet/gnunet-service-cadet_channel.c b/src/cadet/gnunet-service-cadet_channel.c
index debae7d77..d4f9754da 100644
--- a/src/cadet/gnunet-service-cadet_channel.c
+++ b/src/cadet/gnunet-service-cadet_channel.c
@@ -730,13 +730,8 @@ channel_retransmit_message (void *cls)
730 struct CadetChannel *ch; 730 struct CadetChannel *ch;
731 struct GNUNET_CADET_Data *payload; 731 struct GNUNET_CADET_Data *payload;
732 int fwd; 732 int fwd;
733 const struct GNUNET_SCHEDULER_TaskContext *tc;
734 733
735 rel->retry_task = NULL; 734 rel->retry_task = NULL;
736 tc = GNUNET_SCHEDULER_get_task_context ();
737 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
738 return;
739
740 ch = rel->ch; 735 ch = rel->ch;
741 copy = rel->head_sent; 736 copy = rel->head_sent;
742 if (NULL == copy) 737 if (NULL == copy)
@@ -765,15 +760,11 @@ static void
765channel_recreate (void *cls) 760channel_recreate (void *cls)
766{ 761{
767 struct CadetChannelReliability *rel = cls; 762 struct CadetChannelReliability *rel = cls;
768 const struct GNUNET_SCHEDULER_TaskContext *tc;
769 763
770 rel->retry_task = NULL; 764 rel->retry_task = NULL;
771 tc = GNUNET_SCHEDULER_get_task_context ();
772 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
773 return;
774
775 LOG (GNUNET_ERROR_TYPE_DEBUG, "RE-CREATE\n"); 765 LOG (GNUNET_ERROR_TYPE_DEBUG, "RE-CREATE\n");
776 GNUNET_STATISTICS_update (stats, "# data retransmitted", 1, GNUNET_NO); 766 GNUNET_STATISTICS_update (stats,
767 "# data retransmitted", 1, GNUNET_NO);
777 768
778 if (rel == rel->ch->root_rel) 769 if (rel == rel->ch->root_rel)
779 { 770 {
@@ -787,7 +778,6 @@ channel_recreate (void *cls)
787 { 778 {
788 GNUNET_break (0); 779 GNUNET_break (0);
789 } 780 }
790
791} 781}
792 782
793 783