Lines Matching defs:pipes
107 } pipes;
942 thread_data->pipes.msg[0] = -1;
943 thread_data->pipes.msg[1] = -1;
944 thread_data->pipes.ack[0] = -1;
945 thread_data->pipes.ack[1] = -1;
950 if (pipe(thread_data->pipes.msg))
953 if (pipe(thread_data->pipes.ack)) {
954 close(thread_data->pipes.msg[0]);
955 thread_data->pipes.msg[0] = -1;
956 close(thread_data->pipes.msg[1]);
957 thread_data->pipes.msg[1] = -1;
962 thread_data->pipes.msg[0], thread_data->pipes.msg[1],
963 thread_data->pipes.ack[0], thread_data->pipes.ack[1]);
970 if (thread_data->pipes.msg[0] != -1) {
971 close(thread_data->pipes.msg[0]);
972 thread_data->pipes.msg[0] = -1;
974 if (thread_data->pipes.msg[1] != -1) {
975 close(thread_data->pipes.msg[1]);
976 thread_data->pipes.msg[1] = -1;
978 if (thread_data->pipes.ack[0] != -1) {
979 close(thread_data->pipes.ack[0]);
980 thread_data->pipes.ack[0] = -1;
982 if (thread_data->pipes.ack[1] != -1) {
983 close(thread_data->pipes.ack[1]);
984 thread_data->pipes.ack[1] = -1;
1184 pr_err("Failed to open thread[%d] communication pipes\n", t);
1187 ret = fdarray__add(&thread_data[t].pollfd, thread_data[t].pipes.msg[0],
1196 thread_data[t].pipes.msg[0]);
1636 err = write(thread->pipes.ack[1], &msg, sizeof(msg));
1670 close(thread->pipes.msg[0]);
1671 thread->pipes.msg[0] = -1;
1680 err = write(thread->pipes.ack[1], &msg, sizeof(msg));
2193 close(thread_data->pipes.msg[1]);
2194 thread_data->pipes.msg[1] = -1;
2195 err = read(thread_data->pipes.ack[0], &ack, sizeof(ack));
2243 err = read(thread_data[t].pipes.ack[0], &msg, sizeof(msg));
3318 * using pipes, etc.