Function rpc_server

rpc/test/test.cpp:109–121

}

void* rpc_server(void* args_)
{
    LOG_DEBUG("enter");
    auto s = (IStream*)args_;
    while (true)
    {
        auto header = rpc_server_read(s);
        rpc_server_write(s, header.tag);
        if (header.function == (uint64_t)-1) break;
    }
    LOG_DEBUG("exit");
    return nullptr;
}

int server_function(void* instance, iovector* request, rpc::Skeleton::ResponseSender sender, IStream*)
{