[fio.git] / libfio.c

/*
 * fio - the flexible io tester
 *
 * Copyright (C) 2005 Jens Axboe <axboe@suse.de>
 * Copyright (C) 2006-2012 Jens Axboe <axboe@kernel.dk>
 *
 * The license below covers all files distributed with fio unless otherwise
 * noted in the file itself.
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License version 2 as
 *  published by the Free Software Foundation.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
 *
 */

#include <string.h>
#include <signal.h>
#include <stdint.h>
#include <locale.h>
#include <fcntl.h>

#include "fio.h"
#include "smalloc.h"
#include "os/os.h"
#include "filelock.h"
#include "helper_thread.h"
#include "filehash.h"

FLIST_HEAD(disk_list);

unsigned long arch_flags = 0;

uintptr_t page_mask = 0;
uintptr_t page_size = 0;

/* see os/os.h */
static const char *fio_os_strings[os_nr] = {
	"Invalid",
	"Linux",
	"AIX",
	"FreeBSD",
	"HP-UX",
	"OSX",
	"NetBSD",
	"OpenBSD",
	"Solaris",
	"Windows",
	"Android",
	"DragonFly",
};

/* see arch/arch.h */
static const char *fio_arch_strings[arch_nr] = {
	"Invalid",
	"x86-64",
	"x86",
	"ppc",
	"ia64",
	"s390",
	"alpha",
	"sparc",
	"sparc64",
	"arm",
	"sh",
	"hppa",
	"mips",
	"aarch64",
	"loongarch64",
	"riscv64",
	"generic"
};

static void reset_io_counters(struct thread_data *td, int all)
{
	int ddir;

	if (all) {
		for (ddir = 0; ddir < DDIR_RWDIR_CNT; ddir++) {
			td->stat_io_bytes[ddir] = 0;
			td->this_io_bytes[ddir] = 0;
			td->stat_io_blocks[ddir] = 0;
			td->this_io_blocks[ddir] = 0;
			td->last_rate_check_bytes[ddir] = 0;
			td->last_rate_check_blocks[ddir] = 0;
			td->bytes_done[ddir] = 0;
			td->rate_io_issue_bytes[ddir] = 0;
			td->rate_next_io_time[ddir] = 0;
			td->last_usec[ddir] = 0;
		}
		td->bytes_verified = 0;
	}

	td->zone_bytes = 0;

	td->last_was_sync = false;
	td->rwmix_issues = 0;

	/*
	 * reset file done count if we are to start over
	 */
	if (td->o.time_based || td->loops > 1 || td->o.do_verify)
		td->nr_done_files = 0;
}

void clear_io_state(struct thread_data *td, int all)
{
	struct fio_file *f;
	unsigned int i;

	reset_io_counters(td, all);

	close_files(td);
	for_each_file(td, f, i) {
		fio_file_clear_done(f);
		f->file_offset = get_start_offset(td, f);
	}

	/*
	 * Re-Seed random number generator if rand_repeatable is true
	 */
	if (td->o.rand_repeatable)
		td_fill_rand_seeds(td);
}

void reset_all_stats(struct thread_data *td)
{
	unsigned long long b;
	int i;

	reset_io_counters(td, 1);

	b = ddir_rw_sum(td->thinktime_blocks_counter);
	td->last_thinktime_blocks -= b;

	for (i = 0; i < DDIR_RWDIR_CNT; i++) {
		td->io_bytes[i] = 0;
		td->io_blocks[i] = 0;
		td->io_issues[i] = 0;
		td->ts.total_io_u[i] = 0;
		td->ts.runtime[i] = 0;
	}

	set_epoch_time(td, td->o.log_alternate_epoch_clock_id, td->o.job_start_clock_id);
	memcpy(&td->start, &td->epoch, sizeof(td->epoch));
	memcpy(&td->iops_sample_time, &td->epoch, sizeof(td->epoch));
	memcpy(&td->bw_sample_time, &td->epoch, sizeof(td->epoch));
	memcpy(&td->ss.prev_time, &td->epoch, sizeof(td->epoch));

	td->last_thinktime = td->epoch;

	lat_target_reset(td);
	clear_rusage_stat(td);
	helper_reset();
}

void reset_fio_state(void)
{
	int i;

	groupid = 0;
	thread_number = 0;
	cur_segment = 0;
	for (i = 0; i < nr_segments; i++)
		segments[i].nr_threads = 0;
	stat_number = 0;
	done_secs = 0;
}

const char *fio_get_os_string(int nr)
{
	if (nr < os_nr)
		return fio_os_strings[nr];

	return NULL;
}

const char *fio_get_arch_string(int nr)
{
	if (nr < arch_nr)
		return fio_arch_strings[nr];

	return NULL;
}

static const char *td_runstates[] = {
	"NOT_CREATED",
	"CREATED",
	"INITIALIZED",
	"RAMP",
	"SETTING_UP",
	"RUNNING",
	"PRE_READING",
	"VERIFYING",
	"FSYNCING",
	"FINISHING",
	"EXITED",
	"REAPED",
};

const char *runstate_to_name(int runstate)
{
	compiletime_assert(TD_LAST == 12, "td runstate list");
	if (runstate >= 0 && runstate < TD_LAST)
		return td_runstates[runstate];

	return "invalid";
}

void td_set_runstate(struct thread_data *td, int runstate)
{
	if (td->runstate == runstate)
		return;

	dprint(FD_PROCESS, "pid=%d: runstate %s -> %s\n", (int) td->pid,
						runstate_to_name(td->runstate),
						runstate_to_name(runstate));
	td->runstate = runstate;
}

int td_bump_runstate(struct thread_data *td, int new_state)
{
	int old_state = td->runstate;

	td_set_runstate(td, new_state);
	return old_state;
}

void td_restore_runstate(struct thread_data *td, int old_state)
{
	td_set_runstate(td, old_state);
}

void fio_mark_td_terminate(struct thread_data *td)
{
	fio_gettime(&td->terminate_time, NULL);
	write_barrier();
	td->terminate = true;
}

void fio_terminate_threads(unsigned int group_id, unsigned int terminate)
{
	pid_t pid = getpid();

	dprint(FD_PROCESS, "terminate group_id=%d\n", group_id);

	for_each_td(td) {
		if ((terminate == TERMINATE_GROUP && group_id == TERMINATE_ALL) ||
		    (terminate == TERMINATE_GROUP && group_id == td->groupid) ||
		    (terminate == TERMINATE_STONEWALL && td->runstate >= TD_RUNNING) ||
		    (terminate == TERMINATE_ALL)) {
			dprint(FD_PROCESS, "setting terminate on %s/%d\n",
						td->o.name, (int) td->pid);

			if (td->terminate)
				continue;

			fio_mark_td_terminate(td);
			td->o.start_delay = 0;

			/*
			 * if the thread is running, just let it exit
			 */
			if (!td->pid || pid == td->pid)
				continue;
			else if (td->runstate < TD_RAMP)
				kill(td->pid, SIGTERM);
			else {
				struct ioengine_ops *ops = td->io_ops;

				if (ops && ops->terminate)
					ops->terminate(td);
			}
		}
	} end_for_each();
}

int fio_running_or_pending_io_threads(void)
{
	int nr_io_threads = 0;

	for_each_td(td) {
		if (td->io_ops_init && td_ioengine_flagged(td, FIO_NOIO))
			continue;
		nr_io_threads++;
		if (td->runstate < TD_EXITED)
			return 1;
	} end_for_each();

	if (!nr_io_threads)
		return -1; /* we only had cpuio threads to begin with */
	return 0;
}

int fio_set_fd_nonblocking(int fd, const char *who)
{
	int flags;

	flags = fcntl(fd, F_GETFL);
	if (flags < 0)
		log_err("fio: %s failed to get file flags: %s\n", who, strerror(errno));
	else {
		int new_flags = flags | O_NONBLOCK;

		new_flags = fcntl(fd, F_SETFL, new_flags);
		if (new_flags < 0)
			log_err("fio: %s failed to get file flags: %s\n", who, strerror(errno));
	}

	return flags;
}

enum {
	ENDIAN_INVALID_BE = 1,
	ENDIAN_INVALID_LE,
	ENDIAN_INVALID_CONFIG,
	ENDIAN_BROKEN,
};

static int endian_check(void)
{
	union {
		uint8_t c[8];
		uint64_t v;
	} u;
	int le = 0, be = 0;

	u.v = 0x12;
	if (u.c[7] == 0x12)
		be = 1;
	else if (u.c[0] == 0x12)
		le = 1;

#if defined(CONFIG_LITTLE_ENDIAN)
	if (be)
		return ENDIAN_INVALID_BE;
#elif defined(CONFIG_BIG_ENDIAN)
	if (le)
		return ENDIAN_INVALID_LE;
#else
	return ENDIAN_INVALID_CONFIG;
#endif

	if (!le && !be)
		return ENDIAN_BROKEN;

	return 0;
}

int initialize_fio(char *envp[])
{
	long ps;
	int err;

	/*
	 * We need these to be properly 64-bit aligned, otherwise we
	 * can run into problems on archs that fault on unaligned fp
	 * access (ARM).
	 */
	compiletime_assert((offsetof(struct thread_data, ts) % sizeof(void *)) == 0, "ts");
	compiletime_assert((offsetof(struct thread_stat, percentile_list) % 8) == 0, "stat percentile_list");
	compiletime_assert((offsetof(struct thread_stat, total_run_time) % 8) == 0, "total_run_time");
	compiletime_assert((offsetof(struct thread_stat, total_err_count) % 8) == 0, "total_err_count");
	compiletime_assert((offsetof(struct thread_stat, latency_percentile) % 8) == 0, "stat latency_percentile");
	compiletime_assert((offsetof(struct thread_data, ts.clat_stat) % 8) == 0, "ts.clat_stat");
	compiletime_assert((offsetof(struct thread_options_pack, zipf_theta) % 8) == 0, "zipf_theta");
	compiletime_assert((offsetof(struct thread_options_pack, pareto_h) % 8) == 0, "pareto_h");
	compiletime_assert((offsetof(struct thread_options_pack, percentile_list) % 8) == 0, "percentile_list");
	compiletime_assert((offsetof(struct thread_options_pack, latency_percentile) % 8) == 0, "latency_percentile");
	compiletime_assert((offsetof(struct jobs_eta, m_rate) % 8) == 0, "m_rate");

	compiletime_assert(__TD_F_LAST <= TD_ENG_FLAG_SHIFT, "TD_ENG_FLAG_SHIFT");
	compiletime_assert((__TD_F_LAST + __FIO_IOENGINE_F_LAST) <= 8*sizeof(((struct thread_data *)0)->flags), "td->flags");
	compiletime_assert(BSSPLIT_MAX <= ZONESPLIT_MAX, "bsssplit/zone max");

	err = endian_check();
	if (err) {
		log_err("fio: endianness settings appear wrong.\n");
		switch (err) {
		case ENDIAN_INVALID_BE:
			log_err("fio: got big-endian when configured for little\n");
			break;
		case ENDIAN_INVALID_LE:
			log_err("fio: got little-endian when configured for big\n");
			break;
		case ENDIAN_INVALID_CONFIG:
			log_err("fio: not configured to any endianness\n");
			break;
		case ENDIAN_BROKEN:
			log_err("fio: failed to detect endianness\n");
			break;
		default:
			assert(0);
			break;
		}
		log_err("fio: please report this to fio@vger.kernel.org\n");
		return 1;
	}

#if !defined(CONFIG_GETTIMEOFDAY) && !defined(CONFIG_CLOCK_GETTIME)
#error "No available clock source!"
#endif

	arch_init(envp);

	sinit();

	if (fio_filelock_init()) {
		log_err("fio: failed initializing filelock subsys\n");
		return 1;
	}

	file_hash_init();

	/*
	 * We need locale for number printing, if it isn't set then just
	 * go with the US format.
	 */
	if (!getenv("LC_NUMERIC"))
		setlocale(LC_NUMERIC, "en_US");

	ps = sysconf(_SC_PAGESIZE);
	if (ps < 0) {
		log_err("Failed to get page size\n");
		return 1;
	}

	page_size = ps;
	page_mask = ps - 1;

	fio_keywords_init();
	return 0;
}

void deinitialize_fio(void)
{
	fio_keywords_exit();
}
Commit	Line	Data
	1	/*
	2	* fio - the flexible io tester
	3	*
	4	* Copyright (C) 2005 Jens Axboe <axboe@suse.de>
	5	* Copyright (C) 2006-2012 Jens Axboe <axboe@kernel.dk>
	6	*
	7	* The license below covers all files distributed with fio unless otherwise
	8	* noted in the file itself.
	9	*
	10	* This program is free software; you can redistribute it and/or modify
	11	* it under the terms of the GNU General Public License version 2 as
	12	* published by the Free Software Foundation.
	13	*
	14	* This program is distributed in the hope that it will be useful,
	15	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	16	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	17	* GNU General Public License for more details.
	18	*
	19	* You should have received a copy of the GNU General Public License
	20	* along with this program; if not, write to the Free Software
	21	* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
	22	*
	23	*/
	24
	25	#include <string.h>
	26	#include <signal.h>
	27	#include <stdint.h>
	28	#include <locale.h>
	29	#include <fcntl.h>
	30
	31	#include "fio.h"
	32	#include "smalloc.h"
	33	#include "os/os.h"
	34	#include "filelock.h"
	35	#include "helper_thread.h"
	36	#include "filehash.h"
	37
	38	FLIST_HEAD(disk_list);
	39
	40	unsigned long arch_flags = 0;
	41
	42	uintptr_t page_mask = 0;
	43	uintptr_t page_size = 0;
	44
	45	/* see os/os.h */
	46	static const char *fio_os_strings[os_nr] = {
	47	"Invalid",
	48	"Linux",
	49	"AIX",
	50	"FreeBSD",
	51	"HP-UX",
	52	"OSX",
	53	"NetBSD",
	54	"OpenBSD",
	55	"Solaris",
	56	"Windows",
	57	"Android",
	58	"DragonFly",
	59	};
	60
	61	/* see arch/arch.h */
	62	static const char *fio_arch_strings[arch_nr] = {
	63	"Invalid",
	64	"x86-64",
	65	"x86",
	66	"ppc",
	67	"ia64",
	68	"s390",
	69	"alpha",
	70	"sparc",
	71	"sparc64",
	72	"arm",
	73	"sh",
	74	"hppa",
	75	"mips",
	76	"aarch64",
	77	"loongarch64",
	78	"riscv64",
	79	"generic"
	80	};
	81
	82	static void reset_io_counters(struct thread_data *td, int all)
	83	{
	84	int ddir;
	85
	86	if (all) {
	87	for (ddir = 0; ddir < DDIR_RWDIR_CNT; ddir++) {
	88	td->stat_io_bytes[ddir] = 0;
	89	td->this_io_bytes[ddir] = 0;
	90	td->stat_io_blocks[ddir] = 0;
	91	td->this_io_blocks[ddir] = 0;
	92	td->last_rate_check_bytes[ddir] = 0;
	93	td->last_rate_check_blocks[ddir] = 0;
	94	td->bytes_done[ddir] = 0;
	95	td->rate_io_issue_bytes[ddir] = 0;
	96	td->rate_next_io_time[ddir] = 0;
	97	td->last_usec[ddir] = 0;
	98	}
	99	td->bytes_verified = 0;
	100	}
	101
	102	td->zone_bytes = 0;
	103
	104	td->last_was_sync = false;
	105	td->rwmix_issues = 0;
	106
	107	/*
	108	* reset file done count if we are to start over
	109	*/
	110	if (td->o.time_based \|\| td->loops > 1 \|\| td->o.do_verify)
	111	td->nr_done_files = 0;
	112	}
	113
	114	void clear_io_state(struct thread_data *td, int all)
	115	{
	116	struct fio_file *f;
	117	unsigned int i;
	118
	119	reset_io_counters(td, all);
	120
	121	close_files(td);
	122	for_each_file(td, f, i) {
	123	fio_file_clear_done(f);
	124	f->file_offset = get_start_offset(td, f);
	125	}
	126
	127	/*
	128	* Re-Seed random number generator if rand_repeatable is true
	129	*/
	130	if (td->o.rand_repeatable)
	131	td_fill_rand_seeds(td);
	132	}
	133
	134	void reset_all_stats(struct thread_data *td)
	135	{
	136	unsigned long long b;
	137	int i;
	138
	139	reset_io_counters(td, 1);
	140
	141	b = ddir_rw_sum(td->thinktime_blocks_counter);
	142	td->last_thinktime_blocks -= b;
	143
	144	for (i = 0; i < DDIR_RWDIR_CNT; i++) {
	145	td->io_bytes[i] = 0;
	146	td->io_blocks[i] = 0;
	147	td->io_issues[i] = 0;
	148	td->ts.total_io_u[i] = 0;
	149	td->ts.runtime[i] = 0;
	150	}
	151
	152	set_epoch_time(td, td->o.log_alternate_epoch_clock_id, td->o.job_start_clock_id);
	153	memcpy(&td->start, &td->epoch, sizeof(td->epoch));
	154	memcpy(&td->iops_sample_time, &td->epoch, sizeof(td->epoch));
	155	memcpy(&td->bw_sample_time, &td->epoch, sizeof(td->epoch));
	156	memcpy(&td->ss.prev_time, &td->epoch, sizeof(td->epoch));
	157
	158	td->last_thinktime = td->epoch;
	159
	160	lat_target_reset(td);
	161	clear_rusage_stat(td);
	162	helper_reset();
	163	}
	164
	165	void reset_fio_state(void)
	166	{
	167	int i;
	168
	169	groupid = 0;
	170	thread_number = 0;
	171	cur_segment = 0;
	172	for (i = 0; i < nr_segments; i++)
	173	segments[i].nr_threads = 0;
	174	stat_number = 0;
	175	done_secs = 0;
	176	}
	177
	178	const char *fio_get_os_string(int nr)
	179	{
	180	if (nr < os_nr)
	181	return fio_os_strings[nr];
	182
	183	return NULL;
	184	}
	185
	186	const char *fio_get_arch_string(int nr)
	187	{
	188	if (nr < arch_nr)
	189	return fio_arch_strings[nr];
	190
	191	return NULL;
	192	}
	193
	194	static const char *td_runstates[] = {
	195	"NOT_CREATED",
	196	"CREATED",
	197	"INITIALIZED",
	198	"RAMP",
	199	"SETTING_UP",
	200	"RUNNING",
	201	"PRE_READING",
	202	"VERIFYING",
	203	"FSYNCING",
	204	"FINISHING",
	205	"EXITED",
	206	"REAPED",
	207	};
	208
	209	const char *runstate_to_name(int runstate)
	210	{
	211	compiletime_assert(TD_LAST == 12, "td runstate list");
	212	if (runstate >= 0 && runstate < TD_LAST)
	213	return td_runstates[runstate];
	214
	215	return "invalid";
	216	}
	217
	218	void td_set_runstate(struct thread_data *td, int runstate)
	219	{
	220	if (td->runstate == runstate)
	221	return;
	222
	223	dprint(FD_PROCESS, "pid=%d: runstate %s -> %s\n", (int) td->pid,
	224	runstate_to_name(td->runstate),
	225	runstate_to_name(runstate));
	226	td->runstate = runstate;
	227	}
	228
	229	int td_bump_runstate(struct thread_data *td, int new_state)
	230	{
	231	int old_state = td->runstate;
	232
	233	td_set_runstate(td, new_state);
	234	return old_state;
	235	}
	236
	237	void td_restore_runstate(struct thread_data *td, int old_state)
	238	{
	239	td_set_runstate(td, old_state);
	240	}
	241
	242	void fio_mark_td_terminate(struct thread_data *td)
	243	{
	244	fio_gettime(&td->terminate_time, NULL);
	245	write_barrier();
	246	td->terminate = true;
	247	}
	248
	249	void fio_terminate_threads(unsigned int group_id, unsigned int terminate)
	250	{
	251	pid_t pid = getpid();
	252
	253	dprint(FD_PROCESS, "terminate group_id=%d\n", group_id);
	254
	255	for_each_td(td) {
	256	if ((terminate == TERMINATE_GROUP && group_id == TERMINATE_ALL) \|\|
	257	(terminate == TERMINATE_GROUP && group_id == td->groupid) \|\|
	258	(terminate == TERMINATE_STONEWALL && td->runstate >= TD_RUNNING) \|\|
	259	(terminate == TERMINATE_ALL)) {
	260	dprint(FD_PROCESS, "setting terminate on %s/%d\n",
	261	td->o.name, (int) td->pid);
	262
	263	if (td->terminate)
	264	continue;
	265
	266	fio_mark_td_terminate(td);
	267	td->o.start_delay = 0;
	268
	269	/*
	270	* if the thread is running, just let it exit
	271	*/
	272	if (!td->pid \|\| pid == td->pid)
	273	continue;
	274	else if (td->runstate < TD_RAMP)
	275	kill(td->pid, SIGTERM);
	276	else {
	277	struct ioengine_ops *ops = td->io_ops;
	278
	279	if (ops && ops->terminate)
	280	ops->terminate(td);
	281	}
	282	}
	283	} end_for_each();
	284	}
	285
	286	int fio_running_or_pending_io_threads(void)
	287	{
	288	int nr_io_threads = 0;
	289
	290	for_each_td(td) {
	291	if (td->io_ops_init && td_ioengine_flagged(td, FIO_NOIO))
	292	continue;
	293	nr_io_threads++;
	294	if (td->runstate < TD_EXITED)
	295	return 1;
	296	} end_for_each();
	297
	298	if (!nr_io_threads)
	299	return -1; /* we only had cpuio threads to begin with */
	300	return 0;
	301	}
	302
	303	int fio_set_fd_nonblocking(int fd, const char *who)
	304	{
	305	int flags;
	306
	307	flags = fcntl(fd, F_GETFL);
	308	if (flags < 0)
	309	log_err("fio: %s failed to get file flags: %s\n", who, strerror(errno));
	310	else {
	311	int new_flags = flags \| O_NONBLOCK;
	312
	313	new_flags = fcntl(fd, F_SETFL, new_flags);
	314	if (new_flags < 0)
	315	log_err("fio: %s failed to get file flags: %s\n", who, strerror(errno));
	316	}
	317
	318	return flags;
	319	}
	320
	321	enum {
	322	ENDIAN_INVALID_BE = 1,
	323	ENDIAN_INVALID_LE,
	324	ENDIAN_INVALID_CONFIG,
	325	ENDIAN_BROKEN,
	326	};
	327
	328	static int endian_check(void)
	329	{
	330	union {
	331	uint8_t c[8];
	332	uint64_t v;
	333	} u;
	334	int le = 0, be = 0;
	335
	336	u.v = 0x12;
	337	if (u.c[7] == 0x12)
	338	be = 1;
	339	else if (u.c[0] == 0x12)
	340	le = 1;
	341
	342	#if defined(CONFIG_LITTLE_ENDIAN)
	343	if (be)
	344	return ENDIAN_INVALID_BE;
	345	#elif defined(CONFIG_BIG_ENDIAN)
	346	if (le)
	347	return ENDIAN_INVALID_LE;
	348	#else
	349	return ENDIAN_INVALID_CONFIG;
	350	#endif
	351
	352	if (!le && !be)
	353	return ENDIAN_BROKEN;
	354
	355	return 0;
	356	}
	357
	358	int initialize_fio(char *envp[])
	359	{
	360	long ps;
	361	int err;
	362
	363	/*
	364	* We need these to be properly 64-bit aligned, otherwise we
	365	* can run into problems on archs that fault on unaligned fp
	366	* access (ARM).
	367	*/
	368	compiletime_assert((offsetof(struct thread_data, ts) % sizeof(void *)) == 0, "ts");
	369	compiletime_assert((offsetof(struct thread_stat, percentile_list) % 8) == 0, "stat percentile_list");
	370	compiletime_assert((offsetof(struct thread_stat, total_run_time) % 8) == 0, "total_run_time");
	371	compiletime_assert((offsetof(struct thread_stat, total_err_count) % 8) == 0, "total_err_count");
	372	compiletime_assert((offsetof(struct thread_stat, latency_percentile) % 8) == 0, "stat latency_percentile");
	373	compiletime_assert((offsetof(struct thread_data, ts.clat_stat) % 8) == 0, "ts.clat_stat");
	374	compiletime_assert((offsetof(struct thread_options_pack, zipf_theta) % 8) == 0, "zipf_theta");
	375	compiletime_assert((offsetof(struct thread_options_pack, pareto_h) % 8) == 0, "pareto_h");
	376	compiletime_assert((offsetof(struct thread_options_pack, percentile_list) % 8) == 0, "percentile_list");
	377	compiletime_assert((offsetof(struct thread_options_pack, latency_percentile) % 8) == 0, "latency_percentile");
	378	compiletime_assert((offsetof(struct jobs_eta, m_rate) % 8) == 0, "m_rate");
	379
	380	compiletime_assert(__TD_F_LAST <= TD_ENG_FLAG_SHIFT, "TD_ENG_FLAG_SHIFT");
	381	compiletime_assert((__TD_F_LAST + __FIO_IOENGINE_F_LAST) <= 8sizeof(((struct thread_data )0)->flags), "td->flags");
	382	compiletime_assert(BSSPLIT_MAX <= ZONESPLIT_MAX, "bsssplit/zone max");
	383
	384	err = endian_check();
	385	if (err) {
	386	log_err("fio: endianness settings appear wrong.\n");
	387	switch (err) {
	388	case ENDIAN_INVALID_BE:
	389	log_err("fio: got big-endian when configured for little\n");
	390	break;
	391	case ENDIAN_INVALID_LE:
	392	log_err("fio: got little-endian when configured for big\n");
	393	break;
	394	case ENDIAN_INVALID_CONFIG:
	395	log_err("fio: not configured to any endianness\n");
	396	break;
	397	case ENDIAN_BROKEN:
	398	log_err("fio: failed to detect endianness\n");
	399	break;
	400	default:
	401	assert(0);
	402	break;
	403	}
	404	log_err("fio: please report this to fio@vger.kernel.org\n");
	405	return 1;
	406	}
	407
	408	#if !defined(CONFIG_GETTIMEOFDAY) && !defined(CONFIG_CLOCK_GETTIME)
	409	#error "No available clock source!"
	410	#endif
	411
	412	arch_init(envp);
	413
	414	sinit();
	415
	416	if (fio_filelock_init()) {
	417	log_err("fio: failed initializing filelock subsys\n");
	418	return 1;
	419	}
	420
	421	file_hash_init();
	422
	423	/*
	424	* We need locale for number printing, if it isn't set then just
	425	* go with the US format.
	426	*/
	427	if (!getenv("LC_NUMERIC"))
	428	setlocale(LC_NUMERIC, "en_US");
	429
	430	ps = sysconf(_SC_PAGESIZE);
	431	if (ps < 0) {
	432	log_err("Failed to get page size\n");
	433	return 1;
	434	}
	435
	436	page_size = ps;
	437	page_mask = ps - 1;
	438
	439	fio_keywords_init();
	440	return 0;
	441	}
	442
	443	void deinitialize_fio(void)
	444	{
	445	fio_keywords_exit();
	446	}