blob: 9573e8a6c97fc950c1613af91876f1755a92b000 [file] [log] [blame]
Jens Axboe263e5292006-10-18 15:37:01 +02001/*
2 * Status and ETA code
3 */
4#include <unistd.h>
5#include <fcntl.h>
6#include <string.h>
7
8#include "fio.h"
Jens Axboe263e5292006-10-18 15:37:01 +02009
10static char run_str[MAX_JOBS + 1];
11
12/*
13 * Sets the status of the 'td' in the printed status map.
14 */
15static void check_str_update(struct thread_data *td)
16{
17 char c = run_str[td->thread_number - 1];
18
19 switch (td->runstate) {
Jens Axboe5ec10ea2008-03-06 15:42:00 +010020 case TD_REAPED:
21 c = '_';
22 break;
23 case TD_EXITED:
24 c = 'E';
25 break;
Jens Axboeb29ee5b2008-09-11 10:17:26 +020026 case TD_RAMP:
27 c = '/';
28 break;
Jens Axboe5ec10ea2008-03-06 15:42:00 +010029 case TD_RUNNING:
30 if (td_rw(td)) {
31 if (td_random(td))
32 c = 'm';
33 else
34 c = 'M';
35 } else if (td_read(td)) {
36 if (td_random(td))
37 c = 'r';
38 else
39 c = 'R';
40 } else {
41 if (td_random(td))
42 c = 'w';
43 else
44 c = 'W';
45 }
46 break;
Jens Axboeb0f65862009-05-20 11:52:15 +020047 case TD_PRE_READING:
48 c = 'p';
49 break;
Jens Axboe5ec10ea2008-03-06 15:42:00 +010050 case TD_VERIFYING:
51 c = 'V';
52 break;
53 case TD_FSYNCING:
54 c = 'F';
55 break;
56 case TD_CREATED:
57 c = 'C';
58 break;
59 case TD_INITIALIZED:
60 c = 'I';
61 break;
62 case TD_NOT_CREATED:
63 c = 'P';
64 break;
65 default:
66 log_err("state %d\n", td->runstate);
Jens Axboe263e5292006-10-18 15:37:01 +020067 }
68
69 run_str[td->thread_number - 1] = c;
70}
71
72/*
73 * Convert seconds to a printable string.
74 */
Gurudas Pai9c02f6e2008-06-13 08:40:11 +020075static void eta_to_str(char *str, unsigned long eta_sec)
Jens Axboe263e5292006-10-18 15:37:01 +020076{
77 unsigned int d, h, m, s;
Jens Axboe165faf12007-02-07 11:30:37 +010078 int disp_hour = 0;
Jens Axboe263e5292006-10-18 15:37:01 +020079
Jens Axboe263e5292006-10-18 15:37:01 +020080 s = eta_sec % 60;
81 eta_sec /= 60;
82 m = eta_sec % 60;
83 eta_sec /= 60;
84 h = eta_sec % 24;
85 eta_sec /= 24;
86 d = eta_sec;
87
Jens Axboe165faf12007-02-07 11:30:37 +010088 if (d) {
89 disp_hour = 1;
Jens Axboe1e97cce2006-12-05 11:44:16 +010090 str += sprintf(str, "%02ud:", d);
Jens Axboe263e5292006-10-18 15:37:01 +020091 }
Jens Axboe165faf12007-02-07 11:30:37 +010092
93 if (h || disp_hour)
Jens Axboe1e97cce2006-12-05 11:44:16 +010094 str += sprintf(str, "%02uh:", h);
Jens Axboe263e5292006-10-18 15:37:01 +020095
Jens Axboe1e97cce2006-12-05 11:44:16 +010096 str += sprintf(str, "%02um:", m);
97 str += sprintf(str, "%02us", s);
Jens Axboe263e5292006-10-18 15:37:01 +020098}
99
100/*
101 * Best effort calculation of the estimated pending runtime of a job.
102 */
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200103static int thread_eta(struct thread_data *td)
Jens Axboe263e5292006-10-18 15:37:01 +0200104{
105 unsigned long long bytes_total, bytes_done;
Jens Axboe1e97cce2006-12-05 11:44:16 +0100106 unsigned long eta_sec = 0;
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200107 unsigned long elapsed;
108
109 elapsed = (mtime_since_now(&td->epoch) + 999) / 1000;
Jens Axboe263e5292006-10-18 15:37:01 +0200110
111 bytes_total = td->total_io_size;
112
Jens Axboe74939e32006-10-19 20:37:12 +0200113 /*
114 * if writing, bytes_total will be twice the size. If mixing,
115 * assume a 50/50 split and thus bytes_total will be 50% larger.
116 */
Jens Axboe0dd83772007-09-04 12:38:28 +0200117 if (td->o.do_verify && td->o.verify && td_write(td)) {
Jens Axboe74939e32006-10-19 20:37:12 +0200118 if (td_rw(td))
119 bytes_total = bytes_total * 3 / 2;
120 else
121 bytes_total <<= 1;
122 }
123
Jens Axboe2dc1bbe2007-03-15 15:01:33 +0100124 if (td->o.zone_size && td->o.zone_skip)
125 bytes_total /= (td->o.zone_skip / td->o.zone_size);
Jens Axboe263e5292006-10-18 15:37:01 +0200126
Shaozhi Shawn Ye9c5a3852008-09-10 09:09:37 +0200127 if (td->o.fill_device && td->o.size == -1ULL)
128 return 0;
129
Jens Axboe263e5292006-10-18 15:37:01 +0200130 if (td->runstate == TD_RUNNING || td->runstate == TD_VERIFYING) {
Jens Axboecf4464c2007-04-17 20:14:42 +0200131 double perc, perc_t;
Jens Axboe263e5292006-10-18 15:37:01 +0200132
133 bytes_done = td->io_bytes[DDIR_READ] + td->io_bytes[DDIR_WRITE];
134 perc = (double) bytes_done / (double) bytes_total;
135 if (perc > 1.0)
136 perc = 1.0;
137
Jens Axboecf4464c2007-04-17 20:14:42 +0200138 if (td->o.time_based) {
139 perc_t = (double) elapsed / (double) td->o.timeout;
140 if (perc_t < perc)
141 perc = perc_t;
142 }
143
Jens Axboe1e97cce2006-12-05 11:44:16 +0100144 eta_sec = (unsigned long) (elapsed * (1.0 / perc)) - elapsed;
Jens Axboe263e5292006-10-18 15:37:01 +0200145
Jens Axboed3eeeab2008-04-06 12:19:05 +0200146 if (td->o.timeout &&
147 eta_sec > (td->o.timeout + done_secs - elapsed))
148 eta_sec = td->o.timeout + done_secs - elapsed;
Jens Axboe263e5292006-10-18 15:37:01 +0200149 } else if (td->runstate == TD_NOT_CREATED || td->runstate == TD_CREATED
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200150 || td->runstate == TD_INITIALIZED
Jens Axboeb0f65862009-05-20 11:52:15 +0200151 || td->runstate == TD_RAMP
152 || td->runstate == TD_PRE_READING) {
Jens Axboe263e5292006-10-18 15:37:01 +0200153 int t_eta = 0, r_eta = 0;
154
155 /*
156 * We can only guess - assume it'll run the full timeout
157 * if given, otherwise assume it'll run at the specified rate.
158 */
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200159 if (td->o.timeout) {
Jens Axboed3eeeab2008-04-06 12:19:05 +0200160 t_eta = td->o.timeout + td->o.start_delay;
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200161
162 if (in_ramp_time(td)) {
163 unsigned long ramp_left;
164
165 ramp_left = mtime_since_now(&td->start);
166 ramp_left = (ramp_left + 999) / 1000;
167 if (ramp_left <= t_eta)
168 t_eta -= ramp_left;
169 }
170 }
Jens Axboe581e7142009-06-09 12:47:16 +0200171 if (td->o.rate[0] || td->o.rate[1]) {
172 r_eta = (bytes_total / 1024) / (td->o.rate[0] + td->o.rate[1]);
Jens Axboed3eeeab2008-04-06 12:19:05 +0200173 r_eta += td->o.start_delay;
Jens Axboe263e5292006-10-18 15:37:01 +0200174 }
175
176 if (r_eta && t_eta)
177 eta_sec = min(r_eta, t_eta);
178 else if (r_eta)
179 eta_sec = r_eta;
180 else if (t_eta)
181 eta_sec = t_eta;
182 else
183 eta_sec = 0;
184 } else {
185 /*
186 * thread is already done or waiting for fsync
187 */
188 eta_sec = 0;
189 }
190
191 return eta_sec;
192}
193
Jens Axboe46fda8d2007-02-11 00:49:30 +0100194static void calc_rate(unsigned long mtime, unsigned long long *io_bytes,
195 unsigned long long *prev_io_bytes, unsigned int *rate)
196{
197 rate[0] = (io_bytes[0] - prev_io_bytes[0]) / mtime;
198 rate[1] = (io_bytes[1] - prev_io_bytes[1]) / mtime;
199 prev_io_bytes[0] = io_bytes[0];
200 prev_io_bytes[1] = io_bytes[1];
201}
Jens Axboe5ec10ea2008-03-06 15:42:00 +0100202
Jens Axboeadb02ba2009-06-03 10:47:44 +0200203static void calc_iops(unsigned long mtime, unsigned long long *io_iops,
204 unsigned long long *prev_io_iops, unsigned int *iops)
205{
206 iops[0] = ((io_iops[0] - prev_io_iops[0]) * 1000) / mtime;
207 iops[1] = ((io_iops[1] - prev_io_iops[1]) * 1000) / mtime;
208 prev_io_iops[0] = io_iops[0];
209 prev_io_iops[1] = io_iops[1];
210}
211
Jens Axboe263e5292006-10-18 15:37:01 +0200212/*
213 * Print status of the jobs we know about. This includes rate estimates,
214 * ETA, thread state, etc.
215 */
216void print_thread_status(void)
217{
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200218 unsigned long elapsed = (mtime_since_genesis() + 999) / 1000;
219 int i, nr_ramp, nr_running, nr_pending, t_rate, m_rate;
Jens Axboee6e41602007-03-27 20:20:36 +0200220 int t_iops, m_iops, files_open;
Jens Axboe34572e22006-10-20 09:33:18 +0200221 struct thread_data *td;
Jens Axboe2eaa41c2007-02-11 00:51:30 +0100222 char eta_str[128];
Jens Axboe263e5292006-10-18 15:37:01 +0200223 double perc = 0.0;
Jens Axboeadb02ba2009-06-03 10:47:44 +0200224 unsigned long long io_bytes[2], io_iops[2];
Jens Axboed3eeeab2008-04-06 12:19:05 +0200225 unsigned long rate_time, disp_time, bw_avg_time, *eta_secs, eta_sec;
Jens Axboe46fda8d2007-02-11 00:49:30 +0100226 struct timeval now;
227
228 static unsigned long long rate_io_bytes[2];
229 static unsigned long long disp_io_bytes[2];
Jens Axboeadb02ba2009-06-03 10:47:44 +0200230 static unsigned long long disp_io_iops[2];
Jens Axboe46fda8d2007-02-11 00:49:30 +0100231 static struct timeval rate_prev_time, disp_prev_time;
Jens Axboeadb02ba2009-06-03 10:47:44 +0200232 static unsigned int rate[2], iops[2];
Aaron Carroll43819602007-10-26 11:10:28 +0200233 static int linelen_last;
Jens Axboecac58fd2008-06-06 01:17:03 +0200234 static int eta_good;
Jens Axboe6043c572006-11-03 11:37:47 +0100235
Aaron Carrolle592a062007-09-14 09:49:41 +0200236 if (temp_stall_ts || terse_output || eta_print == FIO_ETA_NEVER)
237 return;
238
239 if (!isatty(STDOUT_FILENO) && (eta_print != FIO_ETA_ALWAYS))
Jens Axboe263e5292006-10-18 15:37:01 +0200240 return;
241
Jens Axboe46fda8d2007-02-11 00:49:30 +0100242 if (!rate_io_bytes[0] && !rate_io_bytes[1])
243 fill_start_time(&rate_prev_time);
244 if (!disp_io_bytes[0] && !disp_io_bytes[1])
245 fill_start_time(&disp_prev_time);
Jens Axboe6043c572006-11-03 11:37:47 +0100246
Jens Axboed3eeeab2008-04-06 12:19:05 +0200247 eta_secs = malloc(thread_number * sizeof(unsigned long));
248 memset(eta_secs, 0, thread_number * sizeof(unsigned long));
Jens Axboe263e5292006-10-18 15:37:01 +0200249
Jens Axboe6043c572006-11-03 11:37:47 +0100250 io_bytes[0] = io_bytes[1] = 0;
Jens Axboeadb02ba2009-06-03 10:47:44 +0200251 io_iops[0] = io_iops[1] = 0;
Jens Axboeac71feb2007-03-16 10:24:07 +0100252 nr_pending = nr_running = t_rate = m_rate = t_iops = m_iops = 0;
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200253 nr_ramp = 0;
Jens Axboebb3884d2007-01-17 17:23:11 +1100254 bw_avg_time = ULONG_MAX;
Jens Axboee6e41602007-03-27 20:20:36 +0200255 files_open = 0;
Jens Axboe34572e22006-10-20 09:33:18 +0200256 for_each_td(td, i) {
Jens Axboe2dc1bbe2007-03-15 15:01:33 +0100257 if (td->o.bw_avg_time < bw_avg_time)
258 bw_avg_time = td->o.bw_avg_time;
Jens Axboe46fda8d2007-02-11 00:49:30 +0100259 if (td->runstate == TD_RUNNING || td->runstate == TD_VERIFYING
Jens Axboeb0f65862009-05-20 11:52:15 +0200260 || td->runstate == TD_FSYNCING
261 || td->runstate == TD_PRE_READING) {
Jens Axboe263e5292006-10-18 15:37:01 +0200262 nr_running++;
Jens Axboe581e7142009-06-09 12:47:16 +0200263 t_rate += td->o.rate[0] + td->o.rate[1];
264 m_rate += td->o.ratemin[0] + td->o.ratemin[1];
265 t_iops += td->o.rate_iops[0] + td->o.rate_iops[1];
266 m_iops += td->o.rate_iops_min[0] + td->o.rate_iops_min[1];
Jens Axboee6e41602007-03-27 20:20:36 +0200267 files_open += td->nr_open_files;
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200268 } else if (td->runstate == TD_RAMP) {
269 nr_running++;
270 nr_ramp++;
Jens Axboe263e5292006-10-18 15:37:01 +0200271 } else if (td->runstate < TD_RUNNING)
272 nr_pending++;
273
274 if (elapsed >= 3)
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200275 eta_secs[i] = thread_eta(td);
Jens Axboe263e5292006-10-18 15:37:01 +0200276 else
277 eta_secs[i] = INT_MAX;
278
279 check_str_update(td);
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200280
281 if (td->runstate > TD_RAMP) {
282 io_bytes[0] += td->io_bytes[0];
283 io_bytes[1] += td->io_bytes[1];
Jens Axboeadb02ba2009-06-03 10:47:44 +0200284 io_iops[0] += td->io_blocks[0];
285 io_iops[1] += td->io_blocks[1];
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200286 }
Jens Axboe263e5292006-10-18 15:37:01 +0200287 }
288
289 if (exitall_on_terminate)
290 eta_sec = INT_MAX;
291 else
292 eta_sec = 0;
293
Jens Axboe34572e22006-10-20 09:33:18 +0200294 for_each_td(td, i) {
Shaozhi Shawn Ye9c5a3852008-09-10 09:09:37 +0200295 if (exitall_on_terminate) {
296 if (eta_secs[i] < eta_sec)
297 eta_sec = eta_secs[i];
298 } else {
299 if (eta_secs[i] > eta_sec)
300 eta_sec = eta_secs[i];
301 }
Jens Axboe263e5292006-10-18 15:37:01 +0200302 }
303
Jens Axboeeecf2722006-10-20 14:00:36 +0200304 free(eta_secs);
305
Jens Axboe263e5292006-10-18 15:37:01 +0200306 if (eta_sec != INT_MAX && elapsed) {
307 perc = (double) elapsed / (double) (elapsed + eta_sec);
308 eta_to_str(eta_str, eta_sec);
309 }
310
Jens Axboe46fda8d2007-02-11 00:49:30 +0100311 fio_gettime(&now, NULL);
312 rate_time = mtime_since(&rate_prev_time, &now);
313
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200314 if (write_bw_log && rate_time > bw_avg_time && !in_ramp_time(td)) {
Jens Axboe46fda8d2007-02-11 00:49:30 +0100315 calc_rate(rate_time, io_bytes, rate_io_bytes, rate);
316 memcpy(&rate_prev_time, &now, sizeof(now));
Jens Axboe306ddc92009-05-18 13:08:12 +0200317 add_agg_sample(rate[DDIR_READ], DDIR_READ, 0);
318 add_agg_sample(rate[DDIR_WRITE], DDIR_WRITE, 0);
Jens Axboe6043c572006-11-03 11:37:47 +0100319 }
320
Jens Axboe46fda8d2007-02-11 00:49:30 +0100321 disp_time = mtime_since(&disp_prev_time, &now);
322 if (disp_time < 1000)
323 return;
324
325 calc_rate(disp_time, io_bytes, disp_io_bytes, rate);
Jens Axboeadb02ba2009-06-03 10:47:44 +0200326 calc_iops(disp_time, io_iops, disp_io_iops, iops);
327
Jens Axboe46fda8d2007-02-11 00:49:30 +0100328 memcpy(&disp_prev_time, &now, sizeof(now));
329
Jens Axboe263e5292006-10-18 15:37:01 +0200330 if (!nr_running && !nr_pending)
331 return;
332
Jens Axboee6e41602007-03-27 20:20:36 +0200333 printf("Jobs: %d (f=%d)", nr_running, files_open);
Jens Axboe581e7142009-06-09 12:47:16 +0200334 if (m_rate || t_rate) {
335 char *tr, *mr;
336
337 mr = num2str(m_rate, 4, 0, 1);
338 tr = num2str(t_rate, 4, 0, 1);
339 printf(", CR=%s/%s KiB/s", tr, mr);
340 free(tr);
341 free(mr);
342 } else if (m_iops || t_iops)
Jens Axboeac71feb2007-03-16 10:24:07 +0100343 printf(", CR=%d/%d IOPS", t_iops, m_iops);
Jens Axboe263e5292006-10-18 15:37:01 +0200344 if (eta_sec != INT_MAX && nr_running) {
Jens Axboe0721d112008-06-05 09:03:05 +0200345 char perc_str[32];
Jens Axboeadb02ba2009-06-03 10:47:44 +0200346 char *iops_str[2];
Jens Axboed1bd7212009-06-03 10:53:45 +0200347 char *rate_str[2];
Jens Axboeadb02ba2009-06-03 10:47:44 +0200348 int l;
Jens Axboe5ec10ea2008-03-06 15:42:00 +0100349
Jens Axboeb29ee5b2008-09-11 10:17:26 +0200350 if ((!eta_sec && !eta_good) || nr_ramp == nr_running)
Jens Axboecac58fd2008-06-06 01:17:03 +0200351 strcpy(perc_str, "-.-% done");
352 else {
353 eta_good = 1;
354 perc *= 100.0;
Jens Axboe0721d112008-06-05 09:03:05 +0200355 sprintf(perc_str, "%3.1f%% done", perc);
Jens Axboecac58fd2008-06-06 01:17:03 +0200356 }
Jens Axboe0721d112008-06-05 09:03:05 +0200357
Jens Axboed1bd7212009-06-03 10:53:45 +0200358 rate_str[0] = num2str(rate[0], 5, 10, 1);
359 rate_str[1] = num2str(rate[1], 5, 10, 1);
360
Jens Axboeadb02ba2009-06-03 10:47:44 +0200361 iops_str[0] = num2str(iops[0], 4, 1, 0);
362 iops_str[1] = num2str(iops[1], 4, 1, 0);
363
Jens Axboed1bd7212009-06-03 10:53:45 +0200364 l = printf(": [%s] [%s] [%s/%s /s] [%s/%s iops] [eta %s]",
365 run_str, perc_str, rate_str[0], rate_str[1],
Jens Axboeadb02ba2009-06-03 10:47:44 +0200366 iops_str[0], iops_str[1], eta_str);
367 if (l >= 0 && l < linelen_last)
368 printf("%*s", linelen_last - l, "");
369 linelen_last = l;
Jens Axboed1bd7212009-06-03 10:53:45 +0200370
371 free(rate_str[0]);
372 free(rate_str[1]);
Jens Axboeadb02ba2009-06-03 10:47:44 +0200373 free(iops_str[0]);
374 free(iops_str[1]);
Jens Axboe263e5292006-10-18 15:37:01 +0200375 }
376 printf("\r");
377 fflush(stdout);
Jens Axboe263e5292006-10-18 15:37:01 +0200378}
379
380void print_status_init(int thread_number)
381{
382 run_str[thread_number] = 'P';
383}