Cross Reference: /src/sbin/dump/tape.c

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