mirror/rtbrick-bngblaster
1
0
Fork 0
mirror of https://github.com/rtbrick/bngblaster.git synced 2024-05-06 15:54:57 +00:00
Code Issues Projects Releases Wiki Activity
Files
stream-loss
rtbrick-bngblaster/code/bngblaster/src/bbl_interactive.c
T
Christian Giese c11db83bd8 fix teardown
2024-03-22 13:12:31 +00:00

787 lines
37 KiB
C
Raw Permalink Blame History

/*
* BNG Blaster (BBL) - Interactive Mode
*
* Hannes Gredler, July 2020
* Christian Giese, October 2020
*
* Copyright (C) 2020-2024, RtBrick, Inc.
* SPDX-License-Identifier: BSD-3-Clause
*/
#include "bbl.h"
#include "bbl_stats.h"
#include "bbl_session.h"
#include "bbl_stream.h"
#define PROGRESS_BAR_SIZE 60
#define STATS_WIN_SIZE 90
#define STRING_SP_SIZE 64
#define VISIBLE(_expression) \
visible = false; \
if(_expression) { \
if(pos > stats_win_postion) { \
visible = true; \
} \
pos++; \
} \
if(visible)
typedef enum {
UI_VIEW_DEFAULT = 0,
UI_VIEW_ACCESS_IF_STATS,
UI_VIEW_SESSION,
UI_VIEW_MAX,
} __attribute__ ((__packed__)) bbl_ui_view;
/* ncurses */
WINDOW *stats_win = NULL;
WINDOW *log_win = NULL;
int stats_win_postion;
extern bool g_banner;
extern bool g_interactive;
/* This global variable is used to switch between access interfaces. */
bbl_access_interface_s *g_access_if = NULL;
bbl_network_interface_s *g_network_if = NULL;
bbl_a10nsp_interface_s *g_a10nsp_if = NULL;
/* This global variable is used to switch between views. */
bbl_ui_view g_view_selected = 0;
/* This global variable is used to switch between sessions in some views. */
uint32_t g_session_selected = 1;
extern const char banner[];
/*
* The log message buffer is used to display in the ncurses log window
* even those messages logged before ncurses has started.
*/
extern char *g_log_buf;
extern uint8_t g_log_buf_cur;
void
bbl_interactive_log_buf_init()
{
if(g_log_buf) {
free(g_log_buf);
}
g_log_buf = calloc(LOG_BUF_LINES, LOG_BUF_STR_LEN);
g_log_buf_cur = 0;
}
static void
bbl_interactive_log_buf_free()
{
int i = 0;
char *line = NULL;
if(!g_log_buf) {
return;
}
for(i = g_log_buf_cur; i < LOG_BUF_LINES; i++) {
line = g_log_buf+(i*LOG_BUF_STR_LEN);
if(!strnlen(line, LOG_BUF_STR_LEN)) {
break;
}
wprintw(log_win, "%s", line);
}
for(i = 0; i < g_log_buf_cur; i++) {
line = g_log_buf+(i*LOG_BUF_STR_LEN);
if(!strnlen(line, LOG_BUF_STR_LEN)) {
break;
}
wprintw(log_win, "%s", line);
}
wrefresh(log_win);
free(g_log_buf);
g_log_buf = NULL;
}
/*
* Format a progress bar.
*/
static char *
bbl_interactive_format_progress(uint32_t complete, uint32_t current)
{
static char buf[PROGRESS_BAR_SIZE+1];
float percentage;
uint16_t idx;
if(!complete || !current) {
memset(buf, ' ', sizeof(buf));
goto EXIT;
}
percentage = (float)current / (float)complete;
for(idx = 0; idx < sizeof(buf); idx++) {
if(idx <= (percentage * PROGRESS_BAR_SIZE)) {
buf[idx] = '#';
continue;
}
buf[idx] = ' ';
}
EXIT:
buf[PROGRESS_BAR_SIZE] = 0;
return buf;
}
static void
bbl_interactive_init_window()
{
wclear(stats_win);
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, "F1: Select View F7/F8: Start/Stop Traffic F9: Terminate Sessions\n");
if(g_view_selected == UI_VIEW_SESSION) {
wprintw(stats_win, "Left/Right: Select Session\n");
} else {
if(!CIRCLEQ_EMPTY(&g_ctx->network_interface_qhead)) {
wprintw(stats_win, "F2: Network Interface ");
}
if(!CIRCLEQ_EMPTY(&g_ctx->a10nsp_interface_qhead)) {
wprintw(stats_win, "F3: Select A10NSP Interface ");
}
if(!CIRCLEQ_EMPTY(&g_ctx->access_interface_qhead)) {
wprintw(stats_win, "Left/Right: Access Interface");
}
wprintw(stats_win, "\n");
}
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
if(g_banner) {
wprintw(stats_win, "%s", banner);
}
}
/*
* Interactive keyboard reader
*/
void
bbl_interactive_read_key_job(timer_s *timer)
{
int ch;
UNUSED(timer);
ch = getch();
switch (ch) {
case KEY_F(1):
stats_win_postion = 0;
g_view_selected++;
if(g_view_selected >= UI_VIEW_MAX) {
g_view_selected = UI_VIEW_DEFAULT;
}
/* Skip access interface and session views
* if there is no access interface. */
if(!g_access_if) {
switch(g_view_selected) {
case UI_VIEW_ACCESS_IF_STATS:
case UI_VIEW_SESSION:
g_view_selected = UI_VIEW_DEFAULT;
break;
default:
break;
}
}
bbl_interactive_init_window();
break;
case KEY_F(2):
if(g_network_if) {
g_network_if = CIRCLEQ_LOOP_NEXT(&g_ctx->network_interface_qhead,
g_network_if, network_interface_qnode);
bbl_interactive_init_window();
}
break;
case KEY_F(3):
if(g_a10nsp_if) {
g_a10nsp_if = CIRCLEQ_LOOP_NEXT(&g_ctx->a10nsp_interface_qhead,
g_a10nsp_if, a10nsp_interface_qnode);
bbl_interactive_init_window();
}
break;
case KEY_LEFT:
if(g_view_selected == UI_VIEW_SESSION) {
if(g_session_selected > 1) {
g_session_selected--;
} else {
g_session_selected = g_ctx->sessions;
}
} else {
if(!CIRCLEQ_EMPTY(&g_ctx->access_interface_qhead)) {
g_access_if = CIRCLEQ_LOOP_PREV(&g_ctx->access_interface_qhead,
g_access_if, access_interface_qnode);
bbl_interactive_init_window();
}
}
bbl_interactive_init_window();
break;
case KEY_RIGHT:
if(g_view_selected == UI_VIEW_SESSION) {
g_session_selected++;
if(g_session_selected > g_ctx->sessions) {
g_session_selected = 1;
}
} else {
if(g_access_if) {
g_access_if = CIRCLEQ_LOOP_NEXT(&g_ctx->access_interface_qhead,
g_access_if, access_interface_qnode);
bbl_interactive_init_window();
}
}
bbl_interactive_init_window();
break;
case KEY_F(7):
global_traffic_enable(true);
LOG_NOARG(INFO, "Start traffic\n");
break;
case KEY_F(8):
global_traffic_enable(false);
LOG_NOARG(INFO, "Stop traffic\n");
break;
case KEY_F(9):
teardown_request();
break;
case KEY_DOWN:
if(g_view_selected == UI_VIEW_DEFAULT) {
if(stats_win_postion < 6) {
stats_win_postion++;
}
bbl_interactive_init_window();
} else if(g_view_selected == UI_VIEW_SESSION) {
stats_win_postion++;
bbl_interactive_init_window();
}
break;
case KEY_UP:
if(stats_win_postion) stats_win_postion--;
bbl_interactive_init_window();
break;
default:
break;
}
}
/*
* Display meaningful stats in a curses window.
*/
void
bbl_interactive_window_job(timer_s *timer)
{
UNUSED(timer);
bbl_access_interface_s *access_if;
bbl_network_interface_s *network_if;
bbl_a10nsp_interface_s *a10nsp_if;
struct timespec now;
struct timespec time_duration = {0};
struct timespec time_established = {0};
char strsp[STRING_SP_SIZE];
bbl_session_s *session;
int i;
double d;
int pos = 1; /* position */
bool visible = false;
if(g_banner) {
wmove(stats_win, 14, 0);
} else {
wmove(stats_win, 2, 0);
}
clock_gettime(CLOCK_MONOTONIC, &now);
timespec_sub(&time_duration, &now, &g_ctx->timestamp_start);
if(g_ctx->timestamp_established.tv_sec) {
timespec_sub(&time_established, &now, &g_ctx->timestamp_established);
wprintw(stats_win, "Test Duration: %lus All Sessions Established: %lus\n",
time_duration.tv_sec, time_established.tv_sec);
} else {
wprintw(stats_win, "Test Duration: %lus\n",
time_duration.tv_sec);
}
if(g_view_selected == UI_VIEW_DEFAULT) {
VISIBLE((g_ctx->sessions)) {
wprintw(stats_win, "\nSessions %10u (%u PPPoE / %u IPoE)\n", g_ctx->sessions, g_ctx->sessions_pppoe, g_ctx->sessions_ipoe);
/* Progress bar established sessions */
wprintw(stats_win, " Established %10u [", g_ctx->sessions_established);
if(g_ctx->sessions == g_ctx->sessions_established) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->sessions, g_ctx->sessions_established));
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wattron(stats_win, COLOR_PAIR(COLOR_BLACK));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->sessions, g_ctx->sessions_established));
wattroff(stats_win, COLOR_PAIR(COLOR_BLACK));
}
wprintw(stats_win, "]\n");
/* Progress bar outstanding sessions */
wprintw(stats_win, " Outstanding %10u [", g_ctx->sessions_outstanding);
wattron(stats_win, COLOR_PAIR(COLOR_BLACK));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->config.sessions_max_outstanding, g_ctx->sessions_outstanding));
wattroff(stats_win, COLOR_PAIR(COLOR_BLACK));
wprintw(stats_win, "]\n");
/* Progress bar terminated sessions */
wprintw(stats_win, " Terminated %10u [", g_ctx->sessions_terminated);
wattron(stats_win, COLOR_PAIR(COLOR_RED));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->sessions, g_ctx->sessions_terminated));
wattroff(stats_win, COLOR_PAIR(COLOR_RED));
wprintw(stats_win, "]\n");
/* DHCPv4 */
if(g_ctx->dhcp_requested || g_ctx->dhcp_established_max) {
snprintf(strsp, STRING_SP_SIZE, "%u/%u", g_ctx->dhcp_established, g_ctx->dhcp_requested);
wprintw(stats_win, " DHCPv4 %15s [", strsp);
if(g_ctx->dhcp_requested == g_ctx->dhcp_established) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->dhcp_requested, g_ctx->dhcp_established));
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wattron(stats_win, COLOR_PAIR(COLOR_BLACK));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->dhcp_requested, g_ctx->dhcp_established));
wattroff(stats_win, COLOR_PAIR(COLOR_BLACK));
}
wprintw(stats_win, "]\n");
}
/* DHCPv6 */
if(g_ctx->dhcpv6_requested || g_ctx->dhcpv6_established_max) {
snprintf(strsp, STRING_SP_SIZE, "%u/%u", g_ctx->dhcpv6_established, g_ctx->dhcpv6_requested);
wprintw(stats_win, " DHCPv6 %15s [", strsp);
if(g_ctx->dhcpv6_requested == g_ctx->dhcpv6_established) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->dhcpv6_requested, g_ctx->dhcpv6_established));
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wattron(stats_win, COLOR_PAIR(COLOR_BLACK));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->dhcpv6_requested, g_ctx->dhcpv6_established));
wattroff(stats_win, COLOR_PAIR(COLOR_BLACK));
}
wprintw(stats_win, "]\n");
}
/* Session stats */
wprintw(stats_win, " Setup Time %10u ms\n", g_ctx->stats.setup_time);
wprintw(stats_win, " Setup Rate %10.02lf CPS (MIN: %0.02lf AVG: %0.02lf MAX: %0.02lf)\n",
g_ctx->stats.cps, g_ctx->stats.cps_min, g_ctx->stats.cps_avg, g_ctx->stats.cps_max);
wprintw(stats_win, " Flapped %10u\n", g_ctx->sessions_flapped);
}
if(g_network_if) {
VISIBLE((dict_count(g_ctx->li_flow_dict))) {
wprintw(stats_win, "\nLI Statistics\n");
wprintw(stats_win, " Flows %10lu\n", dict_count(g_ctx->li_flow_dict));
wprintw(stats_win, " RX Packets %10lu (%7lu PPS)\n",
g_network_if->stats.li_rx, g_network_if->stats.rate_li_rx.avg);
}
VISIBLE((g_ctx->config.l2tp_server)) {
wprintw(stats_win, "\nL2TP LNS Statistics\n");
wprintw(stats_win, " Tunnels %10u\n", g_ctx->l2tp_tunnels);
wprintw(stats_win, " Established %10u\n", g_ctx->l2tp_tunnels_established);
wprintw(stats_win, " Sessions %10u\n", g_ctx->l2tp_sessions);
wprintw(stats_win, " Packets:\n");
wprintw(stats_win, " TX Control %10u Retries: %u\n",
g_network_if->stats.l2tp_control_tx, g_network_if->stats.l2tp_control_retry);
wprintw(stats_win, " RX Control %10u Duplicate: %u Out-of-Order: %u\n",
g_network_if->stats.l2tp_control_rx,
g_network_if->stats.l2tp_control_rx_dup,
g_network_if->stats.l2tp_control_rx_ooo);
wprintw(stats_win, " TX Data %10lu (%7lu PPS)\n",
g_network_if->stats.l2tp_data_tx, g_network_if->stats.rate_l2tp_data_tx.avg);
wprintw(stats_win, " RX Data %10lu (%7lu PPS)\n",
g_network_if->stats.l2tp_data_rx, g_network_if->stats.rate_l2tp_data_rx.avg);
}
}
VISIBLE((g_ctx->stats.session_traffic_flows || g_ctx->stats.stream_traffic_flows)) {
wprintw(stats_win, "\nTraffic Flows Verified\n");
if(g_ctx->stats.session_traffic_flows) {
snprintf(strsp, STRING_SP_SIZE, "%u/%u", g_ctx->stats.session_traffic_flows_verified, g_ctx->stats.session_traffic_flows);
wprintw(stats_win, " Session %14s [", strsp);
if(g_ctx->stats.session_traffic_flows == g_ctx->stats.session_traffic_flows_verified) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->stats.session_traffic_flows, g_ctx->stats.session_traffic_flows_verified));
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wattron(stats_win, COLOR_PAIR(COLOR_BLACK));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->stats.session_traffic_flows, g_ctx->stats.session_traffic_flows_verified));
wattroff(stats_win, COLOR_PAIR(COLOR_BLACK));
}
wprintw(stats_win, "]\n");
}
if(g_ctx->stats.stream_traffic_flows) {
snprintf(strsp, STRING_SP_SIZE, "%u/%u", g_ctx->stats.stream_traffic_flows_verified, g_ctx->stats.stream_traffic_flows);
wprintw(stats_win, " Stream %15s [", strsp);
if(g_ctx->stats.stream_traffic_flows == g_ctx->stats.stream_traffic_flows_verified) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->stats.stream_traffic_flows, g_ctx->stats.stream_traffic_flows_verified));
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wattron(stats_win, COLOR_PAIR(COLOR_BLACK));
wprintw(stats_win, "%s", bbl_interactive_format_progress(g_ctx->stats.stream_traffic_flows, g_ctx->stats.stream_traffic_flows_verified));
wattroff(stats_win, COLOR_PAIR(COLOR_BLACK));
}
wprintw(stats_win, "]\n");
}
}
VISIBLE(g_network_if) {
wprintw(stats_win, "\nNetwork Interface (");
CIRCLEQ_FOREACH(network_if, &g_ctx->network_interface_qhead, network_interface_qnode) {
if(network_if == g_network_if) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, " %s", network_if->name);
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wprintw(stats_win, " %s", network_if->name);
}
}
wprintw(stats_win, " )\n TX Packets %10lu |%7lu PPS %10lu Kbps %2.3f Gbps\n",
g_network_if->stats.packets_tx, g_network_if->stats.rate_packets_tx.avg,
g_network_if->stats.rate_bytes_tx.avg * 8 / 1000,
g_network_if->stats.rate_bytes_tx.avg * 8.0 / 1000000000.0);
wprintw(stats_win, " RX Packets %10lu |%7lu PPS %10lu Kbps %2.3f Gbps\n",
g_network_if->stats.packets_rx, g_network_if->stats.rate_packets_rx.avg,
g_network_if->stats.rate_bytes_rx.avg * 8 / 1000,
g_network_if->stats.rate_bytes_rx.avg * 8.0 / 1000000000.0);
if(g_ctx->stats.stream_traffic_flows) {
if(g_network_if->stats.stream_loss) {
d = g_network_if->stats.stream_loss;
d = (d / (d+g_network_if->stats.stream_rx)) * 100.0;
} else {
d = 0;
}
wprintw(stats_win, " TX Stream Packets %10lu |%7lu PPS\n",
g_network_if->stats.stream_tx, g_network_if->stats.rate_stream_tx.avg);
wprintw(stats_win, " RX Stream Packets %10lu |%7lu PPS %10lu Loss (%2.3f%%)\n",
g_network_if->stats.stream_rx, g_network_if->stats.rate_stream_rx.avg,
g_network_if->stats.stream_loss, d);
}
if(g_ctx->stats.session_traffic_flows) {
wprintw(stats_win, " TX Session Packets IPv4 %10lu |%7lu PPS\n",
g_network_if->stats.session_ipv4_tx, g_network_if->stats.rate_session_ipv4_tx.avg);
wprintw(stats_win, " RX Session Packets IPv4 %10lu |%7lu PPS %10lu Loss\n",
g_network_if->stats.session_ipv4_rx, g_network_if->stats.rate_session_ipv4_rx.avg,
g_network_if->stats.session_ipv4_loss);
wprintw(stats_win, " TX Session Packets IPv6 %10lu |%7lu PPS\n",
g_network_if->stats.session_ipv6_tx, g_network_if->stats.rate_session_ipv6_tx.avg);
wprintw(stats_win, " RX Session Packets IPv6 %10lu |%7lu PPS %10lu Loss\n",
g_network_if->stats.session_ipv6_rx, g_network_if->stats.rate_session_ipv6_rx.avg,
g_network_if->stats.session_ipv6_loss);
wprintw(stats_win, " TX Session Packets IPv6PD %10lu |%7lu PPS\n",
g_network_if->stats.session_ipv6pd_tx, g_network_if->stats.rate_session_ipv6pd_tx.avg);
wprintw(stats_win, " RX Session Packets IPv6PD %10lu |%7lu PPS %10lu Loss\n",
g_network_if->stats.session_ipv6pd_rx, g_network_if->stats.rate_session_ipv6pd_rx.avg,
g_network_if->stats.session_ipv6pd_loss);
}
wprintw(stats_win, " TX Multicast Packets %10lu |%7lu PPS\n",
g_network_if->stats.mc_tx, g_network_if->stats.rate_mc_tx.avg);
}
VISIBLE(g_a10nsp_if) {
wprintw(stats_win, "\nA10NSP Interface (");
CIRCLEQ_FOREACH(a10nsp_if, &g_ctx->a10nsp_interface_qhead, a10nsp_interface_qnode) {
if(a10nsp_if == g_a10nsp_if) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, " %s", a10nsp_if->name);
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wprintw(stats_win, " %s", a10nsp_if->name);
}
}
wprintw(stats_win, " )\n TX Packets %10lu |%7lu PPS %10lu Kbps %2.3f Gbps\n",
g_a10nsp_if->stats.packets_tx, g_a10nsp_if->stats.rate_packets_tx.avg,
g_a10nsp_if->stats.rate_bytes_tx.avg * 8 / 1000,
g_a10nsp_if->stats.rate_bytes_tx.avg * 8.0 / 1000000000.0);
wprintw(stats_win, " RX Packets %10lu |%7lu PPS %10lu Kbps %2.3f Gbps\n",
g_a10nsp_if->stats.packets_rx, g_a10nsp_if->stats.rate_packets_rx.avg,
g_a10nsp_if->stats.rate_bytes_rx.avg * 8 / 1000,
g_a10nsp_if->stats.rate_bytes_rx.avg * 8.0 / 1000000000.0);
if(g_ctx->stats.stream_traffic_flows) {
if(g_a10nsp_if->stats.stream_loss) {
d = g_a10nsp_if->stats.stream_loss;
d = (d / (d+g_a10nsp_if->stats.stream_rx)) * 100.0;
} else {
d = 0;
}
wprintw(stats_win, " TX Stream Packets %10lu |%7lu PPS\n",
g_a10nsp_if->stats.stream_tx, g_a10nsp_if->stats.rate_stream_tx.avg);
wprintw(stats_win, " RX Stream Packets %10lu |%7lu PPS %10lu Loss (%2.3f%%)\n",
g_a10nsp_if->stats.stream_rx, g_a10nsp_if->stats.rate_stream_rx.avg,
g_a10nsp_if->stats.stream_loss, d);
}
if(g_ctx->stats.session_traffic_flows) {
wprintw(stats_win, " TX Session Packets IPv4 %10lu |%7lu PPS\n",
g_a10nsp_if->stats.session_ipv4_tx, g_a10nsp_if->stats.rate_session_ipv4_tx.avg);
wprintw(stats_win, " RX Session Packets IPv4 %10lu |%7lu PPS %10lu Loss\n",
g_a10nsp_if->stats.session_ipv4_rx, g_a10nsp_if->stats.rate_session_ipv4_rx.avg,
g_a10nsp_if->stats.session_ipv4_loss);
wprintw(stats_win, " TX Session Packets IPv6 %10lu |%7lu PPS\n",
g_a10nsp_if->stats.session_ipv6_tx, g_a10nsp_if->stats.rate_session_ipv6_tx.avg);
wprintw(stats_win, " RX Session Packets IPv6 %10lu |%7lu PPS %10lu Loss\n",
g_a10nsp_if->stats.session_ipv6_rx, g_a10nsp_if->stats.rate_session_ipv6_rx.avg,
g_a10nsp_if->stats.session_ipv6_loss);
wprintw(stats_win, " TX Session Packets IPv6PD %10lu |%7lu PPS\n",
g_a10nsp_if->stats.session_ipv6pd_tx, g_a10nsp_if->stats.rate_session_ipv6pd_tx.avg);
wprintw(stats_win, " RX Session Packets IPv6PD %10lu |%7lu PPS %10lu Loss\n",
g_a10nsp_if->stats.session_ipv6pd_rx, g_a10nsp_if->stats.rate_session_ipv6pd_rx.avg,
g_a10nsp_if->stats.session_ipv6pd_loss);
}
}
VISIBLE(g_access_if) {
wprintw(stats_win, "\nAccess Interface (");
CIRCLEQ_FOREACH(access_if, &g_ctx->access_interface_qhead, access_interface_qnode) {
if(access_if == g_access_if) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, " %s", access_if->name);
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wprintw(stats_win, " %s", access_if->name);
}
}
wprintw(stats_win, " )\n TX Packets %10lu |%7lu PPS %10lu Kbps %2.3f Gbps\n",
g_access_if->stats.packets_tx, g_access_if->stats.rate_packets_tx.avg,
g_access_if->stats.rate_bytes_tx.avg * 8 / 1000,
g_access_if->stats.rate_bytes_tx.avg * 8.0 / 1000000000.0);
wprintw(stats_win, " RX Packets %10lu |%7lu PPS %10lu Kbps %2.3f Gbps\n",
g_access_if->stats.packets_rx, g_access_if->stats.rate_packets_rx.avg,
g_access_if->stats.rate_bytes_rx.avg * 8 / 1000,
g_access_if->stats.rate_bytes_rx.avg * 8.0 / 1000000000.0);
if(g_ctx->stats.stream_traffic_flows) {
if(g_access_if->stats.stream_loss) {
d = g_access_if->stats.stream_loss;
d = (d / (d+g_access_if->stats.stream_rx)) * 100.0;
} else {
d = 0;
}
wprintw(stats_win, " TX Stream Packets %10lu |%7lu PPS\n",
g_access_if->stats.stream_tx, g_access_if->stats.rate_stream_tx.avg);
wprintw(stats_win, " RX Stream Packets %10lu |%7lu PPS %10lu Loss (%2.3f%%)\n",
g_access_if->stats.stream_rx, g_access_if->stats.rate_stream_rx.avg,
g_access_if->stats.stream_loss, d);
}
if(g_ctx->stats.session_traffic_flows) {
wprintw(stats_win, " TX Session Packets IPv4 %10lu |%7lu PPS\n",
g_access_if->stats.session_ipv4_tx, g_access_if->stats.rate_session_ipv4_tx.avg);
wprintw(stats_win, " RX Session Packets IPv4 %10lu |%7lu PPS %10lu Loss %lu Wrong Session\n",
g_access_if->stats.session_ipv4_rx, g_access_if->stats.rate_session_ipv4_rx.avg,
g_access_if->stats.session_ipv4_loss, g_access_if->stats.session_ipv4_wrong_session);
wprintw(stats_win, " TX Session Packets IPv6 %10lu |%7lu PPS\n",
g_access_if->stats.session_ipv6_tx, g_access_if->stats.rate_session_ipv6_tx.avg);
wprintw(stats_win, " RX Session Packets IPv6 %10lu |%7lu PPS %10lu Loss %lu Wrong Session\n",
g_access_if->stats.session_ipv6_rx, g_access_if->stats.rate_session_ipv6_rx.avg,
g_access_if->stats.session_ipv6_loss, g_access_if->stats.session_ipv6_wrong_session);
wprintw(stats_win, " TX Session Packets IPv6PD %10lu |%7lu PPS\n",
g_access_if->stats.session_ipv6pd_tx, g_access_if->stats.rate_session_ipv6pd_tx.avg);
wprintw(stats_win, " RX Session Packets IPv6PD %10lu |%7lu PPS %10lu Loss %lu Wrong Session\n",
g_access_if->stats.session_ipv6pd_rx, g_access_if->stats.rate_session_ipv6pd_rx.avg,
g_access_if->stats.session_ipv6pd_loss, g_access_if->stats.session_ipv6pd_wrong_session);
}
wprintw(stats_win, " RX Multicast Packets %10lu |%7lu PPS %10lu Loss\n",
g_access_if->stats.mc_rx, g_access_if->stats.rate_mc_rx.avg,
g_access_if->stats.mc_loss);
}
} else if(g_view_selected == UI_VIEW_ACCESS_IF_STATS) {
if(g_access_if) {
wprintw(stats_win, "\nAccess Interface Protocol Stats (");
CIRCLEQ_FOREACH(access_if, &g_ctx->access_interface_qhead, access_interface_qnode) {
if(access_if == g_access_if) {
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, " %s", access_if->name);
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
} else {
wprintw(stats_win, " %s", access_if->name);
}
}
wprintw(stats_win, " )\n");
wprintw(stats_win, "\nPacket Stats\n");
wprintw(stats_win, " ARP TX: %10u RX: %10u\n", g_access_if->stats.arp_tx, g_access_if->stats.arp_rx);
wprintw(stats_win, " PADI TX: %10u RX: %10u\n", g_access_if->stats.padi_tx, 0);
wprintw(stats_win, " PADO TX: %10u RX: %10u\n", 0, g_access_if->stats.pado_rx);
wprintw(stats_win, " PADR TX: %10u RX: %10u\n", g_access_if->stats.padr_tx, 0);
wprintw(stats_win, " PADS TX: %10u RX: %10u\n", 0, g_access_if->stats.pads_rx);
wprintw(stats_win, " PADT TX: %10u RX: %10u\n", g_access_if->stats.padt_tx, g_access_if->stats.padt_rx);
wprintw(stats_win, " LCP TX: %10u RX: %10u\n", g_access_if->stats.lcp_tx, g_access_if->stats.lcp_rx);
wprintw(stats_win, " PAP TX: %10u RX: %10u\n", g_access_if->stats.pap_tx, g_access_if->stats.pap_rx);
wprintw(stats_win, " CHAP TX: %10u RX: %10u\n", g_access_if->stats.chap_tx, g_access_if->stats.chap_rx);
wprintw(stats_win, " IPCP TX: %10u RX: %10u\n", g_access_if->stats.ipcp_tx, g_access_if->stats.ipcp_rx);
wprintw(stats_win, " IP6CP TX: %10u RX: %10u\n", g_access_if->stats.ip6cp_tx, g_access_if->stats.ip6cp_rx);
wprintw(stats_win, " IGMP TX: %10u RX: %10u\n", g_access_if->stats.igmp_tx, g_access_if->stats.igmp_rx);
wprintw(stats_win, " ICMP TX: %10u RX: %10u\n", g_access_if->stats.icmp_tx, g_access_if->stats.icmp_rx);
wprintw(stats_win, " DHCP TX: %10u RX: %10u\n", g_access_if->stats.dhcp_tx, g_access_if->stats.dhcp_rx);
wprintw(stats_win, " DHCPv6 TX: %10u RX: %10u\n", g_access_if->stats.dhcpv6_tx, g_access_if->stats.dhcpv6_rx);
wprintw(stats_win, " ICMPv6 TX: %10u RX: %10u\n", g_access_if->stats.icmpv6_tx, g_access_if->stats.icmpv6_rx);
wprintw(stats_win, "\nTimeout Stats\n");
wprintw(stats_win, " LCP Echo Request: %10u\n", g_access_if->stats.lcp_echo_timeout);
wprintw(stats_win, " LCP Request: %10u\n", g_access_if->stats.lcp_timeout);
wprintw(stats_win, " IPCP Request: %10u\n", g_access_if->stats.ipcp_timeout);
wprintw(stats_win, " IP6CP Request: %10u\n", g_access_if->stats.ip6cp_timeout);
wprintw(stats_win, " PAP: %10u\n", g_access_if->stats.pap_timeout);
wprintw(stats_win, " CHAP: %10u\n", g_access_if->stats.chap_timeout);
wprintw(stats_win, " DHCP Request: %10u\n", g_access_if->stats.dhcp_timeout);
wprintw(stats_win, " DHCPv6 Request: %10u\n", g_access_if->stats.dhcpv6_timeout);
wprintw(stats_win, " ICMPv6 RS: %10u\n", g_access_if->stats.icmpv6_rs_timeout);
} else {
wprintw(stats_win, "\nAccess Interface Protocol Stats");
}
} else if(g_view_selected == UI_VIEW_SESSION) {
wprintw(stats_win, "\nSession and Streams ( Session-Id: ");
wattron(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, "%u", g_session_selected);
wattroff(stats_win, COLOR_PAIR(COLOR_GREEN));
wprintw(stats_win, " )\n");
session = bbl_session_get(g_session_selected);
if(session) {
wprintw(stats_win, "\n State: %s \n", session_state_string(session->session_state));
if(session->username) {
wprintw(stats_win, " Username: %s \n", session->username);
}
if(session->agent_remote_id) {
wprintw(stats_win, " ARI: %s \n", session->agent_remote_id);
}
if(session->agent_remote_id) {
wprintw(stats_win, " ACI: %s \n", session->agent_circuit_id);
}
if(session->connections_status_message || session->reply_message) {
wprintw(stats_win, "\n");
if(session->reply_message) {
wprintw(stats_win, " Reply-Message: %s \n", session->reply_message);
}
if(session->connections_status_message) {
wprintw(stats_win, " Connection-Status-Message: %s \n", session->connections_status_message);
}
}
wprintw(stats_win, "\n Access Client Interface\n");
wprintw(stats_win, " TX Packets %10lu | %7lu PPS | %10lu Kbps\n",
session->stats.packets_tx, session->stats.rate_packets_tx.avg,
session->stats.rate_bytes_tx.avg * 8 / 1000);
wprintw(stats_win, " RX Packets %10lu | %7lu PPS | %10lu Kbps\n",
session->stats.packets_rx, session->stats.rate_packets_rx.avg,
session->stats.rate_bytes_rx.avg * 8 / 1000);
if(session->streams.head) {
wprintw(stats_win, "\n Stream | Direction | TX PPS | TX Kbps | RX PPS | RX Kbps | Loss\n");
wprintw(stats_win, " -------------------------------------------------------------------------------------\n");
uint64_t tx_kbps;
uint64_t rx_kbps;
uint64_t stream_sum_up_tx_pps = 0;
uint64_t stream_sum_up_tx_kbps = 0;
uint64_t stream_sum_up_rx_pps = 0;
uint64_t stream_sum_up_rx_kbps = 0;
uint64_t stream_sum_up_loss = 0;
uint64_t stream_sum_down_tx_pps = 0;
uint64_t stream_sum_down_rx_pps = 0;
uint64_t stream_sum_down_tx_kbps = 0;
uint64_t stream_sum_down_rx_kbps = 0;
uint64_t stream_sum_down_loss = 0;
bbl_stream_s *stream = session->streams.head;
i = 0;
while(stream) {
tx_kbps = stream->rate_packets_tx.avg * stream->tx_len * 8 / 1000;
if(stream->rate_packets_tx.avg && tx_kbps == 0) {
tx_kbps = 1;
}
rx_kbps = stream->rate_packets_rx.avg * stream->rx_len * 8 / 1000;
if(stream->rate_packets_rx.avg && rx_kbps == 0) {
rx_kbps = 1;
}
if(i >= stats_win_postion && i < 16+stats_win_postion) {
wprintw(stats_win, " %-16.16s | %-9.9s | %7lu | %10lu | %7lu | %10lu | %8lu\n", stream->config->name,
stream->direction == BBL_DIRECTION_UP ? "up" : "down",
stream->rate_packets_tx.avg, tx_kbps, stream->rate_packets_rx.avg, rx_kbps, (stream->rx_loss - stream->reset_loss));
} else if(i == 16+stats_win_postion) {
wprintw(stats_win, " ...\n");
}
i++;
if(stream->direction == BBL_DIRECTION_UP) {
stream_sum_up_tx_pps += stream->rate_packets_tx.avg;
stream_sum_up_tx_kbps += tx_kbps;
stream_sum_up_rx_pps += stream->rate_packets_rx.avg;
stream_sum_up_rx_kbps += rx_kbps;
stream_sum_up_loss += (stream->rx_loss - stream->reset_loss);
} else {
stream_sum_down_tx_pps += stream->rate_packets_tx.avg;
stream_sum_down_tx_kbps += tx_kbps;
stream_sum_down_rx_pps += stream->rate_packets_rx.avg;
stream_sum_down_rx_kbps += rx_kbps;
stream_sum_down_loss += (stream->rx_loss - stream->reset_loss);
}
stream = stream->session_next;
}
wprintw(stats_win, " =====================================================================================\n");
wprintw(stats_win, " SUM | up | %7lu | %10lu | %7lu | %10lu | %8lu\n",
stream_sum_up_tx_pps, stream_sum_up_tx_kbps, stream_sum_up_rx_pps, stream_sum_up_rx_kbps, stream_sum_up_loss);
wprintw(stats_win, " | down | %7lu | %10lu | %7lu | %10lu | %8lu\n",
stream_sum_down_tx_pps, stream_sum_down_tx_kbps, stream_sum_down_rx_pps, stream_sum_down_rx_kbps, stream_sum_down_loss);
}
}
}
wrefresh(stats_win);
}
/*
* Curses init.
*/
void
bbl_interactive_init()
{
initscr();
cbreak();
noecho();
keypad(stdscr, TRUE);
/* Stats window */
stats_win = newwin(LINES, STATS_WIN_SIZE, 0, 0);
stats_win_postion = 0;
/* Log window */
log_win = newwin(LINES, COLS-STATS_WIN_SIZE, 0, STATS_WIN_SIZE);
scrollok(log_win, TRUE);
start_color();
init_pair(1, COLOR_RED, COLOR_BLACK);
init_pair(2, COLOR_GREEN, COLOR_BLACK);
init_pair(3, COLOR_BLACK, COLOR_CYAN);
init_pair(4, COLOR_BLACK, COLOR_BLUE);
curs_set(0); /* cursor off */
refresh();
timeout(0);
bbl_interactive_init_window();
wrefresh(stats_win);
bbl_interactive_log_buf_free();
g_interactive = true;
}
void
bbl_interactive_start()
{
if(!CIRCLEQ_EMPTY(&g_ctx->access_interface_qhead)) {
g_access_if = CIRCLEQ_FIRST(&g_ctx->access_interface_qhead);
}
if(!CIRCLEQ_EMPTY(&g_ctx->network_interface_qhead)) {
g_network_if = CIRCLEQ_FIRST(&g_ctx->network_interface_qhead);
}
if(!CIRCLEQ_EMPTY(&g_ctx->a10nsp_interface_qhead)) {
g_a10nsp_if = CIRCLEQ_FIRST(&g_ctx->a10nsp_interface_qhead);
}
timer_add_periodic(&g_ctx->timer_root, &g_ctx->stats_timer, "Window Timer",
0, 500 * MSEC, g_ctx, &bbl_interactive_window_job);
timer_add_periodic(&g_ctx->timer_root, &g_ctx->keyboard_timer, "Keyboard Reader",
0, 100 * MSEC, g_ctx, &bbl_interactive_read_key_job);
}
Reference in New Issue View Git Blame Copy Permalink