diff options
author | YAMAMOTO Takashi <yamamoto@valinux.co.jp> | 2013-06-18 16:35:29 +0900 |
---|---|---|
committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2013-06-20 06:44:24 +0900 |
commit | ea7798fc69d74d5b314129dc3fa3a2d04fbb2586 (patch) | |
tree | c687b0ab3b0f82b91cddb81cdcffea13a00febcf | |
parent | abca83ce235907eeea5f1e1953a5f719ad0e5078 (diff) |
of12: prefix private attributes of OFPMatch with _
Signed-off-by: YAMAMOTO Takashi <yamamoto@valinux.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
-rw-r--r-- | ryu/ofproto/ofproto_v1_2_parser.py | 390 | ||||
-rw-r--r-- | ryu/tests/unit/ofproto/test_parser_v12.py | 108 |
2 files changed, 253 insertions, 245 deletions
diff --git a/ryu/ofproto/ofproto_v1_2_parser.py b/ryu/ofproto/ofproto_v1_2_parser.py index 3591508d..224bcb27 100644 --- a/ryu/ofproto/ofproto_v1_2_parser.py +++ b/ryu/ofproto/ofproto_v1_2_parser.py @@ -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): diff --git a/ryu/tests/unit/ofproto/test_parser_v12.py b/ryu/tests/unit/ofproto/test_parser_v12.py index 733fdfef..6eb76130 100644 --- a/ryu/tests/unit/ofproto/test_parser_v12.py +++ b/ryu/tests/unit/ofproto/test_parser_v12.py @@ -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, []) |