mirror of
https://github.com/rtbrick/bngblaster.git
synced 2024-05-06 15:54:57 +00:00
Christian Giese
275 lines
7.1 KiB
C
275 lines
7.1 KiB
C
/*
|
|
* BNG Blaster (BBL) - Traffic Streams
|
|
*
|
|
* Christian Giese, Match 2021
|
|
*
|
|
* Copyright (C) 2020-2024, RtBrick, Inc.
|
|
* SPDX-License-Identifier: BSD-3-Clause
|
|
*/
|
|
#ifndef __BBL_STREAM_H__
|
|
#define __BBL_STREAM_H__
|
|
|
|
typedef struct bbl_stream_config_
|
|
{
|
|
char *name;
|
|
uint16_t stream_group_id;
|
|
|
|
uint8_t type;
|
|
uint8_t direction;
|
|
|
|
bool autostart;
|
|
bool session_traffic;
|
|
|
|
double pps;
|
|
uint64_t max_packets;
|
|
uint32_t start_delay;
|
|
uint32_t setup_interval;
|
|
|
|
uint16_t src_port;
|
|
uint16_t dst_port;
|
|
|
|
uint16_t length;
|
|
uint8_t priority; /* IPv4 TOS or IPv6 TC */
|
|
uint8_t vlan_priority;
|
|
uint8_t ttl;
|
|
|
|
uint32_t ipv4_ldp_lookup_address;
|
|
uint32_t ipv4_access_src_address; /* overwrite default IPv4 access address */
|
|
ipv6addr_t ipv6_access_src_address; /* overwrite default IPv6 access address */
|
|
uint32_t ipv4_network_address; /* overwrite default IPv4 network address */
|
|
ipv6addr_t ipv6_ldp_lookup_address;
|
|
ipv6addr_t ipv6_network_address; /* overwrite default IPv6 network address */
|
|
uint32_t ipv4_destination_address; /* overwrite IPv4 destination address */
|
|
ipv6addr_t ipv6_destination_address; /* overwrite IPv6 destination address */
|
|
char *network_interface;
|
|
char *a10nsp_interface;
|
|
|
|
bool ipv4_df;
|
|
bool tx_mpls1;
|
|
uint32_t tx_mpls1_label;
|
|
uint8_t tx_mpls1_exp;
|
|
uint8_t tx_mpls1_ttl;
|
|
|
|
bool tx_mpls2;
|
|
uint32_t tx_mpls2_label;
|
|
uint8_t tx_mpls2_exp;
|
|
uint8_t tx_mpls2_ttl;
|
|
|
|
bool rx_mpls1;
|
|
uint32_t rx_mpls1_label;
|
|
|
|
bool rx_mpls2;
|
|
uint32_t rx_mpls2_label;
|
|
|
|
bool nat;
|
|
bool raw_tcp; /* Pseudo TCP Streams*/
|
|
|
|
bbl_stream_config_s *next; /* Next stream config */
|
|
} bbl_stream_config_s;
|
|
|
|
typedef struct bbl_stream_group_
|
|
{
|
|
double pps;
|
|
uint32_t count;
|
|
bbl_stream_s *head;
|
|
struct timer_ *timer;
|
|
bbl_stream_group_s *next;
|
|
} bbl_stream_group_s;
|
|
|
|
/**
|
|
* In the architecture of BNG Blaster, every traffic stream
|
|
* corresponds to one or two flows, namely upstream and downstream.
|
|
* Each flow is encapsulated within a bbl_stream_s structure and is
|
|
* assigned a unique 64-bit flow identifier. The structure is organized
|
|
* into three distinct sections, each separated by cache-line aligned
|
|
* padding (pad0 and pad1). The first section is dedicated to writes
|
|
* by the main thread, the second section by the TX thread, and the
|
|
* final section by the RX thread. This design was used to allow
|
|
* lock-free but thread-safe access across different threads.
|
|
*/
|
|
typedef struct bbl_stream_
|
|
{
|
|
uint64_t last_sync_packets_tx;
|
|
uint64_t last_sync_packets_rx;
|
|
uint64_t last_sync_loss;
|
|
uint64_t last_sync_wrong_session;
|
|
|
|
uint64_t reset_packets_tx;
|
|
uint64_t reset_packets_rx;
|
|
uint64_t reset_loss;
|
|
|
|
bbl_rate_s rate_packets_tx;
|
|
bbl_rate_s rate_packets_rx;
|
|
|
|
uint64_t flow_id; /* KEY */
|
|
uint8_t type;
|
|
uint8_t sub_type;
|
|
uint8_t direction;
|
|
uint8_t tcp_flags;
|
|
|
|
bool enabled;
|
|
bool threaded;
|
|
bool session_traffic;
|
|
bool setup;
|
|
bool verified;
|
|
bool wait;
|
|
bool reset;
|
|
bool nat;
|
|
bool tcp;
|
|
bool lag;
|
|
bool ldp_lookup;
|
|
|
|
uint32_t session_version;
|
|
uint32_t ldp_entry_version;
|
|
|
|
uint32_t ipv4_src;
|
|
uint32_t ipv4_dst;
|
|
|
|
uint16_t tx_len; /* TX length */
|
|
uint16_t tx_bbl_hdr_len; /* TX BBL HDR length */
|
|
uint8_t *tx_buf; /* TX buffer */
|
|
|
|
uint8_t *ipv6_src;
|
|
uint8_t *ipv6_dst;
|
|
|
|
bbl_stream_config_s *config;
|
|
|
|
bbl_stream_s *next; /* Next stream (global) */
|
|
bbl_stream_s *io_next; /* Next stream of same IO handle */
|
|
bbl_stream_s *group_next; /* Next stream of same group */
|
|
bbl_stream_s *lag_next; /* Next stream of same LAG group */
|
|
bbl_stream_s *session_next; /* Next stream of same session */
|
|
bbl_stream_s *reverse; /* Reverse stream direction */
|
|
|
|
bbl_stream_group_s *group;
|
|
bbl_session_s *session;
|
|
endpoint_state_t *endpoint;
|
|
|
|
io_handle_s *io;
|
|
io_bucket_s *io_bucket;
|
|
|
|
bbl_access_interface_s *tx_access_interface;
|
|
bbl_network_interface_s *tx_network_interface;
|
|
bbl_a10nsp_interface_s *tx_a10nsp_interface;
|
|
bbl_interface_s *tx_interface; /* TX interface */
|
|
ldp_db_entry_s *ldp_entry;
|
|
|
|
char _pad0 __attribute__((__aligned__(CACHE_LINE_SIZE))); /* empty cache line */
|
|
|
|
uint64_t flow_seq;
|
|
uint64_t tx_packets;
|
|
uint64_t tokens;
|
|
uint64_t tokens_burst;
|
|
uint64_t max_packets;
|
|
|
|
__time_t tx_first_epoch;
|
|
|
|
struct timespec wait_start;
|
|
|
|
char _pad1 __attribute__((__aligned__(CACHE_LINE_SIZE))); /* empty cache line */
|
|
|
|
uint64_t rx_packets;
|
|
uint64_t rx_loss;
|
|
uint64_t rx_wrong_session;
|
|
uint64_t rx_wrong_order;
|
|
|
|
uint64_t rx_min_delay_us;
|
|
uint64_t rx_max_delay_us;
|
|
|
|
uint16_t rx_len;
|
|
uint64_t rx_first_seq;
|
|
uint64_t rx_last_seq;
|
|
|
|
__time_t rx_first_epoch;
|
|
__time_t rx_last_epoch;
|
|
|
|
uint8_t rx_priority; /* IPv4 TOS or IPv6 TC */
|
|
uint8_t rx_outer_vlan_pbit;
|
|
uint8_t rx_inner_vlan_pbit;
|
|
|
|
bool rx_mpls1;
|
|
uint8_t rx_mpls1_exp;
|
|
uint8_t rx_mpls1_ttl;
|
|
uint32_t rx_mpls1_label;
|
|
|
|
bool rx_mpls2;
|
|
uint8_t rx_mpls2_exp;
|
|
uint8_t rx_mpls2_ttl;
|
|
uint32_t rx_mpls2_label;
|
|
|
|
uint32_t rx_source_ip;
|
|
uint16_t rx_source_port;
|
|
|
|
bbl_access_interface_s *rx_access_interface;
|
|
bbl_network_interface_s *rx_network_interface;
|
|
bbl_a10nsp_interface_s *rx_a10nsp_interface;
|
|
|
|
} bbl_stream_s;
|
|
|
|
bbl_stream_s *
|
|
bbl_stream_index_get(uint64_t flow_id);
|
|
|
|
bool
|
|
bbl_stream_index_init();
|
|
|
|
bool
|
|
bbl_stream_session_init(bbl_session_s *session);
|
|
|
|
bool
|
|
bbl_stream_init();
|
|
|
|
void
|
|
bbl_stream_final();
|
|
|
|
protocol_error_t
|
|
bbl_stream_io_send(io_handle_s *io, bbl_stream_s *stream);
|
|
|
|
bbl_stream_s*
|
|
bbl_stream_io_send_iter(io_handle_s *io);
|
|
|
|
bbl_stream_s *
|
|
bbl_stream_rx(bbl_ethernet_header_s *eth, uint8_t *mac);
|
|
|
|
void
|
|
bbl_stream_reset(bbl_stream_s *stream);
|
|
|
|
json_t *
|
|
bbl_stream_json(bbl_stream_s *stream, bool debug);
|
|
|
|
int
|
|
bbl_stream_ctrl_stats(int fd, uint32_t session_id __attribute__((unused)), json_t *arguments __attribute__((unused)));
|
|
|
|
int
|
|
bbl_stream_ctrl_info(int fd, uint32_t session_id __attribute__((unused)), json_t *arguments);
|
|
|
|
int
|
|
bbl_stream_ctrl_summary(int fd, uint32_t session_id __attribute__((unused)), json_t *arguments __attribute__((unused)));
|
|
|
|
int
|
|
bbl_stream_ctrl_session(int fd, uint32_t session_id, json_t *arguments __attribute__((unused)));
|
|
|
|
int
|
|
bbl_stream_ctrl_traffic_start(int fd, uint32_t session_id, json_t *arguments __attribute__((unused)));
|
|
|
|
int
|
|
bbl_stream_ctrl_traffic_stop(int fd, uint32_t session_id, json_t *arguments __attribute__((unused)));
|
|
|
|
int
|
|
bbl_stream_ctrl_reset(int fd, uint32_t session_id __attribute__((unused)), json_t *arguments __attribute__((unused)));
|
|
|
|
int
|
|
bbl_stream_ctrl_pending(int fd, uint32_t session_id __attribute__((unused)), json_t *arguments __attribute__((unused)));
|
|
|
|
int
|
|
bbl_stream_ctrl_start(int fd, uint32_t session_id, json_t *arguments);
|
|
|
|
int
|
|
bbl_stream_ctrl_stop(int fd, uint32_t session_id, json_t *arguments);
|
|
|
|
int
|
|
bbl_stream_ctrl_stop_verified(int fd, uint32_t session_id, json_t *arguments);
|
|
|
|
int
|
|
bbl_stream_ctrl_update(int fd, uint32_t session_id __attribute__((unused)), json_t *arguments);
|
|
|
|
#endif |