Toggle navigation
Toggle navigation
This project
Loading...
Sign in
홍길동
/
onos
Go to a project
Toggle navigation
Toggle navigation pinning
Projects
Groups
Snippets
Help
Project
Activity
Repository
Pipelines
Graphs
Issues
0
Merge Requests
0
Wiki
Snippets
Network
Create a new issue
Builds
Commits
Issue Boards
Authored by
tom
2014-08-25 22:43:19 -0700
Browse Files
Options
Browse Files
Download
Email Patches
Plain Diff
Commit
9ccd781b4809b7e5c12c2a34136fb204f7cbaa17
9ccd781b
1 parent
e33cc1a6
Refactored the OpenFlow controller package name-space and fixed a number of Javadoc warnings.
Hide whitespace changes
Inline
Side-by-side
Showing
78 changed files
with
168 additions
and
165 deletions
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/IOFSwitch.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/IOFSwitchManager.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageCategory.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageDoc.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageDocs.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/DebugCounter.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/IDebugCounter.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/IDebugCounterService.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/NullDebugCounter.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/Controller.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/HandshakeTimeoutException.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/HandshakeTimeoutHandler.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFChannelHandler.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFMessageDecoder.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFMessageEncoder.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OpenflowPipelineFactory.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeAlreadyStarted.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeCompleted.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeException.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeNotStarted.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeStateException.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchStateException.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/registry/ControllerRegistryEntry.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/registry/IControllerRegistry.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/registry/IdBlock.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/registry/RegistryException.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/Dpid.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/DummySwitchForTesting.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/EnumBitmaps.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/FilterIterator.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/InstanceId.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/IterableIterator.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/LRUHashMap.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/LinkedHashSetWrapper.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/MultiIterator.java
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/OrderedCollection.java
of-save/ctl/src/test/java/net/onrc/onos/of/ctl/internal/ControllerTest.java
of-save/ctl/src/test/java/net/onrc/onos/of/ctl/internal/OFChannelHandlerTest.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/IOFSwitch.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/IOFSwitch.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/IOFSwitchManager.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/IOFSwitchManager.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/Role.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/Role.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageCategory.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/annotations/LogMessageCategory.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageDoc.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/annotations/LogMessageDoc.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageDocs.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/annotations/LogMessageDocs.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/DebugCounter.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/debugcounter/DebugCounter.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/IDebugCounter.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/debugcounter/IDebugCounter.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/IDebugCounterService.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/debugcounter/IDebugCounterService.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/NullDebugCounter.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/debugcounter/NullDebugCounter.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/Controller.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/Controller.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/HandshakeTimeoutException.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/HandshakeTimeoutException.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/HandshakeTimeoutHandler.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/HandshakeTimeoutHandler.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFChannelHandler.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/OFChannelHandler.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFMessageDecoder.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/OFMessageDecoder.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFMessageEncoder.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/OFMessageEncoder.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OpenflowPipelineFactory.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/OpenflowPipelineFactory.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeAlreadyStarted.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/SwitchDriverSubHandshakeAlreadyStarted.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeCompleted.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/SwitchDriverSubHandshakeCompleted.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeException.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/SwitchDriverSubHandshakeException.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeNotStarted.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/SwitchDriverSubHandshakeNotStarted.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeStateException.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/SwitchDriverSubHandshakeStateException.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchStateException.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/internal/SwitchStateException.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/registry/ControllerRegistryEntry.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/registry/ControllerRegistryEntry.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/registry/IControllerRegistry.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/registry/IControllerRegistry.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/registry/IdBlock.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/registry/IdBlock.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/registry/RegistryException.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/registry/RegistryException.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/Dpid.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/Dpid.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/DummySwitchForTesting.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/DummySwitchForTesting.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/EnumBitmaps.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/EnumBitmaps.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/FilterIterator.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/FilterIterator.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/InstanceId.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/InstanceId.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/IterableIterator.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/IterableIterator.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/LRUHashMap.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/LRUHashMap.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/LinkedHashSetWrapper.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/LinkedHashSetWrapper.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/MultiIterator.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/MultiIterator.java
of/ctl/src/main/java/net/onrc/onos/of/ctl/util/OrderedCollection.java → of/ctl/src/main/java/org/onlab/onos/of/controller/impl/util/OrderedCollection.java
of/ctl/src/test/java/net/onrc/onos/of/ctl/internal/ControllerTest.java → of/ctl/src/test/java/org/onlab/onos/of/controller/impl/internal/ControllerTest.java
of/ctl/src/test/java/net/onrc/onos/of/ctl/internal/OFChannelHandlerTest.java → of/ctl/src/test/java/org/onlab/onos/of/controller/impl/internal/OFChannelHandlerTest.java
pom.xml
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/IOFSwitch.java
View file @
9ccd781
...
...
@@ -25,9 +25,9 @@ import java.util.Map;
import
java.util.Set
;
import
java.util.concurrent.Future
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterException
;
import
net.onrc.onos.of.ct
l.util.OrderedCollection
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterException
;
import
org.onlab.onos.of.controller.imp
l.util.OrderedCollection
;
import
org.jboss.netty.channel.Channel
;
import
org.projectfloodlight.openflow.protocol.OFActionType
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/IOFSwitchManager.java
View file @
9ccd781
...
...
@@ -2,7 +2,7 @@ package net.onrc.onos.of.ctl;
import
org.projectfloodlight.openflow.protocol.OFVersion
;
import
net.onrc.onos.of.ct
l.registry.IControllerRegistry
;
import
org.onlab.onos.of.controller.imp
l.registry.IControllerRegistry
;
/**
* Interface to passed to controller class in order to allow
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageCategory.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
annotations
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
annotations
;
import
java.lang.annotation.ElementType
;
import
java.lang.annotation.Target
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageDoc.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
annotations
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
annotations
;
import
java.lang.annotation.ElementType
;
import
java.lang.annotation.Target
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/annotations/LogMessageDocs.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
annotations
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
annotations
;
import
java.lang.annotation.ElementType
;
import
java.lang.annotation.Target
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/DebugCounter.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
debugcounter
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
debugcounter
;
import
java.util.ArrayList
;
import
java.util.Arrays
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/IDebugCounter.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
debugcounter
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
debugcounter
;
public
interface
IDebugCounter
{
/**
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/IDebugCounterService.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
debugcounter
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
debugcounter
;
import
java.util.List
;
import
net.onrc.onos.of.ct
l.debugcounter.DebugCounter.DebugCounterInfo
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.DebugCounter.DebugCounterInfo
;
public
interface
IDebugCounterService
{
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/debugcounter/NullDebugCounter.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
debugcounter
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
debugcounter
;
import
java.util.Collections
;
import
java.util.List
;
import
net.onrc.onos.of.ct
l.debugcounter.DebugCounter.DebugCounterInfo
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.DebugCounter.DebugCounterInfo
;
public
class
NullDebugCounter
implements
IDebugCounterService
{
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/Controller.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.lang.management.ManagementFactory
;
import
java.lang.management.RuntimeMXBean
;
...
...
@@ -31,20 +31,20 @@ import java.util.concurrent.Executors;
import
net.onrc.onos.of.ctl.IOFSwitchManager
;
import
net.onrc.onos.of.ctl.Role
;
import
net.onrc.onos.of.ct
l.annotations.LogMessageDoc
;
import
net.onrc.onos.of.ct
l.annotations.LogMessageDocs
;
import
net.onrc.onos.of.ct
l.debugcounter.DebugCounter
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounter
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterException
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterType
;
import
net.onrc.onos.of.ct
l.internal.OFChannelHandler.RoleRecvStatus
;
import
net.onrc.onos.of.ct
l.registry.IControllerRegistry
;
import
net.onrc.onos.of.ct
l.registry.RegistryException
;
import
net.onrc.onos.of.ct
l.registry.IControllerRegistry.ControlChangeCallback
;
import
net.onrc.onos.of.ct
l.util.Dpid
;
import
net.onrc.onos.of.ct
l.util.DummySwitchForTesting
;
import
net.onrc.onos.of.ct
l.util.InstanceId
;
import
org.onlab.onos.of.controller.imp
l.annotations.LogMessageDoc
;
import
org.onlab.onos.of.controller.imp
l.annotations.LogMessageDocs
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.DebugCounter
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounter
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterException
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterType
;
import
org.onlab.onos.of.controller.imp
l.internal.OFChannelHandler.RoleRecvStatus
;
import
org.onlab.onos.of.controller.imp
l.registry.IControllerRegistry
;
import
org.onlab.onos.of.controller.imp
l.registry.RegistryException
;
import
org.onlab.onos.of.controller.imp
l.registry.IControllerRegistry.ControlChangeCallback
;
import
org.onlab.onos.of.controller.imp
l.util.Dpid
;
import
org.onlab.onos.of.controller.imp
l.util.DummySwitchForTesting
;
import
org.onlab.onos.of.controller.imp
l.util.InstanceId
;
import
net.onrc.onos.of.ctl.IOFSwitch
;
import
net.onrc.onos.of.ctl.IOFSwitch.PortChangeType
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/HandshakeTimeoutException.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Exception is thrown when the handshake fails to complete.
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/HandshakeTimeoutHandler.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.util.concurrent.TimeUnit
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFChannelHandler.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.io.IOException
;
import
java.nio.channels.ClosedChannelException
;
...
...
@@ -12,11 +12,11 @@ import java.util.concurrent.RejectedExecutionException;
import
net.onrc.onos.of.ctl.IOFSwitch
;
import
net.onrc.onos.of.ctl.IOFSwitch.PortChangeEvent
;
import
net.onrc.onos.of.ctl.Role
;
import
net.onrc.onos.of.ct
l.annotations.LogMessageDoc
;
import
net.onrc.onos.of.ct
l.annotations.LogMessageDocs
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterException
;
import
net.onrc.onos.of.ct
l.internal.Controller.Counters
;
import
net.onrc.onos.of.ct
l.internal.OFChannelHandler.ChannelState.RoleReplyInfo
;
import
org.onlab.onos.of.controller.imp
l.annotations.LogMessageDoc
;
import
org.onlab.onos.of.controller.imp
l.annotations.LogMessageDocs
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterException
;
import
org.onlab.onos.of.controller.imp
l.internal.Controller.Counters
;
import
org.onlab.onos.of.controller.imp
l.internal.OFChannelHandler.ChannelState.RoleReplyInfo
;
import
org.jboss.netty.channel.Channel
;
import
org.jboss.netty.channel.ChannelHandlerContext
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFMessageDecoder.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
org.jboss.netty.buffer.ChannelBuffer
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OFMessageEncoder.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.util.List
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/OpenflowPipelineFactory.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.util.concurrent.ThreadPoolExecutor
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeAlreadyStarted.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Thrown when IOFSwitch.startDriverHandshake() is called more than once.
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeCompleted.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
org.projectfloodlight.openflow.protocol.OFMessage
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeException.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Base class for exception thrown by switch driver sub-handshake processing.
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeNotStarted.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Thrown when a switch driver's sub-handshake has not been started but an
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchDriverSubHandshakeStateException.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Thrown when a switch driver's sub-handshake state-machine receives an
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/internal/SwitchStateException.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* This exception indicates an error or unexpected message during
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/registry/ControllerRegistryEntry.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
registry
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
registry
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/registry/IControllerRegistry.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
registry
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
registry
;
import
java.util.Collection
;
import
java.util.List
;
import
java.util.Map
;
import
net.onrc.onos.of.ct
l.util.InstanceId
;
import
org.onlab.onos.of.controller.imp
l.util.InstanceId
;
/**
* A registry service that allows ONOS to register controllers and switches in a
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/registry/IdBlock.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
registry
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
registry
;
public
class
IdBlock
{
private
final
long
start
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/registry/RegistryException.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
registry
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
registry
;
public
class
RegistryException
extends
Exception
{
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/Dpid.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
org.projectfloodlight.openflow.util.HexString
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/DummySwitchForTesting.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.io.IOException
;
import
java.util.Collection
;
...
...
@@ -27,8 +27,8 @@ import org.slf4j.LoggerFactory;
import
net.onrc.onos.of.ctl.IOFSwitch
;
import
net.onrc.onos.of.ctl.Role
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterException
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterException
;
public
class
DummySwitchForTesting
implements
IOFSwitch
{
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/EnumBitmaps.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.EnumSet
;
import
java.util.Set
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/FilterIterator.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Iterator
;
import
java.util.NoSuchElementException
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/InstanceId.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
static
com
.
google
.
common
.
base
.
Preconditions
.
checkNotNull
;
import
static
com
.
google
.
common
.
base
.
Preconditions
.
checkArgument
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/IterableIterator.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Iterator
;
import
java.util.NoSuchElementException
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/LRUHashMap.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.LinkedHashMap
;
import
java.util.Map
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/LinkedHashSetWrapper.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Collection
;
import
java.util.LinkedHashSet
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/MultiIterator.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Iterator
;
import
java.util.NoSuchElementException
;
...
...
of-save/ctl/src/main/java/net/onrc/onos/of/ctl/util/OrderedCollection.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Collection
;
...
...
of-save/ctl/src/test/java/net/onrc/onos/of/ctl/internal/ControllerTest.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
junit.framework.TestCase
;
import
net.onrc.onos.of.ctl.IOFSwitch
;
...
...
of-save/ctl/src/test/java/net/onrc/onos/of/ctl/internal/OFChannelHandlerTest.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
static
org
.
easymock
.
EasyMock
.
capture
;
import
static
org
.
easymock
.
EasyMock
.
createMock
;
...
...
@@ -20,9 +20,9 @@ import java.util.Set;
import
net.onrc.onos.of.ctl.IOFSwitch
;
import
net.onrc.onos.of.ctl.Role
;
import
net.onrc.onos.of.ct
l.debugcounter.DebugCounter
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService
;
import
net.onrc.onos.of.ct
l.internal.OFChannelHandler.RoleRecvStatus
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.DebugCounter
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService
;
import
org.onlab.onos.of.controller.imp
l.internal.OFChannelHandler.RoleRecvStatus
;
import
org.easymock.Capture
;
import
org.easymock.CaptureType
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/IOFSwitch.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/IOFSwitch.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
;
import
java.io.IOException
;
import
java.util.Collection
;
...
...
@@ -25,9 +25,9 @@ import java.util.Map;
import
java.util.Set
;
import
java.util.concurrent.Future
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterException
;
import
net.onrc.onos.of.ct
l.util.OrderedCollection
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterException
;
import
org.onlab.onos.of.controller.imp
l.util.OrderedCollection
;
import
org.jboss.netty.channel.Channel
;
import
org.projectfloodlight.openflow.protocol.OFActionType
;
...
...
@@ -71,7 +71,6 @@ public interface IOFSwitch {
* Writes to the OFMessage to the output stream.
*
* @param m
* @param bc
* @throws IOException
*/
public
void
write
(
OFMessage
m
)
throws
IOException
;
...
...
@@ -80,7 +79,6 @@ public interface IOFSwitch {
* Writes the list of messages to the output stream.
*
* @param msglist
* @param bc
* @throws IOException
*/
public
void
write
(
List
<
OFMessage
>
msglist
)
throws
IOException
;
...
...
@@ -366,7 +364,7 @@ public interface IOFSwitch {
public
boolean
portEnabled
(
int
portName
);
/**
* @param portN
umber
* @param portN
ame
* @return Whether a port is enabled per latest port status message
* (not configured down nor link down nor in spanning tree blocking state)
*/
...
...
@@ -508,7 +506,7 @@ public interface IOFSwitch {
/**
* Set debug counter service for per-switch counters.
* Called immediately after instantiation.
* @param debugCounter
s
* @param debugCounter
* @throws CounterException
*/
public
void
setDebugCounterService
(
IDebugCounterService
debugCounter
)
...
...
@@ -520,7 +518,8 @@ public interface IOFSwitch {
* ready.
* This method must only be called from the I/O thread
* @throws IOException
* @throws SwitchDriverSubHandshakeAlreadyStarted if the sub-handshake has
* @throws org.onlab.onos.of.controller.impl.internal.SwitchDriverSubHandshakeAlreadyStarted
* if the sub-handshake has
* already been started
*/
public
void
startDriverHandshake
()
throws
IOException
;
...
...
@@ -531,7 +530,8 @@ public interface IOFSwitch {
*
* This methods must only be called from the I/O thread
* @return true if the sub-handshake has been completed. False otherwise
* @throws SwitchDriverSubHandshakeNotStarted if startDriverHandshake() has
* @throws org.onlab.onos.of.controller.impl.internal.SwitchDriverSubHandshakeNotStarted
* if startDriverHandshake() has
* not been called yet.
*/
public
boolean
isDriverHandshakeComplete
();
...
...
@@ -541,9 +541,11 @@ public interface IOFSwitch {
* sub-handshake. Must not be called after the handshake has been completed
* This methods must only be called from the I/O thread
* @param m The message that the driver should process
* @throws SwitchDriverSubHandshakeCompleted if isDriverHandshake() returns
* @throws org.onlab.onos.of.controller.impl.internal.SwitchDriverSubHandshakeCompleted
* if isDriverHandshake() returns
* false before this method call
* @throws SwitchDriverSubHandshakeNotStarted if startDriverHandshake() has
* @throws org.onlab.onos.of.controller.impl.internal.SwitchDriverSubHandshakeNotStarted
* if startDriverHandshake() has
* not been called yet.
*/
public
void
processDriverHandshakeMessage
(
OFMessage
m
);
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/IOFSwitchManager.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/IOFSwitchManager.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
;
import
org.projectfloodlight.openflow.protocol.OFVersion
;
import
net.onrc.onos.of.ct
l.registry.IControllerRegistry
;
import
org.onlab.onos.of.controller.imp
l.registry.IControllerRegistry
;
/**
* Interface to passed to controller class in order to allow
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/Role.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/Role.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
;
import
org.projectfloodlight.openflow.protocol.OFControllerRole
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/annotations/LogMessageCategory.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/annotations/LogMessageCategory.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
annotations
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
annotations
;
import
java.lang.annotation.ElementType
;
import
java.lang.annotation.Target
;
...
...
@@ -30,7 +30,7 @@ public @interface LogMessageCategory {
/**
* The category for the log messages for this class.
*
* @return
* @return
category
*/
String
value
()
default
"Core"
;
}
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/annotations/LogMessageDoc.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/annotations/LogMessageDoc.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
annotations
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
annotations
;
import
java.lang.annotation.ElementType
;
import
java.lang.annotation.Target
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/annotations/LogMessageDocs.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/annotations/LogMessageDocs.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
annotations
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
annotations
;
import
java.lang.annotation.ElementType
;
import
java.lang.annotation.Target
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/debugcounter/DebugCounter.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/debugcounter/DebugCounter.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
debugcounter
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
debugcounter
;
import
java.util.ArrayList
;
import
java.util.Arrays
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/debugcounter/IDebugCounter.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/debugcounter/IDebugCounter.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
debugcounter
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
debugcounter
;
public
interface
IDebugCounter
{
/**
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/debugcounter/IDebugCounterService.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/debugcounter/IDebugCounterService.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
debugcounter
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
debugcounter
;
import
java.util.List
;
import
net.onrc.onos.of.ct
l.debugcounter.DebugCounter.DebugCounterInfo
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.DebugCounter.DebugCounterInfo
;
//CHECKSTYLE:OFF
public
interface
IDebugCounterService
{
...
...
@@ -228,7 +228,8 @@ public interface IDebugCounterService {
* may not be enabled for counting, but if it is registered the method will
* return true.
*
* @param param
* @param moduleName
* @param counterHierarchy
* @return false if moduleCounterHierarchy is not a registered counter
*/
public
boolean
containsModuleCounterHierarchy
(
String
moduleName
,
...
...
@@ -240,7 +241,7 @@ public interface IDebugCounterService {
* a counter enabled for counting, but if it is registered the method will
* return true.
*
* @param
param
* @param
moduleName
* @return false if moduleName is not a registered counter
*/
public
boolean
containsModuleName
(
String
moduleName
);
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/debugcounter/NullDebugCounter.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/debugcounter/NullDebugCounter.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
debugcounter
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
debugcounter
;
import
java.util.Collections
;
import
java.util.List
;
import
net.onrc.onos.of.ct
l.debugcounter.DebugCounter.DebugCounterInfo
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.DebugCounter.DebugCounterInfo
;
//CHECKSTYLE:OFF
public
class
NullDebugCounter
implements
IDebugCounterService
{
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/Controller.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/Controller.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.lang.management.ManagementFactory
;
import
java.lang.management.RuntimeMXBean
;
...
...
@@ -29,24 +29,24 @@ import java.util.Set;
import
java.util.concurrent.ConcurrentHashMap
;
import
java.util.concurrent.Executors
;
import
net.onrc.onos.of.ct
l.IOFSwitchManager
;
import
net.onrc.onos.of.ct
l.Role
;
import
net.onrc.onos.of.ct
l.annotations.LogMessageDoc
;
import
net.onrc.onos.of.ct
l.annotations.LogMessageDocs
;
import
net.onrc.onos.of.ct
l.debugcounter.DebugCounter
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounter
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterException
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterType
;
import
net.onrc.onos.of.ct
l.internal.OFChannelHandler.RoleRecvStatus
;
import
net.onrc.onos.of.ct
l.registry.IControllerRegistry
;
import
net.onrc.onos.of.ct
l.registry.RegistryException
;
import
net.onrc.onos.of.ct
l.registry.IControllerRegistry.ControlChangeCallback
;
import
net.onrc.onos.of.ct
l.util.Dpid
;
import
net.onrc.onos.of.ct
l.util.DummySwitchForTesting
;
import
net.onrc.onos.of.ct
l.util.InstanceId
;
import
net.onrc.onos.of.ct
l.IOFSwitch
;
import
net.onrc.onos.of.ct
l.IOFSwitch.PortChangeType
;
import
org.onlab.onos.of.controller.imp
l.IOFSwitchManager
;
import
org.onlab.onos.of.controller.imp
l.Role
;
import
org.onlab.onos.of.controller.imp
l.annotations.LogMessageDoc
;
import
org.onlab.onos.of.controller.imp
l.annotations.LogMessageDocs
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.DebugCounter
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounter
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterException
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterType
;
import
org.onlab.onos.of.controller.imp
l.internal.OFChannelHandler.RoleRecvStatus
;
import
org.onlab.onos.of.controller.imp
l.registry.IControllerRegistry
;
import
org.onlab.onos.of.controller.imp
l.registry.RegistryException
;
import
org.onlab.onos.of.controller.imp
l.registry.IControllerRegistry.ControlChangeCallback
;
import
org.onlab.onos.of.controller.imp
l.util.Dpid
;
import
org.onlab.onos.of.controller.imp
l.util.DummySwitchForTesting
;
import
org.onlab.onos.of.controller.imp
l.util.InstanceId
;
import
org.onlab.onos.of.controller.imp
l.IOFSwitch
;
import
org.onlab.onos.of.controller.imp
l.IOFSwitch.PortChangeType
;
import
org.apache.felix.scr.annotations.Activate
;
import
org.apache.felix.scr.annotations.Component
;
...
...
@@ -242,7 +242,9 @@ public class Controller {
/**
* Indicates that ports on the given switch have changed. Enqueue a
* switch update.
* @param sw
* @param dpid
* @param port
* @param changeType
*/
protected
void
notifyPortChanged
(
long
dpid
,
OFPortDesc
port
,
PortChangeType
changeType
)
{
...
...
@@ -479,8 +481,6 @@ public class Controller {
/**
* Tell controller that we're ready to accept switches loop.
*
* @throws IOException
*/
@LogMessageDocs
({
@LogMessageDoc
(
message
=
"Listening for switch connections on {address}"
,
...
...
@@ -818,7 +818,7 @@ public class Controller {
/**
* Forward to the driver-manager to get an IOFSwitch instance.
* @param desc
* @return
* @return
switch instance
*/
protected
IOFSwitch
getOFSwitchInstance
(
OFDescStatsReply
desc
,
OFVersion
ofv
)
{
if
(
switchManager
==
null
)
{
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/HandshakeTimeoutException.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/HandshakeTimeoutException.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Exception is thrown when the handshake fails to complete.
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/HandshakeTimeoutHandler.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/HandshakeTimeoutHandler.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.util.concurrent.TimeUnit
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/OFChannelHandler.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/OFChannelHandler.java
View file @
9ccd781
//CHECKSTYLE:OFF
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.io.IOException
;
import
java.nio.channels.ClosedChannelException
;
...
...
@@ -10,14 +10,14 @@ import java.util.List;
import
java.util.concurrent.CopyOnWriteArrayList
;
import
java.util.concurrent.RejectedExecutionException
;
import
net.onrc.onos.of.ct
l.IOFSwitch
;
import
net.onrc.onos.of.ct
l.IOFSwitch.PortChangeEvent
;
import
net.onrc.onos.of.ct
l.Role
;
import
net.onrc.onos.of.ct
l.annotations.LogMessageDoc
;
import
net.onrc.onos.of.ct
l.annotations.LogMessageDocs
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterException
;
import
net.onrc.onos.of.ct
l.internal.Controller.Counters
;
import
net.onrc.onos.of.ct
l.internal.OFChannelHandler.ChannelState.RoleReplyInfo
;
import
org.onlab.onos.of.controller.imp
l.IOFSwitch
;
import
org.onlab.onos.of.controller.imp
l.IOFSwitch.PortChangeEvent
;
import
org.onlab.onos.of.controller.imp
l.Role
;
import
org.onlab.onos.of.controller.imp
l.annotations.LogMessageDoc
;
import
org.onlab.onos.of.controller.imp
l.annotations.LogMessageDocs
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterException
;
import
org.onlab.onos.of.controller.imp
l.internal.Controller.Counters
;
import
org.onlab.onos.of.controller.imp
l.internal.OFChannelHandler.ChannelState.RoleReplyInfo
;
import
org.jboss.netty.channel.Channel
;
import
org.jboss.netty.channel.ChannelHandlerContext
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/OFMessageDecoder.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/OFMessageDecoder.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
org.jboss.netty.buffer.ChannelBuffer
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/OFMessageEncoder.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/OFMessageEncoder.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.util.List
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/OpenflowPipelineFactory.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/OpenflowPipelineFactory.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
java.util.concurrent.ThreadPoolExecutor
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/SwitchDriverSubHandshakeAlreadyStarted.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/SwitchDriverSubHandshakeAlreadyStarted.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Thrown when IOFSwitch.startDriverHandshake() is called more than once.
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/SwitchDriverSubHandshakeCompleted.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/SwitchDriverSubHandshakeCompleted.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
org.projectfloodlight.openflow.protocol.OFMessage
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/SwitchDriverSubHandshakeException.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/SwitchDriverSubHandshakeException.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Base class for exception thrown by switch driver sub-handshake processing.
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/SwitchDriverSubHandshakeNotStarted.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/SwitchDriverSubHandshakeNotStarted.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Thrown when a switch driver's sub-handshake has not been started but an
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/SwitchDriverSubHandshakeStateException.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/SwitchDriverSubHandshakeStateException.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* Thrown when a switch driver's sub-handshake state-machine receives an
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/internal/SwitchStateException.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/internal/SwitchStateException.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
/**
* This exception indicates an error or unexpected message during
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/registry/ControllerRegistryEntry.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/registry/ControllerRegistryEntry.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
registry
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
registry
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/registry/IControllerRegistry.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/registry/IControllerRegistry.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
registry
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
registry
;
import
java.util.Collection
;
import
java.util.List
;
import
java.util.Map
;
import
net.onrc.onos.of.ct
l.util.InstanceId
;
import
org.onlab.onos.of.controller.imp
l.util.InstanceId
;
/**
* A registry service that allows ONOS to register controllers and switches in a
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/registry/IdBlock.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/registry/IdBlock.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
registry
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
registry
;
public
class
IdBlock
{
private
final
long
start
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/registry/RegistryException.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/registry/RegistryException.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
registry
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
registry
;
public
class
RegistryException
extends
Exception
{
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/Dpid.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/Dpid.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
org.projectfloodlight.openflow.util.HexString
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/DummySwitchForTesting.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/DummySwitchForTesting.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.io.IOException
;
import
java.util.Collection
;
...
...
@@ -25,10 +25,10 @@ import org.projectfloodlight.openflow.types.U64;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
net.onrc.onos.of.ct
l.IOFSwitch
;
import
net.onrc.onos.of.ct
l.Role
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService.CounterException
;
import
org.onlab.onos.of.controller.imp
l.IOFSwitch
;
import
org.onlab.onos.of.controller.imp
l.Role
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService.CounterException
;
public
class
DummySwitchForTesting
implements
IOFSwitch
{
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/EnumBitmaps.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/EnumBitmaps.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.EnumSet
;
import
java.util.Set
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/FilterIterator.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/FilterIterator.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Iterator
;
import
java.util.NoSuchElementException
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/InstanceId.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/InstanceId.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
static
com
.
google
.
common
.
base
.
Preconditions
.
checkNotNull
;
import
static
com
.
google
.
common
.
base
.
Preconditions
.
checkArgument
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/IterableIterator.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/IterableIterator.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Iterator
;
import
java.util.NoSuchElementException
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/LRUHashMap.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/LRUHashMap.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.LinkedHashMap
;
import
java.util.Map
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/LinkedHashSetWrapper.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/LinkedHashSetWrapper.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Collection
;
import
java.util.LinkedHashSet
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/MultiIterator.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/MultiIterator.java
View file @
9ccd781
...
...
@@ -15,7 +15,7 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Iterator
;
import
java.util.NoSuchElementException
;
...
...
of/ctl/src/main/java/
net/onrc/onos/of/ct
l/util/OrderedCollection.java
→
of/ctl/src/main/java/
org/onlab/onos/of/controller/imp
l/util/OrderedCollection.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
util
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
util
;
import
java.util.Collection
;
...
...
of/ctl/src/test/java/
net/onrc/onos/of/ct
l/internal/ControllerTest.java
→
of/ctl/src/test/java/
org/onlab/onos/of/controller/imp
l/internal/ControllerTest.java
View file @
9ccd781
...
...
@@ -15,10 +15,10 @@
* under the License.
**/
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
junit.framework.TestCase
;
import
net.onrc.onos.of.ct
l.IOFSwitch
;
import
org.onlab.onos.of.controller.imp
l.IOFSwitch
;
import
org.easymock.EasyMock
;
import
org.junit.After
;
...
...
of/ctl/src/test/java/
net/onrc/onos/of/ct
l/internal/OFChannelHandlerTest.java
→
of/ctl/src/test/java/
org/onlab/onos/of/controller/imp
l/internal/OFChannelHandlerTest.java
View file @
9ccd781
package
net
.
onrc
.
onos
.
of
.
ct
l
.
internal
;
package
org
.
onlab
.
onos
.
of
.
controller
.
imp
l
.
internal
;
import
static
org
.
easymock
.
EasyMock
.
capture
;
import
static
org
.
easymock
.
EasyMock
.
createMock
;
...
...
@@ -18,11 +18,11 @@ import java.util.HashSet;
import
java.util.List
;
import
java.util.Set
;
import
net.onrc.onos.of.ct
l.IOFSwitch
;
import
net.onrc.onos.of.ct
l.Role
;
import
net.onrc.onos.of.ct
l.debugcounter.DebugCounter
;
import
net.onrc.onos.of.ct
l.debugcounter.IDebugCounterService
;
import
net.onrc.onos.of.ct
l.internal.OFChannelHandler.RoleRecvStatus
;
import
org.onlab.onos.of.controller.imp
l.IOFSwitch
;
import
org.onlab.onos.of.controller.imp
l.Role
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.DebugCounter
;
import
org.onlab.onos.of.controller.imp
l.debugcounter.IDebugCounterService
;
import
org.onlab.onos.of.controller.imp
l.internal.OFChannelHandler.RoleRecvStatus
;
import
org.easymock.Capture
;
import
org.easymock.CaptureType
;
...
...
pom.xml
View file @
9ccd781
...
...
@@ -248,7 +248,7 @@
<group>
<title>
Network Model
&
Services
</title>
<packages>
org.onlab.onos.
net:org.onlab.onos.net.
*
org.onlab.onos.*
</packages>
</group>
<group>
...
...
Please
register
or
login
to post a comment