linux-master/fs/splice.c

1282 			       struct pipe_inode_info *opipe,
1286 			    struct pipe_inode_info *opipe,
1292 	pipe_lock(opipe);
1293 	ret = wait_for_space(opipe, flags);
1295 		ret = do_splice_read(in, offset, opipe, len, flags);
1296 	pipe_unlock(opipe);
1298 		wakeup_pipe_readers(opipe);
1309 	struct pipe_inode_info *opipe;
1318 	opipe = get_pipe_info(out, true);
1320 	if (ipipe && opipe) {
1325 		if (ipipe == opipe)
1331 		ret = splice_pipe_to_pipe(ipipe, opipe, len, flags);
1361 	} else if (opipe) {
1379 		ret = splice_file_to_pipe(in, opipe, &offset, len, flags);
1407 	struct pipe_inode_info *opipe;
1412 	opipe = get_pipe_info(out, true);
1419 	if (opipe) {
1737  * Splice contents of ipipe to opipe.
1740 			       struct pipe_inode_info *opipe,
1756 	ret = opipe_prep(opipe, flags);
1765 	pipe_double_lock(ipipe, opipe);
1769 	o_head = opipe->head;
1770 	o_mask = opipe->ring_size - 1;
1775 		if (!opipe->readers) {
1783 		o_tail = opipe->tail;
1793 		    pipe_full(o_head, o_tail, opipe->max_usage)) {
1809 			pipe_unlock(opipe);
1814 		obuf = &opipe->bufs[o_head & o_mask];
1818 			 * Simply move the whole buffer from ipipe to opipe
1827 			opipe->head = o_head;
1852 			opipe->head = o_head;
1859 	pipe_unlock(opipe);
1865 		wakeup_pipe_readers(opipe);
1874  * Link contents of ipipe to opipe.
1877 			 struct pipe_inode_info *opipe,
1891 	pipe_double_lock(ipipe, opipe);
1895 	o_head = opipe->head;
1896 	o_mask = opipe->ring_size - 1;
1899 		if (!opipe->readers) {
1907 		o_tail = opipe->tail;
1914 		    pipe_full(o_head, o_tail, opipe->max_usage))
1918 		obuf = &opipe->bufs[o_head & o_mask];
1945 		opipe->head = o_head;
1950 	pipe_unlock(opipe);
1956 		wakeup_pipe_readers(opipe);
1971 	struct pipe_inode_info *opipe = get_pipe_info(out, true);
1979 	 * Duplicate the contents of ipipe to opipe without actually
1982 	if (ipipe && opipe && ipipe != opipe) {
1987 		 * Keep going, unless we encounter an error. The ipipe/opipe
1992 			ret = opipe_prep(opipe, flags);
1994 				ret = link_pipe(ipipe, opipe, len, flags);