mirrors/ryu
1
0
Fork 0
mirror of https://github.com/faucetsdn/ryu.git synced 2026-05-08 13:56:09 +02:00
Code Issues Projects Releases Wiki Activity

of12: prefix private attributes of OFPMatch with _

Browse Source 
Signed-off-by: YAMAMOTO Takashi <yamamoto@valinux.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
This commit is contained in:
YAMAMOTO Takashi 2013-06-18 16:35:29 +09:00 committed by FUJITA Tomonori
parent abca83ce23
commit ea7798fc69
2 changed files with 253 additions and 245 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

390
ryu/ofproto/ofproto_v1_2_parser.py
View File

@ -1528,191 +1528,199 @@ class FlowWildcards(object):
class OFPMatch(object):
def __init__(self):
super(OFPMatch, self).__init__()
self.wc = FlowWildcards()
self.flow = Flow()
self._wc = FlowWildcards()
self._flow = Flow()
self.fields = []
def append_field(self, header, value, mask=None):
self.fields.append(OFPMatchField.make(header, value, mask))
def serialize(self, buf, offset):
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IN_PORT):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IN_PORT):
self.append_field(ofproto_v1_2.OXM_OF_IN_PORT,
self.flow.in_port)
self._flow.in_port)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IN_PHY_PORT):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IN_PHY_PORT):
self.append_field(ofproto_v1_2.OXM_OF_IN_PHY_PORT,
self.flow.in_phy_port)
self._flow.in_phy_port)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_METADATA):
if self.wc.metadata_mask == UINT64_MAX:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_METADATA):
if self._wc.metadata_mask == UINT64_MAX:
header = ofproto_v1_2.OXM_OF_METADATA
else:
header = ofproto_v1_2.OXM_OF_METADATA_W
self.append_field(header, self.flow.metadata,
self.wc.metadata_mask)
self.append_field(header, self._flow.metadata,
self._wc.metadata_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ETH_DST):
if self.wc.dl_dst_mask:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ETH_DST):
if self._wc.dl_dst_mask:
header = ofproto_v1_2.OXM_OF_ETH_DST_W
else:
header = ofproto_v1_2.OXM_OF_ETH_DST
self.append_field(header, self.flow.dl_dst, self.wc.dl_dst_mask)
self.append_field(header, self._flow.dl_dst, self._wc.dl_dst_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ETH_SRC):
if self.wc.dl_src_mask:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ETH_SRC):
if self._wc.dl_src_mask:
header = ofproto_v1_2.OXM_OF_ETH_SRC_W
else:
header = ofproto_v1_2.OXM_OF_ETH_SRC
self.append_field(header, self.flow.dl_src, self.wc.dl_src_mask)
self.append_field(header, self._flow.dl_src, self._wc.dl_src_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ETH_TYPE):
self.append_field(ofproto_v1_2.OXM_OF_ETH_TYPE, self.flow.dl_type)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ETH_TYPE):
self.append_field(ofproto_v1_2.OXM_OF_ETH_TYPE, self._flow.dl_type)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_VLAN_VID):
if self.wc.vlan_vid_mask == UINT16_MAX:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_VLAN_VID):
if self._wc.vlan_vid_mask == UINT16_MAX:
header = ofproto_v1_2.OXM_OF_VLAN_VID
else:
header = ofproto_v1_2.OXM_OF_VLAN_VID_W
self.append_field(header, self.flow.vlan_vid,
self.wc.vlan_vid_mask)
self.append_field(header, self._flow.vlan_vid,
self._wc.vlan_vid_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_VLAN_PCP):
self.append_field(ofproto_v1_2.OXM_OF_VLAN_PCP, self.flow.vlan_pcp)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_VLAN_PCP):
self.append_field(ofproto_v1_2.OXM_OF_VLAN_PCP,
self._flow.vlan_pcp)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IP_DSCP):
self.append_field(ofproto_v1_2.OXM_OF_IP_DSCP, self.flow.ip_dscp)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IP_DSCP):
self.append_field(ofproto_v1_2.OXM_OF_IP_DSCP, self._flow.ip_dscp)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IP_ECN):
self.append_field(ofproto_v1_2.OXM_OF_IP_ECN, self.flow.ip_ecn)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IP_ECN):
self.append_field(ofproto_v1_2.OXM_OF_IP_ECN, self._flow.ip_ecn)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IP_PROTO):
self.append_field(ofproto_v1_2.OXM_OF_IP_PROTO, self.flow.ip_proto)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IP_PROTO):
self.append_field(ofproto_v1_2.OXM_OF_IP_PROTO,
self._flow.ip_proto)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV4_SRC):
if self.wc.ipv4_src_mask == UINT32_MAX:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV4_SRC):
if self._wc.ipv4_src_mask == UINT32_MAX:
header = ofproto_v1_2.OXM_OF_IPV4_SRC
else:
header = ofproto_v1_2.OXM_OF_IPV4_SRC_W
self.append_field(header, self.flow.ipv4_src,
self.wc.ipv4_src_mask)
self.append_field(header, self._flow.ipv4_src,
self._wc.ipv4_src_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV4_DST):
if self.wc.ipv4_dst_mask == UINT32_MAX:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV4_DST):
if self._wc.ipv4_dst_mask == UINT32_MAX:
header = ofproto_v1_2.OXM_OF_IPV4_DST
else:
header = ofproto_v1_2.OXM_OF_IPV4_DST_W
self.append_field(header, self.flow.ipv4_dst,
self.wc.ipv4_dst_mask)
self.append_field(header, self._flow.ipv4_dst,
self._wc.ipv4_dst_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_TCP_SRC):
self.append_field(ofproto_v1_2.OXM_OF_TCP_SRC, self.flow.tcp_src)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_TCP_SRC):
self.append_field(ofproto_v1_2.OXM_OF_TCP_SRC, self._flow.tcp_src)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_TCP_DST):
self.append_field(ofproto_v1_2.OXM_OF_TCP_DST, self.flow.tcp_dst)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_TCP_DST):
self.append_field(ofproto_v1_2.OXM_OF_TCP_DST, self._flow.tcp_dst)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_UDP_SRC):
self.append_field(ofproto_v1_2.OXM_OF_UDP_SRC, self.flow.udp_src)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_UDP_SRC):
self.append_field(ofproto_v1_2.OXM_OF_UDP_SRC, self._flow.udp_src)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_UDP_DST):
self.append_field(ofproto_v1_2.OXM_OF_UDP_DST, self.flow.udp_dst)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_UDP_DST):
self.append_field(ofproto_v1_2.OXM_OF_UDP_DST, self._flow.udp_dst)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_SCTP_SRC):
self.append_field(ofproto_v1_2.OXM_OF_SCTP_SRC, self.flow.sctp_src)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_SCTP_SRC):
self.append_field(ofproto_v1_2.OXM_OF_SCTP_SRC,
self._flow.sctp_src)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_SCTP_DST):
self.append_field(ofproto_v1_2.OXM_OF_SCTP_DST, self.flow.sctp_dst)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_SCTP_DST):
self.append_field(ofproto_v1_2.OXM_OF_SCTP_DST,
self._flow.sctp_dst)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ICMPV4_TYPE):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ICMPV4_TYPE):
self.append_field(ofproto_v1_2.OXM_OF_ICMPV4_TYPE,
self.flow.icmpv4_type)
self._flow.icmpv4_type)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ICMPV4_CODE):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ICMPV4_CODE):
self.append_field(ofproto_v1_2.OXM_OF_ICMPV4_CODE,
self.flow.icmpv4_code)
self._flow.icmpv4_code)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_OP):
self.append_field(ofproto_v1_2.OXM_OF_ARP_OP, self.flow.arp_op)
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_OP):
self.append_field(ofproto_v1_2.OXM_OF_ARP_OP, self._flow.arp_op)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_SPA):
if self.wc.arp_spa_mask == UINT32_MAX:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_SPA):
if self._wc.arp_spa_mask == UINT32_MAX:
header = ofproto_v1_2.OXM_OF_ARP_SPA
else:
header = ofproto_v1_2.OXM_OF_ARP_SPA_W
self.append_field(header, self.flow.arp_spa, self.wc.arp_spa_mask)
self.append_field(header, self._flow.arp_spa,
self._wc.arp_spa_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_TPA):
if self.wc.arp_tpa_mask == UINT32_MAX:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_TPA):
if self._wc.arp_tpa_mask == UINT32_MAX:
header = ofproto_v1_2.OXM_OF_ARP_TPA
else:
header = ofproto_v1_2.OXM_OF_ARP_TPA_W
self.append_field(header, self.flow.arp_tpa, self.wc.arp_tpa_mask)
self.append_field(header, self._flow.arp_tpa,
self._wc.arp_tpa_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_SHA):
if self.wc.arp_sha_mask:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_SHA):
if self._wc.arp_sha_mask:
header = ofproto_v1_2.OXM_OF_ARP_SHA_W
else:
header = ofproto_v1_2.OXM_OF_ARP_SHA
self.append_field(header, self.flow.arp_sha, self.wc.arp_sha_mask)
self.append_field(header, self._flow.arp_sha,
self._wc.arp_sha_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_THA):
if self.wc.arp_tha_mask:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_THA):
if self._wc.arp_tha_mask:
header = ofproto_v1_2.OXM_OF_ARP_THA_W
else:
header = ofproto_v1_2.OXM_OF_ARP_THA
self.append_field(header, self.flow.arp_tha, self.wc.arp_tha_mask)
self.append_field(header, self._flow.arp_tha,
self._wc.arp_tha_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_SRC):
if len(self.wc.ipv6_src_mask):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_SRC):
if len(self._wc.ipv6_src_mask):
header = ofproto_v1_2.OXM_OF_IPV6_SRC_W
else:
header = ofproto_v1_2.OXM_OF_IPV6_SRC
self.append_field(header, self.flow.ipv6_src,
self.wc.ipv6_src_mask)
self.append_field(header, self._flow.ipv6_src,
self._wc.ipv6_src_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_DST):
if len(self.wc.ipv6_dst_mask):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_DST):
if len(self._wc.ipv6_dst_mask):
header = ofproto_v1_2.OXM_OF_IPV6_DST_W
else:
header = ofproto_v1_2.OXM_OF_IPV6_DST
self.append_field(header, self.flow.ipv6_dst,
self.wc.ipv6_dst_mask)
self.append_field(header, self._flow.ipv6_dst,
self._wc.ipv6_dst_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_FLABEL):
if self.wc.ipv6_flabel_mask == UINT32_MAX:
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_FLABEL):
if self._wc.ipv6_flabel_mask == UINT32_MAX:
header = ofproto_v1_2.OXM_OF_IPV6_FLABEL
else:
header = ofproto_v1_2.OXM_OF_IPV6_FLABEL_W
self.append_field(header, self.flow.ipv6_flabel,
self.wc.ipv6_flabel_mask)
self.append_field(header, self._flow.ipv6_flabel,
self._wc.ipv6_flabel_mask)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ICMPV6_TYPE):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ICMPV6_TYPE):
self.append_field(ofproto_v1_2.OXM_OF_ICMPV6_TYPE,
self.flow.icmpv6_type)
self._flow.icmpv6_type)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ICMPV6_CODE):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ICMPV6_CODE):
self.append_field(ofproto_v1_2.OXM_OF_ICMPV6_CODE,
self.flow.icmpv6_code)
self._flow.icmpv6_code)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_TARGET):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_TARGET):
self.append_field(ofproto_v1_2.OXM_OF_IPV6_ND_TARGET,
self.flow.ipv6_nd_target)
self._flow.ipv6_nd_target)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_SLL):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_SLL):
self.append_field(ofproto_v1_2.OXM_OF_IPV6_ND_SLL,
self.flow.ipv6_nd_sll)
self._flow.ipv6_nd_sll)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_TLL):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_TLL):
self.append_field(ofproto_v1_2.OXM_OF_IPV6_ND_TLL,
self.flow.ipv6_nd_tll)
self._flow.ipv6_nd_tll)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_MPLS_LABEL):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_MPLS_LABEL):
self.append_field(ofproto_v1_2.OXM_OF_MPLS_LABEL,
self.flow.mpls_label)
self._flow.mpls_label)
if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_MPLS_TC):
if self._wc.ft_test(ofproto_v1_2.OFPXMT_OFB_MPLS_TC):
self.append_field(ofproto_v1_2.OXM_OF_MPLS_TC,
self.flow.mpls_tc)
self._flow.mpls_tc)
field_offset = offset + 4
for f in self.fields:
@ -1747,207 +1755,207 @@ class OFPMatch(object):
return match
def set_in_port(self, port):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IN_PORT)
self.flow.in_port = port
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IN_PORT)
self._flow.in_port = port
def set_in_phy_port(self, phy_port):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IN_PHY_PORT)
self.flow.in_phy_port = phy_port
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IN_PHY_PORT)
self._flow.in_phy_port = phy_port
def set_metadata(self, metadata):
self.set_metadata_masked(metadata, UINT64_MAX)
def set_metadata_masked(self, metadata, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_METADATA)
self.wc.metadata_mask = mask
self.flow.metadata = metadata & mask
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_METADATA)
self._wc.metadata_mask = mask
self._flow.metadata = metadata & mask
def set_dl_dst(self, dl_dst):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_DST)
self.flow.dl_dst = dl_dst
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_DST)
self._flow.dl_dst = dl_dst
def set_dl_dst_masked(self, dl_dst, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_DST)
self.wc.dl_dst_mask = mask
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_DST)
self._wc.dl_dst_mask = mask
# bit-wise and of the corresponding elements of dl_dst and mask
self.flow.dl_dst = mac.haddr_bitand(dl_dst, mask)
self._flow.dl_dst = mac.haddr_bitand(dl_dst, mask)
def set_dl_src(self, dl_src):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_SRC)
self.flow.dl_src = dl_src
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_SRC)
self._flow.dl_src = dl_src
def set_dl_src_masked(self, dl_src, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_SRC)
self.wc.dl_src_mask = mask
self.flow.dl_src = mac.haddr_bitand(dl_src, mask)
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_SRC)
self._wc.dl_src_mask = mask
self._flow.dl_src = mac.haddr_bitand(dl_src, mask)
def set_dl_type(self, dl_type):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_TYPE)
self.flow.dl_type = dl_type
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ETH_TYPE)
self._flow.dl_type = dl_type
def set_vlan_vid(self, vid):
self.set_vlan_vid_masked(vid, UINT16_MAX)
def set_vlan_vid_masked(self, vid, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_VLAN_VID)
self.wc.vlan_vid_mask = mask
self.flow.vlan_vid = vid
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_VLAN_VID)
self._wc.vlan_vid_mask = mask
self._flow.vlan_vid = vid
def set_vlan_pcp(self, pcp):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_VLAN_PCP)
self.flow.vlan_pcp = pcp
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_VLAN_PCP)
self._flow.vlan_pcp = pcp
def set_ip_dscp(self, ip_dscp):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IP_DSCP)
self.flow.ip_dscp = ip_dscp
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IP_DSCP)
self._flow.ip_dscp = ip_dscp
def set_ip_ecn(self, ip_ecn):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IP_ECN)
self.flow.ip_ecn = ip_ecn
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IP_ECN)
self._flow.ip_ecn = ip_ecn
def set_ip_proto(self, ip_proto):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IP_PROTO)
self.flow.ip_proto = ip_proto
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IP_PROTO)
self._flow.ip_proto = ip_proto
def set_ipv4_src(self, ipv4_src):
self.set_ipv4_src_masked(ipv4_src, UINT32_MAX)
def set_ipv4_src_masked(self, ipv4_src, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV4_SRC)
self.flow.ipv4_src = ipv4_src
self.wc.ipv4_src_mask = mask
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV4_SRC)
self._flow.ipv4_src = ipv4_src
self._wc.ipv4_src_mask = mask
def set_ipv4_dst(self, ipv4_dst):
self.set_ipv4_dst_masked(ipv4_dst, UINT32_MAX)
def set_ipv4_dst_masked(self, ipv4_dst, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV4_DST)
self.flow.ipv4_dst = ipv4_dst
self.wc.ipv4_dst_mask = mask
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV4_DST)
self._flow.ipv4_dst = ipv4_dst
self._wc.ipv4_dst_mask = mask
def set_tcp_src(self, tcp_src):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_TCP_SRC)
self.flow.tcp_src = tcp_src
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_TCP_SRC)
self._flow.tcp_src = tcp_src
def set_tcp_dst(self, tcp_dst):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_TCP_DST)
self.flow.tcp_dst = tcp_dst
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_TCP_DST)
self._flow.tcp_dst = tcp_dst
def set_udp_src(self, udp_src):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_UDP_SRC)
self.flow.udp_src = udp_src
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_UDP_SRC)
self._flow.udp_src = udp_src
def set_udp_dst(self, udp_dst):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_UDP_DST)
self.flow.udp_dst = udp_dst
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_UDP_DST)
self._flow.udp_dst = udp_dst
def set_sctp_src(self, sctp_src):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_SCTP_SRC)
self.flow.sctp_src = sctp_src
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_SCTP_SRC)
self._flow.sctp_src = sctp_src
def set_sctp_dst(self, sctp_dst):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_SCTP_DST)
self.flow.sctp_dst = sctp_dst
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_SCTP_DST)
self._flow.sctp_dst = sctp_dst
def set_icmpv4_type(self, icmpv4_type):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ICMPV4_TYPE)
self.flow.icmpv4_type = icmpv4_type
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ICMPV4_TYPE)
self._flow.icmpv4_type = icmpv4_type
def set_icmpv4_code(self, icmpv4_code):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ICMPV4_CODE)
self.flow.icmpv4_code = icmpv4_code
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ICMPV4_CODE)
self._flow.icmpv4_code = icmpv4_code
def set_arp_opcode(self, arp_op):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_OP)
self.flow.arp_op = arp_op
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_OP)
self._flow.arp_op = arp_op
def set_arp_spa(self, arp_spa):
self.set_arp_spa_masked(arp_spa, UINT32_MAX)
def set_arp_spa_masked(self, arp_spa, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_SPA)
self.wc.arp_spa_mask = mask
self.flow.arp_spa = arp_spa
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_SPA)
self._wc.arp_spa_mask = mask
self._flow.arp_spa = arp_spa
def set_arp_tpa(self, arp_tpa):
self.set_arp_tpa_masked(arp_tpa, UINT32_MAX)
def set_arp_tpa_masked(self, arp_tpa, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_TPA)
self.wc.arp_tpa_mask = mask
self.flow.arp_tpa = arp_tpa
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_TPA)
self._wc.arp_tpa_mask = mask
self._flow.arp_tpa = arp_tpa
def set_arp_sha(self, arp_sha):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_SHA)
self.flow.arp_sha = arp_sha
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_SHA)
self._flow.arp_sha = arp_sha
def set_arp_sha_masked(self, arp_sha, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_SHA)
self.wc.arp_sha_mask = mask
self.flow.arp_sha = mac.haddr_bitand(arp_sha, mask)
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_SHA)
self._wc.arp_sha_mask = mask
self._flow.arp_sha = mac.haddr_bitand(arp_sha, mask)
def set_arp_tha(self, arp_tha):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_THA)
self.flow.arp_tha = arp_tha
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_THA)
self._flow.arp_tha = arp_tha
def set_arp_tha_masked(self, arp_tha, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_THA)
self.wc.arp_tha_mask = mask
self.flow.arp_tha = mac.haddr_bitand(arp_tha, mask)
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_THA)
self._wc.arp_tha_mask = mask
self._flow.arp_tha = mac.haddr_bitand(arp_tha, mask)
def set_ipv6_src(self, src):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_SRC)
self.flow.ipv6_src = src
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_SRC)
self._flow.ipv6_src = src
def set_ipv6_src_masked(self, src, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_SRC)
self.wc.ipv6_src_mask = mask
self.flow.ipv6_src = [x & y for (x, y) in itertools.izip(src, mask)]
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_SRC)
self._wc.ipv6_src_mask = mask
self._flow.ipv6_src = [x & y for (x, y) in itertools.izip(src, mask)]
def set_ipv6_dst(self, dst):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_DST)
self.flow.ipv6_dst = dst
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_DST)
self._flow.ipv6_dst = dst
def set_ipv6_dst_masked(self, dst, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_DST)
self.wc.ipv6_dst_mask = mask
self.flow.ipv6_dst = [x & y for (x, y) in itertools.izip(dst, mask)]
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_DST)
self._wc.ipv6_dst_mask = mask
self._flow.ipv6_dst = [x & y for (x, y) in itertools.izip(dst, mask)]
def set_ipv6_flabel(self, flabel):
self.set_ipv6_flabel_masked(flabel, UINT32_MAX)
def set_ipv6_flabel_masked(self, flabel, mask):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_FLABEL)
self.wc.ipv6_flabel_mask = mask
self.flow.ipv6_flabel = flabel
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_FLABEL)
self._wc.ipv6_flabel_mask = mask
self._flow.ipv6_flabel = flabel
def set_icmpv6_type(self, icmpv6_type):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ICMPV6_TYPE)
self.flow.icmpv6_type = icmpv6_type
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ICMPV6_TYPE)
self._flow.icmpv6_type = icmpv6_type
def set_icmpv6_code(self, icmpv6_code):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ICMPV6_CODE)
self.flow.icmpv6_code = icmpv6_code
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ICMPV6_CODE)
self._flow.icmpv6_code = icmpv6_code
def set_ipv6_nd_target(self, target):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_TARGET)
self.flow.ipv6_nd_target = target
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_TARGET)
self._flow.ipv6_nd_target = target
def set_ipv6_nd_sll(self, ipv6_nd_sll):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_SLL)
self.flow.ipv6_nd_sll = ipv6_nd_sll
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_SLL)
self._flow.ipv6_nd_sll = ipv6_nd_sll
def set_ipv6_nd_tll(self, ipv6_nd_tll):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_TLL)
self.flow.ipv6_nd_tll = ipv6_nd_tll
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_IPV6_ND_TLL)
self._flow.ipv6_nd_tll = ipv6_nd_tll
def set_mpls_label(self, mpls_label):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_MPLS_LABEL)
self.flow.mpls_label = mpls_label
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_MPLS_LABEL)
self._flow.mpls_label = mpls_label
def set_mpls_tc(self, mpls_tc):
self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_MPLS_TC)
self.flow.mpls_tc = mpls_tc
self._wc.ft_set(ofproto_v1_2.OFPXMT_OFB_MPLS_TC)
self._flow.mpls_tc = mpls_tc
class OFPMatchField(object):

108
ryu/tests/unit/ofproto/test_parser_v12.py
View File

@ -2588,7 +2588,7 @@ class TestOFPFlowMod(unittest.TestCase):
eq_(out_port, c.out_port)
eq_(out_group, c.out_group)
eq_(flags, c.flags)
eq_(in_port, c.match.flow.in_port)
eq_(in_port, c.match._flow.in_port)
eq_(instructions[0], c.instructions[0])
def _test_serialize(self, cookie, cookie_mask, table_id,
@ -4564,7 +4564,7 @@ class TestOFPFlowStatsRequest(unittest.TestCase):
eq_(self.out_group, c.out_group)
eq_(self.cookie, c.cookie)
eq_(self.cookie_mask, c.cookie_mask)
eq_(in_port, c.match.flow.in_port)
eq_(in_port, c.match._flow.in_port)
def _test_serialize(self, table_id, out_port, out_group,
cookie, cookie_mask):
@ -4675,7 +4675,7 @@ class TestOFPFlowStats(unittest.TestCase):
eq_(cookie, c.cookie)
eq_(packet_count, c.packet_count)
eq_(byte_count, c.byte_count)
eq_(in_port, c.match.flow.in_port)
eq_(in_port, c.match._flow.in_port)
eq_(goto_table, c.instructions[0].table_id)
def _test_parser(self, table_id, duration_sec, duration_nsec,
@ -4788,7 +4788,7 @@ class TestOFPAggregateStatsRequest(unittest.TestCase):
eq_(self.out_group, c.out_group)
eq_(self.cookie, c.cookie)
eq_(self.cookie_mask, c.cookie_mask)
eq_(dl_type, c.match.flow.dl_type)
eq_(dl_type, c.match._flow.dl_type)
def _test_serialize(self, table_id, out_port, out_group,
cookie, cookie_mask):
@ -6583,58 +6583,58 @@ class TestOFPMatch(unittest.TestCase):
res = OFPMatch()
# wc check
eq_(res.wc.metadata_mask, 0)
eq_(res.wc.dl_dst_mask, 0)
eq_(res.wc.dl_src_mask, 0)
eq_(res.wc.vlan_vid_mask, 0)
eq_(res.wc.ipv4_src_mask, 0)
eq_(res.wc.ipv4_dst_mask, 0)
eq_(res.wc.arp_spa_mask, 0)
eq_(res.wc.arp_tpa_mask, 0)
eq_(res.wc.arp_sha_mask, 0)
eq_(res.wc.arp_tha_mask, 0)
eq_(res.wc.ipv6_src_mask, [])
eq_(res.wc.ipv6_dst_mask, [])
eq_(res.wc.ipv6_flabel_mask, 0)
eq_(res.wc.wildcards, (1 << 64) - 1)
eq_(res._wc.metadata_mask, 0)
eq_(res._wc.dl_dst_mask, 0)
eq_(res._wc.dl_src_mask, 0)
eq_(res._wc.vlan_vid_mask, 0)
eq_(res._wc.ipv4_src_mask, 0)
eq_(res._wc.ipv4_dst_mask, 0)
eq_(res._wc.arp_spa_mask, 0)
eq_(res._wc.arp_tpa_mask, 0)
eq_(res._wc.arp_sha_mask, 0)
eq_(res._wc.arp_tha_mask, 0)
eq_(res._wc.ipv6_src_mask, [])
eq_(res._wc.ipv6_dst_mask, [])
eq_(res._wc.ipv6_flabel_mask, 0)
eq_(res._wc.wildcards, (1 << 64) - 1)
# flow check
eq_(res.flow.in_port, 0)
eq_(res.flow.in_phy_port, 0)
eq_(res.flow.metadata, 0)
eq_(res.flow.dl_dst, mac.DONTCARE)
eq_(res.flow.dl_src, mac.DONTCARE)
eq_(res.flow.dl_type, 0)
eq_(res.flow.vlan_vid, 0)
eq_(res.flow.vlan_pcp, 0)
eq_(res.flow.ip_dscp, 0)
eq_(res.flow.ip_ecn, 0)
eq_(res.flow.ip_proto, 0)
eq_(res.flow.ipv4_src, 0)
eq_(res.flow.ipv4_dst, 0)
eq_(res.flow.tcp_src, 0)
eq_(res.flow.tcp_dst, 0)
eq_(res.flow.udp_src, 0)
eq_(res.flow.udp_dst, 0)
eq_(res.flow.sctp_src, 0)
eq_(res.flow.sctp_dst, 0)
eq_(res.flow.icmpv4_type, 0)
eq_(res.flow.icmpv4_code, 0)
eq_(res.flow.arp_op, 0)
eq_(res.flow.arp_spa, 0)
eq_(res.flow.arp_tpa, 0)
eq_(res.flow.arp_sha, 0)
eq_(res.flow.arp_tha, 0)
eq_(res.flow.ipv6_src, [])
eq_(res.flow.ipv6_dst, [])
eq_(res.flow.ipv6_flabel, 0)
eq_(res.flow.icmpv6_type, 0)
eq_(res.flow.icmpv6_code, 0)
eq_(res.flow.ipv6_nd_target, [])
eq_(res.flow.ipv6_nd_sll, 0)
eq_(res.flow.ipv6_nd_tll, 0)
eq_(res.flow.mpls_lable, 0)
eq_(res.flow.mpls_tc, 0)
eq_(res._flow.in_port, 0)
eq_(res._flow.in_phy_port, 0)
eq_(res._flow.metadata, 0)
eq_(res._flow.dl_dst, mac.DONTCARE)
eq_(res._flow.dl_src, mac.DONTCARE)
eq_(res._flow.dl_type, 0)
eq_(res._flow.vlan_vid, 0)
eq_(res._flow.vlan_pcp, 0)
eq_(res._flow.ip_dscp, 0)
eq_(res._flow.ip_ecn, 0)
eq_(res._flow.ip_proto, 0)
eq_(res._flow.ipv4_src, 0)
eq_(res._flow.ipv4_dst, 0)
eq_(res._flow.tcp_src, 0)
eq_(res._flow.tcp_dst, 0)
eq_(res._flow.udp_src, 0)
eq_(res._flow.udp_dst, 0)
eq_(res._flow.sctp_src, 0)
eq_(res._flow.sctp_dst, 0)
eq_(res._flow.icmpv4_type, 0)
eq_(res._flow.icmpv4_code, 0)
eq_(res._flow.arp_op, 0)
eq_(res._flow.arp_spa, 0)
eq_(res._flow.arp_tpa, 0)
eq_(res._flow.arp_sha, 0)
eq_(res._flow.arp_tha, 0)
eq_(res._flow.ipv6_src, [])
eq_(res._flow.ipv6_dst, [])
eq_(res._flow.ipv6_flabel, 0)
eq_(res._flow.icmpv6_type, 0)
eq_(res._flow.icmpv6_code, 0)
eq_(res._flow.ipv6_nd_target, [])
eq_(res._flow.ipv6_nd_sll, 0)
eq_(res._flow.ipv6_nd_tll, 0)
eq_(res._flow.mpls_lable, 0)
eq_(res._flow.mpls_tc, 0)
# flow check
eq_(res.fields, [])