Initial commit.

2026-06-07 08:34:39 -04:00 · 2018-03-13 22:16:48 +00:00
commit e3abbaa85f
94 changed files with 9980 additions and 0 deletions
@@ -0,0 +1,138 @@
+/*
+*   Copyright (C) 2016,2018 by Jonathan Naylor G4KLX
+*
+*   This program is free software; you can redistribute it and/or modify
+*   it under the terms of the GNU General Public License as published by
+*   the Free Software Foundation; either version 2 of the License, or
+*   (at your option) any later version.
+*
+*   This program is distributed in the hope that it will be useful,
+*   but WITHOUT ANY WARRANTY; without even the implied warranty of
+*   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+*   GNU General Public License for more details.
+*
+*   You should have received a copy of the GNU General Public License
+*   along with this program; if not, write to the Free Software
+*   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+*/
+
+#include "StopWatch.h"
+#include "NXDNParrot.h"
+#include "Parrot.h"
+#include "Network.h"
+#include "Version.h"
+#include "Thread.h"
+#include "Timer.h"
+
+#include <cstdio>
+#include <cstdlib>
+#include <cstring>
+
+int main(int argc, char** argv)
+{
+	if (argc == 1) {
+		::fprintf(stderr, "Usage: NXDNParrot <port>\n");
+		return 1;
+	}
+
+	unsigned int port = ::atoi(argv[1U]);
+	if (port == 0U) {
+		::fprintf(stderr, "NXDNParrot: invalid port number - %s\n", argv[1U]);
+		return 1;
+	}
+
+	CNXDNParrot parrot(port);
+	parrot.run();
+
+	return 0;
+}
+
+CNXDNParrot::CNXDNParrot(unsigned int port) :
+m_port(port)
+{
+}
+
+CNXDNParrot::~CNXDNParrot()
+{
+}
+
+void CNXDNParrot::run()
+{
+	CParrot parrot(180U);
+	CNetwork network(m_port);
+
+	bool ret = network.open();
+	if (!ret)
+		return;
+
+	CStopWatch stopWatch;
+	stopWatch.start();
+
+	CTimer watchdogTimer(1000U, 0U, 1500U);
+	CTimer turnaroundTimer(1000U, 2U);
+
+	CStopWatch playoutTimer;
+	unsigned int count = 0U;
+	bool playing = false;
+
+	::fprintf(stdout, "Starting NXDNParrot-%s\n", VERSION);
+
+	for (;;) {
+		unsigned char buffer[200U];
+
+		unsigned int len = network.read(buffer);
+		if (len > 0U) {
+			parrot.write(buffer, len);
+			watchdogTimer.start();
+
+			if ((buffer[9U] & 0x04U) == 0x04U) {
+				::fprintf(stdout, "Received end of transmission\n");
+				turnaroundTimer.start();
+				watchdogTimer.stop();
+				parrot.end();
+			}
+		}
+
+		if (turnaroundTimer.isRunning() && turnaroundTimer.hasExpired()) {
+			if (!playing) {
+				playoutTimer.start();
+				playing = true;
+				count = 0U;
+			}
+
+			// A frame every 80ms
+			unsigned int wanted = playoutTimer.elapsed() / 80U;
+			while (count < wanted) {
+				len = parrot.read(buffer);
+				if (len > 0U) {
+					network.write(buffer, len);
+					count++;
+				} else {
+					parrot.clear();
+					network.end();
+					turnaroundTimer.stop();
+					playing = false;
+					count = wanted;
+				}
+			}
+		}
+
+		unsigned int ms = stopWatch.elapsed();
+		stopWatch.start();
+
+		network.clock(ms);
+		watchdogTimer.clock(ms);
+		turnaroundTimer.clock(ms);
+
+		if (watchdogTimer.isRunning() && watchdogTimer.hasExpired()) {
+			turnaroundTimer.start();
+			watchdogTimer.stop();
+			parrot.end();
+		}
+
+		if (ms < 5U)
+			CThread::sleep(5U);
+	}
+
+	network.close();
+}