1 87a52e04 2005-12-26 devnull #include <u.h>
  2 87a52e04 2005-12-26 devnull #include <libc.h>
  3 87a52e04 2005-12-26 devnull #include <ip.h>
  4 87a52e04 2005-12-26 devnull #include <bio.h>
  5 87a52e04 2005-12-26 devnull #include <ndb.h>
  6 87a52e04 2005-12-26 devnull #include <ctype.h>
  7 87a52e04 2005-12-26 devnull #include "dat.h"
  8 87a52e04 2005-12-26 devnull 
  9 87a52e04 2005-12-26 devnull /*
 10 87a52e04 2005-12-26 devnull  *  format of a binding entry:
 11 87a52e04 2005-12-26 devnull  *	char ipaddr[32];
 12 87a52e04 2005-12-26 devnull  *	char id[32];
 13 87a52e04 2005-12-26 devnull  *	char hwa[32];
 14 87a52e04 2005-12-26 devnull  *	char otime[10];
 15 87a52e04 2005-12-26 devnull  */
 16 87a52e04 2005-12-26 devnull Binding *bcache;
 17 87a52e04 2005-12-26 devnull uchar bfirst[IPaddrlen];
 18 87a52e04 2005-12-26 devnull char *binddir = nil;
 19 87a52e04 2005-12-26 devnull char *xbinddir = "#9/ndb/dhcp";
 20 87a52e04 2005-12-26 devnull 
 21 87a52e04 2005-12-26 devnull /*
 22 87a52e04 2005-12-26 devnull  *  convert a byte array to hex
 23 87a52e04 2005-12-26 devnull  */
 24 87a52e04 2005-12-26 devnull static char
 25 87a52e04 2005-12-26 devnull hex(int x)
 26 87a52e04 2005-12-26 devnull {
 27 87a52e04 2005-12-26 devnull 	if(x < 10)
 28 87a52e04 2005-12-26 devnull 		return x + '0';
 29 87a52e04 2005-12-26 devnull 	return x - 10 + 'a';
 30 87a52e04 2005-12-26 devnull }
 31 87a52e04 2005-12-26 devnull extern char*
 32 87a52e04 2005-12-26 devnull tohex(char *hdr, uchar *p, int len)
 33 87a52e04 2005-12-26 devnull {
 34 87a52e04 2005-12-26 devnull 	char *s, *sp;
 35 87a52e04 2005-12-26 devnull 	int hlen;
 36 87a52e04 2005-12-26 devnull 
 37 87a52e04 2005-12-26 devnull 	hlen = strlen(hdr);
 38 87a52e04 2005-12-26 devnull 	s = malloc(hlen + 2*len + 1);
 39 87a52e04 2005-12-26 devnull 	sp = s;
 40 87a52e04 2005-12-26 devnull 	strcpy(sp, hdr);
 41 87a52e04 2005-12-26 devnull 	sp += hlen;
 42 87a52e04 2005-12-26 devnull 	for(; len > 0; len--){
 43 87a52e04 2005-12-26 devnull 		*sp++ = hex(*p>>4);
 44 87a52e04 2005-12-26 devnull 		*sp++ = hex(*p & 0xf);
 45 87a52e04 2005-12-26 devnull 		p++;
 46 87a52e04 2005-12-26 devnull 	}
 47 87a52e04 2005-12-26 devnull 	*sp = 0;
 48 87a52e04 2005-12-26 devnull 	return s;
 49 87a52e04 2005-12-26 devnull }
 50 87a52e04 2005-12-26 devnull 
 51 87a52e04 2005-12-26 devnull /*
 52 87a52e04 2005-12-26 devnull  *  convert a client id to a string.  If it's already
 53 87a52e04 2005-12-26 devnull  *  ascii, leave it be.  Otherwise, convert it to hex.
 54 87a52e04 2005-12-26 devnull  */
 55 87a52e04 2005-12-26 devnull extern char*
 56 87a52e04 2005-12-26 devnull toid(uchar *p, int n)
 57 87a52e04 2005-12-26 devnull {
 58 87a52e04 2005-12-26 devnull 	int i;
 59 87a52e04 2005-12-26 devnull 	char *s;
 60 87a52e04 2005-12-26 devnull 
 61 87a52e04 2005-12-26 devnull 	for(i = 0; i < n; i++)
 62 87a52e04 2005-12-26 devnull 		if(!isprint(p[i]))
 63 87a52e04 2005-12-26 devnull 			return tohex("id", p, n);
 64 87a52e04 2005-12-26 devnull 	s = malloc(n + 1);
 65 87a52e04 2005-12-26 devnull 	memmove(s, p, n);
 66 87a52e04 2005-12-26 devnull 	s[n] = 0;
 67 87a52e04 2005-12-26 devnull 	return s;
 68 87a52e04 2005-12-26 devnull }
 69 87a52e04 2005-12-26 devnull 
 70 87a52e04 2005-12-26 devnull /*
 71 87a52e04 2005-12-26 devnull  *  increment an ip address
 72 87a52e04 2005-12-26 devnull  */
 73 87a52e04 2005-12-26 devnull static void
 74 87a52e04 2005-12-26 devnull incip(uchar *ip)
 75 87a52e04 2005-12-26 devnull {
 76 87a52e04 2005-12-26 devnull 	int i, x;
 77 87a52e04 2005-12-26 devnull 
 78 87a52e04 2005-12-26 devnull 	for(i = IPaddrlen-1; i >= 0; i--){
 79 87a52e04 2005-12-26 devnull 		x = ip[i];
 80 87a52e04 2005-12-26 devnull 		x++;
 81 87a52e04 2005-12-26 devnull 		ip[i] = x;
 82 87a52e04 2005-12-26 devnull 		if((x & 0x100) == 0)
 83 87a52e04 2005-12-26 devnull 			break;
 84 87a52e04 2005-12-26 devnull 	}
 85 87a52e04 2005-12-26 devnull }
 86 87a52e04 2005-12-26 devnull 
 87 87a52e04 2005-12-26 devnull /*
 88 87a52e04 2005-12-26 devnull  *  find a binding for an id or hardware address
 89 87a52e04 2005-12-26 devnull  */
 90 87a52e04 2005-12-26 devnull static int
 91 87a52e04 2005-12-26 devnull lockopen(char *file)
 92 87a52e04 2005-12-26 devnull {
 93 87a52e04 2005-12-26 devnull 	char err[ERRMAX];
 94 87a52e04 2005-12-26 devnull 	int fd, tries;
 95 87a52e04 2005-12-26 devnull 
 96 87a52e04 2005-12-26 devnull 	for(tries = 0; tries < 5; tries++){
 97 87a52e04 2005-12-26 devnull 		fd = open(file, OLOCK|ORDWR);
 98 87a52e04 2005-12-26 devnull 		if(fd >= 0)
 99 87a52e04 2005-12-26 devnull 			return fd;
100 87a52e04 2005-12-26 devnull 		errstr(err, sizeof err);
101 87a52e04 2005-12-26 devnull 		if(strstr(err, "lock")){
102 87a52e04 2005-12-26 devnull 			/* wait for other process to let go of lock */
103 87a52e04 2005-12-26 devnull 			sleep(250);
104 87a52e04 2005-12-26 devnull 
105 87a52e04 2005-12-26 devnull 			/* try again */
106 87a52e04 2005-12-26 devnull 			continue;
107 87a52e04 2005-12-26 devnull 		}
108 87a52e04 2005-12-26 devnull 		if(strstr(err, "exist") || strstr(err, "No such")){
109 87a52e04 2005-12-26 devnull 			/* no file, create an exclusive access file */
110 87a52e04 2005-12-26 devnull 			fd = create(file, ORDWR, DMEXCL|0666);
111 87a52e04 2005-12-26 devnull 			chmod(file, 0666);
112 87a52e04 2005-12-26 devnull 			if(fd >= 0)
113 87a52e04 2005-12-26 devnull 				return fd;
114 87a52e04 2005-12-26 devnull 		}
115 87a52e04 2005-12-26 devnull 	}
116 87a52e04 2005-12-26 devnull 	return -1;
117 87a52e04 2005-12-26 devnull }
118 87a52e04 2005-12-26 devnull 
119 87a52e04 2005-12-26 devnull void
120 87a52e04 2005-12-26 devnull setbinding(Binding *b, char *id, long t)
121 87a52e04 2005-12-26 devnull {
122 87a52e04 2005-12-26 devnull 	if(b->boundto)
123 87a52e04 2005-12-26 devnull 		free(b->boundto);
124 87a52e04 2005-12-26 devnull 
125 87a52e04 2005-12-26 devnull 	b->boundto = strdup(id);
126 87a52e04 2005-12-26 devnull 	b->lease = t;
127 87a52e04 2005-12-26 devnull }
128 87a52e04 2005-12-26 devnull 
129 87a52e04 2005-12-26 devnull static void
130 87a52e04 2005-12-26 devnull parsebinding(Binding *b, char *buf)
131 87a52e04 2005-12-26 devnull {
132 87a52e04 2005-12-26 devnull 	long t;
133 87a52e04 2005-12-26 devnull 	char *id, *p;
134 87a52e04 2005-12-26 devnull 
135 87a52e04 2005-12-26 devnull 	/* parse */
136 87a52e04 2005-12-26 devnull 	t = atoi(buf);
137 87a52e04 2005-12-26 devnull 	id = strchr(buf, '\n');
138 87a52e04 2005-12-26 devnull 	if(id){
139 87a52e04 2005-12-26 devnull 		*id++ = 0;
140 87a52e04 2005-12-26 devnull 		p = strchr(id, '\n');
141 87a52e04 2005-12-26 devnull 		if(p)
142 87a52e04 2005-12-26 devnull 			*p = 0;
143 87a52e04 2005-12-26 devnull 	} else
144 87a52e04 2005-12-26 devnull 		id = "";
145 87a52e04 2005-12-26 devnull 
146 87a52e04 2005-12-26 devnull 	/* replace any past info */
147 87a52e04 2005-12-26 devnull 	setbinding(b, id, t);
148 87a52e04 2005-12-26 devnull }
149 87a52e04 2005-12-26 devnull 
150 87a52e04 2005-12-26 devnull static int
151 87a52e04 2005-12-26 devnull writebinding(int fd, Binding *b)
152 87a52e04 2005-12-26 devnull {
153 87a52e04 2005-12-26 devnull 	Dir *d;
154 87a52e04 2005-12-26 devnull 
155 87a52e04 2005-12-26 devnull 	seek(fd, 0, 0);
156 87a52e04 2005-12-26 devnull 	if(fprint(fd, "%ld\n%s\n", b->lease, b->boundto) < 0)
157 87a52e04 2005-12-26 devnull 		return -1;
158 87a52e04 2005-12-26 devnull 	d = dirfstat(fd);
159 87a52e04 2005-12-26 devnull 	if(d == nil)
160 87a52e04 2005-12-26 devnull 		return -1;
161 87a52e04 2005-12-26 devnull 	b->q.type = d->qid.type;
162 87a52e04 2005-12-26 devnull 	b->q.path = d->qid.path;
163 87a52e04 2005-12-26 devnull 	b->q.vers = d->qid.vers;
164 87a52e04 2005-12-26 devnull 	free(d);
165 87a52e04 2005-12-26 devnull 	return 0;
166 87a52e04 2005-12-26 devnull }
167 87a52e04 2005-12-26 devnull 
168 87a52e04 2005-12-26 devnull /*
169 87a52e04 2005-12-26 devnull  *  synchronize cached binding with file.  the file always wins.
170 87a52e04 2005-12-26 devnull  */
171 87a52e04 2005-12-26 devnull int
172 87a52e04 2005-12-26 devnull syncbinding(Binding *b, int returnfd)
173 87a52e04 2005-12-26 devnull {
174 87a52e04 2005-12-26 devnull 	char buf[512];
175 87a52e04 2005-12-26 devnull 	int i, fd;
176 87a52e04 2005-12-26 devnull 	Dir *d;
177 87a52e04 2005-12-26 devnull 
178 87a52e04 2005-12-26 devnull 	if(binddir == nil)
179 87a52e04 2005-12-26 devnull 		binddir = unsharp(xbinddir);
180 87a52e04 2005-12-26 devnull 
181 87a52e04 2005-12-26 devnull 	snprint(buf, sizeof(buf), "%s/%I", binddir, b->ip);
182 87a52e04 2005-12-26 devnull 	fd = lockopen(buf);
183 87a52e04 2005-12-26 devnull 	if(fd < 0){
184 87a52e04 2005-12-26 devnull 		/* assume someone else is using it */
185 87a52e04 2005-12-26 devnull 		b->lease = time(0) + OfferTimeout;
186 87a52e04 2005-12-26 devnull 		return -1;
187 87a52e04 2005-12-26 devnull 	}
188 87a52e04 2005-12-26 devnull 
189 87a52e04 2005-12-26 devnull 	/* reread if changed */
190 87a52e04 2005-12-26 devnull 	d = dirfstat(fd);
191 87a52e04 2005-12-26 devnull 	if(d != nil)	/* BUG? */
192 87a52e04 2005-12-26 devnull 	if(d->qid.type != b->q.type || d->qid.path != b->q.path || d->qid.vers != b->q.vers){
193 87a52e04 2005-12-26 devnull 		i = read(fd, buf, sizeof(buf)-1);
194 87a52e04 2005-12-26 devnull 		if(i < 0)
195 87a52e04 2005-12-26 devnull 			i = 0;
196 87a52e04 2005-12-26 devnull 		buf[i] = 0;
197 87a52e04 2005-12-26 devnull 		parsebinding(b, buf);
198 87a52e04 2005-12-26 devnull 		b->lasttouched = d->mtime;
199 87a52e04 2005-12-26 devnull 		b->q.path = d->qid.path;
200 87a52e04 2005-12-26 devnull 		b->q.vers = d->qid.vers;
201 87a52e04 2005-12-26 devnull 	}
202 87a52e04 2005-12-26 devnull 
203 87a52e04 2005-12-26 devnull 	free(d);
204 87a52e04 2005-12-26 devnull 
205 87a52e04 2005-12-26 devnull 	if(returnfd)
206 87a52e04 2005-12-26 devnull 		return fd;
207 87a52e04 2005-12-26 devnull 
208 87a52e04 2005-12-26 devnull 	close(fd);
209 87a52e04 2005-12-26 devnull 	return 0;
210 87a52e04 2005-12-26 devnull }
211 87a52e04 2005-12-26 devnull 
212 87a52e04 2005-12-26 devnull extern int
213 87a52e04 2005-12-26 devnull samenet(uchar *ip, Info *iip)
214 87a52e04 2005-12-26 devnull {
215 87a52e04 2005-12-26 devnull 	uchar x[IPaddrlen];
216 87a52e04 2005-12-26 devnull 
217 87a52e04 2005-12-26 devnull 	maskip(iip->ipmask, ip, x);
218 87a52e04 2005-12-26 devnull 	return ipcmp(x, iip->ipnet) == 0;
219 87a52e04 2005-12-26 devnull }
220 87a52e04 2005-12-26 devnull 
221 87a52e04 2005-12-26 devnull /*
222 87a52e04 2005-12-26 devnull  *  create a record for each binding
223 87a52e04 2005-12-26 devnull  */
224 87a52e04 2005-12-26 devnull extern void
225 87a52e04 2005-12-26 devnull initbinding(uchar *first, int n)
226 87a52e04 2005-12-26 devnull {
227 87a52e04 2005-12-26 devnull 	while(n-- > 0){
228 87a52e04 2005-12-26 devnull 		iptobinding(first, 1);
229 87a52e04 2005-12-26 devnull 		incip(first);
230 87a52e04 2005-12-26 devnull 	}
231 87a52e04 2005-12-26 devnull }
232 87a52e04 2005-12-26 devnull 
233 87a52e04 2005-12-26 devnull /*
234 87a52e04 2005-12-26 devnull  *  find a binding for a specific ip address
235 87a52e04 2005-12-26 devnull  */
236 87a52e04 2005-12-26 devnull extern Binding*
237 87a52e04 2005-12-26 devnull iptobinding(uchar *ip, int mk)
238 87a52e04 2005-12-26 devnull {
239 87a52e04 2005-12-26 devnull 	Binding *b;
240 87a52e04 2005-12-26 devnull 
241 87a52e04 2005-12-26 devnull 	for(b = bcache; b; b = b->next){
242 87a52e04 2005-12-26 devnull 		if(ipcmp(b->ip, ip) == 0){
243 87a52e04 2005-12-26 devnull 			syncbinding(b, 0);
244 87a52e04 2005-12-26 devnull 			return b;
245 87a52e04 2005-12-26 devnull 		}
246 87a52e04 2005-12-26 devnull 	}
247 87a52e04 2005-12-26 devnull 
248 87a52e04 2005-12-26 devnull 	if(mk == 0)
249 87a52e04 2005-12-26 devnull 		return 0;
250 87a52e04 2005-12-26 devnull 	b = malloc(sizeof(*b));
251 87a52e04 2005-12-26 devnull 	memset(b, 0, sizeof(*b));
252 87a52e04 2005-12-26 devnull 	ipmove(b->ip, ip);
253 87a52e04 2005-12-26 devnull 	b->next = bcache;
254 87a52e04 2005-12-26 devnull 	bcache = b;
255 87a52e04 2005-12-26 devnull 	syncbinding(b, 0);
256 87a52e04 2005-12-26 devnull 	return b;
257 87a52e04 2005-12-26 devnull }
258 87a52e04 2005-12-26 devnull 
259 87a52e04 2005-12-26 devnull static void
260 87a52e04 2005-12-26 devnull lognolease(Binding *b)
261 87a52e04 2005-12-26 devnull {
262 87a52e04 2005-12-26 devnull 	/* renew the old binding, and hope it eventually goes away */
263 87a52e04 2005-12-26 devnull 	b->offer = 5*60;
264 87a52e04 2005-12-26 devnull 	commitbinding(b);
265 87a52e04 2005-12-26 devnull 
266 87a52e04 2005-12-26 devnull 	/* complain if we haven't in the last 5 minutes */
267 87a52e04 2005-12-26 devnull 	if(now - b->lastcomplained < 5*60)
268 87a52e04 2005-12-26 devnull 		return;
269 87a52e04 2005-12-26 devnull 	syslog(0, blog, "dhcp: lease for %I to %s ended at %ld but still in use\n",
270 87a52e04 2005-12-26 devnull 		b->ip, b->boundto != nil ? b->boundto : "?", b->lease);
271 87a52e04 2005-12-26 devnull 	b->lastcomplained = now;
272 87a52e04 2005-12-26 devnull }
273 87a52e04 2005-12-26 devnull 
274 87a52e04 2005-12-26 devnull /*
275 87a52e04 2005-12-26 devnull  *  find a free binding for a hw addr or id on the same network as iip
276 87a52e04 2005-12-26 devnull  */
277 87a52e04 2005-12-26 devnull extern Binding*
278 87a52e04 2005-12-26 devnull idtobinding(char *id, Info *iip, int ping)
279 87a52e04 2005-12-26 devnull {
280 87a52e04 2005-12-26 devnull 	Binding *b, *oldest;
281 87a52e04 2005-12-26 devnull 	int oldesttime;
282 87a52e04 2005-12-26 devnull 
283 87a52e04 2005-12-26 devnull 	/*
284 87a52e04 2005-12-26 devnull 	 *  first look for an old binding that matches.  that way
285 87a52e04 2005-12-26 devnull 	 *  clients will tend to keep the same ip addresses.
286 87a52e04 2005-12-26 devnull 	 */
287 87a52e04 2005-12-26 devnull 	for(b = bcache; b; b = b->next){
288 87a52e04 2005-12-26 devnull 		if(b->boundto && strcmp(b->boundto, id) == 0){
289 87a52e04 2005-12-26 devnull 			if(!samenet(b->ip, iip))
290 87a52e04 2005-12-26 devnull 				continue;
291 87a52e04 2005-12-26 devnull 
292 87a52e04 2005-12-26 devnull 			/* check with the other servers */
293 87a52e04 2005-12-26 devnull 			syncbinding(b, 0);
294 87a52e04 2005-12-26 devnull 			if(strcmp(b->boundto, id) == 0)
295 87a52e04 2005-12-26 devnull 				return b;
296 87a52e04 2005-12-26 devnull 		}
297 87a52e04 2005-12-26 devnull 	}
298 87a52e04 2005-12-26 devnull 
299 87a52e04 2005-12-26 devnull 	/*
300 87a52e04 2005-12-26 devnull 	 *  look for oldest binding that we think is unused
301 87a52e04 2005-12-26 devnull 	 */
302 87a52e04 2005-12-26 devnull 	for(;;){
303 87a52e04 2005-12-26 devnull 		oldest = nil;
304 87a52e04 2005-12-26 devnull 		oldesttime = 0;
305 87a52e04 2005-12-26 devnull 		for(b = bcache; b; b = b->next){
306 87a52e04 2005-12-26 devnull 			if(b->tried != now)
307 87a52e04 2005-12-26 devnull 			if(b->lease < now && b->expoffer < now && samenet(b->ip, iip))
308 87a52e04 2005-12-26 devnull 			if(oldest == nil || b->lasttouched < oldesttime){
309 87a52e04 2005-12-26 devnull 				/* sync and check again */
310 87a52e04 2005-12-26 devnull 				syncbinding(b, 0);
311 87a52e04 2005-12-26 devnull 				if(b->lease < now && b->expoffer < now && samenet(b->ip, iip))
312 87a52e04 2005-12-26 devnull 				if(oldest == nil || b->lasttouched < oldesttime){
313 87a52e04 2005-12-26 devnull 					oldest = b;
314 87a52e04 2005-12-26 devnull 					oldesttime = b->lasttouched;
315 87a52e04 2005-12-26 devnull 				}
316 87a52e04 2005-12-26 devnull 			}
317 87a52e04 2005-12-26 devnull 		}
318 87a52e04 2005-12-26 devnull 		if(oldest == nil)
319 87a52e04 2005-12-26 devnull 			break;
320 87a52e04 2005-12-26 devnull 
321 87a52e04 2005-12-26 devnull 		/* make sure noone is still using it */
322 87a52e04 2005-12-26 devnull 		oldest->tried = now;
323 87a52e04 2005-12-26 devnull 		if(ping == 0 || icmpecho(oldest->ip) == 0)
324 87a52e04 2005-12-26 devnull 			return oldest;
325 87a52e04 2005-12-26 devnull 
326 87a52e04 2005-12-26 devnull 		lognolease(oldest);	/* sets lastcomplained */
327 87a52e04 2005-12-26 devnull 	}
328 87a52e04 2005-12-26 devnull 
329 87a52e04 2005-12-26 devnull 	/* try all bindings */
330 87a52e04 2005-12-26 devnull 	for(b = bcache; b; b = b->next){
331 87a52e04 2005-12-26 devnull 		syncbinding(b, 0);
332 87a52e04 2005-12-26 devnull 		if(b->tried != now)
333 87a52e04 2005-12-26 devnull 		if(b->lease < now && b->expoffer < now && samenet(b->ip, iip)){
334 87a52e04 2005-12-26 devnull 			b->tried = now;
335 87a52e04 2005-12-26 devnull 			if(ping == 0 || icmpecho(b->ip) == 0)
336 87a52e04 2005-12-26 devnull 				return b;
337 87a52e04 2005-12-26 devnull 
338 87a52e04 2005-12-26 devnull 			lognolease(b);
339 87a52e04 2005-12-26 devnull 		}
340 87a52e04 2005-12-26 devnull 	}
341 87a52e04 2005-12-26 devnull 
342 87a52e04 2005-12-26 devnull 	/* nothing worked, give up */
343 87a52e04 2005-12-26 devnull 	return 0;
344 87a52e04 2005-12-26 devnull }
345 87a52e04 2005-12-26 devnull 
346 87a52e04 2005-12-26 devnull /*
347 87a52e04 2005-12-26 devnull  *  create an offer
348 87a52e04 2005-12-26 devnull  */
349 87a52e04 2005-12-26 devnull extern void
350 87a52e04 2005-12-26 devnull mkoffer(Binding *b, char *id, long leasetime)
351 87a52e04 2005-12-26 devnull {
352 87a52e04 2005-12-26 devnull 	if(leasetime <= 0){
353 87a52e04 2005-12-26 devnull 		if(b->lease > now + minlease)
354 87a52e04 2005-12-26 devnull 			leasetime = b->lease - now;
355 87a52e04 2005-12-26 devnull 		else
356 87a52e04 2005-12-26 devnull 			leasetime = minlease;
357 87a52e04 2005-12-26 devnull 	}
358 87a52e04 2005-12-26 devnull 	if(b->offeredto)
359 87a52e04 2005-12-26 devnull 		free(b->offeredto);
360 87a52e04 2005-12-26 devnull 	b->offeredto = strdup(id);
361 87a52e04 2005-12-26 devnull 	b->offer = leasetime;
362 87a52e04 2005-12-26 devnull 	b->expoffer = now + OfferTimeout;
363 87a52e04 2005-12-26 devnull }
364 87a52e04 2005-12-26 devnull 
365 87a52e04 2005-12-26 devnull /*
366 87a52e04 2005-12-26 devnull  *  find an offer for this id
367 87a52e04 2005-12-26 devnull  */
368 87a52e04 2005-12-26 devnull extern Binding*
369 87a52e04 2005-12-26 devnull idtooffer(char *id, Info *iip)
370 87a52e04 2005-12-26 devnull {
371 87a52e04 2005-12-26 devnull 	Binding *b;
372 87a52e04 2005-12-26 devnull 
373 87a52e04 2005-12-26 devnull 	/* look for an offer to this id */
374 87a52e04 2005-12-26 devnull 	for(b = bcache; b; b = b->next){
375 87a52e04 2005-12-26 devnull 		if(b->offeredto && strcmp(b->offeredto, id) == 0 && samenet(b->ip, iip)){
376 87a52e04 2005-12-26 devnull 			/* make sure some other system hasn't stolen it */
377 87a52e04 2005-12-26 devnull 			syncbinding(b, 0);
378 87a52e04 2005-12-26 devnull 			if(b->lease < now
379 87a52e04 2005-12-26 devnull 			|| (b->boundto && strcmp(b->boundto, b->offeredto) == 0))
380 87a52e04 2005-12-26 devnull 				return b;
381 87a52e04 2005-12-26 devnull 		}
382 87a52e04 2005-12-26 devnull 	}
383 87a52e04 2005-12-26 devnull 	return 0;
384 87a52e04 2005-12-26 devnull }
385 87a52e04 2005-12-26 devnull 
386 87a52e04 2005-12-26 devnull /*
387 87a52e04 2005-12-26 devnull  *  commit a lease, this could fail
388 87a52e04 2005-12-26 devnull  */
389 87a52e04 2005-12-26 devnull extern int
390 87a52e04 2005-12-26 devnull commitbinding(Binding *b)
391 87a52e04 2005-12-26 devnull {
392 87a52e04 2005-12-26 devnull 	int fd;
393 87a52e04 2005-12-26 devnull 	long now;
394 87a52e04 2005-12-26 devnull 
395 87a52e04 2005-12-26 devnull 	now = time(0);
396 87a52e04 2005-12-26 devnull 
397 87a52e04 2005-12-26 devnull 	if(b->offeredto == 0)
398 87a52e04 2005-12-26 devnull 		return -1;
399 87a52e04 2005-12-26 devnull 	fd = syncbinding(b, 1);
400 87a52e04 2005-12-26 devnull 	if(fd < 0)
401 87a52e04 2005-12-26 devnull 		return -1;
402 87a52e04 2005-12-26 devnull 	if(b->lease > now && b->boundto && strcmp(b->boundto, b->offeredto) != 0){
403 87a52e04 2005-12-26 devnull 		close(fd);
404 87a52e04 2005-12-26 devnull 		return -1;
405 87a52e04 2005-12-26 devnull 	}
406 87a52e04 2005-12-26 devnull 	setbinding(b, b->offeredto, now + b->offer);
407 87a52e04 2005-12-26 devnull 	b->lasttouched = now;
408 fa325e9b 2020-01-10 cross 
409 87a52e04 2005-12-26 devnull 	if(writebinding(fd, b) < 0){
410 87a52e04 2005-12-26 devnull 		close(fd);
411 87a52e04 2005-12-26 devnull 		return -1;
412 87a52e04 2005-12-26 devnull 	}
413 87a52e04 2005-12-26 devnull 	close(fd);
414 87a52e04 2005-12-26 devnull 	return 0;
415 87a52e04 2005-12-26 devnull }
416 87a52e04 2005-12-26 devnull 
417 87a52e04 2005-12-26 devnull /*
418 87a52e04 2005-12-26 devnull  *  commit a lease, this could fail
419 87a52e04 2005-12-26 devnull  */
420 87a52e04 2005-12-26 devnull extern int
421 87a52e04 2005-12-26 devnull releasebinding(Binding *b, char *id)
422 87a52e04 2005-12-26 devnull {
423 87a52e04 2005-12-26 devnull 	int fd;
424 87a52e04 2005-12-26 devnull 	long now;
425 87a52e04 2005-12-26 devnull 
426 87a52e04 2005-12-26 devnull 	now = time(0);
427 87a52e04 2005-12-26 devnull 
428 87a52e04 2005-12-26 devnull 	fd = syncbinding(b, 1);
429 87a52e04 2005-12-26 devnull 	if(fd < 0)
430 87a52e04 2005-12-26 devnull 		return -1;
431 87a52e04 2005-12-26 devnull 	if(b->lease > now && b->boundto && strcmp(b->boundto, id) != 0){
432 87a52e04 2005-12-26 devnull 		close(fd);
433 87a52e04 2005-12-26 devnull 		return -1;
434 87a52e04 2005-12-26 devnull 	}
435 87a52e04 2005-12-26 devnull 	b->lease = 0;
436 87a52e04 2005-12-26 devnull 	b->expoffer = 0;
437 fa325e9b 2020-01-10 cross 
438 87a52e04 2005-12-26 devnull 	if(writebinding(fd, b) < 0){
439 87a52e04 2005-12-26 devnull 		close(fd);
440 87a52e04 2005-12-26 devnull 		return -1;
441 87a52e04 2005-12-26 devnull 	}
442 87a52e04 2005-12-26 devnull 	close(fd);
443 87a52e04 2005-12-26 devnull 	return 0;
444 87a52e04 2005-12-26 devnull }