projects
/
oweals
/
gnunet.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
cancel existing last_control_qe handle before scheduling a new one, always
[oweals/gnunet.git]
/
src
/
cadet
/
test_cadet.c
diff --git
a/src/cadet/test_cadet.c
b/src/cadet/test_cadet.c
index b8587d4497495819e761cbfb15e2f411adf76277..f2e639e7a5726c7795a88c111fb13e0b2aea68bf 100644
(file)
--- a/
src/cadet/test_cadet.c
+++ b/
src/cadet/test_cadet.c
@@
-19,7
+19,8
@@
*/
/**
* @file cadet/test_cadet.c
*/
/**
* @file cadet/test_cadet.c
- *
+ * @author Bart Polot
+ * @author Christian Grothoff
* @brief Test for the cadet service: retransmission of traffic.
*/
#include <stdio.h>
* @brief Test for the cadet service: retransmission of traffic.
*/
#include <stdio.h>
@@
-395,7
+396,8
@@
stats_iterator (void *cls,
{
static const char *s_sent = "# keepalives sent";
static const char *s_recv = "# keepalives received";
{
static const char *s_sent = "# keepalives sent";
static const char *s_recv = "# keepalives received";
- static const char *drops = "# messages dropped due to full buffer";
+ static const char *rdrops = "# messages dropped due to full buffer";
+ static const char *cdrops = "# messages dropped due to slow client";
uint32_t i;
i = GNUNET_TESTBED_get_index (peer);
uint32_t i;
i = GNUNET_TESTBED_get_index (peer);
@@
-409,7
+411,9
@@
stats_iterator (void *cls,
ka_sent = value;
if (0 == strncmp(s_recv, name, strlen (s_recv)) && peers_requested - 1 == i)
ka_received = value;
ka_sent = value;
if (0 == strncmp(s_recv, name, strlen (s_recv)) && peers_requested - 1 == i)
ka_received = value;
- if (0 == strncmp(drops, name, strlen (drops)))
+ if (0 == strncmp(rdrops, name, strlen (rdrops)))
+ msg_dropped += value;
+ if (0 == strncmp(cdrops, name, strlen (cdrops)))
msg_dropped += value;
return GNUNET_OK;
msg_dropped += value;
return GNUNET_OK;
@@
-820,8
+824,9
@@
incoming_channel (void *cls,
else
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
else
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Incoming channel for unknown client %lu\n", (long) cls);
- GNUNET_break(0);
+ "Incoming channel for unexpected peer #%lu\n",
+ (long) cls);
+ GNUNET_break (0);
}
if (NULL != disconnect_task)
{
}
if (NULL != disconnect_task)
{