8874d1262b
This commit adds a maybeFixupVoiceFrame() function that is used by both the RF and Net code to manage FEC regeneration and DTMF blanking in voice frames. The presence of Fast Data is discovered by reading the mini-header in every second data frame. If found, FEC regeneration and DTMF blanking are disabled for the current and next voice frames. An exception is voice frames that have a sync frame instead of a data frame. This commit always disables FEC regeneration and DTMF blanking for these frames. A later commit will add support for these frames by setting aside the voice frame until the next data frame can be read. This commit also includes a number of debugging statements that will be removed in a later commit.
152 lines
5.1 KiB
C++
152 lines
5.1 KiB
C++
/*
|
|
* Copyright (C) 2015-2019 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.
|
|
*/
|
|
|
|
#if !defined(DStarControl_H)
|
|
#define DStarControl_H
|
|
|
|
#include "RSSIInterpolator.h"
|
|
#include "DStarNetwork.h"
|
|
#include "DStarSlowData.h"
|
|
#include "DStarDefines.h"
|
|
#include "DStarHeader.h"
|
|
#include "RingBuffer.h"
|
|
#include "StopWatch.h"
|
|
#include "AMBEFEC.h"
|
|
#include "Display.h"
|
|
#include "Defines.h"
|
|
#include "Timer.h"
|
|
#include "Modem.h"
|
|
|
|
#include <string>
|
|
#include <vector>
|
|
|
|
class CDStarControl {
|
|
public:
|
|
CDStarControl(const std::string& callsign, const std::string& module, bool selfOnly, bool ackReply, unsigned int ackTime, bool ackMessage, bool errorReply, const std::vector<std::string>& blackList, const std::vector<std::string>& whiteList, CDStarNetwork* network, CDisplay* display, unsigned int timeout, bool duplex, bool remoteGateway, CRSSIInterpolator* rssiMapper);
|
|
~CDStarControl();
|
|
|
|
bool writeModem(unsigned char* data, unsigned int len);
|
|
|
|
unsigned int readModem(unsigned char* data);
|
|
|
|
void clock();
|
|
|
|
bool isBusy() const;
|
|
|
|
void enable(bool enabled);
|
|
|
|
private:
|
|
unsigned char* m_callsign;
|
|
unsigned char* m_gateway;
|
|
bool m_selfOnly;
|
|
bool m_ackReply;
|
|
bool m_ackMessage;
|
|
bool m_errorReply;
|
|
bool m_remoteGateway;
|
|
std::vector<std::string> m_blackList;
|
|
std::vector<std::string> m_whiteList;
|
|
CDStarNetwork* m_network;
|
|
CDisplay* m_display;
|
|
bool m_duplex;
|
|
CRingBuffer<unsigned char> m_queue;
|
|
CDStarHeader m_rfHeader;
|
|
CDStarHeader m_netHeader;
|
|
RPT_RF_STATE m_rfState;
|
|
RPT_NET_STATE m_netState;
|
|
bool m_net;
|
|
CDStarSlowData m_slowData;
|
|
unsigned char m_rfN;
|
|
unsigned char m_netN;
|
|
CTimer m_networkWatchdog;
|
|
CTimer m_rfTimeoutTimer;
|
|
CTimer m_netTimeoutTimer;
|
|
CTimer m_packetTimer;
|
|
CTimer m_ackTimer;
|
|
CTimer m_errTimer;
|
|
CStopWatch m_interval;
|
|
CStopWatch m_elapsed;
|
|
unsigned int m_rfFrames;
|
|
unsigned int m_netFrames;
|
|
unsigned int m_netLost;
|
|
CAMBEFEC m_fec;
|
|
unsigned int m_rfBits;
|
|
unsigned int m_netBits;
|
|
unsigned int m_rfErrs;
|
|
unsigned int m_netErrs;
|
|
unsigned char* m_lastFrame;
|
|
bool m_lastFrameValid;
|
|
CRSSIInterpolator* m_rssiMapper;
|
|
unsigned char m_rssi;
|
|
unsigned char m_maxRSSI;
|
|
unsigned char m_minRSSI;
|
|
unsigned int m_aveRSSI;
|
|
unsigned int m_rssiCount;
|
|
bool m_enabled;
|
|
FILE* m_fp;
|
|
unsigned char* m_rfVoiceSyncData;
|
|
unsigned int m_rfVoiceSyncDataLen;
|
|
unsigned char* m_netVoiceSyncData;
|
|
unsigned int m_netVoiceSyncDataLen;
|
|
bool m_rfNextFrameIsFastData;
|
|
bool m_netNextFrameIsFastData;
|
|
unsigned int m_rfSkipDTMFBlankingFrames;
|
|
unsigned int m_netSkipDTMFBlankingFrames;
|
|
|
|
|
|
unsigned int maybeFixupVoiceFrame(
|
|
unsigned char* data,
|
|
unsigned int len,
|
|
unsigned int offset,
|
|
const char* log_prefix,
|
|
unsigned char n,
|
|
bool blank_dtmf,
|
|
unsigned char* voice_sync_data,
|
|
unsigned int* voice_sync_data_len,
|
|
bool* next_frame_is_fast_data,
|
|
unsigned int* skip_dtmf_blanking_frames
|
|
);
|
|
|
|
void writeNetwork();
|
|
|
|
void writeQueueHeaderRF(const unsigned char* data);
|
|
void writeQueueDataRF(const unsigned char* data);
|
|
void writeQueueEOTRF();
|
|
void writeQueueHeaderNet(const unsigned char* data);
|
|
void writeQueueDataNet(const unsigned char* data);
|
|
void writeQueueEOTNet();
|
|
void writeNetworkHeaderRF(const unsigned char* data);
|
|
void writeNetworkDataRF(const unsigned char* data, unsigned int errors, bool end);
|
|
|
|
void writeEndRF();
|
|
void writeEndNet();
|
|
|
|
bool openFile();
|
|
bool writeFile(const unsigned char* data, unsigned int length);
|
|
void closeFile();
|
|
|
|
bool insertSilence(const unsigned char* data, unsigned char seqNo);
|
|
void insertSilence(unsigned int count);
|
|
|
|
void blankDTMF(unsigned char* data) const;
|
|
|
|
void sendAck();
|
|
void sendError();
|
|
};
|
|
|
|
#endif
|