/**
      This file is part of GoldenGate Project (named also GoldenGate or GG).
   
      Copyright 2009, Frederic Bregier, and individual contributors by the @author
      tags. See the COPYRIGHT.txt in the distribution for a full listing of
      individual contributors.
   
      All GoldenGate Project is free software: you can redistribute it and/or 
      modify it under the terms of the GNU General Public License as published 
     by the Free Software Foundation, either version 3 of the License, or
     (at your option) any later version.
  
     GoldenGate is distributed in the hope that it will be useful,
     but WITHOUT ANY WARRANTY; without even the implied warranty of
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     GNU General Public License for more details.
  
     You should have received a copy of the GNU General Public License
     along with GoldenGate .  If not, see <http://www.gnu.org/licenses/>.
   */
  package openr66.protocol.networkhandler;
  
  import java.util.concurrent.TimeUnit;
  
  import openr66.protocol.configuration.Configuration;
  import openr66.protocol.exception.OpenR66ProtocolNoDataException;
  import openr66.protocol.networkhandler.packet.NetworkPacketCodec;
  
  import org.jboss.netty.channel.ChannelPipeline;
  import org.jboss.netty.channel.ChannelPipelineFactory;
  import org.jboss.netty.channel.Channels;
  import org.jboss.netty.handler.execution.ExecutionHandler;
  import org.jboss.netty.handler.timeout.IdleStateHandler;
  import org.jboss.netty.handler.traffic.ChannelTrafficShapingHandler;
  import org.jboss.netty.handler.traffic.GlobalTrafficShapingHandler;
  import org.jboss.netty.util.HashedWheelTimer;
  
  /**
   * NetworkServer pipeline (Requester side)
   * @author Frederic Bregier
   */
  public class NetworkServerPipelineFactory implements ChannelPipelineFactory {
      /**
       * Global HashedWheelTimer
       */
      public HashedWheelTimer timer = (HashedWheelTimer) Configuration.configuration.getTimerClose();
  
      public static final String TIMEOUT = "timeout";
      public static final String READTIMEOUT = "readTimeout";
      public static final String LIMIT = "LIMIT";
      public static final String LIMITCHANNEL = "LIMITCHANNEL";
  
      private boolean server = false;
      public NetworkServerPipelineFactory(boolean server) {
          this.server = server;
      }
      @Override
      public ChannelPipeline getPipeline() {
          final ChannelPipeline pipeline = Channels.pipeline();
          pipeline.addLast("codec", new NetworkPacketCodec());
          GlobalTrafficShapingHandler handler =
              Configuration.configuration.getGlobalTrafficShapingHandler();
          if (handler != null) {
              pipeline.addLast(LIMIT, handler);
          }
          ChannelTrafficShapingHandler trafficChannel = null;
          try {
              trafficChannel =
                  Configuration.configuration
                  .newChannelTrafficShapingHandler();
              if (trafficChannel != null) {
                  pipeline.addLast(LIMITCHANNEL, trafficChannel);
              }
          } catch (OpenR66ProtocolNoDataException e) {
          }
          pipeline.addLast("pipelineExecutor", new ExecutionHandler(
                  Configuration.configuration.getServerPipelineExecutor()));
          
          pipeline.addLast(TIMEOUT,
                  new IdleStateHandler(timer,
                          0, 0, 
                          Configuration.configuration.TIMEOUTCON, 
                          TimeUnit.MILLISECONDS));
          pipeline.addLast("handler", new NetworkServerHandler(this.server));
          return pipeline;
      }
  
  }