merge srs2, support oryx

@@ -55,6 +55,19 @@ utc_time            off;
 # default: 10000
 # default: 10000
 pithy_print_ms      10000;
 pithy_print_ms      10000;
 
 
+# the work dir for server, to chdir(work_dir) when not empty or "./"
+# user can config this directory to change the dir.
+# @reamrk do not support reload.
+# default: ./
+work_dir ./;
+# whether quit when parent process changed,
+# used for supervisor mode(not daemon), srs should always quit when 
+# supervisor process exited.
+# @remark conflict with daemon, error when both daemon and asprocess are on.
+# @reamrk do not support reload.
+# default: off
+asprocess off;
+
 #############################################################################################
 #############################################################################################
 # heartbeat/stats sections
 # heartbeat/stats sections
 #############################################################################################
 #############################################################################################

@@ -3536,7 +3536,7 @@ int SrsConfig::check_config()
             && n != "max_connections" && n != "daemon" && n != "heartbeat"
             && n != "max_connections" && n != "daemon" && n != "heartbeat"
             && n != "http_api" && n != "stats" && n != "vhost" && n != "pithy_print_ms"
             && n != "http_api" && n != "stats" && n != "vhost" && n != "pithy_print_ms"
             && n != "http_server" && n != "stream_caster" && n != "kafka"
             && n != "http_server" && n != "stream_caster" && n != "kafka"
-            && n != "utc_time" && n != "work_dir"
+            && n != "utc_time" && n != "work_dir" && n != "asprocess"
         ) {
         ) {
             ret = ERROR_SYSTEM_CONFIG_INVALID;
             ret = ERROR_SYSTEM_CONFIG_INVALID;
             srs_error("unsupported directive %s, ret=%d", n.c_str(), ret);
             srs_error("unsupported directive %s, ret=%d", n.c_str(), ret);
@@ -4065,6 +4065,13 @@ int SrsConfig::check_config()
         // TODO: FIXME: required http server when hls storage is ram or both.
         // TODO: FIXME: required http server when hls storage is ram or both.
     }
     }
     
     
+    // asprocess conflict with daemon
+    if (get_asprocess() && get_deamon()) {
+        ret = ERROR_SYSTEM_CONFIG_INVALID;
+        srs_error("daemon conflict with asprocess, ret=%d", ret);
+        return ret;
+    }
+    
     return ret;
     return ret;
 }
 }
 
 
@@ -4188,13 +4195,27 @@ bool SrsConfig::get_utc_time()
 
 
 string SrsConfig::get_work_dir() {
 string SrsConfig::get_work_dir() {
     static string DEFAULT = "";
     static string DEFAULT = "";
-
+    
     SrsConfDirective* conf = root->get("work_dir");
     SrsConfDirective* conf = root->get("work_dir");
     if( !conf || conf->arg0().empty()) {
     if( !conf || conf->arg0().empty()) {
         return DEFAULT;
         return DEFAULT;
     }
     }
 
 
     return conf->arg0();
     return conf->arg0();
+    
+    return conf->arg0();
+}
+
+bool SrsConfig::get_asprocess()
+{
+    static bool DEFAULT = false;
+    
+    SrsConfDirective* conf = root->get("asprocess");
+    if (!conf || conf->arg0().empty()) {
+        return DEFAULT;
+    }
+    
+    return SRS_CONF_PERFER_FALSE(conf->arg0());
 }
 }
 
 
 vector<SrsConfDirective*> SrsConfig::get_stream_casters()
 vector<SrsConfDirective*> SrsConfig::get_stream_casters()

@@ -618,6 +618,8 @@ public:
      * ignore if empty string.
      * ignore if empty string.
      */
      */
     virtual std::string         get_work_dir();
     virtual std::string         get_work_dir();
+    // whether use asprocess mode.
+    virtual bool                get_asprocess();
 // stream_caster section
 // stream_caster section
 public:
 public:
     /**
     /**

@@ -494,6 +494,7 @@ SrsServer::SrsServer()
     signal_manager = NULL;
     signal_manager = NULL;
     
     
     handler = NULL;
     handler = NULL;
+    ppid = ::getppid();
     
     
     // donot new object in constructor,
     // donot new object in constructor,
     // for some global instance is not ready now,
     // for some global instance is not ready now,
@@ -653,7 +654,16 @@ int SrsServer::initialize_st()
     
     
     // set current log id.
     // set current log id.
     _srs_context->generate_id();
     _srs_context->generate_id();
-    srs_trace("server main cid=%d", _srs_context->get_id());
+    
+    // check asprocess.
+    bool asprocess = _srs_config->get_asprocess();
+    if (ppid == 1) {
+        ret = ERROR_SYSTEM_ASSERT_FAILED;
+        srs_error("for asprocess, ppid should never be init(1), ret=%d", ret);
+        return ret;
+    }
+    srs_trace("server main cid=%d, pid=%d, ppid=%d, asprocess=%d",
+        _srs_context->get_id(), ::getpid(), ppid, asprocess);
     
     
     return ret;
     return ret;
 }
 }
@@ -964,6 +974,9 @@ int SrsServer::do_cycle()
     max = srs_max(max, SRS_SYS_NETWORK_RTMP_SERVER_RESOLUTION_TIMES);
     max = srs_max(max, SRS_SYS_NETWORK_RTMP_SERVER_RESOLUTION_TIMES);
 #endif
 #endif
     
     
+    // for asprocess.
+    bool asprocess = _srs_config->get_asprocess();
+    
     // the deamon thread, update the time cache
     // the deamon thread, update the time cache
     // TODO: FIXME: use SrsHourGlass.
     // TODO: FIXME: use SrsHourGlass.
     while (true) {
     while (true) {
@@ -981,7 +994,13 @@ int SrsServer::do_cycle()
         for (int i = 0; i < dynamic_max; i++) {
         for (int i = 0; i < dynamic_max; i++) {
             st_usleep(SRS_SYS_CYCLE_INTERVAL * 1000);
             st_usleep(SRS_SYS_CYCLE_INTERVAL * 1000);
             
             
-            // gracefully quit for SIGINT or SIGTERM(SRS_SIGNAL_GRACEFULLY_QUIT).
+            // asprocess check.
+            if (asprocess && ::getppid() != ppid) {
+                srs_warn("asprocess ppid changed from %d to %d", ppid, ::getppid());
+                return ret;
+            }
+            
+            // gracefully quit for SIGINT or SIGTERM.
             if (signal_gracefully_quit) {
             if (signal_gracefully_quit) {
                 srs_trace("cleanup for gracefully terminate.");
                 srs_trace("cleanup for gracefully terminate.");
                 return ret;
                 return ret;

@@ -288,6 +288,8 @@ private:
     bool signal_persistence_config;
     bool signal_persistence_config;
     bool signal_gmc_stop;
     bool signal_gmc_stop;
     bool signal_gracefully_quit;
     bool signal_gracefully_quit;
+    // parent pid for asprocess.
+    int ppid;
 public:
 public:
     SrsServer();
     SrsServer();
     virtual ~SrsServer();
     virtual ~SrsServer();

@@ -31,7 +31,7 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // current release version
 // current release version
 #define VERSION_MAJOR       3
 #define VERSION_MAJOR       3
 #define VERSION_MINOR       0
 #define VERSION_MINOR       0
-#define VERSION_REVISION    217
+#define VERSION_REVISION    218
 
 
 // generated by configure, only macros.
 // generated by configure, only macros.
 #include <srs_auto_headers.hpp>
 #include <srs_auto_headers.hpp>

@@ -264,7 +264,7 @@ int main(int argc, char** argv)
 
 
     // change the work dir and set cwd.
     // change the work dir and set cwd.
     string cwd = _srs_config->get_work_dir();
     string cwd = _srs_config->get_work_dir();
-    if (!cwd.empty() && (ret = chdir(cwd.c_str())) != ERROR_SUCCESS) {
+    if (!cwd.empty() && cwd != "./" && (ret = chdir(cwd.c_str())) != ERROR_SUCCESS) {
         srs_error("change cwd to %s failed. ret=%d", cwd.c_str(), ret);
         srs_error("change cwd to %s failed. ret=%d", cwd.c_str(), ret);
         return ret;
         return ret;
     }
     }