diff --git a/arch/arm64/configs/gki_defconfig b/arch/arm64/configs/gki_defconfig index 9e75fba692ad..92175e738c81 100644 --- a/arch/arm64/configs/gki_defconfig +++ b/arch/arm64/configs/gki_defconfig @@ -469,6 +469,7 @@ CONFIG_USB_ANNOUNCE_NEW_DEVICES=y CONFIG_USB_OTG=y CONFIG_USB_XHCI_HCD=y CONFIG_USB_EHCI_HCD=y +CONFIG_USB_EHCI_ROOT_HUB_TT=y CONFIG_USB_EHCI_HCD_PLATFORM=y CONFIG_USB_ACM=y CONFIG_USB_STORAGE=y diff --git a/arch/x86/configs/gki_defconfig b/arch/x86/configs/gki_defconfig index c4f89cd04566..65d05fc15038 100644 --- a/arch/x86/configs/gki_defconfig +++ b/arch/x86/configs/gki_defconfig @@ -421,6 +421,7 @@ CONFIG_USB_HIDDEV=y CONFIG_USB_ANNOUNCE_NEW_DEVICES=y CONFIG_USB_XHCI_HCD=y CONFIG_USB_EHCI_HCD=y +CONFIG_USB_EHCI_ROOT_HUB_TT=y CONFIG_USB_EHCI_HCD_PLATFORM=y CONFIG_USB_ACM=y CONFIG_USB_STORAGE=y diff --git a/fs/pipe.c b/fs/pipe.c index 37c9d399258a..6f5f97c0fdee 100644 --- a/fs/pipe.c +++ b/fs/pipe.c @@ -406,7 +406,7 @@ pipe_write(struct kiocb *iocb, struct iov_iter *from) ssize_t ret = 0; size_t total_len = iov_iter_count(from); ssize_t chars; - bool do_wakeup = false; + bool was_empty = false; bool wake_next_writer = false; /* Null write succeeds. */ @@ -429,18 +429,18 @@ pipe_write(struct kiocb *iocb, struct iov_iter *from) #endif /* - * Wake up readers if the pipe was written to. Regardless - * of whether it was empty or not. Otherwise, threads - * waiting with EPOLLET will hang until the pipe is emptied. + * Epoll nonsensically wants a wakeup whether the pipe + * was already empty or not. * - * If pipe wasn't empty we try to merge new data into + * If it wasn't empty we try to merge new data into * the last buffer. * * That naturally merges small writes, but it also - * page-aligs the rest of the writes for large writes + * page-aligns the rest of the writes for large writes * spanning multiple pages. */ head = pipe->head; + was_empty = true; chars = total_len & (PAGE_SIZE-1); if (chars && !pipe_empty(head, pipe->tail)) { unsigned int mask = pipe->ring_size - 1; @@ -460,7 +460,6 @@ pipe_write(struct kiocb *iocb, struct iov_iter *from) } buf->len += ret; - do_wakeup = true; if (!iov_iter_count(from)) goto out; } @@ -527,7 +526,6 @@ pipe_write(struct kiocb *iocb, struct iov_iter *from) ret += copied; buf->offset = 0; buf->len = copied; - do_wakeup = true; if (!iov_iter_count(from)) break; @@ -555,12 +553,13 @@ pipe_write(struct kiocb *iocb, struct iov_iter *from) * become empty while we dropped the lock. */ __pipe_unlock(pipe); - if (do_wakeup) { + if (was_empty) { wake_up_interruptible_sync_poll(&pipe->rd_wait, EPOLLIN | EPOLLRDNORM); kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); } wait_event_interruptible_exclusive(pipe->wr_wait, pipe_writable(pipe)); __pipe_lock(pipe); + was_empty = pipe_empty(pipe->head, pipe->tail); wake_next_writer = true; } out: @@ -577,7 +576,7 @@ out: * how (for example) the GNU make jobserver uses small writes to * wake up pending jobs */ - if (do_wakeup) { + if (was_empty) { wake_up_interruptible_sync_poll(&pipe->rd_wait, EPOLLIN | EPOLLRDNORM); kill_fasync(&pipe->fasync_readers, SIGIO, POLL_IN); }