Hi

I want to split a flow into two flows, e.g., a flow entering into switch 1 will 
be splitted into two flows going to switch 3 and switch 5.



                ________________ switch 3_____________

                |                                                               
         |

h1------switch 1                                                               
switch 4-------- h2

               |_________________ switch 5____________|



Now, to split the flow I have used the following code, however, I have found 
that flow is not splitting and passing through only one link without sending 
any packets in other link.

1. Could you please help me identifying the problem?

2. Could you please share necessary resources/links/guidelines of load sharing 
in SDN using RYU so that I can have workable implementation?



#....................................................... send_group_mod 
.....................................................
    # applicable in Swicth-1 (shared switch/AP)


    def group_mod01(self, datapath):
        ofproto = datapath.ofproto
        parser = datapath.ofproto_parser

        group_id = 1
        action01 = [parser.OFPActionOutput(2)]   #  for switch 3
        action02 = [parser.OFPActionOutput(4)]   # for switch 5
        weight01 = 50
        weight02 = 50
        watch_port = ofproto_v1_3.OFPP_ANY
        watch_group = ofproto_v1_3.OFPQ_ALL
        buckets = [parser.OFPBucket(weight01, watch_port, watch_group, 
action01), parser.OFPBucket(weight02, watch_port, watch_group, action02)]
        req = parser.OFPGroupMod(datapath, ofproto.OFPFC_ADD, 
ofproto.OFPGT_SELECT, group_id, buckets)
        datapath.send_msg(req)

#....................................................... switch_in_handler 
...................................................
                                                  # pro-active rule in Switch 1

    @set_ev_cls(ofp_event.EventOFPSwitchFeatures, CONFIG_DISPATCHER)
    def switch_features_handler(self, ev):
        datapath = ev.msg.datapath
        dpid = datapath.id
        ofproto = datapath.ofproto
        parser = datapath.ofproto_parser

        if datapath.id == 1:
            self.group_mod01(datapath)
            actions = [parser.OFPActionSetField(ip_dscp = 1), 
parser.OFPActionGroup(group_id = 1)]
            priority = 100
            match = parser.OFPMatch(in_port= 1, eth_type=0x0800, 
ipv4_src='10.0.0.1', ipv4_dst='10.0.0.2', ip_proto=17, udp_dst=5555 )
            self.add_flow(datapath, priority , match, actions)






------------------------------------------------------------------------------
Check out the vibrant tech community on one of the world's most
engaging tech sites, Slashdot.org! http://sdm.link/slashdot
_______________________________________________
Ryu-devel mailing list
Ryu-devel@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/ryu-devel

Reply via email to