Btrfs-progs: remove unsed pthread attribute objects
authorRakesh Pandit <rakesh@tuxera.com>
Mon, 24 Mar 2014 09:04:47 +0000 (11:04 +0200)
committerDavid Sterba <dsterba@suse.cz>
Tue, 22 Apr 2014 12:33:35 +0000 (14:33 +0200)
Threads always use default attributes in all tools, so pthread
attribute objects and their initializations are of no use. Just pass
NULL as attr attribute to pthread_create for default attributes.

Signed-off-by: Rakesh Pandit <rakesh@tuxera.com>
Signed-off-by: David Sterba <dsterba@suse.cz>
cmds-scrub.c
cmds-send.c
send-test.c

index ca11fb5..d3bd148 100644 (file)
@@ -1086,7 +1086,6 @@ static int scrub_start(int argc, char **argv, int resume)
        };
        pthread_t *t_devs = NULL;
        pthread_t t_prog;
-       pthread_attr_t t_attr;
        struct scrub_file_record **past_scrubs = NULL;
        struct scrub_file_record *last_scrub = NULL;
        char *datafile = strdup(SCRUB_DATA_FILE);
@@ -1221,14 +1220,6 @@ static int scrub_start(int argc, char **argv, int resume)
                goto out;
        }
 
-       ret = pthread_attr_init(&t_attr);
-       if (ret) {
-               ERR(!do_quiet, "ERROR: pthread_attr_init failed: %s\n",
-                   strerror(ret));
-               err = 1;
-               goto out;
-       }
-
        for (i = 0; i < fi_args.num_devices; ++i) {
                devid = di_args[i].devid;
                ret = pthread_mutex_init(&sp[i].progress_mutex, NULL);
@@ -1376,7 +1367,7 @@ static int scrub_start(int argc, char **argv, int resume)
                devid = di_args[i].devid;
                gettimeofday(&tv, NULL);
                sp[i].stats.t_start = tv.tv_sec;
-               ret = pthread_create(&t_devs[i], &t_attr,
+               ret = pthread_create(&t_devs[i], NULL,
                                        scrub_one_dev, &sp[i]);
                if (ret) {
                        if (do_print)
@@ -1394,7 +1385,7 @@ static int scrub_start(int argc, char **argv, int resume)
        spc.write_mutex = &spc_write_mutex;
        spc.shared_progress = sp;
        spc.fi = &fi_args;
-       ret = pthread_create(&t_prog, &t_attr, scrub_progress_cycle, &spc);
+       ret = pthread_create(&t_prog, NULL, scrub_progress_cycle, &spc);
        if (ret) {
                if (do_print)
                        fprintf(stderr, "ERROR: creating progress thread "
index dcb6607..1cd457d 100644 (file)
@@ -240,7 +240,6 @@ static int do_send(struct btrfs_send *send, u64 parent_root_id,
 {
        int ret;
        pthread_t t_read;
-       pthread_attr_t t_attr;
        struct btrfs_ioctl_send_args io_send;
        void *t_err = NULL;
        int subvol_fd = -1;
@@ -254,8 +253,6 @@ static int do_send(struct btrfs_send *send, u64 parent_root_id,
                goto out;
        }
 
-       ret = pthread_attr_init(&t_attr);
-
        ret = pipe(pipefd);
        if (ret < 0) {
                ret = -errno;
@@ -268,7 +265,7 @@ static int do_send(struct btrfs_send *send, u64 parent_root_id,
        send->send_fd = pipefd[0];
 
        if (!ret)
-               ret = pthread_create(&t_read, &t_attr, dump_thread,
+               ret = pthread_create(&t_read, NULL, dump_thread,
                                        send);
        if (ret) {
                ret = -ret;
@@ -317,8 +314,6 @@ static int do_send(struct btrfs_send *send, u64 parent_root_id,
                goto out;
        }
 
-       pthread_attr_destroy(&t_attr);
-
        ret = 0;
 
 out:
index 5f7c311..0e804a2 100644 (file)
@@ -371,7 +371,6 @@ int main(int argc, char **argv)
        int ret = 0;
        int subvol_fd;
        pthread_t t_read;
-       pthread_attr_t t_attr;
        void *t_err = NULL;
        struct recv_args r;
 
@@ -401,13 +400,6 @@ int main(int argc, char **argv)
                goto out;
        }
 
-       ret = pthread_attr_init(&t_attr);
-       if (ret < 0) {
-               fprintf(stderr, "ERROR: pthread init failed. %s\n",
-                       strerror(ret));
-               goto out;
-       }
-
        ret = pipe(pipefd);
        if (ret < 0) {
                ret = errno;
@@ -415,7 +407,7 @@ int main(int argc, char **argv)
                goto out;
        }
 
-       ret = pthread_create(&t_read, &t_attr, process_thread, &r);
+       ret = pthread_create(&t_read, NULL, process_thread, &r);
        if (ret < 0) {
                ret = errno;
                fprintf(stderr, "ERROR: pthread create failed. %s\n",
@@ -452,7 +444,6 @@ int main(int argc, char **argv)
                goto out;
        }
 
-       pthread_attr_destroy(&t_attr);
 out:
        return !!ret;
 }