From: muzixing <[email protected]>
Hi, First of all, I have to make a apologize for my mistake sincerely. Last
time is my first to send a PATCH to a maillist, and I did not know you have
mentioned some problems among the content of mail, so I just missed the message
until my friend told me last day. I am so sorry for my mistake.The PATCH below
has fixed the problems which you mentioned before. The functions of this APP
is:1)To learn the ARP record and try to reply ARP requests by Controller, if
controller has recorded it. 2)Learn the first in_port of ARP request, and drop
it if it retrun back in a different port form a loop topology, so that we can
break the logical loop and solve the ARP storm problem, which means we can use
this ARP proxy application in any topology even with loops. I am looking
forward to your reply. Thanks for your time.
---
ryu/app/simple_arp_proxy_13.py | 185 ++++++++++++++++++++++++++++++++++++++++
1 file changed, 185 insertions(+)
create mode 100644 ryu/app/simple_arp_proxy_13.py
diff --git a/ryu/app/simple_arp_proxy_13.py b/ryu/app/simple_arp_proxy_13.py
new file mode 100644
index 0000000..87b7c02
--- /dev/null
+++ b/ryu/app/simple_arp_proxy_13.py
@@ -0,0 +1,185 @@
+# Copyright (C) 2011 Nippon Telegraph and Telephone Corporation.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+# implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# Contributor:Li Cheng @BUPT
+# Homepage:www.muzixing.com
+# Time:2014/10/19
+#
+
+from ryu.base import app_manager
+from ryu.controller import ofp_event
+from ryu.controller.handler import CONFIG_DISPATCHER, MAIN_DISPATCHER
+from ryu.controller.handler import set_ev_cls
+from ryu.ofproto import ofproto_v1_3
+from ryu.lib.packet import packet
+from ryu.lib.packet import ethernet
+from ryu.lib.packet import arp
+from ryu.lib.packet import ipv6
+from ryu.lib import mac
+
+
+class SimpleARPProxy13(app_manager.RyuApp):
+ OFP_VERSIONS = [ofproto_v1_3.OFP_VERSION]
+
+ def __init__(self, *args, **kwargs):
+ super(SimpleARPProxy13, self).__init__(*args, **kwargs)
+ self.mac_to_port = {}
+ self.arp_table = {}
+ self.sw = {}
+
+ @set_ev_cls(ofp_event.EventOFPSwitchFeatures, CONFIG_DISPATCHER)
+ def switch_features_handler(self, ev):
+ datapath = ev.msg.datapath
+ ofproto = datapath.ofproto
+ parser = datapath.ofproto_parser
+
+ # install table-miss flow entry
+ #
+ # We specify NO BUFFER to max_len of the output action due to
+ # OVS bug. At this moment, if we specify a lesser number, e.g.,
+ # 128, OVS will send Packet-In with invalid buffer_id and
+ # truncated packet data. In that case, we cannot output packets
+ # correctly.
+
+ match = parser.OFPMatch()
+ actions = [parser.OFPActionOutput(ofproto.OFPP_CONTROLLER,
+ ofproto.OFPCML_NO_BUFFER)]
+ self.add_flow(datapath, 0, match, actions)
+
+ def add_flow(self, datapath, priority, match, actions):
+ ofproto = datapath.ofproto
+ parser = datapath.ofproto_parser
+
+ inst = [parser.OFPInstructionActions(ofproto.OFPIT_APPLY_ACTIONS,
+ actions)]
+
+ mod = parser.OFPFlowMod(datapath=datapath, priority=priority,
+ idle_timeout=5, hard_timeout=15,
+ match=match, instructions=inst)
+ datapath.send_msg(mod)
+
+ @set_ev_cls(ofp_event.EventOFPPacketIn, MAIN_DISPATCHER)
+ def _packet_in_handler(self, ev):
+ msg = ev.msg
+ datapath = msg.datapath
+ ofproto = datapath.ofproto
+ parser = datapath.ofproto_parser
+ in_port = msg.match['in_port']
+
+ pkt = packet.Packet(msg.data)
+ eth = pkt.get_protocols(ethernet.ethernet)[0]
+ dst = eth.dst
+ src = eth.src
+ dpid = datapath.id
+
+ if pkt.get_protocol(ipv6.ipv6): # Drop the IPV6 Packets.
+ match = parser.OFPMatch(eth_type=eth.ethertype)
+ actions = []
+ self.add_flow(datapath, 1, match, actions)
+ return None
+
+ arp_pkt = pkt.get_protocol(arp.arp)
+ if arp_pkt:
+ self.arp_table[arp_pkt.src_ip] = src # ARP learning
+
+ self.mac_to_port.setdefault(dpid, {})
+ self.logger.info("packet in %s %s %s %s", dpid, src, dst, in_port)
+
+ # Learn a mac address to avoid FLOOD next time.
+ self.mac_to_port[dpid][src] = in_port
+
+ if dst in self.mac_to_port[dpid]:
+ out_port = self.mac_to_port[dpid][dst]
+ else:
+ if self.arp_handler(msg): # 1:reply or drop; 0: flood
+ return None
+ else:
+ out_port = ofproto.OFPP_FLOOD
+
+ actions = [parser.OFPActionOutput(out_port)]
+
+ # Install a flow to avoid packet_in next time
+ if out_port != ofproto.OFPP_FLOOD:
+ match = parser.OFPMatch(in_port=in_port, eth_dst=dst)
+ self.add_flow(datapath, 1, match, actions)
+
+ data = None
+ if msg.buffer_id == ofproto.OFP_NO_BUFFER:
+ data = msg.data
+ out = parser.OFPPacketOut(datapath=datapath, buffer_id=msg.buffer_id,
+ in_port=in_port, actions=actions, data=data)
+ datapath.send_msg(out)
+
+ def arp_handler(self, msg):
+ datapath = msg.datapath
+ ofproto = datapath.ofproto
+ parser = datapath.ofproto_parser
+ in_port = msg.match['in_port']
+
+ pkt = packet.Packet(msg.data)
+ eth = pkt.get_protocols(ethernet.ethernet)[0]
+ arp_pkt = pkt.get_protocol(arp.arp)
+
+ if eth:
+ eth_dst = eth.dst
+ eth_src = eth.src
+
+ # Break the loop for avoiding ARP broadcast storm
+ if eth_dst == mac.BROADCAST_STR and arp_pkt:
+ arp_dst_ip = arp_pkt.dst_ip
+
+ if (datapath.id, eth_src, arp_dst_ip) in self.sw:
+ if self.sw[(datapath.id, eth_src, arp_dst_ip)] != in_port:
+ datapath.send_packet_out(in_port=in_port, actions=[])
+ return True
+ else:
+ self.sw[(datapath.id, eth_src, arp_dst_ip)] = in_port
+
+ # Try to reply arp request
+ if arp_pkt:
+ hwtype = arp_pkt.hwtype
+ proto = arp_pkt.proto
+ hlen = arp_pkt.hlen
+ plen = arp_pkt.plen
+ opcode = arp_pkt.opcode
+ arp_src_ip = arp_pkt.src_ip
+ arp_dst_ip = arp_pkt.dst_ip
+
+ if opcode == arp.ARP_REQUEST:
+ if arp_dst_ip in self.arp_table:
+ actions = [parser.OFPActionOutput(in_port)]
+ ARP_Reply = packet.Packet()
+
+ ARP_Reply.add_protocol(ethernet.ethernet(
+ ethertype=eth.ethertype,
+ dst=eth_src,
+ src=self.arp_table[arp_dst_ip]))
+ ARP_Reply.add_protocol(arp.arp(
+ opcode=arp.ARP_REPLY,
+ src_mac=self.arp_table[arp_dst_ip],
+ src_ip=arp_dst_ip,
+ dst_mac=eth_src,
+ dst_ip=arp_src_ip))
+
+ ARP_Reply.serialize()
+
+ out = parser.OFPPacketOut(
+ datapath=datapath,
+ buffer_id=ofproto.OFP_NO_BUFFER,
+ in_port=ofproto.OFPP_CONTROLLER,
+ actions=actions, data=ARP_Reply.data)
+ datapath.send_msg(out)
+ return True
+ return False
--
1.7.9.5------------------------------------------------------------------------------
Download BIRT iHub F-Type - The Free Enterprise-Grade BIRT Server
from Actuate! Instantly Supercharge Your Business Reports and Dashboards
with Interactivity, Sharing, Native Excel Exports, App Integration & more
Get technology previously reserved for billion-dollar corporations, FREE
http://pubads.g.doubleclick.net/gampad/clk?id=157005751&iu=/4140/ostg.clktrk
_______________________________________________
Ryu-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ryu-devel
