2 * Copyright (c) 2013 Pantheon Technologies s.r.o. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
10 package org.opendaylight.openflowjava.protocol.impl.core;
12 import com.google.common.util.concurrent.ListenableFuture;
13 import com.google.common.util.concurrent.SettableFuture;
14 import io.netty.channel.nio.NioEventLoopGroup;
15 import org.opendaylight.openflowjava.protocol.api.connection.ConnectionConfiguration;
16 import org.opendaylight.openflowjava.protocol.api.connection.SwitchConnectionHandler;
17 import org.opendaylight.openflowjava.protocol.api.extensibility.DeserializerRegistry;
18 import org.opendaylight.openflowjava.protocol.api.extensibility.OFDeserializer;
19 import org.opendaylight.openflowjava.protocol.api.extensibility.OFGeneralDeserializer;
20 import org.opendaylight.openflowjava.protocol.api.extensibility.OFGeneralSerializer;
21 import org.opendaylight.openflowjava.protocol.api.extensibility.OFSerializer;
22 import org.opendaylight.openflowjava.protocol.api.extensibility.SerializerRegistry;
23 import org.opendaylight.openflowjava.protocol.api.keys.ActionSerializerKey;
24 import org.opendaylight.openflowjava.protocol.api.keys.ExperimenterActionDeserializerKey;
25 import org.opendaylight.openflowjava.protocol.api.keys.ExperimenterDeserializerKey;
26 import org.opendaylight.openflowjava.protocol.api.keys.ExperimenterIdDeserializerKey;
27 import org.opendaylight.openflowjava.protocol.api.keys.ExperimenterIdSerializerKey;
28 import org.opendaylight.openflowjava.protocol.api.keys.ExperimenterInstructionDeserializerKey;
29 import org.opendaylight.openflowjava.protocol.api.keys.ExperimenterSerializerKey;
30 import org.opendaylight.openflowjava.protocol.api.keys.InstructionSerializerKey;
31 import org.opendaylight.openflowjava.protocol.api.keys.MatchEntryDeserializerKey;
32 import org.opendaylight.openflowjava.protocol.api.keys.MatchEntrySerializerKey;
33 import org.opendaylight.openflowjava.protocol.api.keys.MessageCodeKey;
34 import org.opendaylight.openflowjava.protocol.api.keys.MessageTypeKey;
35 import org.opendaylight.openflowjava.protocol.impl.deserialization.DeserializationFactory;
36 import org.opendaylight.openflowjava.protocol.impl.deserialization.DeserializerRegistryImpl;
37 import org.opendaylight.openflowjava.protocol.impl.serialization.SerializationFactory;
38 import org.opendaylight.openflowjava.protocol.impl.serialization.SerializerRegistryImpl;
39 import org.opendaylight.openflowjava.protocol.spi.connection.SwitchConnectionProvider;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.TransportProtocol;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.MatchField;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OxmClassBase;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterInput;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterMessage;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReplyMessage;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.meter.band.header.meter.band.MeterBandExperimenterCase;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenterCase;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.queue.property.header.QueueProperty;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.table.features.properties.grouping.TableFeatureProperties;
51 import org.slf4j.Logger;
52 import org.slf4j.LoggerFactory;
55 * Exposed class for server handling<br>
56 * C - {@link MatchEntrySerializerKey} parameter representing oxm_class (see specification)<br>
57 * F - {@link MatchEntrySerializerKey} parameter representing oxm_field (see specification)
59 * @author michal.polkorab
61 public class SwitchConnectionProviderImpl implements SwitchConnectionProvider, ConnectionInitializer {
63 private static final Logger LOGGER = LoggerFactory
64 .getLogger(SwitchConnectionProviderImpl.class);
65 private SwitchConnectionHandler switchConnectionHandler;
66 private ServerFacade serverFacade;
67 private ConnectionConfiguration connConfig;
68 private final SerializationFactory serializationFactory;
69 private final SerializerRegistry serializerRegistry;
70 private final DeserializerRegistry deserializerRegistry;
71 private final DeserializationFactory deserializationFactory;
72 private TcpConnectionInitializer connectionInitializer;
75 public SwitchConnectionProviderImpl() {
76 serializerRegistry = new SerializerRegistryImpl();
77 serializerRegistry.init();
78 serializationFactory = new SerializationFactory();
79 serializationFactory.setSerializerTable(serializerRegistry);
80 deserializerRegistry = new DeserializerRegistryImpl();
81 deserializerRegistry.init();
82 deserializationFactory = new DeserializationFactory();
83 deserializationFactory.setRegistry(deserializerRegistry);
87 public void setConfiguration(final ConnectionConfiguration connConfig) {
88 this.connConfig = connConfig;
92 public void setSwitchConnectionHandler(final SwitchConnectionHandler switchConnectionHandler) {
93 LOGGER.debug("setSwitchConnectionHandler");
94 this.switchConnectionHandler = switchConnectionHandler;
98 public ListenableFuture<Boolean> shutdown() {
99 LOGGER.debug("Shutdown summoned");
100 if(serverFacade == null){
101 LOGGER.warn("Can not shutdown - not configured or started");
102 throw new IllegalStateException("SwitchConnectionProvider is not started or not configured.");
104 return serverFacade.shutdown();
108 public ListenableFuture<Boolean> startup() {
109 LOGGER.debug("Startup summoned");
110 ListenableFuture<Boolean> result = null;
112 serverFacade = createAndConfigureServer();
113 if (switchConnectionHandler == null) {
114 throw new IllegalStateException("SwitchConnectionHandler is not set");
116 new Thread(serverFacade).start();
117 result = serverFacade.getIsOnlineFuture();
118 } catch (final Exception e) {
119 final SettableFuture<Boolean> exResult = SettableFuture.create();
120 exResult.setException(e);
129 private ServerFacade createAndConfigureServer() {
130 LOGGER.debug("Configuring ..");
131 ServerFacade server = null;
132 final ChannelInitializerFactory factory = new ChannelInitializerFactory();
133 factory.setSwitchConnectionHandler(switchConnectionHandler);
134 factory.setSwitchIdleTimeout(connConfig.getSwitchIdleTimeout());
135 factory.setTlsConfig(connConfig.getTlsConfiguration());
136 factory.setSerializationFactory(serializationFactory);
137 factory.setDeserializationFactory(deserializationFactory);
138 factory.setUseBarrier(connConfig.useBarrier());
139 final TransportProtocol transportProtocol = (TransportProtocol) connConfig.getTransferProtocol();
140 if (transportProtocol.equals(TransportProtocol.TCP) || transportProtocol.equals(TransportProtocol.TLS)) {
141 server = new TcpHandler(connConfig.getAddress(), connConfig.getPort());
142 final TcpChannelInitializer channelInitializer = factory.createPublishingChannelInitializer();
143 ((TcpHandler) server).setChannelInitializer(channelInitializer);
144 ((TcpHandler) server).initiateEventLoopGroups(connConfig.getThreadConfiguration());
146 final NioEventLoopGroup workerGroupFromTcpHandler = ((TcpHandler) server).getWorkerGroup();
147 connectionInitializer = new TcpConnectionInitializer(workerGroupFromTcpHandler);
148 connectionInitializer.setChannelInitializer(channelInitializer);
149 connectionInitializer.run();
150 } else if (transportProtocol.equals(TransportProtocol.UDP)){
151 server = new UdpHandler(connConfig.getAddress(), connConfig.getPort());
152 ((UdpHandler) server).setChannelInitializer(factory.createUdpChannelInitializer());
154 throw new IllegalStateException("Unknown transport protocol received: " + transportProtocol);
156 server.setThreadConfig(connConfig.getThreadConfiguration());
163 public ServerFacade getServerFacade() {
168 public void close() throws Exception {
173 public boolean unregisterSerializer(final ExperimenterSerializerKey key) {
174 return serializerRegistry.unregisterSerializer((MessageTypeKey<?>) key);
178 public boolean unregisterDeserializer(final ExperimenterDeserializerKey key) {
179 return deserializerRegistry.unregisterDeserializer((MessageCodeKey) key);
183 public void registerActionSerializer(final ActionSerializerKey<?> key,
184 final OFGeneralSerializer serializer) {
185 serializerRegistry.registerSerializer(key, serializer);
189 public void registerActionDeserializer(final ExperimenterActionDeserializerKey key,
190 final OFGeneralDeserializer deserializer) {
191 deserializerRegistry.registerDeserializer(key, deserializer);
195 public void registerInstructionSerializer(final InstructionSerializerKey<?> key,
196 final OFGeneralSerializer serializer) {
197 serializerRegistry.registerSerializer(key, serializer);
201 public void registerInstructionDeserializer(final ExperimenterInstructionDeserializerKey key,
202 final OFGeneralDeserializer deserializer) {
203 deserializerRegistry.registerDeserializer(key, deserializer);
207 public <C extends OxmClassBase, F extends MatchField> void registerMatchEntrySerializer(final MatchEntrySerializerKey<C, F> key,
208 final OFGeneralSerializer serializer) {
209 serializerRegistry.registerSerializer(key, serializer);
213 public void registerMatchEntryDeserializer(final MatchEntryDeserializerKey key,
214 final OFGeneralDeserializer deserializer) {
215 deserializerRegistry.registerDeserializer(key, deserializer);
219 public void registerErrorDeserializer(final ExperimenterIdDeserializerKey key,
220 final OFDeserializer<ErrorMessage> deserializer) {
221 deserializerRegistry.registerDeserializer(key, deserializer);
225 public void registerExperimenterMessageDeserializer(final ExperimenterIdDeserializerKey key,
226 final OFDeserializer<ExperimenterMessage> deserializer) {
227 deserializerRegistry.registerDeserializer(key, deserializer);
231 public void registerMultipartReplyMessageDeserializer(final ExperimenterIdDeserializerKey key,
232 final OFDeserializer<MultipartReplyMessage> deserializer) {
233 deserializerRegistry.registerDeserializer(key, deserializer);
237 public void registerMultipartReplyTFDeserializer(final ExperimenterIdDeserializerKey key,
238 final OFGeneralDeserializer deserializer) {
239 deserializerRegistry.registerDeserializer(key, deserializer);
243 public void registerQueuePropertyDeserializer(final ExperimenterIdDeserializerKey key,
244 final OFDeserializer<QueueProperty> deserializer) {
245 deserializerRegistry.registerDeserializer(key, deserializer);
249 public void registerMeterBandDeserializer(final ExperimenterIdDeserializerKey key,
250 final OFDeserializer<MeterBandExperimenterCase> deserializer) {
251 deserializerRegistry.registerDeserializer(key, deserializer);
255 public void registerExperimenterMessageSerializer(final ExperimenterIdSerializerKey<ExperimenterInput> key,
256 final OFSerializer<ExperimenterInput> serializer) {
257 serializerRegistry.registerSerializer(key, serializer);
261 public void registerMultipartRequestSerializer(final ExperimenterIdSerializerKey<MultipartRequestExperimenterCase> key,
262 final OFSerializer<MultipartRequestExperimenterCase> serializer) {
263 serializerRegistry.registerSerializer(key, serializer);
267 public void registerMultipartRequestTFSerializer(final ExperimenterIdSerializerKey<TableFeatureProperties> key,
268 final OFGeneralSerializer serializer) {
269 serializerRegistry.registerSerializer(key, serializer);
273 public void registerMeterBandSerializer(final ExperimenterIdSerializerKey<MeterBandExperimenterCase> key,
274 final OFSerializer<MeterBandExperimenterCase> serializer) {
275 serializerRegistry.registerSerializer(key, serializer);
279 public void initiateConnection(final String host, final int port) {
280 connectionInitializer.initiateConnection(host, port);