Remove debug printf() in net engine
[fio.git] / engines / null.c
CommitLineData
a94ea28b 1/*
da751ca9
JA
2 * null engine
3 *
4 * IO engine that doesn't do any real IO transfers, it just pretends to.
5 * The main purpose is to test fio itself.
a94ea28b
JA
6 *
7 */
8#include <stdio.h>
9#include <stdlib.h>
10#include <unistd.h>
11#include <errno.h>
12#include <assert.h>
13
14#include "../fio.h"
a94ea28b 15
65afa5f2
JA
16struct null_data {
17 struct io_u **io_us;
18 int queued;
19 int events;
20};
21
22static struct io_u *fio_null_event(struct thread_data *td, int event)
23{
24 struct null_data *nd = td->io_ops->data;
25
26 return nd->io_us[event];
27}
28
e7d2e616
JA
29static int fio_null_getevents(struct thread_data *td, unsigned int min_events,
30 unsigned int fio_unused max,
31 struct timespec fio_unused *t)
65afa5f2
JA
32{
33 struct null_data *nd = td->io_ops->data;
7401c088
JA
34 int ret = 0;
35
36 if (min_events) {
37 ret = nd->events;
38 nd->events = 0;
39 }
65afa5f2 40
65afa5f2
JA
41 return ret;
42}
43
44static int fio_null_commit(struct thread_data *td)
45{
46 struct null_data *nd = td->io_ops->data;
47
ed8bd849
JA
48 if (!nd->events) {
49 nd->events = nd->queued;
50 nd->queued = 0;
51 }
52
65afa5f2
JA
53 return 0;
54}
55
36167d82 56static int fio_null_queue(struct thread_data fio_unused *td, struct io_u *io_u)
a94ea28b 57{
65afa5f2
JA
58 struct null_data *nd = td->io_ops->data;
59
7101d9c2
JA
60 fio_ro_check(td, io_u);
61
65afa5f2
JA
62 if (td->io_ops->flags & FIO_SYNCIO)
63 return FIO_Q_COMPLETED;
ed8bd849
JA
64 if (nd->events)
65 return FIO_Q_BUSY;
65afa5f2
JA
66
67 nd->io_us[nd->queued++] = io_u;
68 return FIO_Q_QUEUED;
a94ea28b
JA
69}
70
b5af8293
JA
71static int fio_null_open(struct thread_data fio_unused *td,
72 struct fio_file fio_unused *f)
73{
74 return 0;
75}
76
65afa5f2
JA
77static void fio_null_cleanup(struct thread_data *td)
78{
79 struct null_data *nd = td->io_ops->data;
80
81 if (nd) {
82 if (nd->io_us)
83 free(nd->io_us);
84 free(nd);
85 td->io_ops->data = NULL;
86 }
87}
88
89static int fio_null_init(struct thread_data *td)
90{
91 struct null_data *nd = malloc(sizeof(*nd));
92
93 memset(nd, 0, sizeof(*nd));
94
2dc1bbeb
JA
95 if (td->o.iodepth != 1) {
96 nd->io_us = malloc(td->o.iodepth * sizeof(struct io_u *));
97 memset(nd->io_us, 0, td->o.iodepth * sizeof(struct io_u *));
65afa5f2
JA
98 } else
99 td->io_ops->flags |= FIO_SYNCIO;
100
101 td->io_ops->data = nd;
102 return 0;
103}
104
a94ea28b
JA
105static struct ioengine_ops ioengine = {
106 .name = "null",
107 .version = FIO_IOOPS_VERSION,
a94ea28b 108 .queue = fio_null_queue,
65afa5f2
JA
109 .commit = fio_null_commit,
110 .getevents = fio_null_getevents,
111 .event = fio_null_event,
112 .init = fio_null_init,
113 .cleanup = fio_null_cleanup,
b5af8293 114 .open_file = fio_null_open,
65afa5f2 115 .flags = FIO_DISKLESSIO,
a94ea28b
JA
116};
117
118static void fio_init fio_null_register(void)
119{
120 register_ioengine(&ioengine);
121}
122
123static void fio_exit fio_null_unregister(void)
124{
125 unregister_ioengine(&ioengine);
126}