Skip to content

Commit 00f3465

Browse files
MionszDawidWesierski4
authored andcommitted
Add: FFmpeg support for redundant mode
Add support for redundant mode in FFmpeg plugin by enabling parameters.
1 parent 88c3566 commit 00f3465

File tree

1 file changed

+42
-0
lines changed

1 file changed

+42
-0
lines changed

ecosystem/ffmpeg_plugin/mtl_common.h

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,11 +83,31 @@
8383

8484
#define MTL_RX_DEV_ARGS \
8585
{"p_port", "mtl p port", OFFSET(devArgs.port[MTL_PORT_P]), \
86+
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = DEC}, \
87+
{"r_port", "mtl r port", OFFSET(devArgs.port[MTL_PORT_R]), \
8688
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = DEC}, \
8789
{"p_sip", "mtl local ip", OFFSET(devArgs.sip[MTL_PORT_P]), AV_OPT_TYPE_STRING, \
8890
{.str = NULL}, .flags = DEC}, \
91+
{"r_sip", "mtl local r ip", OFFSET(devArgs.sip[MTL_PORT_R]), AV_OPT_TYPE_STRING, \
92+
{.str = NULL}, .flags = DEC}, \
8993
{"dma_dev", "mtl dma dev", OFFSET(devArgs.dma_dev), \
9094
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = DEC}, \
95+
{"r_rx_queues", \
96+
"mtl r_port device amount of rx queues", \
97+
OFFSET(devArgs.rx_queues_cnt[MTL_PORT_R]), \
98+
AV_OPT_TYPE_INT, \
99+
{.i64 = 16}, \
100+
-1, \
101+
INT_MAX, \
102+
DEC}, \
103+
{"r_tx_queues", \
104+
"mtl r_port device amount of tx queues", \
105+
OFFSET(devArgs.tx_queues_cnt[MTL_PORT_R]), \
106+
AV_OPT_TYPE_INT, \
107+
{.i64 = 16}, \
108+
-1, \
109+
INT_MAX, \
110+
DEC}, \
91111
{"rx_queues", \
92112
"mtl device amount of rx queues", \
93113
OFFSET(devArgs.rx_queues_cnt[MTL_PORT_P]), \
@@ -104,6 +124,8 @@
104124

105125
#define MTL_RX_PORT_ARGS \
106126
{"p_rx_ip", "p rx ip", OFFSET(portArgs.sip[MTL_SESSION_PORT_P]), \
127+
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = DEC}, \
128+
{"r_rx_ip", "r rx ip", OFFSET(portArgs.sip[MTL_SESSION_PORT_R]), \
107129
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = DEC}, \
108130
{"udp_port", \
109131
"UDP port", \
@@ -120,11 +142,29 @@
120142

121143
#define MTL_TX_DEV_ARGS \
122144
{"p_port", "mtl p port", OFFSET(devArgs.port[MTL_PORT_P]), \
145+
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = ENC}, \
146+
{"r_port", "mtl r port", OFFSET(devArgs.port[MTL_PORT_R]), \
123147
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = ENC}, \
124148
{"p_sip", "mtl local ip", OFFSET(devArgs.sip[MTL_PORT_P]), AV_OPT_TYPE_STRING, \
125149
{.str = NULL}, .flags = ENC}, \
150+
{"r_sip", "mtl local r ip", OFFSET(devArgs.sip[MTL_PORT_R]), AV_OPT_TYPE_STRING, \
151+
{.str = NULL}, .flags = ENC}, \
126152
{"dma_dev", "mtl dma dev", OFFSET(devArgs.dma_dev), \
127153
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = ENC}, \
154+
{"r_rx_queues", "mtl r_port device amount of rx queues", \
155+
OFFSET(devArgs.rx_queues_cnt[MTL_PORT_R]), \
156+
AV_OPT_TYPE_INT, \
157+
{.i64 = 16}, \
158+
-1, \
159+
INT_MAX, \
160+
ENC}, \
161+
{"r_tx_queues", "mtl r_port device amount of tx queues", \
162+
OFFSET(devArgs.tx_queues_cnt[MTL_PORT_R]), \
163+
AV_OPT_TYPE_INT, \
164+
{.i64 = 16}, \
165+
-1, \
166+
INT_MAX, \
167+
ENC}, \
128168
{"rx_queues", \
129169
"mtl device amount of rx queues", \
130170
OFFSET(devArgs.rx_queues_cnt[MTL_PORT_P]), \
@@ -141,6 +181,8 @@
141181

142182
#define MTL_TX_PORT_ARGS \
143183
{"p_tx_ip", "p tx ip", OFFSET(portArgs.dip[MTL_SESSION_PORT_P]), \
184+
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = ENC}, \
185+
{"r_tx_ip", "r tx ip", OFFSET(portArgs.dip[MTL_SESSION_PORT_R]), \
144186
AV_OPT_TYPE_STRING, {.str = NULL}, .flags = ENC}, \
145187
{"udp_port", \
146188
"UDP port", \

0 commit comments

Comments
 (0)