Nice to e-meet you. My name is Okano Yuu.
I created a new ryu application, simple_dhcp_server for DHCPServer.
I tested this application with 2 VMs, and this application worked well.
VM1... DHCPClient
VM2... DHCPServer(Ryu & OpenVSwitch)
I set one flowentry on OpenVSwitch "ovs-ofctl add-flow br-test
udp,actions=Controller".
This application supports pep8.
Check this code and comments please.
Thanks!
From 574912f9524592599978562c7a5693724491f242 Mon Sep 17 00:00:00 2001
From: Okano Yuu <alexei.fyodorovich.karama...@gmail.com>
Date: Wed, 7 Oct 2015 01:14:27 +0900
Subject: [PATCH] add simple_dhcp_server.py
ryu application for DHCPServer.
Signed-off-by: Okano Yuu <alexei.fyodorovich.karama...@gmail.com>
---
ryu/app/simple_dhcp_server.py | 128 ++++++++++++++++++++++++++++++++++++++++++
1 file changed, 128 insertions(+)
create mode 100644 ryu/app/simple_dhcp_server.py
diff --git a/ryu/app/simple_dhcp_server.py b/ryu/app/simple_dhcp_server.py
new file mode 100644
index 0000000..5bb986e
--- /dev/null
+++ b/ryu/app/simple_dhcp_server.py
@@ -0,0 +1,128 @@
+"""
+ Simple DHCP Server
+"""
+import logging
+from netaddr import IPNetwork, IPAddress
+
+from ryu.ofproto import ofproto_v1_3
+from ryu.base import app_manager
+from ryu.lib.packet import dhcp, udp, ipv4, ethernet
+from ryu.controller.handler import set_ev_cls
+from ryu.controller import ofp_event
+from ryu.controller.handler import MAIN_DISPATCHER
+from ryu.lib.packet import packet
+from ryu.lib import addrconv
+
+
+class SimpleDHCPServer(app_manager.RyuApp):
+ OFP_VERSIONS = [ofproto_v1_3.OFP_VERSION]
+
+ def __init__(self, *args, **kwargs):
+ super(SimpleDHCPServer, self).__init__(*args, **kwargs)
+
+ self.hw_addr = "08:00:27:b8:0f:8d"
+ self.dhcp_addr = IPAddress('192.168.1.2')
+ self.gw_addr = IPAddress('192.168.1.1')
+ self.broadcast_addr = IPAddress('192.168.1.255')
+ self.ip_network = IPNetwork('192.168.1.0/24')
+ self.ip_pool_list = list(self.ip_network)
+ self.dns_addr = IPAddress('8.8.8.8')
+
+ assert self.dhcp_addr in self.ip_pool_list
+ assert self.gw_addr in self.ip_pool_list
+
+ self.ip_pool_list.remove(self.dhcp_addr)
+ self.ip_pool_list.remove(self.gw_addr)
+ self.ip_pool_list.remove(self.broadcast_addr)
+
+ @set_ev_cls(ofp_event.EventOFPPacketIn, MAIN_DISPATCHER)
+ def _packet_in_handler(self, ev):
+ msg = ev.msg
+ datapath = msg.datapath
+ ofproto = datapath.ofproto
+ in_port = msg.match['in_port']
+
+ pkt = packet.Packet(msg.data)
+ udpPacket = pkt.get_protocol(udp.udp)
+
+ # check if DHCP Pacet
+ if udpPacket and udpPacket.src_port == 68:
+ dhcpPacket = dhcp.dhcp.parser(pkt.protocols[-1])[0]
+ msgType = dhcpPacket.options.option_list[0].value
+
+ if msgType == '\x01':
+ self.logger.info("Discover message.")
+ self.handle_dhcp_discover(dhcpPacket, datapath, in_port)
+
+ if msgType == '\x03':
+ self.logger.info("Request message.")
+ self.handle_dhcp_request(dhcpPacket, datapath, in_port)
+
+ def handle_dhcp_discover(self, dhcp_pkt, datapath, port):
+
+ # send dhcp_offer message.
+ msg_option = dhcp.option(tag=dhcp.DHCP_MESSAGE_TYPE_OPT, value='\x02')
+ options = dhcp.options(option_list=[msg_option])
+ hlen = len(addrconv.mac.text_to_bin(dhcp_pkt.chaddr))
+
+ dhcp_pkt = dhcp.dhcp(hlen=hlen, op=dhcp.DHCP_BOOT_REPLY,
+ chaddr=dhcp_pkt.chaddr, yiaddr=dhcp_pkt.yiaddr,
+ giaddr=dhcp_pkt.giaddr, xid=dhcp_pkt.xid,
+ options=options)
+
+ self._send_dhcp_packet(datapath, dhcp_pkt, port)
+
+ def handle_dhcp_request(self, dhcp_pkt, datapath, port):
+
+ # send dhcp_ack message.
+ subnet_option = dhcp.option(tag=dhcp.DHCP_SUBNET_MASK_OPT,
+
value=addrconv.ipv4.text_to_bin(self.ip_network.netmask))
+ gw_option = dhcp.option(tag=dhcp.DHCP_GATEWAY_ADDR_OPT,
+ value=addrconv.ipv4.text_to_bin(self.gw_addr))
+ dns_option = dhcp.option(tag=dhcp.DHCP_DNS_SERVER_ADDR_OPT,
+
value=addrconv.ipv4.text_to_bin(self.dns_addr))
+ time_option = dhcp.option(tag=dhcp.DHCP_IP_ADDR_LEASE_TIME_OPT,
+ value='\xFF\xFF\xFF\xFF')
+ msg_option = dhcp.option(tag=dhcp.DHCP_MESSAGE_TYPE_OPT,
+ value='\x05')
+ id_option = dhcp.option(tag=dhcp.DHCP_SERVER_IDENTIFIER_OPT,
+
value=addrconv.ipv4.text_to_bin(self.dhcp_addr))
+ options = dhcp.options(option_list=[msg_option, id_option,
+ time_option, subnet_option,
+ gw_option, dns_option])
+ hlen = len(addrconv.mac.text_to_bin(dhcp_pkt.chaddr))
+ client_ip_addr = str(self.ip_pool_list.pop())
+
+ dhcp_pkt = dhcp.dhcp(op=dhcp.DHCP_BOOT_REPLY, hlen=hlen,
+ chaddr=dhcp_pkt.chaddr, yiaddr=client_ip_addr,
+ giaddr=dhcp_pkt.giaddr, xid=dhcp_pkt.xid,
+ options=options)
+
+ self._send_dhcp_packet(datapath, dhcp_pkt, port)
+
+ def _send_dhcp_packet(self, datapath, dhcp_pkt, port):
+
+ pkt = packet.Packet()
+ pkt.add_protocol(ethernet.ethernet
+ (src=self.hw_addr, dst=dhcp_pkt.chaddr))
+ pkt.add_protocol(ipv4.ipv4
+ (src=self.dhcp_addr, dst="255.255.255.255", proto=17))
+ pkt.add_protocol(udp.udp(src_port=67, dst_port=68))
+ pkt.add_protocol(dhcp_pkt)
+
+ self._send_packet(datapath, pkt, port)
+
+ def _send_packet(self, datapath, pkt, port):
+
+ ofproto = datapath.ofproto
+ parser = datapath.ofproto_parser
+ pkt.serialize()
+ self.logger.info("packet-out %s" % (pkt,))
+ data = pkt.data
+ actions = [parser.OFPActionOutput(port=port)]
+ out = parser.OFPPacketOut(datapath=datapath,
+ buffer_id=ofproto.OFP_NO_BUFFER,
+ in_port=ofproto.OFPP_CONTROLLER,
+ actions=actions,
+ data=data)
+ datapath.send_msg(out)
--
2.3.8 (Apple Git-58)
------------------------------------------------------------------------------
_______________________________________________
Ryu-devel mailing list
Ryu-devel@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/ryu-devel
