Method start_loop

net/rsocket/rsocket.cpp:473–483

    }

    int start_loop(bool block) override {
        if (check_running())
            LOG_ERROR_RETURN(EALREADY, -1, "Already listening");
        m_block_serv = block;
        if (block) return accept_loop();
        auto loop = &RSocketServer::accept_loop;
        auto th = photon::thread_create((photon::thread_entry&)loop, this);
        thread_enable_join(th);
        thread_yield_to(th);
        return 0;
    }
    void terminate() final {
        photon::thread* th = workth.exchange(nullptr);
        if (!th) return;