mirror of
https://github.com/ossrs/srs.git
synced 2025-03-09 15:49:59 +00:00
Release v3.0-r8, 3.0.168
This commit is contained in:
parent
34117027fd
commit
b8177ff2fb
3 changed files with 14 additions and 12 deletions
|
@ -82,21 +82,18 @@ srs_error_t SrsLatestVersion::cycle()
|
|||
{
|
||||
srs_error_t err = srs_success;
|
||||
|
||||
srs_utime_t starttime = srs_update_system_time();
|
||||
if ((err = query_latest_version()) != srs_success) {
|
||||
srs_warn("query err %s", srs_error_desc(err).c_str());
|
||||
srs_freep(err); // Ignore any error.
|
||||
}
|
||||
|
||||
srs_utime_t first_random_wait = 0;
|
||||
srs_random_generate((char*)&first_random_wait, 8);
|
||||
first_random_wait = srs_utime_t(uint64_t((first_random_wait + starttime + getpid())) % (60 * 60)) * SRS_UTIME_SECONDS; // in s.
|
||||
first_random_wait = srs_utime_t(uint64_t((first_random_wait + srs_update_system_time() + getpid())) % (5 * 60)) * SRS_UTIME_SECONDS; // in s.
|
||||
|
||||
srs_trace("Startup query id=%s, eip=%s, match=%s, stable=%s, wait=%ds, cost=%dms", server_id_.c_str(), srs_get_public_internet_address().c_str(), match_version_.c_str(), stable_version_.c_str(), srsu2msi(first_random_wait)/1000, srsu2msi(srs_update_system_time() - starttime));
|
||||
// Only report after 5+ minutes.
|
||||
first_random_wait += 5 * 60 * SRS_UTIME_SECONDS;
|
||||
|
||||
srs_trace("Startup query id=%s, eip=%s, wait=%ds", server_id_.c_str(), srs_get_public_internet_address().c_str(), srsu2msi(first_random_wait)/1000);
|
||||
srs_usleep(first_random_wait);
|
||||
|
||||
while (true) {
|
||||
starttime = srs_update_system_time();
|
||||
srs_utime_t starttime = srs_update_system_time();
|
||||
if ((err = query_latest_version()) != srs_success) {
|
||||
srs_warn("query err %s", srs_error_desc(err).c_str());
|
||||
srs_freep(err); // Ignore any error.
|
||||
|
@ -119,8 +116,10 @@ srs_error_t SrsLatestVersion::query_latest_version()
|
|||
<< "version=v" << VERSION_MAJOR << "." << VERSION_MINOR << "." << VERSION_REVISION
|
||||
<< "&id=" << server_id_ << "&role=srs"
|
||||
<< "&eip=" << srs_get_public_internet_address()
|
||||
<< "&ts=" << srsu2ms(srs_get_system_time());
|
||||
<< "&ts=" << srs_get_system_time()
|
||||
<< "&alive=" << srsu2ms(srs_get_system_time() - srs_get_system_startup_time()) / 1000;
|
||||
srs_build_features(ss);
|
||||
|
||||
string url = ss.str();
|
||||
|
||||
SrsHttpUri uri;
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue