diff options
| author | Thomas Gleixner <tglx@linutronix.de> | 2009-05-20 09:02:28 +0200 | 
|---|---|---|
| committer | Thomas Gleixner <tglx@linutronix.de> | 2009-05-20 09:02:28 +0200 | 
| commit | 521c180874dae86f675d23c4eade4dba8b1f2cc8 (patch) | |
| tree | 7509303da3a9a1b40a26f6811f321c89cd31737b /fs/pipe.c | |
| parent | f1a11e0576c7a73d759d05d776692b2b2d37172b (diff) | |
| parent | 64d1304a64477629cb16b75491a77bafe6f86963 (diff) | |
Merge branch 'core/urgent' into core/futexes
Merge reason: this branch was on an pre -rc1 base, merge it up to -rc6+
              to get the latest upstream fixes.
Conflicts:
	kernel/futex.c
Signed-off-by: Thomas Gleixner <tglx@linutronix.de>
Diffstat (limited to 'fs/pipe.c')
| -rw-r--r-- | fs/pipe.c | 42 | 
1 files changed, 38 insertions, 4 deletions
diff --git a/fs/pipe.c b/fs/pipe.c index 4af7aa52181..13414ec45b8 100644 --- a/fs/pipe.c +++ b/fs/pipe.c @@ -37,6 +37,42 @@   * -- Manfred Spraul <manfred@colorfullife.com> 2002-05-09   */ +static void pipe_lock_nested(struct pipe_inode_info *pipe, int subclass) +{ +	if (pipe->inode) +		mutex_lock_nested(&pipe->inode->i_mutex, subclass); +} + +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); +} +EXPORT_SYMBOL(pipe_lock); + +void pipe_unlock(struct pipe_inode_info *pipe) +{ +	if (pipe->inode) +		mutex_unlock(&pipe->inode->i_mutex); +} +EXPORT_SYMBOL(pipe_unlock); + +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_CHILD); +		pipe_lock_nested(pipe1, I_MUTEX_PARENT); +	} +} +  /* Drop the inode semaphore and wait for a pipe event, atomically */  void pipe_wait(struct pipe_inode_info *pipe)  { @@ -47,12 +83,10 @@ void pipe_wait(struct pipe_inode_info *pipe)  	 * is considered a noninteractive wait:  	 */  	prepare_to_wait(&pipe->wait, &wait, TASK_INTERRUPTIBLE); -	if (pipe->inode) -		mutex_unlock(&pipe->inode->i_mutex); +	pipe_unlock(pipe);  	schedule();  	finish_wait(&pipe->wait, &wait); -	if (pipe->inode) -		mutex_lock(&pipe->inode->i_mutex); +	pipe_lock(pipe);  }  static int  | 
