dc40f17a36
Provide functions to allow an external 802.3ad state machine to transmit and receive LACPDUs and to set the collection/distribution flags on slave interfaces. Signed-off-by: Eric Kinzie <ehkinzie@gmail.com> Acked-by: Declan Doherty <declan.doherty@intel.com>
306 lines
8.5 KiB
C
306 lines
8.5 KiB
C
/*-
|
|
* BSD LICENSE
|
|
*
|
|
* Copyright(c) 2010-2014 Intel Corporation. All rights reserved.
|
|
* All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
*
|
|
* * Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* * Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in
|
|
* the documentation and/or other materials provided with the
|
|
* distribution.
|
|
* * Neither the name of Intel Corporation nor the names of its
|
|
* contributors may be used to endorse or promote products derived
|
|
* from this software without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
#ifndef RTE_ETH_BOND_8023AD_H_
|
|
#define RTE_ETH_BOND_8023AD_H_
|
|
|
|
#include <rte_ether.h>
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
/**
|
|
* Actor/partner states
|
|
*/
|
|
#define STATE_LACP_ACTIVE 0x01
|
|
#define STATE_LACP_SHORT_TIMEOUT 0x02
|
|
#define STATE_AGGREGATION 0x04
|
|
#define STATE_SYNCHRONIZATION 0x08
|
|
#define STATE_COLLECTING 0x10
|
|
#define STATE_DISTRIBUTING 0x20
|
|
/** Partners parameters are defaulted */
|
|
#define STATE_DEFAULTED 0x40
|
|
#define STATE_EXPIRED 0x80
|
|
|
|
#define TLV_TYPE_ACTOR_INFORMATION 0x01
|
|
#define TLV_TYPE_PARTNER_INFORMATION 0x02
|
|
#define TLV_TYPE_COLLECTOR_INFORMATION 0x03
|
|
#define TLV_TYPE_TERMINATOR_INFORMATION 0x00
|
|
|
|
#define SLOW_SUBTYPE_LACP 0x01
|
|
#define SLOW_SUBTYPE_MARKER 0x02
|
|
|
|
#define MARKER_TLV_TYPE_INFO 0x01
|
|
#define MARKER_TLV_TYPE_RESP 0x02
|
|
|
|
typedef void (*rte_eth_bond_8023ad_ext_slowrx_fn)(uint8_t slave_id,
|
|
struct rte_mbuf *lacp_pkt);
|
|
|
|
enum rte_bond_8023ad_selection {
|
|
UNSELECTED,
|
|
STANDBY,
|
|
SELECTED
|
|
};
|
|
|
|
/** Generic slow protocol structure */
|
|
struct slow_protocol {
|
|
uint8_t subtype;
|
|
uint8_t reserved_119[119];
|
|
} __attribute__((__packed__));
|
|
|
|
/** Generic slow protocol frame type structure */
|
|
struct slow_protocol_frame {
|
|
struct ether_hdr eth_hdr;
|
|
struct slow_protocol slow_protocol;
|
|
} __attribute__((__packed__));
|
|
|
|
struct port_params {
|
|
uint16_t system_priority;
|
|
/**< System priority (unused in current implementation) */
|
|
struct ether_addr system;
|
|
/**< System ID - Slave MAC address, same as bonding MAC address */
|
|
uint16_t key;
|
|
/**< Speed information (implementation dependednt) and duplex. */
|
|
uint16_t port_priority;
|
|
/**< Priority of this (unused in current implementation) */
|
|
uint16_t port_number;
|
|
/**< Port number. It corresponds to slave port id. */
|
|
} __attribute__((__packed__));
|
|
|
|
struct lacpdu_actor_partner_params {
|
|
uint8_t tlv_type_info;
|
|
uint8_t info_length;
|
|
struct port_params port_params;
|
|
uint8_t state;
|
|
uint8_t reserved_3[3];
|
|
} __attribute__((__packed__));
|
|
|
|
/** LACPDU structure (5.4.2 in 802.1AX documentation). */
|
|
struct lacpdu {
|
|
uint8_t subtype;
|
|
uint8_t version_number;
|
|
|
|
struct lacpdu_actor_partner_params actor;
|
|
struct lacpdu_actor_partner_params partner;
|
|
|
|
uint8_t tlv_type_collector_info;
|
|
uint8_t collector_info_length;
|
|
uint16_t collector_max_delay;
|
|
uint8_t reserved_12[12];
|
|
|
|
uint8_t tlv_type_terminator;
|
|
uint8_t terminator_length;
|
|
uint8_t reserved_50[50];
|
|
} __attribute__((__packed__));
|
|
|
|
/** LACPDU frame: Contains ethernet header and LACPDU. */
|
|
struct lacpdu_header {
|
|
struct ether_hdr eth_hdr;
|
|
struct lacpdu lacpdu;
|
|
} __attribute__((__packed__));
|
|
|
|
struct marker {
|
|
uint8_t subtype;
|
|
uint8_t version_number;
|
|
|
|
uint8_t tlv_type_marker;
|
|
uint8_t info_length;
|
|
uint16_t requester_port;
|
|
struct ether_addr requester_system;
|
|
uint32_t requester_transaction_id;
|
|
uint8_t reserved_2[2];
|
|
|
|
uint8_t tlv_type_terminator;
|
|
uint8_t terminator_length;
|
|
uint8_t reserved_90[90];
|
|
} __attribute__((__packed__));
|
|
|
|
struct marker_header {
|
|
struct ether_hdr eth_hdr;
|
|
struct marker marker;
|
|
} __attribute__((__packed__));
|
|
|
|
struct rte_eth_bond_8023ad_conf {
|
|
uint32_t fast_periodic_ms;
|
|
uint32_t slow_periodic_ms;
|
|
uint32_t short_timeout_ms;
|
|
uint32_t long_timeout_ms;
|
|
uint32_t aggregate_wait_timeout_ms;
|
|
uint32_t tx_period_ms;
|
|
uint32_t rx_marker_period_ms;
|
|
uint32_t update_timeout_ms;
|
|
rte_eth_bond_8023ad_ext_slowrx_fn slowrx_cb;
|
|
};
|
|
|
|
struct rte_eth_bond_8023ad_slave_info {
|
|
enum rte_bond_8023ad_selection selected;
|
|
uint8_t actor_state;
|
|
struct port_params actor;
|
|
uint8_t partner_state;
|
|
struct port_params partner;
|
|
uint8_t agg_port_id;
|
|
};
|
|
|
|
/**
|
|
* @internal
|
|
*
|
|
* Function returns current configuration of 802.3AX mode.
|
|
*
|
|
* @param port_id Bonding device id
|
|
* @param conf Pointer to timeout structure.
|
|
*
|
|
* @return
|
|
* 0 - if ok
|
|
* -EINVAL if conf is NULL
|
|
*/
|
|
int
|
|
rte_eth_bond_8023ad_conf_get(uint8_t port_id,
|
|
struct rte_eth_bond_8023ad_conf *conf);
|
|
int
|
|
rte_eth_bond_8023ad_conf_get_v1604(uint8_t port_id,
|
|
struct rte_eth_bond_8023ad_conf *conf);
|
|
int
|
|
rte_eth_bond_8023ad_conf_get_v1607(uint8_t port_id,
|
|
struct rte_eth_bond_8023ad_conf *conf);
|
|
|
|
/**
|
|
* @internal
|
|
*
|
|
* Function set new configuration of 802.3AX mode.
|
|
*
|
|
* @param port_id Bonding device id
|
|
* @param conf Configuration, if NULL set default configuration.
|
|
* @return
|
|
* 0 - if ok
|
|
* -EINVAL if configuration is invalid.
|
|
*/
|
|
int
|
|
rte_eth_bond_8023ad_setup(uint8_t port_id,
|
|
struct rte_eth_bond_8023ad_conf *conf);
|
|
int
|
|
rte_eth_bond_8023ad_setup_v1604(uint8_t port_id,
|
|
struct rte_eth_bond_8023ad_conf *conf);
|
|
int
|
|
rte_eth_bond_8023ad_setup_v1607(uint8_t port_id,
|
|
struct rte_eth_bond_8023ad_conf *conf);
|
|
|
|
/**
|
|
* @internal
|
|
*
|
|
* Function returns current state of given slave device.
|
|
*
|
|
* @param slave_id Port id of valid slave.
|
|
* @param conf buffer for configuration
|
|
* @return
|
|
* 0 - if ok
|
|
* -EINVAL if conf is NULL or slave id is invalid (not a slave of given
|
|
* bonded device or is not inactive).
|
|
*/
|
|
int
|
|
rte_eth_bond_8023ad_slave_info(uint8_t port_id, uint8_t slave_id,
|
|
struct rte_eth_bond_8023ad_slave_info *conf);
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
/**
|
|
* Configure a slave port to start collecting.
|
|
*
|
|
* @param port_id Bonding device id
|
|
* @param slave_id Port id of valid slave.
|
|
* @param enabled Non-zero when collection enabled.
|
|
* @return
|
|
* 0 - if ok
|
|
* -EINVAL if slave is not valid.
|
|
*/
|
|
int
|
|
rte_eth_bond_8023ad_ext_collect(uint8_t port_id, uint8_t slave_id, int enabled);
|
|
|
|
/**
|
|
* Get COLLECTING flag from slave port actor state.
|
|
*
|
|
* @param port_id Bonding device id
|
|
* @param slave_id Port id of valid slave.
|
|
* @return
|
|
* 0 - if not set
|
|
* 1 - if set
|
|
* -EINVAL if slave is not valid.
|
|
*/
|
|
int
|
|
rte_eth_bond_8023ad_ext_collect_get(uint8_t port_id, uint8_t slave_id);
|
|
|
|
/**
|
|
* Configure a slave port to start distributing.
|
|
*
|
|
* @param port_id Bonding device id
|
|
* @param slave_id Port id of valid slave.
|
|
* @param enabled Non-zero when distribution enabled.
|
|
* @return
|
|
* 0 - if ok
|
|
* -EINVAL if slave is not valid.
|
|
*/
|
|
int
|
|
rte_eth_bond_8023ad_ext_distrib(uint8_t port_id, uint8_t slave_id, int enabled);
|
|
|
|
/**
|
|
* Get DISTRIBUTING flag from slave port actor state.
|
|
*
|
|
* @param port_id Bonding device id
|
|
* @param slave_id Port id of valid slave.
|
|
* @return
|
|
* 0 - if not set
|
|
* 1 - if set
|
|
* -EINVAL if slave is not valid.
|
|
*/
|
|
int
|
|
rte_eth_bond_8023ad_ext_distrib_get(uint8_t port_id, uint8_t slave_id);
|
|
|
|
/**
|
|
* LACPDU transmit path for external 802.3ad state machine. Caller retains
|
|
* ownership of the packet on failure.
|
|
*
|
|
* @param port_id Bonding device id
|
|
* @param slave_id Port ID of valid slave device.
|
|
* @param lacp_pkt mbuf containing LACPDU.
|
|
*
|
|
* @return
|
|
* 0 on success, negative value otherwise.
|
|
*/
|
|
int
|
|
rte_eth_bond_8023ad_ext_slowtx(uint8_t port_id, uint8_t slave_id,
|
|
struct rte_mbuf *lacp_pkt);
|
|
|
|
#endif /* RTE_ETH_BOND_8023AD_H_ */
|