[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r36603 - gnunet/src/fragmentation
From: |
gnunet |
Subject: |
[GNUnet-SVN] r36603 - gnunet/src/fragmentation |
Date: |
Tue, 27 Oct 2015 17:05:19 +0100 |
Author: grothoff
Date: 2015-10-27 17:05:18 +0100 (Tue, 27 Oct 2015)
New Revision: 36603
Modified:
gnunet/src/fragmentation/fragmentation.c
Log:
-logging, indenting
Modified: gnunet/src/fragmentation/fragmentation.c
===================================================================
--- gnunet/src/fragmentation/fragmentation.c 2015-10-27 16:04:58 UTC (rev
36602)
+++ gnunet/src/fragmentation/fragmentation.c 2015-10-27 16:05:18 UTC (rev
36603)
@@ -203,12 +203,19 @@
else
fsize = fc->mtu;
if (NULL != fc->tracker)
- delay = GNUNET_BANDWIDTH_tracker_get_delay (fc->tracker, fsize);
+ delay = GNUNET_BANDWIDTH_tracker_get_delay (fc->tracker,
+ fsize);
else
delay = GNUNET_TIME_UNIT_ZERO;
if (delay.rel_value_us > 0)
{
- fc->task = GNUNET_SCHEDULER_add_delayed (delay, &transmit_next, fc);
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Fragmentation logic delays transmission of next fragment by
%s\n",
+ GNUNET_STRINGS_relative_time_to_string (delay,
+ GNUNET_YES));
+ fc->task = GNUNET_SCHEDULER_add_delayed (delay,
+ &transmit_next,
+ fc);
return;
}
fc->next_transmission = (fc->next_transmission + 1) % 64;
@@ -273,7 +280,8 @@
fc->proc_busy = GNUNET_YES;
fc->delay_until = GNUNET_TIME_relative_to_absolute (delay);
fc->num_transmissions++;
- fc->proc (fc->proc_cls, &fh->header);
+ fc->proc (fc->proc_cls,
+ &fh->header);
}
@@ -331,7 +339,8 @@
fc->proc = proc;
fc->proc_cls = proc_cls;
fc->fragment_id =
- GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, UINT32_MAX);
+ GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
+ UINT32_MAX);
memcpy (&fc[1], msg, size);
bits =
(size + mtu - sizeof (struct FragmentHeader) - 1) / (mtu -
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r36603 - gnunet/src/fragmentation,
gnunet <=