zotan/nginx-mod-rtmp
1
1
Fork 0
mirror of https://github.com/zotanmew/nginx-rtmp-module.git synced 2024-04-29 11:03:46 +02:00
Code Issues Projects Releases Wiki Activity

added multiple comma-separated push targets in on_publish http callback

Browse source
This commit is contained in:
jthomas 2018-09-17 02:32:51 -04:00 committed by Laura Hausmann
parent 0ce5777675
commit ce54bec0e6
Signed by: zotan
GPG key ID: 5EC1D38FFC321311
1 changed files with 33 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
ngx_rtmp_notify_module.c
View file

@ -1434,24 +1434,43 @@ ngx_rtmp_notify_publish_handle(ngx_rtmp_session_t *s,
local_name.data = v->name;
local_name.len = ngx_strlen(v->name);
ngx_memzero(&target, sizeof(target));
u_char *start = name;
u_char *next;
u = &target.url;
u->url = local_name;
u->url.data = name + 7;
u->url.len = rc - 7;
u->default_port = 1935;
u->uri_part = 1;
u->no_resolve = 1; /* want ip here */
while (start != NULL) {
next = (u_char *) ngx_strchr(start, ',');
if (ngx_parse_url(s->connection->pool, u) != NGX_OK) {
ngx_log_error(NGX_LOG_INFO, s->connection->log, 0,
"notify: push failed '%V'", &local_name);
return NGX_ERROR;
ngx_memzero(&target, sizeof(target));
u = &target.url;
u->url = local_name;
if (next) {
u->url.data = start + 7;
u->url.len = next - start - 7;
start = next + 1;
} else {
u->url.data = start + 7;
u->url.len = rc - (start - name) - 7;
start = NULL;
}
u->default_port = 1935;
u->uri_part = 1;
u->no_resolve = 1; /* want ip here */
ngx_log_error(NGX_LOG_ERR, s->connection->log, 0,
"notify: processing push '%V'", &u->url);
if (ngx_parse_url(s->connection->pool, u) != NGX_OK) {
ngx_log_error(NGX_LOG_INFO, s->connection->log, 0,
"notify: push failed '%V'", &local_name);
return NGX_ERROR;
}
ngx_rtmp_relay_push(s, &local_name, &target);
}
ngx_rtmp_relay_push(s, &local_name, &target);
next:
return next_publish(s, v);