Function RunThreadFunc

example/rpcz_echo_c++/server.cpp:48–85

    BTHREAD_STACKTYPE_NORMAL, BTHREAD_INHERIT_SPAN, NULL, BTHREAD_TAG_INVALID};

void* RunThreadFunc(void*) {
    TRACEPRINTF("RunThreadFunc %lu", bthread_self());
    // brpc::FLAGS_enable_rpcz = true;
    // A Channel represents a communication line to a Server. Notice that
    // Channel is thread-safe and can be shared by all threads in your program.
    brpc::Channel channel;
    // Initialize the channel, NULL means using default options.
    brpc::ChannelOptions options;
    options.protocol = FLAGS_protocol;
    options.connection_type = FLAGS_connection_type;
    options.timeout_ms = FLAGS_timeout_ms /*milliseconds*/;
    options.max_retry = FLAGS_max_retry;
    if (channel.Init(FLAGS_server.c_str(), "", &options) != 0) {
        LOG(ERROR) << "Fail to initialize channel";
        return nullptr;
    }
    example::EchoService_Stub stub(&channel);
    // We will receive response synchronously, safe to put variables
    // on stack.
    example::EchoRequest request;
    example::EchoResponse response;
    brpc::Controller cntl;
    request.set_message("hello world");

    // Because `done'(last parameter) is NULL, this function waits until
    // the response comes back or error occurs(including timedout).
    stub.Echo(&cntl, &request, &response, NULL);
    if (!cntl.Failed()) {
        LOG(INFO) << "Received response from " << cntl.remote_side() << " to " << cntl.local_side()
                  << ": " << response.message() << " (attached=" << cntl.response_attachment()
                  << ")"
                  << " latency=" << cntl.latency_us() << "us";
    } else {
        LOG(WARNING) << cntl.ErrorText();
    }

    return nullptr;
}

class EchoServiceImpl : public EchoService {
public: