本文整理汇总了Java中net.floodlightcontroller.routing.Route类的典型用法代码示例。如果您正苦于以下问题：Java Route类的具体用法？Java Route怎么用？Java Route使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Route类属于net.floodlightcontroller.routing包，在下文中一共展示了Route类的16个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getRoute
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
protected Route getRoute(DatapathId srcId, DatapathId dstId, U64 cookie) {
// Return null route if srcId equals dstId
if (srcId.equals(dstId)) return null;
RouteId id = new RouteId(srcId, dstId);
Route result = null;
try {
result = pathcache.get(id);
} catch (Exception e) {
log.error("{}", e);
}
if (log.isTraceEnabled()) {
log.trace("getRoute: {} -> {}", id, result);
}
return result;
}
开发者ID:xuraylei，项目名称:fresco_floodlight，代码行数:19，代码来源:TopologyInstance.java
示例2: getObfuscationMask
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
public ObfuscationMask getObfuscationMask(long dst, IOFSwitch sw, Route route) {
//System.out.println("get mask for " + dst);
if (!checkMaskID(dst, route)) { // need new mask
if (obfuscationMasks.containsKey(dst)) { // remove because mask must not be used anymore
//System.out.println("*** remove mask !***");
obfuscationMasks.remove(dst);
oLinkStateManager.resetNumberOfMaskUsages(dst);
}
}
if (!obfuscationMasks.containsKey(dst)) {
System.out.println("*** create new mask ***");
obfuscationMasks.put(dst, createNewObfuscationMask(dst));
}
return obfuscationMasks.get(dst);
}
开发者ID:nsg-ethz，项目名称:iTAP-controller，代码行数:18，代码来源:ObfuscationMaskManager.java
示例3: checkMaskID
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
private boolean checkMaskID(long dst, Route route) {
return true;
/*
if (!obfuscationMasks.containsKey(dst))
return false;
else if (obfuscationMasks.get(dst).getAvailableSourceIDs().size() == 0)
return false;
else if (obfuscationMasks.get(dst).getAvailableDestinationIDs().size() == 0)
return false;
if ((route != null) && (route.getPath().size() >= 2)) {
for (NodePortTuple l: route.getPath()) {
Iterator<Link> it = linkDiscoveryService.getPortLinks().get(l).iterator();
while (it.hasNext()) {
Link link = it.next();
if (oLinkStateManager.getNumberOfMaskUsages(link, dst) +1 > ObfuscationPolicy.UNICITY_DISTANCE)
return false;
}
}
}
return true;*/
}
开发者ID:nsg-ethz，项目名称:iTAP-controller，代码行数:23，代码来源:ObfuscationMaskManager.java
示例4: getUnicityDiff
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
/**
* returns the minimum of the difference between the unicity distance and the number of mask usages for each link of the route
* @param mask_id
* @param route
* @return
*/
public float getUnicityDiff(long dst, Route route) {
return 999;/*
//System.out.println("getUnicityDiff for mask"+mask_id);
float min = Float.MAX_VALUE;
if ((route != null) && (route.getPath().size() >= 2)) {
for (NodePortTuple l: route.getPath()) {
Iterator<Link> it = linkDiscoveryService.getPortLinks().get(l).iterator();
while (it.hasNext()) {
Link link = it.next();
//System.out.println("getObservedEntropy="+oLinkStateManager.getObservedEntropy(link, mask_id));
//System.out.println("getNumberOfMaskUsages="+oLinkStateManager.getNumberOfMaskUsages(link, mask_id));
min = Math.min(min, ObfuscationPolicy.UNICITY_DISTANCE-oLinkStateManager.getNumberOfMaskUsages(link, dst));
}
}
}
return min;*/
}
开发者ID:nsg-ethz，项目名称:iTAP-controller，代码行数:25，代码来源:ObfuscationMaskManager.java
示例5: getRoutes
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
public ArrayList<Route> getRoutes(DatapathId srcDpid, DatapathId dstDpid, boolean tunnelEnabled, int maxLength) {
ArrayList<DatapathId> v = new ArrayList<DatapathId>();
ArrayList<Route> routes = new ArrayList<Route>();
//routesList.clear();
ArrayList<Stack<NodePortTuple>> routesList = new ArrayList<Stack<NodePortTuple>>();
this.searchDfs(routesList,srcDpid,dstDpid,v,maxLength+1 /* +1 because #switches = #hops+1*/, new Stack<NodePortTuple>());
for(Stack<NodePortTuple> r:routesList){
ArrayList<NodePortTuple> ports = new ArrayList<NodePortTuple>();
for(NodePortTuple np:r){
ports.add(np);
}
Route path = new Route(srcDpid, dstDpid);
path.setPath(ports);
routes.add(path);
}
return routes;
}
开发者ID:nsg-ethz，项目名称:iTAP-controller，代码行数:23，代码来源:ObfuscationTopologyManager.java
示例6: getRoute
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
protected Route getRoute(DatapathId srcId, DatapathId dstId, U64 cookie) {
// Return null route if srcId equals dstId
if (srcId.equals(dstId)) return null;
RouteId id = new RouteId(srcId, dstId);
Route result = null;
try {
result = pathcache.get(id);
} catch (Exception e) {
log.error("{}", e);
}
if (log.isTraceEnabled()) {
log.trace("getRoute: {} -> {}", id, result);
}
return result;
}
开发者ID:nsg-ethz，项目名称:iTAP-controller，代码行数:20，代码来源:TopologyInstance.java
示例7: MulticastTree
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
MulticastTree(String IP, AttachmentPoint srcAP, MulticastController mc, MulticastGroup group) {
sourceIP = IPv4.toIPv4Address(IP);
memberPorts = new ConcurrentHashMap<Long, HashSet<OFPort>>();
destinationDevices = new Vector<AttachmentPoint> ();
this.mcObject = mc;
routingService = mc.routingService;
treeUpink = new ConcurrentHashMap<Long, Link>();
switchService = mc.switchService;
linkDiscService = mc.lds;
floodlightProviderService = mc.floodlightProvider;
flowPusher = mc.flowPusher;
sourceAP = srcAP;
pathsForDestinations = new ConcurrentHashMap<Long, Route>();
multicastGroup = group;
sendOFFlowModDropMulticastStream(switchService.getSwitch(srcAP.getSw()), true);
}
开发者ID:hksoni，项目名称:SDN-Multicast，代码行数:18，代码来源:MulticastTree.java
示例8: getRoute
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
protected Route getRoute(long srcId, long dstId, long cookie) {
// Return null route if srcId equals dstId
if (srcId == dstId) return null;
RouteId id = new RouteId(srcId, dstId);
Route result = null;
try {
result = pathcache.get(id);
} catch (Exception e) {
log.error("{}", e);
}
if (log.isTraceEnabled()) {
log.trace("getRoute: {} -> {}", id, result);
}
return result;
}
开发者ID:JianqingJiang，项目名称:QoS-floodlight，代码行数:20，代码来源:TopologyInstance.java
示例9: retrieve
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
@Get("json")
public List<NodePortTuple> retrieve() {
IRoutingService routing =
(IRoutingService)getContext().getAttributes().
get(IRoutingService.class.getCanonicalName());
String srcDpid = (String) getRequestAttributes().get("src-dpid");
String srcPort = (String) getRequestAttributes().get("src-port");
String dstDpid = (String) getRequestAttributes().get("dst-dpid");
String dstPort = (String) getRequestAttributes().get("dst-port");
log.debug( srcDpid + "--" + srcPort + "--" + dstDpid + "--" + dstPort);
DatapathId longSrcDpid = DatapathId.of(srcDpid);
OFPort shortSrcPort = OFPort.of(Integer.parseInt(srcPort));
DatapathId longDstDpid = DatapathId.of(dstDpid);
OFPort shortDstPort = OFPort.of(Integer.parseInt(dstPort));
Route result = routing.getRoute(longSrcDpid, shortSrcPort, longDstDpid, shortDstPort, U64.of(0));
if (result != null) {
return routing.getRoute(longSrcDpid, shortSrcPort, longDstDpid, shortDstPort, U64.of(0)).getPath();
}
else {
log.debug("ERROR! no route found");
return null;
}
}
开发者ID:xuraylei，项目名称:fresco_floodlight，代码行数:29，代码来源:RouteResource.java
示例10: getRoutes
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
@Override
public ArrayList<Route> getRoutes(DatapathId srcDpid, DatapathId dstDpid,
boolean tunnelEnabled) {
// Floodlight supports single path routing now
// return single path now
ArrayList<Route> result=new ArrayList<Route>();
result.add(getRoute(srcDpid, dstDpid, U64.of(0), tunnelEnabled));
return result;
}
开发者ID:xuraylei，项目名称:fresco_floodlight，代码行数:11，代码来源:TopologyManager.java
示例11: TopologyInstance
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
public TopologyInstance(Map<DatapathId, Set<OFPort>> switchPorts,
Set<NodePortTuple> blockedPorts,
Map<NodePortTuple, Set<Link>> switchPortLinks,
Set<NodePortTuple> broadcastDomainPorts,
Set<NodePortTuple> tunnelPorts){
// copy these structures
this.switches = new HashSet<DatapathId>(switchPorts.keySet());
this.switchPorts = new HashMap<DatapathId, Set<OFPort>>();
for(DatapathId sw: switchPorts.keySet()) {
this.switchPorts.put(sw, new HashSet<OFPort>(switchPorts.get(sw)));
}
this.blockedPorts = new HashSet<NodePortTuple>(blockedPorts);
this.switchPortLinks = new HashMap<NodePortTuple, Set<Link>>();
for(NodePortTuple npt: switchPortLinks.keySet()) {
this.switchPortLinks.put(npt,
new HashSet<Link>(switchPortLinks.get(npt)));
}
this.broadcastDomainPorts = new HashSet<NodePortTuple>(broadcastDomainPorts);
this.tunnelPorts = new HashSet<NodePortTuple>(tunnelPorts);
blockedLinks = new HashSet<Link>();
clusters = new HashSet<Cluster>();
switchClusterMap = new HashMap<DatapathId, Cluster>();
destinationRootedTrees = new HashMap<DatapathId, BroadcastTree>();
clusterBroadcastTrees = new HashMap<DatapathId, BroadcastTree>();
clusterBroadcastNodePorts = new HashMap<DatapathId, Set<NodePortTuple>>();
pathcache = CacheBuilder.newBuilder().concurrencyLevel(4)
.maximumSize(1000L)
.build(
new CacheLoader<RouteId, Route>() {
public Route load(RouteId rid) {
return pathCacheLoader.load(rid);
}
});
}
开发者ID:nsg-ethz，项目名称:iTAP-controller，代码行数:39，代码来源:TopologyInstance.java
示例12: removeMemberFromTheTree
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
public void removeMemberFromTheTree(AttachmentPoint ap) {
/* Remove flow from edge switch */
DatapathId dSWId = ap.getSw();
IOFSwitch dSW = switchService.getSwitch(dSWId);
HashSet<OFPort> nps;
Route r = pathsForDestinations.get(ap.getSw().getLong());
if (r == null)
return;
NodePortTuple from = null;
List<NodePortTuple> path = r.getPath();
ListIterator<NodePortTuple> it = path.listIterator(path.size());
while (it.hasPrevious()) {
from = it.previous();
dSWId = from.getNodeId();
dSW = switchService.getSwitch(dSWId);
nps = memberPorts.get(dSWId.getLong());
if (nps == null) {
logger.info("RemoveMemberFromTheTree: unexpected null nps");
return;
}
nps.remove(from.getPortId());
if (nps.size() != 0) {
sendOFGroupModDelMemberMsg(dSW, from.getPortId());
/* switch has downstream member other than one removed*/
break;
}
memberPorts.remove(dSWId.getLong());
if (dSWId.getLong() == sourceAP.getSw().getLong())
sendOFFlowModDropMulticastStream(dSW, false);
else
sendOFFlowModDelForGroup(dSW);
pushOFDeleteGroup(dSW);
if (it.hasPrevious())
from = it.previous();
}
pathsForDestinations.remove(ap.getSw().getLong());
}
开发者ID:hksoni，项目名称:SDN-Multicast，代码行数:39，代码来源:MulticastTree.java
示例13: retrieve
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
@Get("json")
public List<NodePortTuple> retrieve() {
IRoutingService routing =
(IRoutingService)getContext().getAttributes().
get(IRoutingService.class.getCanonicalName());
String srcDpid = (String) getRequestAttributes().get("src-dpid");
String srcPort = (String) getRequestAttributes().get("src-port");
String dstDpid = (String) getRequestAttributes().get("dst-dpid");
String dstPort = (String) getRequestAttributes().get("dst-port");
log.debug( srcDpid + "--" + srcPort + "--" + dstDpid + "--" + dstPort);
long longSrcDpid = HexString.toLong(srcDpid);
short shortSrcPort = Short.parseShort(srcPort);
long longDstDpid = HexString.toLong(dstDpid);
short shortDstPort = Short.parseShort(dstPort);
Route result = routing.getRoute(longSrcDpid, shortSrcPort, longDstDpid, shortDstPort, 0);
if (result!=null) {
return routing.getRoute(longSrcDpid, shortSrcPort, longDstDpid, shortDstPort, 0).getPath();
}
else {
log.debug("ERROR! no route found");
return null;
}
}
开发者ID:JianqingJiang，项目名称:QoS-floodlight，代码行数:29，代码来源:RouteResource.java
示例14: TopologyInstance
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
public TopologyInstance(Map<Long, Set<Short>> switchPorts,
Set<NodePortTuple> blockedPorts,
Map<NodePortTuple, Set<Link>> switchPortLinks,
Set<NodePortTuple> broadcastDomainPorts,
Set<NodePortTuple> tunnelPorts){
// copy these structures
this.switches = new HashSet<Long>(switchPorts.keySet());
this.switchPorts = new HashMap<Long, Set<Short>>();
for(long sw: switchPorts.keySet()) {
this.switchPorts.put(sw, new HashSet<Short>(switchPorts.get(sw)));
}
this.blockedPorts = new HashSet<NodePortTuple>(blockedPorts);
this.switchPortLinks = new HashMap<NodePortTuple, Set<Link>>();
for(NodePortTuple npt: switchPortLinks.keySet()) {
this.switchPortLinks.put(npt,
new HashSet<Link>(switchPortLinks.get(npt)));
}
this.broadcastDomainPorts = new HashSet<NodePortTuple>(broadcastDomainPorts);
this.tunnelPorts = new HashSet<NodePortTuple>(tunnelPorts);
blockedLinks = new HashSet<Link>();
clusters = new HashSet<Cluster>();
switchClusterMap = new HashMap<Long, Cluster>();
destinationRootedTrees = new HashMap<Long, BroadcastTree>();
clusterBroadcastTrees = new HashMap<Long, BroadcastTree>();
clusterBroadcastNodePorts = new HashMap<Long, Set<NodePortTuple>>();
pathcache = CacheBuilder.newBuilder().concurrencyLevel(4)
.maximumSize(1000L)
.build(
new CacheLoader<RouteId, Route>() {
public Route load(RouteId rid) {
return pathCacheLoader.load(rid);
}
});
}
开发者ID:JianqingJiang，项目名称:QoS-floodlight，代码行数:39，代码来源:TopologyInstance.java
示例15: getRoutes
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
@Override
public ArrayList<Route> getRoutes(long srcDpid, long dstDpid,
boolean tunnelEnabled) {
// Floodlight supports single path routing now
// return single path now
ArrayList<Route> result=new ArrayList<Route>();
result.add(getRoute(srcDpid, dstDpid, 0, tunnelEnabled));
return result;
}
开发者ID:JianqingJiang，项目名称:QoS-floodlight，代码行数:11，代码来源:TopologyManager.java
示例16: retrieve
import net.floodlightcontroller.routing.Route; //导入依赖的package包/类
@Get("json")
public List<NodePortTuple> retrieve() {
IRoutingService routing =
(IRoutingService)getContext().getAttributes().
get(IRoutingService.class.getCanonicalName());
String srcDpid = (String) getRequestAttributes().get("src-dpid");
String srcPort = (String) getRequestAttributes().get("src-port");
String dstDpid = (String) getRequestAttributes().get("dst-dpid");
String dstPort = (String) getRequestAttributes().get("dst-port");
log.debug( srcDpid + "--" + srcPort + "--" + dstDpid + "--" + dstPort);
DatapathId longSrcDpid = DatapathId.of(srcDpid);
OFPort shortSrcPort = OFPort.of(Integer.parseInt(srcPort));
DatapathId longDstDpid = DatapathId.of(dstDpid);
OFPort shortDstPort = OFPort.of(Integer.parseInt(dstPort));
Route result = routing.getRoute(longSrcDpid, shortSrcPort, longDstDpid, shortDstPort, U64.of(0));
if (result != null) {
return routing.getRoute(longSrcDpid, shortSrcPort, longDstDpid, shortDstPort, U64.of(0)).getPath();
}
else {
log.debug("ERROR! no route found");
return null;
}
}
开发者ID:zhenshengcai，项目名称:floodlight-hardware，代码行数:29，代码来源:RouteResource.java
注：本文中的net.floodlightcontroller.routing.Route类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论