diff options
Diffstat (limited to 'src/transport/gnunet-service-transport_validation.c')
-rw-r--r-- | src/transport/gnunet-service-transport_validation.c | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/src/transport/gnunet-service-transport_validation.c b/src/transport/gnunet-service-transport_validation.c index 3c7edd140..a6a591c84 100644 --- a/src/transport/gnunet-service-transport_validation.c +++ b/src/transport/gnunet-service-transport_validation.c | |||
@@ -206,12 +206,12 @@ struct ValidationEntry | |||
206 | /** | 206 | /** |
207 | * ID of task that will clean up this entry if nothing happens. | 207 | * ID of task that will clean up this entry if nothing happens. |
208 | */ | 208 | */ |
209 | GNUNET_SCHEDULER_TaskIdentifier timeout_task; | 209 | struct GNUNET_SCHEDULER_Task * timeout_task; |
210 | 210 | ||
211 | /** | 211 | /** |
212 | * ID of task that will trigger address revalidation. | 212 | * ID of task that will trigger address revalidation. |
213 | */ | 213 | */ |
214 | GNUNET_SCHEDULER_TaskIdentifier revalidation_task; | 214 | struct GNUNET_SCHEDULER_Task * revalidation_task; |
215 | 215 | ||
216 | /** | 216 | /** |
217 | * At what time did we send the latest validation request (PING)? | 217 | * At what time did we send the latest validation request (PING)? |
@@ -441,15 +441,15 @@ cleanup_validation_entry (void *cls, | |||
441 | GNUNET_CONTAINER_multipeermap_remove (validation_map, | 441 | GNUNET_CONTAINER_multipeermap_remove (validation_map, |
442 | &ve->pid, ve)); | 442 | &ve->pid, ve)); |
443 | GNUNET_HELLO_address_free (ve->address); | 443 | GNUNET_HELLO_address_free (ve->address); |
444 | if (GNUNET_SCHEDULER_NO_TASK != ve->timeout_task) | 444 | if (NULL != ve->timeout_task) |
445 | { | 445 | { |
446 | GNUNET_SCHEDULER_cancel (ve->timeout_task); | 446 | GNUNET_SCHEDULER_cancel (ve->timeout_task); |
447 | ve->timeout_task = GNUNET_SCHEDULER_NO_TASK; | 447 | ve->timeout_task = NULL; |
448 | } | 448 | } |
449 | if (GNUNET_SCHEDULER_NO_TASK != ve->revalidation_task) | 449 | if (NULL != ve->revalidation_task) |
450 | { | 450 | { |
451 | GNUNET_SCHEDULER_cancel (ve->revalidation_task); | 451 | GNUNET_SCHEDULER_cancel (ve->revalidation_task); |
452 | ve->revalidation_task = GNUNET_SCHEDULER_NO_TASK; | 452 | ve->revalidation_task = NULL; |
453 | } | 453 | } |
454 | if ((GNUNET_YES == ve->expecting_pong) && | 454 | if ((GNUNET_YES == ve->expecting_pong) && |
455 | (validations_running > 0)) | 455 | (validations_running > 0)) |
@@ -479,7 +479,7 @@ timeout_hello_validation (void *cls, | |||
479 | struct GNUNET_TIME_Absolute max; | 479 | struct GNUNET_TIME_Absolute max; |
480 | struct GNUNET_TIME_Relative left; | 480 | struct GNUNET_TIME_Relative left; |
481 | 481 | ||
482 | ve->timeout_task = GNUNET_SCHEDULER_NO_TASK; | 482 | ve->timeout_task = NULL; |
483 | max = GNUNET_TIME_absolute_max (ve->valid_until, ve->revalidation_block); | 483 | max = GNUNET_TIME_absolute_max (ve->valid_until, ve->revalidation_block); |
484 | left = GNUNET_TIME_absolute_get_remaining (max); | 484 | left = GNUNET_TIME_absolute_get_remaining (max); |
485 | if (left.rel_value_us > 0) | 485 | if (left.rel_value_us > 0) |
@@ -653,7 +653,7 @@ revalidate_address (void *cls, | |||
653 | struct GST_BlacklistCheck *bc; | 653 | struct GST_BlacklistCheck *bc; |
654 | uint32_t rdelay; | 654 | uint32_t rdelay; |
655 | 655 | ||
656 | ve->revalidation_task = GNUNET_SCHEDULER_NO_TASK; | 656 | ve->revalidation_task = NULL; |
657 | delay = GNUNET_TIME_absolute_get_remaining (ve->revalidation_block); | 657 | delay = GNUNET_TIME_absolute_get_remaining (ve->revalidation_block); |
658 | /* How long until we can possibly permit the next PING? */ | 658 | /* How long until we can possibly permit the next PING? */ |
659 | if (GNUNET_YES == ve->in_use) | 659 | if (GNUNET_YES == ve->in_use) |
@@ -816,7 +816,7 @@ add_valid_address (void *cls, | |||
816 | ve = find_validation_entry (&public_key, address); | 816 | ve = find_validation_entry (&public_key, address); |
817 | ve->valid_until = GNUNET_TIME_absolute_max (ve->valid_until, expiration); | 817 | ve->valid_until = GNUNET_TIME_absolute_max (ve->valid_until, expiration); |
818 | 818 | ||
819 | if (GNUNET_SCHEDULER_NO_TASK == ve->revalidation_task) | 819 | if (NULL == ve->revalidation_task) |
820 | { | 820 | { |
821 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 821 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
822 | "Starting revalidations for valid address `%s'\n", | 822 | "Starting revalidations for valid address `%s'\n", |
@@ -1270,7 +1270,7 @@ validate_address_iterator (void *cls, | |||
1270 | if (papi == NULL) | 1270 | if (papi == NULL) |
1271 | { | 1271 | { |
1272 | /* This plugin is currently unvailable ... retry later */ | 1272 | /* This plugin is currently unvailable ... retry later */ |
1273 | if (GNUNET_SCHEDULER_NO_TASK == ve->revalidation_task) | 1273 | if (NULL == ve->revalidation_task) |
1274 | { | 1274 | { |
1275 | if (GNUNET_YES == ve->in_use) | 1275 | if (GNUNET_YES == ve->in_use) |
1276 | canonical_delay = CONNECTED_PING_FREQUENCY; | 1276 | canonical_delay = CONNECTED_PING_FREQUENCY; |
@@ -1292,7 +1292,7 @@ validate_address_iterator (void *cls, | |||
1292 | } | 1292 | } |
1293 | 1293 | ||
1294 | 1294 | ||
1295 | if (GNUNET_SCHEDULER_NO_TASK == ve->revalidation_task) | 1295 | if (NULL == ve->revalidation_task) |
1296 | { | 1296 | { |
1297 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | 1297 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, |
1298 | "Validation process started for fresh address `%s'\n", | 1298 | "Validation process started for fresh address `%s'\n", |