| 1727 | } |
| 1728 | |
| 1729 | int RtmpClientStream::RunOnFailed(bthread_id_t id, void* data, int) { |
| 1730 | butil::intrusive_ptr<RtmpClientStream> stream( |
| 1731 | static_cast<RtmpClientStream*>(data), false); |
| 1732 | CHECK(stream->_rtmpsock); |
| 1733 | // Must happen after NotifyOnFailed which is after all other callsites |
| 1734 | // to OnStopInternal(). |
| 1735 | stream->OnStopInternal(); |
| 1736 | bthread_id_unlock_and_destroy(id); |
| 1737 | return 0; |
| 1738 | } |
| 1739 | |
| 1740 | void RtmpClientStream::OnFailedToCreateStream() { |
| 1741 | { |
nothing calls this directly
no test coverage detected