From f8a51af7ae5c6910d055cccbd9a988f29f508ec3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Volkan=20Yaz=C4=B1c=C4=B1?= <volkan.yazici@gmail.com>
Date: Fri, 22 Feb 2013 10:23:01 +0200
Subject: [PATCH] Add 'openflowhost' parameter for core.FloodlightProvider.
---
.../core/internal/Controller.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
diff --git a/src/main/java/net/floodlightcontroller/core/internal/Controller.java b/src/main/java/net/floodlightcontroller/core/internal/Controller.java
index 1a41b9bb7..f2f52cac5 100644
--- a/src/main/java/net/floodlightcontroller/core/internal/Controller.java
+++ b/src/main/java/net/floodlightcontroller/core/internal/Controller.java
@@ -174,6 +174,7 @@ public class Controller implements IFloodlightProviderService,
protected IThreadPoolService threadPool;
// Configuration options
+ protected String openFlowHost = null;
protected int openFlowPort = 6633;
protected int workerThreads = 0;
// The id for this controller node. Should be unique for each controller
@@ -1704,7 +1705,10 @@ public class Controller implements IFloodlightProviderService,
ChannelPipelineFactory pfact =
new OpenflowPipelineFactory(this, null);
bootstrap.setPipelineFactory(pfact);
- InetSocketAddress sa = new InetSocketAddress(openFlowPort);
+ InetSocketAddress sa =
+ (openFlowHost == null)
+ ? new InetSocketAddress(openFlowPort)
+ : new InetSocketAddress(openFlowHost, openFlowPort);
final ChannelGroup cg = new DefaultChannelGroup();
cg.add(bootstrap.bind(sa));
@@ -1745,6 +1749,11 @@ public class Controller implements IFloodlightProviderService,
}
public void setConfigParams(Map<String, String> configParams) {
+ String ofHost = configParams.get("openflowhost");
+ if (ofHost != null) {
+ this.openFlowHost = ofHost;
+ log.debug("OpenFlow host set to {}", this.openFlowHost);
+ }
String ofPort = configParams.get("openflowport");
if (ofPort != null) {
this.openFlowPort = Integer.parseInt(ofPort);
--
GitLab