Method ReleaseAllFailedWriteRequests

src/brpc/socket.cpp:544–566

}

void Socket::ReleaseAllFailedWriteRequests(Socket::WriteRequest* req) {
    CHECK(Failed() || IsWriteShutdown());
    int error_code;
    std::string error_text;
    if (Failed()) {
        pthread_mutex_lock(&_id_wait_list_mutex);
        error_code = non_zero_error_code();
        error_text = _error_text;
        pthread_mutex_unlock(&_id_wait_list_mutex);
    } else {
        error_code = ESHUTDOWNWRITE;
        error_text = "Shutdown write of the socket";
    }
    // Notice that `req' is not tail if Address after IsWriteComplete fails.
    do {
        req = ReleaseWriteRequestsExceptLast(req, error_code, error_text);
        if (!req->reset_pipelined_count_and_user_message()) {
            CancelUnwrittenBytes(req->data.size());
        }
        req->data.clear();  // MUST, otherwise IsWriteComplete is false
    } while (!IsWriteComplete(req, true, NULL));
    ReturnFailedWriteRequest(req, error_code, error_text);
}

int Socket::ResetFileDescriptor(int fd) {
    // Reset message sizes when fd is changed.