Commit 497eeb51 authored by Juliusz Chroboczek's avatar Juliusz Chroboczek

Rename src->address to src->id.

parent 87e87774
...@@ -894,7 +894,7 @@ dump_tables(FILE *out) ...@@ -894,7 +894,7 @@ dump_tables(FILE *out)
for(i = 0; i < numroutes; i++) { for(i = 0; i < numroutes; i++) {
int id = int id =
routes[i].src->plen != 128 || routes[i].src->plen != 128 ||
memcmp(routes[i].src->prefix, routes[i].src->address, 16) != 0; memcmp(routes[i].src->prefix, routes[i].src->id, 16) != 0;
const unsigned char *nexthop = const unsigned char *nexthop =
memcmp(routes[i].nexthop, routes[i].neigh->address, 16) == 0 ? memcmp(routes[i].nexthop, routes[i].neigh->address, 16) == 0 ?
NULL : routes[i].nexthop; NULL : routes[i].nexthop;
...@@ -903,7 +903,7 @@ dump_tables(FILE *out) ...@@ -903,7 +903,7 @@ dump_tables(FILE *out)
format_prefix(routes[i].src->prefix, routes[i].src->plen), format_prefix(routes[i].src->prefix, routes[i].src->plen),
routes[i].metric, routes[i].refmetric, routes[i].metric, routes[i].refmetric,
id ? "id " : "", id ? "id " : "",
id ? format_address(routes[i].src->address) : "", id ? format_address(routes[i].src->id) : "",
(int)routes[i].seqno, (int)routes[i].seqno,
(int)(now.tv_sec - routes[i].time), (int)(now.tv_sec - routes[i].time),
routes[i].neigh->network->ifname, routes[i].neigh->network->ifname,
......
...@@ -269,7 +269,7 @@ handle_request(struct neighbour *neigh, const unsigned char *prefix, ...@@ -269,7 +269,7 @@ handle_request(struct neighbour *neigh, const unsigned char *prefix,
if(route && if(route &&
(hop_count == 0 || (hop_count == 0 ||
(route->metric < INFINITY && (route->metric < INFINITY &&
(router_hash != hash_id(route->src->address) || (router_hash != hash_id(route->src->id) ||
seqno_compare(seqno, route->seqno) <= 0)))) { seqno_compare(seqno, route->seqno) <= 0)))) {
/* We can satisfy this request straight away. Note that in the /* We can satisfy this request straight away. Note that in the
hop_count=0 case, we do send a recent retraction, in order to hop_count=0 case, we do send a recent retraction, in order to
...@@ -281,7 +281,7 @@ handle_request(struct neighbour *neigh, const unsigned char *prefix, ...@@ -281,7 +281,7 @@ handle_request(struct neighbour *neigh, const unsigned char *prefix,
if(hop_count <= 1) if(hop_count <= 1)
return; return;
if(route && router_hash == hash_id(route->src->address) && if(route && router_hash == hash_id(route->src->id) &&
seqno_minus(seqno, route->seqno) > 100) { seqno_minus(seqno, route->seqno) > 100) {
/* Hopelessly out-of-date */ /* Hopelessly out-of-date */
return; return;
...@@ -594,7 +594,7 @@ message_source_id(struct network *net) ...@@ -594,7 +594,7 @@ message_source_id(struct network *net)
static void static void
really_send_update(struct network *net, really_send_update(struct network *net,
const unsigned char *address, const unsigned char *id,
const unsigned char *prefix, unsigned char plen, const unsigned char *prefix, unsigned char plen,
unsigned short seqno, unsigned short metric) unsigned short seqno, unsigned short metric)
{ {
...@@ -603,7 +603,7 @@ really_send_update(struct network *net, ...@@ -603,7 +603,7 @@ really_send_update(struct network *net,
if(!net->up) if(!net->up)
return; return;
add_metric = output_filter(address, prefix, plen, net->ifindex); add_metric = output_filter(id, prefix, plen, net->ifindex);
if(add_metric < INFINITY) { if(add_metric < INFINITY) {
if(plen >= 96 && v4mapped(prefix)) { if(plen >= 96 && v4mapped(prefix)) {
...@@ -616,25 +616,25 @@ really_send_update(struct network *net, ...@@ -616,25 +616,25 @@ really_send_update(struct network *net,
memcpy(v4route + 12, prefix + 12, 4); memcpy(v4route + 12, prefix + 12, 4);
start_message(net, 48); start_message(net, 48);
sid = message_source_id(net); sid = message_source_id(net);
if(sid == NULL || memcmp(address, sid, 16) != 0) if(sid == NULL || memcmp(id, sid, 16) != 0)
send_message(net, 3, 0xFF, 0, 0, 0xFFFF, address); send_message(net, 3, 0xFF, 0, 0, 0xFFFF, id);
send_message(net, 5, plen - 96, 0, seqno, metric + add_metric, send_message(net, 5, plen - 96, 0, seqno, metric + add_metric,
v4route); v4route);
} else { } else {
if(in_prefix(address, prefix, plen)) { if(in_prefix(id, prefix, plen)) {
send_message(net, 3, plen, 0, seqno, metric, address); send_message(net, 3, plen, 0, seqno, metric, id);
} else { } else {
const unsigned char *sid; const unsigned char *sid;
start_message(net, 48); start_message(net, 48);
sid = message_source_id(net); sid = message_source_id(net);
if(sid == NULL || memcmp(address, sid, 16) != 0) if(sid == NULL || memcmp(id, sid, 16) != 0)
send_message(net, 3, 0xFF, 0, 0, 0xFFFF, address); send_message(net, 3, 0xFF, 0, 0, 0xFFFF, id);
send_message(net, 4, plen, 0, seqno, metric + add_metric, send_message(net, 4, plen, 0, seqno, metric + add_metric,
prefix); prefix);
} }
} }
} }
satisfy_request(prefix, plen, seqno, hash_id(address), net); satisfy_request(prefix, plen, seqno, hash_id(id), net);
} }
void void
...@@ -672,7 +672,7 @@ flushupdates(void) ...@@ -672,7 +672,7 @@ flushupdates(void)
continue; continue;
seqno = route->seqno; seqno = route->seqno;
metric = route->metric; metric = route->metric;
really_send_update(net, route->src->address, really_send_update(net, route->src->id,
route->src->prefix, route->src->prefix,
route->src->plen, route->src->plen,
seqno, metric); seqno, metric);
...@@ -682,7 +682,7 @@ flushupdates(void) ...@@ -682,7 +682,7 @@ flushupdates(void)
src = find_recent_source(buffered_updates[i].prefix, src = find_recent_source(buffered_updates[i].prefix,
buffered_updates[i].plen); buffered_updates[i].plen);
if(src) { if(src) {
really_send_update(net, src->address, src->prefix, src->plen, really_send_update(net, src->id, src->prefix, src->plen,
src->metric >= INFINITY ? src->metric >= INFINITY ?
src->seqno : seqno_plus(src->seqno, 1), src->seqno : seqno_plus(src->seqno, 1),
INFINITY); INFINITY);
...@@ -751,7 +751,7 @@ send_update(struct network *net, int urgent, ...@@ -751,7 +751,7 @@ send_update(struct network *net, int urgent,
if(route) { if(route) {
urgent = 1; urgent = 1;
satisfy_request(prefix, plen, route->seqno, satisfy_request(prefix, plen, route->seqno,
hash_id(route->src->address), net); hash_id(route->src->id), net);
} }
} }
} }
......
...@@ -214,17 +214,17 @@ change_route_metric(struct route *route, int newmetric) ...@@ -214,17 +214,17 @@ change_route_metric(struct route *route, int newmetric)
int int
route_feasible(struct route *route) route_feasible(struct route *route)
{ {
return update_feasible(route->src->address, return update_feasible(route->src->id,
route->src->prefix, route->src->plen, route->src->prefix, route->src->plen,
route->seqno, route->refmetric); route->seqno, route->refmetric);
} }
int int
update_feasible(const unsigned char *a, update_feasible(const unsigned char *id,
const unsigned char *p, unsigned char plen, const unsigned char *p, unsigned char plen,
unsigned short seqno, unsigned short refmetric) unsigned short seqno, unsigned short refmetric)
{ {
struct source *src = find_source(a, p, plen, 0, 0); struct source *src = find_source(id, p, plen, 0, 0);
if(src == NULL) if(src == NULL)
return 1; return 1;
...@@ -404,9 +404,9 @@ update_route(const unsigned char *a, const unsigned char *p, unsigned char plen, ...@@ -404,9 +404,9 @@ update_route(const unsigned char *a, const unsigned char *p, unsigned char plen,
debugf("Unfeasible update for installed route to %s " debugf("Unfeasible update for installed route to %s "
"(%s %d %d -> %s %d %d).\n", "(%s %d %d -> %s %d %d).\n",
format_prefix(src->prefix, src->plen), format_prefix(src->prefix, src->plen),
format_address(route->src->address), format_address(route->src->id),
route->seqno, route->refmetric, route->seqno, route->refmetric,
format_address(src->address), seqno, refmetric); format_address(src->id), seqno, refmetric);
uninstall_route(route); uninstall_route(route);
lost = 1; lost = 1;
} }
...@@ -477,7 +477,7 @@ send_unfeasible_request(struct neighbour *neigh, ...@@ -477,7 +477,7 @@ send_unfeasible_request(struct neighbour *neigh,
send_request_resend(neigh, prefix, plen, send_request_resend(neigh, prefix, plen,
src->metric >= INFINITY ? src->metric >= INFINITY ?
src->seqno : seqno_plus(src->seqno, 1), src->seqno : seqno_plus(src->seqno, 1),
hash_id(src->address)); hash_id(src->id));
} }
} }
...@@ -552,7 +552,7 @@ send_triggered_update(struct route *route, struct source *oldsrc, int oldmetric) ...@@ -552,7 +552,7 @@ send_triggered_update(struct route *route, struct source *oldsrc, int oldmetric)
/* Make sure that requests are satisfied speedily */ /* Make sure that requests are satisfied speedily */
if(unsatisfied_request(route->src->prefix, route->src->plen, if(unsatisfied_request(route->src->prefix, route->src->plen,
route->seqno, hash_id(route->src->address))) route->seqno, hash_id(route->src->id)))
urgent = 1; urgent = 1;
if(urgent || if(urgent ||
...@@ -567,7 +567,7 @@ send_triggered_update(struct route *route, struct source *oldsrc, int oldmetric) ...@@ -567,7 +567,7 @@ send_triggered_update(struct route *route, struct source *oldsrc, int oldmetric)
route->src->metric >= INFINITY ? route->src->metric >= INFINITY ?
route->src->seqno : route->src->seqno :
seqno_plus(route->src->seqno, 1), seqno_plus(route->src->seqno, 1),
hash_id(route->src->address)); hash_id(route->src->id));
} else if(newmetric >= oldmetric + 288) { } else if(newmetric >= oldmetric + 288) {
/* Ensure that the update goes out before the request */ /* Ensure that the update goes out before the request */
flushupdates(); flushupdates();
...@@ -618,7 +618,7 @@ route_lost(struct source *src, int oldmetric) ...@@ -618,7 +618,7 @@ route_lost(struct source *src, int oldmetric)
send_request_resend(NULL, src->prefix, src->plen, send_request_resend(NULL, src->prefix, src->plen,
src->metric >= INFINITY ? src->metric >= INFINITY ?
src->seqno : seqno_plus(src->seqno, 1), src->seqno : seqno_plus(src->seqno, 1),
hash_id(src->address)); hash_id(src->id));
} }
} }
......
...@@ -49,7 +49,7 @@ void uninstall_route(struct route *route); ...@@ -49,7 +49,7 @@ void uninstall_route(struct route *route);
void change_route(struct route *old, struct route *new); void change_route(struct route *old, struct route *new);
void change_route_metric(struct route *route, int newmetric); void change_route_metric(struct route *route, int newmetric);
int route_feasible(struct route *route); int route_feasible(struct route *route);
int update_feasible(const unsigned char *a, int update_feasible(const unsigned char *id,
const unsigned char *p, unsigned char plen, const unsigned char *p, unsigned char plen,
unsigned short seqno, unsigned short refmetric); unsigned short seqno, unsigned short refmetric);
struct route *find_best_route(const unsigned char *prefix, unsigned char plen, struct route *find_best_route(const unsigned char *prefix, unsigned char plen,
......
...@@ -34,7 +34,7 @@ struct source srcs[MAXSRCS]; ...@@ -34,7 +34,7 @@ struct source srcs[MAXSRCS];
int numsrcs = 0; int numsrcs = 0;
struct source * struct source *
find_source(const unsigned char *a, const unsigned char *p, unsigned char plen, find_source(const unsigned char *id, const unsigned char *p, unsigned char plen,
int create, unsigned short seqno) int create, unsigned short seqno)
{ {
struct source *src; struct source *src;
...@@ -45,9 +45,9 @@ find_source(const unsigned char *a, const unsigned char *p, unsigned char plen, ...@@ -45,9 +45,9 @@ find_source(const unsigned char *a, const unsigned char *p, unsigned char plen,
continue; continue;
/* This should really be a hash table. For now, check the /* This should really be a hash table. For now, check the
last byte first. */ last byte first. */
if(srcs[i].address[15] != a[15]) if(srcs[i].id[15] != id[15])
continue; continue;
if(memcmp(srcs[i].address, a, 16) != 0) if(memcmp(srcs[i].id, id, 16) != 0)
continue; continue;
if(source_match(&srcs[i], p, plen)) if(source_match(&srcs[i], p, plen))
return &srcs[i]; return &srcs[i];
...@@ -79,7 +79,7 @@ find_source(const unsigned char *a, const unsigned char *p, unsigned char plen, ...@@ -79,7 +79,7 @@ find_source(const unsigned char *a, const unsigned char *p, unsigned char plen,
} }
src->valid = 1; src->valid = 1;
memcpy(src->address, a, 16); memcpy(src->id, id, 16);
memcpy(src->prefix, p, 16); memcpy(src->prefix, p, 16);
src->plen = plen; src->plen = plen;
src->seqno = seqno; src->seqno = seqno;
......
...@@ -23,7 +23,7 @@ THE SOFTWARE. ...@@ -23,7 +23,7 @@ THE SOFTWARE.
#define SOURCE_GC_TIME 200 #define SOURCE_GC_TIME 200
struct source { struct source {
unsigned char address[16]; unsigned char id[16];
unsigned char prefix[16]; unsigned char prefix[16];
unsigned char plen; unsigned char plen;
unsigned char valid; unsigned char valid;
...@@ -34,7 +34,7 @@ struct source { ...@@ -34,7 +34,7 @@ struct source {
int source_match(struct source *src, int source_match(struct source *src,
const unsigned char *p, unsigned char plen); const unsigned char *p, unsigned char plen);
struct source *find_source(const unsigned char *a, struct source *find_source(const unsigned char *id,
const unsigned char *p, const unsigned char *p,
unsigned char plen, unsigned char plen,
int create, unsigned short seqno); int create, unsigned short seqno);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment