Method KeepWriteIfConnected

src/brpc/socket.cpp:1514–1535

}

int Socket::KeepWriteIfConnected(int fd, int err, void* data) {
    WriteRequest* req = static_cast<WriteRequest*>(data);
    Socket* s = req->get_socket();
    if (err == 0 && s->ssl_state() == SSL_CONNECTING) {
        // Run ssl connect in a new bthread to avoid blocking
        // the current bthread (thus blocking the EventDispatcher)
        bthread_t th;
        std::unique_ptr<google::protobuf::Closure> thrd_func(
            NewCallback(CheckConnectedAndKeepWrite, fd, err, data));
        bthread_attr_t attr = BTHREAD_ATTR_NORMAL;
        bthread_attr_set_name(&attr, "CheckConnectedAndKeepWrite");
        if ((err = bthread_start_background(&th, &attr, RunClosure, thrd_func.get())) == 0) {
            thrd_func.release();
            return 0;
        } else {
            PLOG(ERROR) << "Fail to start bthread";
            // Fall through with non zero `err'
        }
    }
    CheckConnectedAndKeepWrite(fd, err, data);
    return 0;
}

void Socket::CheckConnectedAndKeepWrite(int fd, int err, void* data) {
    butil::fd_guard sockfd(fd);