aboutsummaryrefslogtreecommitdiff
path: root/src/core/gnunet-service-core_kx.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/gnunet-service-core_kx.c')
-rw-r--r--src/core/gnunet-service-core_kx.c44
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 */
376static GNUNET_SCHEDULER_TaskIdentifier rekey_task; 376static 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
1269send_key (struct GSC_KeyExchangeInfo *kx) 1269send_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,
1684void 1684void
1685GSC_KX_done () 1685GSC_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 {