diff options
| -rw-r--r-- | src/datatypes.h | 2 | ||||
| -rw-r--r-- | src/udp.c | 11 |
2 files changed, 12 insertions, 1 deletions
diff --git a/src/datatypes.h b/src/datatypes.h index f60d97f..2ff5e12 100644 --- a/src/datatypes.h +++ b/src/datatypes.h @@ -39,6 +39,7 @@ #include <stdint.h> #include <glib.h> +#include <gio/gio.h> #include <gst/gst.h> #include <netdb.h> @@ -75,6 +76,7 @@ struct udp_sources { GstElement* rtp_audio_; GstElement* rtcp_audio_; int keepalive_interval_; + GInetAddress* remote_addr_; }; #endif @@ -230,13 +230,22 @@ gboolean attach_udpsinks(struct udp_sinks *sinks) return TRUE; } +static gboolean send_keepalives(gpointer user_data) +{ + log_printf(WARNING, "sending keep alives is not yet supporet!"); + return TRUE; +} gboolean attach_udpsources(struct udp_sources *sources) { if(!sources) return FALSE; - log_printf(WARNING, "udp source keep alive messages are not implemented yet!"); + if(sources->keepalive_interval_ > 0) { + send_keepalives(sources); + if(!g_timeout_add_seconds(sources->keepalive_interval_, send_keepalives, sources)) + return FALSE; + } return TRUE; } |