|
|
|
@ -34,6 +34,16 @@ |
|
|
|
|
#include "os_support.h" |
|
|
|
|
#include "url.h" |
|
|
|
|
|
|
|
|
|
/* This is for MPEG-TS and it's a default SRTO_PAYLOADSIZE for SRTT_LIVE (8 TS packets) */ |
|
|
|
|
#ifndef SRT_LIVE_DEFAULT_PAYLOAD_SIZE |
|
|
|
|
#define SRT_LIVE_DEFAULT_PAYLOAD_SIZE 1316 |
|
|
|
|
#endif |
|
|
|
|
|
|
|
|
|
/* This is the maximum payload size for Live mode, should you have a different payload type than MPEG-TS */ |
|
|
|
|
#ifndef SRT_LIVE_MAX_PAYLOAD_SIZE |
|
|
|
|
#define SRT_LIVE_MAX_PAYLOAD_SIZE 1456 |
|
|
|
|
#endif |
|
|
|
|
|
|
|
|
|
enum SRTMode { |
|
|
|
|
SRT_MODE_CALLER = 0, |
|
|
|
|
SRT_MODE_LISTENER = 1, |
|
|
|
@ -48,7 +58,6 @@ typedef struct SRTContext { |
|
|
|
|
int64_t listen_timeout; |
|
|
|
|
int recv_buffer_size; |
|
|
|
|
int send_buffer_size; |
|
|
|
|
int pkt_size; |
|
|
|
|
|
|
|
|
|
int64_t maxbw; |
|
|
|
|
int pbkeylen; |
|
|
|
@ -63,6 +72,7 @@ typedef struct SRTContext { |
|
|
|
|
int tlpktdrop; |
|
|
|
|
int nakreport; |
|
|
|
|
int64_t connect_timeout; |
|
|
|
|
int payload_size; |
|
|
|
|
enum SRTMode mode; |
|
|
|
|
} SRTContext; |
|
|
|
|
|
|
|
|
@ -74,7 +84,10 @@ static const AVOption libsrt_options[] = { |
|
|
|
|
{ "listen_timeout", "Connection awaiting timeout", OFFSET(listen_timeout), AV_OPT_TYPE_INT64, { .i64 = -1 }, -1, INT64_MAX, .flags = D|E }, |
|
|
|
|
{ "send_buffer_size", "Socket send buffer size (in bytes)", OFFSET(send_buffer_size), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E }, |
|
|
|
|
{ "recv_buffer_size", "Socket receive buffer size (in bytes)", OFFSET(recv_buffer_size), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E }, |
|
|
|
|
{ "pkt_size", "Maximum SRT packet size", OFFSET(pkt_size), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, INT_MAX, .flags = D|E }, |
|
|
|
|
{ "pkt_size", "Maximum SRT packet size", OFFSET(payload_size), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, SRT_LIVE_MAX_PAYLOAD_SIZE, .flags = D|E, "payload_size" }, |
|
|
|
|
{ "payload_size", "Maximum SRT packet size", OFFSET(payload_size), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, SRT_LIVE_MAX_PAYLOAD_SIZE, .flags = D|E, "payload_size" }, |
|
|
|
|
{ "ts_size", NULL, 0, AV_OPT_TYPE_CONST, { .i64 = SRT_LIVE_DEFAULT_PAYLOAD_SIZE }, INT_MIN, INT_MAX, .flags = D|E, "payload_size" }, |
|
|
|
|
{ "max_size", NULL, 0, AV_OPT_TYPE_CONST, { .i64 = SRT_LIVE_MAX_PAYLOAD_SIZE }, INT_MIN, INT_MAX, .flags = D|E, "payload_size" }, |
|
|
|
|
{ "maxbw", "Maximum bandwidth (bytes per second) that the connection can use", OFFSET(maxbw), AV_OPT_TYPE_INT64, { .i64 = -1 }, -1, INT64_MAX, .flags = D|E }, |
|
|
|
|
{ "pbkeylen", "Crypto key len in bytes {16,24,32} Default: 16 (128-bit)", OFFSET(pbkeylen), AV_OPT_TYPE_INT, { .i64 = -1 }, -1, 32, .flags = D|E }, |
|
|
|
|
{ "passphrase", "Crypto PBKDF2 Passphrase size[0,10..64] 0:disable crypto", OFFSET(passphrase), AV_OPT_TYPE_STRING, { .str = NULL }, .flags = D|E }, |
|
|
|
@ -287,8 +300,8 @@ static int libsrt_set_options_pre(URLContext *h, int fd) |
|
|
|
|
(tsbpddelay >= 0 && libsrt_setsockopt(h, fd, SRTO_TSBPDDELAY, "SRTO_TSBPDELAY", &tsbpddelay, sizeof(tsbpddelay)) < 0) || |
|
|
|
|
(s->tlpktdrop >= 0 && libsrt_setsockopt(h, fd, SRTO_TLPKTDROP, "SRTO_TLPKDROP", &s->tlpktdrop, sizeof(s->tlpktdrop)) < 0) || |
|
|
|
|
(s->nakreport >= 0 && libsrt_setsockopt(h, fd, SRTO_NAKREPORT, "SRTO_NAKREPORT", &s->nakreport, sizeof(s->nakreport)) < 0) || |
|
|
|
|
(s->pkt_size >= 0 && libsrt_setsockopt(h, fd, SRTO_PAYLOADSIZE, "SRTO_PAYLOADSIZE", &s->pkt_size, sizeof(s->pkt_size)) < 0) || |
|
|
|
|
(connect_timeout >= 0 && libsrt_setsockopt(h, fd, SRTO_CONNTIMEO, "SRTO_CONNTIMEO", &connect_timeout, sizeof(connect_timeout)) <0 )) { |
|
|
|
|
(connect_timeout >= 0 && libsrt_setsockopt(h, fd, SRTO_CONNTIMEO, "SRTO_CONNTIMEO", &connect_timeout, sizeof(connect_timeout)) <0 )) || |
|
|
|
|
(s->payload_size >= 0 && libsrt_setsockopt(h, fd, SRTO_PAYLOADSIZE, "SRTO_PAYLOADSIZE", &s->payload_size, sizeof(s->payload_size)) < 0) { |
|
|
|
|
return AVERROR(EIO); |
|
|
|
|
} |
|
|
|
|
return 0; |
|
|
|
@ -464,9 +477,6 @@ static int libsrt_open(URLContext *h, const char *uri, int flags) |
|
|
|
|
if (av_find_info_tag(buf, sizeof(buf), "oheadbw", p)) { |
|
|
|
|
s->oheadbw = strtoll(buf, NULL, 10); |
|
|
|
|
} |
|
|
|
|
if (av_find_info_tag(buf, sizeof(buf), "pkt_size", p)) { |
|
|
|
|
s->pkt_size = strtol(buf, NULL, 10); |
|
|
|
|
} |
|
|
|
|
if (av_find_info_tag(buf, sizeof(buf), "tsbpddelay", p)) { |
|
|
|
|
s->tsbpddelay = strtol(buf, NULL, 10); |
|
|
|
|
} |
|
|
|
@ -479,6 +489,9 @@ static int libsrt_open(URLContext *h, const char *uri, int flags) |
|
|
|
|
if (av_find_info_tag(buf, sizeof(buf), "connect_timeout", p)) { |
|
|
|
|
s->connect_timeout = strtol(buf, NULL, 10); |
|
|
|
|
} |
|
|
|
|
if (av_find_info_tag(buf, sizeof(buf), "payload_size", p)) { |
|
|
|
|
s->payload_size = strtol(buf, NULL, 10); |
|
|
|
|
} |
|
|
|
|
if (av_find_info_tag(buf, sizeof(buf), "mode", p)) { |
|
|
|
|
if (!strcmp(buf, "caller")) { |
|
|
|
|
s->mode = SRT_MODE_CALLER; |
|
|
|
|