67 	struct rpc_pipe_msg *msg;  in rpc_purge_list()  local
72 		msg = list_entry(head->next, struct rpc_pipe_msg, list);  in rpc_purge_list()
73 		list_del_init(&msg->list);  in rpc_purge_list()
74 		msg->errno = err;  in rpc_purge_list()
75 		destroy_msg(msg);  in rpc_purge_list()
104 ssize_t rpc_pipe_generic_upcall(struct file *filp, struct rpc_pipe_msg *msg,  in rpc_pipe_generic_upcall()  argument
107 	char *data = (char *)msg->data + msg->copied;  in rpc_pipe_generic_upcall()
108 	size_t mlen = min(msg->len - msg->copied, buflen);  in rpc_pipe_generic_upcall()
113 		msg->errno = -EFAULT;  in rpc_pipe_generic_upcall()
118 	msg->copied += mlen;  in rpc_pipe_generic_upcall()
119 	msg->errno = 0;  in rpc_pipe_generic_upcall()
135 rpc_queue_upcall(struct rpc_pipe *pipe, struct rpc_pipe_msg *msg)  in rpc_queue_upcall()  argument
142 		list_add_tail(&msg->list, &pipe->pipe);  in rpc_queue_upcall()
143 		pipe->pipelen += msg->len;  in rpc_queue_upcall()
150 		list_add_tail(&msg->list, &pipe->pipe);  in rpc_queue_upcall()
151 		pipe->pipelen += msg->len;  in rpc_queue_upcall()
243 	struct rpc_pipe_msg *msg;  in rpc_pipe_release()  local
250 	msg = filp->private_data;  in rpc_pipe_release()
251 	if (msg != NULL) {  in rpc_pipe_release()
253 		msg->errno = -EAGAIN;  in rpc_pipe_release()
254 		list_del_init(&msg->list);  in rpc_pipe_release()
256 		pipe->ops->destroy_msg(msg);  in rpc_pipe_release()
285 	struct rpc_pipe_msg *msg;  in rpc_pipe_read()  local
294 	msg = filp->private_data;  in rpc_pipe_read()
295 	if (msg == NULL) {  in rpc_pipe_read()
298 			msg = list_entry(pipe->pipe.next,  in rpc_pipe_read()
301 			list_move(&msg->list, &pipe->in_upcall);  in rpc_pipe_read()
302 			pipe->pipelen -= msg->len;  in rpc_pipe_read()
303 			filp->private_data = msg;  in rpc_pipe_read()
304 			msg->copied = 0;  in rpc_pipe_read()
307 		if (msg == NULL)  in rpc_pipe_read()
311 	res = pipe->ops->upcall(filp, msg, buf, len);  in rpc_pipe_read()
312 	if (res < 0 || msg->len == msg->copied) {  in rpc_pipe_read()
315 		list_del_init(&msg->list);  in rpc_pipe_read()
317 		pipe->ops->destroy_msg(msg);  in rpc_pipe_read()
374 			struct rpc_pipe_msg *msg;  in rpc_pipe_ioctl()  local
375 			msg = filp->private_data;  in rpc_pipe_ioctl()
376 			len += msg->len - msg->copied;  in rpc_pipe_ioctl()