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

add stream TTL option

Browse Source
This commit is contained in:
Christian Giese
2024-02-09 13:23:45 +00:00
parent e2698cc615
commit dbd62b2eae
5 changed files with 33 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
code/bngblaster/src/bbl_config.c
+8 -1
View File
@@ -2201,7 +2201,7 @@ json_parse_stream(json_t *stream, bbl_stream_config_s *stream_config)
const char *schema[] = {
"name", "stream-group-id", "type",
"direction", "network-interface", "a10nsp-interface",
"source-port", "destination-port", "length",
"source-port", "destination-port", "length", "ttl"
"priority", "vlan-priority", "pps",
"bps", "Kbps", "Mbps",
"Gbps", "max-packets", "start-delay",
@@ -2307,6 +2307,13 @@ json_parse_stream(json_t *stream, bbl_stream_config_s *stream_config)
stream_config->length = 128;
}
JSON_OBJ_GET_NUMBER(stream, value, "stream", "ttl", 0, 255);
if(value) {
stream_config->ttl = json_number_value(value);
} else {
stream_config->ttl = BBL_DEFAULT_TTL;
}
JSON_OBJ_GET_NUMBER(stream, value, "stream", "priority", 0, 255);
if(value) {
stream_config->priority = json_number_value(value);
code/bngblaster/src/bbl_def.h
+2
View File
@@ -54,6 +54,8 @@
#define BBL_SESSION_HASHTABLE_SIZE 128993 /* is a prime number */
#define BBL_LI_HASHTABLE_SIZE 32771 /* is a prime number */
#define BBL_DEFAULT_TTL 64
/* Mock Addresses */
#define MOCK_IP_LOCAL 167772170 /* 10.0.0.10 */
#define MOCK_IP_REMOTE 168430090 /* 10.10.10.10 */
code/bngblaster/src/bbl_stream.c
+19 -12
View File
@@ -161,7 +161,7 @@ bbl_stream_build_access_pppoe_packet(bbl_stream_s *stream)
if(config->ipv4_df) {
ipv4.offset = IPV4_DF;
}
ipv4.ttl = 64;
ipv4.ttl = config->ttl;
ipv4.tos = config->priority;
if(stream->tcp) {
ipv4.protocol = PROTOCOL_IPV4_TCP;
@@ -197,7 +197,7 @@ bbl_stream_build_access_pppoe_packet(bbl_stream_s *stream)
ipv6.dst = network_interface->ip6.address;
}
}
ipv6.ttl = 64;
ipv6.ttl = config->ttl;
ipv6.tos = config->priority;
if(stream->tcp) {
ipv6.protocol = IPV6_NEXT_HEADER_TCP;
@@ -308,7 +308,7 @@ bbl_stream_build_a10nsp_pppoe_packet(bbl_stream_s *stream)
if(config->ipv4_df) {
ipv4.offset = IPV4_DF;
}
ipv4.ttl = 64;
ipv4.ttl = config->ttl;
ipv4.tos = config->priority;
if(stream->tcp) {
ipv4.protocol = PROTOCOL_IPV4_TCP;
@@ -335,7 +335,7 @@ bbl_stream_build_a10nsp_pppoe_packet(bbl_stream_s *stream)
if(*(uint64_t*)stream->config->ipv6_destination_address) {
ipv6.dst = stream->config->ipv6_destination_address;
}
ipv6.ttl = 64;
ipv6.ttl = config->ttl;
ipv6.tos = config->priority;
if(stream->tcp) {
ipv6.protocol = IPV6_NEXT_HEADER_TCP;
@@ -444,7 +444,7 @@ bbl_stream_build_a10nsp_ipoe_packet(bbl_stream_s *stream)
if(config->ipv4_df) {
ipv4.offset = IPV4_DF;
}
ipv4.ttl = 64;
ipv4.ttl = config->ttl;
ipv4.tos = config->priority;
if(stream->tcp) {
ipv4.protocol = PROTOCOL_IPV4_TCP;
@@ -477,7 +477,7 @@ bbl_stream_build_a10nsp_ipoe_packet(bbl_stream_s *stream)
}
}
ipv6.src = session->link_local_ipv6_address;
ipv6.ttl = 64;
ipv6.ttl = config->ttl;
ipv6.tos = config->priority;
if(stream->tcp) {
ipv6.protocol = IPV6_NEXT_HEADER_TCP;
@@ -586,7 +586,7 @@ bbl_stream_build_access_ipoe_packet(bbl_stream_s *stream)
if(config->ipv4_df) {
ipv4.offset = IPV4_DF;
}
ipv4.ttl = 64;
ipv4.ttl = config->ttl;
ipv4.tos = config->priority;
if(stream->tcp) {
ipv4.protocol = PROTOCOL_IPV4_TCP;
@@ -622,7 +622,7 @@ bbl_stream_build_access_ipoe_packet(bbl_stream_s *stream)
ipv6.dst = network_interface->ip6.address;
}
}
ipv6.ttl = 64;
ipv6.ttl = config->ttl;
ipv6.tos = config->priority;
if(stream->tcp) {
ipv6.protocol = IPV6_NEXT_HEADER_TCP;
@@ -751,7 +751,7 @@ bbl_stream_build_network_packet(bbl_stream_s *stream)
if(config->ipv4_df) {
ipv4.offset = IPV4_DF;
}
ipv4.ttl = 64;
ipv4.ttl = config->ttl;
ipv4.tos = config->priority;
if(stream->tcp) {
ipv4.protocol = PROTOCOL_IPV4_TCP;
@@ -794,7 +794,7 @@ bbl_stream_build_network_packet(bbl_stream_s *stream)
return false;
}
}
ipv6.ttl = 64;
ipv6.ttl = config->ttl;
ipv6.tos = config->priority;
if(stream->tcp) {
ipv6.protocol = IPV6_NEXT_HEADER_TCP;
@@ -860,7 +860,7 @@ bbl_stream_build_l2tp_packet(bbl_stream_s *stream)
eth.next = &l2tp_ipv4;
l2tp_ipv4.dst = l2tp_tunnel->peer_ip;
l2tp_ipv4.src = l2tp_tunnel->server->ip;
l2tp_ipv4.ttl = 64;
l2tp_ipv4.ttl = config->ttl;
l2tp_ipv4.tos = config->priority;
l2tp_ipv4.protocol = PROTOCOL_IPV4_UDP;
l2tp_ipv4.next = &l2tp_udp;
@@ -880,7 +880,7 @@ bbl_stream_build_l2tp_packet(bbl_stream_s *stream)
if(config->ipv4_df) {
ipv4.offset = IPV4_DF;
}
ipv4.ttl = 64;
ipv4.ttl = config->ttl;
ipv4.tos = config->priority;
if(stream->tcp) {
ipv4.protocol = PROTOCOL_IPV4_TCP;
@@ -2014,6 +2014,7 @@ bbl_stream_init() {
config->name = (char*)g_multicast_traffic;
config->type = BBL_SUB_TYPE_IPV4;
config->direction = BBL_DIRECTION_DOWN;
config->ttl = BBL_DEFAULT_TTL;
config->pps = g_ctx->config.multicast_traffic_pps;
config->dst_port = BBL_UDP_PORT;
config->src_port = BBL_UDP_PORT;
@@ -2047,6 +2048,7 @@ bbl_stream_init() {
config->stream_group_id = UINT16_MAX;
config->type = BBL_SUB_TYPE_IPV4;
config->direction = BBL_DIRECTION_UP;
config->ttl = BBL_DEFAULT_TTL;
config->session_traffic = true;
config->pps = g_ctx->config.session_traffic_ipv4_pps;
config->dst_port = BBL_UDP_PORT;
@@ -2059,6 +2061,7 @@ bbl_stream_init() {
config->stream_group_id = UINT16_MAX;
config->type = BBL_SUB_TYPE_IPV4;
config->direction = BBL_DIRECTION_DOWN;
config->ttl = BBL_DEFAULT_TTL;
config->session_traffic = true;
config->pps = g_ctx->config.session_traffic_ipv4_pps;
config->dst_port = BBL_UDP_PORT;
@@ -2078,6 +2081,7 @@ bbl_stream_init() {
config->stream_group_id = UINT16_MAX;
config->type = BBL_SUB_TYPE_IPV6;
config->direction = BBL_DIRECTION_UP;
config->ttl = BBL_DEFAULT_TTL;
config->session_traffic = true;
config->pps = g_ctx->config.session_traffic_ipv6_pps;
config->dst_port = BBL_UDP_PORT;
@@ -2090,6 +2094,7 @@ bbl_stream_init() {
config->stream_group_id = UINT16_MAX;
config->type = BBL_SUB_TYPE_IPV6;
config->direction = BBL_DIRECTION_DOWN;
config->ttl = BBL_DEFAULT_TTL;
config->session_traffic = true;
config->pps = g_ctx->config.session_traffic_ipv6_pps;
config->dst_port = BBL_UDP_PORT;
@@ -2109,6 +2114,7 @@ bbl_stream_init() {
config->stream_group_id = UINT16_MAX;
config->type = BBL_SUB_TYPE_IPV6PD;
config->direction = BBL_DIRECTION_UP;
config->ttl = BBL_DEFAULT_TTL;
config->session_traffic = true;
config->pps = g_ctx->config.session_traffic_ipv6pd_pps;
config->dst_port = BBL_UDP_PORT;
@@ -2121,6 +2127,7 @@ bbl_stream_init() {
config->stream_group_id = UINT16_MAX;
config->type = BBL_SUB_TYPE_IPV6PD;
config->direction = BBL_DIRECTION_DOWN;
config->ttl = BBL_DEFAULT_TTL;
config->session_traffic = true;
config->pps = g_ctx->config.session_traffic_ipv6pd_pps;
config->dst_port = BBL_UDP_PORT;
code/bngblaster/src/bbl_stream.h
+1
View File
@@ -30,6 +30,7 @@ typedef struct bbl_stream_config_
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 */
docsrc/sources/configuration/streams.rst
+3
View File
@@ -35,6 +35,9 @@
| **length** | | Layer 3 (IP header + payload) traffic length. |
| | | Default: 128 Range: 76 - 9000 |
+--------------------------------+------------------------------------------------------------------+
| **ttl** | | TTL. |
| | | Default: 64 Range: 0 - 255 |
+--------------------------------+------------------------------------------------------------------+
| **pps** | | Stream traffic rate in packets per second. |
| | | This value supports also float numbers like 0.1 or 2.5. |
| | | In example 0.1 means one packet every 10 seconds. |