24 	struct rw_thread_info *rw_ti;  in rw_thread_info_new()  local
26 	rw_ti = zalloc(sizeof(struct rw_thread_info));  in rw_thread_info_new()
27 	if (rw_ti == NULL) {  in rw_thread_info_new()
32 	rw_ti->cpu_num = -1;  in rw_thread_info_new()
33 	rw_ti->in_fd = -1;  in rw_thread_info_new()
34 	rw_ti->out_fd = -1;  in rw_thread_info_new()
35 	rw_ti->read_pipe = -1;  in rw_thread_info_new()
36 	rw_ti->write_pipe = -1;  in rw_thread_info_new()
37 	rw_ti->pipe_size = PIPE_INIT;  in rw_thread_info_new()
39 	return rw_ti;  in rw_thread_info_new()
44 				struct rw_thread_info *rw_ti)  in rw_thread_init()  argument
48 	rw_ti->cpu_num = cpu;  in rw_thread_init()
51 	rw_ti->in_fd = open(in_path, O_RDONLY);  in rw_thread_init()
52 	if (rw_ti->in_fd == -1) {  in rw_thread_init()
60 		rw_ti->out_fd = open(out_path, O_WRONLY);  in rw_thread_init()
61 		if (rw_ti->out_fd == -1) {  in rw_thread_init()
67 		rw_ti->out_fd = STDOUT_FILENO;  in rw_thread_init()
83 	rw_ti->read_pipe = data_pipe[1];  in rw_thread_init()
84 	rw_ti->write_pipe = data_pipe[0];  in rw_thread_init()
85 	rw_ti->pipe_size = pipe_size;  in rw_thread_init()
180 pthread_t rw_thread_run(struct rw_thread_info *rw_ti)  in rw_thread_run()  argument
185 	ret = pthread_create(&rw_thread_per_cpu, NULL, rw_thread_main, rw_ti);  in rw_thread_run()
187 		pr_err("Could not create a rw thread(%d)\n", rw_ti->cpu_num);  in rw_thread_run()