Controller.java 文件源码

/**
 * Initializes the netty client channel connection.
 */
private void initConnection() {
    if (peerBootstrap != null) {
        return;
    }
    peerBootstrap = createPeerBootStrap();

    peerBootstrap.setOption("reuseAddress", true);
    peerBootstrap.setOption("tcpNoDelay", true);
    peerBootstrap.setOption("keepAlive", true);
    peerBootstrap.setOption("receiveBufferSize", Controller.BUFFER_SIZE);
    peerBootstrap.setOption("receiveBufferSizePredictorFactory",
                            new FixedReceiveBufferSizePredictorFactory(
                                    Controller.BUFFER_SIZE));
    peerBootstrap.setOption("receiveBufferSizePredictor",
                            new AdaptiveReceiveBufferSizePredictor(64, 4096, 65536));
    peerBootstrap.setOption("child.keepAlive", true);
    peerBootstrap.setOption("child.tcpNoDelay", true);
    peerBootstrap.setOption("child.sendBufferSize", Controller.BUFFER_SIZE);
    peerBootstrap.setOption("child.receiveBufferSize", Controller.BUFFER_SIZE);
    peerBootstrap.setOption("child.receiveBufferSizePredictorFactory",
                            new FixedReceiveBufferSizePredictorFactory(
                                    Controller.BUFFER_SIZE));
    peerBootstrap.setOption("child.reuseAddress", true);

    ospfChannelHandler = new OspfInterfaceChannelHandler(this, processes);
    ChannelPipelineFactory pfact = new OspfPipelineFactory(ospfChannelHandler);
    peerBootstrap.setPipelineFactory(pfact);
}