X-Git-Url: https://tinc-vpn.org/git/browse?a=blobdiff_plain;f=src%2Fnode.c;h=dbc5a7eb32152135c1357115814b50fc51e02844;hb=e6b21e1a510691a86dcc1ecdf71a80a7c62ff17f;hp=9281178b582351057d69d7827b11e57cb3e608ff;hpb=ce8775000ab38229a78ecf3dc26bab008ca0f332;p=tinc diff --git a/src/node.c b/src/node.c index 9281178b..dbc5a7eb 100644 --- a/src/node.c +++ b/src/node.c @@ -85,7 +85,8 @@ void free_node(node_t *n) { cipher_close(&n->outcipher); digest_close(&n->outdigest); - event_del(&n->mtuevent); + if(timeout_initialized(&n->mtuevent)) + event_del(&n->mtuevent); if(n->hostname) free(n->hostname); @@ -125,7 +126,7 @@ void node_del(node_t *n) { } node_t *lookup_node(char *name) { - node_t n = {0}; + node_t n = {NULL}; n.name = name; @@ -133,7 +134,7 @@ node_t *lookup_node(char *name) { } node_t *lookup_node_udp(const sockaddr_t *sa) { - node_t n = {0}; + node_t n = {NULL}; n.address = *sa; n.name = NULL; @@ -143,7 +144,7 @@ node_t *lookup_node_udp(const sockaddr_t *sa) { void update_node_udp(node_t *n, const sockaddr_t *sa) { if(n == myself) { - logger(LOG_WARNING, "Trying to update UDP address of myself!\n"); + logger(LOG_WARNING, "Trying to update UDP address of myself!"); return; } @@ -159,7 +160,7 @@ void update_node_udp(node_t *n, const sockaddr_t *sa) { logger(LOG_DEBUG, "UDP address of %s set to %s", n->name, n->hostname); } else { memset(&n->address, 0, sizeof n->address); - n->hostname = 0; + n->hostname = NULL; ifdebug(PROTOCOL) logger(LOG_DEBUG, "UDP address of %s cleared", n->name); } } @@ -179,3 +180,16 @@ bool dump_nodes(connection_t *c) { return send_request(c, "%d %d", CONTROL, REQ_DUMP_NODES); } + +bool dump_traffic(connection_t *c) { + splay_node_t *node; + node_t *n; + + for(node = node_tree->head; node; node = node->next) { + n = node->data; + send_request(c, "%d %d %s %"PRIu64" %"PRIu64" %"PRIu64" %"PRIu64, CONTROL, REQ_DUMP_TRAFFIC, + n->name, n->in_packets, n->in_bytes, n->out_packets, n->out_bytes); + } + + return send_request(c, "%d %d", CONTROL, REQ_DUMP_TRAFFIC); +}