diff options
Diffstat (limited to 'src/cadet/gnunet-service-cadet_connection.c')
-rw-r--r-- | src/cadet/gnunet-service-cadet_connection.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/cadet/gnunet-service-cadet_connection.c b/src/cadet/gnunet-service-cadet_connection.c index 205f0b3b3..c88df79fd 100644 --- a/src/cadet/gnunet-service-cadet_connection.c +++ b/src/cadet/gnunet-service-cadet_connection.c | |||
@@ -736,7 +736,7 @@ conn_message_sent (void *cls, | |||
736 | } | 736 | } |
737 | GNUNET_free (q); | 737 | GNUNET_free (q); |
738 | } | 738 | } |
739 | else if (type == GNUNET_MESSAGE_TYPE_CADET_AX) | 739 | else if (type == GNUNET_MESSAGE_TYPE_CADET_ENCRYPTED) |
740 | { | 740 | { |
741 | /* SHOULD NO LONGER HAPPEN FIXME: REMOVE CASE */ | 741 | /* SHOULD NO LONGER HAPPEN FIXME: REMOVE CASE */ |
742 | // If NULL == q and ENCRYPTED == type, message must have been ch_mngmnt | 742 | // If NULL == q and ENCRYPTED == type, message must have been ch_mngmnt |
@@ -771,7 +771,7 @@ conn_message_sent (void *cls, | |||
771 | schedule_next_keepalive (c, fwd); | 771 | schedule_next_keepalive (c, fwd); |
772 | break; | 772 | break; |
773 | 773 | ||
774 | case GNUNET_MESSAGE_TYPE_CADET_AX: | 774 | case GNUNET_MESSAGE_TYPE_CADET_ENCRYPTED: |
775 | if (GNUNET_YES == sent) | 775 | if (GNUNET_YES == sent) |
776 | { | 776 | { |
777 | GNUNET_assert (NULL != q); | 777 | GNUNET_assert (NULL != q); |
@@ -2517,7 +2517,7 @@ check_message (const struct GNUNET_MessageHeader *message, | |||
2517 | 2517 | ||
2518 | /* Check PID for payload messages */ | 2518 | /* Check PID for payload messages */ |
2519 | type = ntohs (message->type); | 2519 | type = ntohs (message->type); |
2520 | if (GNUNET_MESSAGE_TYPE_CADET_AX == type) | 2520 | if (GNUNET_MESSAGE_TYPE_CADET_ENCRYPTED == type) |
2521 | { | 2521 | { |
2522 | fc = fwd ? &c->bck_fc : &c->fwd_fc; | 2522 | fc = fwd ? &c->bck_fc : &c->fwd_fc; |
2523 | LOG (GNUNET_ERROR_TYPE_DEBUG, " PID %u (expected %u - %u)\n", | 2523 | LOG (GNUNET_ERROR_TYPE_DEBUG, " PID %u (expected %u - %u)\n", |
@@ -2611,7 +2611,7 @@ GCC_handle_kx (struct CadetPeer *peer, | |||
2611 | GNUNET_break (0); | 2611 | GNUNET_break (0); |
2612 | return; | 2612 | return; |
2613 | } | 2613 | } |
2614 | GCT_handle_kx (c->t, &msg[1].header); | 2614 | GCT_handle_kx (c->t, msg); |
2615 | GCC_check_connections (); | 2615 | GCC_check_connections (); |
2616 | return; | 2616 | return; |
2617 | } | 2617 | } |
@@ -2633,7 +2633,7 @@ GCC_handle_kx (struct CadetPeer *peer, | |||
2633 | */ | 2633 | */ |
2634 | void | 2634 | void |
2635 | GCC_handle_encrypted (struct CadetPeer *peer, | 2635 | GCC_handle_encrypted (struct CadetPeer *peer, |
2636 | const struct GNUNET_CADET_AX *msg) | 2636 | const struct GNUNET_CADET_Encrypted *msg) |
2637 | { | 2637 | { |
2638 | const struct GNUNET_CADET_Hash* cid; | 2638 | const struct GNUNET_CADET_Hash* cid; |
2639 | struct CadetConnection *c; | 2639 | struct CadetConnection *c; |
@@ -2670,7 +2670,7 @@ GCC_handle_encrypted (struct CadetPeer *peer, | |||
2670 | GNUNET_break (GNUNET_NO != c->destroy); | 2670 | GNUNET_break (GNUNET_NO != c->destroy); |
2671 | return; | 2671 | return; |
2672 | } | 2672 | } |
2673 | GCT_handle_encrypted (c->t, &msg->header); | 2673 | GCT_handle_encrypted (c->t, msg); |
2674 | GCC_send_ack (c, fwd, GNUNET_NO); | 2674 | GCC_send_ack (c, fwd, GNUNET_NO); |
2675 | GCC_check_connections (); | 2675 | GCC_check_connections (); |
2676 | return; | 2676 | return; |
@@ -3275,7 +3275,7 @@ GCC_send_prebuilt_message (const struct GNUNET_MessageHeader *message, | |||
3275 | GC_f2s(fwd), size); | 3275 | GC_f2s(fwd), size); |
3276 | switch (type) | 3276 | switch (type) |
3277 | { | 3277 | { |
3278 | case GNUNET_MESSAGE_TYPE_CADET_AX: | 3278 | case GNUNET_MESSAGE_TYPE_CADET_ENCRYPTED: |
3279 | LOG (GNUNET_ERROR_TYPE_DEBUG, " Q_N+ %p %u\n", fc, fc->queue_n); | 3279 | LOG (GNUNET_ERROR_TYPE_DEBUG, " Q_N+ %p %u\n", fc, fc->queue_n); |
3280 | LOG (GNUNET_ERROR_TYPE_DEBUG, "last pid sent %u\n", fc->last_pid_sent); | 3280 | LOG (GNUNET_ERROR_TYPE_DEBUG, "last pid sent %u\n", fc->last_pid_sent); |
3281 | LOG (GNUNET_ERROR_TYPE_DEBUG, " ack recv %u\n", fc->last_ack_recv); | 3281 | LOG (GNUNET_ERROR_TYPE_DEBUG, " ack recv %u\n", fc->last_ack_recv); |
@@ -3312,7 +3312,7 @@ GCC_send_prebuilt_message (const struct GNUNET_MessageHeader *message, | |||
3312 | GNUNET_break (0); | 3312 | GNUNET_break (0); |
3313 | LOG (GNUNET_ERROR_TYPE_DEBUG, "queue full: %u/%u\n", | 3313 | LOG (GNUNET_ERROR_TYPE_DEBUG, "queue full: %u/%u\n", |
3314 | fc->queue_n, fc->queue_max); | 3314 | fc->queue_n, fc->queue_max); |
3315 | if (GNUNET_MESSAGE_TYPE_CADET_AX == type) | 3315 | if (GNUNET_MESSAGE_TYPE_CADET_ENCRYPTED == type) |
3316 | { | 3316 | { |
3317 | fc->queue_n--; | 3317 | fc->queue_n--; |
3318 | } | 3318 | } |