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 support to start/stop stream by name

Browse Source
This commit is contained in:
Christian Giese
2024-02-06 12:54:51 +00:00
committed by Hannes Gredler
parent 72e824fd7e
commit aca0ac5ef4
1 changed files with 33 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
code/bngblaster/src/bbl_stream.c
+33 -7
View File
@@ -2730,7 +2730,8 @@ bbl_stream_ctrl_pending(int fd, uint32_t session_id __attribute__((unused)), jso
}
static int
bbl_stream_ctrl_start_stop(int fd, uint32_t session_id, int session_group_id, uint64_t flow_id, bool status)
bbl_stream_ctrl_start_stop(int fd, uint32_t session_id, int session_group_id,
uint64_t flow_id, const char *name, bool status)
{
bbl_session_s *session;
bbl_stream_s *stream = g_ctx->stream_head;
@@ -2747,7 +2748,13 @@ bbl_stream_ctrl_start_stop(int fd, uint32_t session_id, int session_group_id, ui
if(session) {
stream = session->streams.head;
while(stream) {
stream->stop = status;
if(name) {
if(strcmp(name, stream->config->name) == 0) {
stream->stop = status;
}
} else {
stream->stop = status;
}
stream = stream->session_next;
}
} else {
@@ -2756,9 +2763,24 @@ bbl_stream_ctrl_start_stop(int fd, uint32_t session_id, int session_group_id, ui
} else {
/* Iterate over all traffic streams */
while(stream) {
if(!(session_group_id && stream->session &&
stream->session->session_group_id != session_group_id)) {
stream->stop = status;
if(session_group_id >= 0) {
if(stream->session && stream->session->session_group_id == session_group_id) {
if(name) {
if(strcmp(name, stream->config->name) == 0) {
stream->stop = status;
}
} else {
stream->stop = status;
}
}
} else {
if(name) {
if(strcmp(name, stream->config->name) == 0) {
stream->stop = status;
}
} else {
stream->stop = status;
}
}
stream = stream->next;
}
@@ -2772,6 +2794,7 @@ bbl_stream_ctrl_start(int fd, uint32_t session_id, json_t *arguments)
int session_group_id = -1;
int number = 0;
uint64_t flow_id = 0;
const char *name = NULL;
if(json_unpack(arguments, "{s:i}", "flow-id", &number) == 0) {
flow_id = number;
@@ -2781,7 +2804,8 @@ bbl_stream_ctrl_start(int fd, uint32_t session_id, json_t *arguments)
return bbl_ctrl_status(fd, "error", 400, "invalid session-group-id");
}
}
return bbl_stream_ctrl_start_stop(fd, session_id, session_group_id, flow_id, false);
json_unpack(arguments, "{s:s}", "name", &name);
return bbl_stream_ctrl_start_stop(fd, session_id, session_group_id, flow_id, name, false);
}
int
@@ -2790,6 +2814,7 @@ bbl_stream_ctrl_stop(int fd, uint32_t session_id, json_t *arguments)
int session_group_id = -1;
int number = 0;
uint64_t flow_id = 0;
const char *name = NULL;
if(json_unpack(arguments, "{s:i}", "flow-id", &number) == 0) {
flow_id = number;
@@ -2799,5 +2824,6 @@ bbl_stream_ctrl_stop(int fd, uint32_t session_id, json_t *arguments)
return bbl_ctrl_status(fd, "error", 400, "invalid session-group-id");
}
}
return bbl_stream_ctrl_start_stop(fd, session_id, session_group_id, flow_id, true);
json_unpack(arguments, "{s:s}", "name", &name);
return bbl_stream_ctrl_start_stop(fd, session_id, session_group_id, flow_id, name, true);
}