/** * Parse set_dl_dst actions. * The key and delimiter for the action should be omitted, and only the * data should be presented to this decoder. * * TODO should consider using MacAddress's built-in parser.... * * @param actionToDecode; The action as a string to decode * @param version; The OF version to create the action for * @param log * @return */ private static OFActionSetDlDst decode_set_dst_mac(String actionToDecode, OFVersion version, Logger log) { Matcher n = Pattern.compile("(?:(\\p{XDigit}+)\\:(\\p{XDigit}+)\\:(\\p{XDigit}+)\\:(\\p{XDigit}+)\\:(\\p{XDigit}+)\\:(\\p{XDigit}+))").matcher(actionToDecode); if (n.matches()) { MacAddress macaddr = MacAddress.of(get_mac_addr(n, actionToDecode, log)); if (macaddr != null) { OFActionSetDlDst.Builder ab = OFFactories.getFactory(version).actions().buildSetDlDst(); ab.setDlAddr(macaddr); log.debug("action {}", ab.build()); return ab.build(); } } else { log.debug("Invalid action: '{}'", actionToDecode); return null; } return null; }
public FlowAlias(OFFlowMod flowmod){ this.ofm = flowmod; this.aliasList = new ArrayList<>(); this.fra = FlowRuleAction.DROP; this.lastConflictAlias = null; Match match = flowmod.getMatch(); Match.Builder mb = match.createBuilder(); List<OFAction> actions = flowmod.getActions(); //initialize alias with match filed Alias alias = new Alias(match); //add alias to list this.aliasList.add(alias); //update alias based on actions for (OFAction act : actions){ switch (act.getType()){ case SET_DL_SRC: OFActionSetDlSrc setDLSRC = (OFActionSetDlSrc)act; mb.setExact(MatchField.ETH_SRC, setDLSRC.getDlAddr()); break; case SET_DL_DST: OFActionSetDlDst setDLDST = (OFActionSetDlDst)act; mb.setExact(MatchField.ETH_DST, setDLDST.getDlAddr()); break; case SET_NW_SRC: OFActionSetNwSrc setNWSRC = (OFActionSetNwSrc)act; mb.setExact(MatchField.IPV4_SRC,setNWSRC.getNwAddr()); break; case SET_NW_DST: OFActionSetNwDst setNWDST = (OFActionSetNwDst)act; mb.setExact(MatchField.IPV4_DST,setNWDST.getNwAddr()); break; case SET_TP_SRC: OFActionSetTpSrc setTPSRC = (OFActionSetTpSrc)act; mb.setExact(MatchField.TCP_SRC, setTPSRC.getTpPort()); break; case SET_TP_DST: OFActionSetTpDst setTPDST = (OFActionSetTpDst)act; mb.setExact(MatchField.TCP_SRC, setTPDST.getTpPort()); break; case ENQUEUE: case OUTPUT: OFActionOutput output = (OFActionOutput)act; alias.setPort(output.getPort()); this.fra = FlowRuleAction.FORWARD; break; } } //save modified action alias.setMatch(mb.build()); //add updated alias to the list this.aliasList.add(alias); }