2 protocol_node.c -- handle the meta-protocol, nodes
3 Copyright (C) 1999-2002 Ivo Timmermans <ivo@o2w.nl>,
4 2000-2002 Guus Sliepen <guus@sliepen.eu.org>
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 2 of the License, or
9 (at your option) any later version.
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with this program; if not, write to the Free Software
18 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20 $Id: protocol_node.c,v 1.1.4.1 2002/09/02 22:40:42 guus Exp $
41 #include "connection.h"
46 int send_add_node(connection_t *c, node_t *n)
51 sockaddr2str(&n->address, &address, &port);
52 x = send_request(c, "%d %s %s %s %lx %d", ADD_NODE,
53 n->name, address, port,
54 n->options, n->distance + 1);
61 int add_node_h(connection_t *c)
65 char name[MAX_STRING_SIZE];
66 char address[MAX_STRING_SIZE];
67 char port[MAX_STRING_SIZE];
72 if(sscanf(c->buffer, "%*d "MAX_STRING" "MAX_STRING" "MAX_STRING" %lx %d",
73 name, address, port, &options, &distance) != 5)
75 syslog(LOG_ERR, _("Got bad %s from %s (%s)"), "ADD_NODE", c->name, c->hostname);
79 /* Check if names are valid */
83 syslog(LOG_ERR, _("Got bad %s from %s (%s): %s"), "ADD_NODE", c->name, c->hostname, _("invalid name"));
89 n = lookup_node(name);
93 // It's a new node. Add it and tell the others.
95 n->name = xstrdup(name);
96 n->address = str2sockaddr(address, port);
97 n->hostname = sockaddr2hostname(&n->address);
99 n->distance = distance;
100 n->nexthop = c->node;
105 // If this ADD_NODE is closer or more direct, use it instead of the old one.
106 if((n->options & OPTION_INDIRECT) && !(options & OPTION_INDIRECT) || n->distance > distance)
109 n->address = str2sockaddr(address, port);
110 n->hostname = sockaddr2hostname(&n->address);
111 n->options = options;
112 n->distance = distance;
113 n->nexthop = c->node;
116 // Otherwise, just ignore it.
120 /* Tell the rest about the new node */
122 for(node = connection_tree->head; node; node = node->next)
124 other = (connection_t *)node->data;
125 if(other->status.active && other != c)
126 send_add_node(other, n);
133 int send_del_node(connection_t *c, node_t *n)
136 return send_request(c, "%d %s", DEL_NODE, n->name);
139 int del_node_h(connection_t *c)
141 char name[MAX_STRING_SIZE];
146 if(sscanf(c->buffer, "%*d "MAX_STRING, name) != 1)
148 syslog(LOG_ERR, _("Got bad %s from %s (%s)"), "DEL_NODE",
149 c->name, c->hostname);
153 /* Check if names are valid */
157 syslog(LOG_ERR, _("Got bad %s from %s (%s): %s"), "DEL_NODE", c->name, c->hostname, _("invalid name"));
163 n = lookup_node(name);
167 if(debug_lvl >= DEBUG_PROTOCOL)
168 syslog(LOG_WARNING, _("Got %s from %s (%s) which does not appear in the node tree"), "DEL_NODE", c->name, c->hostname);
172 /* If we got a DEL_NODE but we know of a different route to it, tell the one who send the DEL_NODE */
174 if(n->nexthop != c->node)
176 return send_add_node(c, n);
179 /* Otherwise, tell the rest about the deleted node */
181 for(node = connection_tree->head; node; node = node->next)
183 other = (connection_t *)node->data;
184 if(other->status.active && other != c)
185 send_del_node(other, n);
188 /* Delete the node */