1 056fe1ba 2003-11-23 devnull #include <u.h>
2 056fe1ba 2003-11-23 devnull #include <libc.h>
3 056fe1ba 2003-11-23 devnull #include <venti.h>
4 056fe1ba 2003-11-23 devnull #include <libsec.h>
6 056fe1ba 2003-11-23 devnull typedef struct Mem Mem;
7 056fe1ba 2003-11-23 devnull typedef struct Frag Frag;
10 056fe1ba 2003-11-23 devnull BigMemSize = MaxFragSize,
11 056fe1ba 2003-11-23 devnull SmallMemSize = BigMemSize/8,
12 056fe1ba 2003-11-23 devnull NLocalFrag = 2,
15 056fe1ba 2003-11-23 devnull /* position to carve out of a Mem */
22 056fe1ba 2003-11-23 devnull struct Mem
26 056fe1ba 2003-11-23 devnull uchar *bp;
27 056fe1ba 2003-11-23 devnull uchar *ep;
28 056fe1ba 2003-11-23 devnull uchar *rp;
29 056fe1ba 2003-11-23 devnull uchar *wp;
30 056fe1ba 2003-11-23 devnull Mem *next;
34 056fe1ba 2003-11-23 devnull FragLocalFree,
35 056fe1ba 2003-11-23 devnull FragLocalAlloc,
36 056fe1ba 2003-11-23 devnull FragGlobal,
39 056fe1ba 2003-11-23 devnull struct Frag
41 056fe1ba 2003-11-23 devnull int state;
42 056fe1ba 2003-11-23 devnull Mem *mem;
43 056fe1ba 2003-11-23 devnull uchar *rp;
44 056fe1ba 2003-11-23 devnull uchar *wp;
45 056fe1ba 2003-11-23 devnull Frag *next;
46 056fe1ba 2003-11-23 devnull void (*free)(void*);
48 8baa0cbd 2004-06-09 devnull Packet *p; /* parent packet, for debugging only */
51 056fe1ba 2003-11-23 devnull struct Packet
53 056fe1ba 2003-11-23 devnull int size;
54 056fe1ba 2003-11-23 devnull int asize; /* allocated memory - greater than size unless foreign frags */
55 8baa0cbd 2004-06-09 devnull ulong pc;
57 056fe1ba 2003-11-23 devnull Packet *next;
59 056fe1ba 2003-11-23 devnull Frag *first;
60 056fe1ba 2003-11-23 devnull Frag *last;
62 056fe1ba 2003-11-23 devnull Frag local[NLocalFrag];
65 056fe1ba 2003-11-23 devnull static Frag *fragalloc(Packet*, int n, int pos, Frag *next);
66 056fe1ba 2003-11-23 devnull static Frag *fragdup(Packet*, Frag*);
67 056fe1ba 2003-11-23 devnull static void fragfree(Frag*);
69 056fe1ba 2003-11-23 devnull static Mem *memalloc(int, int);
70 056fe1ba 2003-11-23 devnull static void memfree(Mem*);
71 056fe1ba 2003-11-23 devnull static int memhead(Mem *m, uchar *rp, int n);
72 056fe1ba 2003-11-23 devnull static int memtail(Mem *m, uchar *wp, int n);
74 056fe1ba 2003-11-23 devnull static char EPacketSize[] = "bad packet size";
75 056fe1ba 2003-11-23 devnull static char EPacketOffset[] = "bad packet offset";
76 056fe1ba 2003-11-23 devnull static char EBadSize[] = "bad size";
78 8baa0cbd 2004-06-09 devnull static void checkpacket(Packet*);
81 8baa0cbd 2004-06-09 devnull * the free list is primarily for speed, but it is
82 8baa0cbd 2004-06-09 devnull * also necessary for packetsplit that packets
83 8baa0cbd 2004-06-09 devnull * are never freed -- a packet can contain a different
84 8baa0cbd 2004-06-09 devnull * packet's local fragments, thanks to packetsplit!
86 056fe1ba 2003-11-23 devnull static struct {
88 056fe1ba 2003-11-23 devnull Packet *packet;
89 056fe1ba 2003-11-23 devnull int npacket;
90 056fe1ba 2003-11-23 devnull Frag *frag;
91 056fe1ba 2003-11-23 devnull int nfrag;
92 056fe1ba 2003-11-23 devnull Mem *bigmem;
93 056fe1ba 2003-11-23 devnull int nbigmem;
94 056fe1ba 2003-11-23 devnull Mem *smallmem;
95 056fe1ba 2003-11-23 devnull int nsmallmem;
96 056fe1ba 2003-11-23 devnull } freelist;
98 056fe1ba 2003-11-23 devnull #define FRAGSIZE(f) ((f)->wp - (f)->rp)
99 056fe1ba 2003-11-23 devnull #define FRAGASIZE(f) ((f)->mem ? (f)->mem->ep - (f)->mem->bp : 0)
101 8baa0cbd 2004-06-09 devnull #define NOTFREE(p) assert((p)->size>=0)/*; checkpacket(p)*/
103 056fe1ba 2003-11-23 devnull Packet *
104 056fe1ba 2003-11-23 devnull packetalloc(void)
106 056fe1ba 2003-11-23 devnull Packet *p;
108 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
109 056fe1ba 2003-11-23 devnull p = freelist.packet;
110 056fe1ba 2003-11-23 devnull if(p != nil)
111 056fe1ba 2003-11-23 devnull freelist.packet = p->next;
113 056fe1ba 2003-11-23 devnull freelist.npacket++;
114 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
116 056fe1ba 2003-11-23 devnull if(p == nil)
117 056fe1ba 2003-11-23 devnull p = vtbrk(sizeof(Packet));
119 056fe1ba 2003-11-23 devnull assert(p->size == -1);
120 056fe1ba 2003-11-23 devnull p->size = 0;
121 056fe1ba 2003-11-23 devnull p->asize = 0;
122 056fe1ba 2003-11-23 devnull p->first = nil;
123 056fe1ba 2003-11-23 devnull p->last = nil;
124 056fe1ba 2003-11-23 devnull p->next = nil;
125 8baa0cbd 2004-06-09 devnull p->pc = getcallerpc((char*)&p+8); /* might not work, but fine */
127 a09e80f9 2004-05-23 devnull //if(0)fprint(2, "packetalloc %p from %08lux %08lux %08lux\n", p, *((uint*)&p+2), *((uint*)&p+3), *((uint*)&p+4));
129 8baa0cbd 2004-06-09 devnull NOTFREE(p);
130 056fe1ba 2003-11-23 devnull return p;
134 056fe1ba 2003-11-23 devnull packetfree(Packet *p)
136 056fe1ba 2003-11-23 devnull Frag *f, *ff;
138 8baa0cbd 2004-06-09 devnull //if(1)fprint(2, "packetfree %p from %08lux\n", p, getcallerpc(&p));
140 056fe1ba 2003-11-23 devnull if(p == nil)
143 056fe1ba 2003-11-23 devnull NOTFREE(p);
144 8baa0cbd 2004-06-09 devnull p->pc = getcallerpc(&p);
146 056fe1ba 2003-11-23 devnull for(f=p->first; f!=nil; f=ff) {
147 056fe1ba 2003-11-23 devnull ff = f->next;
148 056fe1ba 2003-11-23 devnull fragfree(f);
150 8baa0cbd 2004-06-09 devnull p->first = (void*)0xDeadBeef;
151 8baa0cbd 2004-06-09 devnull p->last = (void*)0xDeadBeef;
152 8baa0cbd 2004-06-09 devnull p->size = -1;
154 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
155 056fe1ba 2003-11-23 devnull p->next = freelist.packet;
156 056fe1ba 2003-11-23 devnull freelist.packet = p;
157 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
160 056fe1ba 2003-11-23 devnull Packet *
161 056fe1ba 2003-11-23 devnull packetdup(Packet *p, int offset, int n)
163 056fe1ba 2003-11-23 devnull Frag *f, *ff;
164 056fe1ba 2003-11-23 devnull Packet *pp;
166 056fe1ba 2003-11-23 devnull NOTFREE(p);
167 056fe1ba 2003-11-23 devnull if(offset < 0 || n < 0 || offset+n > p->size) {
168 056fe1ba 2003-11-23 devnull werrstr(EBadSize);
169 056fe1ba 2003-11-23 devnull return nil;
172 056fe1ba 2003-11-23 devnull pp = packetalloc();
173 8baa0cbd 2004-06-09 devnull pp->pc = getcallerpc(&p);
174 8baa0cbd 2004-06-09 devnull if(n == 0){
175 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
176 056fe1ba 2003-11-23 devnull return pp;
179 056fe1ba 2003-11-23 devnull pp->size = n;
181 056fe1ba 2003-11-23 devnull /* skip offset */
182 056fe1ba 2003-11-23 devnull for(f=p->first; offset >= FRAGSIZE(f); f=f->next)
183 056fe1ba 2003-11-23 devnull offset -= FRAGSIZE(f);
185 056fe1ba 2003-11-23 devnull /* first frag */
186 056fe1ba 2003-11-23 devnull ff = fragdup(pp, f);
187 056fe1ba 2003-11-23 devnull ff->rp += offset;
188 056fe1ba 2003-11-23 devnull pp->first = ff;
189 056fe1ba 2003-11-23 devnull n -= FRAGSIZE(ff);
190 056fe1ba 2003-11-23 devnull pp->asize += FRAGASIZE(ff);
192 056fe1ba 2003-11-23 devnull /* the remaining */
193 056fe1ba 2003-11-23 devnull while(n > 0) {
194 056fe1ba 2003-11-23 devnull f = f->next;
195 056fe1ba 2003-11-23 devnull ff->next = fragdup(pp, f);
196 056fe1ba 2003-11-23 devnull ff = ff->next;
197 056fe1ba 2003-11-23 devnull n -= FRAGSIZE(ff);
198 056fe1ba 2003-11-23 devnull pp->asize += FRAGASIZE(ff);
201 056fe1ba 2003-11-23 devnull /* fix up last frag: note n <= 0 */
202 056fe1ba 2003-11-23 devnull ff->wp += n;
203 056fe1ba 2003-11-23 devnull ff->next = nil;
204 056fe1ba 2003-11-23 devnull pp->last = ff;
206 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
207 8baa0cbd 2004-06-09 devnull NOTFREE(p);
208 056fe1ba 2003-11-23 devnull return pp;
211 056fe1ba 2003-11-23 devnull Packet *
212 056fe1ba 2003-11-23 devnull packetsplit(Packet *p, int n)
214 056fe1ba 2003-11-23 devnull Packet *pp;
215 056fe1ba 2003-11-23 devnull Frag *f, *ff;
217 a09e80f9 2004-05-23 devnull if(0) fprint(2, "packetsplit %p %d\n", p, n);
218 056fe1ba 2003-11-23 devnull NOTFREE(p);
219 056fe1ba 2003-11-23 devnull if(n < 0 || n > p->size) {
220 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
221 056fe1ba 2003-11-23 devnull return nil;
224 056fe1ba 2003-11-23 devnull pp = packetalloc();
225 8baa0cbd 2004-06-09 devnull pp->pc = getcallerpc(&p);
226 8baa0cbd 2004-06-09 devnull if(n == 0){
227 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
228 056fe1ba 2003-11-23 devnull return pp;
231 056fe1ba 2003-11-23 devnull pp->size = n;
232 056fe1ba 2003-11-23 devnull p->size -= n;
233 056fe1ba 2003-11-23 devnull ff = nil;
234 056fe1ba 2003-11-23 devnull for(f=p->first; n > 0 && n >= FRAGSIZE(f); f=f->next) {
235 056fe1ba 2003-11-23 devnull n -= FRAGSIZE(f);
236 056fe1ba 2003-11-23 devnull p->asize -= FRAGASIZE(f);
237 056fe1ba 2003-11-23 devnull pp->asize += FRAGASIZE(f);
238 8baa0cbd 2004-06-09 devnull f->p = pp;
242 056fe1ba 2003-11-23 devnull /* split shared frag */
243 056fe1ba 2003-11-23 devnull if(n > 0) {
244 8baa0cbd 2004-06-09 devnull f->p = pp;
246 8baa0cbd 2004-06-09 devnull f = fragdup(p, ff);
247 056fe1ba 2003-11-23 devnull pp->asize += FRAGASIZE(ff);
248 056fe1ba 2003-11-23 devnull ff->wp = ff->rp + n;
249 056fe1ba 2003-11-23 devnull f->rp += n;
252 056fe1ba 2003-11-23 devnull pp->first = p->first;
253 056fe1ba 2003-11-23 devnull pp->last = ff;
254 8baa0cbd 2004-06-09 devnull ff->next = nil;
255 056fe1ba 2003-11-23 devnull p->first = f;
256 8baa0cbd 2004-06-09 devnull if(f == nil || f->next == nil)
257 8baa0cbd 2004-06-09 devnull p->last = f;
258 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
259 8baa0cbd 2004-06-09 devnull NOTFREE(p);
260 056fe1ba 2003-11-23 devnull return pp;
264 056fe1ba 2003-11-23 devnull packetconsume(Packet *p, uchar *buf, int n)
266 a09e80f9 2004-05-23 devnull if(0) fprint(2, "packetconsume %p %d\n", p, n);
267 056fe1ba 2003-11-23 devnull NOTFREE(p);
268 056fe1ba 2003-11-23 devnull if(buf && packetcopy(p, buf, 0, n) < 0)
269 d23a617a 2004-03-15 devnull return -1;
270 056fe1ba 2003-11-23 devnull return packettrim(p, n, p->size-n);
274 056fe1ba 2003-11-23 devnull packettrim(Packet *p, int offset, int n)
276 056fe1ba 2003-11-23 devnull Frag *f, *ff;
278 a09e80f9 2004-05-23 devnull if(0) fprint(2, "packettrim %p %d %d\n", p, offset, n);
279 056fe1ba 2003-11-23 devnull NOTFREE(p);
280 056fe1ba 2003-11-23 devnull if(offset < 0 || offset > p->size) {
281 056fe1ba 2003-11-23 devnull werrstr(EPacketOffset);
282 056fe1ba 2003-11-23 devnull return -1;
285 056fe1ba 2003-11-23 devnull if(n < 0 || offset + n > p->size) {
286 056fe1ba 2003-11-23 devnull werrstr(EPacketOffset);
287 056fe1ba 2003-11-23 devnull return -1;
290 056fe1ba 2003-11-23 devnull p->size = n;
292 056fe1ba 2003-11-23 devnull /* easy case */
293 056fe1ba 2003-11-23 devnull if(n == 0) {
294 056fe1ba 2003-11-23 devnull for(f=p->first; f != nil; f=ff) {
295 056fe1ba 2003-11-23 devnull ff = f->next;
296 056fe1ba 2003-11-23 devnull fragfree(f);
298 056fe1ba 2003-11-23 devnull p->first = p->last = nil;
299 056fe1ba 2003-11-23 devnull p->asize = 0;
300 8baa0cbd 2004-06-09 devnull NOTFREE(p);
301 056fe1ba 2003-11-23 devnull return 0;
304 056fe1ba 2003-11-23 devnull /* free before offset */
305 056fe1ba 2003-11-23 devnull for(f=p->first; offset >= FRAGSIZE(f); f=ff) {
306 056fe1ba 2003-11-23 devnull p->asize -= FRAGASIZE(f);
307 056fe1ba 2003-11-23 devnull offset -= FRAGSIZE(f);
308 056fe1ba 2003-11-23 devnull ff = f->next;
309 056fe1ba 2003-11-23 devnull fragfree(f);
312 056fe1ba 2003-11-23 devnull /* adjust frag */
313 056fe1ba 2003-11-23 devnull f->rp += offset;
314 056fe1ba 2003-11-23 devnull p->first = f;
316 056fe1ba 2003-11-23 devnull /* skip middle */
317 056fe1ba 2003-11-23 devnull for(; n > 0 && n > FRAGSIZE(f); f=f->next)
318 056fe1ba 2003-11-23 devnull n -= FRAGSIZE(f);
320 056fe1ba 2003-11-23 devnull /* adjust end */
321 056fe1ba 2003-11-23 devnull f->wp = f->rp + n;
322 056fe1ba 2003-11-23 devnull p->last = f;
323 056fe1ba 2003-11-23 devnull ff = f->next;
324 056fe1ba 2003-11-23 devnull f->next = nil;
326 056fe1ba 2003-11-23 devnull /* free after */
327 056fe1ba 2003-11-23 devnull for(f=ff; f != nil; f=ff) {
328 056fe1ba 2003-11-23 devnull p->asize -= FRAGASIZE(f);
329 056fe1ba 2003-11-23 devnull ff = f->next;
330 056fe1ba 2003-11-23 devnull fragfree(f);
332 8baa0cbd 2004-06-09 devnull NOTFREE(p);
333 056fe1ba 2003-11-23 devnull return 0;
337 056fe1ba 2003-11-23 devnull packetheader(Packet *p, int n)
339 056fe1ba 2003-11-23 devnull Frag *f;
342 056fe1ba 2003-11-23 devnull NOTFREE(p);
343 056fe1ba 2003-11-23 devnull if(n <= 0 || n > MaxFragSize) {
344 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
345 056fe1ba 2003-11-23 devnull return nil;
348 056fe1ba 2003-11-23 devnull p->size += n;
350 056fe1ba 2003-11-23 devnull /* try and fix in current frag */
351 056fe1ba 2003-11-23 devnull f = p->first;
352 056fe1ba 2003-11-23 devnull if(f != nil) {
353 056fe1ba 2003-11-23 devnull m = f->mem;
354 056fe1ba 2003-11-23 devnull if(n <= f->rp - m->bp)
355 056fe1ba 2003-11-23 devnull if(m->ref == 1 || memhead(m, f->rp, n) >= 0) {
356 056fe1ba 2003-11-23 devnull f->rp -= n;
357 8baa0cbd 2004-06-09 devnull NOTFREE(p);
358 056fe1ba 2003-11-23 devnull return f->rp;
362 056fe1ba 2003-11-23 devnull /* add frag to front */
363 056fe1ba 2003-11-23 devnull f = fragalloc(p, n, PEnd, p->first);
364 056fe1ba 2003-11-23 devnull p->asize += FRAGASIZE(f);
365 056fe1ba 2003-11-23 devnull if(p->first == nil)
366 056fe1ba 2003-11-23 devnull p->last = f;
367 056fe1ba 2003-11-23 devnull p->first = f;
368 8baa0cbd 2004-06-09 devnull NOTFREE(p);
369 056fe1ba 2003-11-23 devnull return f->rp;
373 056fe1ba 2003-11-23 devnull packettrailer(Packet *p, int n)
376 056fe1ba 2003-11-23 devnull Frag *f;
378 a09e80f9 2004-05-23 devnull if(0) fprint(2, "packettrailer %p %d\n", p, n);
379 056fe1ba 2003-11-23 devnull NOTFREE(p);
380 056fe1ba 2003-11-23 devnull if(n <= 0 || n > MaxFragSize) {
381 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
382 056fe1ba 2003-11-23 devnull return nil;
385 056fe1ba 2003-11-23 devnull p->size += n;
387 056fe1ba 2003-11-23 devnull /* try and fix in current frag */
388 056fe1ba 2003-11-23 devnull if(p->first != nil) {
389 056fe1ba 2003-11-23 devnull f = p->last;
390 056fe1ba 2003-11-23 devnull m = f->mem;
391 056fe1ba 2003-11-23 devnull if(n <= m->ep - f->wp)
392 056fe1ba 2003-11-23 devnull if(m->ref == 1 || memtail(m, f->wp, n) >= 0) {
393 056fe1ba 2003-11-23 devnull f->wp += n;
394 8baa0cbd 2004-06-09 devnull NOTFREE(p);
395 056fe1ba 2003-11-23 devnull return f->wp - n;
399 056fe1ba 2003-11-23 devnull /* add frag to end */
400 056fe1ba 2003-11-23 devnull f = fragalloc(p, n, (p->first == nil)?PMiddle:PFront, nil);
401 056fe1ba 2003-11-23 devnull p->asize += FRAGASIZE(f);
402 056fe1ba 2003-11-23 devnull if(p->first == nil)
403 056fe1ba 2003-11-23 devnull p->first = f;
405 056fe1ba 2003-11-23 devnull p->last->next = f;
406 056fe1ba 2003-11-23 devnull p->last = f;
407 8baa0cbd 2004-06-09 devnull NOTFREE(p);
408 056fe1ba 2003-11-23 devnull return f->rp;
412 056fe1ba 2003-11-23 devnull packetprefix(Packet *p, uchar *buf, int n)
414 056fe1ba 2003-11-23 devnull Frag *f;
418 056fe1ba 2003-11-23 devnull NOTFREE(p);
419 056fe1ba 2003-11-23 devnull if(n <= 0)
422 056fe1ba 2003-11-23 devnull p->size += n;
424 056fe1ba 2003-11-23 devnull /* try and fix in current frag */
425 056fe1ba 2003-11-23 devnull f = p->first;
426 056fe1ba 2003-11-23 devnull if(f != nil) {
427 056fe1ba 2003-11-23 devnull m = f->mem;
428 056fe1ba 2003-11-23 devnull nn = f->rp - m->bp;
429 056fe1ba 2003-11-23 devnull if(nn > n)
431 056fe1ba 2003-11-23 devnull if(m->ref == 1 || memhead(m, f->rp, nn) >= 0) {
432 056fe1ba 2003-11-23 devnull f->rp -= nn;
433 056fe1ba 2003-11-23 devnull n -= nn;
434 056fe1ba 2003-11-23 devnull memmove(f->rp, buf+n, nn);
438 056fe1ba 2003-11-23 devnull while(n > 0) {
440 056fe1ba 2003-11-23 devnull if(nn > MaxFragSize)
441 056fe1ba 2003-11-23 devnull nn = MaxFragSize;
442 056fe1ba 2003-11-23 devnull f = fragalloc(p, nn, PEnd, p->first);
443 056fe1ba 2003-11-23 devnull p->asize += FRAGASIZE(f);
444 056fe1ba 2003-11-23 devnull if(p->first == nil)
445 056fe1ba 2003-11-23 devnull p->last = f;
446 056fe1ba 2003-11-23 devnull p->first = f;
447 056fe1ba 2003-11-23 devnull n -= nn;
448 056fe1ba 2003-11-23 devnull memmove(f->rp, buf+n, nn);
450 8baa0cbd 2004-06-09 devnull NOTFREE(p);
454 056fe1ba 2003-11-23 devnull packetappend(Packet *p, uchar *buf, int n)
456 056fe1ba 2003-11-23 devnull Frag *f;
460 056fe1ba 2003-11-23 devnull NOTFREE(p);
461 056fe1ba 2003-11-23 devnull if(n <= 0)
464 056fe1ba 2003-11-23 devnull p->size += n;
465 056fe1ba 2003-11-23 devnull /* try and fix in current frag */
466 056fe1ba 2003-11-23 devnull if(p->first != nil) {
467 056fe1ba 2003-11-23 devnull f = p->last;
468 056fe1ba 2003-11-23 devnull m = f->mem;
469 056fe1ba 2003-11-23 devnull nn = m->ep - f->wp;
470 056fe1ba 2003-11-23 devnull if(nn > n)
472 056fe1ba 2003-11-23 devnull if(m->ref == 1 || memtail(m, f->wp, nn) >= 0) {
473 056fe1ba 2003-11-23 devnull memmove(f->wp, buf, nn);
474 056fe1ba 2003-11-23 devnull f->wp += nn;
475 056fe1ba 2003-11-23 devnull buf += nn;
476 056fe1ba 2003-11-23 devnull n -= nn;
480 056fe1ba 2003-11-23 devnull while(n > 0) {
482 056fe1ba 2003-11-23 devnull if(nn > MaxFragSize)
483 056fe1ba 2003-11-23 devnull nn = MaxFragSize;
484 056fe1ba 2003-11-23 devnull f = fragalloc(p, nn, (p->first == nil)?PMiddle:PFront, nil);
485 056fe1ba 2003-11-23 devnull p->asize += FRAGASIZE(f);
486 056fe1ba 2003-11-23 devnull if(p->first == nil)
487 056fe1ba 2003-11-23 devnull p->first = f;
489 056fe1ba 2003-11-23 devnull p->last->next = f;
490 056fe1ba 2003-11-23 devnull p->last = f;
491 056fe1ba 2003-11-23 devnull memmove(f->rp, buf, nn);
492 056fe1ba 2003-11-23 devnull buf += nn;
493 056fe1ba 2003-11-23 devnull n -= nn;
495 8baa0cbd 2004-06-09 devnull NOTFREE(p);
499 056fe1ba 2003-11-23 devnull packetconcat(Packet *p, Packet *pp)
501 8baa0cbd 2004-06-09 devnull Frag *f;
503 056fe1ba 2003-11-23 devnull NOTFREE(p);
504 056fe1ba 2003-11-23 devnull NOTFREE(pp);
505 056fe1ba 2003-11-23 devnull if(pp->size == 0)
507 056fe1ba 2003-11-23 devnull p->size += pp->size;
508 056fe1ba 2003-11-23 devnull p->asize += pp->asize;
509 8baa0cbd 2004-06-09 devnull for(f=pp->first; f; f=f->next)
510 8baa0cbd 2004-06-09 devnull f->p = p;
512 056fe1ba 2003-11-23 devnull if(p->first != nil)
513 056fe1ba 2003-11-23 devnull p->last->next = pp->first;
515 056fe1ba 2003-11-23 devnull p->first = pp->first;
517 056fe1ba 2003-11-23 devnull p->last = pp->last;
518 056fe1ba 2003-11-23 devnull pp->size = 0;
519 056fe1ba 2003-11-23 devnull pp->asize = 0;
520 056fe1ba 2003-11-23 devnull pp->first = nil;
521 056fe1ba 2003-11-23 devnull pp->last = nil;
522 8baa0cbd 2004-06-09 devnull NOTFREE(p);
523 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
527 056fe1ba 2003-11-23 devnull packetpeek(Packet *p, uchar *buf, int offset, int n)
529 056fe1ba 2003-11-23 devnull Frag *f;
531 056fe1ba 2003-11-23 devnull uchar *b;
533 056fe1ba 2003-11-23 devnull NOTFREE(p);
534 056fe1ba 2003-11-23 devnull if(n == 0)
535 056fe1ba 2003-11-23 devnull return buf;
537 056fe1ba 2003-11-23 devnull if(offset < 0 || offset >= p->size) {
538 056fe1ba 2003-11-23 devnull werrstr(EPacketOffset);
539 056fe1ba 2003-11-23 devnull return nil;
542 056fe1ba 2003-11-23 devnull if(n < 0 || offset + n > p->size) {
543 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
544 056fe1ba 2003-11-23 devnull return nil;
547 056fe1ba 2003-11-23 devnull /* skip up to offset */
548 056fe1ba 2003-11-23 devnull for(f=p->first; offset >= FRAGSIZE(f); f=f->next)
549 056fe1ba 2003-11-23 devnull offset -= FRAGSIZE(f);
551 056fe1ba 2003-11-23 devnull /* easy case */
552 8baa0cbd 2004-06-09 devnull if(offset + n <= FRAGSIZE(f)){
553 8baa0cbd 2004-06-09 devnull NOTFREE(p);
554 056fe1ba 2003-11-23 devnull return f->rp + offset;
557 056fe1ba 2003-11-23 devnull for(b=buf; n>0; n -= nn) {
558 056fe1ba 2003-11-23 devnull nn = FRAGSIZE(f) - offset;
559 056fe1ba 2003-11-23 devnull if(nn > n)
561 056fe1ba 2003-11-23 devnull memmove(b, f->rp+offset, nn);
562 056fe1ba 2003-11-23 devnull offset = 0;
563 056fe1ba 2003-11-23 devnull f = f->next;
564 056fe1ba 2003-11-23 devnull b += nn;
567 8baa0cbd 2004-06-09 devnull NOTFREE(p);
568 056fe1ba 2003-11-23 devnull return buf;
572 056fe1ba 2003-11-23 devnull packetcopy(Packet *p, uchar *buf, int offset, int n)
574 056fe1ba 2003-11-23 devnull uchar *b;
576 056fe1ba 2003-11-23 devnull NOTFREE(p);
577 056fe1ba 2003-11-23 devnull b = packetpeek(p, buf, offset, n);
578 056fe1ba 2003-11-23 devnull if(b == nil)
579 056fe1ba 2003-11-23 devnull return -1;
580 056fe1ba 2003-11-23 devnull if(b != buf)
581 056fe1ba 2003-11-23 devnull memmove(buf, b, n);
582 056fe1ba 2003-11-23 devnull return 0;
586 056fe1ba 2003-11-23 devnull packetfragments(Packet *p, IOchunk *io, int nio, int offset)
588 056fe1ba 2003-11-23 devnull Frag *f;
589 056fe1ba 2003-11-23 devnull int size;
590 056fe1ba 2003-11-23 devnull IOchunk *eio;
592 056fe1ba 2003-11-23 devnull NOTFREE(p);
593 056fe1ba 2003-11-23 devnull if(p->size == 0 || nio <= 0)
594 056fe1ba 2003-11-23 devnull return 0;
596 056fe1ba 2003-11-23 devnull if(offset < 0 || offset > p->size) {
597 056fe1ba 2003-11-23 devnull werrstr(EPacketOffset);
598 056fe1ba 2003-11-23 devnull return -1;
601 056fe1ba 2003-11-23 devnull for(f=p->first; offset >= FRAGSIZE(f); f=f->next)
602 056fe1ba 2003-11-23 devnull offset -= FRAGSIZE(f);
604 056fe1ba 2003-11-23 devnull size = 0;
605 056fe1ba 2003-11-23 devnull eio = io + nio;
606 056fe1ba 2003-11-23 devnull for(; f != nil && io < eio; f=f->next) {
607 056fe1ba 2003-11-23 devnull io->addr = f->rp + offset;
608 056fe1ba 2003-11-23 devnull io->len = f->wp - (f->rp + offset);
609 056fe1ba 2003-11-23 devnull offset = 0;
610 056fe1ba 2003-11-23 devnull size += io->len;
614 056fe1ba 2003-11-23 devnull return size;
618 056fe1ba 2003-11-23 devnull packetstats(void)
620 056fe1ba 2003-11-23 devnull Packet *p;
621 056fe1ba 2003-11-23 devnull Frag *f;
624 056fe1ba 2003-11-23 devnull int np, nf, nsm, nbm;
626 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
628 056fe1ba 2003-11-23 devnull for(p=freelist.packet; p; p=p->next)
631 056fe1ba 2003-11-23 devnull for(f=freelist.frag; f; f=f->next)
633 056fe1ba 2003-11-23 devnull nsm = 0;
634 056fe1ba 2003-11-23 devnull for(m=freelist.smallmem; m; m=m->next)
636 056fe1ba 2003-11-23 devnull nbm = 0;
637 056fe1ba 2003-11-23 devnull for(m=freelist.bigmem; m; m=m->next)
640 056fe1ba 2003-11-23 devnull fprint(2, "packet: %d/%d frag: %d/%d small mem: %d/%d big mem: %d/%d\n",
641 056fe1ba 2003-11-23 devnull np, freelist.npacket,
642 056fe1ba 2003-11-23 devnull nf, freelist.nfrag,
643 056fe1ba 2003-11-23 devnull nsm, freelist.nsmallmem,
644 056fe1ba 2003-11-23 devnull nbm, freelist.nbigmem);
646 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
651 056fe1ba 2003-11-23 devnull packetsize(Packet *p)
653 056fe1ba 2003-11-23 devnull NOTFREE(p);
655 056fe1ba 2003-11-23 devnull Frag *f;
656 056fe1ba 2003-11-23 devnull int size = 0;
658 056fe1ba 2003-11-23 devnull for(f=p->first; f; f=f->next)
659 056fe1ba 2003-11-23 devnull size += FRAGSIZE(f);
660 056fe1ba 2003-11-23 devnull if(size != p->size)
661 056fe1ba 2003-11-23 devnull fprint(2, "packetsize %d %d\n", size, p->size);
662 056fe1ba 2003-11-23 devnull assert(size == p->size);
664 056fe1ba 2003-11-23 devnull return p->size;
668 056fe1ba 2003-11-23 devnull packetasize(Packet *p)
670 056fe1ba 2003-11-23 devnull NOTFREE(p);
672 056fe1ba 2003-11-23 devnull Frag *f;
673 056fe1ba 2003-11-23 devnull int asize = 0;
675 056fe1ba 2003-11-23 devnull for(f=p->first; f; f=f->next)
676 056fe1ba 2003-11-23 devnull asize += FRAGASIZE(f);
677 056fe1ba 2003-11-23 devnull if(asize != p->asize)
678 056fe1ba 2003-11-23 devnull fprint(2, "packetasize %d %d\n", asize, p->asize);
679 056fe1ba 2003-11-23 devnull assert(asize == p->asize);
681 056fe1ba 2003-11-23 devnull return p->asize;
685 056fe1ba 2003-11-23 devnull packetsha1(Packet *p, uchar digest[VtScoreSize])
687 056fe1ba 2003-11-23 devnull DigestState ds;
688 056fe1ba 2003-11-23 devnull Frag *f;
689 056fe1ba 2003-11-23 devnull int size;
691 056fe1ba 2003-11-23 devnull NOTFREE(p);
692 056fe1ba 2003-11-23 devnull memset(&ds, 0, sizeof ds);
693 056fe1ba 2003-11-23 devnull size = p->size;
694 056fe1ba 2003-11-23 devnull for(f=p->first; f; f=f->next) {
695 056fe1ba 2003-11-23 devnull sha1(f->rp, FRAGSIZE(f), nil, &ds);
696 056fe1ba 2003-11-23 devnull size -= FRAGSIZE(f);
698 056fe1ba 2003-11-23 devnull assert(size == 0);
699 056fe1ba 2003-11-23 devnull sha1(nil, 0, digest, &ds);
703 056fe1ba 2003-11-23 devnull packetcmp(Packet *pkt0, Packet *pkt1)
705 056fe1ba 2003-11-23 devnull Frag *f0, *f1;
706 056fe1ba 2003-11-23 devnull int n0, n1, x;
708 056fe1ba 2003-11-23 devnull NOTFREE(pkt0);
709 056fe1ba 2003-11-23 devnull NOTFREE(pkt1);
710 056fe1ba 2003-11-23 devnull f0 = pkt0->first;
711 056fe1ba 2003-11-23 devnull f1 = pkt1->first;
713 056fe1ba 2003-11-23 devnull if(f0 == nil)
714 056fe1ba 2003-11-23 devnull return (f1 == nil)?0:-1;
715 056fe1ba 2003-11-23 devnull if(f1 == nil)
716 056fe1ba 2003-11-23 devnull return 1;
717 056fe1ba 2003-11-23 devnull n0 = FRAGSIZE(f0);
718 056fe1ba 2003-11-23 devnull n1 = FRAGSIZE(f1);
720 056fe1ba 2003-11-23 devnull for(;;) {
721 056fe1ba 2003-11-23 devnull if(n0 < n1) {
722 056fe1ba 2003-11-23 devnull x = memcmp(f0->wp - n0, f1->wp - n1, n0);
723 056fe1ba 2003-11-23 devnull if(x != 0)
724 056fe1ba 2003-11-23 devnull return x;
725 056fe1ba 2003-11-23 devnull n1 -= n0;
726 056fe1ba 2003-11-23 devnull f0 = f0->next;
727 056fe1ba 2003-11-23 devnull if(f0 == nil)
728 056fe1ba 2003-11-23 devnull return -1;
729 056fe1ba 2003-11-23 devnull n0 = FRAGSIZE(f0);
730 056fe1ba 2003-11-23 devnull } else if (n0 > n1) {
731 056fe1ba 2003-11-23 devnull x = memcmp(f0->wp - n0, f1->wp - n1, n1);
732 056fe1ba 2003-11-23 devnull if(x != 0)
733 056fe1ba 2003-11-23 devnull return x;
734 056fe1ba 2003-11-23 devnull n0 -= n1;
735 056fe1ba 2003-11-23 devnull f1 = f1->next;
736 056fe1ba 2003-11-23 devnull if(f1 == nil)
737 056fe1ba 2003-11-23 devnull return 1;
738 056fe1ba 2003-11-23 devnull n1 = FRAGSIZE(f1);
739 056fe1ba 2003-11-23 devnull } else { /* n0 == n1 */
740 056fe1ba 2003-11-23 devnull x = memcmp(f0->wp - n0, f1->wp - n1, n0);
741 056fe1ba 2003-11-23 devnull if(x != 0)
742 056fe1ba 2003-11-23 devnull return x;
743 056fe1ba 2003-11-23 devnull f0 = f0->next;
744 056fe1ba 2003-11-23 devnull f1 = f1->next;
745 056fe1ba 2003-11-23 devnull if(f0 == nil)
746 056fe1ba 2003-11-23 devnull return (f1 == nil)?0:-1;
747 056fe1ba 2003-11-23 devnull if(f1 == nil)
748 056fe1ba 2003-11-23 devnull return 1;
749 056fe1ba 2003-11-23 devnull n0 = FRAGSIZE(f0);
750 056fe1ba 2003-11-23 devnull n1 = FRAGSIZE(f1);
753 056fe1ba 2003-11-23 devnull return 0; /* for ken */
757 056fe1ba 2003-11-23 devnull static Frag *
758 056fe1ba 2003-11-23 devnull fragalloc(Packet *p, int n, int pos, Frag *next)
760 056fe1ba 2003-11-23 devnull Frag *f, *ef;
763 056fe1ba 2003-11-23 devnull /* look for local frag */
764 056fe1ba 2003-11-23 devnull f = &p->local[0];
765 056fe1ba 2003-11-23 devnull ef = &p->local[NLocalFrag];
766 056fe1ba 2003-11-23 devnull for(;f<ef; f++) {
767 056fe1ba 2003-11-23 devnull if(f->state == FragLocalFree) {
768 056fe1ba 2003-11-23 devnull f->state = FragLocalAlloc;
769 056fe1ba 2003-11-23 devnull goto Found;
772 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
773 056fe1ba 2003-11-23 devnull f = freelist.frag;
774 056fe1ba 2003-11-23 devnull if(f != nil)
775 056fe1ba 2003-11-23 devnull freelist.frag = f->next;
777 056fe1ba 2003-11-23 devnull freelist.nfrag++;
778 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
780 056fe1ba 2003-11-23 devnull if(f == nil) {
781 056fe1ba 2003-11-23 devnull f = vtbrk(sizeof(Frag));
782 056fe1ba 2003-11-23 devnull f->state = FragGlobal;
786 056fe1ba 2003-11-23 devnull f->next = next;
787 8baa0cbd 2004-06-09 devnull f->p = p;
789 056fe1ba 2003-11-23 devnull if(n == 0){
790 056fe1ba 2003-11-23 devnull f->mem = 0;
791 056fe1ba 2003-11-23 devnull f->rp = 0;
792 056fe1ba 2003-11-23 devnull f->wp = 0;
793 056fe1ba 2003-11-23 devnull return f;
796 056fe1ba 2003-11-23 devnull if(pos == PEnd && next == nil)
797 056fe1ba 2003-11-23 devnull pos = PMiddle;
798 056fe1ba 2003-11-23 devnull m = memalloc(n, pos);
799 056fe1ba 2003-11-23 devnull f->mem = m;
800 056fe1ba 2003-11-23 devnull f->rp = m->rp;
801 056fe1ba 2003-11-23 devnull f->wp = m->wp;
802 056fe1ba 2003-11-23 devnull return f;
806 056fe1ba 2003-11-23 devnull packetforeign(uchar *buf, int n, void (*free)(void *a), void *a)
808 056fe1ba 2003-11-23 devnull Packet *p;
809 056fe1ba 2003-11-23 devnull Frag *f;
811 056fe1ba 2003-11-23 devnull p = packetalloc();
812 8baa0cbd 2004-06-09 devnull p->pc = getcallerpc(&buf);
813 056fe1ba 2003-11-23 devnull f = fragalloc(p, 0, 0, nil);
814 056fe1ba 2003-11-23 devnull f->free = free;
815 056fe1ba 2003-11-23 devnull f->a = a;
816 056fe1ba 2003-11-23 devnull f->next = nil;
817 056fe1ba 2003-11-23 devnull f->rp = buf;
818 056fe1ba 2003-11-23 devnull f->wp = buf+n;
820 056fe1ba 2003-11-23 devnull p->first = f;
821 8baa0cbd 2004-06-09 devnull p->last = f;
822 056fe1ba 2003-11-23 devnull p->size = n;
823 8baa0cbd 2004-06-09 devnull NOTFREE(p);
824 056fe1ba 2003-11-23 devnull return p;
827 056fe1ba 2003-11-23 devnull static Frag *
828 056fe1ba 2003-11-23 devnull fragdup(Packet *p, Frag *f)
830 056fe1ba 2003-11-23 devnull Frag *ff;
833 056fe1ba 2003-11-23 devnull m = f->mem;
836 056fe1ba 2003-11-23 devnull * m->rp && m->wp can be out of date when ref == 1
837 056fe1ba 2003-11-23 devnull * also, potentially reclaims space from previous frags
839 056fe1ba 2003-11-23 devnull if(m && m->ref == 1) {
840 056fe1ba 2003-11-23 devnull m->rp = f->rp;
841 056fe1ba 2003-11-23 devnull m->wp = f->wp;
844 056fe1ba 2003-11-23 devnull ff = fragalloc(p, 0, 0, nil);
845 8baa0cbd 2004-06-09 devnull ff->mem = f->mem;
846 8baa0cbd 2004-06-09 devnull ff->rp = f->rp;
847 8baa0cbd 2004-06-09 devnull ff->wp = f->wp;
848 8baa0cbd 2004-06-09 devnull ff->next = f->next;
851 8baa0cbd 2004-06-09 devnull * We can't duplicate these -- there's no dup function.
853 8baa0cbd 2004-06-09 devnull assert(f->free==nil && f->a==nil);
856 056fe1ba 2003-11-23 devnull lock(&m->lk);
857 056fe1ba 2003-11-23 devnull m->ref++;
858 056fe1ba 2003-11-23 devnull unlock(&m->lk);
862 056fe1ba 2003-11-23 devnull return ff;
866 056fe1ba 2003-11-23 devnull static void
867 056fe1ba 2003-11-23 devnull fragfree(Frag *f)
869 056fe1ba 2003-11-23 devnull if(f->mem == nil){
870 056fe1ba 2003-11-23 devnull if(f->free)
871 056fe1ba 2003-11-23 devnull (*f->free)(f->a);
873 056fe1ba 2003-11-23 devnull memfree(f->mem);
874 056fe1ba 2003-11-23 devnull f->mem = 0;
877 056fe1ba 2003-11-23 devnull if(f->state == FragLocalAlloc) {
878 056fe1ba 2003-11-23 devnull f->state = FragLocalFree;
882 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
883 056fe1ba 2003-11-23 devnull f->next = freelist.frag;
884 056fe1ba 2003-11-23 devnull freelist.frag = f;
885 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
888 056fe1ba 2003-11-23 devnull static Mem *
889 056fe1ba 2003-11-23 devnull memalloc(int n, int pos)
894 056fe1ba 2003-11-23 devnull if(n < 0 || n > MaxFragSize) {
895 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
896 056fe1ba 2003-11-23 devnull return 0;
898 056fe1ba 2003-11-23 devnull if(n <= SmallMemSize) {
899 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
900 056fe1ba 2003-11-23 devnull m = freelist.smallmem;
901 056fe1ba 2003-11-23 devnull if(m != nil)
902 056fe1ba 2003-11-23 devnull freelist.smallmem = m->next;
904 056fe1ba 2003-11-23 devnull freelist.nsmallmem++;
905 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
906 056fe1ba 2003-11-23 devnull nn = SmallMemSize;
907 056fe1ba 2003-11-23 devnull } else {
908 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
909 056fe1ba 2003-11-23 devnull m = freelist.bigmem;
910 056fe1ba 2003-11-23 devnull if(m != nil)
911 056fe1ba 2003-11-23 devnull freelist.bigmem = m->next;
913 056fe1ba 2003-11-23 devnull freelist.nbigmem++;
914 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
915 056fe1ba 2003-11-23 devnull nn = BigMemSize;
918 056fe1ba 2003-11-23 devnull if(m == nil) {
919 056fe1ba 2003-11-23 devnull m = vtbrk(sizeof(Mem));
920 056fe1ba 2003-11-23 devnull m->bp = vtbrk(nn);
921 056fe1ba 2003-11-23 devnull m->ep = m->bp + nn;
923 056fe1ba 2003-11-23 devnull assert(m->ref == 0);
924 056fe1ba 2003-11-23 devnull m->ref = 1;
926 056fe1ba 2003-11-23 devnull switch(pos) {
927 056fe1ba 2003-11-23 devnull default:
928 056fe1ba 2003-11-23 devnull assert(0);
929 056fe1ba 2003-11-23 devnull case PFront:
930 056fe1ba 2003-11-23 devnull m->rp = m->bp;
932 056fe1ba 2003-11-23 devnull case PMiddle:
933 056fe1ba 2003-11-23 devnull /* leave a little bit at end */
934 056fe1ba 2003-11-23 devnull m->rp = m->ep - n - 32;
936 056fe1ba 2003-11-23 devnull case PEnd:
937 056fe1ba 2003-11-23 devnull m->rp = m->ep - n;
940 056fe1ba 2003-11-23 devnull /* check we did not blow it */
941 056fe1ba 2003-11-23 devnull if(m->rp < m->bp)
942 056fe1ba 2003-11-23 devnull m->rp = m->bp;
943 056fe1ba 2003-11-23 devnull m->wp = m->rp + n;
944 056fe1ba 2003-11-23 devnull assert(m->rp >= m->bp && m->wp <= m->ep);
945 056fe1ba 2003-11-23 devnull return m;
948 056fe1ba 2003-11-23 devnull static void
949 056fe1ba 2003-11-23 devnull memfree(Mem *m)
951 056fe1ba 2003-11-23 devnull lock(&m->lk);
952 056fe1ba 2003-11-23 devnull m->ref--;
953 056fe1ba 2003-11-23 devnull if(m->ref > 0) {
954 056fe1ba 2003-11-23 devnull unlock(&m->lk);
957 056fe1ba 2003-11-23 devnull unlock(&m->lk);
958 056fe1ba 2003-11-23 devnull assert(m->ref == 0);
960 8baa0cbd 2004-06-09 devnull /* memset(m->bp, 0xEF, m->ep-m->bp); */
961 056fe1ba 2003-11-23 devnull switch(m->ep - m->bp) {
962 056fe1ba 2003-11-23 devnull default:
963 056fe1ba 2003-11-23 devnull assert(0);
964 056fe1ba 2003-11-23 devnull case SmallMemSize:
965 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
966 056fe1ba 2003-11-23 devnull m->next = freelist.smallmem;
967 056fe1ba 2003-11-23 devnull freelist.smallmem = m;
968 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
970 056fe1ba 2003-11-23 devnull case BigMemSize:
971 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
972 056fe1ba 2003-11-23 devnull m->next = freelist.bigmem;
973 056fe1ba 2003-11-23 devnull freelist.bigmem = m;
974 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
979 056fe1ba 2003-11-23 devnull static int
980 056fe1ba 2003-11-23 devnull memhead(Mem *m, uchar *rp, int n)
982 8baa0cbd 2004-06-09 devnull fprint(2, "memhead called\n");
983 8baa0cbd 2004-06-09 devnull abort();
984 056fe1ba 2003-11-23 devnull lock(&m->lk);
985 056fe1ba 2003-11-23 devnull if(m->rp != rp) {
986 056fe1ba 2003-11-23 devnull unlock(&m->lk);
987 056fe1ba 2003-11-23 devnull return -1;
989 056fe1ba 2003-11-23 devnull m->rp -= n;
990 056fe1ba 2003-11-23 devnull unlock(&m->lk);
991 056fe1ba 2003-11-23 devnull return 0;
994 056fe1ba 2003-11-23 devnull static int
995 056fe1ba 2003-11-23 devnull memtail(Mem *m, uchar *wp, int n)
997 8baa0cbd 2004-06-09 devnull fprint(2, "memtail called\n");
998 8baa0cbd 2004-06-09 devnull abort();
999 056fe1ba 2003-11-23 devnull lock(&m->lk);
1000 056fe1ba 2003-11-23 devnull if(m->wp != wp) {
1001 056fe1ba 2003-11-23 devnull unlock(&m->lk);
1002 056fe1ba 2003-11-23 devnull return -1;
1004 056fe1ba 2003-11-23 devnull m->wp += n;
1005 056fe1ba 2003-11-23 devnull unlock(&m->lk);
1006 056fe1ba 2003-11-23 devnull return 0;
1009 8baa0cbd 2004-06-09 devnull static void
1010 8baa0cbd 2004-06-09 devnull checkpacket(Packet *p)
1012 8baa0cbd 2004-06-09 devnull int s, as;
1013 8baa0cbd 2004-06-09 devnull Frag *f;
1014 8baa0cbd 2004-06-09 devnull Frag *ff;
1017 8baa0cbd 2004-06-09 devnull as = 0;
1018 8baa0cbd 2004-06-09 devnull ff=p->first;
1019 8baa0cbd 2004-06-09 devnull for(f=p->first; f; ff=f,f=f->next){
1020 8baa0cbd 2004-06-09 devnull assert(f->p == p);
1021 8baa0cbd 2004-06-09 devnull s += FRAGSIZE(f);
1022 8baa0cbd 2004-06-09 devnull as += FRAGASIZE(f);
1024 8baa0cbd 2004-06-09 devnull assert(s == p->size);
1025 8baa0cbd 2004-06-09 devnull assert(as == p->asize);
1026 8baa0cbd 2004-06-09 devnull if(p->first)
1027 8baa0cbd 2004-06-09 devnull assert(ff==p->last);
