nfs/flexfilelayout/flexfilelayout.c

343 		struct pnfs_layout_segment *lseg,
346 	pnfs_generic_layout_insert_lseg(lo, lseg,
560 ff_layout_free_lseg(struct pnfs_layout_segment *lseg)
562 	struct nfs4_ff_layout_segment *fls = FF_LAYOUT_LSEG(lseg);
566 	if (lseg->pls_range.iomode == IOMODE_RW) {
570 		ffl = FF_LAYOUT_FROM_HDR(lseg->pls_layout);
573 		pnfs_generic_ds_cinfo_release_lseg(&ffl->commit_info, lseg);
724 ff_layout_mark_ds_unreachable(struct pnfs_layout_segment *lseg, u32 idx)
726 	struct nfs4_deviceid_node *devid = FF_LAYOUT_DEVID_NODE(lseg, idx);
733 ff_layout_mark_ds_reachable(struct pnfs_layout_segment *lseg, u32 idx)
735 	struct nfs4_deviceid_node *devid = FF_LAYOUT_DEVID_NODE(lseg, idx);
742 ff_layout_choose_ds_for_read(struct pnfs_layout_segment *lseg,
746 	struct nfs4_ff_layout_segment *fls = FF_LAYOUT_LSEG(lseg);
753 		mirror = FF_LAYOUT_COMP(lseg, idx);
754 		ds = nfs4_ff_layout_prepare_ds(lseg, mirror, false);
770 ff_layout_choose_any_ds_for_read(struct pnfs_layout_segment *lseg,
773 	return ff_layout_choose_ds_for_read(lseg, start_idx, best_idx, false);
777 ff_layout_choose_valid_ds_for_read(struct pnfs_layout_segment *lseg,
780 	return ff_layout_choose_ds_for_read(lseg, start_idx, best_idx, true);
784 ff_layout_choose_best_ds_for_read(struct pnfs_layout_segment *lseg,
789 	ds = ff_layout_choose_valid_ds_for_read(lseg, start_idx, best_idx);
792 	return ff_layout_choose_any_ds_for_read(lseg, start_idx, best_idx);
799 	struct pnfs_layout_segment *lseg = pgio->pg_lseg;
802 	ds = ff_layout_choose_best_ds_for_read(lseg, pgio->pg_mirror_idx,
806 	return ff_layout_choose_best_ds_for_read(lseg, 0, best_idx);
910 	/* If no lseg, fall back to write through mds */
973 	/* no lseg means that pnfs is not in use, so no mirroring here */
1042 				hdr->lseg);
1052 	if (ff_layout_choose_any_ds_for_read(hdr->lseg, idx, &new_idx))
1053 		ff_layout_send_layouterror(hdr->lseg);
1055 		pnfs_error_mark_layout_for_return(hdr->inode, hdr->lseg);
1064 	pnfs_error_mark_layout_for_return(hdr->inode, hdr->lseg);
1078 				hdr->lseg);
1086 					   struct pnfs_layout_segment *lseg,
1089 	struct pnfs_layout_hdr *lo = lseg->pls_layout;
1091 	struct nfs4_deviceid_node *devid = FF_LAYOUT_DEVID_NODE(lseg, idx);
1124 		 * Layout will not be destroyed until all current lseg
1149 		if (ff_layout_avoid_mds_available_ds(lseg))
1162 					   struct pnfs_layout_segment *lseg,
1165 	struct nfs4_deviceid_node *devid = FF_LAYOUT_DEVID_NODE(lseg, idx);
1177 		nfs_inc_stats(lseg->pls_layout->plh_inode, NFSIOS_DELAY);
1197 					struct pnfs_layout_segment *lseg,
1203 		ff_layout_mark_ds_reachable(lseg, idx);
1208 	if (!pnfs_is_valid_lseg(lseg))
1213 		return ff_layout_async_handle_error_v3(task, lseg, idx);
1216 						       lseg, idx);
1224 static void ff_layout_io_track_ds_error(struct pnfs_layout_segment *lseg,
1260 	mirror = FF_LAYOUT_COMP(lseg, idx);
1261 	err = ff_layout_track_ds_error(FF_LAYOUT_FROM_HDR(lseg->pls_layout),
1270 		ff_layout_mark_ds_unreachable(lseg, idx);
1279 		pnfs_error_mark_layout_for_return(lseg->pls_layout->plh_inode,
1280 						  lseg);
1293 		ff_layout_io_track_ds_error(hdr->lseg, hdr->pgio_mirror_idx,
1301 					   hdr->ds_clp, hdr->lseg,
1325 ff_layout_need_layoutcommit(struct pnfs_layout_segment *lseg)
1327 	return !(FF_LAYOUT_LSEG(lseg)->flags & FF_FLAGS_NO_LAYOUTCOMMIT);
1341 		struct pnfs_layout_segment *lseg,
1344 	if (!ff_layout_need_layoutcommit(lseg))
1347 	pnfs_set_layoutcommit(inode, lseg, end_offset);
1358 			FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
1369 			FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
1372 	set_bit(NFS_LSEG_LAYOUTRETURN, &hdr->lseg->pls_flags);
1383 	if (!pnfs_is_valid_lseg(hdr->lseg)) {
1463 		ff_layout_io_track_ds_error(hdr->lseg, hdr->pgio_mirror_idx,
1471 					   hdr->ds_clp, hdr->lseg,
1493 	ff_layout_set_layoutcommit(hdr->inode, hdr->lseg, end_offs);
1509 		ff_layout_io_track_ds_error(data->lseg, data->ds_commit_index,
1517 					   data->lseg, data->ds_commit_index);
1532 	ff_layout_set_layoutcommit(data->inode, data->lseg, data->lwb);
1543 			FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
1554 			FF_LAYOUT_COMP(hdr->lseg, hdr->pgio_mirror_idx),
1557 	set_bit(NFS_LSEG_LAYOUTRETURN, &hdr->lseg->pls_flags);
1568 	if (!pnfs_is_valid_lseg(hdr->lseg)) {
1629 		ff_layout_send_layouterror(hdr->lseg);
1642 			FF_LAYOUT_COMP(cdata->lseg, cdata->ds_commit_index),
1660 			FF_LAYOUT_COMP(cdata->lseg, cdata->ds_commit_index),
1662 	set_bit(NFS_LSEG_LAYOUTRETURN, &cdata->lseg->pls_flags);
1668 	if (!pnfs_is_valid_lseg(cdata->lseg)) {
1764 	struct pnfs_layout_segment *lseg = hdr->lseg;
1778 	mirror = FF_LAYOUT_COMP(lseg, idx);
1779 	ds = nfs4_ff_layout_prepare_ds(lseg, mirror, false);
1788 	ds_cred = ff_layout_get_ds_cred(mirror, &lseg->pls_range, hdr->cred);
1822 	if (ff_layout_avoid_mds_available_ds(lseg))
1826 			IOMODE_READ, NFS_I(hdr->inode)->layout, lseg);
1834 	struct pnfs_layout_segment *lseg = hdr->lseg;
1844 	mirror = FF_LAYOUT_COMP(lseg, idx);
1845 	ds = nfs4_ff_layout_prepare_ds(lseg, mirror, true);
1854 	ds_cred = ff_layout_get_ds_cred(mirror, &lseg->pls_range, hdr->cred);
1890 	if (ff_layout_avoid_mds_available_ds(lseg))
1894 			IOMODE_RW, NFS_I(hdr->inode)->layout, lseg);
1898 static u32 calc_ds_index_from_commit(struct pnfs_layout_segment *lseg, u32 i)
1904 select_ds_fh_from_commit(struct pnfs_layout_segment *lseg, u32 i)
1906 	struct nfs4_ff_layout_segment *flseg = FF_LAYOUT_LSEG(lseg);
1916 	struct pnfs_layout_segment *lseg = data->lseg;
1925 	if (!lseg || !(pnfs_is_valid_lseg(lseg) ||
1926 	    test_bit(NFS_LSEG_LAYOUTRETURN, &lseg->pls_flags)))
1929 	idx = calc_ds_index_from_commit(lseg, data->ds_commit_index);
1930 	mirror = FF_LAYOUT_COMP(lseg, idx);
1931 	ds = nfs4_ff_layout_prepare_ds(lseg, mirror, true);
1940 	ds_cred = ff_layout_get_ds_cred(mirror, &lseg->pls_range, data->cred);
1953 	fh = select_ds_fh_from_commit(lseg, data->ds_commit_index);
1979 			       const struct pnfs_layout_segment *lseg)
1981 	return hdr->lseg == lseg;
1986 				   const struct pnfs_layout_segment *lseg)
1988 	return cdata->lseg == lseg;
2006 static void ff_layout_cancel_io(struct pnfs_layout_segment *lseg)
2008 	struct nfs4_ff_layout_segment *flseg = FF_LAYOUT_LSEG(lseg);
2030 		if (!rpc_cancel_tasks(clnt, -EAGAIN, ff_layout_match_io, lseg))
2049 		struct pnfs_layout_segment *lseg)
2051 	struct nfs4_ff_layout_segment *flseg = FF_LAYOUT_LSEG(lseg);
2052 	struct inode *inode = lseg->pls_layout->plh_inode;
2059 		array = pnfs_add_commit_array(fl_cinfo, new, lseg);
2264 ff_layout_send_layouterror(struct pnfs_layout_segment *lseg)
2266 	struct pnfs_layout_hdr *lo = lseg->pls_layout;
2272 	ff_layout_fetch_ds_ioerr(lo, &lseg->pls_range, &head, -1);
2293 			if (nfs42_proc_layouterror(lseg, errors, n) < 0)
2303 ff_layout_send_layouterror(struct pnfs_layout_segment *lseg)