blob: dc22d4e058a177f373131acb370c838d4441b88f [file] [log] [blame]
Jens Axboed6aed792009-06-03 08:41:15 +02001#ifndef FIO_FILE_H
2#define FIO_FILE_H
3
4#include "io_ddir.h"
5
6/*
7 * The type of object we are working on
8 */
9enum fio_filetype {
10 FIO_TYPE_FILE = 1, /* plain file */
11 FIO_TYPE_BD, /* block device */
12 FIO_TYPE_CHAR, /* character device */
13 FIO_TYPE_PIPE, /* pipe */
14};
15
16enum fio_file_flags {
17 FIO_FILE_open = 1 << 0, /* file is open */
18 FIO_FILE_closing = 1 << 1, /* file being closed */
19 FIO_FILE_extend = 1 << 2, /* needs extend */
20 FIO_FILE_done = 1 << 3, /* io completed to this file */
21 FIO_FILE_size_known = 1 << 4, /* size has been set */
22 FIO_FILE_hashed = 1 << 5, /* file is on hash */
Jens Axboeed47cbf2009-07-03 22:52:38 +020023 FIO_FILE_partial_mmap = 1 << 6, /* can't do full mmap */
Jens Axboed6aed792009-06-03 08:41:15 +020024};
25
26enum file_lock_mode {
27 FILE_LOCK_NONE,
28 FILE_LOCK_EXCLUSIVE,
29 FILE_LOCK_READWRITE,
30};
31
32/*
Jens Axboe590aebd2009-06-03 08:54:00 +020033 * roundrobin available files, or choose one at random, or do each one
34 * serially.
35 */
36enum {
37 FIO_FSERVICE_RANDOM = 1,
38 FIO_FSERVICE_RR = 2,
39 FIO_FSERVICE_SEQ = 3,
40};
41
42/*
Jens Axboed6aed792009-06-03 08:41:15 +020043 * Each thread_data structure has a number of files associated with it,
44 * this structure holds state information for a single file.
45 */
46struct fio_file {
47 struct flist_head hash_list;
48 enum fio_filetype filetype;
49
50 /*
51 * A file may not be a file descriptor, let the io engine decide
52 */
53 union {
54 unsigned long file_data;
55 int fd;
56 };
57
58 /*
59 * filename and possible memory mapping
60 */
61 char *file_name;
62 unsigned int major, minor;
63
64 void *mmap_ptr;
65 size_t mmap_sz;
66 off_t mmap_off;
67
68 /*
69 * size of the file, offset into file, and io size from that offset
70 */
71 unsigned long long real_file_size;
72 unsigned long long file_offset;
73 unsigned long long io_size;
74
75 unsigned long long last_pos;
76
77 /*
78 * if io is protected by a semaphore, this is set
79 */
80 struct fio_mutex *lock;
81 void *lock_owner;
82 unsigned int lock_batch;
83 enum fio_ddir lock_ddir;
84
85 /*
86 * block map for random io
87 */
88 unsigned int *file_map;
89 unsigned int num_maps;
90 unsigned int last_free_lookup;
91
92 int references;
93 enum fio_file_flags flags;
94
95 struct disk_util *du;
96};
97
98#define FILE_FLAG_FNS(name) \
99static inline void fio_file_set_##name(struct fio_file *f) \
100{ \
101 (f)->flags |= FIO_FILE_##name; \
102} \
103static inline void fio_file_clear_##name(struct fio_file *f) \
104{ \
105 (f)->flags &= ~FIO_FILE_##name; \
106} \
107static inline int fio_file_##name(struct fio_file *f) \
108{ \
109 return ((f)->flags & FIO_FILE_##name) != 0; \
110}
111
112FILE_FLAG_FNS(open);
113FILE_FLAG_FNS(closing);
114FILE_FLAG_FNS(extend);
115FILE_FLAG_FNS(done);
116FILE_FLAG_FNS(size_known);
117FILE_FLAG_FNS(hashed);
Jens Axboeed47cbf2009-07-03 22:52:38 +0200118FILE_FLAG_FNS(partial_mmap);
Jens Axboed6aed792009-06-03 08:41:15 +0200119#undef FILE_FLAG_FNS
120
Jens Axboe4cd02b32009-06-03 08:46:38 +0200121/*
122 * File setup/shutdown
123 */
124struct thread_data;
125extern void close_files(struct thread_data *);
126extern void close_and_free_files(struct thread_data *);
127extern int __must_check setup_files(struct thread_data *);
128extern int __must_check file_invalidate_cache(struct thread_data *, struct fio_file *);
129extern int __must_check generic_open_file(struct thread_data *, struct fio_file *);
130extern int __must_check generic_close_file(struct thread_data *, struct fio_file *);
131extern int __must_check generic_get_file_size(struct thread_data *, struct fio_file *);
132extern int __must_check pre_read_files(struct thread_data *);
133extern int add_file(struct thread_data *, const char *);
134extern void get_file(struct fio_file *);
135extern int __must_check put_file(struct thread_data *, struct fio_file *);
Jens Axboee8462bd2009-07-06 12:59:04 +0200136extern void put_file_log(struct thread_data *, struct fio_file *);
Jens Axboe4cd02b32009-06-03 08:46:38 +0200137extern void lock_file(struct thread_data *, struct fio_file *, enum fio_ddir);
138extern void unlock_file(struct thread_data *, struct fio_file *);
139extern void unlock_file_all(struct thread_data *, struct fio_file *);
140extern int add_dir_files(struct thread_data *, const char *);
141extern int init_random_map(struct thread_data *);
142extern void dup_files(struct thread_data *, struct thread_data *);
143extern int get_fileno(struct thread_data *, const char *);
144extern void free_release_files(struct thread_data *);
145
Jens Axboec592b9f2009-06-03 09:29:28 +0200146static inline void fio_file_reset(struct fio_file *f)
147{
148 f->last_free_lookup = 0;
149 f->last_pos = f->file_offset;
150 if (f->file_map)
151 memset(f->file_map, 0, f->num_maps * sizeof(int));
152}
153
Jens Axboed6aed792009-06-03 08:41:15 +0200154#endif