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.c11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/cadet/gnunet-service-cadet_channel.c b/src/cadet/gnunet-service-cadet_channel.c
index a2e01d28f..debae7d77 100644
--- a/src/cadet/gnunet-service-cadet_channel.c
+++ b/src/cadet/gnunet-service-cadet_channel.c
@@ -721,19 +721,19 @@ send_client_nack (struct CadetChannel *ch)
721 * We haven't received an ACK after a certain time: restransmit the message. 721 * We haven't received an ACK after a certain time: restransmit the message.
722 * 722 *
723 * @param cls Closure (CadetChannelReliability with the message to restransmit) 723 * @param cls Closure (CadetChannelReliability with the message to restransmit)
724 * @param tc TaskContext.
725 */ 724 */
726static void 725static void
727channel_retransmit_message (void *cls, 726channel_retransmit_message (void *cls)
728 const struct GNUNET_SCHEDULER_TaskContext *tc)
729{ 727{
730 struct CadetChannelReliability *rel = cls; 728 struct CadetChannelReliability *rel = cls;
731 struct CadetReliableMessage *copy; 729 struct CadetReliableMessage *copy;
732 struct CadetChannel *ch; 730 struct CadetChannel *ch;
733 struct GNUNET_CADET_Data *payload; 731 struct GNUNET_CADET_Data *payload;
734 int fwd; 732 int fwd;
733 const struct GNUNET_SCHEDULER_TaskContext *tc;
735 734
736 rel->retry_task = NULL; 735 rel->retry_task = NULL;
736 tc = GNUNET_SCHEDULER_get_task_context ();
737 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) 737 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
738 return; 738 return;
739 739
@@ -760,14 +760,15 @@ channel_retransmit_message (void *cls,
760 * We haven't received an Channel ACK after a certain time: resend the CREATE. 760 * We haven't received an Channel ACK after a certain time: resend the CREATE.
761 * 761 *
762 * @param cls Closure (CadetChannelReliability of the channel to recreate) 762 * @param cls Closure (CadetChannelReliability of the channel to recreate)
763 * @param tc TaskContext.
764 */ 763 */
765static void 764static void
766channel_recreate (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) 765channel_recreate (void *cls)
767{ 766{
768 struct CadetChannelReliability *rel = cls; 767 struct CadetChannelReliability *rel = cls;
768 const struct GNUNET_SCHEDULER_TaskContext *tc;
769 769
770 rel->retry_task = NULL; 770 rel->retry_task = NULL;
771 tc = GNUNET_SCHEDULER_get_task_context ();
771 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) 772 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
772 return; 773 return;
773 774