mirror of
https://github.com/Fishwaldo/linux-bl808.git
synced 2025-06-17 20:25:19 +00:00
splice: divorce the splice structure/function definitions from the pipe header
We need to move even more stuff into the header so that folks can use the splice_to_pipe() implementation instead of open-coding a lot of pipe knowledge (see relay implementation), so move to our own header file finally. Signed-off-by: Jens Axboe <jens.axboe@oracle.com>
This commit is contained in:
parent
ebf9909343
commit
d6b29d7cee
9 changed files with 83 additions and 68 deletions
|
@ -74,7 +74,7 @@
|
||||||
#include <linux/highmem.h>
|
#include <linux/highmem.h>
|
||||||
#include <linux/gfp.h>
|
#include <linux/gfp.h>
|
||||||
#include <linux/kthread.h>
|
#include <linux/kthread.h>
|
||||||
#include <linux/pipe_fs_i.h>
|
#include <linux/splice.h>
|
||||||
|
|
||||||
#include <asm/uaccess.h>
|
#include <asm/uaccess.h>
|
||||||
|
|
||||||
|
|
|
@ -24,7 +24,7 @@
|
||||||
#include <linux/crash_dump.h>
|
#include <linux/crash_dump.h>
|
||||||
#include <linux/backing-dev.h>
|
#include <linux/backing-dev.h>
|
||||||
#include <linux/bootmem.h>
|
#include <linux/bootmem.h>
|
||||||
#include <linux/pipe_fs_i.h>
|
#include <linux/splice.h>
|
||||||
#include <linux/pfn.h>
|
#include <linux/pfn.h>
|
||||||
|
|
||||||
#include <asm/uaccess.h>
|
#include <asm/uaccess.h>
|
||||||
|
|
|
@ -23,7 +23,7 @@
|
||||||
#include <linux/file.h>
|
#include <linux/file.h>
|
||||||
#include <linux/mount.h>
|
#include <linux/mount.h>
|
||||||
#include <linux/major.h>
|
#include <linux/major.h>
|
||||||
#include <linux/pipe_fs_i.h>
|
#include <linux/splice.h>
|
||||||
#include <linux/proc_fs.h>
|
#include <linux/proc_fs.h>
|
||||||
#include <linux/stat.h>
|
#include <linux/stat.h>
|
||||||
#include <linux/fcntl.h>
|
#include <linux/fcntl.h>
|
||||||
|
|
|
@ -31,7 +31,7 @@
|
||||||
#include <linux/pagemap.h>
|
#include <linux/pagemap.h>
|
||||||
#include <linux/uio.h>
|
#include <linux/uio.h>
|
||||||
#include <linux/sched.h>
|
#include <linux/sched.h>
|
||||||
#include <linux/pipe_fs_i.h>
|
#include <linux/splice.h>
|
||||||
#include <linux/mount.h>
|
#include <linux/mount.h>
|
||||||
#include <linux/writeback.h>
|
#include <linux/writeback.h>
|
||||||
|
|
||||||
|
|
|
@ -15,7 +15,7 @@
|
||||||
#include <linux/module.h>
|
#include <linux/module.h>
|
||||||
#include <linux/syscalls.h>
|
#include <linux/syscalls.h>
|
||||||
#include <linux/pagemap.h>
|
#include <linux/pagemap.h>
|
||||||
#include <linux/pipe_fs_i.h>
|
#include <linux/splice.h>
|
||||||
#include "read_write.h"
|
#include "read_write.h"
|
||||||
|
|
||||||
#include <asm/uaccess.h>
|
#include <asm/uaccess.h>
|
||||||
|
|
24
fs/splice.c
24
fs/splice.c
|
@ -20,7 +20,7 @@
|
||||||
#include <linux/fs.h>
|
#include <linux/fs.h>
|
||||||
#include <linux/file.h>
|
#include <linux/file.h>
|
||||||
#include <linux/pagemap.h>
|
#include <linux/pagemap.h>
|
||||||
#include <linux/pipe_fs_i.h>
|
#include <linux/splice.h>
|
||||||
#include <linux/mm_inline.h>
|
#include <linux/mm_inline.h>
|
||||||
#include <linux/swap.h>
|
#include <linux/swap.h>
|
||||||
#include <linux/writeback.h>
|
#include <linux/writeback.h>
|
||||||
|
@ -29,22 +29,6 @@
|
||||||
#include <linux/syscalls.h>
|
#include <linux/syscalls.h>
|
||||||
#include <linux/uio.h>
|
#include <linux/uio.h>
|
||||||
|
|
||||||
struct partial_page {
|
|
||||||
unsigned int offset;
|
|
||||||
unsigned int len;
|
|
||||||
};
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Passed to splice_to_pipe
|
|
||||||
*/
|
|
||||||
struct splice_pipe_desc {
|
|
||||||
struct page **pages; /* page map */
|
|
||||||
struct partial_page *partial; /* pages[] may not be contig */
|
|
||||||
int nr_pages; /* number of pages in map */
|
|
||||||
unsigned int flags; /* splice flags */
|
|
||||||
const struct pipe_buf_operations *ops;/* ops associated with output pipe */
|
|
||||||
};
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Attempt to steal a page from a pipe buffer. This should perhaps go into
|
* Attempt to steal a page from a pipe buffer. This should perhaps go into
|
||||||
* a vm helper function, it's already simplified quite a bit by the
|
* a vm helper function, it's already simplified quite a bit by the
|
||||||
|
@ -170,10 +154,10 @@ static const struct pipe_buf_operations user_page_pipe_buf_ops = {
|
||||||
};
|
};
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Pipe output worker. This sets up our pipe format with the page cache
|
* Pipe output worker. This fills a pipe with the information contained
|
||||||
* pipe buffer operations. Otherwise very similar to the regular pipe_writev().
|
* from splice_pipe_desc().
|
||||||
*/
|
*/
|
||||||
static ssize_t splice_to_pipe(struct pipe_inode_info *pipe,
|
ssize_t splice_to_pipe(struct pipe_inode_info *pipe,
|
||||||
struct splice_pipe_desc *spd)
|
struct splice_pipe_desc *spd)
|
||||||
{
|
{
|
||||||
unsigned int spd_pages = spd->nr_pages;
|
unsigned int spd_pages = spd->nr_pages;
|
||||||
|
|
|
@ -71,45 +71,4 @@ void generic_pipe_buf_get(struct pipe_inode_info *, struct pipe_buffer *);
|
||||||
int generic_pipe_buf_pin(struct pipe_inode_info *, struct pipe_buffer *);
|
int generic_pipe_buf_pin(struct pipe_inode_info *, struct pipe_buffer *);
|
||||||
int generic_pipe_buf_steal(struct pipe_inode_info *, struct pipe_buffer *);
|
int generic_pipe_buf_steal(struct pipe_inode_info *, struct pipe_buffer *);
|
||||||
|
|
||||||
/*
|
|
||||||
* splice is tied to pipes as a transport (at least for now), so we'll just
|
|
||||||
* add the splice flags here.
|
|
||||||
*/
|
|
||||||
#define SPLICE_F_MOVE (0x01) /* move pages instead of copying */
|
|
||||||
#define SPLICE_F_NONBLOCK (0x02) /* don't block on the pipe splicing (but */
|
|
||||||
/* we may still block on the fd we splice */
|
|
||||||
/* from/to, of course */
|
|
||||||
#define SPLICE_F_MORE (0x04) /* expect more data */
|
|
||||||
#define SPLICE_F_GIFT (0x08) /* pages passed in are a gift */
|
|
||||||
|
|
||||||
/*
|
|
||||||
* Passed to the actors
|
|
||||||
*/
|
|
||||||
struct splice_desc {
|
|
||||||
unsigned int len, total_len; /* current and remaining length */
|
|
||||||
unsigned int flags; /* splice flags */
|
|
||||||
/*
|
|
||||||
* actor() private data
|
|
||||||
*/
|
|
||||||
union {
|
|
||||||
void __user *userptr; /* memory to write to */
|
|
||||||
struct file *file; /* file to read/write */
|
|
||||||
void *data; /* cookie */
|
|
||||||
} u;
|
|
||||||
loff_t pos; /* file position */
|
|
||||||
};
|
|
||||||
|
|
||||||
typedef int (splice_actor)(struct pipe_inode_info *, struct pipe_buffer *,
|
|
||||||
struct splice_desc *);
|
|
||||||
typedef int (splice_direct_actor)(struct pipe_inode_info *,
|
|
||||||
struct splice_desc *);
|
|
||||||
|
|
||||||
extern ssize_t splice_from_pipe(struct pipe_inode_info *, struct file *,
|
|
||||||
loff_t *, size_t, unsigned int,
|
|
||||||
splice_actor *);
|
|
||||||
extern ssize_t __splice_from_pipe(struct pipe_inode_info *,
|
|
||||||
struct splice_desc *, splice_actor *);
|
|
||||||
extern ssize_t splice_direct_to_actor(struct file *, struct splice_desc *,
|
|
||||||
splice_direct_actor *);
|
|
||||||
|
|
||||||
#endif
|
#endif
|
||||||
|
|
72
include/linux/splice.h
Normal file
72
include/linux/splice.h
Normal file
|
@ -0,0 +1,72 @@
|
||||||
|
/*
|
||||||
|
* Function declerations and data structures related to the splice
|
||||||
|
* implementation.
|
||||||
|
*
|
||||||
|
* Copyright (C) 2007 Jens Axboe <jens.axboe@oracle.com>
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
#ifndef SPLICE_H
|
||||||
|
#define SPLICE_H
|
||||||
|
|
||||||
|
#include <linux/pipe_fs_i.h>
|
||||||
|
|
||||||
|
/*
|
||||||
|
* splice is tied to pipes as a transport (at least for now), so we'll just
|
||||||
|
* add the splice flags here.
|
||||||
|
*/
|
||||||
|
#define SPLICE_F_MOVE (0x01) /* move pages instead of copying */
|
||||||
|
#define SPLICE_F_NONBLOCK (0x02) /* don't block on the pipe splicing (but */
|
||||||
|
/* we may still block on the fd we splice */
|
||||||
|
/* from/to, of course */
|
||||||
|
#define SPLICE_F_MORE (0x04) /* expect more data */
|
||||||
|
#define SPLICE_F_GIFT (0x08) /* pages passed in are a gift */
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Passed to the actors
|
||||||
|
*/
|
||||||
|
struct splice_desc {
|
||||||
|
unsigned int len, total_len; /* current and remaining length */
|
||||||
|
unsigned int flags; /* splice flags */
|
||||||
|
/*
|
||||||
|
* actor() private data
|
||||||
|
*/
|
||||||
|
union {
|
||||||
|
void __user *userptr; /* memory to write to */
|
||||||
|
struct file *file; /* file to read/write */
|
||||||
|
void *data; /* cookie */
|
||||||
|
} u;
|
||||||
|
loff_t pos; /* file position */
|
||||||
|
};
|
||||||
|
|
||||||
|
struct partial_page {
|
||||||
|
unsigned int offset;
|
||||||
|
unsigned int len;
|
||||||
|
};
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Passed to splice_to_pipe
|
||||||
|
*/
|
||||||
|
struct splice_pipe_desc {
|
||||||
|
struct page **pages; /* page map */
|
||||||
|
struct partial_page *partial; /* pages[] may not be contig */
|
||||||
|
int nr_pages; /* number of pages in map */
|
||||||
|
unsigned int flags; /* splice flags */
|
||||||
|
const struct pipe_buf_operations *ops;/* ops associated with output pipe */
|
||||||
|
};
|
||||||
|
|
||||||
|
typedef int (splice_actor)(struct pipe_inode_info *, struct pipe_buffer *,
|
||||||
|
struct splice_desc *);
|
||||||
|
typedef int (splice_direct_actor)(struct pipe_inode_info *,
|
||||||
|
struct splice_desc *);
|
||||||
|
|
||||||
|
extern ssize_t splice_from_pipe(struct pipe_inode_info *, struct file *,
|
||||||
|
loff_t *, size_t, unsigned int,
|
||||||
|
splice_actor *);
|
||||||
|
extern ssize_t __splice_from_pipe(struct pipe_inode_info *,
|
||||||
|
struct splice_desc *, splice_actor *);
|
||||||
|
extern ssize_t splice_to_pipe(struct pipe_inode_info *,
|
||||||
|
struct splice_pipe_desc *);
|
||||||
|
extern ssize_t splice_direct_to_actor(struct file *, struct splice_desc *,
|
||||||
|
splice_direct_actor *);
|
||||||
|
|
||||||
|
#endif
|
|
@ -21,7 +21,7 @@
|
||||||
#include <linux/vmalloc.h>
|
#include <linux/vmalloc.h>
|
||||||
#include <linux/mm.h>
|
#include <linux/mm.h>
|
||||||
#include <linux/cpu.h>
|
#include <linux/cpu.h>
|
||||||
#include <linux/pipe_fs_i.h>
|
#include <linux/splice.h>
|
||||||
|
|
||||||
/* list of open channels, for cpu hotplug */
|
/* list of open channels, for cpu hotplug */
|
||||||
static DEFINE_MUTEX(relay_channels_mutex);
|
static DEFINE_MUTEX(relay_channels_mutex);
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue