| 2450 | } |
| 2451 | |
| 2452 | int RtmpRetryingClientStream::AcquireStreamToSend( |
| 2453 | butil::intrusive_ptr<RtmpStreamBase>* ptr) { |
| 2454 | BAIDU_SCOPED_LOCK(_stream_mutex); |
| 2455 | if (!_using_sub_stream) { |
| 2456 | errno = EPERM; |
| 2457 | return -1; |
| 2458 | } |
| 2459 | if (!_using_sub_stream->is_server_accepted()) { |
| 2460 | // not published yet. |
| 2461 | errno = EPERM; |
| 2462 | return -1; |
| 2463 | } |
| 2464 | if (_changed_stream) { |
| 2465 | _changed_stream = false; |
| 2466 | errno = ERTMPPUBLISHABLE; |
| 2467 | return -1; |
| 2468 | } |
| 2469 | *ptr = _using_sub_stream; |
| 2470 | return 0; |
| 2471 | } |
| 2472 | |
| 2473 | int RtmpRetryingClientStream::SendCuePoint(const RtmpCuePoint& obj) { |
| 2474 | butil::intrusive_ptr<RtmpStreamBase> ptr; |
nothing calls this directly
no test coverage detected