diff options
author | YAMAMOTO Takashi <yamamoto@valinux.co.jp> | 2013-06-18 16:35:30 +0900 |
---|---|---|
committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2013-06-20 06:44:29 +0900 |
commit | 2214fae1785d7623150381ea5bfb9ba7bb3a5433 (patch) | |
tree | 9ae66937ebab3a0a232fe56a23577ff0dac23987 | |
parent | ea7798fc69d74d5b314129dc3fa3a2d04fbb2586 (diff) |
of13: 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_3_parser.py | 452 |
1 files changed, 230 insertions, 222 deletions
diff --git a/ryu/ofproto/ofproto_v1_3_parser.py b/ryu/ofproto/ofproto_v1_3_parser.py index 7a220db0..e4edc9ed 100644 --- a/ryu/ofproto/ofproto_v1_3_parser.py +++ b/ryu/ofproto/ofproto_v1_3_parser.py @@ -343,219 +343,227 @@ 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_3.OFPXMT_OFB_IN_PORT): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IN_PORT): self.append_field(ofproto_v1_3.OXM_OF_IN_PORT, - self.flow.in_port) + self._flow.in_port) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IN_PHY_PORT): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IN_PHY_PORT): self.append_field(ofproto_v1_3.OXM_OF_IN_PHY_PORT, - self.flow.in_phy_port) + self._flow.in_phy_port) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_METADATA): - if self.wc.metadata_mask == UINT64_MAX: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_METADATA): + if self._wc.metadata_mask == UINT64_MAX: header = ofproto_v1_3.OXM_OF_METADATA else: header = ofproto_v1_3.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_3.OFPXMT_OFB_ETH_DST): - if self.wc.dl_dst_mask: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ETH_DST): + if self._wc.dl_dst_mask: header = ofproto_v1_3.OXM_OF_ETH_DST_W else: header = ofproto_v1_3.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_3.OFPXMT_OFB_ETH_SRC): - if self.wc.dl_src_mask: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ETH_SRC): + if self._wc.dl_src_mask: header = ofproto_v1_3.OXM_OF_ETH_SRC_W else: header = ofproto_v1_3.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_3.OFPXMT_OFB_ETH_TYPE): - self.append_field(ofproto_v1_3.OXM_OF_ETH_TYPE, self.flow.dl_type) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ETH_TYPE): + self.append_field(ofproto_v1_3.OXM_OF_ETH_TYPE, self._flow.dl_type) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_VLAN_VID): - if self.wc.vlan_vid_mask == UINT16_MAX: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_VLAN_VID): + if self._wc.vlan_vid_mask == UINT16_MAX: header = ofproto_v1_3.OXM_OF_VLAN_VID else: header = ofproto_v1_3.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_3.OFPXMT_OFB_VLAN_PCP): - self.append_field(ofproto_v1_3.OXM_OF_VLAN_PCP, self.flow.vlan_pcp) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_VLAN_PCP): + self.append_field(ofproto_v1_3.OXM_OF_VLAN_PCP, + self._flow.vlan_pcp) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IP_DSCP): - self.append_field(ofproto_v1_3.OXM_OF_IP_DSCP, self.flow.ip_dscp) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IP_DSCP): + self.append_field(ofproto_v1_3.OXM_OF_IP_DSCP, self._flow.ip_dscp) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IP_ECN): - self.append_field(ofproto_v1_3.OXM_OF_IP_ECN, self.flow.ip_ecn) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IP_ECN): + self.append_field(ofproto_v1_3.OXM_OF_IP_ECN, self._flow.ip_ecn) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IP_PROTO): - self.append_field(ofproto_v1_3.OXM_OF_IP_PROTO, self.flow.ip_proto) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IP_PROTO): + self.append_field(ofproto_v1_3.OXM_OF_IP_PROTO, + self._flow.ip_proto) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV4_SRC): - if self.wc.ipv4_src_mask == UINT32_MAX: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV4_SRC): + if self._wc.ipv4_src_mask == UINT32_MAX: header = ofproto_v1_3.OXM_OF_IPV4_SRC else: header = ofproto_v1_3.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_3.OFPXMT_OFB_IPV4_DST): - if self.wc.ipv4_dst_mask == UINT32_MAX: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV4_DST): + if self._wc.ipv4_dst_mask == UINT32_MAX: header = ofproto_v1_3.OXM_OF_IPV4_DST else: header = ofproto_v1_3.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_3.OFPXMT_OFB_TCP_SRC): - self.append_field(ofproto_v1_3.OXM_OF_TCP_SRC, self.flow.tcp_src) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_TCP_SRC): + self.append_field(ofproto_v1_3.OXM_OF_TCP_SRC, self._flow.tcp_src) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_TCP_DST): - self.append_field(ofproto_v1_3.OXM_OF_TCP_DST, self.flow.tcp_dst) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_TCP_DST): + self.append_field(ofproto_v1_3.OXM_OF_TCP_DST, self._flow.tcp_dst) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_UDP_SRC): - self.append_field(ofproto_v1_3.OXM_OF_UDP_SRC, self.flow.udp_src) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_UDP_SRC): + self.append_field(ofproto_v1_3.OXM_OF_UDP_SRC, self._flow.udp_src) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_UDP_DST): - self.append_field(ofproto_v1_3.OXM_OF_UDP_DST, self.flow.udp_dst) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_UDP_DST): + self.append_field(ofproto_v1_3.OXM_OF_UDP_DST, self._flow.udp_dst) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_SCTP_SRC): - self.append_field(ofproto_v1_3.OXM_OF_SCTP_SRC, self.flow.sctp_src) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_SCTP_SRC): + self.append_field(ofproto_v1_3.OXM_OF_SCTP_SRC, + self._flow.sctp_src) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_SCTP_DST): - self.append_field(ofproto_v1_3.OXM_OF_SCTP_DST, self.flow.sctp_dst) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_SCTP_DST): + self.append_field(ofproto_v1_3.OXM_OF_SCTP_DST, + self._flow.sctp_dst) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ICMPV4_TYPE): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ICMPV4_TYPE): self.append_field(ofproto_v1_3.OXM_OF_ICMPV4_TYPE, - self.flow.icmpv4_type) + self._flow.icmpv4_type) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ICMPV4_CODE): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ICMPV4_CODE): self.append_field(ofproto_v1_3.OXM_OF_ICMPV4_CODE, - self.flow.icmpv4_code) + self._flow.icmpv4_code) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ARP_OP): - self.append_field(ofproto_v1_3.OXM_OF_ARP_OP, self.flow.arp_op) + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ARP_OP): + self.append_field(ofproto_v1_3.OXM_OF_ARP_OP, self._flow.arp_op) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ARP_SPA): - if self.wc.arp_spa_mask == UINT32_MAX: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ARP_SPA): + if self._wc.arp_spa_mask == UINT32_MAX: header = ofproto_v1_3.OXM_OF_ARP_SPA else: header = ofproto_v1_3.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_3.OFPXMT_OFB_ARP_TPA): - if self.wc.arp_tpa_mask == UINT32_MAX: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ARP_TPA): + if self._wc.arp_tpa_mask == UINT32_MAX: header = ofproto_v1_3.OXM_OF_ARP_TPA else: header = ofproto_v1_3.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_3.OFPXMT_OFB_ARP_SHA): - if self.wc.arp_sha_mask: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ARP_SHA): + if self._wc.arp_sha_mask: header = ofproto_v1_3.OXM_OF_ARP_SHA_W else: header = ofproto_v1_3.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_3.OFPXMT_OFB_ARP_THA): - if self.wc.arp_tha_mask: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ARP_THA): + if self._wc.arp_tha_mask: header = ofproto_v1_3.OXM_OF_ARP_THA_W else: header = ofproto_v1_3.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_3.OFPXMT_OFB_IPV6_SRC): - if len(self.wc.ipv6_src_mask): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_SRC): + if len(self._wc.ipv6_src_mask): header = ofproto_v1_3.OXM_OF_IPV6_SRC_W else: header = ofproto_v1_3.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_3.OFPXMT_OFB_IPV6_DST): - if len(self.wc.ipv6_dst_mask): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_DST): + if len(self._wc.ipv6_dst_mask): header = ofproto_v1_3.OXM_OF_IPV6_DST_W else: header = ofproto_v1_3.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_3.OFPXMT_OFB_IPV6_FLABEL): - if self.wc.ipv6_flabel_mask == UINT32_MAX: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_FLABEL): + if self._wc.ipv6_flabel_mask == UINT32_MAX: header = ofproto_v1_3.OXM_OF_IPV6_FLABEL else: header = ofproto_v1_3.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_3.OFPXMT_OFB_ICMPV6_TYPE): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ICMPV6_TYPE): self.append_field(ofproto_v1_3.OXM_OF_ICMPV6_TYPE, - self.flow.icmpv6_type) + self._flow.icmpv6_type) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ICMPV6_CODE): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_ICMPV6_CODE): self.append_field(ofproto_v1_3.OXM_OF_ICMPV6_CODE, - self.flow.icmpv6_code) + self._flow.icmpv6_code) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_ND_TARGET): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_ND_TARGET): self.append_field(ofproto_v1_3.OXM_OF_IPV6_ND_TARGET, - self.flow.ipv6_nd_target) + self._flow.ipv6_nd_target) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_ND_SLL): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_ND_SLL): self.append_field(ofproto_v1_3.OXM_OF_IPV6_ND_SLL, - self.flow.ipv6_nd_sll) + self._flow.ipv6_nd_sll) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_ND_TLL): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_ND_TLL): self.append_field(ofproto_v1_3.OXM_OF_IPV6_ND_TLL, - self.flow.ipv6_nd_tll) + self._flow.ipv6_nd_tll) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_MPLS_LABEL): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_MPLS_LABEL): self.append_field(ofproto_v1_3.OXM_OF_MPLS_LABEL, - self.flow.mpls_label) + self._flow.mpls_label) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_MPLS_TC): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_MPLS_TC): self.append_field(ofproto_v1_3.OXM_OF_MPLS_TC, - self.flow.mpls_tc) + self._flow.mpls_tc) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_MPLS_BOS): + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_MPLS_BOS): self.append_field(ofproto_v1_3.OXM_OF_MPLS_BOS, - self.flow.mpls_bos) + self._flow.mpls_bos) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_PBB_ISID): - if self.wc.pbb_isid_mask: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_PBB_ISID): + if self._wc.pbb_isid_mask: header = ofproto_v1_3.OXM_OF_PBB_ISID_W else: header = ofproto_v1_3.OXM_OF_PBB_ISID - self.append_field(header, self.flow.pbb_isid, - self.wc.pbb_isid_mask) + self.append_field(header, self._flow.pbb_isid, + self._wc.pbb_isid_mask) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_TUNNEL_ID): - if self.wc.tunnel_id_mask: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_TUNNEL_ID): + if self._wc.tunnel_id_mask: header = ofproto_v1_3.OXM_OF_TUNNEL_ID_W else: header = ofproto_v1_3.OXM_OF_TUNNEL_ID - self.append_field(header, self.flow.tunnel_id, - self.wc.tunnel_id_mask) + self.append_field(header, self._flow.tunnel_id, + self._wc.tunnel_id_mask) - if self.wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_EXTHDR): - if self.wc.ipv6_exthdr_mask: + if self._wc.ft_test(ofproto_v1_3.OFPXMT_OFB_IPV6_EXTHDR): + if self._wc.ipv6_exthdr_mask: header = ofproto_v1_3.OXM_OF_IPV6_EXTHDR_W else: header = ofproto_v1_3.OXM_OF_IPV6_EXTHDR - self.append_field(header, self.flow.ipv6_exthdr, - self.wc.ipv6_exthdr_mask) + self.append_field(header, self._flow.ipv6_exthdr, + self._wc.ipv6_exthdr_mask) field_offset = offset + 4 for f in self.fields: @@ -590,238 +598,238 @@ class OFPMatch(object): return match def set_in_port(self, port): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IN_PORT) - self.flow.in_port = port + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IN_PORT) + self._flow.in_port = port def set_in_phy_port(self, phy_port): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IN_PHY_PORT) - self.flow.in_phy_port = phy_port + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_METADATA) - self.wc.metadata_mask = mask - self.flow.metadata = metadata & mask + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_ETH_DST) - self.flow.dl_dst = dl_dst + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_ETH_DST) - self.wc.dl_dst_mask = mask + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_ETH_SRC) - self.flow.dl_src = dl_src + self._wc.ft_set(ofproto_v1_3.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_3.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_3.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_3.OFPXMT_OFB_ETH_TYPE) - self.flow.dl_type = dl_type + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_VLAN_VID) - self.wc.vlan_vid_mask = mask - self.flow.vlan_vid = vid + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_VLAN_PCP) - self.flow.vlan_pcp = pcp + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_VLAN_PCP) + self._flow.vlan_pcp = pcp def set_ip_dscp(self, ip_dscp): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IP_DSCP) - self.flow.ip_dscp = ip_dscp + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IP_DSCP) + self._flow.ip_dscp = ip_dscp def set_ip_ecn(self, ip_ecn): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IP_ECN) - self.flow.ip_ecn = ip_ecn + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IP_ECN) + self._flow.ip_ecn = ip_ecn def set_ip_proto(self, ip_proto): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IP_PROTO) - self.flow.ip_proto = ip_proto + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_IPV4_SRC) - self.flow.ipv4_src = ipv4_src - self.wc.ipv4_src_mask = mask + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_IPV4_DST) - self.flow.ipv4_dst = ipv4_dst - self.wc.ipv4_dst_mask = mask + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_TCP_SRC) - self.flow.tcp_src = tcp_src + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_TCP_SRC) + self._flow.tcp_src = tcp_src def set_tcp_dst(self, tcp_dst): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_TCP_DST) - self.flow.tcp_dst = tcp_dst + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_TCP_DST) + self._flow.tcp_dst = tcp_dst def set_udp_src(self, udp_src): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_UDP_SRC) - self.flow.udp_src = udp_src + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_UDP_SRC) + self._flow.udp_src = udp_src def set_udp_dst(self, udp_dst): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_UDP_DST) - self.flow.udp_dst = udp_dst + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_UDP_DST) + self._flow.udp_dst = udp_dst def set_sctp_src(self, sctp_src): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_SCTP_SRC) - self.flow.sctp_src = sctp_src + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_SCTP_SRC) + self._flow.sctp_src = sctp_src def set_sctp_dst(self, sctp_dst): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_SCTP_DST) - self.flow.sctp_dst = sctp_dst + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_SCTP_DST) + self._flow.sctp_dst = sctp_dst def set_icmpv4_type(self, icmpv4_type): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_ICMPV4_TYPE) - self.flow.icmpv4_type = icmpv4_type + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_ICMPV4_TYPE) + self._flow.icmpv4_type = icmpv4_type def set_icmpv4_code(self, icmpv4_code): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_ICMPV4_CODE) - self.flow.icmpv4_code = icmpv4_code + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_ICMPV4_CODE) + self._flow.icmpv4_code = icmpv4_code def set_arp_opcode(self, arp_op): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_ARP_OP) - self.flow.arp_op = arp_op + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_ARP_SPA) - self.wc.arp_spa_mask = mask - self.flow.arp_spa = arp_spa + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_ARP_TPA) - self.wc.arp_tpa_mask = mask - self.flow.arp_tpa = arp_tpa + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_ARP_SHA) - self.flow.arp_sha = arp_sha + self._wc.ft_set(ofproto_v1_3.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_3.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_3.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_3.OFPXMT_OFB_ARP_THA) - self.flow.arp_tha = arp_tha + self._wc.ft_set(ofproto_v1_3.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_3.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_3.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_3.OFPXMT_OFB_IPV6_SRC) - self.flow.ipv6_src = src + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IPV6_SRC) + self._flow.ipv6_src = src def set_ipv6_src_masked(self, src, mask): - self.wc.ft_set(ofproto_v1_3.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_3.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_3.OFPXMT_OFB_IPV6_DST) - self.flow.ipv6_dst = dst + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IPV6_DST) + self._flow.ipv6_dst = dst def set_ipv6_dst_masked(self, dst, mask): - self.wc.ft_set(ofproto_v1_3.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_3.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_3.OFPXMT_OFB_IPV6_FLABEL) - self.wc.ipv6_flabel_mask = mask - self.flow.ipv6_flabel = flabel + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_ICMPV6_TYPE) - self.flow.icmpv6_type = icmpv6_type + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_ICMPV6_TYPE) + self._flow.icmpv6_type = icmpv6_type def set_icmpv6_code(self, icmpv6_code): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_ICMPV6_CODE) - self.flow.icmpv6_code = icmpv6_code + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_ICMPV6_CODE) + self._flow.icmpv6_code = icmpv6_code def set_ipv6_nd_target(self, target): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IPV6_ND_TARGET) - self.flow.ipv6_nd_target = target + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_IPV6_ND_SLL) - self.flow.ipv6_nd_sll = ipv6_nd_sll + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_IPV6_ND_TLL) - self.flow.ipv6_nd_tll = ipv6_nd_tll + self._wc.ft_set(ofproto_v1_3.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_3.OFPXMT_OFB_MPLS_LABEL) - self.flow.mpls_label = mpls_label + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_MPLS_LABEL) + self._flow.mpls_label = mpls_label def set_mpls_tc(self, mpls_tc): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_MPLS_TC) - self.flow.mpls_tc = mpls_tc + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_MPLS_TC) + self._flow.mpls_tc = mpls_tc def set_mpls_bos(self, bos): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_MPLS_BOS) - self.flow.mpls_bos = bos + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_MPLS_BOS) + self._flow.mpls_bos = bos def set_pbb_isid(self, isid): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_PBB_ISID) - self.flow.pbb_isid = isid + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_PBB_ISID) + self._flow.pbb_isid = isid def set_pbb_isid_masked(self, isid, mask): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_PBB_ISID) - self.wc.pbb_isid_mask = mask - self.flow.pbb_isid = isid + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_PBB_ISID) + self._wc.pbb_isid_mask = mask + self._flow.pbb_isid = isid def set_tunnel_id(self, tunnel_id): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_TUNNEL_ID) - self.flow.tunnel_id = tunnel_id + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_TUNNEL_ID) + self._flow.tunnel_id = tunnel_id def set_tunnel_id_masked(self, tunnel_id, mask): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_TUNNEL_ID) - self.wc.tunnel_id_mask = mask - self.flow.tunnel_id = tunnel_id + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_TUNNEL_ID) + self._wc.tunnel_id_mask = mask + self._flow.tunnel_id = tunnel_id def set_ipv6_exthdr(self, hdr): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IPV6_EXTHDR) - self.flow.ipv6_exthdr = hdr + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IPV6_EXTHDR) + self._flow.ipv6_exthdr = hdr def set_ipv6_exthdr_masked(self, hdr, mask): - self.wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IPV6_EXTHDR) - self.wc.ipv6_exthdr_mask = mask - self.flow.ipv6_exthdr = hdr + self._wc.ft_set(ofproto_v1_3.OFPXMT_OFB_IPV6_EXTHDR) + self._wc.ipv6_exthdr_mask = mask + self._flow.ipv6_exthdr = hdr class OFPMatchField(object): |