diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-10-17 19:43:02 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-10-17 19:43:02 +0000 |
commit | 5c3b8bfb02bbc5745383b4c6ea0be7823ddd9eb5 (patch) | |
tree | 8ec83e810ea1b7963fd96e50bb434043768172e8 /src/transport | |
parent | fc91cb864ded72b193682d15667cc0ccfa8afc81 (diff) | |
download | gnunet-5c3b8bfb02bbc5745383b4c6ea0be7823ddd9eb5.tar.gz gnunet-5c3b8bfb02bbc5745383b4c6ea0be7823ddd9eb5.zip |
add logging to watch for transmission delays within transport service
Diffstat (limited to 'src/transport')
-rw-r--r-- | src/transport/gnunet-service-transport_clients.c | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/src/transport/gnunet-service-transport_clients.c b/src/transport/gnunet-service-transport_clients.c index 3533b5f6d..12a5dc557 100644 --- a/src/transport/gnunet-service-transport_clients.c +++ b/src/transport/gnunet-service-transport_clients.c | |||
@@ -688,6 +688,11 @@ struct SendTransmitContinuationContext | |||
688 | * Peer that was the target. | 688 | * Peer that was the target. |
689 | */ | 689 | */ |
690 | struct GNUNET_PeerIdentity target; | 690 | struct GNUNET_PeerIdentity target; |
691 | |||
692 | /** | ||
693 | * At what time did we receive the message? | ||
694 | */ | ||
695 | struct GNUNET_TIME_Absolute send_time; | ||
691 | }; | 696 | }; |
692 | 697 | ||
693 | 698 | ||
@@ -708,6 +713,27 @@ handle_send_transmit_continuation (void *cls, | |||
708 | { | 713 | { |
709 | struct SendTransmitContinuationContext *stcc = cls; | 714 | struct SendTransmitContinuationContext *stcc = cls; |
710 | struct SendOkMessage send_ok_msg; | 715 | struct SendOkMessage send_ok_msg; |
716 | struct GNUNET_TIME_Relative delay; | ||
717 | |||
718 | delay = GNUNET_TIME_absolute_get_duration (stcc->send_time); | ||
719 | if (delay.rel_value_us > GNUNET_CONSTANTS_LATENCY_WARN.rel_value_us) | ||
720 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, | ||
721 | "It took us %s to send %u/%u bytes to %s (%d)\n", | ||
722 | GNUNET_STRINGS_relative_time_to_string (delay, | ||
723 | GNUNET_YES), | ||
724 | (unsigned int) bytes_payload, | ||
725 | (unsigned int) bytes_on_wire, | ||
726 | GNUNET_i2s (&stcc->target), | ||
727 | success); | ||
728 | else | ||
729 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
730 | "It took us %s to send %u/%u bytes to %s (%d)\n", | ||
731 | GNUNET_STRINGS_relative_time_to_string (delay, | ||
732 | GNUNET_YES), | ||
733 | (unsigned int) bytes_payload, | ||
734 | (unsigned int) bytes_on_wire, | ||
735 | GNUNET_i2s (&stcc->target), | ||
736 | success); | ||
711 | 737 | ||
712 | if (GST_neighbours_test_connected (&stcc->target)) | 738 | if (GST_neighbours_test_connected (&stcc->target)) |
713 | { | 739 | { |
@@ -800,6 +826,7 @@ clients_handle_send (void *cls, | |||
800 | stcc = GNUNET_new (struct SendTransmitContinuationContext); | 826 | stcc = GNUNET_new (struct SendTransmitContinuationContext); |
801 | stcc->target = obm->peer; | 827 | stcc->target = obm->peer; |
802 | stcc->client = client; | 828 | stcc->client = client; |
829 | stcc->send_time = GNUNET_TIME_absolute_get (); | ||
803 | GNUNET_SERVER_client_keep (client); | 830 | GNUNET_SERVER_client_keep (client); |
804 | GST_manipulation_send (&obm->peer, | 831 | GST_manipulation_send (&obm->peer, |
805 | obmm, | 832 | obmm, |