plan 9 kernel history: overview | file list | diff list

1999/1029/ip/ipifc.c (diff list | history)

ip/ipifc.c on 1998/0306
1998/0306    
#include "u.h" 
#include "../port/lib.h" 
#include "mem.h" 
#include "dat.h" 
#include "fns.h" 
#include "../port/error.h" 
 
#include "ip.h" 
 
#define DPRINT if(0)print 
 
enum { 
	Maxmedia	= 16, 
	Nself		= Maxmedia*5, 
	NHASH		= (1<<6), 
	NCACHE		= 256, 
	QMAX		= 64*1024-1, 
};
1998/0423    
Medium *media[32] =
1998/0306    
{ 
	0 
}; 
 
/* 
 *  cache of local addresses (addresses we answer to) 
 */ 
typedef struct Ipself Ipself; 
struct Ipself 
{ 
	uchar	a[IPaddrlen]; 
	Ipself	*hnext;		/* next address in the hash table */ 
	Iplink	*link;		/* binding twixt Ipself and Ipifc */ 
	ulong	expire; 
	uchar	type;		/* type of address */ 
	int	ref; 
	Ipself	*next;		/* free list */ 
}; 
 
struct Ipselftab 
{ 
	QLock; 
	int	inited; 
	int	acceptall;	/* true if an interface has the null address */ 
	Ipself	*hash[NHASH];	/* hash chains */ 
}; 
 
/* 
 *  Multicast addresses are chained onto a Chan so that 
 *  we can remove them when the Chan is closed. 
 */ 
typedef struct Ipmcast Ipmcast; 
struct Ipmcast 
{ 
	Ipmcast	*next; 
	uchar	ma[IPaddrlen];	/* multicast address */ 
	uchar	ia[IPaddrlen];	/* interface address */ 
}; 
 
/* quick hash for ip addresses */ 
#define hashipa(a) ( ( ((a)[IPaddrlen-2]<<8) | (a)[IPaddrlen-1] )%NHASH ) 
 
static char tifc[] = "ifc ";
1998/0313    
static void	addselfcache(Fs *f, Ipifc *ifc, Iplifc *lifc, uchar *a, int type); 
static void	remselfcache(Fs *f, Ipifc *ifc, Iplifc *lifc, uchar *a);
1998/0306    
static char*	ipifcjoinmulti(Ipifc *ifc, char **argv, int argc); 
static char*	ipifcleavemulti(Ipifc *ifc, char **argv, int argc);
1999/0731    
static void	ipifcregisterproxy(Fs*, Ipifc*, uchar*);
1998/0423    
 
/* 
 *  link in a new medium 
 */ 
void 
addipmedium(Medium *med) 
{ 
	int i; 
 
	for(i = 0; i < nelem(media)-1; i++) 
		if(media[i] == nil){ 
			media[i] = med; 
			break; 
		} 
}
1998/0306    
 
/* 
 *  find the medium with this name 
 */ 
Medium* 
ipfindmedium(char *name) 
{ 
	Medium **mp; 
 
	for(mp = media; *mp != nil; mp++) 
		if(strcmp((*mp)->name, name) == 0) 
			break; 
	return *mp; 
} 
 
/* 
 *  attach a device (or pkt driver) to the interface. 
 *  called with c->car locked 
 */ 
static char* 
ipifcbind(Conv *c, char **argv, int argc) 
{ 
	Ipifc *ifc; 
	Medium *m; 
 
	if(argc < 2) 
		return Ebadarg; 
 
	ifc = (Ipifc*)c->ptcl; 
 
	/* bind the device to the interface */ 
	m = ipfindmedium(argv[1]); 
	if(m == nil) 
		return "unknown interface type"; 
 
	wlock(ifc); 
	if(ifc->m != nil){ 
		wunlock(ifc); 
		return "interface already bound";	 
	} 
	if(waserror()){ 
		wunlock(ifc); 
		nexterror(); 
	} 
 
	(*m->bind)(ifc, argc, argv); 
	if(argc > 2) 
		strncpy(ifc->dev, argv[2], sizeof(ifc->dev)); 
	else 
		sprint(ifc->dev, "%s%d", m->name, c->x); 
	ifc->dev[sizeof(ifc->dev)-1] = 0; 
	ifc->m = m; 
	ifc->minmtu = ifc->m->minmtu; 
	ifc->maxmtu = ifc->m->maxmtu;
1998/0709    
	if(ifc->m->unbindonclose == 0){
1999/0302    
		qlock(ifc->conv);
1998/0709    
		ifc->conv->inuse++;
1999/0302    
		qunlock(ifc->conv);
1998/0709    
	}
1998/0306    
	ifc->ifcid++; 
 
	wunlock(ifc); 
	poperror(); 
 
	return nil; 
} 
 
/* 
 *  detach a device from an interface, close the interface 
 */ 
static char* 
ipifcunbind(Ipifc *ifc) 
{ 
	char *av[4]; 
	char ip[32]; 
	char mask[32]; 
 
	if(waserror()){ 
		wunlock(ifc); 
		nexterror(); 
	} 
	wlock(ifc);
1998/0307    
	/* dissociate routes */
1998/0709    
	if(ifc->m != nil && ifc->m->unbindonclose == 0){
1999/0302    
		qlock(ifc->conv);
1998/0709    
		ifc->conv->inuse--;
1999/0302    
		qunlock(ifc->conv);
1998/0709    
	}
1998/0307    
	ifc->ifcid++;
1998/0306    
1998/0307    
	/* disassociate device */
1998/0709    
	if(ifc->m != nil && ifc->m->unbind) 
		(*ifc->m->unbind)(ifc);
1998/0307    
	memset(ifc->dev, 0, sizeof(ifc->dev)); 
	ifc->arg = nil;
1998/0306    
	/* hangup queues to stop queuing of packets */ 
	qhangup(ifc->conv->rq, "unbind"); 
	qhangup(ifc->conv->wq, "unbind"); 
 
	/* disassociate logical interfaces */ 
	av[0] = "remove"; 
	av[1] = ip; 
	av[2] = mask; 
	av[3] = 0; 
	while(ifc->lifc){ 
		sprint(ip, "%I", ifc->lifc->local); 
		sprint(mask, "%M", ifc->lifc->mask); 
		ipifcrem(ifc, av, 3, 0); 
	}
1998/0307    
	ifc->m = nil;
1998/0306    
	wunlock(ifc); 
	poperror(); 
	return nil; 
} 
 
static int 
ipifcstate(Conv *c, char *state, int n) 
{ 
	Ipifc *ifc; 
	Iplifc *lifc; 
	int m; 
 
	ifc = (Ipifc*)c->ptcl;
1999/0223    
	m = snprint(state, n, "%-12s %-5d", ifc->dev, ifc->maxmtu);
1998/0709    
1998/0306    
	rlock(ifc);
1998/0717    
	for(lifc = ifc->lifc; lifc && n > m; lifc = lifc->next)
1998/0306    
		m += snprint(state+m, n - m,
1998/0825    
			" %-20.20I %-20.20M %-20.20I %-7lud %-7lud %-7lud %-7lud\n",
1998/0306    
				lifc->local, lifc->mask, lifc->remote, 
				ifc->in, ifc->out, ifc->inerr, ifc->outerr);
1998/1005    
	if(ifc->lifc == nil) 
		m += snprint(state+m, n - m, "\n");
1998/0306    
	runlock(ifc); 
	return m; 
} 
 
static int 
ipifclocal(Conv *c, char *state, int n) 
{ 
	Ipifc *ifc; 
	Iplifc *lifc; 
	Iplink *link; 
	int m; 
 
	ifc = (Ipifc*)c->ptcl; 
 
	m = 0; 
 
	rlock(ifc); 
	for(lifc = ifc->lifc; lifc; lifc = lifc->next){ 
		m += snprint(state+m, n - m, "%-20.20I ->", lifc->local); 
		for(link = lifc->link; link; link = link->lifclink)
1998/0307    
			m += snprint(state+m, n - m, " %-20.20I", link->self->a);
1998/0306    
		m += snprint(state+m, n - m, "\n"); 
	} 
	runlock(ifc); 
	return m; 
} 
 
static int 
ipifcinuse(Conv *c) 
{ 
	Ipifc *ifc; 
 
	ifc = (Ipifc*)c->ptcl; 
	return ifc->m != nil; 
} 
 
/* 
 *  called when a process writes to an interface's 'data' 
 */ 
static void 
ipifckick(Conv *c, int) 
{ 
	Block *bp; 
	Ipifc *ifc; 
 
	bp = qget(c->wq); 
	if(bp == nil) 
		return; 
 
	ifc = (Ipifc*)c->ptcl; 
	if(ifc->m == nil || ifc->m->pktin == nil) 
		freeb(bp); 
	else
1998/0313    
		(*ifc->m->pktin)(c->p->f, ifc, bp);
1998/0306    
} 
 
/* 
 *  we'll have to have a kick routine at 
 *  some point to deal with these 
 */ 
static void 
ipifccreate(Conv *c) 
{ 
	Ipifc *ifc; 
 
	c->rq = qopen(QMAX, 0, 0, 0); 
	c->wq = qopen(QMAX, 0, 0, 0); 
	ifc = (Ipifc*)c->ptcl; 
	ifc->conv = c;
1998/0307    
	ifc->unbinding = 0; 
	ifc->m = nil;
1998/0306    
} 
 
/*  
 *  called after last close of ipifc data or ctl 
 *  called with c locked, we must unlock 
 */ 
static void 
ipifcclose(Conv *c) 
{
1998/0307    
	Ipifc *ifc; 
	Medium *m; 
 
	ifc = (Ipifc*)c->ptcl; 
	m = ifc->m;
1998/0516    
	if(m != nil && m->unbindonclose)
1998/0307    
		ipifcunbind(ifc);
1999/0302    
	qunlock(c);
1998/0306    
} 
 
/*
1998/0330    
 *  change an interface's mtu 
 */ 
char* 
ipifcsetmtu(Ipifc *ifc, char **argv, int argc) 
{ 
	int mtu; 
 
	if(argc < 2) 
		return Ebadarg; 
	if(ifc->m == nil) 
		return Ebadarg; 
	mtu = strtoul(argv[1], 0, 0); 
	if(mtu < ifc->m->minmtu || mtu > ifc->m->maxmtu) 
		return Ebadarg; 
	ifc->maxmtu = mtu; 
	return nil; 
} 
 
/*
1998/0306    
 *  add an address to an interface. 
 */ 
char* 
ipifcadd(Ipifc *ifc, char **argv, int argc) 
{ 
	uchar ip[IPaddrlen], mask[IPaddrlen], rem[IPaddrlen]; 
	uchar bcast[IPaddrlen], net[IPaddrlen]; 
	Iplifc *lifc, **l; 
	int i, type, mtu;
1998/0313    
	Fs *f;
1998/0306    
1998/0702    
	if(ifc->m == nil) 
		return "ipifc not yet bound to device";
1998/0313    
	f = ifc->conv->p->f;
1999/0909    
	type = Rifc;
1998/0306    
	memset(ip, 0, IPaddrlen); 
	memset(mask, 0, IPaddrlen); 
	memset(rem, 0, IPaddrlen); 
	switch(argc){
1999/0909    
	case 6: 
		if(strcmp(argv[5], "proxy") == 0) 
			type |= Rproxy; 
		/* fall through */
1998/0306    
	case 5: 
		mtu = strtoul(argv[4], 0, 0); 
		if(mtu >= ifc->m->minmtu && mtu <= ifc->m->maxmtu) 
			ifc->maxmtu = mtu; 
		/* fall through */ 
	case 4: 
		parseip(ip, argv[1]); 
		parseipmask(mask, argv[2]); 
		parseip(rem, argv[3]); 
		maskip(rem, mask, net); 
		break; 
	case 3: 
		parseip(ip, argv[1]); 
		parseipmask(mask, argv[2]); 
		maskip(ip, mask, rem); 
		maskip(rem, mask, net); 
		break; 
	case 2: 
		parseip(ip, argv[1]); 
		memmove(mask, defmask(ip), IPaddrlen); 
		maskip(ip, mask, rem); 
		maskip(rem, mask, net); 
		break; 
	default: 
		return Ebadarg; 
		break; 
	} 
 
	wlock(ifc); 
 
	/* ignore if this is already a local address for this ifc */ 
	for(lifc = ifc->lifc; lifc; lifc = lifc->next) 
		if(ipcmp(lifc->local, ip) == 0) 
			goto out; 
 
	/* add the address to the list of logical ifc's for this ifc */ 
	lifc = smalloc(sizeof(Iplifc)); 
	ipmove(lifc->local, ip); 
	ipmove(lifc->mask, mask); 
	ipmove(lifc->remote, rem); 
	ipmove(lifc->net, net); 
	lifc->next = nil; 
	for(l = &ifc->lifc; *l; l = &(*l)->next) 
		; 
	*l = lifc; 
 
	/* add a route for the local network */
1998/1005    
	if(ipcmp(mask, IPallbits) == 0){ 
		/* point to point networks are a hack */ 
		if(ipcmp(ip, rem) == 0) 
			findprimaryip(f, lifc->local);
1998/0306    
		type |= Rptpt;
1998/1005    
	}
1998/0306    
	if(isv4(ip))
1998/0313    
		v4addroute(f, tifc, rem+IPv4off, mask+IPv4off, ip+IPv4off, type);
1998/0306    
	else
1998/0316    
		v6addroute(f, tifc, rem, mask, ip, type);
1998/0306    
1998/0313    
	addselfcache(f, ifc, lifc, ip, Runi);
1998/0306    
1999/0909    
	if((type & (Rptpt|Rproxy)) == (Rptpt|Rproxy)){
1999/0731    
		ipifcregisterproxy(f, ifc, rem);
1998/1005    
		goto out;
1999/0731    
	}
1998/1005    
1998/0306    
	/* add subnet directed broadcast addresses to the self cache */ 
	for(i = 0; i < IPaddrlen; i++) 
		bcast[i] = (ip[i] & mask[i]) | ~mask[i];
1998/0313    
	addselfcache(f, ifc, lifc, bcast, Rbcast);
1998/0306    
1998/0318    
	/* add old subnet directed broadcast addresses to the self cache */ 
	for(i = 0; i < IPaddrlen; i++) 
		bcast[i] = (ip[i] & mask[i]) & mask[i]; 
	addselfcache(f, ifc, lifc, bcast, Rbcast);
1998/0306    
	/* add network directed broadcast addresses to the self cache */ 
	memmove(mask, defmask(ip), IPaddrlen); 
	for(i = 0; i < IPaddrlen; i++) 
		bcast[i] = (ip[i] & mask[i]) | ~mask[i];
1998/0318    
	addselfcache(f, ifc, lifc, bcast, Rbcast); 
 
	/* add old network directed broadcast addresses to the self cache */ 
	memmove(mask, defmask(ip), IPaddrlen); 
	for(i = 0; i < IPaddrlen; i++) 
		bcast[i] = (ip[i] & mask[i]) & mask[i];
1998/0313    
	addselfcache(f, ifc, lifc, bcast, Rbcast);
1998/0306    
1998/0313    
	addselfcache(f, ifc, lifc, IPv4bcast, Rbcast);
1998/0306    
1999/0731    
	/* register the address on this network for address resolution */ 
	if(ifc->m->areg != nil) 
		(*ifc->m->areg)(ifc, ip);
1998/0306    
out: 
	wunlock(ifc); 
	return nil; 
} 
 
/* 
 *  remove an address from an interface. 
 *  called with c->car locked 
 */ 
char* 
ipifcrem(Ipifc *ifc, char **argv, int argc, int dolock) 
{ 
	uchar ip[IPaddrlen]; 
	uchar mask[IPaddrlen]; 
	Iplifc *lifc, **l;
1998/0313    
	Fs *f;
1998/0306    
 
	if(argc < 3) 
		return Ebadarg;
1998/0313    
	f = ifc->conv->p->f;
1998/0306    
	parseip(ip, argv[1]); 
	parseipmask(mask, argv[2]);
1998/0717    
	if(dolock)
1998/0306    
		wlock(ifc);
1999/1029    
	/* Are we point to point */ 
	type = 0; 
	if(ipcmp(mask, IPallbits) == 0) 
		type = Rptpt; 
 
	/* 
	 *  find address on this interface and remove from chain. 
	 *  for pt to pt we actually specify the remote address at the 
	 *  addresss to remove. 
	 */ 
	l = &ifc->lifc; 
	for(lifc = *l; lifc != nil; lifc = lifc->next) { 
		addr = lifc->local; 
		if(type == Rptpt) 
			addr = lifc->remote; 
		if(memcmp(ip, addr, IPaddrlen) == 0 && memcmp(mask, lifc->mask, IPaddrlen) == 0) {
1998/0306    
			*l = lifc->next; 
			break; 
		}
1999/1029    
		l = &lifc->next; 
	}
1998/0306    
1998/0717    
	if(lifc == nil){ 
		if(dolock) 
			wunlock(ifc);
1998/0306    
		return "address not on this interface";
1998/0717    
	}
1998/0306    
 
	/* disassociate any addresses */ 
	while(lifc->link)
1998/0313    
		remselfcache(f, ifc, lifc, lifc->link->self->a);
1998/0306    
 
	/* remove the route for this logical interface */ 
	if(isv4(ip))
1998/0630    
		v4delroute(f, lifc->remote+IPv4off, lifc->mask+IPv4off, 1);
1998/0306    
	else
1998/0630    
		v6delroute(f, lifc->remote, lifc->mask, 1);
1998/0306    
 
	free(lifc);
1998/0717    
	if(dolock)
1998/0306    
		wunlock(ifc); 
	return nil; 
} 
 
/* 
 * distrbute routes to active interfaces like the 
 * TRIP linecards 
 */ 
void
1998/0313    
ipifcaddroute(Fs *f, int vers, uchar *addr, uchar *mask, uchar *gate, int type)
1998/0306    
{ 
	Medium *m;
1998/0313    
	Conv **cp, **e;
1998/0306    
	Ipifc *ifc;
1998/0313    
	e = &f->ipifc->conv[f->ipifc->nc]; 
	for(cp = f->ipifc->conv; cp < e; cp++){
1998/0306    
		if(*cp != nil) { 
			ifc = (Ipifc*)(*cp)->ptcl; 
			m = ifc->m;
1998/0307    
			if(m == nil) 
				continue;
1998/0306    
			if(m->addroute != nil) 
				m->addroute(ifc, vers, addr, mask, gate, type); 
		} 
	} 
} 
 
void
1998/0313    
ipifcremroute(Fs *f, int vers, uchar *addr, uchar *mask)
1998/0306    
{ 
	Medium *m;
1998/0313    
	Conv **cp, **e;
1998/0306    
	Ipifc *ifc;
1998/0313    
	e = &f->ipifc->conv[f->ipifc->nc]; 
	for(cp = f->ipifc->conv; cp < e; cp++){
1998/0306    
		if(*cp != nil) { 
			ifc = (Ipifc*)(*cp)->ptcl; 
			m = ifc->m;
1998/0307    
			if(m == nil) 
				continue;
1998/0306    
			if(m->remroute != nil) 
				m->remroute(ifc, vers, addr, mask); 
		} 
	} 
} 
 
/* 
 *  associate an address with the interface.  This wipes out any previous 
 *  addresses.  This is a macro that means, remove all the old interfaces 
 *  and add a new one. 
 */ 
static char* 
ipifcconnect(Conv* c, char **argv, int argc) 
{ 
	char *err; 
	Ipifc *ifc; 
	char *av[4]; 
	char ip[80], mask[80]; 
 
	ifc = (Ipifc*)c->ptcl; 
 
	if(ifc->m == nil) 
		 return "ipifc not yet bound to device"; 
 
	av[0] = "remove"; 
	av[1] = ip; 
	av[2] = mask; 
	av[3] = 0; 
	if(waserror()){ 
		wunlock(ifc); 
		nexterror(); 
	} 
	wlock(ifc); 
	while(ifc->lifc){ 
		sprint(ip, "%I", ifc->lifc->local); 
		sprint(mask, "%I", ifc->lifc->mask); 
		ipifcrem(ifc, av, 3, 0); 
	} 
	wunlock(ifc); 
	poperror(); 
 
	err = ipifcadd(ifc, argv, argc); 
	if(err) 
		return err;
1998/0313    
	Fsconnected(c, nil);
1998/0306    
 
	return nil; 
} 
 
/* 
 *  non-standard control messages. 
 *  called with c->car locked. 
 */ 
static char* 
ipifcctl(Conv* c, char**argv, int argc) 
{ 
	Ipifc *ifc;
1998/0314    
	int i;
1998/0306    
 
	ifc = (Ipifc*)c->ptcl; 
	if(strcmp(argv[0], "add") == 0) 
		return ipifcadd(ifc, argv, argc);
1998/0313    
 	else if(strcmp(argv[0], "bootp") == 0) 
		return bootp(ifc);
1998/0306    
	else if(strcmp(argv[0], "remove") == 0) 
		return ipifcrem(ifc, argv, argc, 1); 
	else if(strcmp(argv[0], "unbind") == 0) 
		return ipifcunbind(ifc); 
	else if(strcmp(argv[0], "joinmulti") == 0) 
		return ipifcjoinmulti(ifc, argv, argc); 
	else if(strcmp(argv[0], "leavemulti") == 0) 
		return ipifcleavemulti(ifc, argv, argc);
1998/0330    
	else if(strcmp(argv[0], "mtu") == 0) 
		return ipifcsetmtu(ifc, argv, argc);
1998/0314    
	else if(strcmp(argv[0], "iprouting") == 0){ 
		i = 1; 
		if(argc > 1) 
			i = atoi(argv[1]); 
		iprouting(c->p->f, i); 
		return nil; 
	}
1998/0306    
	return "unsupported ctl"; 
}
1998/0313    
ipifcstats(Proto *ipifc, char *buf, int len) 
{ 
	return ipstats(ipifc->f, buf, len); 
}
1998/0306    
void
1998/0313    
ipifcinit(Fs *f)
1998/0306    
{
1998/0313    
	Proto *ipifc;
1998/0306    
1998/0313    
	ipifc = smalloc(sizeof(Ipifc)); 
	ipifc->name = "ipifc"; 
	ipifc->kick = ipifckick; 
	ipifc->connect = ipifcconnect; 
	ipifc->announce = nil; 
	ipifc->bind = ipifcbind; 
	ipifc->state = ipifcstate; 
	ipifc->create = ipifccreate; 
	ipifc->close = ipifcclose; 
	ipifc->rcv = nil; 
	ipifc->ctl = ipifcctl; 
	ipifc->advise = nil; 
	ipifc->stats = ipifcstats; 
	ipifc->inuse = ipifcinuse; 
	ipifc->local = ipifclocal; 
	ipifc->ipproto = -1; 
	ipifc->nc = Maxmedia; 
	ipifc->ptclsize = sizeof(Ipifc); 
 
	f->ipifc = ipifc;			/* hack for ipifcremroute, findipifc, ... */ 
	f->self = smalloc(sizeof(Ipselftab));	/* hack for ipforme */ 
 
	Fsproto(f, ipifc);
1998/0306    
} 
 
/* 
 *  add to self routing cache 
 *	called with c->car locked 
 */ 
static void
1998/0313    
addselfcache(Fs *f, Ipifc *ifc, Iplifc *lifc, uchar *a, int type)
1998/0306    
{ 
	Ipself *p; 
	Iplink *lp; 
	int h;
1998/0313    
	qlock(f->self);
1998/0306    
 
	/* see if the address already exists */ 
	h = hashipa(a);
1998/0313    
	for(p = f->self->hash[h]; p; p = p->next)
1998/0306    
		if(memcmp(a, p->a, IPaddrlen) == 0) 
			break; 
 
	/* allocate a local address and add to hash chain */ 
	if(p == nil){ 
		p = smalloc(sizeof(*p)); 
		ipmove(p->a, a); 
		p->type = type;
1998/0313    
		p->next = f->self->hash[h]; 
		f->self->hash[h] = p;
1998/0306    
 
		/* if the null address, accept all packets */ 
		if(ipcmp(a, v4prefix) == 0 || ipcmp(a, IPnoaddr) == 0)
1998/0313    
			f->self->acceptall = 1;
1998/0306    
	} 
 
	/* look for a link for this lifc */
1998/0307    
	for(lp = p->link; lp; lp = lp->selflink)
1998/0306    
		if(lp->lifc == lifc) 
			break; 
 
	/* allocate a lifc-to-local link and link to both */ 
	if(lp == nil){ 
		lp = smalloc(sizeof(*lp)); 
		lp->ref = 1; 
		lp->lifc = lifc;
1998/0307    
		lp->self = p; 
		lp->selflink = p->link;
1998/0306    
		p->link = lp; 
		lp->lifclink = lifc->link; 
		lifc->link = lp; 
 
		/* add to routing table */ 
		if(isv4(a))
1998/0313    
			v4addroute(f, tifc, a+IPv4off, IPallbits+IPv4off, a+IPv4off, type);
1998/0306    
		else
1998/0313    
			v6addroute(f, tifc, a, IPallbits, a, type);
1998/0306    
 
		if((type & Rmulti) && ifc->m->addmulti != nil) 
			(*ifc->m->addmulti)(ifc, a, lifc->local); 
	} else { 
		lp->ref++; 
	}
1998/0313    
	qunlock(f->self);
1998/0306    
} 
 
/* 
 *  These structures are unlinked from their chains while 
 *  other threads may be using them.  To avoid excessive locking, 
 *  just put them aside for a while before freeing them.
1998/0313    
 *	called with f->self locked
1998/0306    
 */ 
static Iplink *freeiplink; 
static Ipself *freeipself; 
 
static void 
iplinkfree(Iplink *p) 
{ 
	Iplink **l, *np; 
	ulong now = msec; 
 
	l = &freeiplink; 
	for(np = *l; np; np = *l){ 
		if(np->expire > now){ 
			*l = np->next; 
			free(np); 
			continue; 
		} 
		l = &np->next; 
	} 
	p->expire = now + 5000;		/* give other threads 5 secs to get out */ 
	p->next = nil; 
	*l = p; 
} 
static void 
ipselffree(Ipself *p) 
{ 
	Ipself **l, *np; 
	ulong now = msec; 
 
	l = &freeipself; 
	for(np = *l; np; np = *l){ 
		if(np->expire > now){ 
			*l = np->next; 
			free(np); 
			continue; 
		} 
		l = &np->next; 
	} 
	p->expire = now + 5000;		/* give other threads 5 secs to get out */ 
	p->next = nil; 
	*l = p; 
} 
 
/* 
 *  Decrement reference for this address on this link. 
 *  Unlink from selftab if this is the last ref. 
 *	called with c->car locked 
 */ 
static void
1998/0313    
remselfcache(Fs *f, Ipifc *ifc, Iplifc *lifc, uchar *a)
1998/0306    
{ 
	Ipself *p, **l;
1998/0307    
	Iplink *link, **l_self, **l_lifc;
1998/0306    
1998/0313    
	qlock(f->self);
1998/0306    
 
	/* find the unique selftab entry */
1998/0313    
	l = &f->self->hash[hashipa(a)];
1998/0306    
	for(p = *l; p; p = *l){ 
		if(ipcmp(p->a, a) == 0) 
			break; 
		l = &p->next; 
	} 
 
	if(p == nil) 
		goto out; 
 
	/* 
	 *  walk down links from an ifc looking for one 
	 *  that matches the selftab entry 
	 */
1998/0307    
	l_lifc = &lifc->link; 
	for(link = *l_lifc; link; link = *l_lifc){ 
		if(link->self == p)
1998/0306    
			break;
1998/0307    
		l_lifc = &link->lifclink;
1998/0306    
	}
1998/0307    
	if(link == nil)
1998/0306    
		goto out; 
 
	/* 
	 *  walk down the links from the selftab looking for 
	 *  the one we just found 
	 */
1998/0307    
	l_self = &p->link; 
	for(link = *l_self; link; link = *l_self){ 
		if(link == *(l_lifc))
1998/0306    
			break;
1998/0307    
		l_self = &link->selflink;
1998/0306    
	}
1998/0307    
	if(link == nil)
1998/0306    
		panic("remselfcache");
1998/0307    
	if(--(link->ref) != 0)
1998/0306    
		goto out; 
 
	if((p->type & Rmulti) && ifc->m->remmulti != nil) 
		(*ifc->m->remmulti)(ifc, a, lifc->local); 
 
	/* ref == 0, remove from both chains and free the link */
1998/0307    
	*l_lifc = link->lifclink; 
	*l_self = link->selflink; 
	iplinkfree(link);
1998/0306    
1998/0310    
	if(p->link != nil) 
		goto out;
1998/0306    
	/* remove from routing table */ 
	if(isv4(a))
1998/0630    
		v4delroute(f, a+IPv4off, IPallbits+IPv4off, 1);
1998/0306    
	else
1998/0630    
		v6delroute(f, a, IPallbits, 1);
1998/0306    
	 
	/* no more links, remove from hash and free */ 
	*l = p->next; 
	ipselffree(p); 
 
	/* if IPnoaddr, forget */ 
	if(ipcmp(a, v4prefix) == 0 || ipcmp(a, IPnoaddr) == 0)
1998/0313    
		f->self->acceptall = 0;
1998/0306    
 
out:
1998/0313    
	qunlock(f->self);
1998/0306    
}
1998/0310    
static char *stformat = "%-32.32I %2.2d %4.4s\n"; 
enum 
{ 
	Nstformat= 41, 
}; 
 
long
1998/0313    
ipselftabread(Fs *f, char *cp, ulong offset, int n)
1998/0310    
{ 
	int i, m, nifc; 
	Ipself *p; 
	Iplink *link; 
	char state[8]; 
 
	m = 0;
1998/0313    
	qlock(f->self);
1998/0310    
	for(i = 0; i < NHASH && m < n; i++){
1998/0313    
		for(p = f->self->hash[i]; p != nil && m < n; p = p->next){
1998/0310    
			if(offset == 0){ 
				nifc = 0; 
				for(link = p->link; link; link = link->selflink) 
					nifc++; 
				routetype(p->type, state); 
				m += snprint(cp + m, n - m, stformat, p->a, nifc, state); 
			} 
			offset -= Nstformat; 
		} 
	}
1998/0313    
	qunlock(f->self);
1998/0310    
	return m;
1998/0306    
} 
 
 
/* 
 *  returns 
 *	0		- no match 
 *	Runi 
 *	Rbcast 
 *	Rmcast 
 */ 
int
1998/0313    
ipforme(Fs *f, uchar *addr)
1998/0306    
{ 
	Ipself *p;
1998/0313    
	p = f->self->hash[hashipa(addr)];
1998/0306    
	for(; p; p = p->next){ 
		if(ipcmp(addr, p->a) == 0) 
			return p->type; 
	} 
 
	/* hack to say accept anything */
1998/0313    
	if(f->self->acceptall)
1998/0306    
		return Runi; 
 
	return 0; 
} 
 
/* 
 *  find the ifc on same net as the remote system.  If none, 
 *  return nil. 
 */ 
Ipifc*
1998/0313    
findipifc(Fs *f, uchar *remote, int type)
1998/0306    
{
1998/0316    
	Ipifc *ifc, *x;
1998/0306    
	Iplifc *lifc;
1998/0313    
	Conv **cp, **e;
1998/0306    
	uchar gnet[IPaddrlen];
1998/0316    
	uchar xmask[IPaddrlen];
1998/0306    
1998/0316    
	x = nil; 
 
	/* find most specific match */
1998/0313    
	e = &f->ipifc->conv[f->ipifc->nc]; 
	for(cp = f->ipifc->conv; cp < e; cp++){
1998/0306    
		if(*cp == 0) 
			continue; 
		ifc = (Ipifc*)(*cp)->ptcl; 
		for(lifc = ifc->lifc; lifc; lifc = lifc->next){ 
			maskip(remote, lifc->mask, gnet);
1998/0316    
			if(ipcmp(gnet, lifc->net) == 0){ 
				if(x == nil || ipcmp(lifc->mask, xmask) > 0){ 
					x = ifc; 
					ipmove(xmask, lifc->mask); 
				} 
			}
1998/0306    
		} 
	}
1998/0316    
	if(x != nil) 
		return x;
1998/0306    
1998/0316    
	/* for now for broadcast and multicast, just use first interface */
1998/0306    
	if(type & (Rbcast|Rmulti)){
1998/0313    
		for(cp = f->ipifc->conv; cp < e; cp++){
1998/0306    
			if(*cp == 0) 
				continue; 
			ifc = (Ipifc*)(*cp)->ptcl; 
			if(ifc->lifc != nil) 
				return ifc; 
		} 
	} 
		 
	return nil; 
} 
 
/*
1998/1005    
 *  returns first ip address configured 
 */ 
void 
findprimaryip(Fs *f, uchar *local) 
{ 
	Conv **cp, **e; 
	Ipifc *ifc; 
	Iplifc *lifc; 
 
	/* find first ifc local address */ 
	e = &f->ipifc->conv[f->ipifc->nc]; 
	for(cp = f->ipifc->conv; cp < e; cp++){ 
		if(*cp == 0) 
			continue; 
		ifc = (Ipifc*)(*cp)->ptcl; 
		for(lifc = ifc->lifc; lifc; lifc = lifc->next){ 
			ipmove(local, lifc->local); 
			return; 
		} 
	} 
} 
 
/*
1998/0306    
 *  find the local address 'closest' to the remote system, copy it to 
 *  local and return the ifc for that address 
 */ 
void
1998/0313    
findlocalip(Fs *f, uchar *local, uchar *remote)
1998/0306    
{ 
	Ipifc *ifc; 
	Iplifc *lifc; 
	Route *r; 
	uchar gate[IPaddrlen]; 
	uchar gnet[IPaddrlen];
1998/0313    
	qlock(f->ipifc); 
	r = v6lookup(f, remote);
1998/0306    
	 
	if(r != nil){ 
		ifc = r->ifc; 
		if(r->type & Rv4) 
			v4tov6(gate, r->v4.gate); 
		else 
			ipmove(gate, r->v6.gate); 
 
		/* find ifc address closest to the gateway to use */ 
		for(lifc = ifc->lifc; lifc; lifc = lifc->next){ 
			maskip(gate, lifc->mask, gnet); 
			if(ipcmp(gnet, lifc->net) == 0){ 
				ipmove(local, lifc->local); 
				goto out; 
			} 
		} 
	}
1998/1005    
 
	findprimaryip(f, local);
1998/0306    
 
out:
1998/0313    
	qunlock(f->ipifc);
1998/0306    
} 
 
/* 
 *  return first v4 address associated with an interface 
 */ 
int 
ipv4local(Ipifc *ifc, uchar *addr) 
{ 
	Iplifc *lifc; 
 
	for(lifc = ifc->lifc; lifc; lifc = lifc->next){ 
		if(isv4(lifc->local)){ 
			memmove(addr, lifc->local+IPv4off, IPv4addrlen); 
			return 1; 
		} 
	} 
	return 0; 
} 
 
/* 
 *  return first v6 address associated with an interface 
 */ 
int 
ipv6local(Ipifc *ifc, uchar *addr) 
{ 
	Iplifc *lifc; 
 
	for(lifc = ifc->lifc; lifc; lifc = lifc->next){ 
		if(!isv4(lifc->local)){ 
			ipmove(addr, lifc->local); 
			return 1; 
		} 
	} 
	return 0; 
} 
 
/* 
 *  see if this address is bound to the interface 
 */ 
Iplifc* 
iplocalonifc(Ipifc *ifc, uchar *ip) 
{ 
	Iplifc *lifc; 
 
	for(lifc = ifc->lifc; lifc; lifc = lifc->next) 
		if(ipcmp(ip, lifc->local) == 0) 
			return lifc; 
	return nil; 
} 
 
 
/* 
 *  See if we're proxying for this address on this interface 
 */ 
int
1998/0313    
ipproxyifc(Fs *f, Ipifc *ifc, uchar *ip)
1998/0306    
{ 
	Route *r; 
	uchar net[IPaddrlen]; 
	Iplifc *lifc; 
 
	/* see if this is a direct connected pt to pt address */
1998/0313    
	r = v6lookup(f, ip);
1998/0306    
	if(r == nil) 
		return 0;
1999/0909    
	if((r->type & (Rifc|Rptpt|Rproxy)) != (Rifc|Rptpt|Rproxy))
1998/0306    
		return 0; 
 
	/* see if this is on the right interface */ 
	for(lifc = ifc->lifc; lifc; lifc = lifc->next){ 
		maskip(ip, lifc->mask, net); 
		if(ipcmp(net, lifc->remote) == 0) 
			return 1; 
	} 
 
	return 0; 
} 
 
/* 
 *  return multicast version if any 
 */ 
int 
ipismulticast(uchar *ip) 
{ 
	if(isv4(ip)){ 
		if(ip[IPv4off] >= 0xe0 && ip[IPv4off] < 0xf0) 
			return V4; 
	} else { 
		if(ip[0] == 0xff) 
			return V6; 
	} 
	return 0; 
}
1998/0728    
int 
ipisbm(uchar *ip) 
{ 
	if(isv4(ip)){ 
		if(ip[IPv4off] >= 0xe0 && ip[IPv4off] < 0xf0) 
			return V4; 
		if(ipcmp(ip, IPv4bcast) == 0) 
			return V4; 
	} else { 
		if(ip[0] == 0xff) 
			return V6; 
	} 
	return 0; 
}
1998/0306    
 
/* 
 *  add a multicast address to an interface, called with c->car locked 
 */ 
void 
ipifcaddmulti(Conv *c, uchar *ma, uchar *ia) 
{ 
	Ipifc *ifc; 
	Iplifc *lifc; 
	Conv **p; 
	Ipmulti *multi, **l;
1998/0313    
	Fs *f; 
 
	f = c->p->f;
1998/0306    
	 
	for(l = &c->multi; *l; l = &(*l)->next) 
		if(ipcmp(ma, (*l)->ma) == 0) 
		if(ipcmp(ia, (*l)->ia) == 0) 
			return;		/* it's already there */ 
 
	multi = *l = smalloc(sizeof(*multi)); 
	ipmove(multi->ma, ma); 
	ipmove(multi->ia, ia); 
	multi->next = nil;
1998/0313    
	for(p = f->ipifc->conv; *p; p++){
1998/0306    
		if((*p)->inuse == 0) 
			continue; 
		ifc = (Ipifc*)(*p)->ptcl; 
		if(waserror()){ 
			wunlock(ifc); 
			nexterror(); 
		} 
		wlock(ifc); 
		for(lifc = ifc->lifc; lifc; lifc = lifc->next) 
			if(ipcmp(ia, lifc->local) == 0)
1998/0313    
				addselfcache(f, ifc, lifc, ma, Rmulti);
1998/0306    
		wunlock(ifc); 
		poperror(); 
	} 
} 
 
 
/* 
 *  remove a multicast address from an interface, called with c->car locked 
 */ 
void 
ipifcremmulti(Conv *c, uchar *ma, uchar *ia) 
{ 
	Ipmulti *multi, **l; 
	Iplifc *lifc; 
	Conv **p; 
	Ipifc *ifc;
1998/0313    
	Fs *f; 
 
	f = c->p->f;
1998/0306    
	 
	for(l = &c->multi; *l; l = &(*l)->next) 
		if(ipcmp(ma, (*l)->ma) == 0) 
		if(ipcmp(ia, (*l)->ia) == 0) 
			break; 
 
	multi = *l; 
	if(multi == nil) 
		return; 	/* we don't have it open */ 
 
	*l = multi->next;
1998/0313    
	for(p = f->ipifc->conv; *p; p++){
1998/0306    
		if((*p)->inuse == 0) 
			continue; 
 
		ifc = (Ipifc*)(*p)->ptcl; 
		if(waserror()){ 
			wunlock(ifc); 
			nexterror(); 
		} 
		wlock(ifc); 
		for(lifc = ifc->lifc; lifc; lifc = lifc->next) 
			if(ipcmp(ia, lifc->local) == 0)
1998/0313    
				remselfcache(f, ifc, lifc, ma);
1998/0306    
		wunlock(ifc); 
		poperror(); 
	} 
 
	free(multi); 
} 
 
/* 
 *  make lifc's join and leave multicast groups 
 */ 
static char* 
ipifcjoinmulti(Ipifc *ifc, char **argv, int argc) 
{ 
	USED(ifc, argv, argc); 
	return nil; 
} 
 
static char* 
ipifcleavemulti(Ipifc *ifc, char **argv, int argc) 
{ 
	USED(ifc, argv, argc); 
	return nil; 
}
1999/0731    
static void 
ipifcregisterproxy(Fs *f, Ipifc *ifc, uchar *ip) 
{ 
	Conv **cp, **e; 
	Ipifc *nifc; 
	Iplifc *lifc;
1999/0803    
	Medium *m;
1999/0731    
	uchar net[IPaddrlen]; 
 
	/* register the address on any network that will proxy for us */ 
	e = &f->ipifc->conv[f->ipifc->nc]; 
	for(cp = f->ipifc->conv; cp < e; cp++){ 
		if(*cp == nil) 
			continue; 
		nifc = (Ipifc*)(*cp)->ptcl; 
		if(nifc == ifc) 
			continue;
1999/0803    
 
		rlock(nifc); 
		m = nifc->m; 
		if(m == nil || m->areg == nil){ 
			runlock(nifc); 
			continue; 
		}
1999/0731    
		for(lifc = nifc->lifc; lifc; lifc = lifc->next){ 
			maskip(ip, lifc->mask, net); 
			if(ipcmp(net, lifc->remote) == 0){
1999/0803    
				(*m->areg)(nifc, ip);
1999/0731    
				break; 
			} 
		}
1999/0803    
		runlock(nifc);
1999/0731    
	} 
}


source code copyright © 1990-2005 Lucent Technologies; see license
Plan 9 distribution
comments to russ cox (rsc@swtch.com)