diff options
| author | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2012-06-23 10:43:57 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2012-06-23 15:54:44 +0900 |
| commit | cb713e44b98088829dac9372becec6cda74e7385 (patch) | |
| tree | 92a5fd4dd362af84340ecd61b73325757a24bebe | |
| parent | 1e9855b2eb02f17f4ea41ee62bb1d328bcaf6d16 (diff) | |
of1.2: add OXM_OF_IP_ECN
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
Reviewed-by: Simon Horman <horms@verge.net.au>
| -rw-r--r-- | ryu/ofproto/ofproto_v1_2_parser.py | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/ryu/ofproto/ofproto_v1_2_parser.py b/ryu/ofproto/ofproto_v1_2_parser.py index f33bb98c..0c530137 100644 --- a/ryu/ofproto/ofproto_v1_2_parser.py +++ b/ryu/ofproto/ofproto_v1_2_parser.py @@ -868,6 +868,7 @@ class Flow(object): self.vlan_vid = 0 self.vlan_pcp = 0 self.ip_dscp = 0 + self.ip_ecn = 0 self.arp_op = 0 self.arp_spa = 0 self.arp_tpa = 0 @@ -943,6 +944,10 @@ class OFPMatch(object): self.fields.append( OFPMatchField.make(ofproto_v1_2.OXM_OF_IP_DSCP)) + if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_IP_ECN): + self.fields.append( + OFPMatchField.make(ofproto_v1_2.OXM_OF_IP_ECN)) + if self.wc.ft_test(ofproto_v1_2.OFPXMT_OFB_ARP_OP): self.fields.append( OFPMatchField.make(ofproto_v1_2.OXM_OF_ARP_OP)) @@ -1045,6 +1050,10 @@ class OFPMatch(object): 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 + def set_arp_opcode(self, arp_op): self.wc.ft_set(ofproto_v1_2.OFPXMT_OFB_ARP_OP) self.flow.arp_op = arp_op @@ -1262,6 +1271,19 @@ class MTIPDscp(OFPMatchField): return MTIPDscp(header) +@OFPMatchField.register_field_header([ofproto_v1_2.OXM_OF_IP_ECN]) +class MTIPECN(OFPMatchField): + def __init__(self, header): + super(MTIPECN, self).__init__(header, '!B') + + def serialize(self, buf, offset, match): + self.put(buf, offset, match.flow.ip_ecn) + + @classmethod + def parser(cls, header, buf, offset): + return MTIPECN(header) + + @OFPMatchField.register_field_header([ofproto_v1_2.OXM_OF_ARP_OP]) class MTArpOp(OFPMatchField): def __init__(self, header): |