1 /* GStreamer
2  * Copyright (C) 2017 Matthew Waters <matthew@centricular.com>
3  *
4  * This library is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU Library General Public
6  * License as published by the Free Software Foundation; either
7  * version 2 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  * Library General Public License for more details.
13  *
14  * You should have received a copy of the GNU Library General Public
15  * License along with this library; if not, write to the
16  * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
17  * Boston, MA 02110-1301, USA.
18  */
19 
20 #ifndef __TRANSPORT_RECEIVE_BIN_H__
21 #define __TRANSPORT_RECEIVE_BIN_H__
22 
23 #include <gst/gst.h>
24 #include "transportstream.h"
25 
26 G_BEGIN_DECLS
27 
28 GType transport_receive_bin_get_type(void);
29 #define GST_TYPE_WEBRTC_TRANSPORT_RECEIVE_BIN (transport_receive_bin_get_type())
30 #define TRANSPORT_RECEIVE_BIN(obj)            (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_WEBRTC_TRANSPORT_RECEIVE_BIN,TransportReceiveBin))
31 #define TRANSPORT_RECEIVE_BIN_CLASS(klass)    (G_TYPE_CHECK_CLASS_CAST((klass) ,GST_TYPE_WEBRTC_TRANSPORT_RECEIVE_BIN,TransportReceiveBinClass))
32 #define TRANSPORT_RECEIVE_BIN_GET_CLASS(obj)  (G_TYPE_INSTANCE_GET_CLASS((obj) ,GST_TYPE_WEBRTC_TRANSPORT_RECEIVE_BIN,TransportReceiveBinClass))
33 
34 typedef enum
35 {
36   RECEIVE_STATE_BLOCK = 1,
37   RECEIVE_STATE_DROP,
38   RECEIVE_STATE_PASS,
39 } ReceiveState;
40 
41 struct _TransportReceiveBin
42 {
43   GstBin                     parent;
44 
45   TransportStream           *stream;        /* parent transport stream */
46   gboolean                   rtcp_mux;
47 
48   GstPad                    *rtp_src;
49   gulong                     rtp_src_probe_id;
50   GstPad                    *rtcp_src;
51   gulong                     rtcp_src_probe_id;
52   struct pad_block          *rtp_block;
53   struct pad_block          *rtcp_block;
54   GMutex                     pad_block_lock;
55   GCond                      pad_block_cond;
56   ReceiveState               receive_state;
57 };
58 
59 struct _TransportReceiveBinClass
60 {
61   GstBinClass           parent_class;
62 };
63 
64 void        transport_receive_bin_set_receive_state         (TransportReceiveBin * receive,
65                                                              ReceiveState state);
66 
67 G_END_DECLS
68 
69 #endif /* __TRANSPORT_RECEIVE_BIN_H__ */
70