1 7a4ee46d 2003-11-23 devnull #include "stdinc.h"
2 7a4ee46d 2003-11-23 devnull #include "dat.h"
3 7a4ee46d 2003-11-23 devnull #include "fns.h"
5 7a4ee46d 2003-11-23 devnull typedef struct LumpQueue LumpQueue;
6 7a4ee46d 2003-11-23 devnull typedef struct WLump WLump;
10 7a4ee46d 2003-11-23 devnull MaxLumpQ = 1 << 3 /* max. lumps on a single write queue, must be pow 2 */
13 7a4ee46d 2003-11-23 devnull struct WLump
16 7a4ee46d 2003-11-23 devnull Packet *p;
17 7a4ee46d 2003-11-23 devnull int creator;
21 7a4ee46d 2003-11-23 devnull struct LumpQueue
23 7a4ee46d 2003-11-23 devnull QLock lock;
24 7a4ee46d 2003-11-23 devnull Rendez flush;
25 7a4ee46d 2003-11-23 devnull Rendez full;
26 7a4ee46d 2003-11-23 devnull Rendez empty;
27 7a4ee46d 2003-11-23 devnull WLump q[MaxLumpQ];
32 7a4ee46d 2003-11-23 devnull static LumpQueue *lumpqs;
33 7a4ee46d 2003-11-23 devnull static int nqs;
35 7a4ee46d 2003-11-23 devnull static QLock glk;
36 7a4ee46d 2003-11-23 devnull static int gen;
38 7a4ee46d 2003-11-23 devnull static void queueproc(void *vq);
41 7a4ee46d 2003-11-23 devnull initlumpqueues(int nq)
43 7a4ee46d 2003-11-23 devnull LumpQueue *q;
46 7a4ee46d 2003-11-23 devnull nqs = nq;
48 7a4ee46d 2003-11-23 devnull lumpqs = MKNZ(LumpQueue, nq);
50 7a4ee46d 2003-11-23 devnull for(i = 0; i < nq; i++){
51 7a4ee46d 2003-11-23 devnull q = &lumpqs[i];
52 7a4ee46d 2003-11-23 devnull q->full.l = &q->lock;
53 7a4ee46d 2003-11-23 devnull q->empty.l = &q->lock;
54 7a4ee46d 2003-11-23 devnull q->flush.l = &q->lock;
56 7a4ee46d 2003-11-23 devnull if(vtproc(queueproc, q) < 0){
57 7a4ee46d 2003-11-23 devnull seterr(EOk, "can't start write queue slave: %r");
58 7a4ee46d 2003-11-23 devnull return -1;
62 7a4ee46d 2003-11-23 devnull return 0;
66 7a4ee46d 2003-11-23 devnull * queue a lump & it's packet data for writing
69 7a4ee46d 2003-11-23 devnull queuewrite(Lump *u, Packet *p, int creator)
71 7a4ee46d 2003-11-23 devnull LumpQueue *q;
74 7a4ee46d 2003-11-23 devnull i = indexsect(mainindex, u->score);
75 7a4ee46d 2003-11-23 devnull if(i < 0 || i >= nqs){
76 7a4ee46d 2003-11-23 devnull seterr(EBug, "internal error: illegal index section in queuewrite");
77 7a4ee46d 2003-11-23 devnull return -1;
80 7a4ee46d 2003-11-23 devnull q = &lumpqs[i];
82 7a4ee46d 2003-11-23 devnull qlock(&q->lock);
83 7a4ee46d 2003-11-23 devnull while(q->r == ((q->w + 1) & (MaxLumpQ - 1)))
84 7a4ee46d 2003-11-23 devnull rsleep(&q->full);
86 7a4ee46d 2003-11-23 devnull q->q[q->w].u = u;
87 7a4ee46d 2003-11-23 devnull q->q[q->w].p = p;
88 7a4ee46d 2003-11-23 devnull q->q[q->w].creator = creator;
89 7a4ee46d 2003-11-23 devnull q->q[q->w].gen = gen;
90 7a4ee46d 2003-11-23 devnull q->w = (q->w + 1) & (MaxLumpQ - 1);
92 7a4ee46d 2003-11-23 devnull rwakeup(&q->empty);
94 7a4ee46d 2003-11-23 devnull qunlock(&q->lock);
96 7a4ee46d 2003-11-23 devnull return 0;
100 24998851 2004-03-11 devnull flushqueue(void)
103 7a4ee46d 2003-11-23 devnull LumpQueue *q;
105 333c1dcc 2004-03-13 devnull if(!lumpqs)
108 7a4ee46d 2003-11-23 devnull qlock(&glk);
110 7a4ee46d 2003-11-23 devnull qunlock(&glk);
112 7a4ee46d 2003-11-23 devnull for(i=0; i<mainindex->nsects; i++){
113 7a4ee46d 2003-11-23 devnull q = &lumpqs[i];
114 7a4ee46d 2003-11-23 devnull qlock(&q->lock);
115 7a4ee46d 2003-11-23 devnull while(q->w != q->r && gen - q->q[q->r].gen > 0)
116 7a4ee46d 2003-11-23 devnull rsleep(&q->flush);
117 7a4ee46d 2003-11-23 devnull qunlock(&q->lock);
121 7a4ee46d 2003-11-23 devnull static void
122 7a4ee46d 2003-11-23 devnull queueproc(void *vq)
124 7a4ee46d 2003-11-23 devnull LumpQueue *q;
125 7a4ee46d 2003-11-23 devnull Lump *u;
126 7a4ee46d 2003-11-23 devnull Packet *p;
127 7a4ee46d 2003-11-23 devnull int creator;
130 7a4ee46d 2003-11-23 devnull for(;;){
131 7a4ee46d 2003-11-23 devnull qlock(&q->lock);
132 7a4ee46d 2003-11-23 devnull while(q->w == q->r)
133 7a4ee46d 2003-11-23 devnull rsleep(&q->empty);
135 7a4ee46d 2003-11-23 devnull u = q->q[q->r].u;
136 7a4ee46d 2003-11-23 devnull p = q->q[q->r].p;
137 7a4ee46d 2003-11-23 devnull creator = q->q[q->r].creator;
139 7a4ee46d 2003-11-23 devnull rwakeup(&q->full);
141 7a4ee46d 2003-11-23 devnull qunlock(&q->lock);
143 7a4ee46d 2003-11-23 devnull if(writeqlump(u, p, creator) < 0)
144 7a4ee46d 2003-11-23 devnull fprint(2, "failed to write lump for %V: %r", u->score);
146 7a4ee46d 2003-11-23 devnull qlock(&q->lock);
147 7a4ee46d 2003-11-23 devnull q->r = (q->r + 1) & (MaxLumpQ - 1);
148 7a4ee46d 2003-11-23 devnull rwakeup(&q->flush);
149 7a4ee46d 2003-11-23 devnull qunlock(&q->lock);
151 7a4ee46d 2003-11-23 devnull putlump(u);