X-Git-Url: https://tinc-vpn.org/git/browse?a=blobdiff_plain;f=src%2Fgraph.c;h=c04cef40e01e48cc8fc67471e6c4c51a903a915f;hb=f02d3ed3e135b5326003e7f69f8331ff6a3cc219;hp=6ad25665772234158475f0caf96845eadc6fd67f;hpb=df3220a1549f992cbf4a9b6e67c1e67b69896c7d;p=tinc diff --git a/src/graph.c b/src/graph.c index 6ad25665..c04cef40 100644 --- a/src/graph.c +++ b/src/graph.c @@ -1,7 +1,7 @@ /* graph.c -- graph algorithms - Copyright (C) 2001-2005 Guus Sliepen , - 2001-2005 Ivo Timmermans + Copyright (C) 2001-2006 Guus Sliepen , + 2001-2005 Ivo Timmermans This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -47,6 +47,7 @@ #include "system.h" #include "avl_tree.h" +#include "config.h" #include "connection.h" #include "device.h" #include "edge.h" @@ -62,8 +63,7 @@ Please note that sorting on weight is already done by add_edge(). */ -void mst_kruskal(void) -{ +void mst_kruskal(void) { avl_node_t *node, *next; edge_t *e; node_t *n; @@ -98,7 +98,13 @@ void mst_kruskal(void) /* Starting point */ - ((edge_t *) edge_weight_tree->head->data)->from->status.visited = true; + for(node = edge_weight_tree->head; node; node = node->next) { + e = node->data; + if(e->from->status.reachable) { + e->from->status.visited = true; + break; + } + } /* Add safe edges */ @@ -140,8 +146,7 @@ void mst_kruskal(void) Running time: O(E) */ -void sssp_bfs(void) -{ +void sssp_bfs(void) { avl_node_t *node, *next, *to; edge_t *e; node_t *n; @@ -283,6 +288,8 @@ void sssp_bfs(void) asprintf(&envp[5], "REMOTEPORT=%s", port); envp[6] = NULL; + execute_script(n->status.reachable ? "host-up" : "host-down", envp); + asprintf(&name, n->status.reachable ? "hosts/%s-up" : "hosts/%s-down", n->name); @@ -300,8 +307,72 @@ void sssp_bfs(void) } } -void graph(void) -{ - mst_kruskal(); +/* Dump nodes and edges to a graphviz file. + + The file can be converted to an image with + dot -Tpng graph_filename -o image_filename.png -Gconcentrate=true +*/ + +static void dump_graph(int fd, short events, void *data) { + avl_node_t *node; + node_t *n; + edge_t *e; + char *filename = NULL, *tmpname = NULL; + FILE *file; + + if(!get_config_string(lookup_config(config_tree, "GraphDumpFile"), &filename)) + return; + + ifdebug(PROTOCOL) logger(LOG_NOTICE, "Dumping graph"); + + if(filename[0] == '|') { + file = popen(filename + 1, "w"); + } else { + asprintf(&tmpname, "%s.new", filename); + file = fopen(tmpname, "w"); + } + + if(!file) { + logger(LOG_ERR, "Unable to open graph dump file %s: %s", filename, strerror(errno)); + free(tmpname); + return; + } + + fprintf(file, "digraph {\n"); + + /* dump all nodes first */ + for(node = node_tree->head; node; node = node->next) { + n = node->data; + fprintf(file, " %s [label = \"%s\"];\n", n->name, n->name); + } + + /* now dump all edges */ + for(node = edge_weight_tree->head; node; node = node->next) { + e = node->data; + fprintf(file, " %s -> %s;\n", e->from->name, e->to->name); + } + + fprintf(file, "}\n"); + + if(filename[0] == '|') { + pclose(file); + } else { + fclose(file); +#ifdef HAVE_MINGW + unlink(filename); +#endif + rename(tmpname, filename); + free(tmpname); + } +} + +void graph(void) { + static struct event ev; + sssp_bfs(); + mst_kruskal(); + + if(!timeout_initialized(&ev)) + timeout_set(&ev, dump_graph, NULL); + event_add(&ev, &(struct timeval){5, 0}); }