X-Git-Url: http://git.lttng.org/?a=blobdiff_plain;f=lib%2Fringbuffer%2Fring_buffer_splice.c;h=bb91f45e01a303303b514814436d388ed9292c23;hb=de23d59d5992b7354b57a533b4d582809ef8d43c;hp=59a1589bb1301cc32ad5372bce6a7f26d3b09d17;hpb=886d51a3d7ed5fa6b41d7f19b3e14ae6c535a44c;p=lttng-modules.git diff --git a/lib/ringbuffer/ring_buffer_splice.c b/lib/ringbuffer/ring_buffer_splice.c index 59a1589b..bb91f45e 100644 --- a/lib/ringbuffer/ring_buffer_splice.c +++ b/lib/ringbuffer/ring_buffer_splice.c @@ -25,6 +25,7 @@ #include #include +#include #include "../../wrapper/splice.h" #include "../../wrapper/ringbuffer/backend.h" @@ -37,10 +38,12 @@ #define printk_dbg(fmt, args...) #endif -loff_t lib_ring_buffer_no_llseek(struct file *file, loff_t offset, int origin) +loff_t vfs_lib_ring_buffer_no_llseek(struct file *file, loff_t offset, + int origin) { return -ESPIPE; } +EXPORT_SYMBOL_GPL(vfs_lib_ring_buffer_no_llseek); /* * Release pages from the buffer so splice pipe_to_file can move them. @@ -54,8 +57,10 @@ static void lib_ring_buffer_pipe_buf_release(struct pipe_inode_info *pipe, static const struct pipe_buf_operations ring_buffer_pipe_buf_ops = { .can_merge = 0, +#if (LINUX_VERSION_CODE < KERNEL_VERSION(3,15,0)) .map = generic_pipe_buf_map, .unmap = generic_pipe_buf_unmap, +#endif .confirm = generic_pipe_buf_confirm, .release = lib_ring_buffer_pipe_buf_release, .steal = generic_pipe_buf_steal, @@ -78,9 +83,9 @@ static int subbuf_splice_actor(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, - unsigned int flags) + unsigned int flags, + struct lib_ring_buffer *buf) { - struct lib_ring_buffer *buf = in->private_data; struct channel *chan = buf->backend.chan; const struct lib_ring_buffer_config *config = &chan->backend.config; unsigned int poff, subbuf_pages, nr_pages; @@ -160,9 +165,9 @@ static int subbuf_splice_actor(struct file *in, ssize_t lib_ring_buffer_splice_read(struct file *in, loff_t *ppos, struct pipe_inode_info *pipe, size_t len, - unsigned int flags) + unsigned int flags, + struct lib_ring_buffer *buf) { - struct lib_ring_buffer *buf = in->private_data; struct channel *chan = buf->backend.chan; const struct lib_ring_buffer_config *config = &chan->backend.config; ssize_t spliced; @@ -189,7 +194,7 @@ ssize_t lib_ring_buffer_splice_read(struct file *in, loff_t *ppos, printk_dbg(KERN_DEBUG "SPLICE read len %zu pos %zd\n", len, (ssize_t)*ppos); while (len && !spliced) { - ret = subbuf_splice_actor(in, ppos, pipe, len, flags); + ret = subbuf_splice_actor(in, ppos, pipe, len, flags, buf); printk_dbg(KERN_DEBUG "SPLICE read loop ret %d\n", ret); if (ret < 0) break; @@ -213,3 +218,13 @@ ssize_t lib_ring_buffer_splice_read(struct file *in, loff_t *ppos, return ret; } EXPORT_SYMBOL_GPL(lib_ring_buffer_splice_read); + +ssize_t vfs_lib_ring_buffer_splice_read(struct file *in, loff_t *ppos, + struct pipe_inode_info *pipe, size_t len, + unsigned int flags) +{ + struct lib_ring_buffer *buf = in->private_data; + + return lib_ring_buffer_splice_read(in, ppos, pipe, len, flags, buf); +} +EXPORT_SYMBOL_GPL(vfs_lib_ring_buffer_splice_read);