diff options
| author | Matthias Wachs <wachs@net.in.tum.de> | 2013-05-17 12:59:36 +0000 |
|---|---|---|
| committer | Matthias Wachs <wachs@net.in.tum.de> | 2013-05-17 12:59:36 +0000 |
| commit | b12945cc27b46280fc2058f251d32480789a99cb (patch) | |
| tree | 2659b9a28e755e30ffc53161df26a72070161a74 /src/transport/gnunet-service-transport_manipulation.c | |
| parent | 28cd8070bed28d153f060d7593e6b9dab433aff2 (diff) | |
improved test
Diffstat (limited to 'src/transport/gnunet-service-transport_manipulation.c')
| -rw-r--r-- | src/transport/gnunet-service-transport_manipulation.c | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/transport/gnunet-service-transport_manipulation.c b/src/transport/gnunet-service-transport_manipulation.c index 417f50d41..786b95bed 100644 --- a/src/transport/gnunet-service-transport_manipulation.c +++ b/src/transport/gnunet-service-transport_manipulation.c @@ -387,7 +387,6 @@ send_delayed (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, next); } } - GNUNET_free (dqe); } @@ -454,7 +453,9 @@ GST_manipulation_send (const struct GNUNET_PeerIdentity *target, const void *msg memcpy (dqe->msg, msg, msg_size); GNUNET_CONTAINER_DLL_insert_tail (generic_dqe_head, generic_dqe_tail, dqe); if (GNUNET_SCHEDULER_NO_TASK == generic_send_delay_task) + { generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, dqe); + } GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Delaying %u byte message to peer `%s' with peer specific delay for %llu ms\n", msg_size, GNUNET_i2s (target), (long long unsigned int) delay.rel_value); @@ -574,7 +575,7 @@ GST_manipulation_init (const struct GNUNET_CONFIGURATION_Handle *GST_cfg) unsigned long long tmp; if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, - "transport", "MANIPULATE_DISTANCE_IN", &tmp)) + "transport", "MANIPULATE_DISTANCE_IN", &tmp) && (tmp > 0)) { GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Setting inbound distance_in to %u\n", (unsigned long long) tmp); @@ -582,7 +583,7 @@ GST_manipulation_init (const struct GNUNET_CONFIGURATION_Handle *GST_cfg) } if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, - "transport", "MANIPULATE_DISTANCE_OUT", &tmp)) + "transport", "MANIPULATE_DISTANCE_OUT", &tmp) && (tmp > 0)) { GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Setting outbound distance_in to %u\n", (unsigned long long) tmp); @@ -590,7 +591,7 @@ GST_manipulation_init (const struct GNUNET_CONFIGURATION_Handle *GST_cfg) } if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, - "transport", "MANIPULATE_DELAY_IN", &tmp)) + "transport", "MANIPULATE_DELAY_IN", &tmp) && (tmp > 0)) { GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Delaying inbound traffic for %llu ms\n", (unsigned long long) tmp); @@ -599,7 +600,7 @@ GST_manipulation_init (const struct GNUNET_CONFIGURATION_Handle *GST_cfg) if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, - "transport", "MANIPULATE_DELAY_OUT", &tmp)) + "transport", "MANIPULATE_DELAY_OUT", &tmp) && (tmp > 0)) { GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Delaying outbound traffic for %llu ms\n", (unsigned long long) tmp); |