Lines Matching refs:wp
108 struct worker *wp; variable
148 wp = &workers[0]; in alloctape()
149 wp->count = 1; in alloctape()
150 wp->tapea = 0; in alloctape()
151 wp->firstrec = 0; in alloctape()
152 nextblock = wp->tblock; in alloctape()
160 wp->req[trecno].dblk = (daddr_t)0; in writerec()
161 wp->req[trecno].count = 1; in writerec()
180 wp->req[trecno].dblk = dblkno; in dumpblock()
181 wp->req[trecno].count = avail; in dumpblock()
282 int siz = (char *)nextblock - (char *)wp->req; in flushtape()
284 wp->req[trecno].count = 0; /* Sentinel */ in flushtape()
286 if (atomic_write(wp->fd, wp->req, siz) != siz) in flushtape()
288 wp->sent = 1; /* we sent a request, read the response later */ in flushtape()
290 lastfirstrec = wp->firstrec; in flushtape()
292 if (++wp >= &workers[WORKERS]) in flushtape()
293 wp = &workers[0]; in flushtape()
296 if (wp->sent) { in flushtape()
297 if (atomic_read(wp->fd, &got, sizeof got) in flushtape()
302 wp->sent = 0; in flushtape()
337 wp->count = lastspclrec + blks + 1 - iswap64(spcl.c_tapea); in flushtape()
338 wp->tapea = iswap64(spcl.c_tapea); in flushtape()
339 wp->firstrec = lastfirstrec + ntrec; in flushtape()
340 wp->inode = curino; in flushtape()
341 nextblock = wp->tblock; in flushtape()
475 otb = (union u_spcl *)wp->tblock; in rollforward()
482 for (p = wp->req; p->count > 0; p += p->count) { in rollforward()
504 spcl.c_tapea = iswap64(wp->tapea); in rollforward()
510 if (atomic_write(wp->fd, q, size) != size) { in rollforward()
514 wp->sent = 1; in rollforward()
515 if (++wp >= &workers[WORKERS]) in rollforward()
516 wp = &workers[0]; in rollforward()
539 wp->req[0] = *q; in rollforward()
540 nextblock = wp->tblock; in rollforward()
549 if (wp->sent) { in rollforward()
550 if (atomic_read(wp->fd, &got, sizeof got) in rollforward()
555 wp->sent = 0; in rollforward()
689 spcl.c_count = iswap32(wp->count); in startnewtape()
694 spcl.c_firstrec = iswap32(wp->firstrec); in startnewtape()
700 writeheader((ino_t)wp->inode); in startnewtape()
707 tapeno, wp->inode); in startnewtape()
764 if (i == wp - &workers[0]) { in create_workers()
840 while ((nread = atomic_read(cmd, wp->req, reqsiz)) == reqsiz) { in doworker()
841 struct req *p = wp->req; in doworker()
846 bread(p->dblk, wp->tblock[trecno], in doworker()
850 wp->tblock[trecno], in doworker()
872 wrote = rmtwrite(wp->tblock[0]+size, in doworker()
876 wrote = write(tapefd, wp->tblock[0]+size, in doworker()