69 	uint32_t	blkno;		/* input block number */  member
161 	while (S->blkno < S->n_blocks) {  in vndcompress()
166 		if ((0 < S->end_block) && (S->end_block <= S->blkno))  in vndcompress()
171 		offtab_prepare_put(&S->offtab, (S->blkno + 1));  in vndcompress()
174 		const uint32_t readsize = (S->blkno == S->n_full_blocks?  in vndcompress()
187 			    S->blkno, (uintmax_t)S->offset,  in vndcompress()
192 		    compress_block(S->image_fd, S->cloop2_fd, S->blkno,  in vndcompress()
201 		assert(ADD_OK(uint32_t, S->blkno, 1));  in vndcompress()
204 		assert((S->blkno + 1) < S->n_offsets);  in vndcompress()
208 		S->blkno += 1;					/* (a) */  in vndcompress()
210 		offtab_put(&S->offtab, S->blkno, S->offset);	/* (c) */  in vndcompress()
216 	assert(S->blkno == S->n_blocks);  in vndcompress()
217 	assert((S->blkno + 1) == S->n_offsets);  in vndcompress()
311 	const uint64_t nread = ((uint64_t)S->blkno * (uint64_t)S->blocksize);  in info_signal_handler()
367 	assert(S->blkno <= MAX_N_BLOCKS);  in checkpoint_signal_handler()
371 	    ((uint64_t)S->blkno * (uint64_t)S->blocksize));  in checkpoint_signal_handler()
526 			if (S->blkno != 0) {  in compress_init()
549 	S->blkno = 0;  in compress_init()
629 	uint32_t blkno = 0;  in compress_restart()  local
631 	for (blkno = 0; blkno < S->n_blocks; blkno++) {  in compress_restart()
632 		if (!offtab_prepare_get(&S->offtab, blkno))  in compress_restart()
634 		const uint64_t offset = offtab_get(&S->offtab, blkno);  in compress_restart()
638 		if (0 < blkno) {  in compress_restart()
652 				    blkno, (end - start), start, end);  in compress_restart()
660 	if (blkno == 0) {  in compress_restart()
666 	if (blkno < S->n_blocks) {  in compress_restart()
669 		for (nblkno = blkno; nblkno < S->n_blocks; nblkno++) {  in compress_restart()
688 	assert(1 <= blkno);  in compress_restart()
689 	blkno -= 1;  in compress_restart()
699 	if (!offtab_transmogrify_read_to_write(&S->offtab, blkno))  in compress_restart()
709 	assert(blkno <= (S->size / S->blocksize));  in compress_restart()
710 	const off_t restart_position = ((off_t)blkno * (off_t)S->blocksize);  in compress_restart()
746 	S->blkno = blkno;  in compress_restart()
748 	S->n_checkpointed_blocks = blkno;  in compress_restart()
762 compress_block(int in_fd, int out_fd, uint32_t blkno, uint32_t blocksize,  in compress_block()  argument
772 		err(1, "read block %"PRIu32, blkno);  in compress_block()
776 		    blkno, (size_t)n_read, readsize);  in compress_block()
787 		errx(1, "compressed failed at block %"PRIu32" (%d): %s", blkno,  in compress_block()
794 		err(1, "write block %"PRIu32, blkno);  in compress_block()
798 		    blkno, (size_t)n_written, complen);  in compress_block()
810 	if ((0 < S->checkpoint_blocks) && (0 < S->blkno) &&  in compress_maybe_checkpoint()
811 	    ((S->blkno % S->checkpoint_blocks) == 0)) {  in compress_maybe_checkpoint()
844 	assert(S->blkno < S->n_offsets);  in compress_checkpoint()
845 	const uint32_t n_offsets = (S->blkno + 1);  in compress_checkpoint()
895 	S->n_checkpointed_blocks = S->blkno;  in compress_checkpoint()