/* SPDX-License-Identifier: BSD-3-Clause * Copyright(c) 2010-2017 Intel Corporation */ #ifndef _RTE_ETH_BOND_PRIVATE_H_ #define _RTE_ETH_BOND_PRIVATE_H_ #include #include #include #include #include #include "rte_eth_bond.h" #include "rte_eth_bond_8023ad_private.h" #include "rte_eth_bond_alb.h" #define PMD_BOND_SLAVE_PORT_KVARG ("slave") #define PMD_BOND_PRIMARY_SLAVE_KVARG ("primary") #define PMD_BOND_MODE_KVARG ("mode") #define PMD_BOND_AGG_MODE_KVARG ("agg_mode") #define PMD_BOND_XMIT_POLICY_KVARG ("xmit_policy") #define PMD_BOND_SOCKET_ID_KVARG ("socket_id") #define PMD_BOND_MAC_ADDR_KVARG ("mac") #define PMD_BOND_LSC_POLL_PERIOD_KVARG ("lsc_poll_period_ms") #define PMD_BOND_LINK_UP_PROP_DELAY_KVARG ("up_delay") #define PMD_BOND_LINK_DOWN_PROP_DELAY_KVARG ("down_delay") #define PMD_BOND_XMIT_POLICY_LAYER2_KVARG ("l2") #define PMD_BOND_XMIT_POLICY_LAYER23_KVARG ("l23") #define PMD_BOND_XMIT_POLICY_LAYER34_KVARG ("l34") extern int bond_logtype; #define RTE_BOND_LOG(lvl, msg, ...) \ rte_log(RTE_LOG_ ## lvl, bond_logtype, \ "%s(%d) - " msg "\n", __func__, __LINE__, ##__VA_ARGS__) #define BONDING_MODE_INVALID 0xFF extern const char *pmd_bond_init_valid_arguments[]; extern struct rte_vdev_driver pmd_bond_drv; extern const struct rte_flow_ops bond_flow_ops; /** Port Queue Mapping Structure */ struct bond_rx_queue { uint16_t queue_id; /**< Queue Id */ struct bond_dev_private *dev_private; /**< Reference to eth_dev private structure */ uint16_t nb_rx_desc; /**< Number of RX descriptors available for the queue */ struct rte_eth_rxconf rx_conf; /**< Copy of RX configuration structure for queue */ struct rte_mempool *mb_pool; /**< Reference to mbuf pool to use for RX queue */ }; struct bond_tx_queue { uint16_t queue_id; /**< Queue Id */ struct bond_dev_private *dev_private; /**< Reference to dev private structure */ uint16_t nb_tx_desc; /**< Number of TX descriptors available for the queue */ struct rte_eth_txconf tx_conf; /**< Copy of TX configuration structure for queue */ }; /** Bonded slave devices structure */ struct bond_ethdev_slave_ports { uint16_t slaves[RTE_MAX_ETHPORTS]; /**< Slave port id array */ uint16_t slave_count; /**< Number of slaves */ }; struct bond_slave_details { uint16_t port_id; uint8_t link_status_poll_enabled; uint8_t link_status_wait_to_complete; uint8_t last_link_status; /**< Port Id of slave eth_dev */ struct ether_addr persisted_mac_addr; uint16_t reta_size; }; struct rte_flow { TAILQ_ENTRY(rte_flow) next; /* Slaves flows */ struct rte_flow *flows[RTE_MAX_ETHPORTS]; /* Flow description for synchronization */ struct rte_flow_desc *fd; }; typedef void (*burst_xmit_hash_t)(struct rte_mbuf **buf, uint16_t nb_pkts, uint8_t slave_count, uint16_t *slaves); /** Link Bonding PMD device private configuration Structure */ struct bond_dev_private { uint16_t port_id; /**< Port Id of Bonded Port */ uint8_t mode; /**< Link Bonding Mode */ rte_spinlock_t lock; rte_spinlock_t lsc_lock; uint16_t primary_port; /**< Primary Slave Port */ uint16_t current_primary_port; /**< Primary Slave Port */ uint16_t user_defined_primary_port; /**< Flag for whether primary port is user defined or not */ uint8_t balance_xmit_policy; /**< Transmit policy - l2 / l23 / l34 for operation in balance mode */ burst_xmit_hash_t burst_xmit_hash; /**< Transmit policy hash function */ uint8_t user_defined_mac; /**< Flag for whether MAC address is user defined or not */ uint8_t promiscuous_en; /**< Enabled/disable promiscuous mode on bonding device */ uint8_t link_status_polling_enabled; uint32_t link_status_polling_interval_ms; uint32_t link_down_delay_ms; uint32_t link_up_delay_ms; uint16_t nb_rx_queues; /**< Total number of rx queues */ uint16_t nb_tx_queues; /**< Total number of tx queues*/ uint16_t active_slave; /**< Next active_slave to poll */ uint16_t active_slave_count; /**< Number of active slaves */ uint16_t active_slaves[RTE_MAX_ETHPORTS]; /**< Active slave list */ uint16_t slave_count; /**< Number of bonded slaves */ struct bond_slave_details slaves[RTE_MAX_ETHPORTS]; /**< Arary of bonded slaves details */ struct mode8023ad_private mode4; uint16_t tlb_slaves_order[RTE_MAX_ETHPORTS]; /**< TLB active slaves send order */ struct mode_alb_private mode6; uint64_t rx_offload_capa; /** Rx offload capability */ uint64_t tx_offload_capa; /** Tx offload capability */ uint64_t rx_queue_offload_capa; /** per queue Rx offload capability */ uint64_t tx_queue_offload_capa; /** per queue Tx offload capability */ /**< List of the configured flows */ TAILQ_HEAD(sub_flows, rte_flow) flow_list; /**< Flow isolation state */ int flow_isolated; int flow_isolated_valid; /** Bit mask of RSS offloads, the bit offset also means flow type */ uint64_t flow_type_rss_offloads; uint16_t reta_size; struct rte_eth_rss_reta_entry64 reta_conf[ETH_RSS_RETA_SIZE_512 / RTE_RETA_GROUP_SIZE]; uint8_t rss_key[52]; /**< 52-byte hash key buffer. */ uint8_t rss_key_len; /**< hash key length in bytes. */ struct rte_kvargs *kvlist; uint8_t slave_update_idx; uint32_t candidate_max_rx_pktlen; uint32_t max_rx_pktlen; void *vlan_filter_bmpmem; /* enabled vlan filter bitmap */ struct rte_bitmap *vlan_filter_bmp; }; extern const struct eth_dev_ops default_dev_ops; int check_for_master_bonded_ethdev(const struct rte_eth_dev *eth_dev); int check_for_bonded_ethdev(const struct rte_eth_dev *eth_dev); /* Search given slave array to find position of given id. * Return slave pos or slaves_count if not found. */ static inline uint16_t find_slave_by_id(uint16_t *slaves, uint16_t slaves_count, uint16_t slave_id) { uint16_t pos; for (pos = 0; pos < slaves_count; pos++) { if (slave_id == slaves[pos]) break; } return pos; } int valid_port_id(uint16_t port_id); int valid_bonded_port_id(uint16_t port_id); int valid_slave_port_id(uint16_t port_id, uint8_t mode); void deactivate_slave(struct rte_eth_dev *eth_dev, uint16_t port_id); void activate_slave(struct rte_eth_dev *eth_dev, uint16_t port_id); void link_properties_set(struct rte_eth_dev *bonded_eth_dev, struct rte_eth_link *slave_dev_link); int link_properties_valid(struct rte_eth_dev *bonded_eth_dev, struct rte_eth_link *slave_dev_link); int mac_address_set(struct rte_eth_dev *eth_dev, struct ether_addr *new_mac_addr); int mac_address_get(struct rte_eth_dev *eth_dev, struct ether_addr *dst_mac_addr); int mac_address_slaves_update(struct rte_eth_dev *bonded_eth_dev); int bond_ethdev_mode_set(struct rte_eth_dev *eth_dev, int mode); int slave_configure(struct rte_eth_dev *bonded_eth_dev, struct rte_eth_dev *slave_eth_dev); void slave_remove(struct bond_dev_private *internals, struct rte_eth_dev *slave_eth_dev); void slave_add(struct bond_dev_private *internals, struct rte_eth_dev *slave_eth_dev); void burst_xmit_l2_hash(struct rte_mbuf **buf, uint16_t nb_pkts, uint8_t slave_count, uint16_t *slaves); void burst_xmit_l23_hash(struct rte_mbuf **buf, uint16_t nb_pkts, uint8_t slave_count, uint16_t *slaves); void burst_xmit_l34_hash(struct rte_mbuf **buf, uint16_t nb_pkts, uint8_t slave_count, uint16_t *slaves); void bond_ethdev_primary_set(struct bond_dev_private *internals, uint16_t slave_port_id); int bond_ethdev_lsc_event_callback(uint16_t port_id, enum rte_eth_event_type type, void *param, void *ret_param); int bond_ethdev_parse_slave_port_kvarg(const char *key, const char *value, void *extra_args); int bond_ethdev_parse_slave_mode_kvarg(const char *key, const char *value, void *extra_args); int bond_ethdev_parse_slave_agg_mode_kvarg(const char *key __rte_unused, const char *value, void *extra_args); int bond_ethdev_parse_socket_id_kvarg(const char *key, const char *value, void *extra_args); int bond_ethdev_parse_primary_slave_port_id_kvarg(const char *key, const char *value, void *extra_args); int bond_ethdev_parse_balance_xmit_policy_kvarg(const char *key, const char *value, void *extra_args); int bond_ethdev_parse_bond_mac_addr_kvarg(const char *key, const char *value, void *extra_args); int bond_ethdev_parse_time_ms_kvarg(const char *key, const char *value, void *extra_args); void bond_tlb_disable(struct bond_dev_private *internals); void bond_tlb_enable(struct bond_dev_private *internals); void bond_tlb_activate_slave(struct bond_dev_private *internals); void bond_ethdev_stop(struct rte_eth_dev *eth_dev); void bond_ethdev_close(struct rte_eth_dev *dev); #endif