mutex: make 0/1 FIO_MUTEX_LOCKED and FIO_MUTEX_UNLOCKED
authorJens Axboe <axboe@kernel.dk>
Thu, 2 Aug 2012 09:21:36 +0000 (11:21 +0200)
committerJens Axboe <axboe@kernel.dk>
Thu, 2 Aug 2012 09:21:36 +0000 (11:21 +0200)
Makes the API look cleaner.

Signed-off-by: Jens Axboe <axboe@kernel.dk>
backend.c
cgroup.c
diskutil.c
filehash.c
filesetup.c
flow.c
gettime.c
init.c
mutex.h
smalloc.c

index 9cc8dbc..e41e8f1 100644 (file)
--- a/backend.c
+++ b/backend.c
@@ -1620,7 +1620,7 @@ static int create_disk_util_thread(void)
 
        setup_disk_util();
 
-       disk_thread_mutex = fio_mutex_init(0);
+       disk_thread_mutex = fio_mutex_init(FIO_MUTEX_LOCKED);
 
        ret = pthread_create(&disk_util_thread, NULL, disk_thread_main, NULL);
        if (ret) {
@@ -1661,10 +1661,10 @@ int fio_backend(void)
                setup_log(&agg_io_log[DDIR_WRITE], 0);
        }
 
-       startup_mutex = fio_mutex_init(0);
+       startup_mutex = fio_mutex_init(FIO_MUTEX_LOCKED);
        if (startup_mutex == NULL)
                return 1;
-       writeout_mutex = fio_mutex_init(1);
+       writeout_mutex = fio_mutex_init(FIO_MUTEX_UNLOCKED);
        if (writeout_mutex == NULL)
                return 1;
 
index ea6bbd6..86d4d5e 100644 (file)
--- a/cgroup.c
+++ b/cgroup.c
@@ -182,7 +182,7 @@ void cgroup_shutdown(struct thread_data *td, char **mnt)
 
 static void fio_init cgroup_init(void)
 {
-       lock = fio_mutex_init(1);
+       lock = fio_mutex_init(FIO_MUTEX_UNLOCKED);
 }
 
 static void fio_exit cgroup_exit(void)
index f51d07b..a3a5b4d 100644 (file)
@@ -290,7 +290,7 @@ static struct disk_util *disk_util_add(struct thread_data *td, int majdev,
        du->minor = mindev;
        INIT_FLIST_HEAD(&du->slavelist);
        INIT_FLIST_HEAD(&du->slaves);
-       du->lock = fio_mutex_init(1);
+       du->lock = fio_mutex_init(FIO_MUTEX_UNLOCKED);
        du->users = 0;
 
        fio_mutex_down(disk_util_mutex);
@@ -624,5 +624,5 @@ void show_disk_util(int terse)
 
 void setup_disk_util(void)
 {
-       disk_util_mutex = fio_mutex_init(1);
+       disk_util_mutex = fio_mutex_init(FIO_MUTEX_UNLOCKED);
 }
index 1bb1eb2..392464e 100644 (file)
@@ -107,5 +107,5 @@ void file_hash_init(void *ptr)
        for (i = 0; i < HASH_BUCKETS; i++)
                INIT_FLIST_HEAD(&file_hash[i]);
 
-       hash_lock = fio_mutex_init(1);
+       hash_lock = fio_mutex_init(FIO_MUTEX_UNLOCKED);
 }
index 371b405..6277f0f 100644 (file)
@@ -1006,7 +1006,7 @@ int add_file(struct thread_data *td, const char *fname)
                f->lock = fio_mutex_rw_init();
                break;
        case FILE_LOCK_EXCLUSIVE:
-               f->lock = fio_mutex_init(1);
+               f->lock = fio_mutex_init(FIO_MUTEX_UNLOCKED);
                break;
        default:
                log_err("fio: unknown lock mode: %d\n", td->o.file_lock_mode);
diff --git a/flow.c b/flow.c
index bf5eeec..2993f4e 100644 (file)
--- a/flow.c
+++ b/flow.c
@@ -92,7 +92,7 @@ void flow_exit_job(struct thread_data *td)
 
 void flow_init(void)
 {
-       flow_lock = fio_mutex_init(1);
+       flow_lock = fio_mutex_init(FIO_MUTEX_UNLOCKED);
        flow_list = smalloc(sizeof(*flow_list));
        INIT_FLIST_HEAD(flow_list);
 }
index e8f5ab5..5b49287 100644 (file)
--- a/gettime.c
+++ b/gettime.c
@@ -304,7 +304,7 @@ int fio_start_gtod_thread(void)
        pthread_attr_t attr;
        int ret;
 
-       mutex = fio_mutex_init(0);
+       mutex = fio_mutex_init(FIO_MUTEX_LOCKED);
        if (!mutex)
                return 1;
 
diff --git a/init.c b/init.c
index 3865d09..475a6ad 100644 (file)
--- a/init.c
+++ b/init.c
@@ -807,7 +807,7 @@ static int add_job(struct thread_data *td, const char *jobname, int job_add_num)
                        f->real_file_size = -1ULL;
        }
 
-       td->mutex = fio_mutex_init(0);
+       td->mutex = fio_mutex_init(FIO_MUTEX_LOCKED);
 
        td->ts.clat_percentiles = td->o.clat_percentiles;
        if (td->o.overwrite_plist)
diff --git a/mutex.h b/mutex.h
index 5938e95..6fdf7c6 100644 (file)
--- a/mutex.h
+++ b/mutex.h
@@ -10,6 +10,11 @@ struct fio_mutex {
        int waiters;
 };
 
+enum {
+       FIO_MUTEX_LOCKED        = 0,
+       FIO_MUTEX_UNLOCKED      = 1,
+};
+
 extern struct fio_mutex *fio_mutex_init(int);
 extern void fio_mutex_remove(struct fio_mutex *);
 extern void fio_mutex_down(struct fio_mutex *);
index 5ba2004..d0b6f1e 100644 (file)
--- a/smalloc.c
+++ b/smalloc.c
@@ -206,7 +206,7 @@ static int add_pool(struct pool *pool, unsigned int alloc_size)
        pool->map = ptr;
        pool->bitmap = (void *) ptr + (pool->nr_blocks * SMALLOC_BPL);
 
-       pool->lock = fio_mutex_init(1);
+       pool->lock = fio_mutex_init(FIO_MUTEX_UNLOCKED);
        if (!pool->lock)
                goto out_fail;