|
|
@ -817,6 +817,8 @@ int main(int argc, char **argv) {
|
|
|
|
rtpe_config.num_threads = 4;
|
|
|
|
rtpe_config.num_threads = 4;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
service_notify("READY=1\n");
|
|
|
|
|
|
|
|
|
|
|
|
for (;idx<rtpe_config.num_threads;++idx) {
|
|
|
|
for (;idx<rtpe_config.num_threads;++idx) {
|
|
|
|
thread_create_detach_prio(poller_loop, rtpe_poller, rtpe_config.scheduling, rtpe_config.priority);
|
|
|
|
thread_create_detach_prio(poller_loop, rtpe_poller, rtpe_config.scheduling, rtpe_config.priority);
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -826,6 +828,8 @@ int main(int argc, char **argv) {
|
|
|
|
threads_join_all(0);
|
|
|
|
threads_join_all(0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
service_notify("STOPPING=1\n");
|
|
|
|
|
|
|
|
|
|
|
|
if (!is_addr_unspecified(&rtpe_config.redis_ep.address)) {
|
|
|
|
if (!is_addr_unspecified(&rtpe_config.redis_ep.address)) {
|
|
|
|
redis_notify_event_base_action(EVENT_BASE_LOOPBREAK);
|
|
|
|
redis_notify_event_base_action(EVENT_BASE_LOOPBREAK);
|
|
|
|
redis_notify_event_base_action(EVENT_BASE_FREE);
|
|
|
|
redis_notify_event_base_action(EVENT_BASE_FREE);
|
|
|
|