[PATCH] Allow io engine to do the file setup
[fio.git] / ioengines.c
... / ...
CommitLineData
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
20struct 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
59void 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}