support dolphin

@@ -364,6 +364,8 @@ int SrsConfDirective::read_token(SrsConfigBuffer* buffer, vector<string>& args,
 
 
 SrsConfig::SrsConfig()
 SrsConfig::SrsConfig()
 {
 {
+    dolphin = false;
+    
     show_help = false;
     show_help = false;
     show_version = false;
     show_version = false;
     test_conf = false;
     test_conf = false;
@@ -378,6 +380,25 @@ SrsConfig::~SrsConfig()
     srs_freep(root);
     srs_freep(root);
 }
 }
 
 
+bool SrsConfig::is_dolphin()
+{
+    return dolphin;
+}
+
+void SrsConfig::set_config_directive(SrsConfDirective* parent, string dir, string value)
+{
+    SrsConfDirective* d = parent->get(dir);
+    
+    if (!d) {
+        d = new SrsConfDirective();
+        d->name = dir;
+        parent->directives.push_back(d);
+    }
+    
+    d->args.clear();
+    d->args.push_back(value);
+}
+
 void SrsConfig::subscribe(ISrsReloadHandler* handler)
 void SrsConfig::subscribe(ISrsReloadHandler* handler)
 {
 {
     std::vector<ISrsReloadHandler*>::iterator it;
     std::vector<ISrsReloadHandler*>::iterator it;
@@ -1260,6 +1281,19 @@ int SrsConfig::parse_argv(int& i, char** argv)
                 show_help = false;
                 show_help = false;
                 test_conf = true;
                 test_conf = true;
                 break;
                 break;
+            case 'p':
+                dolphin = true;
+                if (*p) {
+                    dolphin_port = p;
+                    continue;
+                }
+                if (argv[++i]) {
+                    dolphin_port = argv[i];
+                    continue;
+                }
+                ret = ERROR_SYSTEM_CONFIG_INVALID;
+                srs_error("option \"-p\" requires params, ret=%d", ret);
+                return ret;
             case 'v':
             case 'v':
             case 'V':
             case 'V':
                 show_help = false;
                 show_help = false;
@@ -1269,11 +1303,11 @@ int SrsConfig::parse_argv(int& i, char** argv)
                 show_help = false;
                 show_help = false;
                 if (*p) {
                 if (*p) {
                     config_file = p;
                     config_file = p;
-                    return ret;
+                    continue;
                 }
                 }
                 if (argv[++i]) {
                 if (argv[++i]) {
                     config_file = argv[i];
                     config_file = argv[i];
-                    return ret;
+                    continue;
                 }
                 }
                 ret = ERROR_SYSTEM_CONFIG_INVALID;
                 ret = ERROR_SYSTEM_CONFIG_INVALID;
                 srs_error("option \"-c\" requires parameter, ret=%d", ret);
                 srs_error("option \"-c\" requires parameter, ret=%d", ret);
@@ -1844,6 +1878,14 @@ int SrsConfig::parse_buffer(SrsConfigBuffer* buffer)
     if ((ret = root->parse(buffer)) != ERROR_SUCCESS) {
     if ((ret = root->parse(buffer)) != ERROR_SUCCESS) {
         return ret;
         return ret;
     }
     }
+    
+    // mock by dolphin mode.
+    // for the dolphin will start srs with specified params.
+    if (dolphin) {
+        set_config_directive(root, "listen", dolphin_port);
+        set_config_directive(root, "daemon", "off");
+        set_config_directive(root, "srs_log_tank", "console");
+    }
 
 
     return ret;
     return ret;
 }
 }

@@ -267,6 +267,12 @@ class SrsConfig
 // user command
 // user command
 private:
 private:
     /**
     /**
+     * whether srs is run in dolphin mode.
+     * @see https://github.com/simple-rtmp-server/srs-dolphin
+     */
+    bool dolphin;
+    std::string dolphin_port;
+    /**
     * whether show help and exit.
     * whether show help and exit.
     */
     */
     bool show_help;
     bool show_help;
@@ -309,6 +315,14 @@ private:
 public:
 public:
     SrsConfig();
     SrsConfig();
     virtual ~SrsConfig();
     virtual ~SrsConfig();
+// dolphin
+public:
+    /**
+     * whether srs is in dolphin mode.
+     */
+    virtual bool is_dolphin();
+private:
+    virtual void set_config_directive(SrsConfDirective* parent, std::string dir, std::string value);
 // reload
 // reload
 public:
 public:
     /**
     /**

@@ -639,6 +639,11 @@ int SrsServer::acquire_pid_file()
 {
 {
     int ret = ERROR_SUCCESS;
     int ret = ERROR_SUCCESS;
     
     
+    // when srs in dolphin mode, no need the pid file.
+    if (_srs_config->is_dolphin()) {
+        return ret;
+    }
+    
     std::string pid_file = _srs_config->get_pid_file();
     std::string pid_file = _srs_config->get_pid_file();
     
     
     // -rw-r--r-- 
     // -rw-r--r--