Release 4.11 fs/pipe.c

/*
 *  linux/fs/pipe.c
 *
 *  Copyright (C) 1991, 1992, 1999  Linus Torvalds
 */

#include <linux/mm.h>
#include <linux/file.h>
#include <linux/poll.h>
#include <linux/slab.h>
#include <linux/module.h>
#include <linux/init.h>
#include <linux/fs.h>
#include <linux/log2.h>
#include <linux/mount.h>
#include <linux/magic.h>
#include <linux/pipe_fs_i.h>
#include <linux/uio.h>
#include <linux/highmem.h>
#include <linux/pagemap.h>
#include <linux/audit.h>
#include <linux/syscalls.h>
#include <linux/fcntl.h>
#include <linux/memcontrol.h>

#include <linux/uaccess.h>
#include <asm/ioctls.h>

#include "internal.h"

/*
 * The max size that a non-root user is allowed to grow the pipe. Can
 * be set by root in /proc/sys/fs/pipe-max-size
 */

unsigned int pipe_max_size = 1048576;

/*
 * Minimum pipe size, as required by POSIX
 */

unsigned int pipe_min_size = PAGE_SIZE;

/* Maximum allocatable pages per user. Hard limit is unset by default, soft
 * matches default values.
 */

unsigned long pipe_user_pages_hard;

unsigned long pipe_user_pages_soft = PIPE_DEF_BUFFERS * INR_OPEN_CUR;

/*
 * We use a start+len construction, which provides full use of the 
 * allocated memory.
 * -- Florian Coosmann (FGC)
 * 
 * Reads with count = 0 should always return 0.
 * -- Julian Bradfield 1999-06-07.
 *
 * FIFOs and Pipes now generate SIGIO for both readers and writers.
 * -- Jeremy Elson <jelson@circlemud.org> 2001-08-16
 *
 * pipe_read & write cleanup
 * -- Manfred Spraul <manfred@colorfullife.com> 2002-05-09
 */



static void pipe_lock_nested(struct pipe_inode_info *pipe, int subclass)
{
	if (pipe->files)
		mutex_lock_nested(&pipe->mutex, subclass);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Miklos Szeredi
28
93.33%
1
33.33%
Al Viro
2
6.67%
2
66.67%
Total
30
100.00%
3
100.00%



void pipe_lock(struct pipe_inode_info *pipe)
{
	/*
         * pipe_lock() nests non-pipe inode locks (for writing to a file)
         */
	pipe_lock_nested(pipe, I_MUTEX_PARENT);
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Miklos Szeredi
18
100.00%
1
100.00%
Total
18
100.00%
1
100.00%


EXPORT_SYMBOL(pipe_lock);



void pipe_unlock(struct pipe_inode_info *pipe)
{
	if (pipe->files)
		mutex_unlock(&pipe->mutex);
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Miklos Szeredi
22
91.67%
1
33.33%
Al Viro
2
8.33%
2
66.67%
Total
24
100.00%
3
100.00%


EXPORT_SYMBOL(pipe_unlock);



static inline void __pipe_lock(struct pipe_inode_info *pipe)
{
	mutex_lock_nested(&pipe->mutex, I_MUTEX_PARENT);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
22
100.00%
1
100.00%
Total
22
100.00%
1
100.00%



static inline void __pipe_unlock(struct pipe_inode_info *pipe)
{
	mutex_unlock(&pipe->mutex);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
20
100.00%
1
100.00%
Total
20
100.00%
1
100.00%



void pipe_double_lock(struct pipe_inode_info *pipe1,
		      struct pipe_inode_info *pipe2)
{
	BUG_ON(pipe1 == pipe2);

	if (pipe1 < pipe2) {
		pipe_lock_nested(pipe1, I_MUTEX_PARENT);
		pipe_lock_nested(pipe2, I_MUTEX_CHILD);
	} else {
		pipe_lock_nested(pipe2, I_MUTEX_PARENT);
		pipe_lock_nested(pipe1, I_MUTEX_CHILD);
	}
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Miklos Szeredi
59
96.72%
1
50.00%
Peter Zijlstra
2
3.28%
1
50.00%
Total
61
100.00%
2
100.00%

/* Drop the inode semaphore and wait for a pipe event, atomically */


void pipe_wait(struct pipe_inode_info *pipe)
{
	DEFINE_WAIT(wait);

	/*
         * Pipes are system-local resources, so sleeping on them
         * is considered a noninteractive wait:
         */
	prepare_to_wait(&pipe->wait, &wait, TASK_INTERRUPTIBLE);
	pipe_unlock(pipe);
	schedule();
	finish_wait(&pipe->wait, &wait);
	pipe_lock(pipe);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds (pre-git)
33
62.26%
2
33.33%
Ingo Molnar
13
24.53%
2
33.33%
Andrew Morton
5
9.43%
1
16.67%
Miklos Szeredi
2
3.77%
1
16.67%
Total
53
100.00%
6
100.00%



static void anon_pipe_buf_release(struct pipe_inode_info *pipe,
				  struct pipe_buffer *buf)
{
	struct page *page = buf->page;

	/*
         * If nobody else uses this page, and we don't already have a
         * temporary page, let's keep track of it as a one-deep
         * allocation cache. (Otherwise just release our reference to it)
         */
	if (page_count(page) == 1 && !pipe->tmp_page)
		pipe->tmp_page = page;
	else
		put_page(page);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds
34
65.38%
2
33.33%
Jens Axboe
12
23.08%
1
16.67%
Ingo Molnar
5
9.62%
2
33.33%
Kirill A. Shutemov
1
1.92%
1
16.67%
Total
52
100.00%
6
100.00%



static int anon_pipe_buf_steal(struct pipe_inode_info *pipe,
			       struct pipe_buffer *buf)
{
	struct page *page = buf->page;

	if (page_count(page) == 1) {
		if (memcg_kmem_enabled())
			memcg_kmem_uncharge(page, 0);
		__SetPageLocked(page);
		return 0;
	}
	return 1;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Vladimir Davydov
59
100.00%
1
100.00%
Total
59
100.00%
1
100.00%

/**
 * generic_pipe_buf_steal - attempt to take ownership of a &pipe_buffer
 * @pipe:       the pipe that the buffer belongs to
 * @buf:        the buffer to attempt to steal
 *
 * Description:
 *      This function attempts to steal the &struct page attached to
 *      @buf. If successful, this function returns 0 and returns with
 *      the page locked. The caller may then reuse the page for whatever
 *      he wishes; the typical use is insertion into a different file
 *      page cache.
 */


int generic_pipe_buf_steal(struct pipe_inode_info *pipe,
			   struct pipe_buffer *buf)
{
	struct page *page = buf->page;

	/*
         * A reference of one is golden, that means that the owner of this
         * page is the only one holding a reference to it. lock the page
         * and return OK.
         */
	if (page_count(page) == 1) {
		lock_page(page);
		return 0;
	}

	return 1;
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Jens Axboe
46
97.87%
4
80.00%
Ingo Molnar
1
2.13%
1
20.00%
Total
47
100.00%
5
100.00%


EXPORT_SYMBOL(generic_pipe_buf_steal);

/**
 * generic_pipe_buf_get - get a reference to a &struct pipe_buffer
 * @pipe:       the pipe that the buffer belongs to
 * @buf:        the buffer to get a reference to
 *
 * Description:
 *      This function grabs an extra reference to @buf. It's used in
 *      in the tee() system call, when we duplicate the buffers in one
 *      pipe into another.
 */


void generic_pipe_buf_get(struct pipe_inode_info *pipe, struct pipe_buffer *buf)
{
	get_page(buf->page);
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Jens Axboe
21
95.45%
3
75.00%
Kirill A. Shutemov
1
4.55%
1
25.00%
Total
22
100.00%
4
100.00%


EXPORT_SYMBOL(generic_pipe_buf_get);

/**
 * generic_pipe_buf_confirm - verify contents of the pipe buffer
 * @info:       the pipe that the buffer belongs to
 * @buf:        the buffer to confirm
 *
 * Description:
 *      This function does nothing, because the generic pipe code uses
 *      pages that are always good when inserted into the pipe.
 */


int generic_pipe_buf_confirm(struct pipe_inode_info *info,
			     struct pipe_buffer *buf)
{
	return 0;
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Jens Axboe
18
100.00%
2
100.00%
Total
18
100.00%
2
100.00%


EXPORT_SYMBOL(generic_pipe_buf_confirm);

/**
 * generic_pipe_buf_release - put a reference to a &struct pipe_buffer
 * @pipe:       the pipe that the buffer belongs to
 * @buf:        the buffer to put a reference to
 *
 * Description:
 *      This function releases a reference to @buf.
 */


void generic_pipe_buf_release(struct pipe_inode_info *pipe,
			      struct pipe_buffer *buf)
{
	put_page(buf->page);
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Miklos Szeredi
21
95.45%
1
50.00%
Kirill A. Shutemov
1
4.55%
1
50.00%
Total
22
100.00%
2
100.00%


EXPORT_SYMBOL(generic_pipe_buf_release);


static const struct pipe_buf_operations anon_pipe_buf_ops = {
	.can_merge = 1,
	.confirm = generic_pipe_buf_confirm,
	.release = anon_pipe_buf_release,
	.steal = anon_pipe_buf_steal,
	.get = generic_pipe_buf_get,
};


static const struct pipe_buf_operations packet_pipe_buf_ops = {
	.can_merge = 0,
	.confirm = generic_pipe_buf_confirm,
	.release = anon_pipe_buf_release,
	.steal = anon_pipe_buf_steal,
	.get = generic_pipe_buf_get,
};


static ssize_t

pipe_read(struct kiocb *iocb, struct iov_iter *to)
{
	size_t total_len = iov_iter_count(to);
	struct file *filp = iocb->ki_filp;
	struct pipe_inode_info *pipe = filp->private_data;
	int do_wakeup;
	ssize_t ret;

	/* Null read succeeds. */
	if (unlikely(total_len == 0))
		return 0;

	do_wakeup = 0;
	ret = 0;
	__pipe_lock(pipe);
	for (;;) {
		int bufs = pipe->nrbufs;
		if (bufs) {
			int curbuf = pipe->curbuf;
			struct pipe_buffer *buf = pipe->bufs + curbuf;
			size_t chars = buf->len;
			size_t written;
			int error;

			if (chars > total_len)
				chars = total_len;

			error = pipe_buf_confirm(pipe, buf);
			if (error) {
				if (!ret)
					ret = error;
				break;
			}

			written = copy_page_to_iter(buf->page, buf->offset, chars, to);
			if (unlikely(written < chars)) {
				if (!ret)
					ret = -EFAULT;
				break;
			}
			ret += chars;
			buf->offset += chars;
			buf->len -= chars;

			/* Was it a packet buffer? Clean up and exit */
			if (buf->flags & PIPE_BUF_FLAG_PACKET) {
				total_len = chars;
				buf->len = 0;
			}

			if (!buf->len) {
				pipe_buf_release(pipe, buf);
				curbuf = (curbuf + 1) & (pipe->buffers - 1);
				pipe->curbuf = curbuf;
				pipe->nrbufs = --bufs;
				do_wakeup = 1;
			}
			total_len -= chars;
			if (!total_len)
				break;	/* common path: read succeeded */
		}
		if (bufs)	/* More to do? */
			continue;
		if (!pipe->writers)
			break;
		if (!pipe->waiting_writers) {
			/* syscall merging: Usually we must not sleep
                         * if O_NONBLOCK is set, or if we got some data.
                         * But if a writer sleeps in kernel space, then
                         * we can wait for that data without violating POSIX.
                         */
			if (ret)
				break;
			if (filp->f_flags & O_NONBLOCK) {
				ret = -EAGAIN;
				break;
			}
		}
		if (signal_pending(current)) {
			if (!ret)
				ret = -ERESTARTSYS;
			break;
		}
		if (do_wakeup) {
			wake_up_interruptible_sync_poll(&pipe->wait, POLLOUT | POLLWRNORM);
 			kill_fasync(&pipe->fasync_writers, SIGIO, POLL_OUT);
		}
		pipe_wait(pipe);
	}
	__pipe_unlock(pipe);

	/* Signal writers asynchronously that there is more room. */
	if (do_wakeup) {
		wake_up_interruptible_sync_poll(&pipe->wait, POLLOUT | POLLWRNORM);
		kill_fasync(&pipe->fasync_writers, SIGIO, POLL_OUT);
	}
	if (ret > 0)
		file_accessed(filp);
	return ret;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds
108
24.22%
5
12.50%
Manfred Spraul
103
23.09%
1
2.50%
Linus Torvalds (pre-git)
101
22.65%
13
32.50%
Al Viro
36
8.07%
7
17.50%
Ingo Molnar
32
7.17%
3
7.50%
Jens Axboe
21
4.71%
4
10.00%
Dave Jones
16
3.59%
1
2.50%
Badari Pulavarty
12
2.69%
1
2.50%
Andrew Morton
7
1.57%
1
2.50%
Davide Libenzi
6
1.35%
1
2.50%
Miklos Szeredi
2
0.45%
2
5.00%
Nicolas Kaiser
2
0.45%
1
2.50%
Total
446
100.00%
40
100.00%



static inline int is_packetized(struct file *file)
{
	return (file->f_flags & O_DIRECT) != 0;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds
23
100.00%
1
100.00%
Total
23
100.00%
1
100.00%


static ssize_t

pipe_write(struct kiocb *iocb, struct iov_iter *from)
{
	struct file *filp = iocb->ki_filp;
	struct pipe_inode_info *pipe = filp->private_data;
	ssize_t ret = 0;
	int do_wakeup = 0;
	size_t total_len = iov_iter_count(from);
	ssize_t chars;

	/* Null write succeeds. */
	if (unlikely(total_len == 0))
		return 0;

	__pipe_lock(pipe);

	if (!pipe->readers) {
		send_sig(SIGPIPE, current, 0);
		ret = -EPIPE;
		goto out;
	}

	/* We try to merge small writes */
	chars = total_len & (PAGE_SIZE-1); /* size of the last buffer */
	if (pipe->nrbufs && chars != 0) {
		int lastbuf = (pipe->curbuf + pipe->nrbufs - 1) &
							(pipe->buffers - 1);
		struct pipe_buffer *buf = pipe->bufs + lastbuf;
		int offset = buf->offset + buf->len;

		if (buf->ops->can_merge && offset + chars <= PAGE_SIZE) {
			ret = pipe_buf_confirm(pipe, buf);
			if (ret)
				goto out;

			ret = copy_page_from_iter(buf->page, offset, chars, from);
			if (unlikely(ret < chars)) {
				ret = -EFAULT;
				goto out;
			}
			do_wakeup = 1;
			buf->len += ret;
			if (!iov_iter_count(from))
				goto out;
		}
	}

	for (;;) {
		int bufs;

		if (!pipe->readers) {
			send_sig(SIGPIPE, current, 0);
			if (!ret)
				ret = -EPIPE;
			break;
		}
		bufs = pipe->nrbufs;
		if (bufs < pipe->buffers) {
			int newbuf = (pipe->curbuf + bufs) & (pipe->buffers-1);
			struct pipe_buffer *buf = pipe->bufs + newbuf;
			struct page *page = pipe->tmp_page;
			int copied;

			if (!page) {
				page = alloc_page(GFP_HIGHUSER | __GFP_ACCOUNT);
				if (unlikely(!page)) {
					ret = ret ? : -ENOMEM;
					break;
				}
				pipe->tmp_page = page;
			}
			/* Always wake up, even if the copy fails. Otherwise
                         * we lock up (O_NONBLOCK-)readers that sleep due to
                         * syscall merging.
                         * FIXME! Is this really true?
                         */
			do_wakeup = 1;
			copied = copy_page_from_iter(page, 0, PAGE_SIZE, from);
			if (unlikely(copied < PAGE_SIZE && iov_iter_count(from))) {
				if (!ret)
					ret = -EFAULT;
				break;
			}
			ret += copied;

			/* Insert it into the buffer array */
			buf->page = page;
			buf->ops = &anon_pipe_buf_ops;
			buf->offset = 0;
			buf->len = copied;
			buf->flags = 0;
			if (is_packetized(filp)) {
				buf->ops = &packet_pipe_buf_ops;
				buf->flags = PIPE_BUF_FLAG_PACKET;
			}
			pipe->nrbufs = ++bufs;
			pipe->tmp_page = NULL;

			if (!iov_iter_count(from))
				break;
		}
		if (bufs < pipe->buffers)
			continue;
		if (filp->f_flags & O_NONBLOCK) {
			if (!ret)
				ret = -EAGAIN;
			break;
		}
		if (signal_pending(current)) {
			if (!ret)
				ret = -ERESTARTSYS;
			break;
		}
		if (do_wakeup) {
			wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLRDNORM);
			kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN);
			do_wakeup = 0;
		}
		pipe->waiting_writers++;
		pipe_wait(pipe);
		pipe->waiting_writers--;
	}
out:
	__pipe_unlock(pipe);
	if (do_wakeup) {
		wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLRDNORM);
		kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN);
	}
	if (ret > 0 && sb_start_write_trylock(file_inode(filp)->i_sb)) {
		int err = file_update_time(filp);
		if (err)
			ret = err;
		sb_end_write(file_inode(filp)->i_sb);
	}
	return ret;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds
229
32.67%
6
13.64%
Manfred Spraul
116
16.55%
1
2.27%
Linus Torvalds (pre-git)
74
10.56%
13
29.55%
Al Viro
63
8.99%
5
11.36%
Ingo Molnar
43
6.13%
3
6.82%
Jens Axboe
35
4.99%
4
9.09%
Andrea Arcangeli
23
3.28%
1
2.27%
Prasanna Meda
23
3.28%
1
2.27%
Dmitriy Monakhov
20
2.85%
1
2.27%
Dave Jones
16
2.28%
1
2.27%
Andrew Morton
16
2.28%
1
2.27%
Josef Bacik
13
1.85%
1
2.27%
Badari Pulavarty
12
1.71%
1
2.27%
Davide Libenzi
6
0.86%
1
2.27%
Eric Biggers
5
0.71%
1
2.27%
Miklos Szeredi
3
0.43%
1
2.27%
Vladimir Davydov
2
0.29%
1
2.27%
Christoph Hellwig
2
0.29%
1
2.27%
Total
701
100.00%
44
100.00%



static long pipe_ioctl(struct file *filp, unsigned int cmd, unsigned long arg)
{
	struct pipe_inode_info *pipe = filp->private_data;
	int count, buf, nrbufs;

	switch (cmd) {
		case FIONREAD:
			__pipe_lock(pipe);
			count = 0;
			buf = pipe->curbuf;
			nrbufs = pipe->nrbufs;
			while (--nrbufs >= 0) {
				count += pipe->bufs[buf].len;
				buf = (buf+1) & (pipe->buffers - 1);
			}
			__pipe_unlock(pipe);

			return put_user(count, (int __user *)arg);
		default:
			return -ENOIOCTLCMD;
	}
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds
67
54.03%
2
16.67%
Linus Torvalds (pre-git)
39
31.45%
3
25.00%
Al Viro
8
6.45%
3
25.00%
Ingo Molnar
4
3.23%
1
8.33%
Jens Axboe
3
2.42%
1
8.33%
Andi Kleen
2
1.61%
1
8.33%
Will Deacon
1
0.81%
1
8.33%
Total
124
100.00%
12
100.00%

/* No kernel lock held - fine */

static unsigned int

pipe_poll(struct file *filp, poll_table *wait)
{
	unsigned int mask;
	struct pipe_inode_info *pipe = filp->private_data;
	int nrbufs;

	poll_wait(filp, &pipe->wait, wait);

	/* Reading only -- no need for acquiring the semaphore.  */
	nrbufs = pipe->nrbufs;
	mask = 0;
	if (filp->f_mode & FMODE_READ) {
		mask = (nrbufs > 0) ? POLLIN | POLLRDNORM : 0;
		if (!pipe->writers && filp->f_version != pipe->w_counter)
			mask |= POLLHUP;
	}

	if (filp->f_mode & FMODE_WRITE) {
		mask |= (nrbufs < pipe->buffers) ? POLLOUT | POLLWRNORM : 0;
		/*
                 * Most Unices do not set POLLERR for FIFOs but on Linux they
                 * behave exactly like pipes for poll().
                 */
		if (!pipe->readers)
			mask |= POLLERR;
	}

	return mask;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds (pre-git)
63
45.32%
8
50.00%
Linus Torvalds
55
39.57%
2
12.50%
Ingo Molnar
14
10.07%
2
12.50%
Jens Axboe
3
2.16%
1
6.25%
Al Viro
3
2.16%
2
12.50%
Pekka J Enberg
1
0.72%
1
6.25%
Total
139
100.00%
16
100.00%



static void put_pipe_info(struct inode *inode, struct pipe_inode_info *pipe)
{
	int kill = 0;

	spin_lock(&inode->i_lock);
	if (!--pipe->files) {
		inode->i_pipe = NULL;
		kill = 1;
	}
	spin_unlock(&inode->i_lock);

	if (kill)
		free_pipe_info(pipe);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds
66
100.00%
1
100.00%
Total
66
100.00%
1
100.00%


static int

pipe_release(struct inode *inode, struct file *file)
{
	struct pipe_inode_info *pipe = file->private_data;

	__pipe_lock(pipe);
	if (file->f_mode & FMODE_READ)
		pipe->readers--;
	if (file->f_mode & FMODE_WRITE)
		pipe->writers--;

	if (pipe->readers || pipe->writers) {
		wake_up_interruptible_sync_poll(&pipe->wait, POLLIN | POLLOUT | POLLRDNORM | POLLWRNORM | POLLERR | POLLHUP);
		kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN);
		kill_fasync(&pipe->fasync_writers, SIGIO, POLL_OUT);
	}
	__pipe_unlock(pipe);

	put_pipe_info(inode, pipe);
	return 0;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
36
28.35%
3
23.08%
Ingo Molnar
30
23.62%
2
15.38%
Dave Jones
23
18.11%
1
7.69%
Linus Torvalds (pre-git)
20
15.75%
4
30.77%
Linus Torvalds
13
10.24%
2
15.38%
Davide Libenzi
5
3.94%
1
7.69%
Total
127
100.00%
13
100.00%


static int

pipe_fasync(int fd, struct file *filp, int on)
{
	struct pipe_inode_info *pipe = filp->private_data;
	int retval = 0;

	__pipe_lock(pipe);
	if (filp->f_mode & FMODE_READ)
		retval = fasync_helper(fd, filp, on, &pipe->fasync_readers);
	if ((filp->f_mode & FMODE_WRITE) && retval >= 0) {
		retval = fasync_helper(fd, filp, on, &pipe->fasync_writers);
		if (retval < 0 && (filp->f_mode & FMODE_READ))
			/* this can happen only if on == T */
			fasync_helper(-1, filp, 0, &pipe->fasync_readers);
	}
	__pipe_unlock(pipe);
	return retval;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Dave Jones
58
44.62%
1
10.00%
Al Viro
34
26.15%
4
40.00%
Oleg Nesterov
24
18.46%
1
10.00%
Ingo Molnar
10
7.69%
2
20.00%
Linus Torvalds (pre-git)
4
3.08%
2
20.00%
Total
130
100.00%
10
100.00%



static unsigned long account_pipe_buffers(struct user_struct *user,
                                 unsigned long old, unsigned long new)
{
	return atomic_long_add_return(new - old, &user->pipe_bufs);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Willy Tarreau
26
78.79%
1
33.33%
Michael Kerrisk
7
21.21%
2
66.67%
Total
33
100.00%
3
100.00%



static bool too_many_pipe_buffers_soft(unsigned long user_bufs)
{
	return pipe_user_pages_soft && user_bufs >= pipe_user_pages_soft;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Willy Tarreau
13
76.47%
1
50.00%
Michael Kerrisk
4
23.53%
1
50.00%
Total
17
100.00%
2
100.00%



static bool too_many_pipe_buffers_hard(unsigned long user_bufs)
{
	return pipe_user_pages_hard && user_bufs >= pipe_user_pages_hard;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Willy Tarreau
13
76.47%
1
50.00%
Michael Kerrisk
4
23.53%
1
50.00%
Total
17
100.00%
2
100.00%



struct pipe_inode_info *alloc_pipe_info(void)
{
	struct pipe_inode_info *pipe;
	unsigned long pipe_bufs = PIPE_DEF_BUFFERS;
	struct user_struct *user = get_current_user();
	unsigned long user_bufs;

	pipe = kzalloc(sizeof(struct pipe_inode_info), GFP_KERNEL_ACCOUNT);
	if (pipe == NULL)
		goto out_free_uid;

	if (pipe_bufs * PAGE_SIZE > pipe_max_size && !capable(CAP_SYS_RESOURCE))
		pipe_bufs = pipe_max_size >> PAGE_SHIFT;

	user_bufs = account_pipe_buffers(user, 0, pipe_bufs);

	if (too_many_pipe_buffers_soft(user_bufs)) {
		user_bufs = account_pipe_buffers(user, pipe_bufs, 1);
		pipe_bufs = 1;
	}

	if (too_many_pipe_buffers_hard(user_bufs))
		goto out_revert_acct;

	pipe->bufs = kcalloc(pipe_bufs, sizeof(struct pipe_buffer),
			     GFP_KERNEL_ACCOUNT);

	if (pipe->bufs) {
		init_waitqueue_head(&pipe->wait);
		pipe->r_counter = pipe->w_counter = 1;
		pipe->buffers = pipe_bufs;
		pipe->user = user;
		mutex_init(&pipe->mutex);
		return pipe;
	}

out_revert_acct:
	(void) account_pipe_buffers(user, pipe_bufs, 0);
	kfree(pipe);
out_free_uid:
	free_uid(user);
	return NULL;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Michael Kerrisk
95
44.39%
4
33.33%
Ingo Molnar
48
22.43%
2
16.67%
Jens Axboe
29
13.55%
1
8.33%
Willy Tarreau
24
11.21%
1
8.33%
Al Viro
13
6.07%
3
25.00%
Vladimir Davydov
5
2.34%
1
8.33%
Total
214
100.00%
12
100.00%



void free_pipe_info(struct pipe_inode_info *pipe)
{
	int i;

	(void) account_pipe_buffers(pipe->user, pipe->buffers, 0);
	free_uid(pipe->user);
	for (i = 0; i < pipe->buffers; i++) {
		struct pipe_buffer *buf = pipe->bufs + i;
		if (buf->ops)
			pipe_buf_release(pipe, buf);
	}
	if (pipe->tmp_page)
		__free_page(pipe->tmp_page);
	kfree(pipe->bufs);
	kfree(pipe);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds
60
58.82%
5
38.46%
Willy Tarreau
18
17.65%
1
7.69%
Jens Axboe
11
10.78%
2
15.38%
Ingo Molnar
6
5.88%
1
7.69%
Michael Kerrisk
5
4.90%
2
15.38%
Miklos Szeredi
1
0.98%
1
7.69%
Al Viro
1
0.98%
1
7.69%
Total
102
100.00%
13
100.00%


static struct vfsmount *pipe_mnt __read_mostly;

/*
 * pipefs_dname() is called from d_path().
 */


static char *pipefs_dname(struct dentry *dentry, char *buffer, int buflen)
{
	return dynamic_dname(dentry, buffer, buflen, "pipe:[%lu]",
				d_inode(dentry)->i_ino);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Eric Dumazet
35
92.11%
1
50.00%
David Howells
3
7.89%
1
50.00%
Total
38
100.00%
2
100.00%


static const struct dentry_operations pipefs_dentry_operations = {
	.d_dname	= pipefs_dname,
};



static struct inode * get_pipe_inode(void)
{
	struct inode *inode = new_inode_pseudo(pipe_mnt->mnt_sb);
	struct pipe_inode_info *pipe;

	if (!inode)
		goto fail_inode;

	inode->i_ino = get_next_ino();

	pipe = alloc_pipe_info();
	if (!pipe)
		goto fail_iput;

	inode->i_pipe = pipe;
	pipe->files = 2;
	pipe->readers = pipe->writers = 1;
	inode->i_fop = &pipefifo_fops;

	/*
         * Mark the inode dirty from the very beginning,
         * that way it will never be moved to the dirty
         * list because "mark_inode_dirty()" will think
         * that it already _is_ on the dirty list.
         */
	inode->i_state = I_DIRTY;
	inode->i_mode = S_IFIFO | S_IRUSR | S_IWUSR;
	inode->i_uid = current_fsuid();
	inode->i_gid = current_fsgid();
	inode->i_atime = inode->i_mtime = inode->i_ctime = current_time(inode);

	return inode;

fail_iput:
	iput(inode);

fail_inode:
	return NULL;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds (pre-git)
97
65.99%
4
26.67%
Ingo Molnar
21
14.29%
3
20.00%
Al Viro
8
5.44%
3
20.00%
Christoph Hellwig
7
4.76%
1
6.67%
Linus Torvalds
5
3.40%
1
6.67%
Deepa Dinamani
4
2.72%
1
6.67%
David Howells
4
2.72%
1
6.67%
Eric Dumazet
1
0.68%
1
6.67%
Total
147
100.00%
15
100.00%



int create_pipe_files(struct file **res, int flags)
{
	int err;
	struct inode *inode = get_pipe_inode();
	struct file *f;
	struct path path;
	static struct qstr name = { .name = "" };

	if (!inode)
		return -ENFILE;

	err = -ENOMEM;
	path.dentry = d_alloc_pseudo(pipe_mnt->mnt_sb, &name);
	if (!path.dentry)
		goto err_inode;
	path.mnt = mntget(pipe_mnt);

	d_instantiate(path.dentry, inode);

	f = alloc_file(&path, FMODE_WRITE, &pipefifo_fops);
	if (IS_ERR(f)) {
		err = PTR_ERR(f);
		goto err_dentry;
	}

	f->f_flags = O_WRONLY | (flags & (O_NONBLOCK | O_DIRECT));
	f->private_data = inode->i_pipe;

	res[0] = alloc_file(&path, FMODE_READ, &pipefifo_fops);
	if (IS_ERR(res[0])) {
		err = PTR_ERR(res[0]);
		goto err_file;
	}

	path_get(&path);
	res[0]->private_data = inode->i_pipe;
	res[0]->f_flags = O_RDONLY | (flags & O_NONBLOCK);
	res[1] = f;
	return 0;

err_file:
	put_filp(f);
err_dentry:
	free_pipe_info(inode->i_pipe);
	path_put(&path);
	return err;

err_inode:
	free_pipe_info(inode->i_pipe);
	iput(inode);
	return err;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
127
44.88%
6
26.09%
Linus Torvalds (pre-git)
46
16.25%
8
34.78%
Andi Kleen
44
15.55%
1
4.35%
Eric Biggers
21
7.42%
1
4.35%
Dave Hansen
16
5.65%
1
4.35%
Eric Dumazet
10
3.53%
2
8.70%
Ulrich Drepper
8
2.83%
1
4.35%
Anatol Pomozov
6
2.12%
1
4.35%
Linus Torvalds
4
1.41%
1
4.35%
Nicholas Piggin
1
0.35%
1
4.35%
Total
283
100.00%
23
100.00%



static int __do_pipe_flags(int *fd, struct file **files, int flags)
{
	int error;
	int fdw, fdr;

	if (flags & ~(O_CLOEXEC | O_NONBLOCK | O_DIRECT))
		return -EINVAL;

	error = create_pipe_files(files, flags);
	if (error)
		return error;

	error = get_unused_fd_flags(flags);
	if (error < 0)
		goto err_read_pipe;
	fdr = error;

	error = get_unused_fd_flags(flags);
	if (error < 0)
		goto err_fdr;
	fdw = error;

	audit_fd_pair(fdr, fdw);
	fd[0] = fdr;
	fd[1] = fdw;
	return 0;

 err_fdr:
	put_unused_fd(fdr);
 err_read_pipe:
	fput(files[0]);
	fput(files[1]);
	return error;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Andi Kleen
55
36.18%
1
7.69%
Linus Torvalds (pre-git)
36
23.68%
6
46.15%
Al Viro
32
21.05%
3
23.08%
Ulrich Drepper
27
17.76%
2
15.38%
Linus Torvalds
2
1.32%
1
7.69%
Total
152
100.00%
13
100.00%



int do_pipe_flags(int *fd, int flags)
{
	struct file *files[2];
	int error = __do_pipe_flags(fd, files, flags);
	if (!error) {
		fd_install(fd[0], files[0]);
		fd_install(fd[1], files[1]);
	}
	return error;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
68
100.00%
1
100.00%
Total
68
100.00%
1
100.00%

/*
 * sys_pipe() is the normal C calling standard for creating
 * a pipe. It's not the way Unix traditionally does this, though.
 */

SYSCALL_DEFINE2(pipe2, int __user *, fildes, int, flags)
{
	struct file *files[2];
	int fd[2];
	int error;

	error = __do_pipe_flags(fd, files, flags);
	if (!error) {
		if (unlikely(copy_to_user(fildes, fd, sizeof(fd)))) {
			fput(files[0]);
			fput(files[1]);
			put_unused_fd(fd[0]);
			put_unused_fd(fd[1]);
			error = -EFAULT;
		} else {
			fd_install(fd[0], files[0]);
			fd_install(fd[1], files[1]);
		}
	}
	return error;
}


SYSCALL_DEFINE1(pipe, int __user *, fildes)
{
	return sys_pipe2(fildes, 0);
}



static int wait_for_partner(struct pipe_inode_info *pipe, unsigned int *cnt)
{
	int cur = *cnt;	

	while (cur == *cnt) {
		pipe_wait(pipe);
		if (signal_pending(current))
			break;
	}
	return cur == *cnt ? -ERESTARTSYS : 0;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
55
100.00%
2
100.00%
Total
55
100.00%
2
100.00%



static void wake_up_partner(struct pipe_inode_info *pipe)
{
	wake_up_interruptible(&pipe->wait);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
19
100.00%
2
100.00%
Total
19
100.00%
2
100.00%



static int fifo_open(struct inode *inode, struct file *filp)
{
	struct pipe_inode_info *pipe;
	bool is_pipe = inode->i_sb->s_magic == PIPEFS_MAGIC;
	int ret;

	filp->f_version = 0;

	spin_lock(&inode->i_lock);
	if (inode->i_pipe) {
		pipe = inode->i_pipe;
		pipe->files++;
		spin_unlock(&inode->i_lock);
	} else {
		spin_unlock(&inode->i_lock);
		pipe = alloc_pipe_info();
		if (!pipe)
			return -ENOMEM;
		pipe->files = 1;
		spin_lock(&inode->i_lock);
		if (unlikely(inode->i_pipe)) {
			inode->i_pipe->files++;
			spin_unlock(&inode->i_lock);
			free_pipe_info(pipe);
			pipe = inode->i_pipe;
		} else {
			inode->i_pipe = pipe;
			spin_unlock(&inode->i_lock);
		}
	}
	filp->private_data = pipe;
	/* OK, we have a pipe and it's pinned down */

	__pipe_lock(pipe);

	/* We can only do regular read/write on fifos */
	filp->f_mode &= (FMODE_READ | FMODE_WRITE);

	switch (filp->f_mode) {
	case FMODE_READ:
	/*
         *  O_RDONLY
         *  POSIX.1 says that O_NONBLOCK means return with the FIFO
         *  opened, even when there is no process writing the FIFO.
         */
		pipe->r_counter++;
		if (pipe->readers++ == 0)
			wake_up_partner(pipe);

		if (!is_pipe && !pipe->writers) {
			if ((filp->f_flags & O_NONBLOCK)) {
				/* suppress POLLHUP until we have
                                 * seen a writer */
				filp->f_version = pipe->w_counter;
			} else {
				if (wait_for_partner(pipe, &pipe->w_counter))
					goto err_rd;
			}
		}
		break;
	
	case FMODE_WRITE:
	/*
         *  O_WRONLY
         *  POSIX.1 says that O_NONBLOCK means return -1 with
         *  errno=ENXIO when there is no process reading the FIFO.
         */
		ret = -ENXIO;
		if (!is_pipe && (filp->f_flags & O_NONBLOCK) && !pipe->readers)
			goto err;

		pipe->w_counter++;
		if (!pipe->writers++)
			wake_up_partner(pipe);

		if (!is_pipe && !pipe->readers) {
			if (wait_for_partner(pipe, &pipe->r_counter))
				goto err_wr;
		}
		break;
	
	case FMODE_READ | FMODE_WRITE:
	/*
         *  O_RDWR
         *  POSIX.1 leaves this case "undefined" when O_NONBLOCK is set.
         *  This implementation will NEVER block on a O_RDWR open, since
         *  the process can at least talk to itself.
         */

		pipe->readers++;
		pipe->writers++;
		pipe->r_counter++;
		pipe->w_counter++;
		if (pipe->readers == 1 || pipe->writers == 1)
			wake_up_partner(pipe);
		break;

	default:
		ret = -EINVAL;
		goto err;
	}

	/* Ok! */
	__pipe_unlock(pipe);
	return 0;

err_rd:
	if (!--pipe->readers)
		wake_up_interruptible(&pipe->wait);
	ret = -ERESTARTSYS;
	goto err;

err_wr:
	if (!--pipe->writers)
		wake_up_interruptible(&pipe->wait);
	ret = -ERESTARTSYS;
	goto err;

err:
	__pipe_unlock(pipe);

	put_pipe_info(inode, pipe);
	return ret;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
481
99.38%
8
88.89%
Linus Torvalds
3
0.62%
1
11.11%
Total
484
100.00%
9
100.00%


const struct file_operations pipefifo_fops = {
	.open		= fifo_open,
	.llseek		= no_llseek,
	.read_iter	= pipe_read,
	.write_iter	= pipe_write,
	.poll		= pipe_poll,
	.unlocked_ioctl	= pipe_ioctl,
	.release	= pipe_release,
	.fasync		= pipe_fasync,
};

/*
 * Currently we rely on the pipe array holding a power-of-2 number
 * of pages.
 */


static inline unsigned int round_pipe_size(unsigned int size)
{
	unsigned long nr_pages;

	nr_pages = (size + PAGE_SIZE - 1) >> PAGE_SHIFT;
	return roundup_pow_of_two(nr_pages) << PAGE_SHIFT;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Michael Kerrisk
36
100.00%
1
100.00%
Total
36
100.00%
1
100.00%

/*
 * Allocate a new array of pipe buffers and copy the info over. Returns the
 * pipe size if successful, or return -ERROR on error.
 */


static long pipe_set_size(struct pipe_inode_info *pipe, unsigned long arg)
{
	struct pipe_buffer *bufs;
	unsigned int size, nr_pages;
	unsigned long user_bufs;
	long ret = 0;

	size = round_pipe_size(arg);
	nr_pages = size >> PAGE_SHIFT;

	if (!nr_pages)
		return -EINVAL;

	/*
         * If trying to increase the pipe capacity, check that an
         * unprivileged user is not trying to exceed various limits
         * (soft limit check here, hard limit check just below).
         * Decreasing the pipe capacity is always permitted, even
         * if the user is currently over a limit.
         */
	if (nr_pages > pipe->buffers &&
			size > pipe_max_size && !capable(CAP_SYS_RESOURCE))
		return -EPERM;

	user_bufs = account_pipe_buffers(pipe->user, pipe->buffers, nr_pages);

	if (nr_pages > pipe->buffers &&
			(too_many_pipe_buffers_hard(user_bufs) ||
			 too_many_pipe_buffers_soft(user_bufs)) &&
			!capable(CAP_SYS_RESOURCE) && !capable(CAP_SYS_ADMIN)) {
		ret = -EPERM;
		goto out_revert_acct;
	}

	/*
         * We can shrink the pipe, if arg >= pipe->nrbufs. Since we don't
         * expect a lot of shrink+grow operations, just free and allocate
         * again like we would do for growing. If the pipe currently
         * contains more buffers than arg, then return busy.
         */
	if (nr_pages < pipe->nrbufs) {
		ret = -EBUSY;
		goto out_revert_acct;
	}

	bufs = kcalloc(nr_pages, sizeof(*bufs),
		       GFP_KERNEL_ACCOUNT | __GFP_NOWARN);
	if (unlikely(!bufs)) {
		ret = -ENOMEM;
		goto out_revert_acct;
	}

	/*
         * The pipe array wraps around, so just start the new one at zero
         * and adjust the indexes.
         */
	if (pipe->nrbufs) {
		unsigned int tail;
		unsigned int head;

		tail = pipe->curbuf + pipe->nrbufs;
		if (tail < pipe->buffers)
			tail = 0;
		else
			tail &= (pipe->buffers - 1);

		head = pipe->nrbufs - tail;
		if (head)
			memcpy(bufs, pipe->bufs + pipe->curbuf, head * sizeof(struct pipe_buffer));
		if (tail)
			memcpy(bufs + head, pipe->bufs, tail * sizeof(struct pipe_buffer));
	}

	pipe->curbuf = 0;
	kfree(pipe->bufs);
	pipe->bufs = bufs;
	pipe->buffers = nr_pages;
	return nr_pages * PAGE_SIZE;

out_revert_acct:
	(void) account_pipe_buffers(pipe->user, nr_pages, pipe->buffers);
	return ret;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Jens Axboe
158
45.40%
2
25.00%
Michael Kerrisk
155
44.54%
3
37.50%
Miklos Szeredi
30
8.62%
1
12.50%
Sasha Levin
4
1.15%
1
12.50%
Vladimir Davydov
1
0.29%
1
12.50%
Total
348
100.00%
8
100.00%

/*
 * This should work even if CONFIG_PROC_FS isn't set, as proc_dointvec_minmax
 * will return an error.
 */


int pipe_proc_fn(struct ctl_table *table, int write, void __user *buf,
		 size_t *lenp, loff_t *ppos)
{
	int ret;

	ret = proc_dointvec_minmax(table, write, buf, lenp, ppos);
	if (ret < 0 || !write)
		return ret;

	pipe_max_size = round_pipe_size(pipe_max_size);
	return ret;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Jens Axboe
66
100.00%
1
100.00%
Total
66
100.00%
1
100.00%

/*
 * After the inode slimming patch, i_pipe/i_bdev/i_cdev share the same
 * location, so checking ->i_pipe is not enough to verify that this is a
 * pipe.
 */


struct pipe_inode_info *get_pipe_info(struct file *file)
{
	return file->f_op == &pipefifo_fops ? file->private_data : NULL;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds
19
73.08%
1
50.00%
Al Viro
7
26.92%
1
50.00%
Total
26
100.00%
2
100.00%



long pipe_fcntl(struct file *file, unsigned int cmd, unsigned long arg)
{
	struct pipe_inode_info *pipe;
	long ret;

	pipe = get_pipe_info(file);
	if (!pipe)
		return -EBADF;

	__pipe_lock(pipe);

	switch (cmd) {
	case F_SETPIPE_SZ:
		ret = pipe_set_size(pipe, arg);
		break;
	case F_GETPIPE_SZ:
		ret = pipe->buffers * PAGE_SIZE;
		break;
	default:
		ret = -EINVAL;
		break;
	}

	__pipe_unlock(pipe);
	return ret;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Jens Axboe
87
93.55%
2
40.00%
Linus Torvalds
3
3.23%
1
20.00%
Al Viro
2
2.15%
1
20.00%
Michael Kerrisk
1
1.08%
1
20.00%
Total
93
100.00%
5
100.00%


static const struct super_operations pipefs_ops = {
	.destroy_inode = free_inode_nonrcu,
	.statfs = simple_statfs,
};

/*
 * pipefs should _never_ be mounted by userland - too much of security hassle,
 * no real gain from having the whole whorehouse mounted. So we don't need
 * any operations on the root directory. However, we need a non-trivial
 * d_name - pipe: will go nicely and kill the special-casing in procfs.
 */


static struct dentry *pipefs_mount(struct file_system_type *fs_type,
			 int flags, const char *dev_name, void *data)
{
	return mount_pseudo(fs_type, "pipe:", &pipefs_ops,
			&pipefs_dentry_operations, PIPEFS_MAGIC);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
32
78.05%
4
50.00%
Linus Torvalds (pre-git)
5
12.20%
1
12.50%
Nicholas Piggin
2
4.88%
1
12.50%
Andries E. Brouwer
1
2.44%
1
12.50%
David Howells
1
2.44%
1
12.50%
Total
41
100.00%
8
100.00%


static struct file_system_type pipe_fs_type = {
	.name		= "pipefs",
	.mount		= pipefs_mount,
	.kill_sb	= kill_anon_super,
};



static int __init init_pipe_fs(void)
{
	int err = register_filesystem(&pipe_fs_type);

	if (!err) {
		pipe_mnt = kern_mount(&pipe_fs_type);
		if (IS_ERR(pipe_mnt)) {
			err = PTR_ERR(pipe_mnt);
			unregister_filesystem(&pipe_fs_type);
		}
	}
	return err;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Linus Torvalds (pre-git)
49
84.48%
2
66.67%
Rusty Russell
9
15.52%
1
33.33%
Total
58
100.00%
3
100.00%


fs_initcall(init_pipe_fs);
Overall Contributors
Person
Tokens
Prop
Commits
CommitProp
Al Viro
1202
24.19%
27
15.52%
Linus Torvalds
751
15.11%
16
9.20%
Linus Torvalds (pre-git)
606
12.20%
42
24.14%
Jens Axboe
546
10.99%
14
8.05%
Michael Kerrisk
308
6.20%
8
4.60%
Ingo Molnar
227
4.57%
5
2.87%
Manfred Spraul
220
4.43%
1
0.57%
Miklos Szeredi
217
4.37%
6
3.45%
Dave Jones
116
2.33%
2
1.15%
Ulrich Drepper
113
2.27%
4
2.30%
Willy Tarreau
107
2.15%
1
0.57%
Andi Kleen
101
2.03%
2
1.15%
Vladimir Davydov
72
1.45%
1
0.57%
Eric Dumazet
52
1.05%
5
2.87%
Andrew Morton
34
0.68%
3
1.72%
Eric Biggers
26
0.52%
2
1.15%
Oleg Nesterov
24
0.48%
1
0.57%
Badari Pulavarty
24
0.48%
1
0.57%
Prasanna Meda
23
0.46%
1
0.57%
Andrea Arcangeli
23
0.46%
1
0.57%
Dmitriy Monakhov
20
0.40%
1
0.57%
Heiko Carstens
20
0.40%
2
1.15%
Davide Libenzi
17
0.34%
1
0.57%
Nicholas Piggin
16
0.32%
2
1.15%
Dave Hansen
16
0.32%
1
0.57%
Christoph Hellwig
15
0.30%
4
2.30%
Josef Bacik
13
0.26%
1
0.57%
Rusty Russell
9
0.18%
1
0.57%
David Howells
8
0.16%
3
1.72%
Art Haas
7
0.14%
1
0.57%
Anatol Pomozov
6
0.12%
1
0.57%
Pavel Emelyanov
5
0.10%
1
0.57%
Sasha Levin
4
0.08%
1
0.57%
Deepa Dinamani
4
0.08%
1
0.57%
Muthu Kumar
3
0.06%
1
0.57%
Randy Dunlap
3
0.06%
2
1.15%
Kirill A. Shutemov
3
0.06%
1
0.57%
Peter Zijlstra
2
0.04%
1
0.57%
Nicolas Kaiser
2
0.04%
1
0.57%
Will Deacon
1
0.02%
1
0.57%
Pekka J Enberg
1
0.02%
1
0.57%
Andries E. Brouwer
1
0.02%
1
0.57%
Kent Overstreet
1
0.02%
1
0.57%
Total
4969
100.00%
174
100.00%
Directory: fs

Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.