diff options
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) | |||
387 | generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, next); | 387 | generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, next); |
388 | } | 388 | } |
389 | } | 389 | } |
390 | |||
391 | GNUNET_free (dqe); | 390 | GNUNET_free (dqe); |
392 | } | 391 | } |
393 | 392 | ||
@@ -454,7 +453,9 @@ GST_manipulation_send (const struct GNUNET_PeerIdentity *target, const void *msg | |||
454 | memcpy (dqe->msg, msg, msg_size); | 453 | memcpy (dqe->msg, msg, msg_size); |
455 | GNUNET_CONTAINER_DLL_insert_tail (generic_dqe_head, generic_dqe_tail, dqe); | 454 | GNUNET_CONTAINER_DLL_insert_tail (generic_dqe_head, generic_dqe_tail, dqe); |
456 | if (GNUNET_SCHEDULER_NO_TASK == generic_send_delay_task) | 455 | if (GNUNET_SCHEDULER_NO_TASK == generic_send_delay_task) |
456 | { | ||
457 | generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, dqe); | 457 | generic_send_delay_task = GNUNET_SCHEDULER_add_delayed (delay, &send_delayed, dqe); |
458 | } | ||
458 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 459 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
459 | "Delaying %u byte message to peer `%s' with peer specific delay for %llu ms\n", | 460 | "Delaying %u byte message to peer `%s' with peer specific delay for %llu ms\n", |
460 | msg_size, GNUNET_i2s (target), (long long unsigned int) delay.rel_value); | 461 | 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) | |||
574 | unsigned long long tmp; | 575 | unsigned long long tmp; |
575 | 576 | ||
576 | if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, | 577 | if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, |
577 | "transport", "MANIPULATE_DISTANCE_IN", &tmp)) | 578 | "transport", "MANIPULATE_DISTANCE_IN", &tmp) && (tmp > 0)) |
578 | { | 579 | { |
579 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Setting inbound distance_in to %u\n", | 580 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Setting inbound distance_in to %u\n", |
580 | (unsigned long long) tmp); | 581 | (unsigned long long) tmp); |
@@ -582,7 +583,7 @@ GST_manipulation_init (const struct GNUNET_CONFIGURATION_Handle *GST_cfg) | |||
582 | } | 583 | } |
583 | 584 | ||
584 | if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, | 585 | if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, |
585 | "transport", "MANIPULATE_DISTANCE_OUT", &tmp)) | 586 | "transport", "MANIPULATE_DISTANCE_OUT", &tmp) && (tmp > 0)) |
586 | { | 587 | { |
587 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Setting outbound distance_in to %u\n", | 588 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Setting outbound distance_in to %u\n", |
588 | (unsigned long long) tmp); | 589 | (unsigned long long) tmp); |
@@ -590,7 +591,7 @@ GST_manipulation_init (const struct GNUNET_CONFIGURATION_Handle *GST_cfg) | |||
590 | } | 591 | } |
591 | 592 | ||
592 | if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, | 593 | if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, |
593 | "transport", "MANIPULATE_DELAY_IN", &tmp)) | 594 | "transport", "MANIPULATE_DELAY_IN", &tmp) && (tmp > 0)) |
594 | { | 595 | { |
595 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Delaying inbound traffic for %llu ms\n", | 596 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Delaying inbound traffic for %llu ms\n", |
596 | (unsigned long long) tmp); | 597 | (unsigned long long) tmp); |
@@ -599,7 +600,7 @@ GST_manipulation_init (const struct GNUNET_CONFIGURATION_Handle *GST_cfg) | |||
599 | 600 | ||
600 | 601 | ||
601 | if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, | 602 | if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (GST_cfg, |
602 | "transport", "MANIPULATE_DELAY_OUT", &tmp)) | 603 | "transport", "MANIPULATE_DELAY_OUT", &tmp) && (tmp > 0)) |
603 | { | 604 | { |
604 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Delaying outbound traffic for %llu ms\n", | 605 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Delaying outbound traffic for %llu ms\n", |
605 | (unsigned long long) tmp); | 606 | (unsigned long long) tmp); |