Method TestRPCServer

net/test/zerocopy-server.cpp:113–121

class TestRPCServer : public Object {
public:
    explicit TestRPCServer(IOAlloc alloc) {
        m_skeleton = rpc::new_skeleton();
        m_skeleton->set_allocator(alloc);
        m_skeleton->register_service<TestReadProto>(this);
        m_skeleton->register_service<TestWriteProto>(this);
        m_qps = 0;
        m_statis_thread = photon::thread_create11(&TestRPCServer::loop_show_statis, this);
        photon::thread_enable_join(m_statis_thread);
    }

    ~TestRPCServer() override {
        photon::thread_interrupt(m_statis_thread);