netty Architecture Docs
Home / Function/ shutdownInput() — netty Function Reference

shutdownInput() — netty Function Reference

Architecture documentation for the shutdownInput() function in AbstractEpollChannel.java from the netty codebase.

Function java Buffer Telemetry calls 5 called by 1

Entity Profile

Dependency Diagram

graph TD
  0f938c96_9ae0_6ccc_0306_33c0df2458f1["shutdownInput()"]
  48a4b0f2_9a93_c0ec_29eb_423e8fb5ce85["AbstractEpollUnsafe"]
  0f938c96_9ae0_6ccc_0306_33c0df2458f1 -->|defined in| 48a4b0f2_9a93_c0ec_29eb_423e8fb5ce85
  d090690c_ba63_7842_6536_a467e153f1b2["epollRdHupReady()"]
  d090690c_ba63_7842_6536_a467e153f1b2 -->|calls| 0f938c96_9ae0_6ccc_0306_33c0df2458f1
  d6bcc092_987d_0719_ef13_bc31c0683a82["isAllowHalfClosure()"]
  0f938c96_9ae0_6ccc_0306_33c0df2458f1 -->|calls| d6bcc092_987d_0719_ef13_bc31c0683a82
  6f55cbec_9a52_e47a_1d73_fecef5eb8c03["fireEventAndClose()"]
  0f938c96_9ae0_6ccc_0306_33c0df2458f1 -->|calls| 6f55cbec_9a52_e47a_1d73_fecef5eb8c03
  79fa9e79_7cee_d3a0_2104_e37cb65f90fb["shouldStopReading()"]
  0f938c96_9ae0_6ccc_0306_33c0df2458f1 -->|calls| 79fa9e79_7cee_d3a0_2104_e37cb65f90fb
  87f92a25_820d_6da3_4383_913f8e4f4164["clearEpollIn0()"]
  0f938c96_9ae0_6ccc_0306_33c0df2458f1 -->|calls| 87f92a25_820d_6da3_4383_913f8e4f4164
  d9ab1040_9ace_496a_a503_4d950b47fbce["close()"]
  0f938c96_9ae0_6ccc_0306_33c0df2458f1 -->|calls| d9ab1040_9ace_496a_a503_4d950b47fbce
  style 0f938c96_9ae0_6ccc_0306_33c0df2458f1 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollChannel.java lines 544–572

        void shutdownInput(boolean allDataRead) {
            if (!socket.isInputShutdown()) {
                if (isAllowHalfClosure(config())) {
                    try {
                        socket.shutdown(true, false);
                    } catch (IOException ignored) {
                        // We attempted to shutdown and failed, which means the input has already effectively been
                        // shutdown.
                        fireEventAndClose(ChannelInputShutdownEvent.INSTANCE);
                        return;
                    } catch (NotYetConnectedException ignore) {
                        // We attempted to shutdown and failed, which means the input has already effectively been
                        // shutdown.
                    }
                    if (shouldStopReading(config())) {
                        clearEpollIn0();
                    }
                    pipeline().fireUserEventTriggered(ChannelInputShutdownEvent.INSTANCE);
                } else {
                    close(voidPromise());
                    return;
                }
            }

            if (allDataRead && !inputClosedSeenErrorOnRead) {
                inputClosedSeenErrorOnRead = true;
                pipeline().fireUserEventTriggered(ChannelInputShutdownReadComplete.INSTANCE);
            }
        }

Domain

Subdomains

Defined In

Calls

Called By

Source

Frequently Asked Questions

What does shutdownInput() do?
shutdownInput() is a function in the netty codebase, defined in transport-classes-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollChannel.java.
Where is shutdownInput() defined?
shutdownInput() is defined in transport-classes-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollChannel.java at line 544.
What does shutdownInput() call?
shutdownInput() calls 5 function(s): clearEpollIn0, close, fireEventAndClose, isAllowHalfClosure, shouldStopReading.
What calls shutdownInput()?
shutdownInput() is called by 1 function(s): epollRdHupReady.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free