import org.projectfloodlight.openflow.protocol.action.OFActionSetTpSrc; //导入依赖的package包/类
/**
 * Parse set_tp_src actions.
 * The key and delimiter for the action should be omitted, and only the
 * data should be presented to this decoder. A leading 0x is permitted.
 * 
 * @param actionToDecode; The action as a string to decode
 * @param version; The OF version to create the action for
 * @param log
 * @return
 */
private static OFActionSetTpSrc decode_set_src_port(String actionToDecode, OFVersion version, Logger log) {
	Matcher n = Pattern.compile("((?:0x)?\\d+)").matcher(actionToDecode); 
	if (n.matches()) {
		if (n.group(1) != null) {
			try {
				TransportPort portnum = TransportPort.of(get_int(n.group(1)));
				OFActionSetTpSrc.Builder ab = OFFactories.getFactory(version).actions().buildSetTpSrc();
				ab.setTpPort(portnum);
				log.debug("action {}", ab.build());
				return ab.build();
			} 
			catch (NumberFormatException e) {
				log.debug("Invalid src-port in: {} (error ignored)", actionToDecode);
				return null;
			}
		}
	}
	else {
		log.debug("Invalid action: '{}'", actionToDecode);
		return null;
	}
	return null;
}
 

import org.projectfloodlight.openflow.protocol.action.OFActionSetTpSrc; //导入依赖的package包/类
/**
 * Parse set_tp_src actions.
 * The key and delimiter for the action should be omitted, and only the
 * data should be presented to this decoder. A leading 0x is permitted.
 * 
 * @param actionToDecode; The action as a string to decode
 * @param version; The OF version to create the action for
 * @param log
 * @return
 */
private static OFActionSetTpSrc decode_set_src_port(String actionToDecode, OFVersion version, Logger log) {
	Matcher n = Pattern.compile("((?:0x)?\\d+)").matcher(actionToDecode); 
	if (n.matches()) {
		if (n.group(1) != null) {
			try {
				TransportPort portnum = TransportPort.of(get_short(n.group(1)));
				OFActionSetTpSrc.Builder ab = OFFactories.getFactory(version).actions().buildSetTpSrc();
				ab.setTpPort(portnum);
				log.debug("action {}", ab.build());
				return ab.build();
			} 
			catch (NumberFormatException e) {
				log.debug("Invalid src-port in: {} (error ignored)", actionToDecode);
				return null;
			}
		}
	}
	else {
		log.debug("Invalid action: '{}'", actionToDecode);
		return null;
	}
	return null;
}
 

import org.projectfloodlight.openflow.protocol.action.OFActionSetTpSrc; //导入依赖的package包/类
/**
 * Parse set_tp_src actions.
 * The key and delimiter for the action should be omitted, and only the
 * data should be presented to this decoder. A leading 0x is permitted.
 *
 * @param actionToDecode; The action as a string to decode
 * @param version; The OF version to create the action for
 * @param log
 * @return
 */
private static OFActionSetTpSrc decode_set_src_port(String actionToDecode, OFVersion version, Logger log) {
	Matcher n = Pattern.compile("((?:0x)?\\d+)").matcher(actionToDecode);
	if (n.matches()) {
		if (n.group(1) != null) {
			try {
				TransportPort portnum = TransportPort.of(get_int(n.group(1)));
				OFActionSetTpSrc.Builder ab = OFFactories.getFactory(version).actions().buildSetTpSrc();
				ab.setTpPort(portnum);
				log.debug("action {}", ab.build());
				return ab.build();
			}
			catch (NumberFormatException e) {
				log.debug("Invalid src-port in: {} (error ignored)", actionToDecode);
				return null;
			}
		}
	}
	else {
		log.debug("Invalid action: '{}'", actionToDecode);
		return null;
	}
	return null;
}
 

import org.projectfloodlight.openflow.protocol.action.OFActionSetTpSrc; //导入依赖的package包/类
/**
 * Applies all applicable FlowMods from a list of given FlowMods to the given Ethernet packet. The wrapperMessage is necessary for FlowMods that match on the InPort.
 *
 * @param flowMods       The list of flowmods to apply.
 * @param original       The packet to apply them to.
 * @param wrapperMessage The PakcetIn message that caused this. Needed for FlowMods that match on the InPort.
 * @return The modified packet.
 */
public static Ethernet applyFlowMods(final List<OFFlowMod> flowMods, Ethernet original, OFPacketIn wrapperMessage) {
    OFFlowMod matchingFlowMod = getFirstMatchingFlowMod(flowMods, original, wrapperMessage);
    Ethernet modified = (Ethernet) original.clone();
    List<OFFlowMod> appliedFlowMods = new ArrayList<>();
    while (matchingFlowMod != null && !appliedFlowMods.contains(matchingFlowMod)) {
        modified = (Ethernet) modified.clone();
        for (OFAction action : matchingFlowMod.getActions()) {
            if (action.getType() == OFActionType.SET_TP_SRC) {
                ((TCP) modified.getPayload().getPayload()).setSourcePort((short) ((OFActionSetTpSrc) action).getTpPort().getPort());
            } else if (action.getType() == OFActionType.SET_TP_DST) {
                ((TCP) modified.getPayload().getPayload()).setDestinationPort((short) ((OFActionSetTpDst) action).getTpPort().getPort());
            }
            // TODO support more actions
        }
        appliedFlowMods.add(matchingFlowMod);
        matchingFlowMod = getFirstMatchingFlowMod(flowMods, modified, wrapperMessage);
    }
    return modified;
}
 

import org.projectfloodlight.openflow.protocol.action.OFActionSetTpSrc; //导入依赖的package包/类
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);
}