[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r34601 - gnunet/src/cadet
From: |
gnunet |
Subject: |
[GNUnet-SVN] r34601 - gnunet/src/cadet |
Date: |
Mon, 15 Dec 2014 08:18:08 +0100 |
Author: bartpolot
Date: 2014-12-15 08:18:08 +0100 (Mon, 15 Dec 2014)
New Revision: 34601
Modified:
gnunet/src/cadet/gnunet-service-cadet_peer.c
Log:
- Added correct core request timing info
Modified: gnunet/src/cadet/gnunet-service-cadet_peer.c
===================================================================
--- gnunet/src/cadet/gnunet-service-cadet_peer.c 2014-12-15 07:18:07 UTC
(rev 34600)
+++ gnunet/src/cadet/gnunet-service-cadet_peer.c 2014-12-15 07:18:08 UTC
(rev 34601)
@@ -976,6 +976,7 @@
struct CadetPeer *peer = cls;
struct CadetConnection *c;
struct CadetPeerQueue *queue;
+ struct GNUNET_TIME_Relative core_wait_time;
const struct GNUNET_PeerIdentity *dst_id;
size_t msg_size;
size_t total_size;
@@ -997,6 +998,7 @@
if (NULL == dst || 0 == size)
{
LOG (GNUNET_ERROR_TYPE_DEBUG, "Buffer size 0.\n");
+ peer->tmt_time.abs_value_us = 0;
return 0;
}
@@ -1005,8 +1007,13 @@
if (NULL == queue)
{
GNUNET_break (0); /* Core tmt_rdy should've been canceled */
+ peer->tmt_time.abs_value_us = 0;
return 0;
}
+ core_wait_time = GNUNET_TIME_absolute_get_duration (peer->tmt_time);
+ LOG (GNUNET_ERROR_TYPE_DEBUG, " core wait time %s\n",
+ GNUNET_STRINGS_relative_time_to_string (core_wait_time, GNUNET_NO));
+ peer->tmt_time.abs_value_us = 0;
while (NULL != queue && rest >= queue->size)
{
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r34601 - gnunet/src/cadet,
gnunet <=