QtSoundModem/tcpCode.h at master · g8bpq/QtSoundModem · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
#include <QtCore/QCoreApplication>
#include <QtNetwork>
//#include <QDebug>

#define CONNECT(sndr, sig, rcvr, slt) connect(sndr, SIGNAL(sig), rcvr, SLOT(slt))

//class myTcpSocket : public QTcpSocket
//{
//public:
//	char Msg[512];			// Received message
//	int Len;
//	int BPQPort[4];			// BPQ port for each modem

//};


class mynet : public QObject
{
	Q_OBJECT

signals:

	void HLSetPTT(int c);
	void FLRigSetPTT(int c);
	void mgmtSetPTT(int port, int state);
	void startTimer(int Time);
	void stopTimer();

public:
	void start();
	void OpenUDP();


public slots:
	void onAGWReadyRead();
	void onKISSSocketStateChanged(QAbstractSocket::SocketState socketState);
	void onMgmtSocketStateChanged(QAbstractSocket::SocketState socketState);
	void onMgmtReadyRead();
	void onRHPConnection();
	void onRHPSocketStateChanged(QAbstractSocket::SocketState socketState);
	void onRHPReadyRead();
	void onRHPAPIConnection();
	void onRHPAPISocketStateChanged(QAbstractSocket::SocketState socketState);
	void onRHPAPIReadyRead();
	void onKISSReadyRead();
	void onAGWSocketStateChanged(QAbstractSocket::SocketState socketState);
	void onKISSConnection();
	void onMgmtConnection();
	void MyTimerSlot();
	void onAGWConnection();
	void on6PackConnection();
	void on6PackReadyRead();
	void on6PackSocketStateChanged(QAbstractSocket::SocketState socketState);
	void dropPTT();

	void displayError(QAbstractSocket::SocketError socketError);

	void sendtoKISS(void * sock, unsigned char * Msg, int Len);

	void FLRigdisplayError(QAbstractSocket::SocketError socketError);
	void FLRigreadyRead();
	void onFLRigSocketStateChanged(QAbstractSocket::SocketState socketState);
	void ConnecttoFLRig();
	void HAMLIBdisplayError(QAbstractSocket::SocketError socketError);
	void HAMLIBreadyRead();
	void onHAMLIBSocketStateChanged(QAbstractSocket::SocketState socketState);
	void ConnecttoHAMLIB();
	void dostartTimer(int Time);
	void dostopTimer();
	void doHLSetPTT(int c);
	void domgmtSetPTT(int chan, int state);
	void doFLRigSetPTT(int c);

	void readPendingDatagrams();
	void socketError();

	void sendtoRHP(void * sock, char * Msg, int Len);

private:
	QTcpServer* tcpServer;
	QTcpSocket* tcpClient;
	QTcpSocket* tcpServerConnection;
	int bytesToWrite;
	int bytesWritten;
	int bytesReceived;
	int TotalBytes;
	int PayloadSize;
	void MgmtProcessLine(QTcpSocket* socket);
};


class workerThread : public QThread
{
	Q_OBJECT
signals:
	void updateDCD(int, int);
	void sendtoTrace(char *, int);
	void sendtoKISS(void *, unsigned char *, int);
	void sendtoRHP(void *, char *, int);
	void openSockets();
	void startCWIDTimer();
	void setWaterfallImage();
	void setLevelImage();
	void setConstellationImage(int, int);
	void startWatchdog();
	void stopWatchdog();


private:
	void run();
public:

};