rte_eth_bond_8023ad.h

/*-
 *   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

#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

#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)(uint16_t slave_id,
                          struct rte_mbuf *lacp_pkt);

enum rte_bond_8023ad_selection {
    UNSELECTED,
    STANDBY,
    SELECTED
};

enum rte_bond_8023ad_agg_selection {
    AGG_BANDWIDTH,
    AGG_COUNT,
    AGG_STABLE
};

struct slow_protocol {
    uint8_t subtype;
    uint8_t reserved_119[119];
} __attribute__((__packed__));

struct slow_protocol_frame {
    struct ether_hdr eth_hdr;
    struct slow_protocol slow_protocol;
} __attribute__((__packed__));

struct port_params {
    uint16_t system_priority;
    struct ether_addr system;
    uint16_t key;
    uint16_t port_priority;
    uint16_t port_number;
} __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__));

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__));

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;
    enum rte_bond_8023ad_agg_selection agg_selection;
};

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;
    uint16_t agg_port_id;
};

int
rte_eth_bond_8023ad_conf_get(uint16_t port_id,
        struct rte_eth_bond_8023ad_conf *conf);

int
rte_eth_bond_8023ad_setup(uint16_t port_id,
        struct rte_eth_bond_8023ad_conf *conf);

int
rte_eth_bond_8023ad_slave_info(uint16_t port_id, uint16_t slave_id,
        struct rte_eth_bond_8023ad_slave_info *conf);

#ifdef __cplusplus
}
#endif

int
rte_eth_bond_8023ad_ext_collect(uint16_t port_id, uint16_t slave_id,
                int enabled);

int
rte_eth_bond_8023ad_ext_collect_get(uint16_t port_id, uint16_t slave_id);

int
rte_eth_bond_8023ad_ext_distrib(uint16_t port_id, uint16_t slave_id,
                int enabled);

int
rte_eth_bond_8023ad_ext_distrib_get(uint16_t port_id, uint16_t slave_id);

int
rte_eth_bond_8023ad_ext_slowtx(uint16_t port_id, uint16_t slave_id,
        struct rte_mbuf *lacp_pkt);

int
rte_eth_bond_8023ad_dedicated_queues_enable(uint16_t port_id);

int
rte_eth_bond_8023ad_dedicated_queues_disable(uint16_t port_id);

/*
 * Get aggregator mode for 8023ad
 * @param port_id Bonding device id
 *
 * @return
 *   agregator mode on success, negative value otherwise
 */
int
rte_eth_bond_8023ad_agg_selection_get(uint16_t port_id);

int
rte_eth_bond_8023ad_agg_selection_set(uint16_t port_id,
        enum rte_bond_8023ad_agg_selection agg_selection);
#endif /* RTE_ETH_BOND_8023AD_H_ */