diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-02-12 15:18:37 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-02-12 15:18:37 +0000 |
commit | 9408c72ce1cbc03d7001a778e793359cb94d4798 (patch) | |
tree | cf936e44c2b00a5c51319852a34a3816b664a34f /src/transport/gnunet-service-transport.c | |
parent | b08879fa56e3c3979466650ae07c55ac8873fb28 (diff) | |
download | gnunet-9408c72ce1cbc03d7001a778e793359cb94d4798.tar.gz gnunet-9408c72ce1cbc03d7001a778e793359cb94d4798.zip |
-better stats for KEEPALIVEs
Diffstat (limited to 'src/transport/gnunet-service-transport.c')
-rw-r--r-- | src/transport/gnunet-service-transport.c | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/src/transport/gnunet-service-transport.c b/src/transport/gnunet-service-transport.c index efbd67619..60f942d91 100644 --- a/src/transport/gnunet-service-transport.c +++ b/src/transport/gnunet-service-transport.c | |||
@@ -504,7 +504,7 @@ GST_receive_callback (void *cls, | |||
504 | return ret; | 504 | return ret; |
505 | case GNUNET_MESSAGE_TYPE_TRANSPORT_PING: | 505 | case GNUNET_MESSAGE_TYPE_TRANSPORT_PING: |
506 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 506 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
507 | "Processing `%s' from `%s'\n", "PING", | 507 | "Processing PING from `%s'\n", |
508 | GST_plugins_a2s (address)); | 508 | GST_plugins_a2s (address)); |
509 | if (GNUNET_OK != | 509 | if (GNUNET_OK != |
510 | GST_validation_handle_ping (&address->peer, | 510 | GST_validation_handle_ping (&address->peer, |
@@ -520,7 +520,7 @@ GST_receive_callback (void *cls, | |||
520 | break; | 520 | break; |
521 | case GNUNET_MESSAGE_TYPE_TRANSPORT_PONG: | 521 | case GNUNET_MESSAGE_TYPE_TRANSPORT_PONG: |
522 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, | 522 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
523 | "Processing `%s' from `%s'\n", "PONG", | 523 | "Processing PONG from `%s'\n", |
524 | GST_plugins_a2s (address)); | 524 | GST_plugins_a2s (address)); |
525 | if (GNUNET_OK != GST_validation_handle_pong (&address->peer, message)) | 525 | if (GNUNET_OK != GST_validation_handle_pong (&address->peer, message)) |
526 | { | 526 | { |
@@ -572,13 +572,16 @@ GST_receive_callback (void *cls, | |||
572 | } | 572 | } |
573 | break; | 573 | break; |
574 | case GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_DISCONNECT: | 574 | case GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_DISCONNECT: |
575 | GST_neighbours_handle_disconnect_message (&address->peer, message); | 575 | GST_neighbours_handle_disconnect_message (&address->peer, |
576 | message); | ||
576 | break; | 577 | break; |
577 | case GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_KEEPALIVE: | 578 | case GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_KEEPALIVE: |
578 | GST_neighbours_keepalive (&address->peer, message); | 579 | GST_neighbours_keepalive (&address->peer, |
580 | message); | ||
579 | break; | 581 | break; |
580 | case GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_KEEPALIVE_RESPONSE: | 582 | case GNUNET_MESSAGE_TYPE_TRANSPORT_SESSION_KEEPALIVE_RESPONSE: |
581 | GST_neighbours_keepalive_response (&address->peer, message); | 583 | GST_neighbours_keepalive_response (&address->peer, |
584 | message); | ||
582 | break; | 585 | break; |
583 | default: | 586 | default: |
584 | /* should be payload */ | 587 | /* should be payload */ |
@@ -591,7 +594,7 @@ GST_receive_callback (void *cls, | |||
591 | message); | 594 | message); |
592 | break; | 595 | break; |
593 | } | 596 | } |
594 | end: | 597 | end: |
595 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 598 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
596 | "Allowing receive from peer %s to continue in %s\n", | 599 | "Allowing receive from peer %s to continue in %s\n", |
597 | GNUNET_i2s (&address->peer), | 600 | GNUNET_i2s (&address->peer), |