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

extend commands #89

Browse Source 
+ extend session-counters
+ extend interfaces
This commit is contained in:
Christian Giese
2022-06-28 14:24:27 +00:00
parent 37297d323b
commit 092d91b2aa
6 changed files with 164 additions and 122 deletions
Download Patch File Download Diff File Expand all files Collapse all files
code/bngblaster/src/bbl_ctrl.c
+135 -93
View File
@@ -32,7 +32,7 @@ extern volatile bool g_teardown;
extern volatile bool g_teardown_request;
extern volatile bool g_monkey;
typedef ssize_t callback_function(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments);
typedef int callback_function(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments);
static char *
string_or_na(char *string) {
@@ -43,9 +43,9 @@ string_or_na(char *string) {
}
}
ssize_t
int
bbl_ctrl_status(int fd, const char *status, uint32_t code, const char *message) {
ssize_t result = 0;
int result = 0;
json_t *root = json_pack("{sssiss*}", "status", status, "code", code, "message", message);
if(root) {
result = json_dumpfd(root, fd, 0);
@@ -54,21 +54,21 @@ bbl_ctrl_status(int fd, const char *status, uint32_t code, const char *message)
return result;
}
ssize_t
int
bbl_ctrl_multicast_traffic_start(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ctx->multicast_traffic = true;
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bbl_ctrl_multicast_traffic_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ctx->multicast_traffic = false;
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bbl_ctrl_session_traffic_stats(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root = json_pack("{ss si s{si si}}",
"status", "ok",
"code", 200,
@@ -82,7 +82,7 @@ bbl_ctrl_session_traffic_stats(int fd, bbl_ctx_s *ctx, uint32_t session_id __att
return result;
}
ssize_t
int
bbl_ctrl_session_traffic(int fd, bbl_ctx_s *ctx, uint32_t session_id, bool status) {
bbl_session_s *session;
uint32_t i;
@@ -106,17 +106,17 @@ bbl_ctrl_session_traffic(int fd, bbl_ctx_s *ctx, uint32_t session_id, bool statu
}
}
ssize_t
int
bbl_ctrl_session_traffic_start(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_session_traffic(fd, ctx, session_id, true);
}
ssize_t
int
bbl_ctrl_session_traffic_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_session_traffic(fd, ctx, session_id, false);
}
ssize_t
int
bbl_ctrl_igmp_join(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments) {
bbl_session_s *session;
const char *s;
@@ -195,7 +195,7 @@ bbl_ctrl_igmp_join(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* argument
}
}
ssize_t
int
bbl_ctrl_igmp_join_iter(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
bbl_session_s *session;
@@ -294,8 +294,7 @@ bbl_ctrl_igmp_join_iter(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute_
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bbl_ctrl_igmp_leave(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments) {
bbl_session_s *session;
@@ -352,7 +351,7 @@ bbl_ctrl_igmp_leave(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* argumen
}
}
ssize_t
int
bbl_ctrl_igmp_leave_all(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
bbl_session_s *session;
@@ -386,9 +385,9 @@ bbl_ctrl_igmp_leave_all(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute_
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bbl_ctrl_igmp_info(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root, *groups, *record, *sources;
bbl_session_s *session = NULL;
bbl_igmp_group_s *group = NULL;
@@ -479,21 +478,21 @@ bbl_ctrl_igmp_info(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* argument
}
}
ssize_t
int
bbl_ctrl_zapping_start(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ctx->zapping = true;
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bbl_ctrl_zapping_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ctx->zapping = false;
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bbl_ctrl_zapping_stats(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root;
bbl_stats_t stats = {0};
@@ -527,17 +526,37 @@ bbl_ctrl_zapping_stats(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__
return result;
}
ssize_t
int
bbl_ctrl_session_counters(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
json_t *root = json_pack("{ss si s{si si si si}}",
int result = 0;
json_t *root = json_pack("{ss si s{si si si si si si si si si si si si si si sf sf sf sf si si si si}}",
"status", "ok",
"code", 200,
"session-counters",
"session-counters",
"sessions", ctx->config.sessions,
"sessions-established", ctx->sessions_established_max,
"sessions-pppoe", ctx->sessions_pppoe,
"sessions-ipoe", ctx->sessions_ipoe,
"sessions-established", ctx->sessions_established,
"sessions-established-max", ctx->sessions_established_max,
"sessions-terminated", ctx->sessions_terminated,
"sessions-flapped", ctx->sessions_flapped,
"dhcpv6-sessions-established", ctx->dhcpv6_established_max);
"dhcp-sessions", ctx->dhcp_requested,
"dhcp-sessions-established", ctx->dhcp_established,
"dhcp-sessions-established-max", ctx->dhcp_established_max,
"dhcpv6-sessions", ctx->dhcpv6_requested,
"dhcpv6-sessions-established", ctx->dhcpv6_established,
"dhcpv6-sessions-established-max", ctx->dhcpv6_established_max,
"setup-time", ctx->stats.setup_time,
"setup-rate", ctx->stats.cps,
"setup-rate-min", ctx->stats.cps_min,
"setup-rate-avg", ctx->stats.cps_avg,
"setup-rate-max", ctx->stats.cps_max,
"session-traffic-flows", ctx->stats.session_traffic_flows,
"session-traffic-flows-verified", ctx->stats.session_traffic_flows_verified,
"stream-traffic-flows", ctx->stats.stream_traffic_flows,
"stream-traffic-flows-verified", ctx->stats.stream_traffic_flows_verified
);
if(root) {
result = json_dumpfd(root, fd, 0);
json_decref(root);
@@ -545,9 +564,9 @@ bbl_ctrl_session_counters(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribut
return result;
}
ssize_t
int
bbl_ctrl_session_info(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root;
json_t *session_json;
bbl_session_s *session;
@@ -582,7 +601,7 @@ bbl_ctrl_session_info(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* argum
}
}
ssize_t
int
bbl_ctrl_session_start(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
bbl_session_s *session;
@@ -619,24 +638,47 @@ bbl_ctrl_session_start(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* argu
}
static json_t *
bbl_ctrl_interfaces_json(bbl_interface_s *interace, const char *type) {
bbl_ctrl_interfaces_json(bbl_interface_s *interface, const char *type) {
return json_pack("{ss si ss si si si si si si si si}",
"name", interace->name,
"ifindex", interace->ifindex,
"name", interface->name,
"ifindex", interface->ifindex,
"type", type,
"tx-packets", interace->stats.packets_tx,
"tx-bytes", interace->stats.bytes_tx,
"tx-pps", interace->stats.rate_packets_tx.avg,
"tx-kbps", interace->stats.rate_bytes_tx.avg * 8 / 1000,
"rx-packets", interace->stats.packets_rx,
"rx-bytes", interace->stats.bytes_rx,
"rx-pps", interace->stats.rate_packets_rx.avg,
"rx-kbps", interace->stats.rate_bytes_rx.avg * 8 / 1000);
"tx-packets", interface->stats.packets_tx,
"tx-bytes", interface->stats.bytes_tx,
"tx-pps", interface->stats.rate_packets_tx.avg,
"tx-kbps", interface->stats.rate_bytes_tx.avg * 8 / 1000,
"rx-packets", interface->stats.packets_rx,
"rx-bytes", interface->stats.bytes_rx,
"rx-pps", interface->stats.rate_packets_rx.avg,
"rx-kbps", interface->stats.rate_bytes_rx.avg * 8 / 1000,
"tx-packets-multicast", interface->stats.mc_tx,
"tx-pps-multicast", interface->stats.rate_mc_tx.avg,
"tx-packets-session-ipv4", interface->stats.session_ipv4_tx,
"tx-pps-session-ipv4", interface->stats.rate_session_ipv4_tx.avg,
"rx-packets-session-ipv4", interface->stats.session_ipv4_rx,
"rx-pps-session-ipv4", interface->stats.rate_session_ipv4_rx.avg,
"loss-packets-session-ipv4", interface->stats.session_ipv4_loss,
"tx-packets-session-ipv6", interface->stats.session_ipv6_tx,
"tx-pps-session-ipv6", interface->stats.rate_session_ipv6_tx.avg,
"rx-packets-session-ipv6", interface->stats.session_ipv6_rx,
"rx-pps-session-ipv6", interface->stats.rate_session_ipv6_rx.avg,
"loss-packets-session-ipv6", interface->stats.session_ipv6_loss,
"tx-packets-session-ipv6pd", interface->stats.session_ipv6pd_tx,
"tx-pps-session-ipv6pd", interface->stats.rate_session_ipv6pd_tx.avg,
"rx-packets-session-ipv6pd", interface->stats.session_ipv6pd_rx,
"rx-pps-session-ipv6pd", interface->stats.rate_session_ipv6pd_rx.avg,
"loss-packets-session-ipv6pd", interface->stats.session_ipv6pd_loss,
"tx-packets-streams", interface->stats.stream_tx,
"tx-pps-streams", interface->stats.rate_stream_tx.avg,
"rx-packets-streams", interface->stats.stream_rx,
"rx-pps-streams", interface->stats.rate_stream_rx.avg,
"loss-packets-streams", interface->stats.stream_loss
);
}
ssize_t
int
bbl_ctrl_interfaces(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root, *interfaces, *interface;
int i;
@@ -667,7 +709,7 @@ bbl_ctrl_interfaces(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((u
return result;
}
ssize_t
int
bbl_ctrl_session_terminate(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments) {
bbl_session_s *session;
int reconnect_delay = 0;
@@ -694,7 +736,7 @@ bbl_ctrl_session_terminate(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t*
}
}
ssize_t
int
bbl_ctrl_session_ncp_open_close(int fd, bbl_ctx_s *ctx, uint32_t session_id, bool open, bool ipcp) {
bbl_session_s *session;
uint32_t i;
@@ -732,29 +774,29 @@ bbl_ctrl_session_ncp_open_close(int fd, bbl_ctx_s *ctx, uint32_t session_id, boo
}
}
ssize_t
int
bbl_ctrl_session_ipcp_open(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_session_ncp_open_close(fd, ctx, session_id, true, true);
}
ssize_t
int
bbl_ctrl_session_ipcp_close(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_session_ncp_open_close(fd, ctx, session_id, false, true);
}
ssize_t
int
bbl_ctrl_session_ip6cp_open(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_session_ncp_open_close(fd, ctx, session_id, true, false);
}
ssize_t
int
bbl_ctrl_session_ip6cp_close(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_session_ncp_open_close(fd, ctx, session_id, false, false);
}
ssize_t
int
bbl_ctrl_li_flows(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root, *flows, *flow;
bbl_li_flow_t *li_flow;
struct dict_itor *itor;
@@ -803,9 +845,9 @@ bbl_ctrl_li_flows(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unu
return result;
}
ssize_t
int
bbl_ctrl_l2tp_tunnels(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root, *tunnels, *tunnel;
bbl_l2tp_server_t *l2tp_server = ctx->config.l2tp_server;
@@ -886,9 +928,9 @@ l2tp_session_json(bbl_l2tp_session_t *l2tp_session) {
"data-ipv4-packets-tx", l2tp_session->stats.data_ipv4_tx);
}
ssize_t
int
bbl_ctrl_l2tp_sessions(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
ssize_t result = 0;
int result = 0;
json_t *root, *sessions;
bbl_l2tp_server_t *l2tp_server = ctx->config.l2tp_server;
@@ -957,7 +999,7 @@ bbl_ctrl_l2tp_sessions(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__
return result;
}
ssize_t
int
bbl_ctrl_l2tp_csurq(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
json_t *sessions, *number;
@@ -1004,7 +1046,7 @@ bbl_ctrl_l2tp_csurq(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((u
}
}
ssize_t
int
bbl_ctrl_l2tp_tunnel_terminate(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
bbl_l2tp_tunnel_t *l2tp_tunnel;
bbl_l2tp_session_t *l2tp_session;
@@ -1048,7 +1090,7 @@ bbl_ctrl_l2tp_tunnel_terminate(int fd, bbl_ctx_s *ctx, uint32_t session_id __att
}
}
ssize_t
int
bbl_ctrl_l2tp_session_terminate(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments) {
bbl_session_s *session;
bbl_l2tp_tunnel_t *l2tp_tunnel;
@@ -1116,9 +1158,9 @@ bbl_ctrl_l2tp_session_terminate(int fd, bbl_ctx_s *ctx, uint32_t session_id, jso
}
}
ssize_t
int
bbl_ctrl_session_streams(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root;
json_t *json_streams = NULL;
json_t *json_stream = NULL;
@@ -1171,7 +1213,7 @@ bbl_ctrl_session_streams(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* ar
}
}
static ssize_t
static int
bbl_ctrl_stream_traffic_start_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id, bool status) {
bbl_session_s *session;
uint32_t i;
@@ -1196,17 +1238,17 @@ bbl_ctrl_stream_traffic_start_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id,
}
}
ssize_t
int
bbl_ctrl_stream_traffic_start(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_stream_traffic_start_stop(fd, ctx, session_id, true);
}
ssize_t
int
bbl_ctrl_stream_traffic_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_stream_traffic_start_stop(fd, ctx, session_id, false);
}
ssize_t
int
bbl_ctrl_stream_reset(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
bbl_stream *stream;
struct dict_itor *itor;
@@ -1262,10 +1304,10 @@ bbl_ctrl_stream_reset(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__(
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bbl_ctrl_sessions_pending(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root, *json_session, *json_sessions;
bbl_session_s *session;
@@ -1303,7 +1345,7 @@ bbl_ctrl_sessions_pending(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribut
return result;
}
ssize_t
int
bbl_ctrl_cfm_cc_start_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id, bool status) {
bbl_session_s *session;
uint32_t i;
@@ -1327,17 +1369,17 @@ bbl_ctrl_cfm_cc_start_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id, bool sta
}
}
ssize_t
int
bbl_ctrl_cfm_cc_start(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_cfm_cc_start_stop(fd, ctx, session_id, true);
}
ssize_t
int
bbl_ctrl_cfm_cc_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_cfm_cc_start_stop(fd, ctx, session_id, false);
}
ssize_t
int
bbl_ctrl_cfm_cc_rdi(int fd, bbl_ctx_s *ctx, uint32_t session_id, bool status) {
bbl_session_s *session;
uint32_t i;
@@ -1361,19 +1403,19 @@ bbl_ctrl_cfm_cc_rdi(int fd, bbl_ctx_s *ctx, uint32_t session_id, bool status) {
}
}
ssize_t
int
bbl_ctrl_cfm_cc_rdi_on(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_cfm_cc_rdi(fd, ctx, session_id, true);
}
ssize_t
int
bbl_ctrl_cfm_cc_rdi_off(int fd, bbl_ctx_s *ctx, uint32_t session_id, json_t* arguments __attribute__((unused))) {
return bbl_ctrl_cfm_cc_rdi(fd, ctx, session_id, false);
}
ssize_t
int
bbl_ctrl_stream_stats(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root = json_pack("{ss si s{si si}}",
"status", "ok",
"code", 200,
@@ -1387,9 +1429,9 @@ bbl_ctrl_stream_stats(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__(
return result;
}
ssize_t
int
bbl_ctrl_stream_info(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
ssize_t result = 0;
int result = 0;
json_t *root;
json_t *json_stream = NULL;
@@ -1433,19 +1475,19 @@ bbl_ctrl_stream_info(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((
}
}
ssize_t
int
bbl_ctrl_traffic_start(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
enable_disable_traffic(ctx, true);
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bbl_ctrl_traffic_stop(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
enable_disable_traffic(ctx, false);
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bgp_ctrl_monkey_start(int fd, bbl_ctx_s *ctx __attribute__((unused)), uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
if(!g_monkey) {
LOG_NOARG(INFO, "Start monkey\n");
@@ -1454,7 +1496,7 @@ bgp_ctrl_monkey_start(int fd, bbl_ctx_s *ctx __attribute__((unused)), uint32_t s
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bgp_ctrl_monkey_stop(int fd, bbl_ctx_s *ctx __attribute__((unused)), uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
if(g_monkey) {
LOG_NOARG(INFO, "Stop monkey\n");
@@ -1471,10 +1513,6 @@ struct action {
struct action actions[] = {
{"interfaces", bbl_ctrl_interfaces},
{"terminate", bbl_ctrl_session_terminate},
{"ipcp-open", bbl_ctrl_session_ipcp_open},
{"ipcp-close", bbl_ctrl_session_ipcp_close},
{"ip6cp-open", bbl_ctrl_session_ip6cp_open},
{"ip6cp-close", bbl_ctrl_session_ip6cp_close},
{"session-counters", bbl_ctrl_session_counters},
{"session-info", bbl_ctrl_session_info},
{"session-start", bbl_ctrl_session_start},
@@ -1483,6 +1521,15 @@ struct action actions[] = {
{"session-traffic-start", bbl_ctrl_session_traffic_start},
{"session-traffic-disabled", bbl_ctrl_session_traffic_stop},
{"session-traffic-stop", bbl_ctrl_session_traffic_stop},
{"session-streams", bbl_ctrl_session_streams},
{"sessions-pending", bbl_ctrl_sessions_pending},
{"stream-traffic-enabled", bbl_ctrl_stream_traffic_start},
{"stream-traffic-start", bbl_ctrl_stream_traffic_start},
{"stream-traffic-disabled", bbl_ctrl_stream_traffic_stop},
{"stream-traffic-stop", bbl_ctrl_stream_traffic_stop},
{"stream-info", bbl_ctrl_stream_info},
{"stream-stats", bbl_ctrl_stream_stats},
{"stream-reset", bbl_ctrl_stream_reset},
{"multicast-traffic-start", bbl_ctrl_multicast_traffic_start},
{"multicast-traffic-stop", bbl_ctrl_multicast_traffic_stop},
{"igmp-join", bbl_ctrl_igmp_join},
@@ -1499,15 +1546,10 @@ struct action actions[] = {
{"l2tp-csurq", bbl_ctrl_l2tp_csurq},
{"l2tp-tunnel-terminate", bbl_ctrl_l2tp_tunnel_terminate},
{"l2tp-session-terminate", bbl_ctrl_l2tp_session_terminate},
{"session-streams", bbl_ctrl_session_streams},
{"stream-traffic-enabled", bbl_ctrl_stream_traffic_start},
{"stream-traffic-start", bbl_ctrl_stream_traffic_start},
{"stream-traffic-disabled", bbl_ctrl_stream_traffic_stop},
{"stream-traffic-stop", bbl_ctrl_stream_traffic_stop},
{"stream-info", bbl_ctrl_stream_info},
{"stream-stats", bbl_ctrl_stream_stats},
{"stream-reset", bbl_ctrl_stream_reset},
{"sessions-pending", bbl_ctrl_sessions_pending},
{"ipcp-open", bbl_ctrl_session_ipcp_open},
{"ipcp-close", bbl_ctrl_session_ipcp_close},
{"ip6cp-open", bbl_ctrl_session_ip6cp_open},
{"ip6cp-close", bbl_ctrl_session_ip6cp_close},
{"cfm-cc-start", bbl_ctrl_cfm_cc_start},
{"cfm-cc-stop", bbl_ctrl_cfm_cc_stop},
{"cfm-cc-rdi-on", bbl_ctrl_cfm_cc_rdi_on},
code/bngblaster/src/bbl_ctrl.h
+3 -3
View File
@@ -10,13 +10,13 @@
#ifndef __BBL_CTRL_H__
#define __BBL_CTRL_H__
ssize_t
int
bbl_ctrl_status(int fd, const char *status, uint32_t code, const char *message);
bool
bbl_ctrl_socket_open (bbl_ctx_s *ctx);
bbl_ctrl_socket_open(bbl_ctx_s *ctx);
bool
bbl_ctrl_socket_close (bbl_ctx_s *ctx);
bbl_ctrl_socket_close(bbl_ctx_s *ctx);
#endif
code/bngblaster/src/bgp/bgp_ctrl.c
+9 -9
View File
@@ -74,9 +74,9 @@ bgp_ctrl_session_json(bgp_session_t *session) {
return root;
}
ssize_t
int
bgp_ctrl_sessions(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
ssize_t result = 0;
int result = 0;
json_t *root, *sessions, *session;
bgp_session_t *bgp_session = ctx->bgp_sessions;
@@ -129,15 +129,15 @@ bgp_ctrl_sessions(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unu
return result;
}
ssize_t
int
bgp_ctrl_teardown(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
bgp_teardown(ctx);
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
bgp_ctrl_raw_update(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
ssize_t result = 0;
int result = 0;
json_t *root;
bgp_session_t *bgp_session = ctx->bgp_sessions;
@@ -217,9 +217,9 @@ bgp_ctrl_raw_update(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((u
return result;
}
ssize_t
int
bgp_ctrl_raw_update_list(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
bgp_raw_update_t *raw_update = ctx->bgp_raw_updates;
json_t *root, *updates, *update;
@@ -249,9 +249,9 @@ bgp_ctrl_raw_update_list(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute
return result;
}
ssize_t
int
bgp_ctrl_disconnect(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
ssize_t result = 0;
int result = 0;
json_t *root;
bgp_session_t *bgp_session = ctx->bgp_sessions;
code/bngblaster/src/bgp/bgp_ctrl.h
+5 -5
View File
@@ -9,19 +9,19 @@
#ifndef __BBL_BGP_CTRL_H__
#define __BBL_BGP_CTRL_H__
ssize_t
int
bgp_ctrl_sessions(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused)));
ssize_t
int
bgp_ctrl_teardown(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused)));
ssize_t
int
bgp_ctrl_raw_update(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments);
ssize_t
int
bgp_ctrl_raw_update_list(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused)));
ssize_t
int
bgp_ctrl_disconnect(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments);
#endif
code/bngblaster/src/isis/isis_ctrl.c
+7 -7
View File
@@ -62,9 +62,9 @@ isis_ctrl_adjacency_p2p(isis_adjacency_p2p_t *adjacency) {
return root;
}
ssize_t
int
isis_ctrl_adjacencies(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
ssize_t result = 0;
int result = 0;
json_t *root, *adjacencies, *adjacency;
adjacencies = json_array();
@@ -153,10 +153,10 @@ isis_ctrl_database_entries(hb_tree *lsdb) {
return database;
}
ssize_t
int
isis_ctrl_database(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
ssize_t result = 0;
int result = 0;
json_t *root = NULL;
json_t *database = NULL;
isis_instance_t *instance = NULL;
@@ -211,7 +211,7 @@ isis_ctrl_database(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((un
}
}
ssize_t
int
isis_ctrl_load_mrt(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
char *file_path;
int instance_id = 0;
@@ -245,7 +245,7 @@ isis_ctrl_load_mrt(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((un
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
isis_ctrl_lsp_update(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments) {
protocol_error_t result;
@@ -312,7 +312,7 @@ isis_ctrl_lsp_update(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((
return bbl_ctrl_status(fd, "ok", 200, NULL);
}
ssize_t
int
isis_ctrl_teardown(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused))) {
isis_teardown(ctx);
return bbl_ctrl_status(fd, "ok", 200, NULL);
code/bngblaster/src/isis/isis_ctrl.h
+5 -5
View File
@@ -9,19 +9,19 @@
#ifndef __BBL_ISIS_CTRL_H__
#define __BBL_ISIS_CTRL_H__
ssize_t
int
isis_ctrl_adjacencies(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused)));
ssize_t
int
isis_ctrl_database(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments);
ssize_t
int
isis_ctrl_load_mrt(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments);
ssize_t
int
isis_ctrl_lsp_update(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments);
ssize_t
int
isis_ctrl_teardown(int fd, bbl_ctx_s *ctx, uint32_t session_id __attribute__((unused)), json_t* arguments __attribute__((unused)));
#endif