diff options
Diffstat (limited to 'src/zmq2edi/EDISender.h')
-rw-r--r-- | src/zmq2edi/EDISender.h | 91 |
1 files changed, 0 insertions, 91 deletions
diff --git a/src/zmq2edi/EDISender.h b/src/zmq2edi/EDISender.h deleted file mode 100644 index 44502c1..0000000 --- a/src/zmq2edi/EDISender.h +++ /dev/null @@ -1,91 +0,0 @@ -/* - Copyright (C) 2002, 2003, 2004, 2005, 2006, 2007, 2008, 2009, 2010, - 2011, 2012 Her Majesty the Queen in Right of Canada (Communications - Research Center Canada) - - Copyright (C) 2018 - Matthias P. Braendli, matthias.braendli@mpb.li - - http://www.opendigitalradio.org - */ -/* - This file is part of ODR-DabMux. - - ODR-DabMux 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 3 of the - License, or (at your option) any later version. - - ODR-DabMux 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 ODR-DabMux. If not, see <http://www.gnu.org/licenses/>. -*/ - -#pragma once -#include <iostream> -#include <iterator> -#include <thread> -#include <vector> -#include <chrono> -#include <atomic> -#include "ThreadsafeQueue.h" -#include "dabOutput/dabOutput.h" -#include "dabOutput/edi/TagItems.h" -#include "dabOutput/edi/TagPacket.h" -#include "dabOutput/edi/AFPacket.h" -#include "dabOutput/edi/PFT.h" -#include "dabOutput/edi/Interleaver.h" - -// This metadata gets transmitted in the zmq stream -struct metadata_t { - uint32_t edi_time = 0; - int16_t utc_offset = 0; - uint16_t dlfc = 0; -}; - -using frame_t = std::pair<std::vector<uint8_t>, metadata_t>; - -class EDISender { - public: - EDISender() = default; - EDISender(const EDISender& other) = delete; - EDISender& operator=(const EDISender& other) = delete; - ~EDISender(); - void start(const edi_configuration_t& conf, int delay_ms, int max_delay_ms); - void push_frame(const frame_t& frame); - void print_configuration(void); - - private: - void send_eti_frame(uint8_t* p, metadata_t metadata); - void process(void); - - int tist_delay_ms = 0; - int tist_max_delay_ms = 0; - std::atomic<bool> running = ATOMIC_VAR_INIT(false); - std::thread process_thread; - edi_configuration_t edi_conf; - std::chrono::steady_clock::time_point startTime; - ThreadsafeQueue<frame_t> frames; - std::ofstream edi_debug_file; - - // The TagPacket will then be placed into an AFPacket - edi::AFPacketiser edi_afPacketiser; - - // The AF Packet will be protected with reed-solomon and split in fragments - edi::PFT edi_pft; - - // To mitigate for burst packet loss, PFT fragments can be sent out-of-order - edi::Interleaver edi_interleaver; - - // For statistics about wait time before we transmit packets, - // in microseconds - std::vector<double> wait_times; - - // Number of frames dropped because their TIST was larger than max_delay - std::atomic<size_t> num_dropped = ATOMIC_VAR_INIT(0); - -}; |