162306a36Sopenharmony_ci// SPDX-License-Identifier: GPL-2.0-or-later 262306a36Sopenharmony_ci/* 362306a36Sopenharmony_ci * drivers/net/team/team_mode_roundrobin.c - Round-robin mode for team 462306a36Sopenharmony_ci * Copyright (c) 2011 Jiri Pirko <jpirko@redhat.com> 562306a36Sopenharmony_ci */ 662306a36Sopenharmony_ci 762306a36Sopenharmony_ci#include <linux/kernel.h> 862306a36Sopenharmony_ci#include <linux/types.h> 962306a36Sopenharmony_ci#include <linux/module.h> 1062306a36Sopenharmony_ci#include <linux/init.h> 1162306a36Sopenharmony_ci#include <linux/netdevice.h> 1262306a36Sopenharmony_ci#include <linux/if_team.h> 1362306a36Sopenharmony_ci 1462306a36Sopenharmony_cistruct rr_priv { 1562306a36Sopenharmony_ci unsigned int sent_packets; 1662306a36Sopenharmony_ci}; 1762306a36Sopenharmony_ci 1862306a36Sopenharmony_cistatic struct rr_priv *rr_priv(struct team *team) 1962306a36Sopenharmony_ci{ 2062306a36Sopenharmony_ci return (struct rr_priv *) &team->mode_priv; 2162306a36Sopenharmony_ci} 2262306a36Sopenharmony_ci 2362306a36Sopenharmony_cistatic bool rr_transmit(struct team *team, struct sk_buff *skb) 2462306a36Sopenharmony_ci{ 2562306a36Sopenharmony_ci struct team_port *port; 2662306a36Sopenharmony_ci int port_index; 2762306a36Sopenharmony_ci 2862306a36Sopenharmony_ci port_index = team_num_to_port_index(team, 2962306a36Sopenharmony_ci rr_priv(team)->sent_packets++); 3062306a36Sopenharmony_ci port = team_get_port_by_index_rcu(team, port_index); 3162306a36Sopenharmony_ci if (unlikely(!port)) 3262306a36Sopenharmony_ci goto drop; 3362306a36Sopenharmony_ci port = team_get_first_port_txable_rcu(team, port); 3462306a36Sopenharmony_ci if (unlikely(!port)) 3562306a36Sopenharmony_ci goto drop; 3662306a36Sopenharmony_ci if (team_dev_queue_xmit(team, port, skb)) 3762306a36Sopenharmony_ci return false; 3862306a36Sopenharmony_ci return true; 3962306a36Sopenharmony_ci 4062306a36Sopenharmony_cidrop: 4162306a36Sopenharmony_ci dev_kfree_skb_any(skb); 4262306a36Sopenharmony_ci return false; 4362306a36Sopenharmony_ci} 4462306a36Sopenharmony_ci 4562306a36Sopenharmony_cistatic const struct team_mode_ops rr_mode_ops = { 4662306a36Sopenharmony_ci .transmit = rr_transmit, 4762306a36Sopenharmony_ci .port_enter = team_modeop_port_enter, 4862306a36Sopenharmony_ci .port_change_dev_addr = team_modeop_port_change_dev_addr, 4962306a36Sopenharmony_ci}; 5062306a36Sopenharmony_ci 5162306a36Sopenharmony_cistatic const struct team_mode rr_mode = { 5262306a36Sopenharmony_ci .kind = "roundrobin", 5362306a36Sopenharmony_ci .owner = THIS_MODULE, 5462306a36Sopenharmony_ci .priv_size = sizeof(struct rr_priv), 5562306a36Sopenharmony_ci .ops = &rr_mode_ops, 5662306a36Sopenharmony_ci .lag_tx_type = NETDEV_LAG_TX_TYPE_ROUNDROBIN, 5762306a36Sopenharmony_ci}; 5862306a36Sopenharmony_ci 5962306a36Sopenharmony_cistatic int __init rr_init_module(void) 6062306a36Sopenharmony_ci{ 6162306a36Sopenharmony_ci return team_mode_register(&rr_mode); 6262306a36Sopenharmony_ci} 6362306a36Sopenharmony_ci 6462306a36Sopenharmony_cistatic void __exit rr_cleanup_module(void) 6562306a36Sopenharmony_ci{ 6662306a36Sopenharmony_ci team_mode_unregister(&rr_mode); 6762306a36Sopenharmony_ci} 6862306a36Sopenharmony_ci 6962306a36Sopenharmony_cimodule_init(rr_init_module); 7062306a36Sopenharmony_cimodule_exit(rr_cleanup_module); 7162306a36Sopenharmony_ci 7262306a36Sopenharmony_ciMODULE_LICENSE("GPL v2"); 7362306a36Sopenharmony_ciMODULE_AUTHOR("Jiri Pirko <jpirko@redhat.com>"); 7462306a36Sopenharmony_ciMODULE_DESCRIPTION("Round-robin mode for team"); 7562306a36Sopenharmony_ciMODULE_ALIAS_TEAM_MODE("roundrobin"); 76