external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

RTC: Refine is_alive code

Browse source
This commit is contained in:
winlin 2021-02-03 18:58:07 +08:00
parent aeca278de0
commit 4bcfce7ff1
2 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trunk/src/app/srs_app_rtc_conn.cpp
View file

@ -2199,7 +2199,7 @@ srs_error_t SrsRtcConnection::start_publish(std::string stream_uri)
bool SrsRtcConnection::is_alive() bool SrsRtcConnection::is_alive()
{ {
return last_stun_time + session_timeout < srs_get_system_time(); return last_stun_time + session_timeout > srs_get_system_time();
} }
void SrsRtcConnection::alive() void SrsRtcConnection::alive()

8
trunk/src/app/srs_app_rtc_server.cpp
View file

@ -603,7 +603,13 @@ srs_error_t SrsRtcServer::notify(int type, srs_utime_t interval, srs_utime_t tic
// Check all sessions and dispose the dead sessions. // Check all sessions and dispose the dead sessions.
for (int i = 0; i < (int)_srs_rtc_manager->size(); i++) { for (int i = 0; i < (int)_srs_rtc_manager->size(); i++) {
SrsRtcConnection* session = dynamic_cast<SrsRtcConnection*>(_srs_rtc_manager->at(i)); SrsRtcConnection* session = dynamic_cast<SrsRtcConnection*>(_srs_rtc_manager->at(i));
if (!session || !session->is_alive() || session->disposing_) { // Ignore not session, or already disposing.
if (!session || session->disposing_) {
continue;
}
// Update stat if session is alive.
if (session->is_alive()) {
nn_rtc_conns++; nn_rtc_conns++;
continue; continue;
} }