Method HandleSocketFailed

src/brpc/controller.cpp:1286–1334

}

int Controller::HandleSocketFailed(bthread_id_t id, void* data, int error_code,
                                   const std::string& error_text) {
    Controller* cntl = static_cast<Controller*>(data);
    if (!cntl->is_used_by_rpc()) {
        // Cannot destroy the call_id before RPC otherwise an async RPC
        // using the controller cannot be joined and related resources may be
        // destroyed before done->Run() running in another bthread.
        // The error set will be detected in Channel::CallMethod and fail
        // the RPC.
        cntl->SetFailed(error_code, "Cancel call_id=%" PRId64
                        " before CallMethod()", id.value);
        return bthread_id_unlock(id);
    }
    const int saved_error = cntl->ErrorCode();
    if (error_code == ERPCTIMEDOUT) {
        cntl->SetFailed(error_code, "Reached timeout=%" PRId64 "ms @%s",
                        cntl->timeout_ms(),
                        butil::endpoint2str(cntl->remote_side()).c_str());
    } else if (error_code == EBACKUPREQUEST) {
        cntl->SetFailed(error_code, "Reached backup timeout=%" PRId64 "ms @%s",
                        cntl->backup_request_ms(),
                        butil::endpoint2str(cntl->remote_side()).c_str());
    } else if (!error_text.empty()) {
        cntl->SetFailed(error_code, "%s", error_text.c_str());
    } else {
        cntl->SetFailed(error_code, "%s @%s", berror(error_code),
                        butil::endpoint2str(cntl->remote_side()).c_str());
    }

    struct OnVersionedRPCReturnedArgs {
        bthread_id_t id;
        Controller* cntl;
        int error;
    };
    auto func = [](void* p) -> void* {
        std::unique_ptr<OnVersionedRPCReturnedArgs> args(static_cast<OnVersionedRPCReturnedArgs*>(p));
        CompletionInfo info = { args->id, false };
        args->cntl->OnVersionedRPCReturned(info, true, args->error);
        return NULL;
    };

    auto* args = new OnVersionedRPCReturnedArgs{ id, cntl, saved_error };
    bthread_t tid;
    // RetryPolicy may block current bthread, so start a new bthread to run OnVersionedRPCReturned
    if (!cntl->_retry_policy || bthread_start_background(&tid, NULL, func, args) != 0) {
        func(args);
    }
    return 0;
}

CallId Controller::call_id() {
    butil::atomic<uint64_t>* target =