|
|
|
@ -826,8 +826,10 @@ int main(int argc, char **argv) { |
|
|
|
threads_join_all(0); |
|
|
|
} |
|
|
|
|
|
|
|
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_FREE); |
|
|
|
} |
|
|
|
|
|
|
|
threads_join_all(1); |
|
|
|
|
|
|
|
|