openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/IdleHandler.java

   1 /* Copyright (C)2013 Pantheon Technologies, s.r.o. All rights reserved. */
   2 package org.opendaylight.openflowjava.protocol.impl.core;
   3
   4 import java.util.concurrent.TimeUnit;
   5
   6 import io.netty.channel.ChannelHandlerContext;
   7 import io.netty.handler.timeout.IdleState;
   8 import io.netty.handler.timeout.IdleStateEvent;
   9 import io.netty.handler.timeout.IdleStateHandler;
  10
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.system.rev130927.SwitchIdleEventBuilder;
  12 import org.slf4j.Logger;
  13 import org.slf4j.LoggerFactory;
  14
  15 /**
  16  * Detects idle state of switch and informs upper layers
  17  * @author michal.polkorab
  18  */
  19 public class IdleHandler extends IdleStateHandler{
  20
  21     private static final Logger LOGGER = LoggerFactory.getLogger(IdleHandler.class);
  22
  23     /**
  24      * @param readerIdleTime
  25      * @param writerIdleTime
  26      * @param allIdleTime
  27      * @param unit
  28      */
  29     public IdleHandler(long readerIdleTime, long writerIdleTime,
  30             long allIdleTime, TimeUnit unit) {
  31         super(readerIdleTime, writerIdleTime, allIdleTime, unit);
  32     }
  33
  34     @Override
  35     protected void channelIdle(ChannelHandlerContext ctx, IdleStateEvent evt)
  36             throws Exception {
  37         if ((evt.state() == IdleState.READER_IDLE) && (evt.isFirst())) {
  38             LOGGER.info("Switch idle");
  39             SwitchIdleEventBuilder builder = new SwitchIdleEventBuilder();
  40             builder.setInfo("Switch idle");
  41             ctx.fireChannelRead(builder.build());
  42         }
  43     }
  44
  45 }