zotan/nginx-mod-rtmp
1
1
Fork 0
mirror of https://github.com/zotanmew/nginx-rtmp-module.git synced 2024-05-20 18:01:08 +02:00
Code Issues Projects Releases Wiki Activity

Merge branch 'shared_record'

Browse source
This commit is contained in:
Roman Arutyunyan 2012-08-30 18:20:35 +04:00
parent 6b5f76654c 5d7a5ea535
commit 94fdac52a7
2 changed files with 50 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
ngx_rtmp_record_module.c
View file

@ -9,14 +9,12 @@
#include "ngx_rtmp_cmd_module.h"
#include "ngx_rtmp_netcall_module.h"
#include "ngx_rtmp_codec_module.h"
#include "ngx_rtmp_record_module.h"
static ngx_rtmp_publish_pt next_publish;
static ngx_rtmp_delete_stream_pt next_delete_stream;
static ngx_int_t ngx_rtmp_record_open(ngx_rtmp_session_t *s);
static ngx_int_t ngx_rtmp_record_close(ngx_rtmp_session_t *s);
static char * ngx_rtmp_notify_on_record_done(ngx_conf_t *cf,
ngx_command_t *cmd, void *conf);
@ -28,29 +26,6 @@ static ngx_int_t ngx_rtmp_record_write_frame(ngx_rtmp_session_t *s,
ngx_rtmp_header_t *h, ngx_chain_t *in);
typedef struct {
ngx_uint_t flags;
ngx_str_t path;
size_t max_size;
size_t max_frames;
ngx_msec_t interval;
ngx_str_t suffix;
ngx_flag_t unique;
ngx_url_t *url;
} ngx_rtmp_record_app_conf_t;
typedef struct {
ngx_file_t file;
ngx_uint_t nframes;
uint32_t epoch;
ngx_time_t last;
time_t timestamp;
u_char name[NGX_RTMP_MAX_NAME];
u_char args[NGX_RTMP_MAX_ARGS];
} ngx_rtmp_record_ctx_t;
#define NGX_RTMP_RECORD_OFF 0x01
#define NGX_RTMP_RECORD_AUDIO 0x02
#define NGX_RTMP_RECORD_VIDEO 0x04
@ -223,7 +198,7 @@ ngx_rtmp_record_write_header(ngx_file_t *file)
/* This funcion returns pointer to a static buffer */
static u_char *
u_char *
ngx_rtmp_record_make_path(ngx_rtmp_session_t *s)
{
ngx_rtmp_record_ctx_t *ctx;
@ -256,7 +231,7 @@ ngx_rtmp_record_make_path(ngx_rtmp_session_t *s)
}
static ngx_int_t
ngx_int_t
ngx_rtmp_record_open(ngx_rtmp_session_t *s)
{
ngx_rtmp_record_ctx_t *ctx;
@ -455,7 +430,7 @@ ngx_rtmp_record_notify(ngx_rtmp_session_t *s)
}
static ngx_int_t
ngx_int_t
ngx_rtmp_record_close(ngx_rtmp_session_t *s)
{
ngx_rtmp_record_ctx_t *ctx;

46
ngx_rtmp_record_module.h Normal file
View file

@ -0,0 +1,46 @@
/*
* Copyright (c) 2012 Roman Arutyunyan
*/
#ifndef _NGX_RTMP_RECORD_H_INCLUDED_
#define _NGX_RTMP_RECORD_H_INCLUDED_
#include "ngx_rtmp.h"
typedef struct {
ngx_uint_t flags;
ngx_str_t path;
size_t max_size;
size_t max_frames;
ngx_msec_t interval;
ngx_str_t suffix;
ngx_flag_t unique;
ngx_url_t *url;
} ngx_rtmp_record_app_conf_t;
typedef struct {
ngx_file_t file;
ngx_uint_t nframes;
uint32_t epoch;
ngx_time_t last;
time_t timestamp;
u_char name[NGX_RTMP_MAX_NAME];
u_char args[NGX_RTMP_MAX_ARGS];
} ngx_rtmp_record_ctx_t;
u_char * ngx_rtmp_record_make_path(ngx_rtmp_session_t *s);
ngx_int_t ngx_rtmp_record_open(ngx_rtmp_session_t *s);
ngx_int_t ngx_rtmp_record_close(ngx_rtmp_session_t *s);
extern ngx_module_t ngx_rtmp_record_module;
#endif /* _NGX_RTMP_RECORD_H_INCLUDED_ */