structix/network_softwarization
1
0
Fork 0
Code Issues 3 Pull Requests Projects Releases Wiki Activity

Add lpm match

Browse Source
This commit is contained in:
structix
2022-05-24 14:06:01 +00:00
parent ade625fdb9
commit f982395ae6
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
Uebung1/controller_1_3.py
View File

@@ -40,15 +40,18 @@ class L3Switch(app_manager.RyuApp):
ofproto.OFPCML_NO_BUFFER)] ofproto.OFPCML_NO_BUFFER)]
self.add_flow(datapath, 0, match, actions) self.add_flow(datapath, 0, match, actions)
self.logger.info("Add new action for: ")
self.logger.info(datapath.id)
# Routing Switch 2 to 1 # Routing Switch 2 to 1
actions = [parser.OFPActionDecNwTtl(), #decrease TTL count if datapath.id == 2:
parser.OFPActionSetField(eth_src=self.MAC_ADDR[1]), # set own mac as source actions = [parser.OFPActionDecNwTtl(), #decrease TTL count
parser.OFPActionSetField(eth_dst=self.MAC_ADDR[0]), # set dst switch parser.OFPActionSetField(eth_src=self.MAC_ADDR[1]), # set own mac as source
parser.OFPActionOutput(1)] parser.OFPActionSetField(eth_dst=self.MAC_ADDR[0]), # set dst switch
parser.OFPActionOutput(1)]
match = parser.OFPMatch(ipv4_src="10.0.4.0/30", ipv4_dst="0.0.0.0", eth_type=0x0800) match = parser.OFPMatch(ipv4_src=("10.0.4.1", "255.255.255.252"), ipv4_dst=("10.0.1.1", "255.255.255.240"), eth_type=0x0800)
#match = parser.OFPMatch(ipv4_src="10.0.4.1", ipv4_dst="10.0.1.1", eth_type=0x0800)
self.add_flow(datapath, 0, match, actions) self.add_flow(datapath, 0, match, actions)
def add_flow(self, datapath, priority, match, actions, buffer_id=None): def add_flow(self, datapath, priority, match, actions, buffer_id=None):
ofproto = datapath.ofproto ofproto = datapath.ofproto
@@ -182,7 +185,7 @@ class L3Switch(app_manager.RyuApp):
pkt = packet.Packet() pkt = packet.Packet()
pkt.add_protocol(ethernet.ethernet(ethertype=pkt_ethernet.ethertype, pkt.add_protocol(ethernet.ethernet(ethertype=pkt_ethernet.ethertype,
dst=pkt_ethernet.src, dst=pkt_ethernet.src,
src=dpid)) src=self.MAC_ADDR[dpid]))
pkt.add_protocol(ipv4.ipv4(dst=pkt_ipv4.src, pkt.add_protocol(ipv4.ipv4(dst=pkt_ipv4.src,
src=pkt_ipv4.dst, src=pkt_ipv4.dst,
proto=pkt_ipv4.proto)) proto=pkt_ipv4.proto))
@@ -298,7 +301,7 @@ class L3Switch(app_manager.RyuApp):
self.logger.info("packet in dpid: %s, src: %s, dest: %s, in_port: %s", dpid, src, dst, in_port) self.logger.info("packet in dpid: %s, src: %s, dest: %s, in_port: %s", dpid, src, dst, in_port)
self.logger.info(pkt)
#learn mac to port mapping #learn mac to port mapping
if src not in self.mac_to_port[dpid]: if src not in self.mac_to_port[dpid]:
self.mac_to_port[dpid][src] = in_port self.mac_to_port[dpid][src] = in_port