From aa4bcf89d78b4e3cb5ba2a502c6ddcec8eb867b1 Mon Sep 17 00:00:00 2001
From: Roman Arutyunyan <arut@qip.ru>
Date: Mon, 16 Dec 2013 12:58:25 +0400
Subject: [PATCH] fixed dash/hls cleanup when recorder{} block exists

---
 dash/ngx_rtmp_dash_module.c | 57 ++++++++++++++++++-----------------
 hls/ngx_rtmp_hls_module.c   | 59 ++++++++++++++++++-------------------
 2 files changed, 57 insertions(+), 59 deletions(-)

diff --git a/dash/ngx_rtmp_dash_module.c b/dash/ngx_rtmp_dash_module.c
index 2a2e3ff..e6e4779 100644
--- a/dash/ngx_rtmp_dash_module.c
+++ b/dash/ngx_rtmp_dash_module.c
@@ -1454,7 +1454,6 @@ ngx_rtmp_dash_merge_app_conf(ngx_conf_t *cf, void *parent, void *child)
     ngx_conf_merge_value(conf->dash, prev->dash, 0);
     ngx_conf_merge_msec_value(conf->fraglen, prev->fraglen, 5000);
     ngx_conf_merge_msec_value(conf->playlen, prev->playlen, 30000);
-    ngx_conf_merge_str_value(conf->path, prev->path, "");
     ngx_conf_merge_value(conf->cleanup, prev->cleanup, 1);
     ngx_conf_merge_value(conf->nested, prev->nested, 0);
 
@@ -1464,36 +1463,36 @@ ngx_rtmp_dash_merge_app_conf(ngx_conf_t *cf, void *parent, void *child)
 
     /* schedule cleanup */
 
-    if (conf->path.len == 0 || !conf->cleanup) {
-        return NGX_CONF_OK;
+    if (conf->dash && conf->path.len && conf->cleanup) {
+        if (conf->path.data[conf->path.len - 1] == '/') {
+            conf->path.len--;
+        }
+
+        cleanup = ngx_pcalloc(cf->pool, sizeof(*cleanup));
+        if (cleanup == NULL) {
+            return NGX_CONF_ERROR;
+        }
+
+        cleanup->path = conf->path;
+        cleanup->playlen = conf->playlen;
+
+        conf->slot = ngx_pcalloc(cf->pool, sizeof(*conf->slot));
+        if (conf->slot == NULL) {
+            return NGX_CONF_ERROR;
+        }
+
+        conf->slot->manager = ngx_rtmp_dash_cleanup;
+        conf->slot->name = conf->path;
+        conf->slot->data = cleanup;
+        conf->slot->conf_file = cf->conf_file->file.name.data;
+        conf->slot->line = cf->conf_file->line;
+
+        if (ngx_add_path(cf, &conf->slot) != NGX_OK) {
+            return NGX_CONF_ERROR;
+        }
     }
 
-    if (conf->path.data[conf->path.len - 1] == '/') {
-        conf->path.len--;
-    }
-
-    cleanup = ngx_pcalloc(cf->pool, sizeof(*cleanup));
-    if (cleanup == NULL) {
-        return NGX_CONF_ERROR;
-    }
-
-    cleanup->path = conf->path;
-    cleanup->playlen = conf->playlen;
-
-    conf->slot = ngx_pcalloc(cf->pool, sizeof(*conf->slot));
-    if (conf->slot == NULL) {
-        return NGX_CONF_ERROR;
-    }
-
-    conf->slot->manager = ngx_rtmp_dash_cleanup;
-    conf->slot->name = conf->path;
-    conf->slot->data = cleanup;
-    conf->slot->conf_file = cf->conf_file->file.name.data;
-    conf->slot->line = cf->conf_file->line;
-
-    if (ngx_add_path(cf, &conf->slot) != NGX_OK) {
-        return NGX_CONF_ERROR;
-    }
+    ngx_conf_merge_str_value(conf->path, prev->path, "");
 
     return NGX_CONF_OK;
 }
diff --git a/hls/ngx_rtmp_hls_module.c b/hls/ngx_rtmp_hls_module.c
index 8462150..30a538e 100644
--- a/hls/ngx_rtmp_hls_module.c
+++ b/hls/ngx_rtmp_hls_module.c
@@ -2144,7 +2144,6 @@ ngx_rtmp_hls_merge_app_conf(ngx_conf_t *cf, void *parent, void *child)
     ngx_conf_merge_msec_value(conf->muxdelay, prev->muxdelay, 700);
     ngx_conf_merge_msec_value(conf->sync, prev->sync, 2);
     ngx_conf_merge_msec_value(conf->playlen, prev->playlen, 30000);
-    ngx_conf_merge_str_value(conf->path, prev->path, "");
     ngx_conf_merge_value(conf->continuous, prev->continuous, 1);
     ngx_conf_merge_value(conf->nested, prev->nested, 0);
     ngx_conf_merge_uint_value(conf->naming, prev->naming,
@@ -2166,38 +2165,38 @@ ngx_rtmp_hls_merge_app_conf(ngx_conf_t *cf, void *parent, void *child)
 
     /* schedule cleanup */
 
-    if (conf->path.len == 0 || !conf->cleanup ||
-        conf->type == NGX_RTMP_HLS_TYPE_EVENT)
+    if (conf->hls && conf->path.len && conf->cleanup &&
+        conf->type != NGX_RTMP_HLS_TYPE_EVENT)
     {
-        return NGX_CONF_OK;
+        if (conf->path.data[conf->path.len - 1] == '/') {
+            conf->path.len--;
+        }
+
+        cleanup = ngx_pcalloc(cf->pool, sizeof(*cleanup));
+        if (cleanup == NULL) {
+            return NGX_CONF_ERROR;
+        }
+
+        cleanup->path = conf->path;
+        cleanup->playlen = conf->playlen;
+
+        conf->slot = ngx_pcalloc(cf->pool, sizeof(*conf->slot));
+        if (conf->slot == NULL) {
+            return NGX_CONF_ERROR;
+        }
+
+        conf->slot->manager = ngx_rtmp_hls_cleanup;
+        conf->slot->name = conf->path;
+        conf->slot->data = cleanup;
+        conf->slot->conf_file = cf->conf_file->file.name.data;
+        conf->slot->line = cf->conf_file->line;
+
+        if (ngx_add_path(cf, &conf->slot) != NGX_OK) {
+            return NGX_CONF_ERROR;
+        }
     }
 
-    if (conf->path.data[conf->path.len - 1] == '/') {
-        conf->path.len--;
-    }
-
-    cleanup = ngx_pcalloc(cf->pool, sizeof(*cleanup));
-    if (cleanup == NULL) {
-        return NGX_CONF_ERROR;
-    }
-
-    cleanup->path = conf->path;
-    cleanup->playlen = conf->playlen;
-
-    conf->slot = ngx_pcalloc(cf->pool, sizeof(*conf->slot));
-    if (conf->slot == NULL) {
-        return NGX_CONF_ERROR;
-    }
-
-    conf->slot->manager = ngx_rtmp_hls_cleanup;
-    conf->slot->name = conf->path;
-    conf->slot->data = cleanup;
-    conf->slot->conf_file = cf->conf_file->file.name.data;
-    conf->slot->line = cf->conf_file->line;
-
-    if (ngx_add_path(cf, &conf->slot) != NGX_OK) {
-        return NGX_CONF_ERROR;
-    }
+    ngx_conf_merge_str_value(conf->path, prev->path, "");
 
     return NGX_CONF_OK;
 }