add monitor module for monitor publisher and player buffer, if buffered, record in buffer log

Author: AlexWoo

config

@@ -26,6 +26,7 @@ RTMP_CORE_MODULES="                                         \
                 ngx_rtmp_dash_module                        \
                 ngx_rtmp_shared_module                      \
                 ngx_rtmp_gop_module                         \
+                ngx_rtmp_monitor_module                     \
                 "
 
 
@@ -53,6 +54,7 @@ RTMP_DEPS="                                                     \
                 $ngx_addon_dir/ngx_rtmp_streams.h               \
                 $ngx_addon_dir/ngx_rtmp_bitop.h                 \
                 $ngx_addon_dir/ngx_rtmp_proxy_protocol.h        \
+                $ngx_addon_dir/ngx_rtmp_monitor_module.h        \
                 $ngx_addon_dir/hls/ngx_rtmp_mpegts.h            \
                 $ngx_addon_dir/dash/ngx_rtmp_mp4.h              \
                 $ngx_addon_dir/http/ngx_http_set_header.h       \
@@ -96,6 +98,7 @@ RTMP_CORE_SRCS="                                                \
                 $ngx_addon_dir/ngx_live.c                       \
                 $ngx_addon_dir/ngx_rtmp_shared_module.c         \
                 $ngx_addon_dir/ngx_rtmp_gop_module.c            \
+                $ngx_addon_dir/ngx_rtmp_monitor_module.c        \
                 $ngx_addon_dir/ngx_rtmp_auth_request_module.c   \
                 $ngx_addon_dir/ngx_rtmp_dynamic.c               \
                 "

http/ngx_http_flv_live_module.c

@@ -11,6 +11,7 @@
 #include "ngx_rtmp_cmd_module.h"
 #include "ngx_rbuf.h"
 #include "ngx_http_set_header.h"
+#include "ngx_rtmp_monitor_module.h"
 
 
 static char *ngx_http_flv_live(ngx_conf_t *cf, ngx_command_t *cmd, void *conf);
@@ -226,6 +227,8 @@ ngx_http_flv_live_prepare_out_chain(ngx_http_request_t *r,
     (*ll)->buf->last = p;
     (*ll)->buf->flush = 1;
 
+    ngx_rtmp_monitor_frame(s, &frame->hdr, NULL, frame->av_header, 0);
+
     return head;
 
 falied:

ngx_rtmp_codec_module.c

@@ -853,7 +853,7 @@ ngx_rtmp_codec_meta_data(ngx_rtmp_session_t *s, ngx_rtmp_header_t *h,
     ctx->width = (ngx_uint_t) v.width;
     ctx->height = (ngx_uint_t) v.height;
     ctx->duration = (ngx_uint_t) v.duration;
-    ctx->frame_rate = (ngx_uint_t) v.frame_rate;
+    ctx->frame_rate = v.frame_rate;
     ctx->video_data_rate = (ngx_uint_t) v.video_data_rate;
     ctx->video_codec_id = (ngx_uint_t) v.video_codec_id_n;
     ctx->audio_data_rate = (ngx_uint_t) v.audio_data_rate;

ngx_rtmp_codec_module.h

@@ -53,7 +53,7 @@ typedef struct {
     ngx_uint_t                  width;
     ngx_uint_t                  height;
     ngx_uint_t                  duration;
-    ngx_uint_t                  frame_rate;
+    double                      frame_rate;
     ngx_uint_t                  video_data_rate;
     ngx_uint_t                  video_codec_id;
     ngx_uint_t                  audio_data_rate;

ngx_rtmp_handler.c

@@ -9,6 +9,7 @@
 #include "ngx_rtmp.h"
 #include "ngx_rtmp_amf.h"
 #include "ngx_rbuf.h"
+#include "ngx_rtmp_monitor_module.h"
 
 
 static void ngx_rtmp_recv(ngx_event_t *rev);
@@ -649,6 +650,8 @@ ngx_rtmp_prepare_out_chain(ngx_rtmp_session_t *s, ngx_rtmp_frame_t *frame)
         (*ll)->buf->last = l->buf->last;
     }
 
+    ngx_rtmp_monitor_frame(s, &frame->hdr, NULL, frame->av_header, 0);
+
     return head;
 
 failed: