From 8d3c716c5f9423aa7df32742acec721f3ca94cd9 Mon Sep 17 00:00:00 2001 From: Geoffrey Merck Date: Sun, 20 Feb 2022 17:03:00 +0100 Subject: [PATCH] #20 clean up --- DGWTimeServer/TimeServerThread.cpp | 71 ++---------------------------- DGWTimeServer/TimeServerThread.h | 1 - 2 files changed, 3 insertions(+), 69 deletions(-) diff --git a/DGWTimeServer/TimeServerThread.cpp b/DGWTimeServer/TimeServerThread.cpp index 8018255..3efea8d 100644 --- a/DGWTimeServer/TimeServerThread.cpp +++ b/DGWTimeServer/TimeServerThread.cpp @@ -106,8 +106,8 @@ void * CTimeServerThread::Entry() unsigned int hour = tm->tm_hour; unsigned int min = tm->tm_min; - if (min != lastMin) - sendTime(15, 45); + // if (min != lastMin) + // sendTime(15, 45); if (min != lastMin) { if (m_interval == INTERVAL_15MINS && (min == 0U || min == 15U || min == 30U || min == 45U)) @@ -1339,7 +1339,7 @@ bool CTimeServerThread::send(const std::vector &words, unsigned int unsigned int out = 0U; auto start = std::chrono::high_resolution_clock::now(); - for (;loop;) { + while(loop) { unsigned int needed = std::chrono::duration_cast(std::chrono::high_resolution_clock::now() - start).count(); needed /= DSTAR_FRAME_TIME_MS; @@ -1368,74 +1368,9 @@ bool CTimeServerThread::send(const std::vector &words, unsigned int delete socket; } - // bool res = true; - // for(auto rpt : m_repeaters) { - // res = sendToRepeater(header, rpt) && res; - // } - - // std::vector *> tasks; - - // for(auto rpt : m_repeaters) { - // std::packaged_task * task = new std::packaged_task([header, rpt, this] { return sendToRepeater(header, rpt);} ); - // std::thread t(std::move(*task)); - // } - - // bool res = true; - // for(auto task : tasks) { - // auto future = task->get_future(); - // future.wait(); - // res = future.get() && res; - // delete task; - // } - - // for(unsigned int i = 0U; i < MAX_FRAMES; i++) { - // delete m_data[i]; - // m_data[i] = nullptr; - // } - return true; } -bool CTimeServerThread::sendToRepeater(const CHeaderData& h, const std::string& rptCall2) -{ - CUDPReaderWriter socket("", 0U); - if(!socket.open()) - return false; - - auto id = CHeaderData::createId(); - CHeaderData header(h); - header.setId(id); - header.setRptCall2(rptCall2); - - sendHeader(socket, header); - - bool loop = true; - unsigned int out = 0U; - auto start = std::chrono::high_resolution_clock::now(); - - for (;loop;) { - unsigned int needed = std::chrono::duration_cast(std::chrono::high_resolution_clock::now() - start).count(); - needed /= DSTAR_FRAME_TIME_MS; - - while (out < needed) { - CAMBEData data(*(m_data[out])); - out++; - data.setId(id); - sendData(socket, data); - - if (m_in == out) { - loop = false; - break; - } - } - - Sleep(10UL); - } - - socket.close(); - - return true; -} bool CTimeServerThread::sendHeader(CUDPReaderWriter& socket, const CHeaderData &header) { diff --git a/DGWTimeServer/TimeServerThread.h b/DGWTimeServer/TimeServerThread.h index ef501fc..3abe883 100644 --- a/DGWTimeServer/TimeServerThread.h +++ b/DGWTimeServer/TimeServerThread.h @@ -108,7 +108,6 @@ private: bool send(const std::vector& words, unsigned int hour, unsigned int min); bool sendHeader(CUDPReaderWriter& socket, const CHeaderData& header); bool sendData(CUDPReaderWriter& socket, const CAMBEData& data); - bool sendToRepeater(const CHeaderData& header, const std::string& rptCall2); bool loadAMBE(); bool readAMBE(const std::string& dir, const std::string& name);