aboutsummaryrefslogtreecommitdiffstats
path: root/fs/splice.c
diff options
context:
space:
mode:
Diffstat (limited to 'fs/splice.c')
-rw-r--r--fs/splice.c16
1 files changed, 12 insertions, 4 deletions
diff --git a/fs/splice.c b/fs/splice.c
index 26f5f7ecee5c..9f796b1034d1 100644
--- a/fs/splice.c
+++ b/fs/splice.c
@@ -187,7 +187,9 @@ static ssize_t move_to_pipe(struct inode *inode, struct page **pages,
187 } 187 }
188 188
189 if (do_wakeup) { 189 if (do_wakeup) {
190 wake_up_interruptible_sync(PIPE_WAIT(*inode)); 190 smp_mb();
191 if (waitqueue_active(PIPE_WAIT(*inode)))
192 wake_up_interruptible_sync(PIPE_WAIT(*inode));
191 kill_fasync(PIPE_FASYNC_READERS(*inode), SIGIO, 193 kill_fasync(PIPE_FASYNC_READERS(*inode), SIGIO,
192 POLL_IN); 194 POLL_IN);
193 do_wakeup = 0; 195 do_wakeup = 0;
@@ -201,7 +203,9 @@ static ssize_t move_to_pipe(struct inode *inode, struct page **pages,
201 mutex_unlock(PIPE_MUTEX(*inode)); 203 mutex_unlock(PIPE_MUTEX(*inode));
202 204
203 if (do_wakeup) { 205 if (do_wakeup) {
204 wake_up_interruptible(PIPE_WAIT(*inode)); 206 smp_mb();
207 if (waitqueue_active(PIPE_WAIT(*inode)))
208 wake_up_interruptible(PIPE_WAIT(*inode));
205 kill_fasync(PIPE_FASYNC_READERS(*inode), SIGIO, POLL_IN); 209 kill_fasync(PIPE_FASYNC_READERS(*inode), SIGIO, POLL_IN);
206 } 210 }
207 211
@@ -600,7 +604,9 @@ static ssize_t move_from_pipe(struct inode *inode, struct file *out,
600 } 604 }
601 605
602 if (do_wakeup) { 606 if (do_wakeup) {
603 wake_up_interruptible_sync(PIPE_WAIT(*inode)); 607 smp_mb();
608 if (waitqueue_active(PIPE_WAIT(*inode)))
609 wake_up_interruptible_sync(PIPE_WAIT(*inode));
604 kill_fasync(PIPE_FASYNC_WRITERS(*inode),SIGIO,POLL_OUT); 610 kill_fasync(PIPE_FASYNC_WRITERS(*inode),SIGIO,POLL_OUT);
605 do_wakeup = 0; 611 do_wakeup = 0;
606 } 612 }
@@ -611,7 +617,9 @@ static ssize_t move_from_pipe(struct inode *inode, struct file *out,
611 mutex_unlock(PIPE_MUTEX(*inode)); 617 mutex_unlock(PIPE_MUTEX(*inode));
612 618
613 if (do_wakeup) { 619 if (do_wakeup) {
614 wake_up_interruptible(PIPE_WAIT(*inode)); 620 smp_mb();
621 if (waitqueue_active(PIPE_WAIT(*inode)))
622 wake_up_interruptible(PIPE_WAIT(*inode));
615 kill_fasync(PIPE_FASYNC_WRITERS(*inode), SIGIO, POLL_OUT); 623 kill_fasync(PIPE_FASYNC_WRITERS(*inode), SIGIO, POLL_OUT);
616 } 624 }
617 625