along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
- $Id: protocol.c,v 1.28.4.113 2001/10/30 12:59:12 guus Exp $
+ $Id: protocol.c,v 1.28.4.116 2001/10/31 20:02:06 guus Exp $
*/
#include "config.h"
syslog(LOG_ERR, _("Peer %s had unknown identity (%s)"), c->hostname, c->name);
return -1;
}
+ }
- if(read_rsa_public_key(c))
- {
- return -1;
- }
+ if(read_rsa_public_key(c))
+ {
+ return -1;
}
c->allow_request = METAKEY;
*/
- /* Create a edge_t for this connection */
+ /* Create an edge_t for this connection */
c->edge = new_edge();
/* Run MST and SSSP algorithms */
mst_kruskal();
- sssp_bfs();
+ sssp_bfs(0);
cp
return 0;
}
if(n)
{
/* Check if it matches */
+
+ if(n->address != address || n->port != port)
+ syslog(LOG_DEBUG, _("Got %s from %s (%s) for %s which does not match existing entry"), "ADD_NODE", c->name, c->hostname, n->name);
+
+ return 0;
}
else
{
if(address != n->address || port != n->port)
{
- syslog(LOG_WARNING, _("Got %s from %s (%s) for %s which doesn't match"), "DEL_NODE", c->name, c->hostname, n->name);
- return 0;
+ syslog(LOG_WARNING, _("Got %s from %s (%s) for %s which does not match existing entry"), "DEL_NODE", c->name, c->hostname, n->name);
}
/* Tell the rest about the deleted node */
/* Delete the node */
node_del(n);
+
+ mst_kruskal();
+ sssp_bfs(0);
cp
return 0;
}
return -1;
}
- /* Check if node already exists */
+ /* Check if edge already exists */
e = lookup_edge(from, to);
if(e)
{
- /* Check if it matches */
+ if(e->weight != weight || e->options != options)
+ {
+ syslog(LOG_ERR, _("Got %s from %s (%s) which does not match existing entry"), "ADD_EDGE", c->name, c->hostname);
+ return -1;
+ }
+
+ return 0;
}
else
{
/* Run MST before or after we tell the rest? */
mst_kruskal();
- sssp_bfs();
+ sssp_bfs(0);
cp
return 0;
}
int send_del_edge(connection_t *c, edge_t *e)
{
cp
- return send_request(c, "%d %s %s %lx", DEL_EDGE,
- e->from->name, e->to->name, e->options);
+ return send_request(c, "%d %s %s %lx %d", DEL_EDGE,
+ e->from->name, e->to->name, e->options, e->weight);
}
int del_edge_h(connection_t *c)
char to_name[MAX_STRING_SIZE];
node_t *from, *to;
long int options;
+ int weight;
connection_t *other;
avl_node_t *node;
cp
- if(sscanf(c->buffer, "%*d "MAX_STRING" "MAX_STRING" %lx", from_name, to_name, &options) != 3)
+ if(sscanf(c->buffer, "%*d "MAX_STRING" "MAX_STRING" %lx %d", from_name, to_name, &options, &weight) != 4)
{
syslog(LOG_ERR, _("Got bad %s from %s (%s)"), "DEL_EDGE",
c->name, c->hostname);
if(e)
{
- /* Check if it matches */
+ if(e->weight != weight || e->options != options)
+ {
+ syslog(LOG_ERR, _("Got %s from %s (%s) which does not match existing entry"), "ADD_EDGE", c->name, c->hostname);
+ return -1;
+ }
}
else
{
/* Run MST before or after we tell the rest? */
mst_kruskal();
- sssp_bfs();
+ sssp_bfs(1);
cp
return 0;
}