aboutsummaryrefslogtreecommitdiff
path: root/src/transport/gnunet-service-transport.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2015-02-12 15:18:37 +0000
committerChristian Grothoff <christian@grothoff.org>2015-02-12 15:18:37 +0000
commit9408c72ce1cbc03d7001a778e793359cb94d4798 (patch)
treecf936e44c2b00a5c51319852a34a3816b664a34f /src/transport/gnunet-service-transport.c
parentb08879fa56e3c3979466650ae07c55ac8873fb28 (diff)
downloadgnunet-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.c15
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),