projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
iolog: replace tp usage with workqueue
[fio.git]
/
backend.c
diff --git
a/backend.c
b/backend.c
index 01e0b3ac7cc5909b503f6d35d0a1f8e541215f6f..5c35757ce1ad0316214a58b83efcd9278cd2887b 100644
(file)
--- a/
backend.c
+++ b/
backend.c
@@
-54,7
+54,6
@@
#include "lib/getrusage.h"
#include "idletime.h"
#include "err.h"
#include "lib/getrusage.h"
#include "idletime.h"
#include "err.h"
-#include "lib/tp.h"
#include "workqueue.h"
#include "lib/mountcheck.h"
#include "rate-submit.h"
#include "workqueue.h"
#include "lib/mountcheck.h"
#include "rate-submit.h"
@@
-1554,8
+1553,8
@@
static void *thread_main(void *data)
goto err;
}
goto err;
}
- if (
td->flags & TD_F_COMPRESS_LOG
)
-
tp_init(&td->tp_data)
;
+ if (
iolog_compress_init(td)
)
+
goto err
;
fio_verify_init(td);
fio_verify_init(td);
@@
-1661,8
+1660,7
@@
static void *thread_main(void *data)
if (o->io_submit_mode == IO_MODE_OFFLOAD)
workqueue_exit(&td->io_wq);
if (o->io_submit_mode == IO_MODE_OFFLOAD)
workqueue_exit(&td->io_wq);
- if (td->flags & TD_F_COMPRESS_LOG)
- tp_exit(&td->tp_data);
+ iolog_compress_exit(td);
if (o->exec_postrun)
exec_string(o, o->exec_postrun, (const char *)"postrun");
if (o->exec_postrun)
exec_string(o, o->exec_postrun, (const char *)"postrun");