summaryrefslogtreecommitdiff
path: root/helper_thread.c
diff options
context:
space:
mode:
Diffstat (limited to 'helper_thread.c')
-rw-r--r--helper_thread.c14
1 files changed, 7 insertions, 7 deletions
diff --git a/helper_thread.c b/helper_thread.c
index 1d89d3a1..c890da4a 100644
--- a/helper_thread.c
+++ b/helper_thread.c
@@ -12,7 +12,7 @@ static struct helper_data {
pthread_t thread;
pthread_mutex_t lock;
pthread_cond_t cond;
- struct fio_mutex *startup_mutex;
+ struct fio_sem *startup_sem;
} *helper_data;
void helper_thread_destroy(void)
@@ -84,7 +84,7 @@ static void *helper_thread_main(void *data)
memcpy(&last_du, &ts, sizeof(ts));
memcpy(&last_ss, &ts, sizeof(ts));
- fio_mutex_up(hd->startup_mutex);
+ fio_sem_up(hd->startup_sem);
msec_to_next_event = DISK_UTIL_MSEC;
while (!ret && !hd->exit) {
@@ -152,7 +152,7 @@ static void *helper_thread_main(void *data)
return NULL;
}
-int helper_thread_create(struct fio_mutex *startup_mutex, struct sk_out *sk_out)
+int helper_thread_create(struct fio_sem *startup_sem, struct sk_out *sk_out)
{
struct helper_data *hd;
int ret;
@@ -168,7 +168,7 @@ int helper_thread_create(struct fio_mutex *startup_mutex, struct sk_out *sk_out)
if (ret)
return 1;
- hd->startup_mutex = startup_mutex;
+ hd->startup_sem = startup_sem;
ret = pthread_create(&hd->thread, NULL, helper_thread_main, hd);
if (ret) {
@@ -178,8 +178,8 @@ int helper_thread_create(struct fio_mutex *startup_mutex, struct sk_out *sk_out)
helper_data = hd;
- dprint(FD_MUTEX, "wait on startup_mutex\n");
- fio_mutex_down(startup_mutex);
- dprint(FD_MUTEX, "done waiting on startup_mutex\n");
+ dprint(FD_MUTEX, "wait on startup_sem\n");
+ fio_sem_down(startup_sem);
+ dprint(FD_MUTEX, "done waiting on startup_sem\n");
return 0;
}