Commit 7b66f132 authored by Linus Torvalds's avatar Linus Torvalds
Browse files

Merge tag 'for-4.12/dm-post-merge-changes' of... 

Merge tag 'for-4.12/dm-post-merge-changes' of git://git.kernel.org/pub/scm/linux/kernel/git/device-mapper/linux-dm

Pull additional device mapper updates from Mike Snitzer:
 "Here are some changes from Christoph that needed to be rebased ontop
  of changes that were already merged into the device mapper tree. In
  addition, these changes depend on the 'for-4.12/block' changes that
  you've already merged.

   - Cleanups to request-based DM and DM multipath from Christoph that
     prepare for his block core error code type checking improvements"

* tag 'for-4.12/dm-post-merge-changes' of git://git.kernel.org/pub/scm/linux/kernel/git/device-mapper/linux-dm:
  dm: introduce a new DM_MAPIO_KILL return value
  dm rq: change ->rq_end_io calling conventions
  dm mpath: merge do_end_io into multipath_end_io
parents d35a878a 412445ac

drivers/md/dm-mpath.c

+21 −33
Original line number Diff line number Diff line
@@ -1464,12 +1464,13 @@ static int noretry_error(int error) 
	return 0;

}



/*

 * end_io handling

 */

static int do_end_io(struct multipath *m, struct request *clone,

		     int error, struct dm_mpath_io *mpio)

static int multipath_end_io(struct dm_target *ti, struct request *clone,

			    int error, union map_info *map_context)

{

	struct dm_mpath_io *mpio = get_mpio(map_context);

	struct pgpath *pgpath = mpio->pgpath;

	int r = DM_ENDIO_DONE;



	/*

	 * We don't queue any clone request inside the multipath target

	 * during end I/O handling, since those clone requests don't have
@@ -1481,39 +1482,26 @@ static int do_end_io(struct multipath *m, struct request *clone, 
	 * request into dm core, which will remake a clone request and

	 * clone bios for it and resubmit it later.

	 */

	int r = DM_ENDIO_REQUEUE;



	if (!error)

		return 0;	/* I/O complete */

	if (error && !noretry_error(error)) {

		struct multipath *m = ti->private;



	if (noretry_error(error))

		return error;

		r = DM_ENDIO_REQUEUE;



	if (mpio->pgpath)

		fail_path(mpio->pgpath);

		if (pgpath)

			fail_path(pgpath);



		if (atomic_read(&m->nr_valid_paths) == 0 &&

	    !test_bit(MPATHF_QUEUE_IF_NO_PATH, &m->flags))

		r = dm_report_EIO(m);



	return r;

		    !test_bit(MPATHF_QUEUE_IF_NO_PATH, &m->flags)) {

			if (error == -EIO)

				error = dm_report_EIO(m);

			/* complete with the original error */

			r = DM_ENDIO_DONE;

		}

	}



static int multipath_end_io(struct dm_target *ti, struct request *clone,

			    int error, union map_info *map_context)

{

	struct multipath *m = ti->private;

	struct dm_mpath_io *mpio = get_mpio(map_context);

	struct pgpath *pgpath;

	struct path_selector *ps;

	int r;



	BUG_ON(!mpio);



	r = do_end_io(m, clone, error, mpio);

	pgpath = mpio->pgpath;

	if (pgpath) {

		ps = &pgpath->pg->ps;

		struct path_selector *ps = &pgpath->pg->ps;



		if (ps->type->end_io)

			ps->type->end_io(ps, &pgpath->path, mpio->nr_bytes);

	}

drivers/md/dm-rq.c

+15 −14
Original line number Diff line number Diff line
@@ -287,7 +287,7 @@ static void dm_requeue_original_request(struct dm_rq_target_io *tio, bool delay_ 


static void dm_done(struct request *clone, int error, bool mapped)

{

	int r = error;

	int r = DM_ENDIO_DONE;

	struct dm_rq_target_io *tio = clone->end_io_data;

	dm_request_endio_fn rq_end_io = NULL;
@@ -298,7 +298,7 @@ static void dm_done(struct request *clone, int error, bool mapped) 
			r = rq_end_io(tio->ti, clone, error, &tio->info);

	}



	if (unlikely(r == -EREMOTEIO)) {

	if (unlikely(error == -EREMOTEIO)) {

		if (req_op(clone) == REQ_OP_WRITE_SAME &&

		    !clone->q->limits.max_write_same_sectors)

			disable_write_same(tio->md);
@@ -307,16 +307,19 @@ static void dm_done(struct request *clone, int error, bool mapped) 
			disable_write_zeroes(tio->md);

	}



	if (r <= 0)

	switch (r) {

	case DM_ENDIO_DONE:

		/* The target wants to complete the I/O */

		dm_end_request(clone, r);

	else if (r == DM_ENDIO_INCOMPLETE)

		dm_end_request(clone, error);

		break;

	case DM_ENDIO_INCOMPLETE:

		/* The target will handle the I/O */

		return;

	else if (r == DM_ENDIO_REQUEUE)

	case DM_ENDIO_REQUEUE:

		/* The target wants to requeue the I/O */

		dm_requeue_original_request(tio, false);

	else {

		break;

	default:

		DMWARN("unimplemented target endio return value: %d", r);

		BUG();

	}
@@ -501,16 +504,14 @@ static int map_request(struct dm_rq_target_io *tio) 
		/* The target wants to requeue the I/O after a delay */

		dm_requeue_original_request(tio, true);

		break;

	case DM_MAPIO_KILL:

		/* The target wants to complete the I/O */

		dm_kill_unmapped_request(rq, -EIO);

	default:

		if (r > 0) {

		DMWARN("unimplemented target map return value: %d", r);

		BUG();

	}



		/* The target wants to complete the I/O */

		dm_kill_unmapped_request(rq, r);

	}



	return r;

}

drivers/md/dm-target.c

+1 −1
Original line number Diff line number Diff line
@@ -135,7 +135,7 @@ static int io_err_clone_and_map_rq(struct dm_target *ti, struct request *rq, 
				   union map_info *map_context,

				   struct request **clone)

{

	return -EIO;

	return DM_MAPIO_KILL;

}



static void io_err_release_clone_rq(struct request *clone)

include/linux/device-mapper.h

+2 −0
Original line number Diff line number Diff line
@@ -593,6 +593,7 @@ extern struct ratelimit_state dm_ratelimit_state; 
/*

 * Definitions of return values from target end_io function.

 */

#define DM_ENDIO_DONE		0

#define DM_ENDIO_INCOMPLETE	1

#define DM_ENDIO_REQUEUE	2
@@ -603,6 +604,7 @@ extern struct ratelimit_state dm_ratelimit_state; 
#define DM_MAPIO_REMAPPED	1

#define DM_MAPIO_REQUEUE	DM_ENDIO_REQUEUE

#define DM_MAPIO_DELAY_REQUEUE	3

#define DM_MAPIO_KILL		4



#define dm_sector_div64(x, y)( \

{ \

CRA Git | Maintained and supported by SUSTech CRA and CCSE