projects
/
oweals
/
gnunet.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (from parent 1:
9b42f77
)
UNIX stats
author
Matthias Wachs
<wachs@net.in.tum.de>
Wed, 26 Sep 2012 13:55:19 +0000
(13:55 +0000)
committer
Matthias Wachs
<wachs@net.in.tum.de>
Wed, 26 Sep 2012 13:55:19 +0000
(13:55 +0000)
src/transport/plugin_transport_unix.c
patch
|
blob
|
history
diff --git
a/src/transport/plugin_transport_unix.c
b/src/transport/plugin_transport_unix.c
index 290640636030e9a6dec2abc40775cc8b68da5c99..c688039e6e80e37369d5101453bc7d3b02f60846 100644
(file)
--- a/
src/transport/plugin_transport_unix.c
+++ b/
src/transport/plugin_transport_unix.c
@@
-788,7
+788,7
@@
unix_plugin_send (void *cls,
GNUNET_CONTAINER_DLL_insert(plugin->msg_head, plugin->msg_tail, wrapper);
plugin->bytes_in_queue += ssize;
GNUNET_CONTAINER_DLL_insert(plugin->msg_head, plugin->msg_tail, wrapper);
plugin->bytes_in_queue += ssize;
- GNUNET_STATISTICS_set (plugin->env->stats,"#
UNIX bytes in send queue
",
+ GNUNET_STATISTICS_set (plugin->env->stats,"#
bytes currently in UNIX buffers
",
plugin->bytes_in_queue, GNUNET_NO);
LOG (GNUNET_ERROR_TYPE_DEBUG, "Sent %d bytes to `%s'\n", ssize,
plugin->bytes_in_queue, GNUNET_NO);
LOG (GNUNET_ERROR_TYPE_DEBUG, "Sent %d bytes to `%s'\n", ssize,
@@
-830,8
+830,10
@@
unix_demultiplexer (struct Plugin *plugin, struct GNUNET_PeerIdentity *sender,
LOG (GNUNET_ERROR_TYPE_DEBUG, "Received message from %s\n",
un->sun_path);
LOG (GNUNET_ERROR_TYPE_DEBUG, "Received message from %s\n",
un->sun_path);
+
+
plugin->bytes_in_recv += ntohs(currhdr->size);
plugin->bytes_in_recv += ntohs(currhdr->size);
- GNUNET_STATISTICS_set (plugin->env->stats,"#
UNIX bytes received
",
+ GNUNET_STATISTICS_set (plugin->env->stats,"#
bytes received via UNIX
",
plugin->bytes_in_recv, GNUNET_NO);
addr = GNUNET_HELLO_address_allocate(sender, "unix", un->sun_path, strlen (un->sun_path) + 1);
plugin->bytes_in_recv, GNUNET_NO);
addr = GNUNET_HELLO_address_allocate(sender, "unix", un->sun_path, strlen (un->sun_path) + 1);
@@
-958,7
+960,7
@@
unix_plugin_select_write (struct Plugin * plugin)
GNUNET_assert (plugin->bytes_in_queue >= msgw->msgsize);
plugin->bytes_in_queue -= msgw->msgsize;
GNUNET_assert (plugin->bytes_in_queue >= msgw->msgsize);
plugin->bytes_in_queue -= msgw->msgsize;
- GNUNET_STATISTICS_set (plugin->env->stats,
"# UNIX bytes in send queue
",
+ GNUNET_STATISTICS_set (plugin->env->stats,
"# bytes currently in UNIX buffers
",
plugin->bytes_in_queue, GNUNET_NO);
plugin->bytes_discarded += msgw->msgsize;
GNUNET_STATISTICS_set (plugin->env->stats,"# UNIX bytes discarded",
plugin->bytes_in_queue, GNUNET_NO);
plugin->bytes_discarded += msgw->msgsize;
GNUNET_STATISTICS_set (plugin->env->stats,"# UNIX bytes discarded",
@@
-976,10
+978,10
@@
unix_plugin_select_write (struct Plugin * plugin)
GNUNET_assert (plugin->bytes_in_queue >= msgw->msgsize);
plugin->bytes_in_queue -= msgw->msgsize;
GNUNET_assert (plugin->bytes_in_queue >= msgw->msgsize);
plugin->bytes_in_queue -= msgw->msgsize;
- GNUNET_STATISTICS_set (plugin->env->stats,"#
UNIX bytes in send queue
",
+ GNUNET_STATISTICS_set (plugin->env->stats,"#
bytes currently in UNIX buffers
",
plugin->bytes_in_queue, GNUNET_NO);
plugin->bytes_in_sent += msgw->msgsize;
plugin->bytes_in_queue, GNUNET_NO);
plugin->bytes_in_sent += msgw->msgsize;
- GNUNET_STATISTICS_set (plugin->env->stats,"#
UNIX bytes sent
",
+ GNUNET_STATISTICS_set (plugin->env->stats,"#
bytes transmitted via UNIX
",
plugin->bytes_in_sent, GNUNET_NO);
GNUNET_free (msgw->msg);
plugin->bytes_in_sent, GNUNET_NO);
GNUNET_free (msgw->msg);