KB8PMY
/
F4KXL_DStarGateway
mirror of https://github.com/F4FXL/DStarGateway.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from '4511d88e0f'
${ noResults }
F4KXL_DStarGateway/DGWTimeServer/TimeServerThread.cpp

1404 lines
34 KiB
Raw Blame History

/*
* Copyright (C) 2012,2013 by Jonathan Naylor G4KLX
* Copyright (C) 2022 by Geoffrey Merck F4FXL / KC3FRA
*
* 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 <sys/stat.h>
#include <cstring>
#include <cstdlib>
#include <stdio.h>
#include <vector>
#include <boost/algorithm/string.hpp>
#include <chrono>
#include "TimeServerThread.h"
#include "DStarDefines.h"
#include "Utils.h"
#include "NetUtils.h"
#include "StringUtils.h"
#include "Log.h"
const unsigned int MAX_FRAMES = 60U * DSTAR_FRAMES_PER_SEC;
const unsigned int SILENCE_LENGTH = 10U;
CTimeServerThread::CTimeServerThread() :
CThread("Time Server"),
m_callsign(),
m_repeaters(),
m_callsignG(),
m_address(),
m_addressStr(),
m_language(LANG_ENGLISH_UK_1),
m_format(FORMAT_VOICE_TIME),
m_interval(INTERVAL_15MINS),
m_ambe(NULL),
m_ambeLength(0U),
m_index(),
m_seqNo(0U),
m_in(0U),
m_encoder(),
m_data(NULL),
m_killed(false),
m_dataPath("")
{
CHeaderData::initialise();
m_address.s_addr = INADDR_NONE;
m_data = new CAMBEData*[MAX_FRAMES];
for (unsigned int i = 0U; i < MAX_FRAMES; i++)
m_data[i] = nullptr;
}
CTimeServerThread::~CTimeServerThread()
{
for (auto it = m_index.begin(); it != m_index.end(); it++)
delete it->second;
delete[] m_ambe;
delete[] m_data;
}
void * CTimeServerThread::Entry()
{
// Wait here until we have the essentials to run
while (!m_killed && m_address.s_addr == INADDR_NONE && m_repeaters.size() == 0U)
Sleep(500UL); // 1/2 sec
if (m_killed)
return nullptr;
if (m_format != FORMAT_TEXT_TIME) {
bool ret = loadAMBE();
if (!ret) {
CLog::logWarning(("Cannot load the AMBE data, using text only time"));
m_format = FORMAT_TEXT_TIME;
}
}
CLog::logInfo(("Starting the Time Server thread"));
unsigned int lastMin = 0U;
while (!m_killed) {
time_t now;
::time(&now);
struct tm* tm = ::localtime(&now);
unsigned int hour = tm->tm_hour;
unsigned int min = tm->tm_min;
// if (min != lastMin)
// sendTime(15, 45);
if (min != lastMin) {
if (m_interval == INTERVAL_15MINS && (min == 0U || min == 15U || min == 30U || min == 45U))
sendTime(hour, min);
else if (m_interval == INTERVAL_30MINS && (min == 0U || min == 30U))
sendTime(hour, min);
else if (m_interval == INTERVAL_60MINS && min == 0U)
sendTime(hour, min);
}
lastMin = min;
Sleep(450UL);
}
CLog::logInfo(("Stopping the Time Server thread"));
return nullptr;
}
void CTimeServerThread::kill()
{
m_killed = true;
}
bool CTimeServerThread::setGateway(const std::string& callsign, const std::string& rpt1, const std::string& rpt2, const std::string& rpt3, const std::string& rpt4, const std::string& address, const std::string& dataPath)
{
m_callsign = callsign;
m_callsign.resize(LONG_CALLSIGN_LENGTH - 1U, (' '));
m_callsignG = m_callsign;
m_callsignG.push_back('G');
if (!rpt1.empty()) {
m_repeaters.push_back(m_callsign + rpt1);
}
if (!rpt2.empty()) {
m_repeaters.push_back(m_callsign + rpt2);
}
if (!rpt3.empty()) {
m_repeaters.push_back(m_callsign + rpt3);
}
if (!rpt4.empty()) {
m_repeaters.push_back(m_callsign + rpt4);
}
m_callsign.push_back(' ');
m_addressStr.assign(address);
m_address = CUDPReaderWriter::lookup(address);
m_dataPath.assign(dataPath);
return true;
}
void CTimeServerThread::setAnnouncements(LANGUAGE language, FORMAT format, INTERVAL interval)
{
m_language = language;
m_format = format;
m_interval = interval;
}
void CTimeServerThread::sendTime(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
switch (m_language) {
case LANG_ENGLISH_UK_1:
words = sendTimeEnGB1(hour, min);
break;
case LANG_ENGLISH_UK_2:
words = sendTimeEnGB2(hour, min);
break;
case LANG_ENGLISH_US_1:
words = sendTimeEnUS1(hour, min);
break;
case LANG_ENGLISH_US_2:
words = sendTimeEnUS2(hour, min);
break;
case LANG_DEUTSCH_1:
words = sendTimeDeDE1(hour, min);
break;
case LANG_DEUTSCH_2:
words = sendTimeDeDE2(hour, min);
break;
case LANG_FRANCAIS:
words = sendTimeFrFR(hour, min);
break;
case LANG_NEDERLANDS:
words = sendTimeNlNL(hour, min);
break;
case LANG_SVENSKA:
words = sendTimeSeSE(hour, min);
break;
case LANG_ESPANOL:
words = sendTimeEsES(hour, min);
break;
case LANG_NORSK:
words = sendTimeNoNO(hour, min);
break;
case LANG_PORTUGUES:
words = sendTimePtPT(hour, min);
break;
default:
break;
}
send(words, hour, min);
}
std::vector<std::string> CTimeServerThread::sendTimeEnGB1(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back(("It_is"));
switch (hour) {
case 0U:
case 12U:
words.push_back(("twelve"));
break;
case 1U:
case 13U:
words.push_back(("one"));
break;
case 2U:
case 14U:
words.push_back(("two"));
break;
case 3U:
case 15U:
words.push_back(("three"));
break;
case 4U:
case 16U:
words.push_back(("four"));
break;
case 5U:
case 17U:
words.push_back(("five"));
break;
case 6U:
case 18U:
words.push_back(("six"));
break;
case 7U:
case 19U:
words.push_back(("seven"));
break;
case 8U:
case 20U:
words.push_back(("eight"));
break;
case 9U:
case 21U:
words.push_back(("nine"));
break;
case 10U:
case 22U:
words.push_back(("ten"));
break;
case 11U:
case 23U:
words.push_back(("eleven"));
break;
default:
break;
}
switch (min) {
case 15U:
words.push_back(("fifteen"));
break;
case 30U:
words.push_back(("thirty"));
break;
case 45U:
words.push_back(("forty-five"));
break;
default:
break;
}
if (hour >= 12U)
words.push_back(("PM"));
else
words.push_back(("AM"));
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeEnGB2(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back("It_is");
if (min == 15U) {
words.push_back(("a_quarter_past"));
} else if (min == 30U) {
words.push_back(("half_past"));
} else if (min == 45U) {
words.push_back(("a_quarter_to"));
if (hour == 23U)
hour = 0U;
else
hour++;
}
if (hour == 0U && min == 0U) {
words.push_back(("midnight"));
} else if (hour == 12U && min == 0U) {
words.push_back(("twelve"));
words.push_back(("noon"));
} else if (hour == 0U || hour == 12U) {
words.push_back(("twelve"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("one"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("two"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("three"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("four"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("five"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("six"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("seven"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("eight"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("nine"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("ten"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("eleven"));
}
if (hour != 0U && hour != 12U && min == 0U)
words.push_back(("O_Clock"));
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeEnUS1(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back(("It_is"));
switch (hour) {
case 0U:
case 12U:
words.push_back(("twelve"));
break;
case 1U:
case 13U:
words.push_back(("one"));
break;
case 2U:
case 14U:
words.push_back(("two"));
break;
case 3U:
case 15U:
words.push_back(("three"));
break;
case 4U:
case 16U:
words.push_back(("four"));
break;
case 5U:
case 17U:
words.push_back(("five"));
break;
case 6U:
case 18U:
words.push_back(("six"));
break;
case 7U:
case 19U:
words.push_back(("seven"));
break;
case 8U:
case 20U:
words.push_back(("eight"));
break;
case 9U:
case 21U:
words.push_back(("nine"));
break;
case 10U:
case 22U:
words.push_back(("ten"));
break;
case 11U:
case 23U:
words.push_back(("eleven"));
break;
default:
break;
}
switch (min) {
case 15U:
words.push_back(("fifteen"));
break;
case 30U:
words.push_back(("thirty"));
break;
case 45U:
words.push_back(("forty-five"));
break;
default:
break;
}
if (hour >= 12U)
words.push_back(("PM"));
else
words.push_back(("AM"));
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeEnUS2(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back(("It_is"));
if (min == 15U) {
words.push_back(("a_quarter_past"));
} else if (min == 30U) {
words.push_back(("half_past"));
} else if (min == 45U) {
words.push_back(("a_quarter_to"));
if (hour == 23U)
hour = 0U;
else
hour++;
}
if (hour == 0U && min == 0U) {
words.push_back(("midnight"));
} else if (hour == 12U && min == 0U) {
words.push_back(("twelve"));
words.push_back(("noon"));
} else if (hour == 0U || hour == 12U) {
words.push_back(("twelve"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("one"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("two"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("three"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("four"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("five"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("six"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("seven"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("eight"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("nine"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("ten"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("eleven"));
}
if (hour != 0U && hour != 12U && min == 0U)
words.push_back(("O_Clock"));
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeDeDE1(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back(("Es_ist"));
switch (hour) {
case 0U: words.push_back(("null")); break;
case 1U: words.push_back(("ein")); break;
case 2U: words.push_back(("zwei")); break;
case 3U: words.push_back(("drei")); break;
case 4U: words.push_back(("vier")); break;
case 5U: words.push_back(("fuenf")); break;
case 6U: words.push_back(("sechs")); break;
case 7U: words.push_back(("sieben")); break;
case 8U: words.push_back(("acht")); break;
case 9U: words.push_back(("neun")); break;
case 10U: words.push_back(("zehn")); break;
case 11U: words.push_back(("elf")); break;
case 12U: words.push_back(("zwoelf")); break;
case 13U: words.push_back(("dreizehn")); break;
case 14U: words.push_back(("vierzehn")); break;
case 15U: words.push_back(("fuenfzehn")); break;
case 16U: words.push_back(("sechzehn")); break;
case 17U: words.push_back(("siebzehn")); break;
case 18U: words.push_back(("achtzehn")); break;
case 19U: words.push_back(("neunzehn")); break;
case 20U: words.push_back(("zwanzig")); break;
case 21U: words.push_back(("einundzwanzig")); break;
case 22U: words.push_back(("zweiundzwanzig")); break;
case 23U: words.push_back(("dreiundzwanzig")); break;
default: break;
}
words.push_back(("Uhr"));
switch (min) {
case 15U:
words.push_back(("fuenfzehn"));
break;
case 30U:
words.push_back(("dreissig"));
break;
case 45U:
words.push_back(("fuenfundvierzig"));
break;
default:
break;
}
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeDeDE2(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back(("Es_ist"));
if (min == 15U) {
words.push_back(("viertel_nach"));
} else if (min == 30U) {
words.push_back(("halb"));
if (hour == 23U)
hour = 0U;
else
hour++;
} else if (min == 45U) {
words.push_back(("viertel_vor"));
if (hour == 23U)
hour = 0U;
else
hour++;
}
if (hour == 0U) {
words.push_back(("null"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("ein"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("zwei"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("drei"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("vier"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("fuenf"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("sechs"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("sieben"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("acht"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("neun"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("zehn"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("elf"));
} else if (hour == 12U) {
words.push_back(("zwoelf"));
}
if (min == 0U)
words.push_back(("Uhr"));
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeFrFR(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
// if (hour > 17U)
// words.push_back(("bonsoir"));
// else
// words.push_back(("bonjour"));
words.push_back(("il_est"));
if (min == 45U)
hour++;
if (hour == 0U) {
words.push_back(("minuit"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("une"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("deux"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("trois"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("quatre"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("cinq"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("six"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("sept"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("huit"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("neuf"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("dix"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("onze"));
} else if (hour == 12U) {
words.push_back(("midi"));
}
if (hour == 1U || hour == 13U)
words.push_back(("heure"));
else if (hour != 12U && hour != 0U)
words.push_back(("heures"));
if (min == 15U) {
words.push_back(("et_quart"));
} else if (min == 30U) {
words.push_back(("et_demie"));
} else if (min == 45U) {
words.push_back(("moins_le_quart"));
if (hour == 23U)
hour = 0U;
else
hour++;
}
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeNlNL(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back(("Het_is"));
if (min == 15U) {
words.push_back(("kwart_over"));
} else if (min == 30U) {
words.push_back(("half"));
if (hour == 23U)
hour = 0U;
else
hour++;
} else if (min == 45U) {
words.push_back(("kwart_voor"));
if (hour == 23U)
hour = 0U;
else
hour++;
}
if (hour == 0U || hour == 12U) {
words.push_back(("twaalf"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("een"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("twee"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("drie"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("vier"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("vijf"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("zes"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("zeven"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("acht"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("negen"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("tien"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("elf"));
}
if (min == 0U)
words.push_back(("uur"));
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeSeSE(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back(("Klockan_ar"));
if (min == 15U) {
words.push_back(("kvart_over"));
} else if (min == 30U) {
words.push_back(("halv"));
if (hour == 23U)
hour = 0U;
else
hour++;
} else if (min == 45U) {
words.push_back(("kvart_i"));
if (hour == 23U)
hour = 0U;
else
hour++;
}
if (hour == 0U || hour == 12U) {
words.push_back(("tolv"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("ett"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("tva"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("tre"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("fyra"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("fem"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("sex"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("sju"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("atta"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("nio"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("tio"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("elva"));
}
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeEsES(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
if (min == 45U) {
hour++;
if (hour == 24U)
hour = 0U;
}
if (hour == 1U)
words.push_back(("Es_la"));
else if (hour == 0U || hour == 12U)
words.push_back(("Es"));
else
words.push_back(("Son_las"));
if (hour == 0U) {
words.push_back(("medianoche"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("una"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("dos"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("tres"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("cuarto"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("cinco"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("seis"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("siete"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("ocho"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("nueve"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("diez"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("once"));
} else {
words.push_back(("mediodia"));
}
if (min == 15U)
words.push_back(("y_cuarto"));
else if (min == 30U)
words.push_back(("y_media"));
else if (min == 45U)
words.push_back(("menos_cuarto"));
if (hour > 0U && hour < 12U)
words.push_back(("de_la_manana"));
else if (hour > 12U && hour < 19U)
words.push_back(("de_la_tarde"));
else if (hour >= 19U && hour <= 23U)
words.push_back(("de_la_noche"));
return words;
}
std::vector<std::string> CTimeServerThread::sendTimeNoNO(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
words.push_back(("Klokken_er"));
if (min == 15U) {
words.push_back(("kvart_over"));
} else if (min == 30U) {
words.push_back(("halv"));
if (hour == 23U)
hour = 0U;
else
hour++;
} else if (min == 45U) {
words.push_back(("kvart_pa"));
if (hour == 23U)
hour = 0U;
else
hour++;
}
if (hour == 0U || hour == 12U) {
words.push_back(("tolv"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("ett"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("to"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("tre"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("fire"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("fem"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("seks"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("sju"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("atte"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("ni"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("ti"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("elleve"));
}
return words;
}
std::vector<std::string> CTimeServerThread::sendTimePtPT(unsigned int hour, unsigned int min)
{
std::vector<std::string> words;
if (min == 45U) {
hour++;
if (hour == 24U)
hour = 0U;
}
if (hour == 1U || hour == 13U)
words.push_back(("E"));
else if (hour == 0U || hour == 12U)
words.push_back(("Es"));
else
words.push_back(("Sao"));
if (min == 45U) {
if (hour == 0U || hour == 12U || hour == 1U || hour == 13U)
words.push_back(("quinze_para"));
else
words.push_back(("quinze_para_as"));
}
if (hour == 0U) {
words.push_back(("meia-noite"));
} else if (hour == 1U || hour == 13U) {
words.push_back(("uma"));
} else if (hour == 2U || hour == 14U) {
words.push_back(("duas"));
} else if (hour == 3U || hour == 15U) {
words.push_back(("tres"));
} else if (hour == 4U || hour == 16U) {
words.push_back(("quatro"));
} else if (hour == 5U || hour == 17U) {
words.push_back(("cinco"));
} else if (hour == 6U || hour == 18U) {
words.push_back(("seis"));
} else if (hour == 7U || hour == 19U) {
words.push_back(("sete"));
} else if (hour == 8U || hour == 20U) {
words.push_back(("oito"));
} else if (hour == 9U || hour == 21U) {
words.push_back(("nove"));
} else if (hour == 10U || hour == 22U) {
words.push_back(("dez"));
} else if (hour == 11U || hour == 23U) {
words.push_back(("onze"));
} else {
words.push_back(("meio-dia"));
}
if (min == 0U)
words.push_back(("hora"));
else if (min == 15U)
words.push_back(("e_quinze"));
else if (min == 30U)
words.push_back(("e_meia"));
return words;
}
bool CTimeServerThread::loadAMBE()
{
std::string ambeFileName;
std::string indxFileName;
switch (m_language) {
case LANG_ENGLISH_US_1:
case LANG_ENGLISH_US_2:
ambeFileName = "TIME_en_US.ambe";
indxFileName = "TIME_en_US.indx";
break;
case LANG_DEUTSCH_1:
case LANG_DEUTSCH_2:
ambeFileName = "TIME_de_DE.ambe";
indxFileName = "TIME_de_DE.indx";
break;
case LANG_FRANCAIS:
ambeFileName = "TIME_fr_FR.ambe";
indxFileName = "TIME_fr_FR.indx";
break;
case LANG_NEDERLANDS:
ambeFileName = "TIME_nl_NL.ambe";
indxFileName = "TIME_nl_NL.indx";
break;
case LANG_SVENSKA:
ambeFileName = "TIME_se_SE.ambe";
indxFileName = "TIME_se_SE.indx";
break;
case LANG_ESPANOL:
ambeFileName = "TIME_es_ES.ambe";
indxFileName = "TIME_es_ES.indx";
break;
case LANG_NORSK:
ambeFileName = "TIME_no_NO.ambe";
indxFileName = "TIME_no_NO.indx";
break;
case LANG_PORTUGUES:
ambeFileName = "TIME_pt_PT.ambe";
indxFileName = "TIME_pt_PT.indx";
break;
default:
ambeFileName = "TIME_en_GB.ambe";
indxFileName = "TIME_en_GB.indx";
break;
}
bool ret = readAMBE(m_dataPath, ambeFileName);
if (!ret) {
delete[] m_ambe;
m_ambe = NULL;
return false;
}
ret = readIndex(m_dataPath, indxFileName);
if (!ret) {
delete[] m_ambe;
m_ambe = NULL;
return false;
}
return true;
}
bool CTimeServerThread::readAMBE(const std::string& dir, const std::string& name)
{
std::string fileName = dir + "/" + name;
struct stat sbuf;
if (stat(fileName.c_str(), &sbuf)) {
CLog::logInfo("File %s not readable\n", fileName.c_str());
fileName.append("/data/");
fileName += name;
if (stat(fileName.c_str(), &sbuf)) {
CLog::logInfo("File %s not readable\n", fileName.c_str());
return false;
}
}
unsigned int fsize = sbuf.st_size;
FILE *file = fopen(fileName.c_str(), "rb");
if (NULL == file) {
CLog::logInfo("Cannot open %s for reading\n", fileName.c_str());
return false;
}
CLog::logInfo("Reading %s\n", fileName.c_str());
unsigned char buffer[VOICE_FRAME_LENGTH_BYTES];
size_t n = fread(buffer, sizeof(unsigned char), 4, file);
if (n != 4) {
CLog::logError("Unable to read the header from %s\n", fileName.c_str());
fclose(file);
return false;
}
if (memcmp(buffer, "AMBE", 4)) {
CLog::logError("Invalid header from %s\n", fileName.c_str());
fclose(file);
return false;
}
// Length of the file minus the header
unsigned int length = fsize - 4U;
// Hold the file data plus silence at the end
m_ambe = new unsigned char[length + SILENCE_LENGTH * VOICE_FRAME_LENGTH_BYTES];
m_ambeLength = length / VOICE_FRAME_LENGTH_BYTES;
// Add silence to the beginning of the buffer
unsigned char* p = m_ambe;
for (unsigned int i = 0U; i < SILENCE_LENGTH; i++, p += VOICE_FRAME_LENGTH_BYTES)
memcpy(p, NULL_AMBE_DATA_BYTES, VOICE_FRAME_LENGTH_BYTES);
n = fread(p, 1, length, file);
if (n != length) {
CLog::logError("Unable to read the AMBE data from %s\n", fileName.c_str());
fclose(file);
delete[] m_ambe;
m_ambe = NULL;
return false;
}
fclose(file);
return true;
}
bool CTimeServerThread::readIndex(const std::string& dir, const std::string& name)
{
std::string fileName = dir + "/" + name;
struct stat sbuf;
if (stat(fileName.c_str(), &sbuf)) {
CLog::logInfo("File %s not readable\n", fileName.c_str());
fileName.append("/data/");
fileName += name;
if (stat(fileName.c_str(), &sbuf)) {
CLog::logInfo("File %s not readable\n", fileName.c_str());
return false;
}
}
FILE *file = fopen(fileName.c_str(), "r");
if (NULL == file) {
CLog::logInfo("Cannot open %s for reading\n", fileName.c_str());
return false;
}
// Add a silence entry at the beginning
m_index[" "] = new CIndexRecord(" ", 0, SILENCE_LENGTH);
CLog::logInfo("Reading %s\n", fileName.c_str());
char line[128];
while (fgets(line, 128, file)) {
if (strlen(line) && '#'!=line[0]) {
const std::string space(" \t\r\n");
std::string name(strtok(line, space.c_str()));
std::string strt(strtok(NULL, space.c_str()));
std::string leng(strtok(NULL, space.c_str()));
if (name.size() && strt.size() && leng.size()) {
unsigned long start = std::stoul(strt);
unsigned long length = std::stoul(leng);
if (start >= m_ambeLength || (start + length) >= m_ambeLength)
CLog::logInfo("The start or end for *%s* is out of range, start: %lu, end: %lu\n", name.c_str(), start, start + length);
else
m_index[name] = new CIndexRecord(name, start + SILENCE_LENGTH, length);
}
}
}
fclose(file);
return true;
}
bool CTimeServerThread::lookup(const std::string &id)
{
CIndexRecord* info = m_index[id];
if (info == NULL) {
// wxLogError(("Cannot find the AMBE index for *%s*"), id.c_str());
return false;
}
unsigned int start = info->getStart();
unsigned int length = info->getLength();
for (unsigned int i = 0U; i < length; i++) {
unsigned char* dataIn = m_ambe + (start + i) * VOICE_FRAME_LENGTH_BYTES;
CAMBEData* dataOut = new CAMBEData;
dataOut->setDestination(m_address, G2_DV_PORT);
dataOut->setSeq(m_seqNo);
unsigned char buffer[DV_FRAME_LENGTH_BYTES];
::memcpy(buffer + 0U, dataIn, VOICE_FRAME_LENGTH_BYTES);
// Insert sync bytes when the sequence number is zero, slow data otherwise
if (m_seqNo == 0U) {
::memcpy(buffer + VOICE_FRAME_LENGTH_BYTES, DATA_SYNC_BYTES, DATA_FRAME_LENGTH_BYTES);
m_encoder.sync();
} else {
m_encoder.getInterleavedData(buffer + VOICE_FRAME_LENGTH_BYTES);
}
dataOut->setData(buffer, DV_FRAME_LENGTH_BYTES);
m_seqNo++;
if (m_seqNo == 21U)
m_seqNo = 0U;
m_data[m_in] = dataOut;
m_in++;
}
return true;
}
void CTimeServerThread::end()
{
CAMBEData* dataOut = new CAMBEData;
dataOut->setData(END_PATTERN_BYTES, DV_FRAME_LENGTH_BYTES);
dataOut->setDestination(m_address, G2_DV_PORT);
dataOut->setSeq(m_seqNo);
dataOut->setEnd(true);
m_data[m_in] = dataOut;
m_in++;
}
bool CTimeServerThread::send(const std::vector<std::string> &words, unsigned int hour, unsigned int min)
{
CHeaderData header;
header.setMyCall1(m_callsign);
header.setRptCall1(m_callsignG);
header.setRptCall2(m_callsign); // Just for the slow data header
header.setYourCall("CQCQCQ ");
header.setDestination(m_address, G2_DV_PORT);
std::string slowData;
switch (m_language) {
case LANG_DEUTSCH_1:
case LANG_DEUTSCH_2:
header.setMyCall2(("ZEIT"));
slowData = CStringUtils::string_format(("Es ist %02u:%02u Uhr"), hour, min);
break;
case LANG_FRANCAIS:
header.setMyCall2(("TIME"));
slowData = CStringUtils::string_format(("Il est %02u:%02u"), hour, min);
break;
case LANG_NEDERLANDS:
header.setMyCall2(("TIJD"));
slowData = CStringUtils::string_format(("Het is %02u:%02u"), hour, min);
break;
case LANG_SVENSKA:
header.setMyCall2(("TID "));
slowData = CStringUtils::string_format(("Klockan ar %02u:%02u"), hour, min);
break;
case LANG_ENGLISH_US_1:
case LANG_ENGLISH_UK_1:
header.setMyCall2(("TIME"));
if (hour == 0U)
slowData = CStringUtils::string_format(("It is 12:%02u AM"), min);
else if (hour == 12U)
slowData = CStringUtils::string_format(("It is 12:%02u PM"), min);
else if (hour > 12U)
slowData = CStringUtils::string_format(("It is %02u:%02u PM"), hour - 12U, min);
else
slowData = CStringUtils::string_format(("It is %02u:%02u AM"), hour, min);
break;
case LANG_ESPANOL:
header.setMyCall2(("HORA"));
if (hour == 1U)
slowData = CStringUtils::string_format(("Es la %02u:%02u"), hour, min);
else
slowData = CStringUtils::string_format(("Son las %02u:%02u"), hour, min);
break;
case LANG_NORSK:
header.setMyCall2(("TID "));
slowData = CStringUtils::string_format(("Klokken er %02u:%02u"), hour, min);
break;
case LANG_PORTUGUES:
header.setMyCall2(("HORA"));
if (hour == 1U)
slowData = CStringUtils::string_format(("E %02u:%02u"), hour, min);
else
slowData = CStringUtils::string_format(("Sao %02u:%02u"), hour, min);
break;
default:
header.setMyCall2(("TIME"));
slowData = CStringUtils::string_format(("It is %02u:%02u"), hour, min);
break;
}
m_encoder.setHeaderData(header);
m_encoder.setTextData(slowData);
m_in = 0U;
if (m_format != FORMAT_TEXT_TIME) {
std::string text = words.at(0U);
for (unsigned int i = 1U; i < words.size(); i++) {
text.push_back(' ');
text += words.at(i);
}
boost::replace_all(text, "_", " ");
CLog::logInfo(("Sending voice \"%s\", sending text \"%s\""), text.c_str(), slowData.c_str());
m_seqNo = 0U;
// Build the audio
lookup((" "));
lookup((" "));
lookup((" "));
lookup((" "));
for (unsigned int i = 0U; i < words.size(); i++)
lookup(words.at(i));
lookup((" "));
lookup((" "));
lookup((" "));
lookup((" "));
end();
} else {
CLog::logInfo(("Sending text \"%s\""), slowData.c_str());
for (unsigned int i = 0U; i < 21U; i++) {
CAMBEData* dataOut = new CAMBEData;
dataOut->setDestination(m_address, G2_DV_PORT);
dataOut->setSeq(i);
unsigned char buffer[DV_FRAME_LENGTH_BYTES];
::memcpy(buffer + 0U, NULL_AMBE_DATA_BYTES, VOICE_FRAME_LENGTH_BYTES);
// Insert sync bytes when the sequence number is zero, slow data otherwise
if (i == 0U) {
::memcpy(buffer + VOICE_FRAME_LENGTH_BYTES, DATA_SYNC_BYTES, DATA_FRAME_LENGTH_BYTES);
m_encoder.sync();
} else {
m_encoder.getTextData(buffer + VOICE_FRAME_LENGTH_BYTES);
}
dataOut->setData(buffer, DV_FRAME_LENGTH_BYTES);
m_data[m_in] = dataOut;
m_in++;
}
CAMBEData* dataOut = new CAMBEData;
dataOut->setData(END_PATTERN_BYTES, DV_FRAME_LENGTH_BYTES);
dataOut->setDestination(m_address, G2_DV_PORT);
dataOut->setSeq(0U);
dataOut->setEnd(true);
m_data[m_in] = dataOut;
m_in++;
}
if (m_in == 0U) {
CLog::logWarning(("Not sending, no audio files loaded"));
return false;
}
std::vector<unsigned int> ids;
std::vector<CUDPReaderWriter *> sockets;
for(auto rpt : m_repeaters) {
auto socket = new CUDPReaderWriter("", 0U);
sockets.push_back(socket);
ids.push_back(CHeaderData::createId());
}
bool allOpen = std::all_of(sockets.begin(), sockets.end(), [](CUDPReaderWriter* s) { return s->open(); });
if(allOpen) {
//send headers
for(unsigned int i = 0; i < m_repeaters.size(); i++) {
CHeaderData headerCopy(header);
headerCopy.setId(ids[i]);
headerCopy.setRptCall2(m_repeaters[i]);
sendHeader(*(sockets[i]), headerCopy);
Sleep(5);
}
// send audio
bool loop = true;
unsigned int out = 0U;
auto start = std::chrono::high_resolution_clock::now();
while(loop) {
unsigned int needed = std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::high_resolution_clock::now() - start).count();
needed /= DSTAR_FRAME_TIME_MS;
while (out < needed) {
for(unsigned int i = 0; i < m_repeaters.size(); i++) {
CAMBEData data(*(m_data[out]));
data.setId(ids[i]);
sendData(*(sockets[i]), data);
Sleep(5);
}
delete m_data[out];
m_data[out] = nullptr;
out++;
if (m_in == out) {
loop = false;
break;
}
}
}
}
for(auto socket : sockets) {
socket->close();
delete socket;
}
return true;
}
bool CTimeServerThread::sendHeader(CUDPReaderWriter& socket, const CHeaderData &header)
{
unsigned char buffer[60U];
unsigned int length = header.getG2Data(buffer, 60U, true);
#if defined(DUMP_TX)
CUtils::dump(("Sending Header"), buffer, length);
return true;
#else
for (unsigned int i = 0U; i < 5U; i++) {
bool res = socket.write(buffer, length, header.getYourAddress(), header.getYourPort());
if (!res)
return false;
}
return true;
#endif
}
bool CTimeServerThread::sendData(CUDPReaderWriter& socket, const CAMBEData& data)
{
unsigned char buffer[40U];
unsigned int length = data.getG2Data(buffer, 40U);
#if defined(DUMP_TX)
CUtils::dump(("Sending Data"), buffer, length);
return true;
#else
return socket.write(buffer, length, data.getYourAddress(), data.getYourPort());
#endif
}
Reference in new issue View Git Blame Copy Permalink

Powered by TurnKey Linux.