mirror of
https://github.com/ZLMediaKit/ZLMediaKit.git
synced 2024-11-01 00:57:28 +08:00
68 lines
2.2 KiB
C++
68 lines
2.2 KiB
C++
/*
|
|
* Copyright (c) 2016 The ZLMediaKit project authors. All Rights Reserved.
|
|
*
|
|
* This file is part of ZLMediaKit(https://github.com/xiongziliang/ZLMediaKit).
|
|
*
|
|
* Use of this source code is governed by MIT 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 "HlsMediaSource.h"
|
|
|
|
namespace mediakit{
|
|
|
|
HlsCookieData::HlsCookieData(const MediaInfo &info, const string &sessionIdentifier, const string &peer_ip, uint16_t peer_port) {
|
|
_info = info;
|
|
_sessionIdentifier = sessionIdentifier;
|
|
_peer_ip = peer_ip;
|
|
_peer_port = peer_port;
|
|
_added = std::make_shared<bool>(false);
|
|
addReaderCount();
|
|
}
|
|
|
|
void HlsCookieData::addReaderCount(){
|
|
if(!*_added){
|
|
auto src = dynamic_pointer_cast<HlsMediaSource>(MediaSource::find(HLS_SCHEMA,_info._vhost,_info._app,_info._streamid));
|
|
if(src){
|
|
src->modifyReaderCount(true);
|
|
*_added = true;
|
|
_src = src;
|
|
_ring_reader = src->getRing()->attach(EventPollerPool::Instance().getPoller());
|
|
auto added = _added;
|
|
_ring_reader->setDetachCB([added](){
|
|
//HlsMediaSource已经销毁
|
|
*added = false;
|
|
});
|
|
}
|
|
}
|
|
}
|
|
|
|
HlsCookieData::~HlsCookieData() {
|
|
if (*_added) {
|
|
auto src = _src.lock();
|
|
if (src) {
|
|
src->modifyReaderCount(false);
|
|
}
|
|
uint64_t duration = (_ticker.createdTime() - _ticker.elapsedTime()) / 1000;
|
|
WarnL << _sessionIdentifier << "(" << _peer_ip << ":" << _peer_port << ") "
|
|
<< "HLS播放器(" << _info._vhost << "/" << _info._app << "/" << _info._streamid
|
|
<< ")断开,耗时(s):" << duration;
|
|
|
|
GET_CONFIG(uint32_t, iFlowThreshold, General::kFlowThreshold);
|
|
if (_bytes > iFlowThreshold * 1024) {
|
|
NoticeCenter::Instance().emitEvent(Broadcast::kBroadcastFlowReport, _info, _bytes, duration, true, _sessionIdentifier, _peer_ip, _peer_port);
|
|
}
|
|
}
|
|
}
|
|
|
|
void HlsCookieData::addByteUsage(uint64_t bytes) {
|
|
addReaderCount();
|
|
_bytes += bytes;
|
|
_ticker.resetTime();
|
|
}
|
|
|
|
|
|
}//namespace mediakit
|
|
|