diff options
Diffstat (limited to 'src/core/gnunet-service-core_kx.c')
-rw-r--r-- | src/core/gnunet-service-core_kx.c | 44 |
1 files changed, 22 insertions, 22 deletions
diff --git a/src/core/gnunet-service-core_kx.c b/src/core/gnunet-service-core_kx.c index a4e964312..94f3f5c87 100644 --- a/src/core/gnunet-service-core_kx.c +++ b/src/core/gnunet-service-core_kx.c | |||
@@ -302,12 +302,12 @@ struct GSC_KeyExchangeInfo | |||
302 | /** | 302 | /** |
303 | * ID of task used for re-trying SET_KEY and PING message. | 303 | * ID of task used for re-trying SET_KEY and PING message. |
304 | */ | 304 | */ |
305 | GNUNET_SCHEDULER_TaskIdentifier retry_set_key_task; | 305 | struct GNUNET_SCHEDULER_Task * retry_set_key_task; |
306 | 306 | ||
307 | /** | 307 | /** |
308 | * ID of task used for sending keep-alive pings. | 308 | * ID of task used for sending keep-alive pings. |
309 | */ | 309 | */ |
310 | GNUNET_SCHEDULER_TaskIdentifier keep_alive_task; | 310 | struct GNUNET_SCHEDULER_Task * keep_alive_task; |
311 | 311 | ||
312 | /** | 312 | /** |
313 | * Bit map indicating which of the 32 sequence numbers before the last | 313 | * Bit map indicating which of the 32 sequence numbers before the last |
@@ -373,7 +373,7 @@ static struct GSC_KeyExchangeInfo *kx_tail; | |||
373 | * Task scheduled for periodic re-generation (and thus rekeying) of our | 373 | * Task scheduled for periodic re-generation (and thus rekeying) of our |
374 | * ephemeral key. | 374 | * ephemeral key. |
375 | */ | 375 | */ |
376 | static GNUNET_SCHEDULER_TaskIdentifier rekey_task; | 376 | static struct GNUNET_SCHEDULER_Task * rekey_task; |
377 | 377 | ||
378 | /** | 378 | /** |
379 | * Notification context for all monitors. | 379 | * Notification context for all monitors. |
@@ -651,7 +651,7 @@ set_key_retry_task (void *cls, | |||
651 | { | 651 | { |
652 | struct GSC_KeyExchangeInfo *kx = cls; | 652 | struct GSC_KeyExchangeInfo *kx = cls; |
653 | 653 | ||
654 | kx->retry_set_key_task = GNUNET_SCHEDULER_NO_TASK; | 654 | kx->retry_set_key_task = NULL; |
655 | kx->set_key_retry_frequency = GNUNET_TIME_STD_BACKOFF (kx->set_key_retry_frequency); | 655 | kx->set_key_retry_frequency = GNUNET_TIME_STD_BACKOFF (kx->set_key_retry_frequency); |
656 | GNUNET_assert (GNUNET_CORE_KX_STATE_DOWN != kx->status); | 656 | GNUNET_assert (GNUNET_CORE_KX_STATE_DOWN != kx->status); |
657 | send_key (kx); | 657 | send_key (kx); |
@@ -746,15 +746,15 @@ GSC_KX_stop (struct GSC_KeyExchangeInfo *kx) | |||
746 | GSC_SESSIONS_end (&kx->peer); | 746 | GSC_SESSIONS_end (&kx->peer); |
747 | GNUNET_STATISTICS_update (GSC_stats, gettext_noop ("# key exchanges stopped"), | 747 | GNUNET_STATISTICS_update (GSC_stats, gettext_noop ("# key exchanges stopped"), |
748 | 1, GNUNET_NO); | 748 | 1, GNUNET_NO); |
749 | if (kx->retry_set_key_task != GNUNET_SCHEDULER_NO_TASK) | 749 | if (kx->retry_set_key_task != NULL) |
750 | { | 750 | { |
751 | GNUNET_SCHEDULER_cancel (kx->retry_set_key_task); | 751 | GNUNET_SCHEDULER_cancel (kx->retry_set_key_task); |
752 | kx->retry_set_key_task = GNUNET_SCHEDULER_NO_TASK; | 752 | kx->retry_set_key_task = NULL; |
753 | } | 753 | } |
754 | if (kx->keep_alive_task != GNUNET_SCHEDULER_NO_TASK) | 754 | if (kx->keep_alive_task != NULL) |
755 | { | 755 | { |
756 | GNUNET_SCHEDULER_cancel (kx->keep_alive_task); | 756 | GNUNET_SCHEDULER_cancel (kx->keep_alive_task); |
757 | kx->keep_alive_task = GNUNET_SCHEDULER_NO_TASK; | 757 | kx->keep_alive_task = NULL; |
758 | } | 758 | } |
759 | kx->status = GNUNET_CORE_KX_PEER_DISCONNECT; | 759 | kx->status = GNUNET_CORE_KX_PEER_DISCONNECT; |
760 | monitor_notify_all (kx); | 760 | monitor_notify_all (kx); |
@@ -929,7 +929,7 @@ GSC_KX_handle_ephemeral_key (struct GSC_KeyExchangeInfo *kx, | |||
929 | switch (kx->status) | 929 | switch (kx->status) |
930 | { | 930 | { |
931 | case GNUNET_CORE_KX_STATE_DOWN: | 931 | case GNUNET_CORE_KX_STATE_DOWN: |
932 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == kx->keep_alive_task); | 932 | GNUNET_assert (NULL == kx->keep_alive_task); |
933 | kx->status = GNUNET_CORE_KX_STATE_KEY_RECEIVED; | 933 | kx->status = GNUNET_CORE_KX_STATE_KEY_RECEIVED; |
934 | monitor_notify_all (kx); | 934 | monitor_notify_all (kx); |
935 | if (GNUNET_CORE_KX_STATE_KEY_SENT == sender_status) | 935 | if (GNUNET_CORE_KX_STATE_KEY_SENT == sender_status) |
@@ -937,7 +937,7 @@ GSC_KX_handle_ephemeral_key (struct GSC_KeyExchangeInfo *kx, | |||
937 | send_ping (kx); | 937 | send_ping (kx); |
938 | break; | 938 | break; |
939 | case GNUNET_CORE_KX_STATE_KEY_SENT: | 939 | case GNUNET_CORE_KX_STATE_KEY_SENT: |
940 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == kx->keep_alive_task); | 940 | GNUNET_assert (NULL == kx->keep_alive_task); |
941 | kx->status = GNUNET_CORE_KX_STATE_KEY_RECEIVED; | 941 | kx->status = GNUNET_CORE_KX_STATE_KEY_RECEIVED; |
942 | monitor_notify_all (kx); | 942 | monitor_notify_all (kx); |
943 | if (GNUNET_CORE_KX_STATE_KEY_SENT == sender_status) | 943 | if (GNUNET_CORE_KX_STATE_KEY_SENT == sender_status) |
@@ -945,7 +945,7 @@ GSC_KX_handle_ephemeral_key (struct GSC_KeyExchangeInfo *kx, | |||
945 | send_ping (kx); | 945 | send_ping (kx); |
946 | break; | 946 | break; |
947 | case GNUNET_CORE_KX_STATE_KEY_RECEIVED: | 947 | case GNUNET_CORE_KX_STATE_KEY_RECEIVED: |
948 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == kx->keep_alive_task); | 948 | GNUNET_assert (NULL == kx->keep_alive_task); |
949 | if (GNUNET_CORE_KX_STATE_KEY_SENT == sender_status) | 949 | if (GNUNET_CORE_KX_STATE_KEY_SENT == sender_status) |
950 | send_key (kx); | 950 | send_key (kx); |
951 | send_ping (kx); | 951 | send_ping (kx); |
@@ -1069,7 +1069,7 @@ send_keep_alive (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
1069 | struct GNUNET_TIME_Relative retry; | 1069 | struct GNUNET_TIME_Relative retry; |
1070 | struct GNUNET_TIME_Relative left; | 1070 | struct GNUNET_TIME_Relative left; |
1071 | 1071 | ||
1072 | kx->keep_alive_task = GNUNET_SCHEDULER_NO_TASK; | 1072 | kx->keep_alive_task = NULL; |
1073 | left = GNUNET_TIME_absolute_get_remaining (kx->timeout); | 1073 | left = GNUNET_TIME_absolute_get_remaining (kx->timeout); |
1074 | if (0 == left.rel_value_us) | 1074 | if (0 == left.rel_value_us) |
1075 | { | 1075 | { |
@@ -1122,7 +1122,7 @@ update_timeout (struct GSC_KeyExchangeInfo *kx) | |||
1122 | are bigger than the threshold (5s) */ | 1122 | are bigger than the threshold (5s) */ |
1123 | monitor_notify_all (kx); | 1123 | monitor_notify_all (kx); |
1124 | } | 1124 | } |
1125 | if (kx->keep_alive_task != GNUNET_SCHEDULER_NO_TASK) | 1125 | if (kx->keep_alive_task != NULL) |
1126 | GNUNET_SCHEDULER_cancel (kx->keep_alive_task); | 1126 | GNUNET_SCHEDULER_cancel (kx->keep_alive_task); |
1127 | kx->keep_alive_task = | 1127 | kx->keep_alive_task = |
1128 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_divide | 1128 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_divide |
@@ -1213,10 +1213,10 @@ GSC_KX_handle_pong (struct GSC_KeyExchangeInfo *kx, | |||
1213 | "Received PONG from `%s'\n", | 1213 | "Received PONG from `%s'\n", |
1214 | GNUNET_i2s (&kx->peer)); | 1214 | GNUNET_i2s (&kx->peer)); |
1215 | /* no need to resend key any longer */ | 1215 | /* no need to resend key any longer */ |
1216 | if (GNUNET_SCHEDULER_NO_TASK != kx->retry_set_key_task) | 1216 | if (NULL != kx->retry_set_key_task) |
1217 | { | 1217 | { |
1218 | GNUNET_SCHEDULER_cancel (kx->retry_set_key_task); | 1218 | GNUNET_SCHEDULER_cancel (kx->retry_set_key_task); |
1219 | kx->retry_set_key_task = GNUNET_SCHEDULER_NO_TASK; | 1219 | kx->retry_set_key_task = NULL; |
1220 | } | 1220 | } |
1221 | switch (kx->status) | 1221 | switch (kx->status) |
1222 | { | 1222 | { |
@@ -1234,7 +1234,7 @@ GSC_KX_handle_pong (struct GSC_KeyExchangeInfo *kx, | |||
1234 | kx->status = GNUNET_CORE_KX_STATE_UP; | 1234 | kx->status = GNUNET_CORE_KX_STATE_UP; |
1235 | monitor_notify_all (kx); | 1235 | monitor_notify_all (kx); |
1236 | GSC_SESSIONS_create (&kx->peer, kx); | 1236 | GSC_SESSIONS_create (&kx->peer, kx); |
1237 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == kx->keep_alive_task); | 1237 | GNUNET_assert (NULL == kx->keep_alive_task); |
1238 | update_timeout (kx); | 1238 | update_timeout (kx); |
1239 | break; | 1239 | break; |
1240 | case GNUNET_CORE_KX_STATE_UP: | 1240 | case GNUNET_CORE_KX_STATE_UP: |
@@ -1269,10 +1269,10 @@ static void | |||
1269 | send_key (struct GSC_KeyExchangeInfo *kx) | 1269 | send_key (struct GSC_KeyExchangeInfo *kx) |
1270 | { | 1270 | { |
1271 | GNUNET_assert (GNUNET_CORE_KX_STATE_DOWN != kx->status); | 1271 | GNUNET_assert (GNUNET_CORE_KX_STATE_DOWN != kx->status); |
1272 | if (GNUNET_SCHEDULER_NO_TASK != kx->retry_set_key_task) | 1272 | if (NULL != kx->retry_set_key_task) |
1273 | { | 1273 | { |
1274 | GNUNET_SCHEDULER_cancel (kx->retry_set_key_task); | 1274 | GNUNET_SCHEDULER_cancel (kx->retry_set_key_task); |
1275 | kx->retry_set_key_task = GNUNET_SCHEDULER_NO_TASK; | 1275 | kx->retry_set_key_task = NULL; |
1276 | } | 1276 | } |
1277 | /* always update sender status in SET KEY message */ | 1277 | /* always update sender status in SET KEY message */ |
1278 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1278 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
@@ -1402,10 +1402,10 @@ GSC_KX_handle_encrypted_message (struct GSC_KeyExchangeInfo *kx, | |||
1402 | gettext_noop ("# sessions terminated by key expiration"), | 1402 | gettext_noop ("# sessions terminated by key expiration"), |
1403 | 1, GNUNET_NO); | 1403 | 1, GNUNET_NO); |
1404 | GSC_SESSIONS_end (&kx->peer); | 1404 | GSC_SESSIONS_end (&kx->peer); |
1405 | if (GNUNET_SCHEDULER_NO_TASK != kx->keep_alive_task) | 1405 | if (NULL != kx->keep_alive_task) |
1406 | { | 1406 | { |
1407 | GNUNET_SCHEDULER_cancel (kx->keep_alive_task); | 1407 | GNUNET_SCHEDULER_cancel (kx->keep_alive_task); |
1408 | kx->keep_alive_task = GNUNET_SCHEDULER_NO_TASK; | 1408 | kx->keep_alive_task = NULL; |
1409 | } | 1409 | } |
1410 | kx->status = GNUNET_CORE_KX_STATE_KEY_SENT; | 1410 | kx->status = GNUNET_CORE_KX_STATE_KEY_SENT; |
1411 | monitor_notify_all (kx); | 1411 | monitor_notify_all (kx); |
@@ -1684,10 +1684,10 @@ GSC_KX_init (struct GNUNET_CRYPTO_EddsaPrivateKey *pk, | |||
1684 | void | 1684 | void |
1685 | GSC_KX_done () | 1685 | GSC_KX_done () |
1686 | { | 1686 | { |
1687 | if (GNUNET_SCHEDULER_NO_TASK != rekey_task) | 1687 | if (NULL != rekey_task) |
1688 | { | 1688 | { |
1689 | GNUNET_SCHEDULER_cancel (rekey_task); | 1689 | GNUNET_SCHEDULER_cancel (rekey_task); |
1690 | rekey_task = GNUNET_SCHEDULER_NO_TASK; | 1690 | rekey_task = NULL; |
1691 | } | 1691 | } |
1692 | if (NULL != my_ephemeral_key) | 1692 | if (NULL != my_ephemeral_key) |
1693 | { | 1693 | { |