/* * BIRD -- OSPF * * (c) 1999 Ondrej Filip <feela@network.cz> * * Can be freely distributed and used under the terms of the GNU GPL. */ #include "ospf.h" static int ospf_start(struct proto *p) { struct proto_ospf *po=(struct proto_ospf *)p; debug("%s: Start\n",p->name); fib_init(&po->efib,p->pool,sizeof(struct extfib),16,init_efib); init_list(&(po->iface_list)); init_list(&(po->area_list)); po->areano=0; return PS_UP; } static void ospf_dump(struct proto *p) { char areastr[20]; struct ospf_iface *ifa; struct ospf_neighbor *n; struct ospf_config *c = (void *) p->cf; struct proto_ospf *po=(struct proto_ospf *)p; struct ospf_area *oa; debug("%s: Area number: %d\n", p->name, po->areano); WALK_LIST(ifa, po->iface_list) { debug("%s: Interface: %s\n", p->name, ifa->iface->name); debug("%s: state: %u\n", p->name, ifa->state); debug("%s: DR: %I\n", p->name, ifa->drid); debug("%s: BDR: %I\n", p->name, ifa->bdrid); WALK_LIST(n, ifa->neigh_list) { debug("%s: neighbor %I in state %u\n", p->name, n->rid, n->state); } } WALK_LIST(NODE oa,po->area_list) { debug("\n%s: LSA graph dump for area \"%I\" start:\n", p->name,oa->areaid); ospf_top_dump(oa->gr); debug("%s: LSA graph dump for area \"%I\" finished\n\n", p->name, oa->areaid); } neigh_dump_all(); } static struct proto * ospf_init(struct proto_config *c) { struct proto *p = proto_new(c, sizeof(struct proto_ospf)); struct proto_ospf *po=(struct proto_ospf *)p; debug("OSPF: Init requested.\n"); p->import_control = ospf_import_control; p->make_tmp_attrs = ospf_make_tmp_attrs; p->store_tmp_attrs = ospf_store_tmp_attrs; p->rt_notify = ospf_rt_notify; p->if_notify = ospf_if_notify; p->rte_better = ospf_rte_better; p->rte_same = ospf_rte_same; return p; } /* If new is better return 1 */ static int ospf_rte_better(struct rte *new, struct rte *old) { struct proto *p = new->attrs->proto; if(new->u.ospf.metric1=LSINFINITY) return 0; if(((new->attrs->source==RTS_OSPF) || (new->attrs->source==RTS_OSPF_IA)) && (old->attrs->source==RTS_OSPF_EXT)) return 1; if(((old->attrs->source==RTS_OSPF) || (old->attrs->source==RTS_OSPF_IA)) && (new->attrs->source==RTS_OSPF_EXT)) return 0; if(new->u.ospf.metric2!=0) { if(old->u.ospf.metric2==0) return 0; if(new->u.ospf.metric2<old->u.ospf.metric2) return 1; return 0; } else { if(old->u.ospf.metric2!=0) return 1; if(new->u.ospf.metric1<old->u.ospf.metric1) return 1; return 0; } } static int ospf_rte_same(struct rte *new, struct rte *old) { /* new->attrs == old->attrs always */ return new->u.ospf.metric1 == old->u.ospf.metric1 && new->u.ospf.metric2 == old->u.ospf.metric2 && new->u.ospf.tag == old->u.ospf.tag; } static ea_list * ospf_build_attrs(ea_list *next, struct linpool *pool, u32 m1, u32 m2, u32 tag) { struct ea_list *l = lp_alloc(pool, sizeof(struct ea_list) + 3*sizeof(eattr)); l->next = next; l->flags = EALF_SORTED; l->count = 3; l->attrs[0].id = EA_OSPF_METRIC1; l->attrs[0].flags = 0; l->attrs[0].type = EAF_TYPE_INT | EAF_TEMP; l->attrs[0].u.data = m1; l->attrs[1].id = EA_OSPF_METRIC2; l->attrs[1].flags = 0; l->attrs[1].type = EAF_TYPE_INT | EAF_TEMP; l->attrs[1].u.data = m2; l->attrs[2].id = EA_OSPF_TAG; l->attrs[2].flags = 0; l->attrs[2].type = EAF_TYPE_INT | EAF_TEMP; l->attrs[2].u.data = tag; return l; } void schedule_rt_lsa(struct ospf_area *oa) { struct proto_ospf *po=oa->po; struct proto *p=&po->proto; debug("%s: Scheduling RT lsa origination for area %I.\n", p->name, oa->areaid); oa->origrt=1; } void schedule_rtcalc(struct ospf_area *oa) { struct proto_ospf *po=oa->po; struct proto *p=&po->proto; debug("%s: Scheduling RT calculation for area %I.\n", p->name, oa->areaid); oa->calcrt=1; } void area_disp(timer *timer) { struct ospf_area *oa=timer->data; struct top_hash_entry *en,*nxt; /* First of all try to age LSA DB */ ospf_age(oa); /* Now try to originage rt_lsa */ if(oa->origrt) originate_rt_lsa(oa); oa->origrt=0; if(oa->calcrt) ospf_rt_spfa(oa); oa->calcrt=0; } int ospf_import_control(struct proto *p, rte **new, ea_list **attrs, struct linpool *pool) { rte *e=*new; struct proto_ospf *po=(struct proto_ospf *)p; if(p==e->attrs->proto) return -1; /* Reject our own routes */ *attrs = ospf_build_attrs(*attrs, pool, 0, 0, 0); /* FIXME: Use better defaults? */ return 0; /* Leave decision to the filters */ } struct ea_list * ospf_make_tmp_attrs(struct rte *rt, struct linpool *pool) { return ospf_build_attrs(NULL, pool, rt->u.ospf.metric1, rt->u.ospf.metric2, rt->u.ospf.tag); } void ospf_store_tmp_attrs(struct rte *rt, struct ea_list *attrs) { rt->u.ospf.metric1 = ea_get_int(attrs, EA_OSPF_METRIC1, 0); rt->u.ospf.metric2 = ea_get_int(attrs, EA_OSPF_METRIC2, 0); rt->u.ospf.tag = ea_get_int(attrs, EA_OSPF_TAG, 0); } static int ospf_shutdown(struct proto *p) { struct proto_ospf *po=(struct proto_ospf *)p; struct ospf_iface *ifa; struct ospf_neighbor *n; struct ospf_area *oa; debug("%s: Shutdown requested\n", p->name); /* And send to all my neighbors 1WAY */ WALK_LIST(ifa, po->iface_list) { init_list(&ifa->neigh_list); hello_timer_hook(ifa->hello_timer); } return PS_DOWN; } void ospf_rt_notify(struct proto *p, net *n, rte *new, rte *old, ea_list *attrs) { struct proto_ospf *po=(struct proto_ospf *)p; debug("%s: Got route %I/%d %s\n", p->name, n->n.prefix, n->n.pxlen, new ? "up" : "down"); if(new) /* Got some new route */ { originate_ext_lsa(n, new, po, attrs); } else { u32 rtid=po->proto.cf->global->router_id; struct ospf_area *oa; struct top_hash_entry *en; /* Flush old external LSA */ WALK_LIST(oa, po->area_list) { if(en=ospf_hash_find(oa->gr, ipa_to_u32(n->n.prefix), rtid, LSA_T_EXT)) net_flush_lsa(en,po,oa); } } } static void ospf_get_status(struct proto *p, byte *buf) { struct proto_ospf *po=(struct proto_ospf *)p; if (p->proto_state == PS_DOWN) buf[0] = 0; else { struct ospf_iface *ifa; struct ospf_neighbor *n; int adj=0; WALK_LIST(ifa,po->iface_list) WALK_LIST(n,ifa->neigh_list) if(n->state==NEIGHBOR_FULL) adj=1; if(adj==0) strcpy(buf, "Alone"); else strcpy(buf, "Running"); } } static void ospf_get_route_info(rte *rte, byte *buf, ea_list *attrs) { char met=' '; char type=' '; if(rte->attrs->source==RTS_OSPF_EXT) { met='1'; type='E'; } if(rte->u.ospf.metric2!=LSINFINITY) met='2'; if(rte->attrs->source==RTS_OSPF_IA) type='A'; if(rte->attrs->source==RTS_OSPF) type='I'; buf += bsprintf(buf, " %c", type); if(met!=' ') buf += bsprintf(buf, "%c", met); buf += bsprintf(buf, " (%d/%d)", rte->pref, (rte->u.ospf.metric2==LSINFINITY) ? rte->u.ospf.metric1 : rte->u.ospf.metric2); if(rte->attrs->source==RTS_OSPF_EXT && rte->u.ospf.tag) { buf += bsprintf(buf, " [%x]", rte->u.ospf.tag); } } static int ospf_get_attr(eattr *a, byte *buf) { switch (a->id) { case EA_OSPF_METRIC1: bsprintf(buf, "metric1"); return GA_NAME; case EA_OSPF_METRIC2: bsprintf(buf, "metric2"); return GA_NAME; case EA_OSPF_TAG: bsprintf(buf, "tag: %08x", a->u.data); return GA_FULL; default: return GA_UNKNOWN; } } struct protocol proto_ospf = { name: "OSPF", template: "ospf%d", attr_class: EAP_OSPF, init: ospf_init, dump: ospf_dump, start: ospf_start, shutdown: ospf_shutdown, get_route_info: ospf_get_route_info, get_attr: ospf_get_attr, get_status: ospf_get_status }; void ospf_sh_neigh(struct proto *p, char *iff) { struct ospf_iface *ifa=NULL,*f; struct ospf_neighbor *n; struct proto_ospf *po=(struct proto_ospf *)p; if(iff!=NULL) { WALK_LIST(f, po->iface_list) { if(strcmp(iff,f->iface->name)==0) ifa=f; break; } if(ifa==NULL) { cli_msg(0,""); return; } cli_msg(-1013,"%s:", p->name); cli_msg(-1013,"%-12s\t%3s\t%-15s\t%-5s\t%-12s\t%-10s","Router ID","Pri", " State", "DTime", "Router IP", "Interface"); WALK_LIST(n, ifa->neigh_list) ospf_sh_neigh_info(n); cli_msg(0,""); } cli_msg(-1013,"%s:", p->name); cli_msg(-1013,"%-12s\t%3s\t%-15s\t%-5s\t%-12s\t%-10s","Router ID","Pri", " State", "DTime", "Router IP", "Interface"); WALK_LIST(ifa,po->iface_list) WALK_LIST(n, ifa->neigh_list) ospf_sh_neigh_info(n); cli_msg(0,""); } void ospf_sh(struct proto *p) { struct ospf_area *oa; struct proto_ospf *po=(struct proto_ospf *)p; struct ospf_iface *ifa; struct ospf_neighbor *n; int ifano; int nno; int adjno; cli_msg(-1014,"%s:", p->name); cli_msg(-1014,"Number of areas: %u", po->areano); WALK_LIST(oa,po->area_list) { cli_msg(-1014,"\tArea: %I (%u) %s", oa->areaid, oa->areaid, oa->areaid==0 ? "[BACKBONE]" : ""); ifano=0; nno=0; adjno=0; WALK_LIST(ifa, po->iface_list) { if(oa==ifa->oa) ifano++; WALK_LIST(n, ifa->neigh_list) { nno++; if(n->state==NEIGHBOR_FULL) adjno++; } } cli_msg(-1014,"\t\tNumber of interfaces: %u", ifano); cli_msg(-1014,"\t\tNumber of LSAs: %u", oa->gr->hash_entries); cli_msg(-1014,"\t\tNumber of neighbors: %u", nno); cli_msg(-1014,"\t\tNumber of fully adjacent neighbors: %u", adjno); } cli_msg(0,""); } void ospf_sh_iface(struct proto *p, char *iff) { struct ospf_area *oa; struct proto_ospf *po=(struct proto_ospf *)p; struct ospf_iface *ifa=NULL,*f; struct ospf_neighbor *n; int ifano; int nno; int adjno; if(iff!=NULL) { WALK_LIST(f, po->iface_list) { if(strcmp(iff,f->iface->name)==0) ifa=f; break; } if(ifa==NULL) { cli_msg(0,""); return; } cli_msg(-1015,"%s:", p->name); ospf_iface_info(ifa); cli_msg(0,""); return; } cli_msg(-1015,"%s:", p->name); WALK_LIST(ifa, po->iface_list) ospf_iface_info(ifa); cli_msg(0,""); }