From 745b0494b15cea3cdd2e91a166e189485a798764 Mon Sep 17 00:00:00 2001
From: Roman Arutyunyan <arut@qip.ru>
Date: Thu, 15 Nov 2012 16:46:44 +0400
Subject: [PATCH] added NetStream.Record.Failed

---
 ngx_rtmp_record_module.c | 21 +++++++++++++++++++++
 1 file changed, 21 insertions(+)

diff --git a/ngx_rtmp_record_module.c b/ngx_rtmp_record_module.c
index d355e23..f535d52 100644
--- a/ngx_rtmp_record_module.c
+++ b/ngx_rtmp_record_module.c
@@ -385,6 +385,19 @@ ngx_rtmp_record_make_path(ngx_rtmp_session_t *s,
 }
 
 
+static void
+ngx_rtmp_record_notify_error(ngx_rtmp_session_t *s,
+                             ngx_rtmp_record_app_conf_t *rracf)
+{
+    if (!rracf->notify) {
+        return;
+    }
+
+    ngx_rtmp_send_status(s, "NetStream.Record.Failed", "error",
+                         rracf->id.data ? (char *) rracf->id.data : "");
+}
+
+
 static ngx_int_t
 ngx_rtmp_record_node_open(ngx_rtmp_session_t *s, 
                           ngx_rtmp_record_rec_ctx_t *rctx)
@@ -425,6 +438,8 @@ ngx_rtmp_record_node_open(ngx_rtmp_session_t *s,
                           &rracf->id, &path);
         }
 
+        ngx_rtmp_record_notify_error(s, rracf);
+
         return NGX_OK;
     }
 
@@ -572,6 +587,8 @@ ngx_rtmp_record_node_close(ngx_rtmp_session_t *s,
         err = ngx_errno;
         ngx_log_error(NGX_LOG_CRIT, s->connection->log, err,
                       "record: %V error closing file", &rracf->id);
+
+        ngx_rtmp_record_notify_error(s, rracf);
     }
 
     rctx->file.fd = NGX_INVALID_FILE;
@@ -673,6 +690,10 @@ ngx_rtmp_record_write_frame(ngx_rtmp_session_t *s,
     if (ngx_write_file(&rctx->file, hdr, ph - hdr, rctx->file.offset)
         == NGX_ERROR) 
     {
+        ngx_rtmp_record_notify_error(s, rracf);
+
+        ngx_close_file(rctx->file.fd);
+
         return NGX_ERROR;
     }