import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionAdapterImpl;
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterImpl;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageConsumer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.system.rev130927.DisconnectEventBuilder;
import org.opendaylight.yangtools.yang.binding.DataObject;
import org.slf4j.Logger;
import io.netty.channel.ChannelHandlerContext;\r
import io.netty.channel.SimpleChannelInboundHandler;\r
\r
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageConsumer;\r
import org.opendaylight.openflowjava.protocol.impl.deserialization.DeserializationFactory;\r
import org.opendaylight.openflowjava.util.ByteBufUtils;\r
import org.opendaylight.yangtools.yang.binding.DataObject;\r
\r
import java.util.List;\r
\r
-import org.opendaylight.openflowjava.protocol.impl.connection.UdpMessageListenerWrapper;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.UdpMessageListenerWrapper;\r
import org.opendaylight.openflowjava.protocol.impl.serialization.SerializationFactory;\r
import org.slf4j.Logger;\r
import org.slf4j.LoggerFactory;\r
\r
import org.opendaylight.openflowjava.protocol.api.connection.SwitchConnectionHandler;\r
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;\r
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionAdapterFactory;\r
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionAdapterFactoryImpl;\r
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionFacade;\r
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterFactory;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterFactoryImpl;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionFacade;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageConsumer;\r
import org.opendaylight.openflowjava.util.ByteBufUtils;\r
import org.slf4j.Logger;\r
import org.slf4j.LoggerFactory;\r
import io.netty.handler.codec.MessageToByteEncoder;
import io.netty.util.concurrent.Future;
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageListenerWrapper;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageListenerWrapper;
import org.opendaylight.openflowjava.protocol.impl.serialization.SerializationFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.List;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionFacade;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionFacade;
import org.opendaylight.openflowjava.util.ByteBufUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core;
import com.google.common.util.concurrent.ListenableFuture;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core;
import org.opendaylight.openflowjava.protocol.api.connection.ThreadConfiguration;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core;
import com.google.common.util.concurrent.ListenableFuture;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core;
import org.opendaylight.openflowjava.protocol.api.connection.ConnectionConfiguration;
import org.opendaylight.openflowjava.protocol.api.connection.SwitchConnectionHandler;
import org.opendaylight.openflowjava.protocol.api.keys.experimenter.ExperimenterInstructionDeserializerKey;
import org.opendaylight.openflowjava.protocol.api.keys.experimenter.ExperimenterInstructionSerializerKey;
import org.opendaylight.openflowjava.protocol.api.keys.experimenter.ExperimenterSerializerKey;
-import org.opendaylight.openflowjava.protocol.impl.core.ChannelInitializerFactory;
-import org.opendaylight.openflowjava.protocol.impl.core.TcpHandler;
-import org.opendaylight.openflowjava.protocol.impl.core.UdpHandler;
import org.opendaylight.openflowjava.protocol.impl.deserialization.DeserializationFactory;
import org.opendaylight.openflowjava.protocol.impl.deserialization.DeserializerRegistryImpl;
import org.opendaylight.openflowjava.protocol.impl.serialization.SerializationFactory;
import javax.net.ssl.SSLEngine;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionAdapterFactory;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionAdapterFactoryImpl;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionFacade;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterFactory;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterFactoryImpl;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionFacade;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.net.InetSocketAddress;
import org.opendaylight.openflowjava.protocol.api.connection.ThreadConfiguration;
-import org.opendaylight.openflowjava.protocol.impl.connection.ServerFacade;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Map;\r
import java.util.concurrent.ConcurrentHashMap;\r
\r
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageConsumer;\r
\r
/**\r
* As UDP communication is handled only by one channel, it is needed\r
import java.net.InetSocketAddress;\r
\r
import org.opendaylight.openflowjava.protocol.api.connection.ThreadConfiguration;\r
-import org.opendaylight.openflowjava.protocol.impl.connection.ServerFacade;\r
import org.slf4j.Logger;\r
import org.slf4j.LoggerFactory;\r
\r
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.GenericFutureListener;
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import java.net.InetSocketAddress;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import java.net.InetSocketAddress;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import org.opendaylight.openflowjava.protocol.api.connection.ConnectionAdapter;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import org.opendaylight.yangtools.yang.binding.DataObject;
* and is available at http://www.eclipse.org/legal/epl-v10.html\r
*/\r
\r
-package org.opendaylight.openflowjava.protocol.impl.connection;\r
+package org.opendaylight.openflowjava.protocol.impl.core.connection;\r
\r
import io.netty.util.concurrent.Future;\r
import io.netty.util.concurrent.GenericFutureListener;\r
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import java.util.concurrent.TimeoutException;
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
final class SimpleRpcListener extends AbstractRpcListener<Void> {
public SimpleRpcListener(final Object message, final String failureInfo) {
* and is available at http://www.eclipse.org/legal/epl-v10.html\r
*/\r
\r
-package org.opendaylight.openflowjava.protocol.impl.connection;\r
+package org.opendaylight.openflowjava.protocol.impl.core.connection;\r
\r
import io.netty.util.concurrent.Future;\r
import io.netty.util.concurrent.GenericFutureListener;\r
import org.opendaylight.openflowjava.protocol.api.connection.ConnectionConfiguration;
import org.opendaylight.openflowjava.protocol.api.connection.ThreadConfiguration;
import org.opendaylight.openflowjava.protocol.api.connection.TlsConfiguration;
-import org.opendaylight.openflowjava.protocol.impl.connection.SwitchConnectionProviderImpl;
+import org.opendaylight.openflowjava.protocol.impl.core.SwitchConnectionProviderImpl;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.KeystoreType;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.TransportProtocol;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageConsumer;
import org.opendaylight.yangtools.yang.binding.DataObject;
/**
import org.mockito.Mock;\r
import org.mockito.MockitoAnnotations;\r
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;\r
-import org.opendaylight.openflowjava.protocol.impl.connection.UdpMessageListenerWrapper;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.UdpMessageListenerWrapper;\r
import org.opendaylight.openflowjava.protocol.impl.serialization.SerializationFactory;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloInput;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloInputBuilder;\r
import org.mockito.MockitoAnnotations;
import org.opendaylight.openflowjava.protocol.api.connection.SwitchConnectionHandler;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageConsumer;
import org.opendaylight.openflowjava.util.ByteBufUtils;
/**
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageListenerWrapper;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageListenerWrapper;
import org.opendaylight.openflowjava.protocol.impl.serialization.SerializationFactory;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
import org.opendaylight.yangtools.yang.binding.DataObject;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
import org.mockito.runners.MockitoJUnitRunner;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionFacade;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionFacade;
import org.opendaylight.openflowjava.util.ByteBufUtils;
/**
import org.opendaylight.openflowjava.protocol.api.connection.SwitchConnectionHandler;
import org.opendaylight.openflowjava.protocol.api.connection.TlsConfiguration;
import org.opendaylight.openflowjava.protocol.api.connection.TlsConfigurationImpl;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionAdapterFactory;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionFacade;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterFactory;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionFacade;
import org.opendaylight.openflowjava.protocol.impl.deserialization.DeserializationFactory;
import org.opendaylight.openflowjava.protocol.impl.serialization.SerializationFactory;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.KeystoreType;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
-import org.opendaylight.openflowjava.protocol.impl.connection.MessageConsumer;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageConsumer;
/**
* @author madamjak
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ChannelOutboundQueue;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterImpl;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageListenerWrapper;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ResponseExpectedRpcListener;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.RpcResponseKey;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoReplyInput;
* and is available at http://www.eclipse.org/legal/epl-v10.html\r
*/\r
\r
-package org.opendaylight.openflowjava.protocol.impl.connection;\r
+package org.opendaylight.openflowjava.protocol.impl.core.connection;\r
\r
import io.netty.channel.Channel;\r
\r
import org.junit.Test;\r
import org.mockito.Mock;\r
import org.mockito.MockitoAnnotations;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ChannelOutboundQueue;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.SimpleRpcListener;\r
\r
/**\r
* @author michal.polkorab\r
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import static org.mockito.Mockito.when;
import io.netty.channel.Channel;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterFactoryImpl;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionFacade;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelOutboundHandlerAdapter;
import io.netty.channel.ChannelPromise;
import io.netty.channel.embedded.EmbeddedChannel;
+
import java.net.InetSocketAddress;
import java.util.concurrent.TimeUnit;
+
import junit.framework.Assert;
+
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterImpl;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageListenerWrapper;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ResponseExpectedRpcListener;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.RpcResponseKey;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoReplyInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetAsyncInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetConfigInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.TableModInput;
+
import com.google.common.cache.Cache;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.RemovalListener;
* and is available at http://www.eclipse.org/legal/epl-v10.html\r
*/\r
\r
-package org.opendaylight.openflowjava.protocol.impl.connection;\r
+package org.opendaylight.openflowjava.protocol.impl.core.connection;\r
\r
import static org.mockito.Matchers.any;\r
import static org.mockito.Mockito.times;\r
import org.mockito.MockitoAnnotations;\r
import org.opendaylight.openflowjava.protocol.api.connection.ConnectionReadyListener;\r
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionAdapterImpl;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ResponseExpectedRpcListener;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.RpcResponseKey;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierInput;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierInputBuilder;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierOutput;\r
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import java.net.InetAddress;
* and is available at http://www.eclipse.org/legal/epl-v10.html\r
*/\r
\r
-package org.opendaylight.openflowjava.protocol.impl.connection;\r
+package org.opendaylight.openflowjava.protocol.impl.core.connection;\r
\r
import org.junit.Assert;\r
import org.junit.Test;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.MessageListenerWrapper;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.SimpleRpcListener;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloInput;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloInputBuilder;\r
\r
* and is available at http://www.eclipse.org/legal/epl-v10.html\r
*/\r
\r
-package org.opendaylight.openflowjava.protocol.impl.connection;\r
+package org.opendaylight.openflowjava.protocol.impl.core.connection;\r
\r
import static org.junit.Assert.fail;\r
\r
import org.junit.Assert;\r
import org.junit.Test;\r
import org.opendaylight.controller.sal.common.util.Rpcs;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.AbstractRpcListener;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ResponseExpectedRpcListener;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.RpcResponseKey;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierInput;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierInputBuilder;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.BarrierOutput;\r
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import org.junit.Test;
import org.junit.Assert;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.RpcResponseKey;
/**
*
* and is available at http://www.eclipse.org/legal/epl-v10.html\r
*/\r
\r
-package org.opendaylight.openflowjava.protocol.impl.connection;\r
+package org.opendaylight.openflowjava.protocol.impl.core.connection;\r
\r
import static org.junit.Assert.fail;\r
import static org.mockito.Mockito.times;\r
import org.mockito.Mock;\r
import org.mockito.MockitoAnnotations;\r
import org.opendaylight.controller.sal.common.util.Rpcs;\r
+import org.opendaylight.openflowjava.protocol.impl.core.connection.SimpleRpcListener;\r
import org.opendaylight.yangtools.yang.common.RpcError;\r
import org.opendaylight.yangtools.yang.common.RpcResult;\r
\r
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import java.net.InetAddress;
import java.net.UnknownHostException;
import org.opendaylight.openflowjava.protocol.api.keys.experimenter.ExperimenterInstructionDeserializerKey;
import org.opendaylight.openflowjava.protocol.api.keys.experimenter.ExperimenterInstructionSerializerKey;
import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
+import org.opendaylight.openflowjava.protocol.impl.core.ServerFacade;
+import org.opendaylight.openflowjava.protocol.impl.core.SwitchConnectionProviderImpl;
import org.opendaylight.openflowjava.protocol.spi.connection.SwitchConnectionProvider;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.action.rev130731.ExperimenterActionSubType;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.KeystoreType;
* and is available at http://www.eclipse.org/legal/epl-v10.html\r
*/\r
\r
-package org.opendaylight.openflowjava.protocol.impl.connection;\r
+package org.opendaylight.openflowjava.protocol.impl.core.connection;\r
\r
import java.net.InetAddress;\r
import java.net.UnknownHostException;\r
import org.opendaylight.openflowjava.protocol.api.connection.SwitchConnectionHandler;\r
import org.opendaylight.openflowjava.protocol.api.connection.TlsConfiguration;\r
import org.opendaylight.openflowjava.protocol.api.connection.TlsConfigurationImpl;\r
+import org.opendaylight.openflowjava.protocol.impl.core.SwitchConnectionProviderImpl;\r
import org.opendaylight.openflowjava.protocol.spi.connection.SwitchConnectionProvider;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.KeystoreType;\r
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.PathType;\r
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import java.io.IOException;
import java.net.InetAddress;
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-package org.opendaylight.openflowjava.protocol.impl.connection;
+package org.opendaylight.openflowjava.protocol.impl.core.connection;
import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.GenericFutureListener;
+
import java.net.InetSocketAddress;
+
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.UdpMessageListenerWrapper;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OfHeader;
/**
import org.opendaylight.openflowjava.protocol.impl.clients.SleepEvent;
import org.opendaylight.openflowjava.protocol.impl.clients.UdpSimpleClient;
import org.opendaylight.openflowjava.protocol.impl.clients.WaitForMessageEvent;
-import org.opendaylight.openflowjava.protocol.impl.connection.ConnectionConfigurationImpl;
-import org.opendaylight.openflowjava.protocol.impl.connection.SwitchConnectionProviderImpl;
+import org.opendaylight.openflowjava.protocol.impl.core.SwitchConnectionProviderImpl;
import org.opendaylight.openflowjava.protocol.impl.core.TcpHandler;
import org.opendaylight.openflowjava.protocol.impl.core.UdpHandler;
+import org.opendaylight.openflowjava.protocol.impl.core.connection.ConnectionConfigurationImpl;
import org.opendaylight.openflowjava.util.ByteBufUtils;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.KeystoreType;
import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.config.rev140630.PathType;