Method NotifyOnStopped

src/brpc/progressive_attachment.cpp:241–259

}

void ProgressiveAttachment::NotifyOnStopped(google::protobuf::Closure* done) {
    if (done == NULL) {
        LOG(ERROR) << "Param[done] is NULL";
        return;
    }
    if (_notify_id != INVALID_BTHREAD_ID) {
        LOG(ERROR) << "NotifyOnStopped() can only be called once";
        return done->Run();
    }
    if (_httpsock == NULL) {
        return done->Run();
    }
    const int rc = bthread_id_create(&_notify_id, done, RunOnFailed);
    if (rc) {
        LOG(ERROR) << "Fail to create _notify_id: " << berror(rc);
        return done->Run();
    }
    _httpsock->NotifyOnFailed(_notify_id);
}
    
} // namespace brpc