bsd/vfs/vfs_cluster.c

156 static void cluster_EOT(buf_t cbp_head, buf_t cbp_tail, int zero_offset);
157 static void cluster_wait_IO(buf_t cbp_head, int async);
158 static void cluster_complete_transaction(buf_t *cbp_head, void *callback_arg, int *retval, int flags, int needwait);
602 	buf_t	cbp_head;
608 	cbp_head = (buf_t)(bp->b_trans_head);
611 		     cbp_head, bp->b_lblkno, bp->b_bcount, bp->b_flags, 0);
613 	if (cbp_head->b_trans_next || !(cbp_head->b_flags & B_EOT)) {
624 		for (cbp = cbp_head; cbp; cbp = cbp->b_trans_next) {
632 					     cbp_head, cbp, cbp->b_bcount, cbp->b_flags, 0);
651 				     cbp_head, 0, 0, 0, 0);
659 	cbp        = cbp_head;
688 		if (cbp != cbp_head)
697 	        int	(*cliodone_func)(buf_t, void *) = (int (*)(buf_t, void *))(cbp_head->b_cliodone);
700 		        cbp_head->b_bcount = transaction_size;
702 		        error = (*cliodone_func)(cbp_head, callback_arg);
708         free_io_buf(cbp_head);
828 cluster_EOT(buf_t cbp_head, buf_t cbp_tail, int zero_offset)
830         cbp_head->b_validend = zero_offset;
835 cluster_wait_IO(buf_t cbp_head, int async)
853 		for (cbp = cbp_head; cbp; cbp = cbp->b_trans_next)
858 	for (cbp = cbp_head; cbp; cbp = cbp->b_trans_next) {
878 cluster_complete_transaction(buf_t *cbp_head, void *callback_arg, int *retval, int flags, int needwait)
889 	        for (cbp = *cbp_head; cbp; cbp = cbp->b_trans_next)
897 	for (cbp = *cbp_head; cbp; cbp = cbp->b_trans_next)
900 	error = cluster_iodone(*cbp_head, callback_arg);
906 	*cbp_head = (buf_t)NULL;
921 	buf_t	cbp_head = NULL;
1170 			if (cbp_head) {
1179 				cluster_wait_IO(cbp_head, (flags & CL_ASYNC));
1188                                 for (last_cbp = cbp = cbp_head; cbp->b_trans_next; cbp = cbp->b_trans_next)
1199 					if (cbp == cbp_head) {
1204 					        cbp_head = NULL;
1214 				if (cbp_head) {
1221 				        cluster_EOT(cbp_head, cbp_tail, 0);
1223 					cluster_complete_transaction(&cbp_head, callback_arg, &retval, flags, 0);
1313 			if (cbp_head) {
1385 			if (cbp_head && (complete_transaction_now || size == 0))  {
1386 			        cluster_wait_IO(cbp_head, (flags & CL_ASYNC));
1388 				cluster_EOT(cbp_head, cbp_tail, size == 0 ? zero_offset : 0);
1390 				cluster_complete_transaction(&cbp_head, callback_arg, &retval, flags, 0);
1495 		if (cbp_head) {
1499 		        cbp_head = cbp;
1502 			if ( (cbp_head->b_real_bp = real_bp) )
1505 		*(buf_t *)(&cbp->b_trans_head) = cbp_head;
1553 		        cluster_EOT(cbp_head, cbp_tail, size == 0 ? zero_offset : 0);
1573 			        cluster_complete_transaction(&cbp_head, callback_arg, &retval, flags, 1);
1577 			cbp_head = NULL;
1585 		if (cbp_head) {
1590 		        cluster_wait_IO(cbp_head, (flags & CL_ASYNC));
1596 			upl_offset = cbp_head->b_uploffset;
1598 			for (cbp = cbp_head; cbp;) {
1649 	} else if (cbp_head)
1650 			panic("%s(): cbp_head is not NULL.\n", __FUNCTION__);