[fio.git] / ioengines.c

/*
 * The io parts of the fio tool, includes workers for sync and mmap'ed
 * io, as well as both posix and linux libaio support.
 *
 * sync io is implemented on top of aio.
 *
 * This is not really specific to fio, if the get_io_u/put_io_u and
 * structures was pulled into this as well it would be a perfectly
 * generic io engine that could be used for other projects.
 *
 */
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <dlfcn.h>
#include "fio.h"
#include "os.h"

struct ioengine_ops *load_ioengine(struct thread_data *td, char *name)
{
	char engine[16], engine_lib[256];
	struct ioengine_ops *ops;
	void *dlhandle;

	strcpy(engine, name);

	/*
	 * linux libaio has alias names, so convert to what we want
	 */
	if (!strncmp(engine, "linuxaio", 8) || !strncmp(engine, "aio", 3))
		strcpy(engine, "libaio");

	sprintf(engine_lib, "%s/lib/fio/fio-engine-%s.o", fio_inst_prefix, engine);
	dlerror();
	dlhandle = dlopen(engine_lib, RTLD_LAZY);
	if (!dlhandle) {
		td_vmsg(td, -1, dlerror());
		return NULL;
	}

	ops = dlsym(dlhandle, "ioengine");
	if (!ops) {
		td_vmsg(td, -1, dlerror());
		dlclose(dlhandle);
		return NULL;
	}

	if (ops->version != FIO_IOOPS_VERSION) {
		log_err("bad ioops version %d (want %d)\n", ops->version, FIO_IOOPS_VERSION);
		dlclose(dlhandle);
		return NULL;
	}

	ops->dlhandle = dlhandle;
	return ops;
}

void close_ioengine(struct thread_data *td)
{
	if (td->io_ops->cleanup)
		td->io_ops->cleanup(td);

	dlclose(td->io_ops->dlhandle);
}
Commit	Line	Data
	1	/*
	2	* The io parts of the fio tool, includes workers for sync and mmap'ed
	3	* io, as well as both posix and linux libaio support.
	4	*
	5	* sync io is implemented on top of aio.
	6	*
	7	* This is not really specific to fio, if the get_io_u/put_io_u and
	8	* structures was pulled into this as well it would be a perfectly
	9	* generic io engine that could be used for other projects.
	10	*
	11	*/
	12	#include <stdio.h>
	13	#include <stdlib.h>
	14	#include <unistd.h>
	15	#include <string.h>
	16	#include <dlfcn.h>
	17	#include "fio.h"
	18	#include "os.h"
	19
	20	struct ioengine_ops load_ioengine(struct thread_data td, char *name)
	21	{
	22	char engine[16], engine_lib[256];
	23	struct ioengine_ops *ops;
	24	void *dlhandle;
	25
	26	strcpy(engine, name);
	27
	28	/*
	29	* linux libaio has alias names, so convert to what we want
	30	*/
	31	if (!strncmp(engine, "linuxaio", 8) \|\| !strncmp(engine, "aio", 3))
	32	strcpy(engine, "libaio");
	33
	34	sprintf(engine_lib, "%s/lib/fio/fio-engine-%s.o", fio_inst_prefix, engine);
	35	dlerror();
	36	dlhandle = dlopen(engine_lib, RTLD_LAZY);
	37	if (!dlhandle) {
	38	td_vmsg(td, -1, dlerror());
	39	return NULL;
	40	}
	41
	42	ops = dlsym(dlhandle, "ioengine");
	43	if (!ops) {
	44	td_vmsg(td, -1, dlerror());
	45	dlclose(dlhandle);
	46	return NULL;
	47	}
	48
	49	if (ops->version != FIO_IOOPS_VERSION) {
	50	log_err("bad ioops version %d (want %d)\n", ops->version, FIO_IOOPS_VERSION);
	51	dlclose(dlhandle);
	52	return NULL;
	53	}
	54
	55	ops->dlhandle = dlhandle;
	56	return ops;
	57	}
	58
	59	void close_ioengine(struct thread_data *td)
	60	{
	61	if (td->io_ops->cleanup)
	62	td->io_ops->cleanup(td);
	63
	64	dlclose(td->io_ops->dlhandle);
	65	}