Function routingmanagerd_process

examples/routingmanagerd/routingmanagerd.cpp:27–110

* Create a vsomeip application object and start it. */

 * Create a vsomeip application object and start it.
 */
int routingmanagerd_process(bool _is_quiet) {
#ifdef USE_DLT
    if (!_is_quiet)
        DLT_REGISTER_APP(VSOMEIP_LOG_DEFAULT_APPLICATION_ID, VSOMEIP_LOG_DEFAULT_APPLICATION_NAME);
#else
    (void)_is_quiet;
#endif

    std::shared_ptr<vsomeip::runtime> its_runtime = vsomeip::runtime::get();

    if (!its_runtime) {
        return -1;
    }

    // Create the application object, and initialize it before sighandler thread starts
    its_application = its_runtime->create_application("routingmanagerd");
    if (!its_application->init()) {
        its_application.reset();
        return -1;
    }

#ifndef VSOMEIP_ENABLE_SIGNAL_HANDLING

    auto signal_worker_fn = []() {
#if defined(__linux__) || defined(__QNX__)
        pthread_setname_np(pthread_self(), "signal_w");
#endif

        // Unblock signals for this thread only
        sigset_t handler_mask;
        sigemptyset(&handler_mask);
        sigaddset(&handler_mask, SIGUSR1);
        sigaddset(&handler_mask, SIGUSR2);
        sigaddset(&handler_mask, SIGTERM);
        sigaddset(&handler_mask, SIGINT);
        sigaddset(&handler_mask, SIGSEGV);
        sigaddset(&handler_mask, SIGABRT);

        while (true) {
            int its_signal = 0;
            sigwait(&handler_mask, &its_signal);

            if (its_signal == SIGTERM || its_signal == SIGINT) {
                its_application->stop();
                return;
            } else if (its_signal == SIGUSR1) {
                its_application->set_routing_state(vsomeip::routing_state_e::RS_SUSPENDED);
            } else if (its_signal == SIGUSR2) {
                its_application->set_routing_state(vsomeip::routing_state_e::RS_RESUMED);
            }
        }
    };

    std::thread sighandler_thread(signal_worker_fn);
#endif

    if (its_application->is_routing()) {
        its_application->start();