scottk/nDPId
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/nDPId.git synced 2025-11-01 18:57:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

nDPId-test: print additional startup/init log messages

Browse Source 
Signed-off-by: Toni Uhlig <matzeton@googlemail.com>
This commit is contained in:
Toni Uhlig
2023-08-02 22:32:33 +02:00
parent ebb439d959
commit d9f304e4b0
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
nDPId-test.c
View File

@@ -292,6 +292,8 @@ static void * nDPIsrvd_mainloop_thread(void * const arg)
struct epoll_event events[32]; struct epoll_event events[32];
size_t const events_size = sizeof(events) / sizeof(events[0]); size_t const events_size = sizeof(events) / sizeof(events[0]);
logger(0, "nDPIsrvd thread started, init..");
errno = 0; errno = 0;
epollfd = create_evq(); epollfd = create_evq();
if (epollfd < 0) if (epollfd < 0)
@@ -348,6 +350,7 @@ static void * nDPIsrvd_mainloop_thread(void * const arg)
THREAD_ERROR_GOTO(arg); THREAD_ERROR_GOTO(arg);
} }
logger(0, "nDPIsrvd thread init done");
thread_signal(&start_condition); thread_signal(&start_condition);
thread_wait(&start_condition); thread_wait(&start_condition);
@@ -852,6 +855,8 @@ static void * distributor_client_mainloop_thread(void * const arg)
struct distributor_global_user_data * buff_stats; struct distributor_global_user_data * buff_stats;
int * mock_null_shutdown_events; int * mock_null_shutdown_events;
logger(0, "Distributor thread started, init..");
errno = 0; errno = 0;
if (mock_sock == NULL || mock_buff == NULL || mock_null == NULL) if (mock_sock == NULL || mock_buff == NULL || mock_null == NULL)
{ {
@@ -900,6 +905,7 @@ static void * distributor_client_mainloop_thread(void * const arg)
mock_null_shutdown_events = (int *)mock_null->global_user_data; mock_null_shutdown_events = (int *)mock_null->global_user_data;
*mock_null_shutdown_events = 0; *mock_null_shutdown_events = 0;
logger(0, "Distributor thread init done");
thread_signal(&start_condition); thread_signal(&start_condition);
thread_wait(&start_condition); thread_wait(&start_condition);
@@ -1162,6 +1168,8 @@ static void * nDPId_mainloop_thread(void * const arg)
struct nDPId_return_value * const nrv = (struct nDPId_return_value *)arg; struct nDPId_return_value * const nrv = (struct nDPId_return_value *)arg;
struct thread_return_value * const trr = &nrv->thread_return_value; struct thread_return_value * const trr = &nrv->thread_return_value;
logger(0, "nDPId thread started, init..");
if (setup_reader_threads() != 0) if (setup_reader_threads() != 0)
{ {
THREAD_ERROR(trr); THREAD_ERROR(trr);
@@ -1176,6 +1184,7 @@ static void * nDPId_mainloop_thread(void * const arg)
goto error; goto error;
} }
logger(0, "nDPId thread initialize done");
thread_signal(&start_condition); thread_signal(&start_condition);
thread_wait(&start_condition); thread_wait(&start_condition);