On Sun, Jun 10, 2012 at 09:37:03AM +0900, FUJITA Tomonori wrote:
> Signed-off-by: FUJITA Tomonori <[email protected]>
> ---
>  ryu/ofproto/nx_match.py     |   28 +++++++++++++++++++++-------
>  ryu/ofproto/ofproto_v1_0.py |    1 +
>  2 files changed, 22 insertions(+), 7 deletions(-)
> 
> diff --git a/ryu/ofproto/nx_match.py b/ryu/ofproto/nx_match.py
> index 30e9e3a..ff89357 100644
> --- a/ryu/ofproto/nx_match.py
> +++ b/ryu/ofproto/nx_match.py
> @@ -31,7 +31,6 @@ UINT64_MAX = (1 << 64) - 1
>  UINT16_MAX = (1 << 16) - 1
>  
>  FWW_IN_PORT = 1 << 0
> -FWW_DL_SRC = 1 << 2
>  FWW_DL_TYPE = 1 << 4
>  FWW_NW_PROTO = 1 << 5
>  # No corresponding OFPFW_* bits
> @@ -72,6 +71,7 @@ class Flow(object):
>  
>  class FlowWildcards(object):
>      def __init__(self):
> +        self.dl_src_mask = 0
>          self.dl_dst_mask = 0
>          self.tun_id_mask = 0
>          self.vlan_tci_mask = 0
> @@ -98,9 +98,14 @@ class ClsRule(object):
>                                        zip(dl_dst, mask)))
>  
>      def set_dl_src(self, dl_src):
> -        self.wc.wildcards &= ~FWW_DL_SRC
>          self.flow.dl_src = dl_src
>  
> +    def set_dl_src_masked(self, dl_src, mask):
> +        self.wc.dl_src_mask = mask
> +        self.flow.dl_src = reduce(lambda x, y: x + y,
> +                                  map(lambda x: chr(ord(x[0]) & ord(x[1])),
> +                                      zip(dl_src, mask)))
> +

The above reduce(...) logic also appears in set_dl_dst_masked().
Perhaps it would be a good time to put it in its own method?

>      def set_dl_type(self, dl_type):
>          self.wc.wildcards &= ~FWW_DL_TYPE
>          self.flow.dl_type = dl_type
> @@ -159,7 +164,7 @@ class ClsRule(object):
>          if not self.wc.wildcards & FWW_IN_PORT:
>              wildcards &= ~ofproto.OFPFW_IN_PORT
>  
> -        if not self.wc.wildcards & FWW_DL_SRC:
> +        if self.flow.dl_src != mac.DONTCARE:
>              wildcards &= ~ofproto.OFPFW_DL_SRC
>  
>          if self.wc.dl_dst_mask:
> @@ -254,14 +259,18 @@ class MFEthDst(MFField):
>  
>  
>  @_register_make
> -@_set_nxm_headers([ofproto_v1_0.NXM_OF_ETH_SRC])
> +@_set_nxm_headers([ofproto_v1_0.NXM_OF_ETH_SRC, 
> ofproto_v1_0.NXM_OF_ETH_SRC_W])
>  class MFEthSrc(MFField):
>      @classmethod
>      def make(cls):
>          return cls(MF_PACK_STRING_MAC)
>  
>      def put(self, buf, offset, rule):
> -        return self._put(buf, offset, rule.flow.dl_src)
> +        if rule.wc.dl_src_mask:
> +            return self.putw(buf, offset, rule.flow.dl_src,
> +                             rule.wc.dl_src_mask)
> +        else:
> +            return self._put(buf, offset, rule.flow.dl_src)
>  
>  
>  @_register_make
> @@ -359,8 +368,13 @@ def serialize_nxm_match(rule, buf, offset):
>              header = ofproto_v1_0.NXM_OF_ETH_DST
>          offset += nxm_put(buf, offset, header, rule)
>  
> -    if not rule.wc.wildcards & FWW_DL_SRC:
> -        offset += nxm_put(buf, offset, ofproto_v1_0.NXM_OF_ETH_SRC, rule)
> +    if rule.flow.dl_src != mac.DONTCARE:
> +        if rule.wc.dl_src_mask:
> +            header = ofproto_v1_0.NXM_OF_ETH_SRC_W
> +        else:
> +            header = ofproto_v1_0.NXM_OF_ETH_SRC
> +        offset += nxm_put(buf, offset, header, rule)
> +
>      if not rule.wc.wildcards & FWW_DL_TYPE:
>          offset += nxm_put(buf, offset, ofproto_v1_0.NXM_OF_ETH_TYPE, rule)
>  
> diff --git a/ryu/ofproto/ofproto_v1_0.py b/ryu/ofproto/ofproto_v1_0.py
> index 4be305c..b88581e 100644
> --- a/ryu/ofproto/ofproto_v1_0.py
> +++ b/ryu/ofproto/ofproto_v1_0.py
> @@ -666,6 +666,7 @@ NXM_OF_IN_PORT = nxm_header(0x0000, 0, 2)
>  NXM_OF_ETH_DST = nxm_header(0x0000, 1, 6)
>  NXM_OF_ETH_DST_W = nxm_header_w(0x0000, 1, 6)
>  NXM_OF_ETH_SRC = nxm_header(0x0000, 2, 6)
> +NXM_OF_ETH_SRC_W = nxm_header_w(0x0000, 2, 6)
>  NXM_OF_ETH_TYPE = nxm_header(0x0000, 3, 2)
>  
>  NXM_OF_VLAN_TCI = nxm_header(0x0000, 4, 2)
> -- 
> 1.7.4.4
> 
> 
> ------------------------------------------------------------------------------
> Live Security Virtual Conference
> Exclusive live event will cover all the ways today's security and 
> threat landscape has changed and how IT managers can respond. Discussions 
> will include endpoint security, mobile security and the latest in malware 
> threats. http://www.accelacomm.com/jaw/sfrnl04242012/114/50122263/
> _______________________________________________
> Ryu-devel mailing list
> [email protected]
> https://lists.sourceforge.net/lists/listinfo/ryu-devel
> 

------------------------------------------------------------------------------
Live Security Virtual Conference
Exclusive live event will cover all the ways today's security and 
threat landscape has changed and how IT managers can respond. Discussions 
will include endpoint security, mobile security and the latest in malware 
threats. http://www.accelacomm.com/jaw/sfrnl04242012/114/50122263/
_______________________________________________
Ryu-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ryu-devel

Reply via email to