22 	struct rw_thread_info *rw_ti;  in rw_thread_info_new()  local
24 	rw_ti = zalloc(sizeof(struct rw_thread_info));  in rw_thread_info_new()
25 	if (rw_ti == NULL) {  in rw_thread_info_new()
30 	rw_ti->cpu_num = -1;  in rw_thread_info_new()
31 	rw_ti->in_fd = -1;  in rw_thread_info_new()
32 	rw_ti->out_fd = -1;  in rw_thread_info_new()
33 	rw_ti->read_pipe = -1;  in rw_thread_info_new()
34 	rw_ti->write_pipe = -1;  in rw_thread_info_new()
35 	rw_ti->pipe_size = PIPE_INIT;  in rw_thread_info_new()
37 	return rw_ti;  in rw_thread_info_new()
42 				struct rw_thread_info *rw_ti)  in rw_thread_init()  argument
46 	rw_ti->cpu_num = cpu;  in rw_thread_init()
49 	rw_ti->in_fd = open(in_path, O_RDONLY);  in rw_thread_init()
50 	if (rw_ti->in_fd == -1) {  in rw_thread_init()
58 		rw_ti->out_fd = open(out_path, O_WRONLY);  in rw_thread_init()
59 		if (rw_ti->out_fd == -1) {  in rw_thread_init()
65 		rw_ti->out_fd = STDOUT_FILENO;  in rw_thread_init()
81 	rw_ti->read_pipe = data_pipe[1];  in rw_thread_init()
82 	rw_ti->write_pipe = data_pipe[0];  in rw_thread_init()
83 	rw_ti->pipe_size = pipe_size;  in rw_thread_init()
178 pthread_t rw_thread_run(struct rw_thread_info *rw_ti)  in rw_thread_run()  argument
183 	ret = pthread_create(&rw_thread_per_cpu, NULL, rw_thread_main, rw_ti);  in rw_thread_run()
185 		pr_err("Could not create a rw thread(%d)\n", rw_ti->cpu_num);  in rw_thread_run()