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

Always enable SRS_Ingest

Browse source
This commit is contained in:
winlin 2018-12-22 20:30:13 +08:00
parent c6844527fb
commit aa1a5442f9
9 changed files with 3 additions and 130 deletions
Download patch file Download diff file Expand all files Collapse all files

10
trunk/src/app/srs_app_config.cpp
View file

@ -3895,16 +3895,6 @@ srs_error_t SrsConfig::check_normal_config()
if (get_hls_enabled(vhost->arg0())) {
srs_warn("can't enable vhost.hls of %s", vhost->arg0().c_str());
}
#ifndef SRS_AUTO_INGEST
vector<SrsConfDirective*> ingesters = get_ingesters(vhost->arg0());
for (int j = 0; j < (int)ingesters.size(); j++) {
SrsConfDirective* ingest = ingesters[j];
if (get_ingest_enabled(ingest)) {
srs_warn("cant' enable vhost.ingest.%s of %s",
ingest->arg0().c_str(), vhost->arg0().c_str());
}
}
#endif
// TODO: FIXME: required http server when hls storage is ram or both.
}

4
trunk/src/app/srs_app_http_api.cpp
View file

@ -600,11 +600,7 @@ srs_error_t SrsGoApiFeatures::serve_http(ISrsHttpResponseWriter* w, ISrsHttpMess
features->set("httpd", SrsJsonAny::boolean(true));
features->set("dvr", SrsJsonAny::boolean(true));
features->set("transcode", SrsJsonAny::boolean(true));
#ifdef SRS_AUTO_INGEST
features->set("ingest", SrsJsonAny::boolean(true));
#else
features->set("ingest", SrsJsonAny::boolean(false));
#endif
features->set("stat", SrsJsonAny::boolean(true));
#ifdef SRS_AUTO_NGINX
features->set("nginx", SrsJsonAny::boolean(true));

4
trunk/src/app/srs_app_ingest.cpp
View file

@ -23,8 +23,6 @@
#include <srs_app_ingest.hpp>
#ifdef SRS_AUTO_INGEST
#include <stdlib.h>
using namespace std;
@ -570,5 +568,3 @@ srs_error_t SrsIngester::on_reload_listen()
return srs_success;
}
#endif

3
trunk/src/app/srs_app_ingest.hpp
View file

@ -26,8 +26,6 @@
#include <srs_core.hpp>
#ifdef SRS_AUTO_INGEST
#include <vector>
#include <srs_app_thread.hpp>
@ -115,5 +113,4 @@ public:
};
#endif
#endif

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

@ -485,10 +485,7 @@ SrsServer::SrsServer()
http_api_mux = new SrsHttpServeMux();
http_server = new SrsHttpServer(this);
http_heartbeat = new SrsHttpHeartbeat();
#ifdef SRS_AUTO_INGEST
ingester = new SrsIngester();
#endif
}
SrsServer::~SrsServer()
@ -505,10 +502,7 @@ void SrsServer::destroy()
srs_freep(http_api_mux);
srs_freep(http_server);
srs_freep(http_heartbeat);
#ifdef SRS_AUTO_INGEST
srs_freep(ingester);
#endif
if (pid_fd > 0) {
::close(pid_fd);
@ -810,11 +804,9 @@ srs_error_t SrsServer::ingest()
{
srs_error_t err = srs_success;
#ifdef SRS_AUTO_INGEST
if ((err = ingester->start()) != srs_success) {
return srs_error_wrap(err, "ingest start");
}
#endif
return err;
}

2
trunk/src/app/srs_app_server.hpp
View file

@ -243,9 +243,7 @@ private:
SrsHttpServeMux* http_api_mux;
SrsHttpServer* http_server;
SrsHttpHeartbeat* http_heartbeat;
#ifdef SRS_AUTO_INGEST
SrsIngester* ingester;
#endif
SrsCoroutineManager* conn_manager;
private:
/**

2
trunk/src/main/srs_main_server.cpp
View file

@ -228,7 +228,7 @@ void show_macro_features()
// trans(transcode)
ss << ", trans:" << srs_bool2switch(true);
// inge(ingest)
ss << ", inge:" << srs_bool2switch(SRS_AUTO_INGEST_BOOL);
ss << ", inge:" << srs_bool2switch(true);
ss << ", kafka:" << srs_bool2switch(SRS_AUTO_KAFKA_BOOL);
ss << ", stat:" << srs_bool2switch(true);
ss << ", nginx:" << srs_bool2switch(SRS_AUTO_NGINX_BOOL);