projects
/
fio.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
f44c1d4
)
[PATCH] Also print pending string if some threads have yet to run
author
Jens Axboe
<axboe@suse.de>
Thu, 8 Jun 2006 12:48:47 +0000
(14:48 +0200)
committer
Jens Axboe
<axboe@suse.de>
Thu, 8 Jun 2006 12:48:47 +0000
(14:48 +0200)
fio.c
patch
|
blob
|
blame
|
history
diff --git
a/fio.c
b/fio.c
index cc71a08955a66f4f16c9510426aad5a3106cbf3e..93ca720e63d561af530a1dddc4730891de3e445c 100644
(file)
--- a/
fio.c
+++ b/
fio.c
@@
-1563,14
+1563,14
@@
static int thread_eta(struct thread_data *td, unsigned long elapsed)
static void print_thread_status(void)
{
unsigned long elapsed = time_since_now(&genesis);
static void print_thread_status(void)
{
unsigned long elapsed = time_since_now(&genesis);
- int i, nr_running, t_rate, m_rate, *eta_secs, eta_sec;
+ int i, nr_running,
nr_pending,
t_rate, m_rate, *eta_secs, eta_sec;
char eta_str[32];
double perc = 0.0;
eta_secs = malloc(thread_number * sizeof(int));
memset(eta_secs, 0, thread_number * sizeof(int));
char eta_str[32];
double perc = 0.0;
eta_secs = malloc(thread_number * sizeof(int));
memset(eta_secs, 0, thread_number * sizeof(int));
- nr_running = t_rate = m_rate = 0;
+ nr_
pending = nr_
running = t_rate = m_rate = 0;
for (i = 0; i < thread_number; i++) {
struct thread_data *td = &threads[i];
for (i = 0; i < thread_number; i++) {
struct thread_data *td = &threads[i];
@@
-1579,7
+1579,8
@@
static void print_thread_status(void)
nr_running++;
t_rate += td->rate;
m_rate += td->ratemin;
nr_running++;
t_rate += td->rate;
m_rate += td->ratemin;
- }
+ } else if (td->runstate < TD_RUNNING)
+ nr_pending++;
if (elapsed >= 3)
eta_secs[i] = thread_eta(td, elapsed);
if (elapsed >= 3)
eta_secs[i] = thread_eta(td, elapsed);
@@
-1609,7
+1610,7
@@
static void print_thread_status(void)
eta_to_str(eta_str, eta_sec);
}
eta_to_str(eta_str, eta_sec);
}
- if (!nr_running)
+ if (!nr_running
&& !nr_pending
)
return;
printf("Threads now running (%d)", nr_running);
return;
printf("Threads now running (%d)", nr_running);