import org.openflow.protocol.Wildcards; //导入依赖的package包/类
private void sendFlowStatistics(int tid, short port) {
    OVXStatisticsRequest req = new OVXStatisticsRequest();
    // TODO: stuff like below should be wrapped into an XIDUtil class
    int xid = (tid << 16) | port;
    req.setXid(xid);
    req.setStatisticType(OFStatisticsType.FLOW);
    OVXFlowStatisticsRequest freq = new OVXFlowStatisticsRequest();
    OVXMatch match = new OVXMatch();
    match.setWildcards(Wildcards.FULL);
    freq.setMatch(match);
    freq.setOutPort(OFPort.OFPP_NONE.getValue());
    freq.setTableId((byte) 0xFF);
    req.setStatistics(Collections.singletonList(freq));
    req.setLengthU(req.getLengthU() + freq.getLength());
    sendMsg(req, this);
}
 

import org.openflow.protocol.Wildcards; //导入依赖的package包/类
private void addFlowOnSwitchLinkPorts(IOFSwitch sw, OFFlowMod fm ,
								OFMatch match,
								Short inport, 
								ArrayList<Short> outports,
								FloodlightContext cntx){
	 // set the match.
       int multicastAddr = match.getNetworkDestination();
       match.setNetworkDestination(multicastAddr);
       match.setWildcards(Wildcards.FULL.matchOn(Flag.IN_PORT).
       									matchOn(Flag.NW_DST));
       
       fm.setMatch(match);
       for(Short outport: outports){
       	fm.getActions().add(new OFActionOutput().
       								setPort(outport));
       }
       fm.getMatch().setInputPort(inport);
       ((OFPacketOut) fm.getActions()).setActionsLength(
			(short) (OFActionOutput.MINIMUM_LENGTH *
					outports.size()));
	int  length = OFFlowMod.MINIMUM_LENGTH+ 
				((OFPacketOut)fm.getActions()).getActionsLength(); 
	fm.setLengthU(length);
	 try {
            counterStore.updatePktOutFMCounterStoreLocal(sw, fm);
            if (log.isTraceEnabled()) {
                log.trace("Pushing Multicast flowmod multicast switchDPID={} " +
                        "sw={} inPort={} actions={}",
                        new Object[] {sw.getId(),
                                      sw,
                                      fm.getMatch().getInputPort(),
                                      fm.getActions() });
            }
            messageDamper.write(sw, fm, cntx);
        } catch (IOException e) {
            log.error("Failure writing flow mod", e);
        }
}