1 files changed, 101 insertions, 0 deletions
diff --git a/mcast/netcv2dvbip/streamer.c b/mcast/netcv2dvbip/streamer.c
new file mode 100644
index 0000000..6403386
--- /dev/null
+++ b/mcast/netcv2dvbip/streamer.c
@@ -0,0 +1,101 @@
+#include "defs.h"
+
+#include <stdio.h>
+
+#include "misc.h"
+#include "igmp.h"
+#include "streamer.h"
+#include "stream.h"
+
+#define MULTICAST_PRIV_MIN (0xEFFF0000)
+#define MULTICAST_PRIV_MAX (0xEFFF1000)
+
+cStreamer::cStreamer()
+{
+	m_IgmpMain = NULL;
+	m_bindaddr = 0;
+	m_portnum = 0;
+	m_table = 0;
+}
+
+void cStreamer::SetBindIf(iface_t bindif)
+{
+	m_bindaddr = bindif.ipaddr;
+	m_bindif = bindif;
+}
+
+void cStreamer::SetStreamPort(int portnum)
+{
+        m_portnum = portnum;
+}
+
+void cStreamer::SetTable(int table)
+{
+        m_table = table;
+}
+
+void cStreamer::Run()
+{
+	if ( m_IgmpMain == NULL )
+	{
+		m_IgmpMain = new cIgmpMain(this, m_bindif, m_table);
+		m_IgmpMain->StartListener();
+	}
+	return;
+}
+
+void cStreamer::Stop()
+{
+	if ( m_IgmpMain )
+	{
+		m_IgmpMain->Destruct();
+		delete m_IgmpMain;
+		m_IgmpMain = NULL;
+	}
+	return;
+}
+
+void cStreamer::SetNumGroups(int numgroups)
+{
+	m_numgroups = numgroups;
+}
+
+bool cStreamer::IsGroupinRange(in_addr_t groupaddr)
+{
+        in_addr_t g = htonl(groupaddr);
+        if ( (g > MULTICAST_PRIV_MIN) && (g <= MULTICAST_PRIV_MIN+m_numgroups) 
+		&&(g <= MULTICAST_PRIV_MAX) )
+        {
+                return true;
+        }
+        return false;
+}
+
+void cStreamer::StartMulticast(cMulticastGroup* Group)
+{
+        in_addr group;
+        group.s_addr = Group->group;
+        unsigned long channel = htonl(Group->group) - MULTICAST_PRIV_MIN;
+
+        printf("START Channel %d on Multicast Group: %s\n", 
+		(unsigned short) channel, inet_ntoa(group));
+        if (Group->stream == NULL)
+        {
+                Group->stream = new cStream(channel,  Group->group, m_portnum);
+                Group->stream->StartStream(m_bindaddr);
+        }
+}
+
+void cStreamer::StopMulticast(cMulticastGroup* Group)
+{
+        in_addr group;
+        group.s_addr = Group->group;
+
+        printf("STOP Multicast Group: %s\n", inet_ntoa(group));
+        if (Group->stream)
+        {
+                Group->stream->StopStream();
+                delete Group->stream;
+                Group->stream = NULL;
+        }
+}