Blame


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>
5 056fe1ba 2003-11-23 devnull
6 056fe1ba 2003-11-23 devnull typedef struct Mem Mem;
7 056fe1ba 2003-11-23 devnull typedef struct Frag Frag;
8 056fe1ba 2003-11-23 devnull
9 056fe1ba 2003-11-23 devnull enum {
10 056fe1ba 2003-11-23 devnull BigMemSize = MaxFragSize,
11 056fe1ba 2003-11-23 devnull SmallMemSize = BigMemSize/8,
12 cbeb0b26 2006-04-01 devnull NLocalFrag = 2
13 056fe1ba 2003-11-23 devnull };
14 056fe1ba 2003-11-23 devnull
15 056fe1ba 2003-11-23 devnull /* position to carve out of a Mem */
16 056fe1ba 2003-11-23 devnull enum {
17 056fe1ba 2003-11-23 devnull PFront,
18 056fe1ba 2003-11-23 devnull PMiddle,
19 cbeb0b26 2006-04-01 devnull PEnd
20 056fe1ba 2003-11-23 devnull };
21 056fe1ba 2003-11-23 devnull
22 056fe1ba 2003-11-23 devnull struct Mem
23 056fe1ba 2003-11-23 devnull {
24 056fe1ba 2003-11-23 devnull Lock lk;
25 056fe1ba 2003-11-23 devnull int ref;
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;
31 056fe1ba 2003-11-23 devnull };
32 056fe1ba 2003-11-23 devnull
33 056fe1ba 2003-11-23 devnull enum {
34 056fe1ba 2003-11-23 devnull FragLocalFree,
35 056fe1ba 2003-11-23 devnull FragLocalAlloc,
36 cbeb0b26 2006-04-01 devnull FragGlobal
37 056fe1ba 2003-11-23 devnull };
38 fa325e9b 2020-01-10 cross
39 056fe1ba 2003-11-23 devnull struct Frag
40 056fe1ba 2003-11-23 devnull {
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*);
47 056fe1ba 2003-11-23 devnull void *a;
48 8baa0cbd 2004-06-09 devnull Packet *p; /* parent packet, for debugging only */
49 056fe1ba 2003-11-23 devnull };
50 056fe1ba 2003-11-23 devnull
51 056fe1ba 2003-11-23 devnull struct Packet
52 056fe1ba 2003-11-23 devnull {
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;
56 8baa0cbd 2004-06-09 devnull
57 056fe1ba 2003-11-23 devnull Packet *next;
58 fa325e9b 2020-01-10 cross
59 056fe1ba 2003-11-23 devnull Frag *first;
60 056fe1ba 2003-11-23 devnull Frag *last;
61 fa325e9b 2020-01-10 cross
62 056fe1ba 2003-11-23 devnull Frag local[NLocalFrag];
63 056fe1ba 2003-11-23 devnull };
64 056fe1ba 2003-11-23 devnull
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*);
68 056fe1ba 2003-11-23 devnull
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);
73 056fe1ba 2003-11-23 devnull
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";
77 056fe1ba 2003-11-23 devnull
78 6ce75e8d 2007-04-21 devnull #ifdef NOTDEF
79 8baa0cbd 2004-06-09 devnull static void checkpacket(Packet*);
80 e5d47e6e 2004-12-28 devnull #endif
81 8baa0cbd 2004-06-09 devnull
82 8baa0cbd 2004-06-09 devnull /*
83 fa325e9b 2020-01-10 cross * the free list is primarily for speed, but it is
84 8baa0cbd 2004-06-09 devnull * also necessary for packetsplit that packets
85 8baa0cbd 2004-06-09 devnull * are never freed -- a packet can contain a different
86 8baa0cbd 2004-06-09 devnull * packet's local fragments, thanks to packetsplit!
87 8baa0cbd 2004-06-09 devnull */
88 056fe1ba 2003-11-23 devnull static struct {
89 056fe1ba 2003-11-23 devnull Lock lk;
90 056fe1ba 2003-11-23 devnull Packet *packet;
91 056fe1ba 2003-11-23 devnull int npacket;
92 056fe1ba 2003-11-23 devnull Frag *frag;
93 056fe1ba 2003-11-23 devnull int nfrag;
94 056fe1ba 2003-11-23 devnull Mem *bigmem;
95 056fe1ba 2003-11-23 devnull int nbigmem;
96 056fe1ba 2003-11-23 devnull Mem *smallmem;
97 056fe1ba 2003-11-23 devnull int nsmallmem;
98 056fe1ba 2003-11-23 devnull } freelist;
99 056fe1ba 2003-11-23 devnull
100 056fe1ba 2003-11-23 devnull #define FRAGSIZE(f) ((f)->wp - (f)->rp)
101 056fe1ba 2003-11-23 devnull #define FRAGASIZE(f) ((f)->mem ? (f)->mem->ep - (f)->mem->bp : 0)
102 056fe1ba 2003-11-23 devnull
103 8baa0cbd 2004-06-09 devnull #define NOTFREE(p) assert((p)->size>=0)/*; checkpacket(p)*/
104 056fe1ba 2003-11-23 devnull
105 056fe1ba 2003-11-23 devnull Packet *
106 056fe1ba 2003-11-23 devnull packetalloc(void)
107 056fe1ba 2003-11-23 devnull {
108 056fe1ba 2003-11-23 devnull Packet *p;
109 056fe1ba 2003-11-23 devnull
110 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
111 056fe1ba 2003-11-23 devnull p = freelist.packet;
112 056fe1ba 2003-11-23 devnull if(p != nil)
113 056fe1ba 2003-11-23 devnull freelist.packet = p->next;
114 056fe1ba 2003-11-23 devnull else
115 056fe1ba 2003-11-23 devnull freelist.npacket++;
116 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
117 056fe1ba 2003-11-23 devnull
118 056fe1ba 2003-11-23 devnull if(p == nil)
119 056fe1ba 2003-11-23 devnull p = vtbrk(sizeof(Packet));
120 056fe1ba 2003-11-23 devnull else
121 056fe1ba 2003-11-23 devnull assert(p->size == -1);
122 056fe1ba 2003-11-23 devnull p->size = 0;
123 056fe1ba 2003-11-23 devnull p->asize = 0;
124 056fe1ba 2003-11-23 devnull p->first = nil;
125 056fe1ba 2003-11-23 devnull p->last = nil;
126 056fe1ba 2003-11-23 devnull p->next = nil;
127 8baa0cbd 2004-06-09 devnull p->pc = getcallerpc((char*)&p+8); /* might not work, but fine */
128 056fe1ba 2003-11-23 devnull
129 8baa0cbd 2004-06-09 devnull NOTFREE(p);
130 056fe1ba 2003-11-23 devnull return p;
131 056fe1ba 2003-11-23 devnull }
132 056fe1ba 2003-11-23 devnull
133 056fe1ba 2003-11-23 devnull void
134 056fe1ba 2003-11-23 devnull packetfree(Packet *p)
135 056fe1ba 2003-11-23 devnull {
136 056fe1ba 2003-11-23 devnull Frag *f, *ff;
137 056fe1ba 2003-11-23 devnull
138 056fe1ba 2003-11-23 devnull if(p == nil)
139 056fe1ba 2003-11-23 devnull return;
140 056fe1ba 2003-11-23 devnull
141 056fe1ba 2003-11-23 devnull NOTFREE(p);
142 8baa0cbd 2004-06-09 devnull p->pc = getcallerpc(&p);
143 056fe1ba 2003-11-23 devnull
144 056fe1ba 2003-11-23 devnull for(f=p->first; f!=nil; f=ff) {
145 056fe1ba 2003-11-23 devnull ff = f->next;
146 056fe1ba 2003-11-23 devnull fragfree(f);
147 056fe1ba 2003-11-23 devnull }
148 8baa0cbd 2004-06-09 devnull p->first = (void*)0xDeadBeef;
149 8baa0cbd 2004-06-09 devnull p->last = (void*)0xDeadBeef;
150 8baa0cbd 2004-06-09 devnull p->size = -1;
151 056fe1ba 2003-11-23 devnull
152 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
153 056fe1ba 2003-11-23 devnull p->next = freelist.packet;
154 056fe1ba 2003-11-23 devnull freelist.packet = p;
155 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
156 056fe1ba 2003-11-23 devnull }
157 056fe1ba 2003-11-23 devnull
158 056fe1ba 2003-11-23 devnull Packet *
159 056fe1ba 2003-11-23 devnull packetdup(Packet *p, int offset, int n)
160 fa325e9b 2020-01-10 cross {
161 056fe1ba 2003-11-23 devnull Frag *f, *ff;
162 056fe1ba 2003-11-23 devnull Packet *pp;
163 056fe1ba 2003-11-23 devnull
164 056fe1ba 2003-11-23 devnull NOTFREE(p);
165 056fe1ba 2003-11-23 devnull if(offset < 0 || n < 0 || offset+n > p->size) {
166 056fe1ba 2003-11-23 devnull werrstr(EBadSize);
167 056fe1ba 2003-11-23 devnull return nil;
168 056fe1ba 2003-11-23 devnull }
169 056fe1ba 2003-11-23 devnull
170 056fe1ba 2003-11-23 devnull pp = packetalloc();
171 8baa0cbd 2004-06-09 devnull pp->pc = getcallerpc(&p);
172 8baa0cbd 2004-06-09 devnull if(n == 0){
173 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
174 056fe1ba 2003-11-23 devnull return pp;
175 8baa0cbd 2004-06-09 devnull }
176 056fe1ba 2003-11-23 devnull
177 056fe1ba 2003-11-23 devnull pp->size = n;
178 056fe1ba 2003-11-23 devnull
179 056fe1ba 2003-11-23 devnull /* skip offset */
180 056fe1ba 2003-11-23 devnull for(f=p->first; offset >= FRAGSIZE(f); f=f->next)
181 056fe1ba 2003-11-23 devnull offset -= FRAGSIZE(f);
182 fa325e9b 2020-01-10 cross
183 056fe1ba 2003-11-23 devnull /* first frag */
184 056fe1ba 2003-11-23 devnull ff = fragdup(pp, f);
185 056fe1ba 2003-11-23 devnull ff->rp += offset;
186 056fe1ba 2003-11-23 devnull pp->first = ff;
187 056fe1ba 2003-11-23 devnull n -= FRAGSIZE(ff);
188 056fe1ba 2003-11-23 devnull pp->asize += FRAGASIZE(ff);
189 056fe1ba 2003-11-23 devnull
190 056fe1ba 2003-11-23 devnull /* the remaining */
191 056fe1ba 2003-11-23 devnull while(n > 0) {
192 056fe1ba 2003-11-23 devnull f = f->next;
193 056fe1ba 2003-11-23 devnull ff->next = fragdup(pp, f);
194 056fe1ba 2003-11-23 devnull ff = ff->next;
195 056fe1ba 2003-11-23 devnull n -= FRAGSIZE(ff);
196 056fe1ba 2003-11-23 devnull pp->asize += FRAGASIZE(ff);
197 056fe1ba 2003-11-23 devnull }
198 fa325e9b 2020-01-10 cross
199 056fe1ba 2003-11-23 devnull /* fix up last frag: note n <= 0 */
200 056fe1ba 2003-11-23 devnull ff->wp += n;
201 056fe1ba 2003-11-23 devnull ff->next = nil;
202 056fe1ba 2003-11-23 devnull pp->last = ff;
203 056fe1ba 2003-11-23 devnull
204 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
205 8baa0cbd 2004-06-09 devnull NOTFREE(p);
206 056fe1ba 2003-11-23 devnull return pp;
207 056fe1ba 2003-11-23 devnull }
208 056fe1ba 2003-11-23 devnull
209 056fe1ba 2003-11-23 devnull Packet *
210 056fe1ba 2003-11-23 devnull packetsplit(Packet *p, int n)
211 056fe1ba 2003-11-23 devnull {
212 056fe1ba 2003-11-23 devnull Packet *pp;
213 056fe1ba 2003-11-23 devnull Frag *f, *ff;
214 056fe1ba 2003-11-23 devnull
215 056fe1ba 2003-11-23 devnull NOTFREE(p);
216 056fe1ba 2003-11-23 devnull if(n < 0 || n > p->size) {
217 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
218 056fe1ba 2003-11-23 devnull return nil;
219 056fe1ba 2003-11-23 devnull }
220 056fe1ba 2003-11-23 devnull
221 056fe1ba 2003-11-23 devnull pp = packetalloc();
222 8baa0cbd 2004-06-09 devnull pp->pc = getcallerpc(&p);
223 8baa0cbd 2004-06-09 devnull if(n == 0){
224 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
225 056fe1ba 2003-11-23 devnull return pp;
226 8baa0cbd 2004-06-09 devnull }
227 056fe1ba 2003-11-23 devnull
228 056fe1ba 2003-11-23 devnull pp->size = n;
229 056fe1ba 2003-11-23 devnull p->size -= n;
230 056fe1ba 2003-11-23 devnull ff = nil;
231 056fe1ba 2003-11-23 devnull for(f=p->first; n > 0 && n >= FRAGSIZE(f); f=f->next) {
232 056fe1ba 2003-11-23 devnull n -= FRAGSIZE(f);
233 056fe1ba 2003-11-23 devnull p->asize -= FRAGASIZE(f);
234 056fe1ba 2003-11-23 devnull pp->asize += FRAGASIZE(f);
235 8baa0cbd 2004-06-09 devnull f->p = pp;
236 056fe1ba 2003-11-23 devnull ff = f;
237 056fe1ba 2003-11-23 devnull }
238 056fe1ba 2003-11-23 devnull
239 056fe1ba 2003-11-23 devnull /* split shared frag */
240 056fe1ba 2003-11-23 devnull if(n > 0) {
241 8baa0cbd 2004-06-09 devnull f->p = pp;
242 056fe1ba 2003-11-23 devnull ff = f;
243 8baa0cbd 2004-06-09 devnull f = fragdup(p, ff);
244 056fe1ba 2003-11-23 devnull pp->asize += FRAGASIZE(ff);
245 056fe1ba 2003-11-23 devnull ff->wp = ff->rp + n;
246 056fe1ba 2003-11-23 devnull f->rp += n;
247 056fe1ba 2003-11-23 devnull }
248 056fe1ba 2003-11-23 devnull
249 056fe1ba 2003-11-23 devnull pp->first = p->first;
250 056fe1ba 2003-11-23 devnull pp->last = ff;
251 8baa0cbd 2004-06-09 devnull ff->next = nil;
252 056fe1ba 2003-11-23 devnull p->first = f;
253 8baa0cbd 2004-06-09 devnull if(f == nil || f->next == nil)
254 8baa0cbd 2004-06-09 devnull p->last = f;
255 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
256 8baa0cbd 2004-06-09 devnull NOTFREE(p);
257 056fe1ba 2003-11-23 devnull return pp;
258 056fe1ba 2003-11-23 devnull }
259 056fe1ba 2003-11-23 devnull
260 056fe1ba 2003-11-23 devnull int
261 056fe1ba 2003-11-23 devnull packetconsume(Packet *p, uchar *buf, int n)
262 056fe1ba 2003-11-23 devnull {
263 056fe1ba 2003-11-23 devnull NOTFREE(p);
264 056fe1ba 2003-11-23 devnull if(buf && packetcopy(p, buf, 0, n) < 0)
265 d23a617a 2004-03-15 devnull return -1;
266 056fe1ba 2003-11-23 devnull return packettrim(p, n, p->size-n);
267 056fe1ba 2003-11-23 devnull }
268 056fe1ba 2003-11-23 devnull
269 056fe1ba 2003-11-23 devnull int
270 056fe1ba 2003-11-23 devnull packettrim(Packet *p, int offset, int n)
271 056fe1ba 2003-11-23 devnull {
272 056fe1ba 2003-11-23 devnull Frag *f, *ff;
273 056fe1ba 2003-11-23 devnull
274 056fe1ba 2003-11-23 devnull NOTFREE(p);
275 056fe1ba 2003-11-23 devnull if(offset < 0 || offset > p->size) {
276 056fe1ba 2003-11-23 devnull werrstr(EPacketOffset);
277 056fe1ba 2003-11-23 devnull return -1;
278 056fe1ba 2003-11-23 devnull }
279 056fe1ba 2003-11-23 devnull
280 056fe1ba 2003-11-23 devnull if(n < 0 || offset + n > p->size) {
281 056fe1ba 2003-11-23 devnull werrstr(EPacketOffset);
282 056fe1ba 2003-11-23 devnull return -1;
283 056fe1ba 2003-11-23 devnull }
284 056fe1ba 2003-11-23 devnull
285 056fe1ba 2003-11-23 devnull p->size = n;
286 056fe1ba 2003-11-23 devnull
287 056fe1ba 2003-11-23 devnull /* easy case */
288 056fe1ba 2003-11-23 devnull if(n == 0) {
289 056fe1ba 2003-11-23 devnull for(f=p->first; f != nil; f=ff) {
290 056fe1ba 2003-11-23 devnull ff = f->next;
291 056fe1ba 2003-11-23 devnull fragfree(f);
292 056fe1ba 2003-11-23 devnull }
293 056fe1ba 2003-11-23 devnull p->first = p->last = nil;
294 056fe1ba 2003-11-23 devnull p->asize = 0;
295 8baa0cbd 2004-06-09 devnull NOTFREE(p);
296 056fe1ba 2003-11-23 devnull return 0;
297 056fe1ba 2003-11-23 devnull }
298 fa325e9b 2020-01-10 cross
299 056fe1ba 2003-11-23 devnull /* free before offset */
300 056fe1ba 2003-11-23 devnull for(f=p->first; offset >= FRAGSIZE(f); f=ff) {
301 056fe1ba 2003-11-23 devnull p->asize -= FRAGASIZE(f);
302 056fe1ba 2003-11-23 devnull offset -= FRAGSIZE(f);
303 056fe1ba 2003-11-23 devnull ff = f->next;
304 056fe1ba 2003-11-23 devnull fragfree(f);
305 056fe1ba 2003-11-23 devnull }
306 056fe1ba 2003-11-23 devnull
307 056fe1ba 2003-11-23 devnull /* adjust frag */
308 056fe1ba 2003-11-23 devnull f->rp += offset;
309 056fe1ba 2003-11-23 devnull p->first = f;
310 056fe1ba 2003-11-23 devnull
311 056fe1ba 2003-11-23 devnull /* skip middle */
312 056fe1ba 2003-11-23 devnull for(; n > 0 && n > FRAGSIZE(f); f=f->next)
313 056fe1ba 2003-11-23 devnull n -= FRAGSIZE(f);
314 056fe1ba 2003-11-23 devnull
315 056fe1ba 2003-11-23 devnull /* adjust end */
316 056fe1ba 2003-11-23 devnull f->wp = f->rp + n;
317 056fe1ba 2003-11-23 devnull p->last = f;
318 056fe1ba 2003-11-23 devnull ff = f->next;
319 056fe1ba 2003-11-23 devnull f->next = nil;
320 056fe1ba 2003-11-23 devnull
321 056fe1ba 2003-11-23 devnull /* free after */
322 056fe1ba 2003-11-23 devnull for(f=ff; f != nil; f=ff) {
323 056fe1ba 2003-11-23 devnull p->asize -= FRAGASIZE(f);
324 056fe1ba 2003-11-23 devnull ff = f->next;
325 056fe1ba 2003-11-23 devnull fragfree(f);
326 056fe1ba 2003-11-23 devnull }
327 8baa0cbd 2004-06-09 devnull NOTFREE(p);
328 056fe1ba 2003-11-23 devnull return 0;
329 056fe1ba 2003-11-23 devnull }
330 056fe1ba 2003-11-23 devnull
331 056fe1ba 2003-11-23 devnull uchar *
332 056fe1ba 2003-11-23 devnull packetheader(Packet *p, int n)
333 056fe1ba 2003-11-23 devnull {
334 056fe1ba 2003-11-23 devnull Frag *f;
335 056fe1ba 2003-11-23 devnull Mem *m;
336 056fe1ba 2003-11-23 devnull
337 056fe1ba 2003-11-23 devnull NOTFREE(p);
338 056fe1ba 2003-11-23 devnull if(n <= 0 || n > MaxFragSize) {
339 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
340 056fe1ba 2003-11-23 devnull return nil;
341 056fe1ba 2003-11-23 devnull }
342 056fe1ba 2003-11-23 devnull
343 056fe1ba 2003-11-23 devnull p->size += n;
344 fa325e9b 2020-01-10 cross
345 056fe1ba 2003-11-23 devnull /* try and fix in current frag */
346 056fe1ba 2003-11-23 devnull f = p->first;
347 056fe1ba 2003-11-23 devnull if(f != nil) {
348 056fe1ba 2003-11-23 devnull m = f->mem;
349 056fe1ba 2003-11-23 devnull if(n <= f->rp - m->bp)
350 056fe1ba 2003-11-23 devnull if(m->ref == 1 || memhead(m, f->rp, n) >= 0) {
351 056fe1ba 2003-11-23 devnull f->rp -= n;
352 8baa0cbd 2004-06-09 devnull NOTFREE(p);
353 056fe1ba 2003-11-23 devnull return f->rp;
354 056fe1ba 2003-11-23 devnull }
355 056fe1ba 2003-11-23 devnull }
356 056fe1ba 2003-11-23 devnull
357 056fe1ba 2003-11-23 devnull /* add frag to front */
358 056fe1ba 2003-11-23 devnull f = fragalloc(p, n, PEnd, p->first);
359 056fe1ba 2003-11-23 devnull p->asize += FRAGASIZE(f);
360 056fe1ba 2003-11-23 devnull if(p->first == nil)
361 056fe1ba 2003-11-23 devnull p->last = f;
362 056fe1ba 2003-11-23 devnull p->first = f;
363 8baa0cbd 2004-06-09 devnull NOTFREE(p);
364 056fe1ba 2003-11-23 devnull return f->rp;
365 056fe1ba 2003-11-23 devnull }
366 056fe1ba 2003-11-23 devnull
367 056fe1ba 2003-11-23 devnull uchar *
368 056fe1ba 2003-11-23 devnull packettrailer(Packet *p, int n)
369 056fe1ba 2003-11-23 devnull {
370 056fe1ba 2003-11-23 devnull Mem *m;
371 056fe1ba 2003-11-23 devnull Frag *f;
372 056fe1ba 2003-11-23 devnull
373 056fe1ba 2003-11-23 devnull NOTFREE(p);
374 056fe1ba 2003-11-23 devnull if(n <= 0 || n > MaxFragSize) {
375 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
376 056fe1ba 2003-11-23 devnull return nil;
377 056fe1ba 2003-11-23 devnull }
378 056fe1ba 2003-11-23 devnull
379 056fe1ba 2003-11-23 devnull p->size += n;
380 fa325e9b 2020-01-10 cross
381 056fe1ba 2003-11-23 devnull /* try and fix in current frag */
382 056fe1ba 2003-11-23 devnull if(p->first != nil) {
383 056fe1ba 2003-11-23 devnull f = p->last;
384 056fe1ba 2003-11-23 devnull m = f->mem;
385 056fe1ba 2003-11-23 devnull if(n <= m->ep - f->wp)
386 056fe1ba 2003-11-23 devnull if(m->ref == 1 || memtail(m, f->wp, n) >= 0) {
387 056fe1ba 2003-11-23 devnull f->wp += n;
388 8baa0cbd 2004-06-09 devnull NOTFREE(p);
389 056fe1ba 2003-11-23 devnull return f->wp - n;
390 056fe1ba 2003-11-23 devnull }
391 056fe1ba 2003-11-23 devnull }
392 056fe1ba 2003-11-23 devnull
393 056fe1ba 2003-11-23 devnull /* add frag to end */
394 056fe1ba 2003-11-23 devnull f = fragalloc(p, n, (p->first == nil)?PMiddle:PFront, nil);
395 056fe1ba 2003-11-23 devnull p->asize += FRAGASIZE(f);
396 056fe1ba 2003-11-23 devnull if(p->first == nil)
397 056fe1ba 2003-11-23 devnull p->first = f;
398 056fe1ba 2003-11-23 devnull else
399 056fe1ba 2003-11-23 devnull p->last->next = f;
400 056fe1ba 2003-11-23 devnull p->last = f;
401 8baa0cbd 2004-06-09 devnull NOTFREE(p);
402 056fe1ba 2003-11-23 devnull return f->rp;
403 056fe1ba 2003-11-23 devnull }
404 056fe1ba 2003-11-23 devnull
405 d23a617a 2004-03-15 devnull void
406 056fe1ba 2003-11-23 devnull packetprefix(Packet *p, uchar *buf, int n)
407 056fe1ba 2003-11-23 devnull {
408 056fe1ba 2003-11-23 devnull Frag *f;
409 056fe1ba 2003-11-23 devnull int nn;
410 056fe1ba 2003-11-23 devnull Mem *m;
411 056fe1ba 2003-11-23 devnull
412 056fe1ba 2003-11-23 devnull NOTFREE(p);
413 056fe1ba 2003-11-23 devnull if(n <= 0)
414 d23a617a 2004-03-15 devnull return;
415 056fe1ba 2003-11-23 devnull
416 056fe1ba 2003-11-23 devnull p->size += n;
417 056fe1ba 2003-11-23 devnull
418 056fe1ba 2003-11-23 devnull /* try and fix in current frag */
419 056fe1ba 2003-11-23 devnull f = p->first;
420 056fe1ba 2003-11-23 devnull if(f != nil) {
421 056fe1ba 2003-11-23 devnull m = f->mem;
422 056fe1ba 2003-11-23 devnull nn = f->rp - m->bp;
423 056fe1ba 2003-11-23 devnull if(nn > n)
424 056fe1ba 2003-11-23 devnull nn = n;
425 056fe1ba 2003-11-23 devnull if(m->ref == 1 || memhead(m, f->rp, nn) >= 0) {
426 056fe1ba 2003-11-23 devnull f->rp -= nn;
427 056fe1ba 2003-11-23 devnull n -= nn;
428 056fe1ba 2003-11-23 devnull memmove(f->rp, buf+n, nn);
429 056fe1ba 2003-11-23 devnull }
430 056fe1ba 2003-11-23 devnull }
431 056fe1ba 2003-11-23 devnull
432 056fe1ba 2003-11-23 devnull while(n > 0) {
433 056fe1ba 2003-11-23 devnull nn = n;
434 056fe1ba 2003-11-23 devnull if(nn > MaxFragSize)
435 056fe1ba 2003-11-23 devnull nn = MaxFragSize;
436 fa325e9b 2020-01-10 cross f = fragalloc(p, nn, PEnd, p->first);
437 056fe1ba 2003-11-23 devnull p->asize += FRAGASIZE(f);
438 056fe1ba 2003-11-23 devnull if(p->first == nil)
439 056fe1ba 2003-11-23 devnull p->last = f;
440 056fe1ba 2003-11-23 devnull p->first = f;
441 056fe1ba 2003-11-23 devnull n -= nn;
442 056fe1ba 2003-11-23 devnull memmove(f->rp, buf+n, nn);
443 056fe1ba 2003-11-23 devnull }
444 8baa0cbd 2004-06-09 devnull NOTFREE(p);
445 056fe1ba 2003-11-23 devnull }
446 056fe1ba 2003-11-23 devnull
447 d23a617a 2004-03-15 devnull void
448 056fe1ba 2003-11-23 devnull packetappend(Packet *p, uchar *buf, int n)
449 056fe1ba 2003-11-23 devnull {
450 056fe1ba 2003-11-23 devnull Frag *f;
451 056fe1ba 2003-11-23 devnull int nn;
452 056fe1ba 2003-11-23 devnull Mem *m;
453 056fe1ba 2003-11-23 devnull
454 056fe1ba 2003-11-23 devnull NOTFREE(p);
455 056fe1ba 2003-11-23 devnull if(n <= 0)
456 d23a617a 2004-03-15 devnull return;
457 056fe1ba 2003-11-23 devnull
458 056fe1ba 2003-11-23 devnull p->size += n;
459 056fe1ba 2003-11-23 devnull /* try and fix in current frag */
460 056fe1ba 2003-11-23 devnull if(p->first != nil) {
461 056fe1ba 2003-11-23 devnull f = p->last;
462 056fe1ba 2003-11-23 devnull m = f->mem;
463 056fe1ba 2003-11-23 devnull nn = m->ep - f->wp;
464 056fe1ba 2003-11-23 devnull if(nn > n)
465 056fe1ba 2003-11-23 devnull nn = n;
466 056fe1ba 2003-11-23 devnull if(m->ref == 1 || memtail(m, f->wp, nn) >= 0) {
467 056fe1ba 2003-11-23 devnull memmove(f->wp, buf, nn);
468 056fe1ba 2003-11-23 devnull f->wp += nn;
469 056fe1ba 2003-11-23 devnull buf += nn;
470 056fe1ba 2003-11-23 devnull n -= nn;
471 056fe1ba 2003-11-23 devnull }
472 056fe1ba 2003-11-23 devnull }
473 fa325e9b 2020-01-10 cross
474 056fe1ba 2003-11-23 devnull while(n > 0) {
475 056fe1ba 2003-11-23 devnull nn = n;
476 056fe1ba 2003-11-23 devnull if(nn > MaxFragSize)
477 056fe1ba 2003-11-23 devnull nn = MaxFragSize;
478 056fe1ba 2003-11-23 devnull f = fragalloc(p, nn, (p->first == nil)?PMiddle:PFront, nil);
479 056fe1ba 2003-11-23 devnull p->asize += FRAGASIZE(f);
480 056fe1ba 2003-11-23 devnull if(p->first == nil)
481 056fe1ba 2003-11-23 devnull p->first = f;
482 056fe1ba 2003-11-23 devnull else
483 056fe1ba 2003-11-23 devnull p->last->next = f;
484 056fe1ba 2003-11-23 devnull p->last = f;
485 056fe1ba 2003-11-23 devnull memmove(f->rp, buf, nn);
486 056fe1ba 2003-11-23 devnull buf += nn;
487 056fe1ba 2003-11-23 devnull n -= nn;
488 056fe1ba 2003-11-23 devnull }
489 8baa0cbd 2004-06-09 devnull NOTFREE(p);
490 056fe1ba 2003-11-23 devnull }
491 056fe1ba 2003-11-23 devnull
492 d23a617a 2004-03-15 devnull void
493 056fe1ba 2003-11-23 devnull packetconcat(Packet *p, Packet *pp)
494 056fe1ba 2003-11-23 devnull {
495 8baa0cbd 2004-06-09 devnull Frag *f;
496 8baa0cbd 2004-06-09 devnull
497 056fe1ba 2003-11-23 devnull NOTFREE(p);
498 056fe1ba 2003-11-23 devnull NOTFREE(pp);
499 056fe1ba 2003-11-23 devnull if(pp->size == 0)
500 d23a617a 2004-03-15 devnull return;
501 056fe1ba 2003-11-23 devnull p->size += pp->size;
502 056fe1ba 2003-11-23 devnull p->asize += pp->asize;
503 8baa0cbd 2004-06-09 devnull for(f=pp->first; f; f=f->next)
504 8baa0cbd 2004-06-09 devnull f->p = p;
505 056fe1ba 2003-11-23 devnull
506 056fe1ba 2003-11-23 devnull if(p->first != nil)
507 056fe1ba 2003-11-23 devnull p->last->next = pp->first;
508 056fe1ba 2003-11-23 devnull else
509 056fe1ba 2003-11-23 devnull p->first = pp->first;
510 8baa0cbd 2004-06-09 devnull
511 056fe1ba 2003-11-23 devnull p->last = pp->last;
512 056fe1ba 2003-11-23 devnull pp->size = 0;
513 056fe1ba 2003-11-23 devnull pp->asize = 0;
514 056fe1ba 2003-11-23 devnull pp->first = nil;
515 056fe1ba 2003-11-23 devnull pp->last = nil;
516 8baa0cbd 2004-06-09 devnull NOTFREE(p);
517 8baa0cbd 2004-06-09 devnull NOTFREE(pp);
518 056fe1ba 2003-11-23 devnull }
519 056fe1ba 2003-11-23 devnull
520 056fe1ba 2003-11-23 devnull uchar *
521 056fe1ba 2003-11-23 devnull packetpeek(Packet *p, uchar *buf, int offset, int n)
522 056fe1ba 2003-11-23 devnull {
523 056fe1ba 2003-11-23 devnull Frag *f;
524 056fe1ba 2003-11-23 devnull int nn;
525 056fe1ba 2003-11-23 devnull uchar *b;
526 056fe1ba 2003-11-23 devnull
527 056fe1ba 2003-11-23 devnull NOTFREE(p);
528 056fe1ba 2003-11-23 devnull if(n == 0)
529 056fe1ba 2003-11-23 devnull return buf;
530 056fe1ba 2003-11-23 devnull
531 056fe1ba 2003-11-23 devnull if(offset < 0 || offset >= p->size) {
532 056fe1ba 2003-11-23 devnull werrstr(EPacketOffset);
533 056fe1ba 2003-11-23 devnull return nil;
534 056fe1ba 2003-11-23 devnull }
535 056fe1ba 2003-11-23 devnull
536 056fe1ba 2003-11-23 devnull if(n < 0 || offset + n > p->size) {
537 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
538 056fe1ba 2003-11-23 devnull return nil;
539 056fe1ba 2003-11-23 devnull }
540 fa325e9b 2020-01-10 cross
541 056fe1ba 2003-11-23 devnull /* skip up to offset */
542 056fe1ba 2003-11-23 devnull for(f=p->first; offset >= FRAGSIZE(f); f=f->next)
543 056fe1ba 2003-11-23 devnull offset -= FRAGSIZE(f);
544 056fe1ba 2003-11-23 devnull
545 056fe1ba 2003-11-23 devnull /* easy case */
546 8baa0cbd 2004-06-09 devnull if(offset + n <= FRAGSIZE(f)){
547 8baa0cbd 2004-06-09 devnull NOTFREE(p);
548 056fe1ba 2003-11-23 devnull return f->rp + offset;
549 8baa0cbd 2004-06-09 devnull }
550 056fe1ba 2003-11-23 devnull
551 056fe1ba 2003-11-23 devnull for(b=buf; n>0; n -= nn) {
552 056fe1ba 2003-11-23 devnull nn = FRAGSIZE(f) - offset;
553 056fe1ba 2003-11-23 devnull if(nn > n)
554 056fe1ba 2003-11-23 devnull nn = n;
555 056fe1ba 2003-11-23 devnull memmove(b, f->rp+offset, nn);
556 056fe1ba 2003-11-23 devnull offset = 0;
557 056fe1ba 2003-11-23 devnull f = f->next;
558 056fe1ba 2003-11-23 devnull b += nn;
559 056fe1ba 2003-11-23 devnull }
560 056fe1ba 2003-11-23 devnull
561 8baa0cbd 2004-06-09 devnull NOTFREE(p);
562 056fe1ba 2003-11-23 devnull return buf;
563 056fe1ba 2003-11-23 devnull }
564 056fe1ba 2003-11-23 devnull
565 056fe1ba 2003-11-23 devnull int
566 056fe1ba 2003-11-23 devnull packetcopy(Packet *p, uchar *buf, int offset, int n)
567 056fe1ba 2003-11-23 devnull {
568 056fe1ba 2003-11-23 devnull uchar *b;
569 056fe1ba 2003-11-23 devnull
570 056fe1ba 2003-11-23 devnull NOTFREE(p);
571 056fe1ba 2003-11-23 devnull b = packetpeek(p, buf, offset, n);
572 056fe1ba 2003-11-23 devnull if(b == nil)
573 056fe1ba 2003-11-23 devnull return -1;
574 056fe1ba 2003-11-23 devnull if(b != buf)
575 056fe1ba 2003-11-23 devnull memmove(buf, b, n);
576 056fe1ba 2003-11-23 devnull return 0;
577 056fe1ba 2003-11-23 devnull }
578 056fe1ba 2003-11-23 devnull
579 056fe1ba 2003-11-23 devnull int
580 056fe1ba 2003-11-23 devnull packetfragments(Packet *p, IOchunk *io, int nio, int offset)
581 056fe1ba 2003-11-23 devnull {
582 056fe1ba 2003-11-23 devnull Frag *f;
583 056fe1ba 2003-11-23 devnull int size;
584 056fe1ba 2003-11-23 devnull IOchunk *eio;
585 056fe1ba 2003-11-23 devnull
586 056fe1ba 2003-11-23 devnull NOTFREE(p);
587 056fe1ba 2003-11-23 devnull if(p->size == 0 || nio <= 0)
588 056fe1ba 2003-11-23 devnull return 0;
589 fa325e9b 2020-01-10 cross
590 056fe1ba 2003-11-23 devnull if(offset < 0 || offset > p->size) {
591 056fe1ba 2003-11-23 devnull werrstr(EPacketOffset);
592 056fe1ba 2003-11-23 devnull return -1;
593 056fe1ba 2003-11-23 devnull }
594 056fe1ba 2003-11-23 devnull
595 056fe1ba 2003-11-23 devnull for(f=p->first; offset >= FRAGSIZE(f); f=f->next)
596 056fe1ba 2003-11-23 devnull offset -= FRAGSIZE(f);
597 056fe1ba 2003-11-23 devnull
598 056fe1ba 2003-11-23 devnull size = 0;
599 056fe1ba 2003-11-23 devnull eio = io + nio;
600 056fe1ba 2003-11-23 devnull for(; f != nil && io < eio; f=f->next) {
601 056fe1ba 2003-11-23 devnull io->addr = f->rp + offset;
602 fa325e9b 2020-01-10 cross io->len = f->wp - (f->rp + offset);
603 056fe1ba 2003-11-23 devnull offset = 0;
604 056fe1ba 2003-11-23 devnull size += io->len;
605 056fe1ba 2003-11-23 devnull io++;
606 056fe1ba 2003-11-23 devnull }
607 9c8fc128 2005-07-13 devnull for(; io < eio; io++){
608 9c8fc128 2005-07-13 devnull io->addr = nil;
609 9c8fc128 2005-07-13 devnull io->len = 0;
610 9c8fc128 2005-07-13 devnull }
611 056fe1ba 2003-11-23 devnull return size;
612 056fe1ba 2003-11-23 devnull }
613 056fe1ba 2003-11-23 devnull
614 056fe1ba 2003-11-23 devnull void
615 056fe1ba 2003-11-23 devnull packetstats(void)
616 056fe1ba 2003-11-23 devnull {
617 056fe1ba 2003-11-23 devnull Packet *p;
618 056fe1ba 2003-11-23 devnull Frag *f;
619 056fe1ba 2003-11-23 devnull Mem *m;
620 056fe1ba 2003-11-23 devnull
621 056fe1ba 2003-11-23 devnull int np, nf, nsm, nbm;
622 056fe1ba 2003-11-23 devnull
623 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
624 056fe1ba 2003-11-23 devnull np = 0;
625 056fe1ba 2003-11-23 devnull for(p=freelist.packet; p; p=p->next)
626 056fe1ba 2003-11-23 devnull np++;
627 056fe1ba 2003-11-23 devnull nf = 0;
628 056fe1ba 2003-11-23 devnull for(f=freelist.frag; f; f=f->next)
629 056fe1ba 2003-11-23 devnull nf++;
630 056fe1ba 2003-11-23 devnull nsm = 0;
631 056fe1ba 2003-11-23 devnull for(m=freelist.smallmem; m; m=m->next)
632 056fe1ba 2003-11-23 devnull nsm++;
633 056fe1ba 2003-11-23 devnull nbm = 0;
634 056fe1ba 2003-11-23 devnull for(m=freelist.bigmem; m; m=m->next)
635 056fe1ba 2003-11-23 devnull nbm++;
636 fa325e9b 2020-01-10 cross
637 056fe1ba 2003-11-23 devnull fprint(2, "packet: %d/%d frag: %d/%d small mem: %d/%d big mem: %d/%d\n",
638 056fe1ba 2003-11-23 devnull np, freelist.npacket,
639 056fe1ba 2003-11-23 devnull nf, freelist.nfrag,
640 056fe1ba 2003-11-23 devnull nsm, freelist.nsmallmem,
641 056fe1ba 2003-11-23 devnull nbm, freelist.nbigmem);
642 056fe1ba 2003-11-23 devnull
643 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
644 056fe1ba 2003-11-23 devnull }
645 056fe1ba 2003-11-23 devnull
646 056fe1ba 2003-11-23 devnull
647 056fe1ba 2003-11-23 devnull uint
648 056fe1ba 2003-11-23 devnull packetsize(Packet *p)
649 056fe1ba 2003-11-23 devnull {
650 056fe1ba 2003-11-23 devnull NOTFREE(p);
651 a09e80f9 2004-05-23 devnull if(1) {
652 056fe1ba 2003-11-23 devnull Frag *f;
653 056fe1ba 2003-11-23 devnull int size = 0;
654 fa325e9b 2020-01-10 cross
655 056fe1ba 2003-11-23 devnull for(f=p->first; f; f=f->next)
656 056fe1ba 2003-11-23 devnull size += FRAGSIZE(f);
657 056fe1ba 2003-11-23 devnull if(size != p->size)
658 056fe1ba 2003-11-23 devnull fprint(2, "packetsize %d %d\n", size, p->size);
659 056fe1ba 2003-11-23 devnull assert(size == p->size);
660 056fe1ba 2003-11-23 devnull }
661 056fe1ba 2003-11-23 devnull return p->size;
662 056fe1ba 2003-11-23 devnull }
663 056fe1ba 2003-11-23 devnull
664 056fe1ba 2003-11-23 devnull uint
665 056fe1ba 2003-11-23 devnull packetasize(Packet *p)
666 056fe1ba 2003-11-23 devnull {
667 056fe1ba 2003-11-23 devnull NOTFREE(p);
668 056fe1ba 2003-11-23 devnull if(0) {
669 056fe1ba 2003-11-23 devnull Frag *f;
670 056fe1ba 2003-11-23 devnull int asize = 0;
671 fa325e9b 2020-01-10 cross
672 056fe1ba 2003-11-23 devnull for(f=p->first; f; f=f->next)
673 056fe1ba 2003-11-23 devnull asize += FRAGASIZE(f);
674 056fe1ba 2003-11-23 devnull if(asize != p->asize)
675 056fe1ba 2003-11-23 devnull fprint(2, "packetasize %d %d\n", asize, p->asize);
676 056fe1ba 2003-11-23 devnull assert(asize == p->asize);
677 056fe1ba 2003-11-23 devnull }
678 056fe1ba 2003-11-23 devnull return p->asize;
679 056fe1ba 2003-11-23 devnull }
680 056fe1ba 2003-11-23 devnull
681 056fe1ba 2003-11-23 devnull void
682 056fe1ba 2003-11-23 devnull packetsha1(Packet *p, uchar digest[VtScoreSize])
683 056fe1ba 2003-11-23 devnull {
684 056fe1ba 2003-11-23 devnull DigestState ds;
685 056fe1ba 2003-11-23 devnull Frag *f;
686 056fe1ba 2003-11-23 devnull int size;
687 056fe1ba 2003-11-23 devnull
688 056fe1ba 2003-11-23 devnull NOTFREE(p);
689 056fe1ba 2003-11-23 devnull memset(&ds, 0, sizeof ds);
690 056fe1ba 2003-11-23 devnull size = p->size;
691 056fe1ba 2003-11-23 devnull for(f=p->first; f; f=f->next) {
692 056fe1ba 2003-11-23 devnull sha1(f->rp, FRAGSIZE(f), nil, &ds);
693 056fe1ba 2003-11-23 devnull size -= FRAGSIZE(f);
694 056fe1ba 2003-11-23 devnull }
695 056fe1ba 2003-11-23 devnull assert(size == 0);
696 056fe1ba 2003-11-23 devnull sha1(nil, 0, digest, &ds);
697 056fe1ba 2003-11-23 devnull }
698 056fe1ba 2003-11-23 devnull
699 056fe1ba 2003-11-23 devnull int
700 056fe1ba 2003-11-23 devnull packetcmp(Packet *pkt0, Packet *pkt1)
701 056fe1ba 2003-11-23 devnull {
702 056fe1ba 2003-11-23 devnull Frag *f0, *f1;
703 056fe1ba 2003-11-23 devnull int n0, n1, x;
704 056fe1ba 2003-11-23 devnull
705 056fe1ba 2003-11-23 devnull NOTFREE(pkt0);
706 056fe1ba 2003-11-23 devnull NOTFREE(pkt1);
707 056fe1ba 2003-11-23 devnull f0 = pkt0->first;
708 056fe1ba 2003-11-23 devnull f1 = pkt1->first;
709 056fe1ba 2003-11-23 devnull
710 056fe1ba 2003-11-23 devnull if(f0 == nil)
711 056fe1ba 2003-11-23 devnull return (f1 == nil)?0:-1;
712 056fe1ba 2003-11-23 devnull if(f1 == nil)
713 056fe1ba 2003-11-23 devnull return 1;
714 056fe1ba 2003-11-23 devnull n0 = FRAGSIZE(f0);
715 056fe1ba 2003-11-23 devnull n1 = FRAGSIZE(f1);
716 056fe1ba 2003-11-23 devnull
717 056fe1ba 2003-11-23 devnull for(;;) {
718 056fe1ba 2003-11-23 devnull if(n0 < n1) {
719 056fe1ba 2003-11-23 devnull x = memcmp(f0->wp - n0, f1->wp - n1, n0);
720 056fe1ba 2003-11-23 devnull if(x != 0)
721 056fe1ba 2003-11-23 devnull return x;
722 056fe1ba 2003-11-23 devnull n1 -= n0;
723 056fe1ba 2003-11-23 devnull f0 = f0->next;
724 056fe1ba 2003-11-23 devnull if(f0 == nil)
725 056fe1ba 2003-11-23 devnull return -1;
726 056fe1ba 2003-11-23 devnull n0 = FRAGSIZE(f0);
727 056fe1ba 2003-11-23 devnull } else if (n0 > n1) {
728 056fe1ba 2003-11-23 devnull x = memcmp(f0->wp - n0, f1->wp - n1, n1);
729 056fe1ba 2003-11-23 devnull if(x != 0)
730 056fe1ba 2003-11-23 devnull return x;
731 056fe1ba 2003-11-23 devnull n0 -= n1;
732 056fe1ba 2003-11-23 devnull f1 = f1->next;
733 056fe1ba 2003-11-23 devnull if(f1 == nil)
734 056fe1ba 2003-11-23 devnull return 1;
735 056fe1ba 2003-11-23 devnull n1 = FRAGSIZE(f1);
736 056fe1ba 2003-11-23 devnull } else { /* n0 == n1 */
737 056fe1ba 2003-11-23 devnull x = memcmp(f0->wp - n0, f1->wp - n1, n0);
738 056fe1ba 2003-11-23 devnull if(x != 0)
739 056fe1ba 2003-11-23 devnull return x;
740 056fe1ba 2003-11-23 devnull f0 = f0->next;
741 056fe1ba 2003-11-23 devnull f1 = f1->next;
742 056fe1ba 2003-11-23 devnull if(f0 == nil)
743 056fe1ba 2003-11-23 devnull return (f1 == nil)?0:-1;
744 056fe1ba 2003-11-23 devnull if(f1 == nil)
745 056fe1ba 2003-11-23 devnull return 1;
746 056fe1ba 2003-11-23 devnull n0 = FRAGSIZE(f0);
747 056fe1ba 2003-11-23 devnull n1 = FRAGSIZE(f1);
748 056fe1ba 2003-11-23 devnull }
749 056fe1ba 2003-11-23 devnull }
750 056fe1ba 2003-11-23 devnull }
751 056fe1ba 2003-11-23 devnull
752 056fe1ba 2003-11-23 devnull static Frag *
753 056fe1ba 2003-11-23 devnull fragalloc(Packet *p, int n, int pos, Frag *next)
754 056fe1ba 2003-11-23 devnull {
755 056fe1ba 2003-11-23 devnull Frag *f, *ef;
756 056fe1ba 2003-11-23 devnull Mem *m;
757 056fe1ba 2003-11-23 devnull
758 056fe1ba 2003-11-23 devnull /* look for local frag */
759 056fe1ba 2003-11-23 devnull f = &p->local[0];
760 056fe1ba 2003-11-23 devnull ef = &p->local[NLocalFrag];
761 056fe1ba 2003-11-23 devnull for(;f<ef; f++) {
762 056fe1ba 2003-11-23 devnull if(f->state == FragLocalFree) {
763 056fe1ba 2003-11-23 devnull f->state = FragLocalAlloc;
764 056fe1ba 2003-11-23 devnull goto Found;
765 056fe1ba 2003-11-23 devnull }
766 056fe1ba 2003-11-23 devnull }
767 fa325e9b 2020-01-10 cross lock(&freelist.lk);
768 056fe1ba 2003-11-23 devnull f = freelist.frag;
769 056fe1ba 2003-11-23 devnull if(f != nil)
770 056fe1ba 2003-11-23 devnull freelist.frag = f->next;
771 056fe1ba 2003-11-23 devnull else
772 056fe1ba 2003-11-23 devnull freelist.nfrag++;
773 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
774 056fe1ba 2003-11-23 devnull
775 056fe1ba 2003-11-23 devnull if(f == nil) {
776 056fe1ba 2003-11-23 devnull f = vtbrk(sizeof(Frag));
777 056fe1ba 2003-11-23 devnull f->state = FragGlobal;
778 056fe1ba 2003-11-23 devnull }
779 056fe1ba 2003-11-23 devnull
780 056fe1ba 2003-11-23 devnull Found:
781 056fe1ba 2003-11-23 devnull f->next = next;
782 8baa0cbd 2004-06-09 devnull f->p = p;
783 056fe1ba 2003-11-23 devnull
784 056fe1ba 2003-11-23 devnull if(n == 0){
785 056fe1ba 2003-11-23 devnull f->mem = 0;
786 056fe1ba 2003-11-23 devnull f->rp = 0;
787 056fe1ba 2003-11-23 devnull f->wp = 0;
788 056fe1ba 2003-11-23 devnull return f;
789 056fe1ba 2003-11-23 devnull }
790 056fe1ba 2003-11-23 devnull
791 056fe1ba 2003-11-23 devnull if(pos == PEnd && next == nil)
792 056fe1ba 2003-11-23 devnull pos = PMiddle;
793 056fe1ba 2003-11-23 devnull m = memalloc(n, pos);
794 056fe1ba 2003-11-23 devnull f->mem = m;
795 056fe1ba 2003-11-23 devnull f->rp = m->rp;
796 056fe1ba 2003-11-23 devnull f->wp = m->wp;
797 056fe1ba 2003-11-23 devnull return f;
798 056fe1ba 2003-11-23 devnull }
799 056fe1ba 2003-11-23 devnull
800 056fe1ba 2003-11-23 devnull Packet*
801 056fe1ba 2003-11-23 devnull packetforeign(uchar *buf, int n, void (*free)(void *a), void *a)
802 056fe1ba 2003-11-23 devnull {
803 056fe1ba 2003-11-23 devnull Packet *p;
804 056fe1ba 2003-11-23 devnull Frag *f;
805 056fe1ba 2003-11-23 devnull
806 056fe1ba 2003-11-23 devnull p = packetalloc();
807 8baa0cbd 2004-06-09 devnull p->pc = getcallerpc(&buf);
808 056fe1ba 2003-11-23 devnull f = fragalloc(p, 0, 0, nil);
809 056fe1ba 2003-11-23 devnull f->free = free;
810 056fe1ba 2003-11-23 devnull f->a = a;
811 056fe1ba 2003-11-23 devnull f->next = nil;
812 056fe1ba 2003-11-23 devnull f->rp = buf;
813 056fe1ba 2003-11-23 devnull f->wp = buf+n;
814 056fe1ba 2003-11-23 devnull
815 056fe1ba 2003-11-23 devnull p->first = f;
816 8baa0cbd 2004-06-09 devnull p->last = f;
817 056fe1ba 2003-11-23 devnull p->size = n;
818 8baa0cbd 2004-06-09 devnull NOTFREE(p);
819 056fe1ba 2003-11-23 devnull return p;
820 056fe1ba 2003-11-23 devnull }
821 056fe1ba 2003-11-23 devnull
822 056fe1ba 2003-11-23 devnull static Frag *
823 056fe1ba 2003-11-23 devnull fragdup(Packet *p, Frag *f)
824 056fe1ba 2003-11-23 devnull {
825 056fe1ba 2003-11-23 devnull Frag *ff;
826 056fe1ba 2003-11-23 devnull Mem *m;
827 056fe1ba 2003-11-23 devnull
828 fa325e9b 2020-01-10 cross m = f->mem;
829 056fe1ba 2003-11-23 devnull
830 056fe1ba 2003-11-23 devnull /*
831 056fe1ba 2003-11-23 devnull * m->rp && m->wp can be out of date when ref == 1
832 056fe1ba 2003-11-23 devnull * also, potentially reclaims space from previous frags
833 056fe1ba 2003-11-23 devnull */
834 056fe1ba 2003-11-23 devnull if(m && m->ref == 1) {
835 056fe1ba 2003-11-23 devnull m->rp = f->rp;
836 056fe1ba 2003-11-23 devnull m->wp = f->wp;
837 056fe1ba 2003-11-23 devnull }
838 056fe1ba 2003-11-23 devnull
839 056fe1ba 2003-11-23 devnull ff = fragalloc(p, 0, 0, nil);
840 8baa0cbd 2004-06-09 devnull ff->mem = f->mem;
841 8baa0cbd 2004-06-09 devnull ff->rp = f->rp;
842 8baa0cbd 2004-06-09 devnull ff->wp = f->wp;
843 8baa0cbd 2004-06-09 devnull ff->next = f->next;
844 8baa0cbd 2004-06-09 devnull
845 8baa0cbd 2004-06-09 devnull /*
846 8baa0cbd 2004-06-09 devnull * We can't duplicate these -- there's no dup function.
847 8baa0cbd 2004-06-09 devnull */
848 8baa0cbd 2004-06-09 devnull assert(f->free==nil && f->a==nil);
849 8baa0cbd 2004-06-09 devnull
850 056fe1ba 2003-11-23 devnull if(m){
851 056fe1ba 2003-11-23 devnull lock(&m->lk);
852 056fe1ba 2003-11-23 devnull m->ref++;
853 056fe1ba 2003-11-23 devnull unlock(&m->lk);
854 056fe1ba 2003-11-23 devnull }
855 8baa0cbd 2004-06-09 devnull
856 fa325e9b 2020-01-10 cross
857 056fe1ba 2003-11-23 devnull return ff;
858 056fe1ba 2003-11-23 devnull }
859 056fe1ba 2003-11-23 devnull
860 056fe1ba 2003-11-23 devnull
861 056fe1ba 2003-11-23 devnull static void
862 056fe1ba 2003-11-23 devnull fragfree(Frag *f)
863 056fe1ba 2003-11-23 devnull {
864 056fe1ba 2003-11-23 devnull if(f->mem == nil){
865 056fe1ba 2003-11-23 devnull if(f->free)
866 056fe1ba 2003-11-23 devnull (*f->free)(f->a);
867 056fe1ba 2003-11-23 devnull }else{
868 056fe1ba 2003-11-23 devnull memfree(f->mem);
869 056fe1ba 2003-11-23 devnull f->mem = 0;
870 056fe1ba 2003-11-23 devnull }
871 056fe1ba 2003-11-23 devnull
872 056fe1ba 2003-11-23 devnull if(f->state == FragLocalAlloc) {
873 056fe1ba 2003-11-23 devnull f->state = FragLocalFree;
874 056fe1ba 2003-11-23 devnull return;
875 056fe1ba 2003-11-23 devnull }
876 056fe1ba 2003-11-23 devnull
877 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
878 056fe1ba 2003-11-23 devnull f->next = freelist.frag;
879 056fe1ba 2003-11-23 devnull freelist.frag = f;
880 fa325e9b 2020-01-10 cross unlock(&freelist.lk);
881 056fe1ba 2003-11-23 devnull }
882 056fe1ba 2003-11-23 devnull
883 056fe1ba 2003-11-23 devnull static Mem *
884 056fe1ba 2003-11-23 devnull memalloc(int n, int pos)
885 056fe1ba 2003-11-23 devnull {
886 056fe1ba 2003-11-23 devnull Mem *m;
887 056fe1ba 2003-11-23 devnull int nn;
888 056fe1ba 2003-11-23 devnull
889 056fe1ba 2003-11-23 devnull if(n < 0 || n > MaxFragSize) {
890 056fe1ba 2003-11-23 devnull werrstr(EPacketSize);
891 13096891 2008-06-15 rsc return nil;
892 056fe1ba 2003-11-23 devnull }
893 056fe1ba 2003-11-23 devnull if(n <= SmallMemSize) {
894 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
895 056fe1ba 2003-11-23 devnull m = freelist.smallmem;
896 056fe1ba 2003-11-23 devnull if(m != nil)
897 056fe1ba 2003-11-23 devnull freelist.smallmem = m->next;
898 056fe1ba 2003-11-23 devnull else
899 056fe1ba 2003-11-23 devnull freelist.nsmallmem++;
900 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
901 056fe1ba 2003-11-23 devnull nn = SmallMemSize;
902 056fe1ba 2003-11-23 devnull } else {
903 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
904 056fe1ba 2003-11-23 devnull m = freelist.bigmem;
905 056fe1ba 2003-11-23 devnull if(m != nil)
906 056fe1ba 2003-11-23 devnull freelist.bigmem = m->next;
907 056fe1ba 2003-11-23 devnull else
908 056fe1ba 2003-11-23 devnull freelist.nbigmem++;
909 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
910 056fe1ba 2003-11-23 devnull nn = BigMemSize;
911 056fe1ba 2003-11-23 devnull }
912 056fe1ba 2003-11-23 devnull
913 056fe1ba 2003-11-23 devnull if(m == nil) {
914 056fe1ba 2003-11-23 devnull m = vtbrk(sizeof(Mem));
915 056fe1ba 2003-11-23 devnull m->bp = vtbrk(nn);
916 056fe1ba 2003-11-23 devnull m->ep = m->bp + nn;
917 056fe1ba 2003-11-23 devnull }
918 fa325e9b 2020-01-10 cross assert(m->ref == 0);
919 056fe1ba 2003-11-23 devnull m->ref = 1;
920 056fe1ba 2003-11-23 devnull
921 056fe1ba 2003-11-23 devnull switch(pos) {
922 056fe1ba 2003-11-23 devnull default:
923 056fe1ba 2003-11-23 devnull assert(0);
924 056fe1ba 2003-11-23 devnull case PFront:
925 056fe1ba 2003-11-23 devnull m->rp = m->bp;
926 056fe1ba 2003-11-23 devnull break;
927 056fe1ba 2003-11-23 devnull case PMiddle:
928 056fe1ba 2003-11-23 devnull /* leave a little bit at end */
929 056fe1ba 2003-11-23 devnull m->rp = m->ep - n - 32;
930 056fe1ba 2003-11-23 devnull break;
931 056fe1ba 2003-11-23 devnull case PEnd:
932 056fe1ba 2003-11-23 devnull m->rp = m->ep - n;
933 fa325e9b 2020-01-10 cross break;
934 056fe1ba 2003-11-23 devnull }
935 056fe1ba 2003-11-23 devnull /* check we did not blow it */
936 056fe1ba 2003-11-23 devnull if(m->rp < m->bp)
937 056fe1ba 2003-11-23 devnull m->rp = m->bp;
938 056fe1ba 2003-11-23 devnull m->wp = m->rp + n;
939 056fe1ba 2003-11-23 devnull assert(m->rp >= m->bp && m->wp <= m->ep);
940 056fe1ba 2003-11-23 devnull return m;
941 056fe1ba 2003-11-23 devnull }
942 056fe1ba 2003-11-23 devnull
943 056fe1ba 2003-11-23 devnull static void
944 056fe1ba 2003-11-23 devnull memfree(Mem *m)
945 056fe1ba 2003-11-23 devnull {
946 056fe1ba 2003-11-23 devnull lock(&m->lk);
947 056fe1ba 2003-11-23 devnull m->ref--;
948 056fe1ba 2003-11-23 devnull if(m->ref > 0) {
949 056fe1ba 2003-11-23 devnull unlock(&m->lk);
950 056fe1ba 2003-11-23 devnull return;
951 056fe1ba 2003-11-23 devnull }
952 056fe1ba 2003-11-23 devnull unlock(&m->lk);
953 056fe1ba 2003-11-23 devnull assert(m->ref == 0);
954 056fe1ba 2003-11-23 devnull
955 8baa0cbd 2004-06-09 devnull /* memset(m->bp, 0xEF, m->ep-m->bp); */
956 056fe1ba 2003-11-23 devnull switch(m->ep - m->bp) {
957 056fe1ba 2003-11-23 devnull default:
958 056fe1ba 2003-11-23 devnull assert(0);
959 056fe1ba 2003-11-23 devnull case SmallMemSize:
960 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
961 056fe1ba 2003-11-23 devnull m->next = freelist.smallmem;
962 056fe1ba 2003-11-23 devnull freelist.smallmem = m;
963 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
964 056fe1ba 2003-11-23 devnull break;
965 056fe1ba 2003-11-23 devnull case BigMemSize:
966 056fe1ba 2003-11-23 devnull lock(&freelist.lk);
967 056fe1ba 2003-11-23 devnull m->next = freelist.bigmem;
968 056fe1ba 2003-11-23 devnull freelist.bigmem = m;
969 056fe1ba 2003-11-23 devnull unlock(&freelist.lk);
970 056fe1ba 2003-11-23 devnull break;
971 056fe1ba 2003-11-23 devnull }
972 056fe1ba 2003-11-23 devnull }
973 056fe1ba 2003-11-23 devnull
974 056fe1ba 2003-11-23 devnull static int
975 056fe1ba 2003-11-23 devnull memhead(Mem *m, uchar *rp, int n)
976 056fe1ba 2003-11-23 devnull {
977 8baa0cbd 2004-06-09 devnull fprint(2, "memhead called\n");
978 8baa0cbd 2004-06-09 devnull abort();
979 056fe1ba 2003-11-23 devnull lock(&m->lk);
980 056fe1ba 2003-11-23 devnull if(m->rp != rp) {
981 056fe1ba 2003-11-23 devnull unlock(&m->lk);
982 056fe1ba 2003-11-23 devnull return -1;
983 056fe1ba 2003-11-23 devnull }
984 056fe1ba 2003-11-23 devnull m->rp -= n;
985 056fe1ba 2003-11-23 devnull unlock(&m->lk);
986 056fe1ba 2003-11-23 devnull return 0;
987 056fe1ba 2003-11-23 devnull }
988 056fe1ba 2003-11-23 devnull
989 056fe1ba 2003-11-23 devnull static int
990 056fe1ba 2003-11-23 devnull memtail(Mem *m, uchar *wp, int n)
991 056fe1ba 2003-11-23 devnull {
992 8baa0cbd 2004-06-09 devnull fprint(2, "memtail called\n");
993 8baa0cbd 2004-06-09 devnull abort();
994 056fe1ba 2003-11-23 devnull lock(&m->lk);
995 056fe1ba 2003-11-23 devnull if(m->wp != wp) {
996 056fe1ba 2003-11-23 devnull unlock(&m->lk);
997 056fe1ba 2003-11-23 devnull return -1;
998 056fe1ba 2003-11-23 devnull }
999 056fe1ba 2003-11-23 devnull m->wp += n;
1000 056fe1ba 2003-11-23 devnull unlock(&m->lk);
1001 056fe1ba 2003-11-23 devnull return 0;
1002 056fe1ba 2003-11-23 devnull }
1003 8baa0cbd 2004-06-09 devnull
1004 6ce75e8d 2007-04-21 devnull #ifdef NOTDEF
1005 8baa0cbd 2004-06-09 devnull static void
1006 8baa0cbd 2004-06-09 devnull checkpacket(Packet *p)
1007 8baa0cbd 2004-06-09 devnull {
1008 8baa0cbd 2004-06-09 devnull int s, as;
1009 8baa0cbd 2004-06-09 devnull Frag *f;
1010 8baa0cbd 2004-06-09 devnull Frag *ff;
1011 8baa0cbd 2004-06-09 devnull
1012 8baa0cbd 2004-06-09 devnull s = 0;
1013 8baa0cbd 2004-06-09 devnull as = 0;
1014 8baa0cbd 2004-06-09 devnull ff=p->first;
1015 8baa0cbd 2004-06-09 devnull for(f=p->first; f; ff=f,f=f->next){
1016 8baa0cbd 2004-06-09 devnull assert(f->p == p);
1017 8baa0cbd 2004-06-09 devnull s += FRAGSIZE(f);
1018 8baa0cbd 2004-06-09 devnull as += FRAGASIZE(f);
1019 8baa0cbd 2004-06-09 devnull }
1020 8baa0cbd 2004-06-09 devnull assert(s == p->size);
1021 8baa0cbd 2004-06-09 devnull assert(as == p->asize);
1022 8baa0cbd 2004-06-09 devnull if(p->first)
1023 8baa0cbd 2004-06-09 devnull assert(ff==p->last);
1024 8baa0cbd 2004-06-09 devnull }
1025 e5d47e6e 2004-12-28 devnull #endif