mirror of
https://github.com/ossrs/srs.git
synced 2025-03-09 15:49:59 +00:00
Merge branch 'develop' into 3.0release.srt.dev
This commit is contained in:
commit
ed1a3aa37c
26 changed files with 424 additions and 84 deletions
|
@ -40,6 +40,7 @@ SrsAsyncCallWorker::SrsAsyncCallWorker()
|
|||
{
|
||||
trd = new SrsDummyCoroutine();
|
||||
wait = srs_cond_new();
|
||||
lock = srs_mutex_new();
|
||||
}
|
||||
|
||||
SrsAsyncCallWorker::~SrsAsyncCallWorker()
|
||||
|
@ -54,6 +55,7 @@ SrsAsyncCallWorker::~SrsAsyncCallWorker()
|
|||
tasks.clear();
|
||||
|
||||
srs_cond_destroy(wait);
|
||||
srs_mutex_destroy(lock);
|
||||
}
|
||||
|
||||
srs_error_t SrsAsyncCallWorker::execute(ISrsAsyncCallTask* t)
|
||||
|
@ -87,6 +89,7 @@ srs_error_t SrsAsyncCallWorker::start()
|
|||
|
||||
void SrsAsyncCallWorker::stop()
|
||||
{
|
||||
flush_tasks();
|
||||
srs_cond_signal(wait);
|
||||
trd->stop();
|
||||
}
|
||||
|
@ -103,23 +106,40 @@ srs_error_t SrsAsyncCallWorker::cycle()
|
|||
if (tasks.empty()) {
|
||||
srs_cond_wait(wait);
|
||||
}
|
||||
|
||||
std::vector<ISrsAsyncCallTask*> copy = tasks;
|
||||
tasks.clear();
|
||||
|
||||
std::vector<ISrsAsyncCallTask*>::iterator it;
|
||||
for (it = copy.begin(); it != copy.end(); ++it) {
|
||||
ISrsAsyncCallTask* task = *it;
|
||||
|
||||
if ((err = task->call()) != srs_success) {
|
||||
srs_warn("ignore task failed %s", srs_error_desc(err).c_str());
|
||||
srs_freep(err);
|
||||
}
|
||||
srs_freep(task);
|
||||
}
|
||||
|
||||
flush_tasks();
|
||||
}
|
||||
|
||||
return err;
|
||||
}
|
||||
|
||||
void SrsAsyncCallWorker::flush_tasks()
|
||||
{
|
||||
srs_error_t err = srs_success;
|
||||
|
||||
// Avoid the async call blocking other coroutines.
|
||||
std::vector<ISrsAsyncCallTask*> copy;
|
||||
if (true) {
|
||||
SrsLocker(lock);
|
||||
|
||||
if (tasks.empty()) {
|
||||
return;
|
||||
}
|
||||
|
||||
copy = tasks;
|
||||
tasks.clear();
|
||||
}
|
||||
|
||||
std::vector<ISrsAsyncCallTask*>::iterator it;
|
||||
for (it = copy.begin(); it != copy.end(); ++it) {
|
||||
ISrsAsyncCallTask* task = *it;
|
||||
|
||||
if ((err = task->call()) != srs_success) {
|
||||
srs_warn("ignore task failed %s", srs_error_desc(err).c_str());
|
||||
srs_freep(err);
|
||||
}
|
||||
srs_freep(task);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
|
|
@ -61,6 +61,7 @@ private:
|
|||
protected:
|
||||
std::vector<ISrsAsyncCallTask*> tasks;
|
||||
srs_cond_t wait;
|
||||
srs_mutex_t lock;
|
||||
public:
|
||||
SrsAsyncCallWorker();
|
||||
virtual ~SrsAsyncCallWorker();
|
||||
|
@ -73,6 +74,8 @@ public:
|
|||
// Interface ISrsReusableThreadHandler
|
||||
public:
|
||||
virtual srs_error_t cycle();
|
||||
private:
|
||||
virtual void flush_tasks();
|
||||
};
|
||||
|
||||
#endif
|
||||
|
|
|
@ -76,8 +76,12 @@ srs_error_t SrsAppCasterFlv::initialize()
|
|||
srs_error_t SrsAppCasterFlv::on_tcp_client(srs_netfd_t stfd)
|
||||
{
|
||||
srs_error_t err = srs_success;
|
||||
|
||||
|
||||
string ip = srs_get_peer_ip(srs_netfd_fileno(stfd));
|
||||
if (ip.empty() && !_srs_config->empty_ip_ok()) {
|
||||
srs_warn("empty ip for fd=%d", srs_netfd_fileno(stfd));
|
||||
}
|
||||
|
||||
SrsHttpConn* conn = new SrsDynamicHttpConn(this, stfd, http_mux, ip);
|
||||
conns.push_back(conn);
|
||||
|
||||
|
|
|
@ -3488,7 +3488,8 @@ srs_error_t SrsConfig::check_normal_config()
|
|||
&& n != "http_api" && n != "stats" && n != "vhost" && n != "pithy_print_ms"
|
||||
&& n != "http_server" && n != "stream_caster" && n != "srt_server"
|
||||
&& n != "utc_time" && n != "work_dir" && n != "asprocess"
|
||||
&& n != "ff_log_level"
|
||||
&& n != "ff_log_level" && n != "grace_final_wait" && n != "force_grace_quit"
|
||||
&& n != "grace_start_wait" && n != "empty_ip_ok"
|
||||
) {
|
||||
return srs_error_new(ERROR_SYSTEM_CONFIG_INVALID, "illegal directive %s", n.c_str());
|
||||
}
|
||||
|
@ -3528,7 +3529,8 @@ srs_error_t SrsConfig::check_normal_config()
|
|||
if (n != "enabled" && n != "listen" && n != "maxbw"
|
||||
&& n != "mss" && n != "latency" && n != "recvlatency"
|
||||
&& n != "peerlatency" && n != "tlpkdrop" && n != "connect_timeout"
|
||||
&& n != "sendbuf" && n != "recvbuf" && n != "payloadsize") {
|
||||
&& n != "sendbuf" && n != "recvbuf" && n != "payloadsize"
|
||||
&& n != "default_app") {
|
||||
return srs_error_new(ERROR_SYSTEM_CONFIG_INVALID, "illegal srt_stream.%s", n.c_str());
|
||||
}
|
||||
}
|
||||
|
@ -4064,6 +4066,54 @@ bool SrsConfig::get_asprocess()
|
|||
return SRS_CONF_PERFER_FALSE(conf->arg0());
|
||||
}
|
||||
|
||||
bool SrsConfig::empty_ip_ok()
|
||||
{
|
||||
static bool DEFAULT = true;
|
||||
|
||||
SrsConfDirective* conf = root->get("empty_ip_ok");
|
||||
if (!conf || conf->arg0().empty()) {
|
||||
return DEFAULT;
|
||||
}
|
||||
|
||||
return SRS_CONF_PERFER_TRUE(conf->arg0());
|
||||
}
|
||||
|
||||
srs_utime_t SrsConfig::get_grace_start_wait()
|
||||
{
|
||||
static srs_utime_t DEFAULT = 2300 * SRS_UTIME_MILLISECONDS;
|
||||
|
||||
SrsConfDirective* conf = root->get("grace_start_wait");
|
||||
if (!conf || conf->arg0().empty()) {
|
||||
return DEFAULT;
|
||||
}
|
||||
|
||||
return (srs_utime_t)(::atol(conf->arg0().c_str()) * SRS_UTIME_MILLISECONDS);
|
||||
}
|
||||
|
||||
srs_utime_t SrsConfig::get_grace_final_wait()
|
||||
{
|
||||
static srs_utime_t DEFAULT = 3200 * SRS_UTIME_MILLISECONDS;
|
||||
|
||||
SrsConfDirective* conf = root->get("grace_final_wait");
|
||||
if (!conf || conf->arg0().empty()) {
|
||||
return DEFAULT;
|
||||
}
|
||||
|
||||
return (srs_utime_t)(::atol(conf->arg0().c_str()) * SRS_UTIME_MILLISECONDS);
|
||||
}
|
||||
|
||||
bool SrsConfig::is_force_grace_quit()
|
||||
{
|
||||
static bool DEFAULT = false;
|
||||
|
||||
SrsConfDirective* conf = root->get("force_grace_quit");
|
||||
if (!conf || conf->arg0().empty()) {
|
||||
return DEFAULT;
|
||||
}
|
||||
|
||||
return SRS_CONF_PERFER_FALSE(conf->arg0());
|
||||
}
|
||||
|
||||
vector<SrsConfDirective*> SrsConfig::get_stream_casters()
|
||||
{
|
||||
srs_assert(root);
|
||||
|
@ -6844,6 +6894,20 @@ int SrsConfig::get_srto_payloadsize() {
|
|||
return atoi(conf->arg0().c_str());
|
||||
}
|
||||
|
||||
string SrsConfig::get_default_app_name() {
|
||||
static string DEFAULT = "live";
|
||||
SrsConfDirective* conf = root->get("srt_server");
|
||||
if (!conf) {
|
||||
return DEFAULT;
|
||||
}
|
||||
|
||||
conf = conf->get("default_app");
|
||||
if (!conf || conf->arg0().empty()) {
|
||||
return DEFAULT;
|
||||
}
|
||||
return conf->arg0();
|
||||
}
|
||||
|
||||
bool SrsConfig::get_http_stream_enabled()
|
||||
{
|
||||
SrsConfDirective* conf = root->get("http_server");
|
||||
|
|
|
@ -468,6 +468,14 @@ public:
|
|||
virtual std::string get_work_dir();
|
||||
// Whether use asprocess mode.
|
||||
virtual bool get_asprocess();
|
||||
// Whether empty client IP is ok.
|
||||
virtual bool empty_ip_ok();
|
||||
// Get the start wait in ms for gracefully quit.
|
||||
virtual srs_utime_t get_grace_start_wait();
|
||||
// Get the final wait in ms for gracefully quit.
|
||||
virtual srs_utime_t get_grace_final_wait();
|
||||
// Whether force to gracefully quit, never fast quit.
|
||||
virtual bool is_force_grace_quit();
|
||||
// stream_caster section
|
||||
public:
|
||||
// Get all stream_caster in config file.
|
||||
|
@ -615,6 +623,8 @@ public:
|
|||
virtual int get_srto_recvbuf();
|
||||
// SRTO_PAYLOADSIZE
|
||||
virtual int get_srto_payloadsize();
|
||||
// Get the default app.
|
||||
virtual std::string get_default_app_name();
|
||||
|
||||
// http_hooks section
|
||||
private:
|
||||
|
|
|
@ -740,8 +740,6 @@ srs_error_t SrsDvrSessionPlan::on_publish()
|
|||
|
||||
void SrsDvrSessionPlan::on_unpublish()
|
||||
{
|
||||
SrsDvrPlan::on_unpublish();
|
||||
|
||||
// support multiple publish.
|
||||
if (!dvr_enabled) {
|
||||
return;
|
||||
|
@ -754,6 +752,10 @@ void SrsDvrSessionPlan::on_unpublish()
|
|||
}
|
||||
|
||||
dvr_enabled = false;
|
||||
|
||||
// We should notify the on_dvr, then stop the async.
|
||||
// @see https://github.com/ossrs/srs/issues/1601
|
||||
SrsDvrPlan::on_unpublish();
|
||||
}
|
||||
|
||||
SrsDvrSegmentPlan::SrsDvrSegmentPlan()
|
||||
|
@ -815,14 +817,16 @@ void SrsDvrSegmentPlan::on_unpublish()
|
|||
{
|
||||
srs_error_t err = srs_success;
|
||||
|
||||
SrsDvrPlan::on_unpublish();
|
||||
|
||||
if ((err = segment->close()) != srs_success) {
|
||||
srs_warn("ignore err %s", srs_error_desc(err).c_str());
|
||||
srs_freep(err);
|
||||
}
|
||||
|
||||
dvr_enabled = false;
|
||||
|
||||
// We should notify the on_dvr, then stop the async.
|
||||
// @see https://github.com/ossrs/srs/issues/1601
|
||||
SrsDvrPlan::on_unpublish();
|
||||
}
|
||||
|
||||
srs_error_t SrsDvrSegmentPlan::on_audio(SrsSharedPtrMessage* shared_audio, SrsFormat* format)
|
||||
|
|
|
@ -230,7 +230,7 @@ srs_error_t SrsFFMPEG::start()
|
|||
params.push_back(ffmpeg);
|
||||
|
||||
// input params
|
||||
for (int i = 0; i < iparams.size(); i++) {
|
||||
for (int i = 0; i < (int)iparams.size(); i++) {
|
||||
string iparam = iparams.at(i);
|
||||
if (!iparam.empty()) {
|
||||
params.push_back(iparam);
|
||||
|
|
|
@ -406,7 +406,7 @@ srs_error_t SrsRtmpConn::service_cycle()
|
|||
rtmp->set_send_timeout(SRS_REPUBLISH_RECV_TIMEOUT);
|
||||
rtmp->set_recv_timeout(SRS_REPUBLISH_SEND_TIMEOUT);
|
||||
|
||||
srs_trace("rtmp: retry for republish");
|
||||
srs_info("rtmp: retry for republish");
|
||||
srs_freep(err);
|
||||
continue;
|
||||
}
|
||||
|
|
|
@ -94,11 +94,14 @@ srs_error_t SrsRtpConn::on_udp_packet(const sockaddr* from, const int fromlen, c
|
|||
}
|
||||
cache->copy(&pkt);
|
||||
cache->payload->append(pkt.payload->bytes(), pkt.payload->length());
|
||||
if (!cache->completed && pprint->can_print()) {
|
||||
if (pprint->can_print()) {
|
||||
srs_trace("<- " SRS_CONSTS_LOG_STREAM_CASTER " rtsp: rtp chunked %dB, age=%d, vt=%d/%u, sts=%u/%#x/%#x, paylod=%dB",
|
||||
nb_buf, pprint->age(), cache->version, cache->payload_type, cache->sequence_number, cache->timestamp, cache->ssrc,
|
||||
cache->payload->length()
|
||||
);
|
||||
}
|
||||
|
||||
if (!cache->completed){
|
||||
return err;
|
||||
}
|
||||
} else {
|
||||
|
@ -243,6 +246,9 @@ srs_error_t SrsRtspConn::do_cycle()
|
|||
|
||||
// retrieve ip of client.
|
||||
std::string ip = srs_get_peer_ip(srs_netfd_fileno(stfd));
|
||||
if (ip.empty() && !_srs_config->empty_ip_ok()) {
|
||||
srs_warn("empty ip for fd=%d", srs_netfd_fileno(stfd));
|
||||
}
|
||||
srs_trace("rtsp: serve %s", ip.c_str());
|
||||
|
||||
// consume all rtsp messages.
|
||||
|
@ -645,6 +651,7 @@ srs_error_t SrsRtspConn::connect()
|
|||
std::string output = output_template;
|
||||
output = srs_string_replace(output, "[app]", app);
|
||||
output = srs_string_replace(output, "[stream]", rtsp_stream);
|
||||
url = output;
|
||||
}
|
||||
|
||||
// connect host.
|
||||
|
|
|
@ -392,6 +392,11 @@ srs_error_t SrsSignalManager::start()
|
|||
sa.sa_flags = 0;
|
||||
sigaction(SRS_SIGNAL_RELOAD, &sa, NULL);
|
||||
|
||||
sa.sa_handler = SrsSignalManager::sig_catcher;
|
||||
sigemptyset(&sa.sa_mask);
|
||||
sa.sa_flags = 0;
|
||||
sigaction(SRS_SIGNAL_FAST_QUIT, &sa, NULL);
|
||||
|
||||
sa.sa_handler = SrsSignalManager::sig_catcher;
|
||||
sigemptyset(&sa.sa_mask);
|
||||
sa.sa_flags = 0;
|
||||
|
@ -407,8 +412,8 @@ srs_error_t SrsSignalManager::start()
|
|||
sa.sa_flags = 0;
|
||||
sigaction(SRS_SIGNAL_REOPEN_LOG, &sa, NULL);
|
||||
|
||||
srs_trace("signal installed, reload=%d, reopen=%d, grace_quit=%d",
|
||||
SRS_SIGNAL_RELOAD, SRS_SIGNAL_REOPEN_LOG, SRS_SIGNAL_GRACEFULLY_QUIT);
|
||||
srs_trace("signal installed, reload=%d, reopen=%d, fast_quit=%d, grace_quit=%d",
|
||||
SRS_SIGNAL_RELOAD, SRS_SIGNAL_REOPEN_LOG, SRS_SIGNAL_FAST_QUIT, SRS_SIGNAL_GRACEFULLY_QUIT);
|
||||
|
||||
if ((err = trd->start()) != srs_success) {
|
||||
return srs_error_wrap(err, "signal manager");
|
||||
|
@ -465,6 +470,7 @@ SrsServer::SrsServer()
|
|||
signal_reload = false;
|
||||
signal_persistence_config = false;
|
||||
signal_gmc_stop = false;
|
||||
signal_fast_quit = false;
|
||||
signal_gracefully_quit = false;
|
||||
pid_fd = -1;
|
||||
|
||||
|
@ -533,6 +539,48 @@ void SrsServer::dispose()
|
|||
#endif
|
||||
}
|
||||
|
||||
void SrsServer::gracefully_dispose()
|
||||
{
|
||||
_srs_config->unsubscribe(this);
|
||||
|
||||
// Always wait for a while to start.
|
||||
srs_usleep(_srs_config->get_grace_start_wait());
|
||||
srs_trace("start wait for %dms", srsu2msi(_srs_config->get_grace_start_wait()));
|
||||
|
||||
// prevent fresh clients.
|
||||
close_listeners(SrsListenerRtmpStream);
|
||||
close_listeners(SrsListenerHttpApi);
|
||||
close_listeners(SrsListenerHttpStream);
|
||||
close_listeners(SrsListenerMpegTsOverUdp);
|
||||
close_listeners(SrsListenerRtsp);
|
||||
close_listeners(SrsListenerFlv);
|
||||
|
||||
// Fast stop to notify FFMPEG to quit, wait for a while then fast kill.
|
||||
ingester->stop();
|
||||
|
||||
// Wait for connections to quit.
|
||||
// While gracefully quiting, user can requires SRS to fast quit.
|
||||
int wait_step = 1;
|
||||
while (!conns.empty() && !signal_fast_quit) {
|
||||
for (int i = 0; i < wait_step && !conns.empty() && !signal_fast_quit; i++) {
|
||||
srs_usleep(1000 * SRS_UTIME_MILLISECONDS);
|
||||
}
|
||||
|
||||
wait_step = (wait_step * 2) % 33;
|
||||
srs_trace("wait for %d conns to quit", conns.size());
|
||||
}
|
||||
|
||||
// dispose the source for hls and dvr.
|
||||
_srs_sources->dispose();
|
||||
|
||||
#ifdef SRS_AUTO_MEM_WATCH
|
||||
srs_memory_report();
|
||||
#endif
|
||||
|
||||
srs_usleep(_srs_config->get_grace_final_wait());
|
||||
srs_trace("final wait for %dms", srsu2msi(_srs_config->get_grace_final_wait()));
|
||||
}
|
||||
|
||||
srs_error_t SrsServer::initialize(ISrsServerCycle* ch)
|
||||
{
|
||||
srs_error_t err = srs_success;
|
||||
|
@ -802,19 +850,33 @@ srs_error_t SrsServer::cycle()
|
|||
srs_warn("sleep a long time for system st-threads to cleanup.");
|
||||
srs_usleep(3 * 1000 * 1000);
|
||||
srs_warn("system quit");
|
||||
#else
|
||||
// normally quit with neccessary cleanup by dispose().
|
||||
|
||||
return err;
|
||||
#endif
|
||||
|
||||
// quit normally.
|
||||
srs_warn("main cycle terminated, system quit normally.");
|
||||
dispose();
|
||||
|
||||
// fast quit, do some essential cleanup.
|
||||
if (signal_fast_quit) {
|
||||
dispose();
|
||||
srs_trace("srs disposed");
|
||||
}
|
||||
|
||||
// gracefully quit, do carefully cleanup.
|
||||
if (signal_gracefully_quit) {
|
||||
gracefully_dispose();
|
||||
srs_trace("srs gracefully quit");
|
||||
}
|
||||
|
||||
srs_trace("srs terminated");
|
||||
|
||||
// for valgrind to detect.
|
||||
srs_freep(_srs_config);
|
||||
srs_freep(_srs_log);
|
||||
|
||||
|
||||
exit(0);
|
||||
#endif
|
||||
|
||||
|
||||
return err;
|
||||
}
|
||||
|
||||
|
@ -857,9 +919,22 @@ void SrsServer::on_signal(int signo)
|
|||
#endif
|
||||
#endif
|
||||
}
|
||||
|
||||
if ((signo == SIGINT || signo == SRS_SIGNAL_GRACEFULLY_QUIT) && !signal_gracefully_quit) {
|
||||
srs_trace("sig=%d, user terminate program, gracefully quit", signo);
|
||||
|
||||
// For K8S, force to gracefully quit for gray release or canary.
|
||||
// @see https://github.com/ossrs/srs/issues/1595#issuecomment-587473037
|
||||
if (signo == SRS_SIGNAL_FAST_QUIT && _srs_config->is_force_grace_quit()) {
|
||||
srs_trace("force gracefully quit, signo=%d", signo);
|
||||
signo = SRS_SIGNAL_GRACEFULLY_QUIT;
|
||||
}
|
||||
|
||||
if ((signo == SIGINT || signo == SRS_SIGNAL_FAST_QUIT) && !signal_fast_quit) {
|
||||
srs_trace("sig=%d, user terminate program, fast quit", signo);
|
||||
signal_fast_quit = true;
|
||||
return;
|
||||
}
|
||||
|
||||
if (signo == SRS_SIGNAL_GRACEFULLY_QUIT && !signal_gracefully_quit) {
|
||||
srs_trace("sig=%d, user start gracefully quit", signo);
|
||||
signal_gracefully_quit = true;
|
||||
return;
|
||||
}
|
||||
|
@ -904,9 +979,9 @@ srs_error_t SrsServer::do_cycle()
|
|||
return srs_error_new(ERROR_ASPROCESS_PPID, "asprocess ppid changed from %d to %d", ppid, ::getppid());
|
||||
}
|
||||
|
||||
// gracefully quit for SIGINT or SIGTERM.
|
||||
if (signal_gracefully_quit) {
|
||||
srs_trace("cleanup for gracefully terminate.");
|
||||
// gracefully quit for SIGINT or SIGTERM or SIGQUIT.
|
||||
if (signal_fast_quit || signal_gracefully_quit) {
|
||||
srs_trace("cleanup for quit signal fast=%d, grace=%d", signal_fast_quit, signal_gracefully_quit);
|
||||
return err;
|
||||
}
|
||||
|
||||
|
@ -1157,6 +1232,10 @@ srs_error_t SrsServer::accept_client(SrsListenerType type, srs_netfd_t stfd)
|
|||
SrsConnection* conn = NULL;
|
||||
|
||||
if ((err = fd2conn(type, stfd, &conn)) != srs_success) {
|
||||
if (srs_error_code(err) == ERROR_SOCKET_GET_PEER_IP && _srs_config->empty_ip_ok()) {
|
||||
srs_close_stfd(stfd); srs_error_reset(err);
|
||||
return srs_success;
|
||||
}
|
||||
return srs_error_wrap(err, "fd2conn");
|
||||
}
|
||||
srs_assert(conn);
|
||||
|
|
|
@ -227,6 +227,7 @@ private:
|
|||
bool signal_reload;
|
||||
bool signal_persistence_config;
|
||||
bool signal_gmc_stop;
|
||||
bool signal_fast_quit;
|
||||
bool signal_gracefully_quit;
|
||||
// Parent pid for asprocess.
|
||||
int ppid;
|
||||
|
@ -241,6 +242,9 @@ private:
|
|||
// When SIGTERM, SRS should do cleanup, for example,
|
||||
// to stop all ingesters, cleanup HLS and dvr.
|
||||
virtual void dispose();
|
||||
// Close listener to stop accepting new connections,
|
||||
// then wait and quit when all connections finished.
|
||||
virtual void gracefully_dispose();
|
||||
// server startup workflow, @see run_master()
|
||||
public:
|
||||
// Initialize server with callback handler ch.
|
||||
|
@ -260,12 +264,13 @@ public:
|
|||
// The signal manager convert signal to io message,
|
||||
// whatever, we will got the signo like the orignal signal(int signo) handler.
|
||||
// @param signo the signal number from user, where:
|
||||
// SRS_SIGNAL_GRACEFULLY_QUIT, the SIGTERM, dispose then quit.
|
||||
// SRS_SIGNAL_FAST_QUIT, the SIGTERM, do essential dispose then quit.
|
||||
// SRS_SIGNAL_GRACEFULLY_QUIT, the SIGQUIT, do careful dispose then quit.
|
||||
// SRS_SIGNAL_REOPEN_LOG, the SIGUSR1, reopen the log file.
|
||||
// SRS_SIGNAL_RELOAD, the SIGHUP, reload the config.
|
||||
// SRS_SIGNAL_PERSISTENCE_CONFIG, application level signal, persistence config to file.
|
||||
// @remark, for SIGINT:
|
||||
// no gmc, directly exit.
|
||||
// no gmc, fast quit, do essential dispose then quit.
|
||||
// for gmc, set the variable signal_gmc_stop, the cycle will return and cleanup for gmc.
|
||||
// @remark, maybe the HTTP RAW API will trigger the on_signal() also.
|
||||
virtual void on_signal(int signo);
|
||||
|
|
|
@ -74,7 +74,7 @@ void srs_memory_report()
|
|||
std::map<void*, SrsMemoryObject*>::iterator it;
|
||||
for (it = _srs_ptrs.begin(); it != _srs_ptrs.end(); ++it) {
|
||||
SrsMemoryObject* obj = it->second;
|
||||
printf(" %s: %#"PRIx64", %dB\n", obj->category.c_str(), (int64_t)obj->ptr, obj->size);
|
||||
printf(" %s: %#" PRIx64 ", %dB\n", obj->category.c_str(), (int64_t)obj->ptr, obj->size);
|
||||
total += obj->size;
|
||||
}
|
||||
|
||||
|
|
|
@ -24,6 +24,6 @@
|
|||
#ifndef SRS_CORE_VERSION3_HPP
|
||||
#define SRS_CORE_VERSION3_HPP
|
||||
|
||||
#define SRS_VERSION3_REVISION 116
|
||||
#define SRS_VERSION3_REVISION 123
|
||||
|
||||
#endif
|
||||
|
|
|
@ -24,6 +24,6 @@
|
|||
#ifndef SRS_CORE_VERSION4_HPP
|
||||
#define SRS_CORE_VERSION4_HPP
|
||||
|
||||
#define SRS_VERSION4_REVISION 4
|
||||
#define SRS_VERSION4_REVISION 9
|
||||
|
||||
#endif
|
||||
|
|
|
@ -124,8 +124,15 @@
|
|||
#define SRS_SIGNAL_RELOAD SIGHUP
|
||||
// Reopen the log file.
|
||||
#define SRS_SIGNAL_REOPEN_LOG SIGUSR1
|
||||
// The signal for srs to gracefully quit, do dispose then exit.
|
||||
#define SRS_SIGNAL_GRACEFULLY_QUIT SIGTERM
|
||||
// For gracefully upgrade, start new SRS and gracefully quit old one.
|
||||
// @see https://github.com/ossrs/srs/issues/1579
|
||||
// TODO: Not implemented.
|
||||
#define SRS_SIGNAL_UPGRADE SIGUSR2
|
||||
// The signal for srs to fast quit, do essential dispose then exit.
|
||||
#define SRS_SIGNAL_FAST_QUIT SIGTERM
|
||||
// The signal for srs to gracefully quit, do carefully dispose then exit.
|
||||
// @see https://github.com/ossrs/srs/issues/1579
|
||||
#define SRS_SIGNAL_GRACEFULLY_QUIT SIGQUIT
|
||||
|
||||
// The application level signals.
|
||||
// Persistence the config in memory to config file.
|
||||
|
@ -146,7 +153,7 @@
|
|||
// Downloading speed-up, play to edge, ingest from origin
|
||||
#define SRS_CONSTS_LOG_EDGE_PLAY "EIG"
|
||||
// Uploading speed-up, publish to edge, foward to origin
|
||||
#define SRS_CONSTS_LOG_EDGE_PUBLISH "EFW"
|
||||
#define SRS_CONSTS_LOG_EDGE_PUBLISH "EPB"
|
||||
// The edge/origin forwarder.
|
||||
#define SRS_CONSTS_LOG_FOWARDER "FWR"
|
||||
// Play stream on edge/origin.
|
||||
|
|
|
@ -77,8 +77,11 @@
|
|||
#ifndef SRS_HIJACK_IO
|
||||
struct SrsBlockSyncSocket
|
||||
{
|
||||
int family;
|
||||
SOCKET fd;
|
||||
int family;
|
||||
SOCKET fdv4;
|
||||
SOCKET fdv6;
|
||||
// Bytes transmit.
|
||||
int64_t rbytes;
|
||||
int64_t sbytes;
|
||||
// The send/recv timeout in ms.
|
||||
|
@ -86,15 +89,26 @@ struct SrsBlockSyncSocket
|
|||
int64_t stm;
|
||||
|
||||
SrsBlockSyncSocket() {
|
||||
family = AF_UNSPEC;
|
||||
stm = rtm = SRS_UTIME_NO_TIMEOUT;
|
||||
rbytes = sbytes = 0;
|
||||
|
||||
SOCKET_RESET(fd);
|
||||
SOCKET_RESET(fdv4);
|
||||
SOCKET_RESET(fdv6);
|
||||
SOCKET_SETUP();
|
||||
}
|
||||
|
||||
virtual ~SrsBlockSyncSocket() {
|
||||
SOCKET_CLOSE(fd);
|
||||
if (SOCKET_VALID(fd)) {
|
||||
SOCKET_CLOSE(fd);
|
||||
}
|
||||
if (SOCKET_VALID(fdv4)) {
|
||||
SOCKET_CLOSE(fdv4);
|
||||
}
|
||||
if (SOCKET_VALID(fdv6)) {
|
||||
SOCKET_CLOSE(fdv6);
|
||||
}
|
||||
SOCKET_CLEANUP();
|
||||
}
|
||||
};
|
||||
|
@ -112,19 +126,17 @@ int srs_hijack_io_create_socket(srs_hijack_io_t ctx, srs_rtmp_t owner)
|
|||
{
|
||||
SrsBlockSyncSocket* skt = (SrsBlockSyncSocket*)ctx;
|
||||
|
||||
skt->family = AF_INET6;
|
||||
skt->fd = ::socket(skt->family, SOCK_STREAM, 0); // Try IPv6 first.
|
||||
if (!SOCKET_VALID(skt->fd)) {
|
||||
skt->family = AF_INET;
|
||||
skt->fd = ::socket(skt->family, SOCK_STREAM, 0); // Try IPv4 instead, if IPv6 fails.
|
||||
}
|
||||
if (!SOCKET_VALID(skt->fd)) {
|
||||
skt->family = AF_UNSPEC;
|
||||
skt->fdv4 = ::socket(AF_INET, SOCK_STREAM, 0);
|
||||
skt->fdv6 = ::socket(AF_INET6, SOCK_STREAM, 0);
|
||||
if (!SOCKET_VALID(skt->fdv4) && !SOCKET_VALID(skt->fdv4)) {
|
||||
return ERROR_SOCKET_CREATE;
|
||||
}
|
||||
|
||||
// No TCP cache.
|
||||
int v = 1;
|
||||
setsockopt(skt->fd, IPPROTO_TCP, TCP_NODELAY, &v, sizeof(v));
|
||||
setsockopt(skt->fdv4, IPPROTO_TCP, TCP_NODELAY, &v, sizeof(v));
|
||||
setsockopt(skt->fdv6, IPPROTO_TCP, TCP_NODELAY, &v, sizeof(v));
|
||||
|
||||
return ERROR_SUCCESS;
|
||||
}
|
||||
|
@ -137,7 +149,7 @@ int srs_hijack_io_connect(srs_hijack_io_t ctx, const char* server_ip, int port)
|
|||
|
||||
addrinfo hints;
|
||||
memset(&hints, 0, sizeof(hints));
|
||||
hints.ai_family = skt->family;
|
||||
hints.ai_family = AF_UNSPEC;
|
||||
hints.ai_socktype = SOCK_STREAM;
|
||||
|
||||
addrinfo* r = NULL;
|
||||
|
@ -145,7 +157,16 @@ int srs_hijack_io_connect(srs_hijack_io_t ctx, const char* server_ip, int port)
|
|||
if(getaddrinfo(server_ip, sport, (const addrinfo*)&hints, &r)) {
|
||||
return ERROR_SOCKET_CONNECT;
|
||||
}
|
||||
|
||||
|
||||
skt->family = r->ai_family;
|
||||
if (r->ai_family == AF_INET6) {
|
||||
skt->fd = skt->fdv6;
|
||||
SOCKET_RESET(skt->fdv6);
|
||||
} else {
|
||||
skt->fd = skt->fdv4;
|
||||
SOCKET_RESET(skt->fdv4);
|
||||
}
|
||||
|
||||
if(::connect(skt->fd, r->ai_addr, r->ai_addrlen) < 0){
|
||||
return ERROR_SOCKET_CONNECT;
|
||||
}
|
||||
|
|
|
@ -1105,6 +1105,7 @@ extern void srs_hijack_io_destroy(srs_hijack_io_t ctx);
|
|||
* create socket, not connect yet.
|
||||
* @param owner, the rtmp context which create this socket.
|
||||
* @return 0, success; otherswise, failed.
|
||||
* TODO: FIXME: Incompatible API for https://github.com/ossrs/srs/blob/2.0release/trunk/src/libs/srs_librtmp.hpp#L989
|
||||
*/
|
||||
extern int srs_hijack_io_create_socket(srs_hijack_io_t ctx, srs_rtmp_t owner);
|
||||
/**
|
||||
|
@ -1156,6 +1157,7 @@ extern int srs_hijack_io_writev(srs_hijack_io_t ctx, const iovec *iov, int iov_s
|
|||
/**
|
||||
* whether the timeout is never timeout in ms.
|
||||
* @return 0, with timeout specified; otherwise, never timeout.
|
||||
* TODO: FIXME: Incompatible API for https://github.com/ossrs/srs/blob/2.0release/trunk/src/libs/srs_librtmp.hpp#L1039
|
||||
*/
|
||||
extern int srs_hijack_io_is_never_timeout(srs_hijack_io_t ctx, int64_t tm);
|
||||
/**
|
||||
|
|
|
@ -122,7 +122,7 @@ void srs_discovery_tc_url(string tcUrl, string& schema, string& host, string& vh
|
|||
srs_vhost_resolve(vhost, stream, param);
|
||||
|
||||
// Ignore when the param only contains the default vhost.
|
||||
if (param == "?vhost="SRS_CONSTS_RTMP_DEFAULT_VHOST) {
|
||||
if (param == "?vhost=" SRS_CONSTS_RTMP_DEFAULT_VHOST) {
|
||||
param = "";
|
||||
}
|
||||
}
|
||||
|
|
|
@ -3,6 +3,8 @@
|
|||
#include "stringex.hpp"
|
||||
#include <vector>
|
||||
|
||||
#include <srs_app_config.hpp>
|
||||
|
||||
bool is_streamid_valid(const std::string& streamid) {
|
||||
if (streamid.empty()) {
|
||||
return false;
|
||||
|
@ -71,7 +73,7 @@ bool get_streamid_info(const std::string& streamid, int& mode, std::string& url_
|
|||
if (pos != 0) {
|
||||
pos = streamid.find("/");
|
||||
if (pos == streamid.npos) {
|
||||
url_subpath = "live/" + streamid;
|
||||
url_subpath = _srs_config->get_default_app_name() + "/" + streamid;
|
||||
return true;
|
||||
}
|
||||
url_subpath = streamid;
|
||||
|
|
|
@ -256,7 +256,12 @@ void srt_server::on_work()
|
|||
}
|
||||
}
|
||||
}
|
||||
|
||||
// New API at 2020-01-28, >1.4.1
|
||||
// @see https://github.com/Haivision/srt/commit/b8c70ec801a56bea151ecce9c09c4ebb720c2f68#diff-fb66028e8746fea578788532533a296bR786
|
||||
#if (SRT_VERSION_MAJOR<<24 | SRT_VERSION_MINOR<<16 | SRT_VERSION_PATCH<<8) > 0x01040100
|
||||
srt_epoll_clear_usocks(_pollid);
|
||||
#endif
|
||||
}
|
||||
|
||||
SrtServerAdapter::SrtServerAdapter()
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue