Skip to content
Snippets Groups Projects
Commit 1bb2585d authored by Ryan Izard's avatar Ryan Izard
Browse files

Merge pull request #592 from rizard/master

Allow Load Balancer to LB multiple connections from single source host
parents 39518413 a40165e7
No related branches found
No related tags found
No related merge requests found
...@@ -512,7 +512,8 @@ public class LoadBalancer implements IFloodlightModule, ...@@ -512,7 +512,8 @@ public class LoadBalancer implements IFloodlightModule,
fmb.setPriority(FlowModUtils.PRIORITY_MAX); fmb.setPriority(FlowModUtils.PRIORITY_MAX);
if (inBound) { if (inBound) {
entryName = "inbound-vip-"+ member.vipId+"-client-"+client.ipAddress+"-port-"+client.targetPort entryName = "inbound-vip-"+ member.vipId+"-client-"+client.ipAddress
+"-srcport-"+client.srcPort+"-dstport-"+client.targetPort
+"-srcswitch-"+path.get(0).getNodeId()+"-sw-"+sw; +"-srcswitch-"+path.get(0).getNodeId()+"-sw-"+sw;
mb.setExact(MatchField.ETH_TYPE, EthType.IPv4) mb.setExact(MatchField.ETH_TYPE, EthType.IPv4)
.setExact(MatchField.IP_PROTO, client.nw_proto) .setExact(MatchField.IP_PROTO, client.nw_proto)
...@@ -545,7 +546,8 @@ public class LoadBalancer implements IFloodlightModule, ...@@ -545,7 +546,8 @@ public class LoadBalancer implements IFloodlightModule,
actions.add(switchService.getSwitch(path.get(i+1).getNodeId()).getOFFactory().actions().output(path.get(i+1).getPortId(), Integer.MAX_VALUE)); actions.add(switchService.getSwitch(path.get(i+1).getNodeId()).getOFFactory().actions().output(path.get(i+1).getPortId(), Integer.MAX_VALUE));
} }
} else { } else {
entryName = "outbound-vip-"+ member.vipId+"-client-"+client.ipAddress+"-port-"+client.targetPort entryName = "outbound-vip-"+ member.vipId+"-client-"+client.ipAddress
+"-srcport-"+client.srcPort+"-dstport-"+client.targetPort
+"-srcswitch-"+path.get(0).getNodeId()+"-sw-"+sw; +"-srcswitch-"+path.get(0).getNodeId()+"-sw-"+sw;
mb.setExact(MatchField.ETH_TYPE, EthType.IPv4) mb.setExact(MatchField.ETH_TYPE, EthType.IPv4)
.setExact(MatchField.IP_PROTO, client.nw_proto) .setExact(MatchField.IP_PROTO, client.nw_proto)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment