1 /* GStreamer plugin for forward error correction
2  * Copyright (C) 2017 Pexip
3  *
4  * This library is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU Lesser General Public
6  * License as published by the Free Software Foundation; either
7  * version 2.1 of the License, or (at your option) any later version.
8  *
9  * This library is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
12  * Lesser General Public License for more details.
13  *
14  * You should have received a copy of the GNU Lesser General Public
15  * License along with this library; if not, write to the Free Software
16  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
17  *
18  * Author: Mikhail Fludkov <misha@pexip.com>
19  */
20 
21 #ifndef __GST_FEC_H__
22 #define __GST_FEC_H__
23 
24 #include <gst/gst.h>
25 
26 G_BEGIN_DECLS
27 
28 #define GST_TYPE_RTP_ULPFEC_ENC \
29   (gst_rtp_ulpfec_enc_get_type())
30 #define GST_RTP_ULPFEC_ENC(obj) \
31   (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_RTP_ULPFEC_ENC,GstRtpUlpFecEnc))
32 #define GST_RTP_ULPFEC_ENC_CLASS(klass) \
33   (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_RTP_ULPFEC_ENC,GstRtpUlpFecEncClass))
34 #define GST_IS_RTP_ULPFEC_ENC(obj) \
35   (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_RTP_ULPFEC_ENC))
36 #define GST_IS_RTP_ULPFEC_ENC_CLASS(klass) \
37   (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_RTP_ULPFEC_ENC))
38 
39 typedef struct _GstRtpUlpFecEnc GstRtpUlpFecEnc;
40 typedef struct _GstRtpUlpFecEncClass GstRtpUlpFecEncClass;
41 
42 struct _GstRtpUlpFecEncClass {
43   GstElementClass parent_class;
44 };
45 
46 struct _GstRtpUlpFecEnc {
47   GstElement parent;
48   GstPad *srcpad;
49   GstPad *sinkpad;
50 
51   GHashTable *ssrc_to_ctx;
52 
53   /* properties */
54   guint pt;
55   guint32 ssrc;
56   guint percentage;
57   guint percentage_important;
58   gboolean multipacket;
59   guint num_packets_protected;
60 };
61 
62 typedef struct {
63   guint ssrc;
64 
65   GstElement *parent;
66   GstPad *srcpad;
67 
68   /* settings */
69   guint pt;
70   guint percentage;
71   guint percentage_important;
72   gboolean multipacket;
73   gboolean mux_seq;
74 
75   guint num_packets_protected;
76   guint16 seqnum;
77   guint seqnum_offset;
78   guint num_packets_received;
79   guint num_packets_fec;
80   guint fec_nth;
81   GQueue packets_buf;
82 
83   gdouble budget;
84   gdouble budget_inc;
85   gdouble budget_important;
86   gdouble budget_inc_important;
87 
88   GArray *info_arr;
89   GArray *scratch_buf;
90 
91   guint fec_packets;
92   guint fec_packet_idx;
93 } GstRtpUlpFecEncStreamCtx;
94 
95 GType gst_rtp_ulpfec_enc_get_type (void);
96 
97 G_END_DECLS
98 
99 #endif /* __GST_FEC_H__ */
100