Commit ded0c2d1 authored by Ben Walker's avatar Ben Walker Committed by Tomasz Zawadzki
Browse files

bdevperf: Break code for running a job into a separate function 



This will make some refactoring later a bit clearer.

Signed-off-by: default avatarBen Walker <benjamin.walker@intel.com>
Change-Id: Iae2c36d1c298377cd20cf3226b3b8dfe712484ff
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/1503


Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarDarek Stojaczyk <dariusz.stojaczyk@intel.com>
Reviewed-by: default avatarPaul Luse <paul.e.luse@intel.com>
Reviewed-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: default avatarChangpeng Liu <changpeng.liu@intel.com>
Reviewed-by: default avatarAleksey Marchuk <alexeymar@mellanox.com>
parent 5dfd4f26

test/bdev/bdevperf/bdevperf.c

+17 −8
Original line number Diff line number Diff line
@@ -826,6 +826,22 @@ reset_job(void *arg) 
	return -1;

}



static void

bdevperf_job_run(struct bdevperf_job *job)

{

	/* Submit initial I/O for this job. Each time one

	 * completes, another will be submitted. */



	/* Start a timer to stop this I/O chain when the run is over */

	job->run_timer = spdk_poller_register(bdevperf_job_drain, job, g_time_in_usec);

	if (g_reset) {

		job->reset_timer = spdk_poller_register(reset_job, job,

							10 * 1000000);

	}



	bdevperf_submit_io(job, g_queue_depth);

}



static void

bdevperf_submit_on_reactor(struct spdk_io_channel_iter *i)

{
@@ -849,14 +865,7 @@ bdevperf_submit_on_reactor(struct spdk_io_channel_iter *i) 
			continue;

		}



		/* Start a timer to stop this I/O chain when the run is over */

		job->run_timer = spdk_poller_register(bdevperf_job_drain, job,

						      g_time_in_usec);

		if (g_reset) {

			job->reset_timer = spdk_poller_register(reset_job, job,

								10 * 1000000);

		}

		bdevperf_submit_io(job, g_queue_depth);

		bdevperf_job_run(job);

	}



	spdk_for_each_channel_continue(i, 0);