Commit b627344f authored by Steven Rostedt's avatar Steven Rostedt Committed by Steven Rostedt

tracing: Fix read blocking on trace_pipe_raw

If the ring buffer is empty, a read to trace_pipe_raw wont block.
The tracing code has the infrastructure to wake up waiting readers,
but the trace_pipe_raw doesn't take advantage of that.

When a read is done to trace_pipe_raw without the O_NONBLOCK flag
set, have the read block until there's data in the requested buffer.
Signed-off-by: default avatarSteven Rostedt <rostedt@goodmis.org>
parent cc60cdc9
...@@ -4389,6 +4389,7 @@ static int tracing_buffers_open(struct inode *inode, struct file *filp) ...@@ -4389,6 +4389,7 @@ static int tracing_buffers_open(struct inode *inode, struct file *filp)
info->iter.tr = tr; info->iter.tr = tr;
info->iter.cpu_file = tc->cpu; info->iter.cpu_file = tc->cpu;
info->iter.trace = tr->current_trace;
info->spare = NULL; info->spare = NULL;
/* Force reading ring buffer for first read */ /* Force reading ring buffer for first read */
info->read = (unsigned int)-1; info->read = (unsigned int)-1;
...@@ -4428,18 +4429,29 @@ tracing_buffers_read(struct file *filp, char __user *ubuf, ...@@ -4428,18 +4429,29 @@ tracing_buffers_read(struct file *filp, char __user *ubuf,
if (info->read < PAGE_SIZE) if (info->read < PAGE_SIZE)
goto read; goto read;
again:
trace_access_lock(iter->cpu_file); trace_access_lock(iter->cpu_file);
ret = ring_buffer_read_page(iter->tr->buffer, ret = ring_buffer_read_page(iter->tr->buffer,
&info->spare, &info->spare,
count, count,
iter->cpu_file, 0); iter->cpu_file, 0);
trace_access_unlock(iter->cpu_file); trace_access_unlock(iter->cpu_file);
if (ret < 0)
if (ret < 0) {
if (trace_empty(iter)) {
if ((filp->f_flags & O_NONBLOCK))
return -EAGAIN;
iter->trace->wait_pipe(iter);
if (signal_pending(current))
return -EINTR;
goto again;
}
return 0; return 0;
}
info->read = 0; info->read = 0;
read: read:
size = PAGE_SIZE - info->read; size = PAGE_SIZE - info->read;
if (size > count) if (size > count)
size = count; size = count;
...@@ -4616,7 +4628,7 @@ tracing_buffers_splice_read(struct file *file, loff_t *ppos, ...@@ -4616,7 +4628,7 @@ tracing_buffers_splice_read(struct file *file, loff_t *ppos,
ret = -EAGAIN; ret = -EAGAIN;
goto out; goto out;
} }
default_wait_pipe(iter); iter->trace->wait_pipe(iter);
if (signal_pending(current)) { if (signal_pending(current)) {
ret = -EINTR; ret = -EINTR;
goto out; goto out;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment