1 package org.openflow.lib;
\r
3 import io.netty.channel.Channel;
\r
4 import io.netty.channel.ChannelInitializer;
\r
5 import io.netty.channel.group.DefaultChannelGroup;
\r
7 import java.util.Iterator;
\r
9 import org.openflow.lib.TcpHandler.COMPONENT_NAMES;
\r
12 * @author michal.polkorab
\r
15 public class PublishingChannelInitializer extends ChannelInitializer<Channel> {
\r
17 private DefaultChannelGroup allChannels;
\r
22 public PublishingChannelInitializer() {
\r
23 allChannels = new DefaultChannelGroup("netty-receiver", null);
\r
27 protected void initChannel(Channel ch) throws Exception {
\r
28 allChannels.add(ch);
\r
29 ch.pipeline().addLast(COMPONENT_NAMES.TLS_DETECTOR.name(), new TlsDetector());
\r
33 * @return iterator through active connections
\r
35 public Iterator<Channel> getConnectionIterator() {
\r
36 return allChannels.iterator();
\r
40 * @return amount of active channels
\r
43 return allChannels.size();
\r