dist/tools/pvmove.c

52 				     struct volume_group *vg)
54 	if (vg_is_clustered(vg))
101 					 char **argv, struct volume_group *vg,
109 		allocatable_pvs = create_pv_list(cmd->mem, vg, argc, argv, 1);
111 		allocatable_pvs = clone_pv_list(cmd->mem, &vg->pvs);
166 			    lv->vg->name, lv->name);
174 						struct volume_group *vg,
189 					ALLOC_CONTIGUOUS, vg))) {
204 	dm_list_iterate_items(lvl, &vg->lvs) {
245 		log_error("No data to move for %s", vg->name);
272 static int _finish_pvmove(struct cmd_context *cmd, struct volume_group *vg,
276 static int _update_metadata(struct cmd_context *cmd, struct volume_group *vg,
280 	unsigned exclusive = _pvmove_is_exclusive(cmd, vg);
285 	if (!vg_write(vg)) {
298 			vg_revert(vg);
304 	if (!vg_commit(vg)) {
324 			if (!_finish_pvmove(cmd, vg, lv_mirr, lvs_changed))
344 	backup(vg);
353 	struct volume_group *vg;
390 	vg = _get_vg(cmd, pv_vg_name(pv));
391 	if (vg_read_error(vg)) {
392 		vg_release(vg);
397 	exclusive = _pvmove_is_exclusive(cmd, vg);
399 	if ((lv_mirr = find_pvmove_lv(vg, pv_dev(pv), PVMOVE))) {
404 		if (!(lvs_changed = lvs_using_lv(cmd, vg, lv_mirr))) {
418 		if (!(source_pvl = create_pv_list(cmd->mem, vg, 1,
424 			alloc = vg->alloc;
428 							     vg, pv, alloc)))
431 		if (!archive(vg))
434 		if (!(lv_mirr = _set_up_pvmove_lv(cmd, vg, source_pvl, lv_name,
446 	/* vg->status |= PVMOVE; */
450 		    (cmd, vg, lv_mirr, lvs_changed, PVMOVE_FIRST_TIME))
457 	unlock_and_release_vg(cmd, vg, pv_vg_name(pv));
461 static int _finish_pvmove(struct cmd_context *cmd, struct volume_group *vg,
483 	if (!vg_write(vg)) {
502 	if (!vg_commit(vg)) {
505 		vg_revert(vg);
536 	if (!vg_write(vg) || !vg_commit(vg)) {
543 	backup(vg);