init.c revision 5cd033bbb08dbdd2241a0eac09ef34a59a5d8f52
1906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe/*
2cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe * This file contains job initialization and setup functions.
3906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe */
4ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <stdio.h>
5ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <stdlib.h>
6ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <unistd.h>
7ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <fcntl.h>
8ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <ctype.h>
9ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <string.h>
10ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <errno.h>
11b46928282e0a890f49250e79b81af773a2b7108fJens Axboe#include <getopt.h>
12b46928282e0a890f49250e79b81af773a2b7108fJens Axboe#include <assert.h>
13ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <sys/ipc.h>
14ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <sys/shm.h>
15ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <sys/types.h>
16ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include <sys/stat.h>
17ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
18ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#include "fio.h"
19cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe#include "parse.h"
20ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
21906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe/*
22906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * The default options
23906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe */
2420dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_BS			(4096)
2520dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_TIMEOUT		(0)
2620dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_RATE_CYCLE		(1000)
2720dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_ODIRECT		(1)
2820dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_IO_ENGINE		(FIO_SYNCIO)
29ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#define DEF_IO_ENGINE_NAME	"sync"
3020dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_SEQUENTIAL		(1)
3120dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_RAND_REPEAT		(1)
32178d11f29ffc50c46d907129ee81c3b41f48c926Jens Axboe#define DEF_OVERWRITE		(0)
3320dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_INVALIDATE		(1)
3420dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_SYNCIO		(0)
3520dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_RANDSEED		(0xb1899bedUL)
3620dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_BWAVGTIME		(500)
3720dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_CREATE_SER		(1)
38ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#define DEF_CREATE_FSYNC	(1)
3920dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_LOOPS		(1)
4020dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_VERIFY		(0)
4120dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_STONEWALL		(0)
4220dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_NUMJOBS		(1)
4320dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_USE_THREAD		(0)
4420dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_FILE_SIZE		(1024 * 1024 * 1024UL)
4520dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_ZONE_SIZE		(0)
4620dc95c47087d486b5d4608fc15b1c2021761923Jens Axboe#define DEF_ZONE_SKIP		(0)
47a6ccc7be771650f903ea77ace2a1af593622c0f4Jens Axboe#define DEF_RWMIX_CYCLE		(500)
48a6ccc7be771650f903ea77ace2a1af593622c0f4Jens Axboe#define DEF_RWMIX_READ		(50)
49b6f4d8804ad499adf10b4cad0657284a8a4a6287Jens Axboe#define DEF_NICE		(0)
5053cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe#define DEF_NR_FILES		(1)
51178d11f29ffc50c46d907129ee81c3b41f48c926Jens Axboe#define DEF_UNLINK		(1)
52ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboe#define DEF_WRITE_BW_LOG	(0)
53ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboe#define DEF_WRITE_LAT_LOG	(0)
54bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe#define DEF_NO_RAND_MAP		(0)
5556bb17f297c50b2832c845b0f6cdde5063748b34Jens Axboe#define DEF_HUGEPAGE_SIZE	FIO_HUGE_PAGE
569c1f7434526606fc8a4296190a2dea5de2651266Jens Axboe#define DEF_THINKTIME_BLOCKS	(1)
57ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
58e1f365035a952233463d85d659bd960ba78f012eJens Axboe#define td_var_offset(var)	((size_t) &((struct thread_data *)0)->var)
59e1f365035a952233463d85d659bd960ba78f012eJens Axboe
60b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic int str_rw_cb(void *, const char *);
61b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic int str_ioengine_cb(void *, const char *);
62b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic int str_mem_cb(void *, const char *);
63b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic int str_verify_cb(void *, const char *);
64e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_lockmem_cb(void *, unsigned long *);
6534cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe#ifdef FIO_HAVE_IOPRIO
66e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_prio_cb(void *, unsigned int *);
67e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_prioclass_cb(void *, unsigned int *);
6834cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe#endif
69e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_exitall_cb(void);
70e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_cpumask_cb(void *, unsigned int *);
71e1f365035a952233463d85d659bd960ba78f012eJens Axboe
72e1f365035a952233463d85d659bd960ba78f012eJens Axboe/*
73e1f365035a952233463d85d659bd960ba78f012eJens Axboe * Map of job/command line options
74e1f365035a952233463d85d659bd960ba78f012eJens Axboe */
75e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic struct fio_option options[] = {
76e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
77e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "name",
78e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_STORE,
79e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(name),
80e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
81e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
82e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "directory",
83e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_STORE,
84e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(directory),
85e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
86e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
87e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "filename",
88e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_STORE,
89e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(filename),
90e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
91e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
92e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "rw",
93e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR,
94e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_rw_cb,
95e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
96e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
97e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "ioengine",
98e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR,
99e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_ioengine_cb,
100e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
101e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
102e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "mem",
103e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR,
104e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_mem_cb,
105e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
106e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
107e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "verify",
108e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR,
109e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_verify_cb,
110e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
111e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
112e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "write_iolog",
113076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe		.type	= FIO_OPT_STR_STORE,
114076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe		.off1	= td_var_offset(write_iolog_file),
115e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
116e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
117076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe		.name	= "read_iolog",
118e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_STORE,
119076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe		.off1	= td_var_offset(read_iolog_file),
120e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
121e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
122e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "exec_prerun",
123e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_STORE,
124e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(exec_prerun),
125e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
126e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
127e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "exec_postrun",
128e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_STORE,
129e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(exec_postrun),
130e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
131e1f365035a952233463d85d659bd960ba78f012eJens Axboe#ifdef FIO_HAVE_IOSCHED_SWITCH
132e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
133e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "ioscheduler",
134e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_STORE,
135e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(ioscheduler),
136e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
137e1f365035a952233463d85d659bd960ba78f012eJens Axboe#endif
138e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
139e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "size",
140e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_VAL,
141e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(total_file_size),
142e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
143e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
144e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "bs",
14575e6f36fae06978f29296fce76a7f00ca0df7b56Jens Axboe		.type	= FIO_OPT_STR_VAL_INT,
146a00735e66f9ec42549da94eba3170e543b542904Jens Axboe		.off1	= td_var_offset(bs[DDIR_READ]),
147f90eff5a414f6e8c16a51c3a7d9b5e077ab49aacJens Axboe		.off2	= td_var_offset(bs[DDIR_WRITE]),
148e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
149e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
150e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "offset",
151e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_VAL,
152e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(start_offset),
153e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
154e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
155e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "zonesize",
156e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_VAL,
157e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(zone_size),
158e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
159e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
160e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "zoneskip",
161e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_VAL,
162e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(zone_skip),
163e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
164e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
165e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "lockmem",
166e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_VAL,
167e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_lockmem_cb,
168e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
169e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
170e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "bsrange",
171e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_RANGE,
172a00735e66f9ec42549da94eba3170e543b542904Jens Axboe		.off1	= td_var_offset(min_bs[DDIR_READ]),
173a00735e66f9ec42549da94eba3170e543b542904Jens Axboe		.off2	= td_var_offset(max_bs[DDIR_READ]),
174f90eff5a414f6e8c16a51c3a7d9b5e077ab49aacJens Axboe		.off3	= td_var_offset(min_bs[DDIR_WRITE]),
175f90eff5a414f6e8c16a51c3a7d9b5e077ab49aacJens Axboe		.off4	= td_var_offset(max_bs[DDIR_WRITE]),
176e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
177e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
178e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "nrfiles",
179e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
180e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(nr_files),
181e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
182e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
183e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "iodepth",
184e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
185e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(iodepth),
186e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
187e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
188e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "fsync",
189e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
190e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(fsync_blocks),
191e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
192e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
193e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "rwmixcycle",
194e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
195e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(rwmixcycle),
196e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
197e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
198e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "rwmixread",
199e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
200e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(rwmixread),
201e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.max_val= 100,
202e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
203e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
204e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "rwmixwrite",
205e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
206e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(rwmixwrite),
207e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.max_val= 100,
208e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
209e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
210e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "nice",
211e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
212e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(nice),
213e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
214e1f365035a952233463d85d659bd960ba78f012eJens Axboe#ifdef FIO_HAVE_IOPRIO
215e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
216e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "prio",
217e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
218e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_prio_cb,
219e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
220e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
221e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "prioclass",
222e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
223e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_prioclass_cb,
224e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
225e1f365035a952233463d85d659bd960ba78f012eJens Axboe#endif
226e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
227e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "thinktime",
228e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2291304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(thinktime),
230e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
231e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
2329c1f7434526606fc8a4296190a2dea5de2651266Jens Axboe		.name	= "thinktime_blocks",
2339c1f7434526606fc8a4296190a2dea5de2651266Jens Axboe		.type	= FIO_OPT_INT,
2341304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(thinktime_blocks),
2359c1f7434526606fc8a4296190a2dea5de2651266Jens Axboe	},
2369c1f7434526606fc8a4296190a2dea5de2651266Jens Axboe	{
237e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "rate",
238e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2391304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(rate),
240e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
241e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
242e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "ratemin",
243e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2441304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(ratemin),
245e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
246e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
247e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "ratecycle",
248e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2491304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(ratecycle),
250e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
251e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
252e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "startdelay",
253e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2541304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(start_delay),
255e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
256e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
257e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "timeout",
258e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_VAL_TIME,
2591304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(timeout),
260e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
261e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
262e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "invalidate",
263e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2641304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(invalidate_cache),
265e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
266e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
267e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "sync",
268e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2691304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(sync_io),
270e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
271e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
272e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "bwavgtime",
273e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2741304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(bw_avg_time),
275e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
276e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
277e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "create_serialize",
278e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2791304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(create_serialize),
280e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
281e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
282e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "create_fsync",
283e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2841304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(create_fsync),
285e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
286e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
287e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "loops",
288e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2891304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(loops),
290e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
291e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
292e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "numjobs",
293e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2941304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(numjobs),
295e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
296e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
297e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "cpuload",
298e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
2991304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(cpuload),
300e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
301e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
302e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "cpuchunks",
303e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
3041304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(cpucycle),
305e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
306e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
307e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "direct",
308e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
3091304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(odirect),
310e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
311e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
312e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "overwrite",
313e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
3141304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(overwrite),
315e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
316e1f365035a952233463d85d659bd960ba78f012eJens Axboe#ifdef FIO_HAVE_CPU_AFFINITY
317e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
318e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "cpumask",
319e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
320e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_cpumask_cb,
321e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
322e1f365035a952233463d85d659bd960ba78f012eJens Axboe#endif
323e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
324e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "end_fsync",
325e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_INT,
3261304923a76e2e7f8c283240b3c6eb13ddd71db7aJens Axboe		.off1	= td_var_offset(end_fsync),
327e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
328e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
329e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "unlink",
3308aeebd5570ac4fccbcdd48f2e6f1cf1577f3c08dJens Axboe		.type	= FIO_OPT_INT,
331e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(unlink),
332e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
333e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
334e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "exitall",
335e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_SET,
336e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.cb	= str_exitall_cb,
337e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
338e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
339e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "stonewall",
340e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_SET,
341e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(stonewall),
342e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
343e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
344e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "thread",
345e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_SET,
346e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(thread),
347e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
348e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
349e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "write_bw_log",
350e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_SET,
351e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(write_bw_log),
352e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
353e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
354e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name	= "write_lat_log",
355e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.type	= FIO_OPT_STR_SET,
356e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.off1	= td_var_offset(write_lat_log),
357e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
358e1f365035a952233463d85d659bd960ba78f012eJens Axboe	{
359bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe		.name	= "norandommap",
360bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe		.type	= FIO_OPT_STR_SET,
361bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe		.off1	= td_var_offset(norandommap),
362bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe	},
363bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe	{
364690adba373bb8c97a365c67da369e265953c4b4cJens Axboe		.name	= "bs_unaligned",
365690adba373bb8c97a365c67da369e265953c4b4cJens Axboe		.type	= FIO_OPT_STR_SET,
366690adba373bb8c97a365c67da369e265953c4b4cJens Axboe		.off1	= td_var_offset(bs_unaligned),
367690adba373bb8c97a365c67da369e265953c4b4cJens Axboe	},
368690adba373bb8c97a365c67da369e265953c4b4cJens Axboe	{
36956bb17f297c50b2832c845b0f6cdde5063748b34Jens Axboe		.name	= "hugepage-size",
37056bb17f297c50b2832c845b0f6cdde5063748b34Jens Axboe		.type	= FIO_OPT_STR_VAL,
37156bb17f297c50b2832c845b0f6cdde5063748b34Jens Axboe		.off1	= td_var_offset(hugepage_size),
37256bb17f297c50b2832c845b0f6cdde5063748b34Jens Axboe	},
37356bb17f297c50b2832c845b0f6cdde5063748b34Jens Axboe	{
374e1f365035a952233463d85d659bd960ba78f012eJens Axboe		.name = NULL,
375e1f365035a952233463d85d659bd960ba78f012eJens Axboe	},
376e1f365035a952233463d85d659bd960ba78f012eJens Axboe};
377e1f365035a952233463d85d659bd960ba78f012eJens Axboe
378b46928282e0a890f49250e79b81af773a2b7108fJens Axboe#define FIO_JOB_OPTS	(sizeof(options) / sizeof(struct fio_option))
379b46928282e0a890f49250e79b81af773a2b7108fJens Axboe#define FIO_CMD_OPTS	(16)
380b46928282e0a890f49250e79b81af773a2b7108fJens Axboe#define FIO_GETOPT_JOB	(0x89988998)
381b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
382b46928282e0a890f49250e79b81af773a2b7108fJens Axboe/*
383b46928282e0a890f49250e79b81af773a2b7108fJens Axboe * Command line options. These will contain the above, plus a few
384b46928282e0a890f49250e79b81af773a2b7108fJens Axboe * extra that only pertain to fio itself and not jobs.
385b46928282e0a890f49250e79b81af773a2b7108fJens Axboe */
386b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic struct option long_options[FIO_JOB_OPTS + FIO_CMD_OPTS] = {
387b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	{
388b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.name		= "output",
389b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.has_arg	= required_argument,
390b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.val		= 'o',
391b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	},
392b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	{
393b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.name		= "timeout",
394b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.has_arg	= required_argument,
395b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.val		= 't',
396b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	},
397b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	{
398b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.name		= "latency-log",
399b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.has_arg	= required_argument,
400b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.val		= 'l',
401b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	},
402b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	{
403b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.name		= "bandwidth-log",
404b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.has_arg	= required_argument,
405b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.val		= 'b',
406b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	},
407b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	{
408b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.name		= "minimal",
409b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.has_arg	= optional_argument,
410b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.val		= 'm',
411b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	},
412b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	{
413b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.name		= "version",
414b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.has_arg	= no_argument,
415b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.val		= 'v',
416b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	},
417b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	{
418b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		.name		= NULL,
419b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	},
420b46928282e0a890f49250e79b81af773a2b7108fJens Axboe};
421b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
422972cfd2546081c0397447ca9243ea419b1ff579aJens Axboestatic int def_timeout = DEF_TIMEOUT;
423972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe
4245cd033bbb08dbdd2241a0eac09ef34a59a5d8f52Jens Axboestatic char fio_version_string[] = "fio 1.11";
425ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
426972cfd2546081c0397447ca9243ea419b1ff579aJens Axboestatic char **ini_file;
427ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestatic int max_jobs = MAX_JOBS;
428ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
429ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestruct thread_data def_thread;
430ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestruct thread_data *threads = NULL;
431ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
432ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboeint exitall_on_terminate = 0;
433c6ae0a5b8123ea9af2ce70319081fbd5d65c8093Jens Axboeint terse_output = 0;
434c04f7ec3ecb8ce780bde6ad3515f003e6015c62aJens Axboeunsigned long long mlock_size = 0;
435eb8bbf48e79a8c6afd3c84e3d64263d10ee45daaJens AxboeFILE *f_out = NULL;
436eb8bbf48e79a8c6afd3c84e3d64263d10ee45daaJens AxboeFILE *f_err = NULL;
437ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
438ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboestatic int write_lat_log = DEF_WRITE_LAT_LOG;
439ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboestatic int write_bw_log = DEF_WRITE_BW_LOG;
440ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboe
441906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe/*
442906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * Return a free job structure.
443906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe */
444ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestatic struct thread_data *get_new_job(int global, struct thread_data *parent)
445ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
446ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	struct thread_data *td;
447ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
448ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (global)
449ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return &def_thread;
450ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (thread_number >= max_jobs)
451ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return NULL;
452ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
453ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	td = &threads[thread_number++];
454ddaeaa5ab1e3f1cb6f35a9f4a18ee932151a0ab8Jens Axboe	*td = *parent;
455ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
456ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	td->thread_number = thread_number;
457ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return td;
458ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
459ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
460ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestatic void put_job(struct thread_data *td)
461ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
462549577a728fc3bacbfea8978c4f514cef5b073dcJens Axboe	if (td == &def_thread)
463549577a728fc3bacbfea8978c4f514cef5b073dcJens Axboe		return;
464549577a728fc3bacbfea8978c4f514cef5b073dcJens Axboe
465ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	memset(&threads[td->thread_number - 1], 0, sizeof(*td));
466ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	thread_number--;
467ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
468ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
469dad915e36819e74c4540db19faae488ede963ee4Jens Axboe/*
470dad915e36819e74c4540db19faae488ede963ee4Jens Axboe * Lazy way of fixing up options that depend on each other. We could also
471dad915e36819e74c4540db19faae488ede963ee4Jens Axboe * define option callback handlers, but this is easier.
472dad915e36819e74c4540db19faae488ede963ee4Jens Axboe */
473e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic void fixup_options(struct thread_data *td)
474e1f365035a952233463d85d659bd960ba78f012eJens Axboe{
475e1f365035a952233463d85d659bd960ba78f012eJens Axboe	if (!td->rwmixread && td->rwmixwrite)
476e1f365035a952233463d85d659bd960ba78f012eJens Axboe		td->rwmixread = 100 - td->rwmixwrite;
477dad915e36819e74c4540db19faae488ede963ee4Jens Axboe
478076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe	if (td->write_iolog_file && td->read_iolog_file) {
479076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe		log_err("fio: read iolog overrides write_iolog\n");
480076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe		free(td->write_iolog_file);
481076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe		td->write_iolog_file = NULL;
482076efc7c60c351df783960a646e7fe8fba29dc19Jens Axboe	}
48316b462aeb47996111ee6aa516c9226708db7c248Jens Axboe
48416b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	if (td->io_ops->flags & FIO_SYNCIO)
48516b462aeb47996111ee6aa516c9226708db7c248Jens Axboe		td->iodepth = 1;
48616b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	else {
48716b462aeb47996111ee6aa516c9226708db7c248Jens Axboe		if (!td->iodepth)
48816b462aeb47996111ee6aa516c9226708db7c248Jens Axboe			td->iodepth = td->nr_files;
48916b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	}
49016b462aeb47996111ee6aa516c9226708db7c248Jens Axboe
49116b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	/*
49216b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	 * only really works for sequential io for now, and with 1 file
49316b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	 */
49416b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	if (td->zone_size && !td->sequential && td->nr_files == 1)
49516b462aeb47996111ee6aa516c9226708db7c248Jens Axboe		td->zone_size = 0;
49616b462aeb47996111ee6aa516c9226708db7c248Jens Axboe
49716b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	/*
49816b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	 * Reads can do overwrites, we always need to pre-create the file
49916b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	 */
50016b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	if (td_read(td) || td_rw(td))
50116b462aeb47996111ee6aa516c9226708db7c248Jens Axboe		td->overwrite = 1;
50216b462aeb47996111ee6aa516c9226708db7c248Jens Axboe
503a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	if (!td->min_bs[DDIR_READ])
504a00735e66f9ec42549da94eba3170e543b542904Jens Axboe		td->min_bs[DDIR_READ]= td->bs[DDIR_READ];
505a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	if (!td->max_bs[DDIR_READ])
506a00735e66f9ec42549da94eba3170e543b542904Jens Axboe		td->max_bs[DDIR_READ] = td->bs[DDIR_READ];
507a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	if (!td->min_bs[DDIR_WRITE])
50875e6f36fae06978f29296fce76a7f00ca0df7b56Jens Axboe		td->min_bs[DDIR_WRITE]= td->bs[DDIR_WRITE];
509a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	if (!td->max_bs[DDIR_WRITE])
51075e6f36fae06978f29296fce76a7f00ca0df7b56Jens Axboe		td->max_bs[DDIR_WRITE] = td->bs[DDIR_WRITE];
511a00735e66f9ec42549da94eba3170e543b542904Jens Axboe
512a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	td->rw_min_bs = min(td->min_bs[DDIR_READ], td->min_bs[DDIR_WRITE]);
513a00735e66f9ec42549da94eba3170e543b542904Jens Axboe
51416b462aeb47996111ee6aa516c9226708db7c248Jens Axboe	if (td_read(td) && !td_rw(td))
51516b462aeb47996111ee6aa516c9226708db7c248Jens Axboe		td->verify = 0;
516bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe
517bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe	if (td->norandommap && td->verify != VERIFY_NONE) {
518bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe		log_err("fio: norandommap given, verify disabled\n");
519bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe		td->verify = VERIFY_NONE;
520bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe	}
521690adba373bb8c97a365c67da369e265953c4b4cJens Axboe	if (td->bs_unaligned && (td->odirect || td->io_ops->flags & FIO_RAWIO))
522690adba373bb8c97a365c67da369e265953c4b4cJens Axboe		log_err("fio: bs_unaligned may not work with raw io\n");
523e0a223354342cc45a916b669343718b80a20c2eaJens Axboe
524e0a223354342cc45a916b669343718b80a20c2eaJens Axboe	/*
525e0a223354342cc45a916b669343718b80a20c2eaJens Axboe	 * O_DIRECT and char doesn't mix, clear that flag if necessary.
526e0a223354342cc45a916b669343718b80a20c2eaJens Axboe	 */
527e0a223354342cc45a916b669343718b80a20c2eaJens Axboe	if (td->filetype == FIO_TYPE_CHAR && td->odirect)
528e0a223354342cc45a916b669343718b80a20c2eaJens Axboe		td->odirect = 0;
529e1f365035a952233463d85d659bd960ba78f012eJens Axboe}
530e1f365035a952233463d85d659bd960ba78f012eJens Axboe
531906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe/*
532f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe * This function leaks the buffer
533f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe */
534f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboestatic char *to_kmg(unsigned int val)
535f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe{
536f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe	char *buf = malloc(32);
537245142ff7554290cf666e3ef6b7b57512bf17d75Jens Axboe	char post[] = { 0, 'K', 'M', 'G', 'P', 0 };
538f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe	char *p = post;
539f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe
540245142ff7554290cf666e3ef6b7b57512bf17d75Jens Axboe	do {
541f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe		if (val & 1023)
542f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe			break;
543f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe
544f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe		val >>= 10;
545f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe		p++;
546245142ff7554290cf666e3ef6b7b57512bf17d75Jens Axboe	} while (*p);
547f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe
548f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe	snprintf(buf, 31, "%u%c", val, *p);
549f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe	return buf;
550f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe}
551f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe
552f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe/*
553906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * Adds a job to the list of things todo. Sanitizes the various options
554906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * to make sure we don't have conflicts, and initializes various
555906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * members of td.
556906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe */
557751548451d969148529b642c05e7544726ec3b64Jens Axboestatic int add_job(struct thread_data *td, const char *jobname, int job_add_num)
558ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
5593c9b60c1fb144950ca51220ffa18f485672c3ba6Jens Axboe	const char *ddir_str[] = { "read", "write", "randread", "randwrite",
5603c9b60c1fb144950ca51220ffa18f485672c3ba6Jens Axboe				   "rw", NULL, "randrw" };
561ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	struct stat sb;
56253cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	int numjobs, ddir, i;
56353cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	struct fio_file *f;
564ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
565ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	/*
566ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 * the def_thread is just for options, it's not a real job
567ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 */
568ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (td == &def_thread)
569ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
570ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
571df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe	/*
572df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe	 * Set default io engine, if none set
573df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe	 */
574df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe	if (!td->io_ops) {
575df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe		td->io_ops = load_ioengine(td, DEF_IO_ENGINE_NAME);
576df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe		if (!td->io_ops) {
577df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe			log_err("default engine %s not there?\n", DEF_IO_ENGINE_NAME);
578df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe			return 1;
579df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe		}
580df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe	}
581df64119de537aba99c85d1dc80190b354589f8b9Jens Axboe
582690adba373bb8c97a365c67da369e265953c4b4cJens Axboe	if (td->odirect)
583690adba373bb8c97a365c67da369e265953c4b4cJens Axboe		td->io_ops->flags |= FIO_RAWIO;
584690adba373bb8c97a365c67da369e265953c4b4cJens Axboe
585ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	td->filetype = FIO_TYPE_FILE;
5860af7b542b69af5ab2400a9960a5bcde82c05723fJens Axboe	if (!stat(jobname, &sb)) {
5870af7b542b69af5ab2400a9960a5bcde82c05723fJens Axboe		if (S_ISBLK(sb.st_mode))
5880af7b542b69af5ab2400a9960a5bcde82c05723fJens Axboe			td->filetype = FIO_TYPE_BD;
5890af7b542b69af5ab2400a9960a5bcde82c05723fJens Axboe		else if (S_ISCHR(sb.st_mode))
5900af7b542b69af5ab2400a9960a5bcde82c05723fJens Axboe			td->filetype = FIO_TYPE_CHAR;
5910af7b542b69af5ab2400a9960a5bcde82c05723fJens Axboe	}
592ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
593e0a223354342cc45a916b669343718b80a20c2eaJens Axboe	fixup_options(td);
594e0a223354342cc45a916b669343718b80a20c2eaJens Axboe
59513f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe	if (td->filename)
59613f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe		td->nr_uniq_files = 1;
59713f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe	else
59813f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe		td->nr_uniq_files = td->nr_files;
59913f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe
60013f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe	if (td->filetype == FIO_TYPE_FILE || td->filename) {
601e9c047a0d8dfc32634b896e1600c6f1aa4174378Jens Axboe		char tmp[PATH_MAX];
60253cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		int len = 0;
603e9c047a0d8dfc32634b896e1600c6f1aa4174378Jens Axboe
604ef899b6393c43abd655ad2cbc22de18b88a101f8Jens Axboe		if (td->directory && td->directory[0] != '\0')
6058aeebd5570ac4fccbcdd48f2e6f1cf1577f3c08dJens Axboe			len = sprintf(tmp, "%s/", td->directory);
606ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
60753cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		td->files = malloc(sizeof(struct fio_file) * td->nr_files);
60853cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe
60953cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		for_each_file(td, f, i) {
61053cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe			memset(f, 0, sizeof(*f));
61153cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe			f->fd = -1;
61253cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe
61313f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe			if (td->filename)
61413f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe				sprintf(tmp + len, "%s", td->filename);
61513f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe			else
61613f8e2d2e3e5ec7d8c18b70fb2a2e2a026190020Jens Axboe				sprintf(tmp + len, "%s.%d.%d", jobname, td->thread_number, i);
61753cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe			f->file_name = strdup(tmp);
61853cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		}
61953cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	} else {
62053cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		td->nr_files = 1;
62153cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		td->files = malloc(sizeof(struct fio_file));
62253cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		f = &td->files[0];
62353cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe
62453cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		memset(f, 0, sizeof(*f));
62553cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		f->fd = -1;
62653cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		f->file_name = strdup(jobname);
62753cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	}
62853cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe
62953cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	for_each_file(td, f, i) {
63053cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		f->file_size = td->total_file_size / td->nr_files;
63153cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe		f->file_offset = td->start_offset;
63253cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	}
63353cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe
634bbfd6b00dea4daee05133c8cb991b78d091df9aeJens Axboe	fio_sem_init(&td->mutex, 0);
635ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
636ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	td->clat_stat[0].min_val = td->clat_stat[1].min_val = ULONG_MAX;
637ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	td->slat_stat[0].min_val = td->slat_stat[1].min_val = ULONG_MAX;
638ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	td->bw_stat[0].min_val = td->bw_stat[1].min_val = ULONG_MAX;
639ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
640ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (td->stonewall && td->thread_number > 1)
641ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		groupid++;
642ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
643ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	td->groupid = groupid;
644ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
645ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (setup_rate(td))
646ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		goto err;
647ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
648ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboe	if (td->write_lat_log) {
649ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		setup_log(&td->slat_log);
650ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		setup_log(&td->clat_log);
651ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
652ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboe	if (td->write_bw_log)
653ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		setup_log(&td->bw_log);
654ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
655b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	if (!td->name)
656b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		td->name = strdup(jobname);
65701452055af61d6f5de543575dba3ebb0c9e55fabJens Axboe
6583d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe	ddir = td->ddir + (!td->sequential << 1) + (td->iomix << 2);
659751548451d969148529b642c05e7544726ec3b64Jens Axboe
660c6ae0a5b8123ea9af2ce70319081fbd5d65c8093Jens Axboe	if (!terse_output) {
661b990b5c06801d6d25e3fcc5415efbbe7bb23341eJens Axboe		if (!job_add_num) {
6622866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe			if (td->io_ops->flags & FIO_CPUIO)
663b990b5c06801d6d25e3fcc5415efbbe7bb23341eJens Axboe				fprintf(f_out, "%s: ioengine=cpu, cpuload=%u, cpucycle=%u\n", td->name, td->cpuload, td->cpucycle);
664f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe			else {
665f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				char *c1, *c2, *c3, *c4;
666f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe
667f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				c1 = to_kmg(td->min_bs[DDIR_READ]);
668f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				c2 = to_kmg(td->max_bs[DDIR_READ]);
669f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				c3 = to_kmg(td->min_bs[DDIR_WRITE]);
670f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				c4 = to_kmg(td->max_bs[DDIR_WRITE]);
671f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe
6721e97cce9f5a87a67293a05ec4533ed6968698b2eJens Axboe				fprintf(f_out, "%s: (g=%d): rw=%s, odir=%u, bs=%s-%s/%s-%s, rate=%u, ioengine=%s, iodepth=%u\n", td->name, td->groupid, ddir_str[ddir], td->odirect, c1, c2, c3, c4, td->rate, td->io_ops->name, td->iodepth);
673f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe
674f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				free(c1);
675f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				free(c2);
676f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				free(c3);
677f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe				free(c4);
678f8977ee606bc51138a77f6a1b653df00faa77742Jens Axboe			}
679b990b5c06801d6d25e3fcc5415efbbe7bb23341eJens Axboe		} else if (job_add_num == 1)
680c6ae0a5b8123ea9af2ce70319081fbd5d65c8093Jens Axboe			fprintf(f_out, "...\n");
681c6ae0a5b8123ea9af2ce70319081fbd5d65c8093Jens Axboe	}
682ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
683ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	/*
684ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 * recurse add identical jobs, clear numjobs and stonewall options
685ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 * as they don't apply to sub-jobs
686ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 */
687ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	numjobs = td->numjobs;
688ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	while (--numjobs) {
689ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		struct thread_data *td_new = get_new_job(0, td);
690ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
691ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		if (!td_new)
692ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			goto err;
693ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
694ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td_new->numjobs = 1;
695ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td_new->stonewall = 0;
696751548451d969148529b642c05e7544726ec3b64Jens Axboe		job_add_num = numjobs - 1;
697ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
698751548451d969148529b642c05e7544726ec3b64Jens Axboe		if (add_job(td_new, jobname, job_add_num))
699ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			goto err;
700ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
701ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 0;
702ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboeerr:
703ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	put_job(td);
704ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return -1;
705ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
706ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
707906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe/*
708906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * Initialize the various random states we need (random io, block size ranges,
709906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * read/write mix, etc).
710906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe */
711ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboeint init_random_state(struct thread_data *td)
712ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
713a6ccc7be771650f903ea77ace2a1af593622c0f4Jens Axboe	unsigned long seeds[4];
71453cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	int fd, num_maps, blocks, i;
7150ab8db8943acc6b9ea778735563bfad2a79e8dddJens Axboe	struct fio_file *f;
716ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
717f48b467cba78af0843c7320caf841e2bee72fb1eJens Axboe	if (td->io_ops->flags & FIO_CPUIO)
718f48b467cba78af0843c7320caf841e2bee72fb1eJens Axboe		return 0;
719f48b467cba78af0843c7320caf841e2bee72fb1eJens Axboe
7201ac267bb7dd678fa12bb3573c29cff5238ef9ccfJens Axboe	fd = open("/dev/urandom", O_RDONLY);
721ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (fd == -1) {
722ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td_verror(td, errno);
723ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 1;
724ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
725ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
726a6ccc7be771650f903ea77ace2a1af593622c0f4Jens Axboe	if (read(fd, seeds, sizeof(seeds)) < (int) sizeof(seeds)) {
727ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td_verror(td, EIO);
728ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		close(fd);
729ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 1;
730ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
731ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
732ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	close(fd);
733ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
7346dfd46b99af38cc1e5f702f53c59212129fe615eJens Axboe	os_random_seed(seeds[0], &td->bsrange_state);
7356dfd46b99af38cc1e5f702f53c59212129fe615eJens Axboe	os_random_seed(seeds[1], &td->verify_state);
7366dfd46b99af38cc1e5f702f53c59212129fe615eJens Axboe	os_random_seed(seeds[2], &td->rwmix_state);
737ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
738ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (td->sequential)
739ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
740ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
7419ebc27e1352b905fe3396ce2350a7765fe9c57b8Jens Axboe	if (td->rand_repeatable)
742a6ccc7be771650f903ea77ace2a1af593622c0f4Jens Axboe		seeds[3] = DEF_RANDSEED;
743ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
744bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe	if (!td->norandommap) {
745bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe		for_each_file(td, f, i) {
746a00735e66f9ec42549da94eba3170e543b542904Jens Axboe			blocks = (f->file_size + td->rw_min_bs - 1) / td->rw_min_bs;
747c7c280ed2e4f836bd8e9e125d55d097539b70e21Jens Axboe			num_maps = (blocks + BLOCKS_PER_MAP-1)/ BLOCKS_PER_MAP;
748bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe			f->file_map = malloc(num_maps * sizeof(long));
749bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe			f->num_maps = num_maps;
750bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe			memset(f->file_map, 0, num_maps * sizeof(long));
751bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe		}
75253cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	}
753ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
7546dfd46b99af38cc1e5f702f53c59212129fe615eJens Axboe	os_random_seed(seeds[3], &td->random_state);
755ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 0;
756ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
757ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
758ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestatic void fill_cpu_mask(os_cpu_mask_t cpumask, int cpu)
759ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
760ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#ifdef FIO_HAVE_CPU_AFFINITY
761ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	unsigned int i;
762ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
763ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	CPU_ZERO(&cpumask);
764ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
765ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	for (i = 0; i < sizeof(int) * 8; i++) {
766ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		if ((1 << i) & cpu)
767ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			CPU_SET(i, &cpumask);
768ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
769ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#endif
770ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
771ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
772ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestatic int is_empty_or_comment(char *line)
773ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
774ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	unsigned int i;
775ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
776ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	for (i = 0; i < strlen(line); i++) {
777ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		if (line[i] == ';')
778ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			return 1;
779ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		if (!isspace(line[i]) && !iscntrl(line[i]))
780ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			return 0;
781ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
782ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
783ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 1;
784ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
785ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
786b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic int str_rw_cb(void *data, const char *mem)
787ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
788cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe	struct thread_data *td = data;
789cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe
790ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (!strncmp(mem, "read", 4) || !strncmp(mem, "0", 1)) {
791ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->ddir = DDIR_READ;
792ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->sequential = 1;
793ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
794ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	} else if (!strncmp(mem, "randread", 8)) {
795ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->ddir = DDIR_READ;
796ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->sequential = 0;
797ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
798ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	} else if (!strncmp(mem, "write", 5) || !strncmp(mem, "1", 1)) {
799ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->ddir = DDIR_WRITE;
800ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->sequential = 1;
801ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
802ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	} else if (!strncmp(mem, "randwrite", 9)) {
803ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->ddir = DDIR_WRITE;
804ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->sequential = 0;
805ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
8063d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe	} else if (!strncmp(mem, "rw", 2)) {
8071e97cce9f5a87a67293a05ec4533ed6968698b2eJens Axboe		td->ddir = DDIR_READ;
8083d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe		td->iomix = 1;
8093d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe		td->sequential = 1;
8103d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe		return 0;
8113d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe	} else if (!strncmp(mem, "randrw", 6)) {
8121e97cce9f5a87a67293a05ec4533ed6968698b2eJens Axboe		td->ddir = DDIR_READ;
8133d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe		td->iomix = 1;
8143d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe		td->sequential = 0;
8153d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe		return 0;
816ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
817ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
8183b70d7e51e0b672a8b337c57c8faf865c0b7f415Jens Axboe	log_err("fio: data direction: read, write, randread, randwrite, rw, randrw\n");
819ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 1;
820ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
821ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
822b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic int str_verify_cb(void *data, const char *mem)
823ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
824cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe	struct thread_data *td = data;
825cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe
826ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (!strncmp(mem, "0", 1)) {
827ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->verify = VERIFY_NONE;
828ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
829ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	} else if (!strncmp(mem, "md5", 3) || !strncmp(mem, "1", 1)) {
830ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->verify = VERIFY_MD5;
831ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
832ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	} else if (!strncmp(mem, "crc32", 5)) {
833ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->verify = VERIFY_CRC32;
834ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
835ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
836ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
8373b70d7e51e0b672a8b337c57c8faf865c0b7f415Jens Axboe	log_err("fio: verify types: md5, crc32\n");
838ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 1;
839ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
840ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
841313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe/*
842313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe * Check if mmap/mmaphuge has a :/foo/bar/file at the end. If so, return that.
843313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe */
844313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboestatic char *get_mmap_file(const char *str)
845313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe{
846313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe	char *p = strstr(str, ":");
847313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe
848313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe	if (!p)
849313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe		return NULL;
850313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe
851313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe	p++;
852313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe	strip_blank_front(&p);
853313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe	strip_blank_end(p);
854313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe	return strdup(p);
855313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe}
856313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe
857b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic int str_mem_cb(void *data, const char *mem)
858ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
859cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe	struct thread_data *td = data;
860cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe
861ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (!strncmp(mem, "malloc", 6)) {
862ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->mem_type = MEM_MALLOC;
863ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
864d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe	} else if (!strncmp(mem, "mmaphuge", 8)) {
865d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe#ifdef FIO_HAVE_HUGETLB
866d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe		/*
867d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe		 * mmaphuge must be appended with the actual file
868d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe		 */
869313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe		td->mmapfile = get_mmap_file(mem);
870313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe		if (!td->mmapfile) {
871d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe			log_err("fio: mmaphuge:/path/to/file\n");
872d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe			return 1;
873d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe		}
874d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe
875d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe		td->mem_type = MEM_MMAPHUGE;
876d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe		return 0;
877d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe#else
878d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe		log_err("fio: mmaphuge not available\n");
879d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe		return 1;
880d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe#endif
881ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	} else if (!strncmp(mem, "mmap", 4)) {
882313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe		/*
883313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe		 * Check if the user wants file backed memory. It's ok
884313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe		 * if there's no file given, we'll just use anon mamp then.
885313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe		 */
886313cb206ffc6e50c089314d322ebf1c523f37531Jens Axboe		td->mmapfile = get_mmap_file(mem);
887ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td->mem_type = MEM_MMAP;
888ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 0;
88974b025b071b5bfbffa7ad7682b66b749e8d1f955Jens Axboe	} else if (!strncmp(mem, "shmhuge", 7)) {
89074b025b071b5bfbffa7ad7682b66b749e8d1f955Jens Axboe#ifdef FIO_HAVE_HUGETLB
89174b025b071b5bfbffa7ad7682b66b749e8d1f955Jens Axboe		td->mem_type = MEM_SHMHUGE;
89274b025b071b5bfbffa7ad7682b66b749e8d1f955Jens Axboe		return 0;
89374b025b071b5bfbffa7ad7682b66b749e8d1f955Jens Axboe#else
89474b025b071b5bfbffa7ad7682b66b749e8d1f955Jens Axboe		log_err("fio: shmhuge not available\n");
89574b025b071b5bfbffa7ad7682b66b749e8d1f955Jens Axboe		return 1;
89674b025b071b5bfbffa7ad7682b66b749e8d1f955Jens Axboe#endif
8970268b8ba7b2c79c669323cb1fcc0b045b84313f1Jens Axboe	} else if (!strncmp(mem, "shm", 3)) {
8980268b8ba7b2c79c669323cb1fcc0b045b84313f1Jens Axboe		td->mem_type = MEM_SHM;
8990268b8ba7b2c79c669323cb1fcc0b045b84313f1Jens Axboe		return 0;
900ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
901ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
902d0bdaf49eb3f4faa941d02274f2bd875a187e7d7Jens Axboe	log_err("fio: mem type: malloc, shm, shmhuge, mmap, mmaphuge\n");
903ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 1;
904ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
905ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
906b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic int str_ioengine_cb(void *data, const char *str)
907ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
908cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe	struct thread_data *td = data;
909cb2c86fdf03241fee32fd2e2caff43af1022403cJens Axboe
9102866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe	td->io_ops = load_ioengine(td, str);
9112866c82d598e30604d8a92723c664ee6ced90fb0Jens Axboe	if (td->io_ops)
912b990b5c06801d6d25e3fcc5415efbbe7bb23341eJens Axboe		return 0;
913ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
91408aae9a0d5f3d24152abd7515984439bbfd3c05dJens Axboe	log_err("fio: ioengine= libaio, posixaio, sync, mmap, sgio, splice, cpu, null\n");
9155f350952eff89948bfbf1eb6ac4d3d08a9109581Jens Axboe	log_err("fio: or specify path to dynamic ioengine module\n");
916ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 1;
917ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
918ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
919e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_lockmem_cb(void fio_unused *data, unsigned long *val)
920e1f365035a952233463d85d659bd960ba78f012eJens Axboe{
921e1f365035a952233463d85d659bd960ba78f012eJens Axboe	mlock_size = *val;
922e1f365035a952233463d85d659bd960ba78f012eJens Axboe	return 0;
923e1f365035a952233463d85d659bd960ba78f012eJens Axboe}
924e1f365035a952233463d85d659bd960ba78f012eJens Axboe
92534cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe#ifdef FIO_HAVE_IOPRIO
926e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_prioclass_cb(void *data, unsigned int *val)
927e1f365035a952233463d85d659bd960ba78f012eJens Axboe{
928e1f365035a952233463d85d659bd960ba78f012eJens Axboe	struct thread_data *td = data;
929e1f365035a952233463d85d659bd960ba78f012eJens Axboe
930e1f365035a952233463d85d659bd960ba78f012eJens Axboe	td->ioprio |= *val << IOPRIO_CLASS_SHIFT;
931e1f365035a952233463d85d659bd960ba78f012eJens Axboe	return 0;
932e1f365035a952233463d85d659bd960ba78f012eJens Axboe}
933e1f365035a952233463d85d659bd960ba78f012eJens Axboe
934e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_prio_cb(void *data, unsigned int *val)
935e1f365035a952233463d85d659bd960ba78f012eJens Axboe{
936e1f365035a952233463d85d659bd960ba78f012eJens Axboe	struct thread_data *td = data;
937e1f365035a952233463d85d659bd960ba78f012eJens Axboe
938e1f365035a952233463d85d659bd960ba78f012eJens Axboe	td->ioprio |= *val;
939e1f365035a952233463d85d659bd960ba78f012eJens Axboe	return 0;
940e1f365035a952233463d85d659bd960ba78f012eJens Axboe}
94134cfcdafa994a0a75120e498c51eda08bde5df72Jens Axboe#endif
942e1f365035a952233463d85d659bd960ba78f012eJens Axboe
943e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_exitall_cb(void)
944e1f365035a952233463d85d659bd960ba78f012eJens Axboe{
945e1f365035a952233463d85d659bd960ba78f012eJens Axboe	exitall_on_terminate = 1;
946e1f365035a952233463d85d659bd960ba78f012eJens Axboe	return 0;
947e1f365035a952233463d85d659bd960ba78f012eJens Axboe}
948e1f365035a952233463d85d659bd960ba78f012eJens Axboe
949e1f365035a952233463d85d659bd960ba78f012eJens Axboestatic int str_cpumask_cb(void *data, unsigned int *val)
950e1f365035a952233463d85d659bd960ba78f012eJens Axboe{
951e1f365035a952233463d85d659bd960ba78f012eJens Axboe	struct thread_data *td = data;
952e1f365035a952233463d85d659bd960ba78f012eJens Axboe
953e1f365035a952233463d85d659bd960ba78f012eJens Axboe	fill_cpu_mask(td->cpumask, *val);
954e1f365035a952233463d85d659bd960ba78f012eJens Axboe	return 0;
955e1f365035a952233463d85d659bd960ba78f012eJens Axboe}
956e1f365035a952233463d85d659bd960ba78f012eJens Axboe
957072619835aa805f3335dca9d72f4d4eb1009aecdJens Axboe/*
958072619835aa805f3335dca9d72f4d4eb1009aecdJens Axboe * This is our [ini] type file parser.
959072619835aa805f3335dca9d72f4d4eb1009aecdJens Axboe */
9601e97cce9f5a87a67293a05ec4533ed6968698b2eJens Axboestatic int parse_jobs_ini(char *file, int stonewall_flag)
961ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
962e1f365035a952233463d85d659bd960ba78f012eJens Axboe	unsigned int global;
963ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	struct thread_data *td;
964fee3bb48f748afe5cf10f8505e1efd36b87c627eJens Axboe	char *string, *name;
965ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	fpos_t off;
966ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	FILE *f;
967ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	char *p;
9680c7e37a04aa04ba22e812f8de7971fcef46b8191Jens Axboe	int ret = 0, stonewall;
969ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
970ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	f = fopen(file, "r");
971ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (!f) {
972aea47d444b02bd7c622f82bb73151fd7136a499fJens Axboe		perror("fopen job file");
973ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 1;
974ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
975ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
976ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	string = malloc(4096);
977ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	name = malloc(256);
978fee3bb48f748afe5cf10f8505e1efd36b87c627eJens Axboe	memset(name, 0, 256);
979ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
9800c7e37a04aa04ba22e812f8de7971fcef46b8191Jens Axboe	stonewall = stonewall_flag;
9817c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe	do {
9827c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe		p = fgets(string, 4095, f);
9837c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe		if (!p)
98445410acb636e526575d62a037f81ade7916b738cJens Axboe			break;
985ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		if (is_empty_or_comment(p))
986ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			continue;
987fee3bb48f748afe5cf10f8505e1efd36b87c627eJens Axboe		if (sscanf(p, "[%255s]", name) != 1)
988ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			continue;
989ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
990ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		global = !strncmp(name, "global", 6);
991ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
992ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		name[strlen(name) - 1] = '\0';
993ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
994ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		td = get_new_job(global, &def_thread);
99545410acb636e526575d62a037f81ade7916b738cJens Axboe		if (!td) {
99645410acb636e526575d62a037f81ade7916b738cJens Axboe			ret = 1;
99745410acb636e526575d62a037f81ade7916b738cJens Axboe			break;
99845410acb636e526575d62a037f81ade7916b738cJens Axboe		}
999ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1000972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe		/*
1001972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe		 * Seperate multiple job files by a stonewall
1002972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe		 */
1003f94819192600fe35d03ebed26a803abdc2b9864cJens Axboe		if (!global && stonewall) {
1004972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe			td->stonewall = stonewall;
1005972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe			stonewall = 0;
1006972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe		}
1007972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe
1008ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		fgetpos(f, &off);
1009ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		while ((p = fgets(string, 4096, f)) != NULL) {
1010ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			if (is_empty_or_comment(p))
1011ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe				continue;
1012e1f365035a952233463d85d659bd960ba78f012eJens Axboe
1013b6754f9d3f719627d8aae4c3e8f39212d9405f99Jens Axboe			strip_blank_front(&p);
10147c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe
10157c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe			if (p[0] == '[')
10167c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe				break;
10177c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe
10184ae3f76333bf2382e516db0b5c202b8982b1170fJens Axboe			strip_blank_end(p);
1019aea47d444b02bd7c622f82bb73151fd7136a499fJens Axboe
1020e1f365035a952233463d85d659bd960ba78f012eJens Axboe			fgetpos(f, &off);
1021ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
102245410acb636e526575d62a037f81ade7916b738cJens Axboe			/*
102345410acb636e526575d62a037f81ade7916b738cJens Axboe			 * Don't break here, continue parsing options so we
102445410acb636e526575d62a037f81ade7916b738cJens Axboe			 * dump all the bad ones. Makes trial/error fixups
102545410acb636e526575d62a037f81ade7916b738cJens Axboe			 * easier on the user.
102645410acb636e526575d62a037f81ade7916b738cJens Axboe			 */
10277c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe			ret |= parse_option(p, options, td);
1028ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		}
1029ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
103045410acb636e526575d62a037f81ade7916b738cJens Axboe		if (!ret) {
103145410acb636e526575d62a037f81ade7916b738cJens Axboe			fsetpos(f, &off);
103245410acb636e526575d62a037f81ade7916b738cJens Axboe			ret = add_job(td, name, 0);
1033b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe		} else {
1034b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe			log_err("fio: job %s dropped\n", name);
1035b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe			put_job(td);
103645410acb636e526575d62a037f81ade7916b738cJens Axboe		}
10377c124ac153eebf48bc85f9033ae06fd7152e4216Jens Axboe	} while (!ret);
1038ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1039ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	free(string);
1040ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	free(name);
1041ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	fclose(f);
104245410acb636e526575d62a037f81ade7916b738cJens Axboe	return ret;
1043ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
1044ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1045ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestatic int fill_def_thread(void)
1046ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
1047ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	memset(&def_thread, 0, sizeof(def_thread));
1048ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1049ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (fio_getaffinity(getpid(), &def_thread.cpumask) == -1) {
1050ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		perror("sched_getaffinity");
1051ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 1;
1052ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
1053ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1054ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	/*
1055ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 * fill globals
1056ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 */
1057ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.ddir = DDIR_READ;
10583d60d1ed78b663659967e04cc92e1359bd50fb3aJens Axboe	def_thread.iomix = 0;
1059a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	def_thread.bs[DDIR_READ] = DEF_BS;
1060a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	def_thread.bs[DDIR_WRITE] = DEF_BS;
1061a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	def_thread.min_bs[DDIR_READ] = def_thread.min_bs[DDIR_WRITE] = 0;
1062a00735e66f9ec42549da94eba3170e543b542904Jens Axboe	def_thread.max_bs[DDIR_READ] = def_thread.max_bs[DDIR_WRITE] = 0;
10639ebc27e1352b905fe3396ce2350a7765fe9c57b8Jens Axboe	def_thread.odirect = DEF_ODIRECT;
1064ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.ratecycle = DEF_RATE_CYCLE;
10659ebc27e1352b905fe3396ce2350a7765fe9c57b8Jens Axboe	def_thread.sequential = DEF_SEQUENTIAL;
1066972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe	def_thread.timeout = def_timeout;
1067ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.overwrite = DEF_OVERWRITE;
1068ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.invalidate_cache = DEF_INVALIDATE;
1069ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.sync_io = DEF_SYNCIO;
1070ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.mem_type = MEM_MALLOC;
1071ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.bw_avg_time = DEF_BWAVGTIME;
1072ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.create_serialize = DEF_CREATE_SER;
1073ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.create_fsync = DEF_CREATE_FSYNC;
1074ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.loops = DEF_LOOPS;
1075ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.verify = DEF_VERIFY;
1076ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.stonewall = DEF_STONEWALL;
1077ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.numjobs = DEF_NUMJOBS;
1078ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.use_thread = DEF_USE_THREAD;
1079a6ccc7be771650f903ea77ace2a1af593622c0f4Jens Axboe	def_thread.rwmixcycle = DEF_RWMIX_CYCLE;
1080a6ccc7be771650f903ea77ace2a1af593622c0f4Jens Axboe	def_thread.rwmixread = DEF_RWMIX_READ;
1081b6f4d8804ad499adf10b4cad0657284a8a4a6287Jens Axboe	def_thread.nice = DEF_NICE;
10829ebc27e1352b905fe3396ce2350a7765fe9c57b8Jens Axboe	def_thread.rand_repeatable = DEF_RAND_REPEAT;
108353cdc6864f7471b28cc9b40a5314ab43e5b1cb5eJens Axboe	def_thread.nr_files = DEF_NR_FILES;
1084f6cbb269c54ff40f3922818d42117f5a8026df36Jens Axboe	def_thread.unlink = DEF_UNLINK;
1085ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboe	def_thread.write_bw_log = write_bw_log;
1086ec94ec567cae47f91fa31a18250c2a7a0029d2adJens Axboe	def_thread.write_lat_log = write_lat_log;
1087bb8895e07c6d6417410545f45d34b1b7916cd90aJens Axboe	def_thread.norandommap = DEF_NO_RAND_MAP;
108856bb17f297c50b2832c845b0f6cdde5063748b34Jens Axboe	def_thread.hugepage_size = DEF_HUGEPAGE_SIZE;
10899c1f7434526606fc8a4296190a2dea5de2651266Jens Axboe	def_thread.thinktime_blocks = DEF_THINKTIME_BLOCKS;
1090ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#ifdef FIO_HAVE_DISK_UTIL
1091ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	def_thread.do_disk_util = 1;
1092ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe#endif
1093ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1094ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 0;
1095ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
1096ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
10970ab8db8943acc6b9ea778735563bfad2a79e8dddJens Axboestatic void usage(void)
10984785f99523f5c69635eb4bd826f25cd2e264cda7Jens Axboe{
10994785f99523f5c69635eb4bd826f25cd2e264cda7Jens Axboe	printf("%s\n", fio_version_string);
1100b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	printf("\t--output\tWrite output to file\n");
1101b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	printf("\t--timeout\tRuntime in seconds\n");
1102b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	printf("\t--latency-log\tGenerate per-job latency logs\n");
1103b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	printf("\t--bandwidth-log\tGenerate per-job bandwidth logs\n");
1104b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	printf("\t--minimal\tMinimal (terse) output\n");
1105b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	printf("\t--version\tPrint version info and exit\n");
11064785f99523f5c69635eb4bd826f25cd2e264cda7Jens Axboe}
11074785f99523f5c69635eb4bd826f25cd2e264cda7Jens Axboe
1108972cfd2546081c0397447ca9243ea419b1ff579aJens Axboestatic int parse_cmd_line(int argc, char *argv[])
1109ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
1110b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	struct thread_data *td = NULL;
1111c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe	int c, ini_idx = 0, lidx, ret;
1112ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1113b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	while ((c = getopt_long(argc, argv, "", long_options, &lidx)) != -1) {
1114ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		switch (c) {
1115b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		case 't':
1116b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			def_timeout = atoi(optarg);
1117b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			break;
1118b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		case 'l':
1119b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			write_lat_log = 1;
1120b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			break;
1121b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		case 'w':
1122b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			write_bw_log = 1;
1123b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			break;
1124b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		case 'o':
1125b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			f_out = fopen(optarg, "w+");
1126b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			if (!f_out) {
1127b46928282e0a890f49250e79b81af773a2b7108fJens Axboe				perror("fopen output");
1128b46928282e0a890f49250e79b81af773a2b7108fJens Axboe				exit(1);
1129b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			}
1130b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			f_err = f_out;
1131b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			break;
1132b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		case 'm':
1133b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			terse_output = 1;
1134b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			break;
1135b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		case 'h':
1136b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			usage();
1137b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			exit(0);
1138b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		case 'v':
1139b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			printf("%s\n", fio_version_string);
1140b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			exit(0);
1141b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		case FIO_GETOPT_JOB: {
1142b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			const char *opt = long_options[lidx].name;
1143b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			char *val = optarg;
1144b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1145c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe			if (!strncmp(opt, "name", 4) && td) {
1146c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe				ret = add_job(td, td->name ?: "fio", 0);
1147c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe				if (ret) {
1148c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe					put_job(td);
1149c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe					return 0;
1150c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe				}
1151c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe				td = NULL;
1152c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe			}
1153b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			if (!td) {
115438d0adb0d129e2eef7bf21e85ba4758c3789cb8eJens Axboe				int global = !strncmp(val, "global", 6);
1155c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe
1156c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe				td = get_new_job(global, &def_thread);
1157b46928282e0a890f49250e79b81af773a2b7108fJens Axboe				if (!td)
1158b46928282e0a890f49250e79b81af773a2b7108fJens Axboe					return 0;
1159b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			}
116038d0adb0d129e2eef7bf21e85ba4758c3789cb8eJens Axboe
1161b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe			ret = parse_cmd_option(opt, val, options, td);
1162b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe			if (ret) {
1163b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe				log_err("fio: job dropped\n");
1164b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe				put_job(td);
1165b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe				td = NULL;
1166b1508cf9ead36dc789a4e289f7522a070e57058cJens Axboe			}
1167b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			break;
1168b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		}
1169b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		default:
1170b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			break;
1171ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		}
1172ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
1173c9fad893e8333682d6ab67a269b0dd74f303c5bcJens Axboe
1174b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	if (td) {
1175c2b1e753ca7abaca7f177cb1ca5087ca3971542bJens Axboe		ret = add_job(td, td->name ?: "fio", 0);
1176b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		if (ret)
1177b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			put_job(td);
1178972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe	}
1179774a617767830b5023f6cad4a45609a92ec82d41Jens Axboe
1180b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	while (optind < argc) {
1181b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		ini_idx++;
1182b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		ini_file = realloc(ini_file, ini_idx * sizeof(char *));
1183b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		ini_file[ini_idx - 1] = strdup(argv[optind]);
1184b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		optind++;
1185eb8bbf48e79a8c6afd3c84e3d64263d10ee45daaJens Axboe	}
1186972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe
1187972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe	return ini_idx;
1188ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
1189ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1190ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestatic void free_shm(void)
1191ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
1192ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	struct shmid_ds sbuf;
1193ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1194ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (threads) {
11952c0ecd28459b6a1b236c865defb5ef76ce8bfa02Jens Axboe		shmdt((void *) threads);
1196ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		threads = NULL;
1197ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		shmctl(shm_id, IPC_RMID, &sbuf);
1198ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
1199ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
1200ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1201906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe/*
1202906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * The thread area is shared between the main process and the job
1203906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * threads/processes. So setup a shared memory segment that will hold
1204906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe * all the job info.
1205906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe */
1206ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboestatic int setup_thread_area(void)
1207ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
1208ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	/*
1209ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 * 1024 is too much on some machines, scale max_jobs if
1210ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 * we get a failure that looks like too large a shm segment
1211ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	 */
1212ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	do {
1213906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe		size_t size = max_jobs * sizeof(struct thread_data);
1214ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1215906c8d75eef9247c02d1f1f6771b6fa2338329faJens Axboe		shm_id = shmget(0, size, IPC_CREAT | 0600);
1216ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		if (shm_id != -1)
1217ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			break;
1218ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		if (errno != EINVAL) {
1219ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			perror("shmget");
1220ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe			break;
1221ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		}
1222ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1223ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		max_jobs >>= 1;
1224ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	} while (max_jobs);
1225ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1226ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (shm_id == -1)
1227ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 1;
1228ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1229ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	threads = shmat(shm_id, NULL, 0);
1230ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (threads == (void *) -1) {
1231ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		perror("shmat");
1232ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 1;
1233ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	}
1234ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1235ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	atexit(free_shm);
1236ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 0;
1237ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
1238ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1239b46928282e0a890f49250e79b81af773a2b7108fJens Axboe/*
1240b46928282e0a890f49250e79b81af773a2b7108fJens Axboe * Copy the fio options into the long options map, so we mirror
1241b46928282e0a890f49250e79b81af773a2b7108fJens Axboe * job and cmd line options.
1242b46928282e0a890f49250e79b81af773a2b7108fJens Axboe */
1243b46928282e0a890f49250e79b81af773a2b7108fJens Axboestatic void dupe_job_options(void)
1244b46928282e0a890f49250e79b81af773a2b7108fJens Axboe{
1245b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	struct fio_option *o;
1246b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	unsigned int i;
1247b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1248b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	i = 0;
1249b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	while (long_options[i].name)
1250b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		i++;
1251b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1252b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	o = &options[0];
1253b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	while (o->name) {
1254b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		long_options[i].name = o->name;
1255b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		long_options[i].val = FIO_GETOPT_JOB;
1256b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		if (o->type == FIO_OPT_STR_SET)
1257b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			long_options[i].has_arg = no_argument;
1258b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		else
1259b46928282e0a890f49250e79b81af773a2b7108fJens Axboe			long_options[i].has_arg = required_argument;
1260b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1261b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		i++;
1262b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		o++;
1263b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		assert(i < FIO_JOB_OPTS + FIO_CMD_OPTS);
1264b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	}
1265b46928282e0a890f49250e79b81af773a2b7108fJens Axboe}
1266b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1267ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboeint parse_options(int argc, char *argv[])
1268ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe{
1269972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe	int job_files, i;
1270972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe
1271b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	f_out = stdout;
1272b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	f_err = stderr;
1273b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1274b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	dupe_job_options();
1275b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1276ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (setup_thread_area())
1277ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 1;
1278ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	if (fill_def_thread())
1279ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe		return 1;
1280ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1281972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe	job_files = parse_cmd_line(argc, argv);
1282ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
1283972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe	for (i = 0; i < job_files; i++) {
1284972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe		if (fill_def_thread())
1285972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe			return 1;
12860c7e37a04aa04ba22e812f8de7971fcef46b8191Jens Axboe		if (parse_jobs_ini(ini_file[i], i))
1287972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe			return 1;
128888c6ed8085efd1403fd34072311991cb666a5b9eJens Axboe		free(ini_file[i]);
1289972cfd2546081c0397447ca9243ea419b1ff579aJens Axboe	}
1290ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe
129188c6ed8085efd1403fd34072311991cb666a5b9eJens Axboe	free(ini_file);
1292b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1293b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	if (!thread_number) {
1294b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		log_err("No jobs defined(s)\n");
1295b46928282e0a890f49250e79b81af773a2b7108fJens Axboe		return 1;
1296b46928282e0a890f49250e79b81af773a2b7108fJens Axboe	}
1297b46928282e0a890f49250e79b81af773a2b7108fJens Axboe
1298ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe	return 0;
1299ebac4655dd3624f3296ff83be48e0cdc02852f1Jens Axboe}
1300