80 lines
2.7 KiB
C++
80 lines
2.7 KiB
C++
/*
|
||
* Copyright (c) 2020 The ZLMediaKit project authors. All Rights Reserved.
|
||
* Created by alex on 2021/4/6.
|
||
* This file is part of ZLMediaKit(https://github.com/ZLMediaKit/ZLMediaKit).
|
||
*
|
||
* Use of this source code is governed by MIT-like license that can be found in the
|
||
* LICENSE file in the root of the source tree. All contributing project authors
|
||
* may be found in the AUTHORS file in the root of the source tree.
|
||
*/
|
||
|
||
#include "TsPlayerImp.h"
|
||
#include "HlsPlayer.h"
|
||
#include "Common/config.h"
|
||
|
||
using namespace std;
|
||
using namespace toolkit;
|
||
|
||
namespace mediakit {
|
||
|
||
TsPlayerImp::TsPlayerImp(const EventPoller::Ptr &poller) : PlayerImp<TsPlayer, PlayerBase>(poller) {}
|
||
|
||
void TsPlayerImp::onResponseBody(const char *data, size_t len) {
|
||
TsPlayer::onResponseBody(data, len);
|
||
if (!_decoder && _demuxer) {
|
||
_decoder = DecoderImp::createDecoder(DecoderImp::decoder_ts, _demuxer.get());
|
||
}
|
||
|
||
if (_decoder && _demuxer) {
|
||
_decoder->input((uint8_t *) data, len);
|
||
}
|
||
}
|
||
|
||
void TsPlayerImp::addTrackCompleted() {
|
||
PlayerImp<TsPlayer, PlayerBase>::onPlayResult(SockException(Err_success, "play http-ts success"));
|
||
}
|
||
|
||
void TsPlayerImp::onPlayResult(const SockException &ex) {
|
||
auto benchmark_mode = (*this)[Client::kBenchmarkMode].as<int>();
|
||
if (ex || benchmark_mode) {
|
||
PlayerImp<TsPlayer, PlayerBase>::onPlayResult(ex);
|
||
} else {
|
||
auto demuxer = std::make_shared<HlsDemuxer>();
|
||
demuxer->start(getPoller(), this);
|
||
_demuxer = std::move(demuxer);
|
||
}
|
||
}
|
||
|
||
void TsPlayerImp::onShutdown(const SockException &ex) {
|
||
while (_demuxer) {
|
||
try {
|
||
// shared_from_this()可能抛异常 [AUTO-TRANSLATED:6af9bd3c]
|
||
// shared_from_this() may throw an exception
|
||
std::weak_ptr<TsPlayerImp> weak_self = static_pointer_cast<TsPlayerImp>(shared_from_this());
|
||
if (_decoder) {
|
||
_decoder->flush();
|
||
}
|
||
// 等待所有frame flush输出后，再触发onShutdown事件 [AUTO-TRANSLATED:93982eb3]
|
||
// Wait for all frame flush output before triggering the onShutdown event
|
||
static_pointer_cast<HlsDemuxer>(_demuxer)->pushTask([weak_self, ex]() {
|
||
if (auto strong_self = weak_self.lock()) {
|
||
strong_self->_demuxer = nullptr;
|
||
strong_self->onShutdown(ex);
|
||
}
|
||
});
|
||
return;
|
||
} catch (...) {
|
||
break;
|
||
}
|
||
}
|
||
PlayerImp<TsPlayer, PlayerBase>::onShutdown(ex);
|
||
}
|
||
|
||
vector<Track::Ptr> TsPlayerImp::getTracks(bool ready) const {
|
||
if (!_demuxer) {
|
||
return vector<Track::Ptr>();
|
||
}
|
||
return static_pointer_cast<HlsDemuxer>(_demuxer)->getTracks(ready);
|
||
}
|
||
|
||
}//namespace mediakit
|