run() — netty Function Reference

Architecture documentation for the run() function in AbstractTrafficShapingHandler.java from the netty codebase.

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ run() — netty Function Reference

Dependency Diagram

graph TD
  e70be341_45e2_2ba2_5f42_466a29b6017b["run()"]
  6b25c5a3_60ff_5947_dd8c_953a33240929["ReopenReadTimerTask"]
  e70be341_45e2_2ba2_5f42_466a29b6017b -->|defined in| 6b25c5a3_60ff_5947_dd8c_953a33240929
  5546df53_f7c6_1216_f0ef_637a40f2a3fa["isHandlerActive()"]
  e70be341_45e2_2ba2_5f42_466a29b6017b -->|calls| 5546df53_f7c6_1216_f0ef_637a40f2a3fa
  0c56445d_5a40_0e47_fe4c_642f12d61202["read()"]
  e70be341_45e2_2ba2_5f42_466a29b6017b -->|calls| 0c56445d_5a40_0e47_fe4c_642f12d61202
  style e70be341_45e2_2ba2_5f42_466a29b6017b fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/traffic/AbstractTrafficShapingHandler.java lines 422–457

        @Override
        public void run() {
            Channel channel = ctx.channel();
            ChannelConfig config = channel.config();
            if (!config.isAutoRead() && isHandlerActive(ctx)) {
                // If AutoRead is False and Active is True, user make a direct setAutoRead(false)
                // Then Just reset the status
                if (logger.isDebugEnabled()) {
                    logger.debug("Not unsuspend: " + config.isAutoRead() + ':' +
                            isHandlerActive(ctx));
                }
                channel.attr(READ_SUSPENDED).set(false);
            } else {
                // Anything else allows the handler to reset the AutoRead
                if (logger.isDebugEnabled()) {
                    if (config.isAutoRead() && !isHandlerActive(ctx)) {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Unsuspend: " + config.isAutoRead() + ':' +
                                    isHandlerActive(ctx));
                        }
                    } else {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Normal unsuspend: " + config.isAutoRead() + ':'
                                    + isHandlerActive(ctx));
                        }
                    }
                }
                channel.attr(READ_SUSPENDED).set(false);
                config.setAutoRead(true);
                channel.read();
            }
            if (logger.isDebugEnabled()) {
                logger.debug("Unsuspend final status => " + config.isAutoRead() + ':'
                        + isHandlerActive(ctx));
            }
        }