doReadMessages() — netty Function Reference

Architecture documentation for the doReadMessages() function in OioServerSocketChannel.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ doReadMessages() — netty Function Reference

Dependency Diagram

graph TD
  959bd64d_86c8_5d74_e1a6_ca7306657edb["doReadMessages()"]
  a517615e_df65_930b_be6c_232b9e1779dd["OioServerSocketChannel"]
  959bd64d_86c8_5d74_e1a6_ca7306657edb -->|defined in| a517615e_df65_930b_be6c_232b9e1779dd
  style 959bd64d_86c8_5d74_e1a6_ca7306657edb fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/socket/oio/OioServerSocketChannel.java lines 147–170

    @Override
    protected int doReadMessages(List<Object> buf) throws Exception {
        if (socket.isClosed()) {
            return -1;
        }

        try {
            Socket s = socket.accept();
            try {
                buf.add(new OioSocketChannel(this, s));
                return 1;
            } catch (Throwable t) {
                logger.warn("Failed to create a new channel from an accepted socket.", t);
                try {
                    s.close();
                } catch (Throwable t2) {
                    logger.warn("Failed to close a socket.", t2);
                }
            }
        } catch (SocketTimeoutException e) {
            // Expected
        }
        return 0;
    }