Skip to content

Commit

Permalink
[PATCH] make kernel/relay.c __user-clean
Browse files Browse the repository at this point in the history
Signed-off-by: Al Viro <viro@zeniv.linux.org.uk>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
  • Loading branch information
Al Viro authored and Linus Torvalds committed Oct 10, 2006
1 parent fb136e9 commit ba2397e
Showing 1 changed file with 22 additions and 19 deletions.
41 changes: 22 additions & 19 deletions kernel/relay.c
Original file line number Diff line number Diff line change
Expand Up @@ -887,7 +887,7 @@ static int subbuf_read_actor(size_t read_start,

from = buf->start + read_start;
ret = avail;
if (copy_to_user(desc->arg.data, from, avail)) {
if (copy_to_user(desc->arg.buf, from, avail)) {
desc->error = -EFAULT;
ret = 0;
}
Expand Down Expand Up @@ -946,24 +946,17 @@ typedef int (*subbuf_actor_t) (size_t read_start,
*/
static inline ssize_t relay_file_read_subbufs(struct file *filp,
loff_t *ppos,
size_t count,
subbuf_actor_t subbuf_actor,
read_actor_t actor,
void *target)
read_descriptor_t *desc)
{
struct rchan_buf *buf = filp->private_data;
size_t read_start, avail;
read_descriptor_t desc;
int ret;

if (!count)
if (!desc->count)
return 0;

desc.written = 0;
desc.count = count;
desc.arg.data = target;
desc.error = 0;

mutex_lock(&filp->f_dentry->d_inode->i_mutex);
do {
if (!relay_file_read_avail(buf, *ppos))
Expand All @@ -974,28 +967,33 @@ static inline ssize_t relay_file_read_subbufs(struct file *filp,
if (!avail)
break;

avail = min(desc.count, avail);
ret = subbuf_actor(read_start, buf, avail, &desc, actor);
if (desc.error < 0)
avail = min(desc->count, avail);
ret = subbuf_actor(read_start, buf, avail, desc, actor);
if (desc->error < 0)
break;

if (ret) {
relay_file_read_consume(buf, read_start, ret);
*ppos = relay_file_read_end_pos(buf, read_start, ret);
}
} while (desc.count && ret);
} while (desc->count && ret);
mutex_unlock(&filp->f_dentry->d_inode->i_mutex);

return desc.written;
return desc->written;
}

static ssize_t relay_file_read(struct file *filp,
char __user *buffer,
size_t count,
loff_t *ppos)
{
return relay_file_read_subbufs(filp, ppos, count, subbuf_read_actor,
NULL, buffer);
read_descriptor_t desc;
desc.written = 0;
desc.count = count;
desc.arg.buf = buffer;
desc.error = 0;
return relay_file_read_subbufs(filp, ppos, subbuf_read_actor,
NULL, &desc);
}

static ssize_t relay_file_sendfile(struct file *filp,
Expand All @@ -1004,8 +1002,13 @@ static ssize_t relay_file_sendfile(struct file *filp,
read_actor_t actor,
void *target)
{
return relay_file_read_subbufs(filp, ppos, count, subbuf_send_actor,
actor, target);
read_descriptor_t desc;
desc.written = 0;
desc.count = count;
desc.arg.data = target;
desc.error = 0;
return relay_file_read_subbufs(filp, ppos, subbuf_send_actor,
actor, &desc);
}

struct file_operations relay_file_operations = {
Expand Down

0 comments on commit ba2397e

Please sign in to comment.