@Get("json") public OFFlowModMap ListStaticFlowEntries() { IStaticFlowEntryPusherService sfpService = (IStaticFlowEntryPusherService)getContext().getAttributes(). get(IStaticFlowEntryPusherService.class.getCanonicalName()); String param = (String) getRequestAttributes().get("switch"); if (log.isDebugEnabled()) log.debug("Listing all static flow entires for switch: " + param); if (param.toLowerCase().equals("all")) { return new OFFlowModMap(sfpService.getFlows()); } else { try { Map<String, Map<String, OFFlowMod>> retMap = new HashMap<String, Map<String, OFFlowMod>>(); retMap.put(param, sfpService.getFlows(DatapathId.of(param))); return new OFFlowModMap(retMap); } catch (NumberFormatException e){ setStatus(Status.CLIENT_ERROR_BAD_REQUEST, ControllerSwitchesResource.DPID_ERROR); } } return null; }
@Get("json") public String ClearStaticFlowEntries() { IStaticFlowEntryPusherService sfpService = (IStaticFlowEntryPusherService)getContext().getAttributes(). get(IStaticFlowEntryPusherService.class.getCanonicalName()); String param = (String) getRequestAttributes().get("switch"); if (log.isDebugEnabled()) log.debug("Clearing all static flow entires for switch: " + param); if (param.toLowerCase().equals("all")) { sfpService.deleteAllFlows(); return "{\"status\":\"Deleted all flows.\"}"; } else { try { sfpService.deleteFlowsForSwitch(DatapathId.of(param)); return "{\"status\":\"Deleted all flows for switch " + param + ".\"}"; } catch (NumberFormatException e){ setStatus(Status.CLIENT_ERROR_BAD_REQUEST, ControllerSwitchesResource.DPID_ERROR); return "'{\"status\":\"Could not delete flows requested! See controller log for details.\"}'"; } } }
@Get public Map<String, Map<String, OFFlowMod>> ListStaticFlowEntries() { IStaticFlowEntryPusherService sfpService = (IStaticFlowEntryPusherService)getContext().getAttributes(). get(IStaticFlowEntryPusherService.class.getCanonicalName()); String param = (String) getRequestAttributes().get("switch"); if (log.isDebugEnabled()) log.debug("Listing all static flow entires for switch: " + param); if (param.toLowerCase().equals("all")) { return sfpService.getFlows(); } else { try { Map<String, Map<String, OFFlowMod>> retMap = new HashMap<String, Map<String, OFFlowMod>>(); retMap.put(param, sfpService.getFlows(param)); return retMap; } catch (NumberFormatException e){ setStatus(Status.CLIENT_ERROR_BAD_REQUEST, ControllerSwitchesResource.DPID_ERROR); } } return null; }
@Get public void ClearStaticFlowEntries() { IStaticFlowEntryPusherService sfpService = (IStaticFlowEntryPusherService)getContext().getAttributes(). get(IStaticFlowEntryPusherService.class.getCanonicalName()); String param = (String) getRequestAttributes().get("switch"); if (log.isDebugEnabled()) log.debug("Clearing all static flow entires for switch: " + param); if (param.toLowerCase().equals("all")) { sfpService.deleteAllFlows(); } else { try { sfpService.deleteFlowsForSwitch(HexString.toLong(param)); } catch (NumberFormatException e){ setStatus(Status.CLIENT_ERROR_BAD_REQUEST, ControllerSwitchesResource.DPID_ERROR); return; } } }