Hibbian
/
linbpq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
linbpq/SCSTrackeMulti.c

1714 lines
37 KiB
C
Raw Permalink Normal View History

23.18
2022-08-28 09:35:46 +01:00
/*
6.0.23.26
2022-11-14 14:02:28 +00:00
Copyright 2001-2022 John Wiseman G8BPQ
23.18
2022-08-28 09:35:46 +01:00
This file is part of LinBPQ/BPQ32.
LinBPQ/BPQ32 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.
LinBPQ/BPQ32 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 LinBPQ/BPQ32. If not, see http://www.gnu.org/licenses
*/
//
// DLL to inteface DED Host Mode TNCs to BPQ32 switch
//
// Uses BPQ EXTERNAL interface
#define _CRT_SECURE_NO_WARNINGS
#define _CRT_SECURE_NO_DEPRECATE
#include <stdio.h>
#include <stdlib.h>
#include "time.h"
#define MaxStreams 10
#include "CHeaders.h"
#include "tncinfo.h"
#include "bpq32.h"
static char ClassName[]="TRACKERSTATUS";
static char WindowTitle[] = "SCS Tracker";
static int RigControlRow = 140;
#define NARROWMODE 30
#define WIDEMODE 30 // PIII only
extern UCHAR BPQDirectory[];
extern char * PortConfig[33];
static RECT Rect;
extern struct TNCINFO * TNCInfo[41]; // Records are Malloc'd
VOID __cdecl Debugprintf(const char * format, ...);
char * strlop(char * buf, char delim);
BOOL KAMStartPort(struct PORTCONTROL * PORT);
BOOL KAMStopPort(struct PORTCONTROL * PORT);
char NodeCall[11]; // Nodecall, Null Terminated
void WriteDebugLogLine(int Port, char Dirn, char * Msg, int MsgLen);
static int ProcessLine(char * buf, int Port)
{
UCHAR * ptr;
char * p_port = 0;
int BPQport;
int len=510;
struct TNCINFO * TNC;
char errbuf[256];
strcpy(errbuf, buf);
BPQport = Port;
TNC = TNCInfo[BPQport] = malloc(sizeof(struct TNCINFO));
memset(TNC, 0, sizeof(struct TNCINFO));
TNC->InitScript = malloc(1000);
TNC->InitScript[0] = 0;
TNC->PacketChannels = 10; // Default
goto ConfigLine;
while(TRUE)
{
if (GetLine(buf) == 0)
return TRUE;
ConfigLine:
strcpy(errbuf, buf);
if (memcmp(buf, "****", 4) == 0)
return TRUE;
ptr = strchr(buf, ';');
if (ptr)
{
*ptr++ = 13;
*ptr = 0;
}
if (_memicmp(buf, "APPL", 4) == 0)
{
}
else
if (_memicmp(buf, "RIGCONTROL", 10) == 0)
{
}
else
if (_memicmp(buf, "SWITCHMODES", 11) == 0)
{
}
else
if (_memicmp(buf, "USEAPPLCALLS", 12) == 0)
{
// TNC->UseAPPLCalls = TRUE;
}
else if (_memicmp(buf, "DEBUGLOG", 8) == 0) // Write Debug Log
TNC->WRITELOG = atoi(&buf[9]);
else
if (_memicmp(buf, "DEFAULT ROBUST", 14) == 0)
{
}
else
if (_memicmp(buf, "WL2KREPORT", 10) == 0)
{
}
else
if (_memicmp(buf, "UPDATEMAP", 9) == 0)
TNC->PktUpdateMap = TRUE;
else
if (_memicmp(buf, "PACKETCHANNELS", 14) == 0)
// Packet Channels
TNC->PacketChannels = atoi(&buf[14]);
else
strcat (TNC->InitScript, buf);
}
return (TRUE);
}
struct TNCINFO * CreateTTYInfo(int port, int speed);
BOOL OpenConnection(int);
BOOL SetupConnection(int);
BOOL CloseConnection(struct TNCINFO * conn);
static BOOL WriteCommBlock(struct TNCINFO * TNC);
BOOL DestroyTTYInfo(int port);
static void DEDCheckRX(struct TNCINFO * TNC);
static VOID DEDPoll(int Port);
VOID StuffAndSend(struct TNCINFO * TNC, UCHAR * Msg, int Len);
unsigned short int compute_crc(unsigned char *buf,int len);
int Unstuff(UCHAR * MsgIn, UCHAR * MsgOut, int len);
static VOID ProcessDEDFrame(struct TNCINFO * TNC);
static VOID ProcessTermModeResponse(struct TNCINFO * TNC);
static VOID ExitHost(struct TNCINFO * TNC);
static VOID DoTNCReinit(struct TNCINFO * TNC);
static VOID DoTermModeTimeout(struct TNCINFO * TNC);
VOID DoMonitorHddr(struct TNCINFO * TNC, UCHAR * Msg, int Len, int Type);
VOID DoMonitorData(struct TNCINFO * TNC, UCHAR * Msg, int Len);
int Switchmode(struct TNCINFO * TNC, int Mode);
VOID SwitchToRPacket(struct TNCINFO * TNC);
VOID SwitchToNormPacket(struct TNCINFO * TNC);
static size_t ExtProc(int fn, int port, PDATAMESSAGE buff)
{
PMSGWITHLEN buffptr;
int txlen = 0;
struct TNCINFO * TNC = TNCInfo[port];
int Stream = 0;
struct STREAMINFO * STREAM;
int TNCOK;
if (TNC == NULL)
return 0;
if (TNC->hDevice == 0)
{
// Clear anything from UI_Q
while (TNC->PortRecord->UI_Q)
{
buffptr = Q_REM(&TNC->PortRecord->UI_Q);
ReleaseBuffer(buffptr);
}
if (fn > 3 && fn < 6)
goto ok;
// Try to reopen every 30 secs
TNC->ReopenTimer++;
if (TNC->ReopenTimer < 300)
return 0;
TNC->ReopenTimer = 0;
if (TNC->PortRecord->PORTCONTROL.PortStopped == 0)
OpenCOMMPort(TNC, TNC->PortRecord->PORTCONTROL.SerialPortName, TNC->PortRecord->PORTCONTROL.BAUDRATE, TRUE);
if (TNC->hDevice == 0)
return 0;
}
ok:
switch (fn)
{
case 1: // poll
for (Stream = 0; Stream <= MaxStreams; Stream++)
{
if (TNC->Streams[Stream].ReportDISC)
{
TNC->Streams[Stream].ReportDISC = FALSE;
buff->PORT = Stream;
return -1;
}
}
DEDCheckRX(TNC);
DEDPoll(port);
DEDCheckRX(TNC);
for (Stream = 0; Stream <= MaxStreams; Stream++)
{
STREAM = &TNC->Streams[Stream];
if (STREAM->PACTORtoBPQ_Q == 0)
{
if (STREAM->DiscWhenAllSent)
{
STREAM->DiscWhenAllSent--;
if (STREAM->DiscWhenAllSent == 0)
STREAM->ReportDISC = TRUE; // Dont want to leave session attached. Causes too much confusion
}
}
else
{
int datalen;
buffptr=Q_REM(&STREAM->PACTORtoBPQ_Q);
datalen=buffptr->Len;
buff->PORT = Stream;
buff->PID = 0xf0;
memcpy(buff->L2DATA, buffptr->Data, datalen); // Data goes t, but we have an extra byte
datalen += sizeof(void *) + 4;
PutLengthinBuffer((PDATAMESSAGE)buff, datalen); // Neded for arm5 portability
// buff[5]=(datalen & 0xff);
// buff[6]=(datalen >> 8);
ReleaseBuffer(buffptr);
return (1);
}
}
return 0;
case 2: // send
buffptr = GetBuff();
if (buffptr == 0) return (0); // No buffers, so ignore
Stream = buff->PORT;
if (!TNC->TNCOK)
{
// Send Error Response
buffptr->Len = sprintf(buffptr->Data, "No Connection to TNC\r");
C_Q_ADD(&TNC->Streams[Stream].PACTORtoBPQ_Q, buffptr);
return 0;
}
txlen = GetLengthfromBuffer((PDATAMESSAGE)buff) - (sizeof(void *) + 4);;
buffptr->Len = txlen;
memcpy(buffptr->Data, buff->L2DATA, txlen);
C_Q_ADD(&TNC->Streams[Stream].BPQtoPACTOR_Q, buffptr);
TNC->Streams[Stream].FramesOutstanding++;
return (0);
case 3: // CHECK IF OK TO SEND. Also used to check if TNC is responding
Stream = (int)(size_t)buff;
TNCOK = (TNC->HostMode == 1 && TNC->ReinitState != 10);
STREAM = &TNC->Streams[Stream];
if (Stream == 0)
{
if (STREAM->FramesOutstanding > 4)
return (1 | TNCOK << 8 | STREAM->Disconnecting << 15);
}
else
{
if (STREAM->FramesOutstanding > 3 || TNC->Buffers < 200)
return (1 | TNCOK << 8 | STREAM->Disconnecting << 15); }
return TNCOK << 8 | STREAM->Disconnecting << 15; // OK, but lock attach if disconnecting
case 4: // reinit
ExitHost(TNC);
Sleep(50);
CloseCOMPort(TNC->hDevice);
TNC->hDevice =(HANDLE) 0;
TNC->ReopenTimer = 250;
TNC->HostMode = FALSE;
return (0);
case 5: // Close
// Ensure in Pactor
ExitHost(TNC);
Sleep(25);
CloseCOMPort(TNCInfo[port]->hDevice);
return (0);
case 6:
return 0; // No scan interface
}
return 0;
}
void * TrackerMExtInit(EXTPORTDATA * PortEntry)
{
char msg[500];
struct TNCINFO * TNC;
int port;
char * ptr;
int Stream = 0;
char * TempScript;
char YCmd[10];
//
// Will be called once for each DED Host TNC Port
// The COM port number is in IOBASE
//
sprintf(msg,"SCSTRK M %s", PortEntry->PORTCONTROL.SerialPortName);
WritetoConsole(msg);
port=PortEntry->PORTCONTROL.PORTNUMBER;
ReadConfigFile(port, ProcessLine);
TNC = TNCInfo[port];
if (TNC == NULL)
{
// Not defined in Config file
sprintf(msg," ** Error - no info in BPQ32.cfg for this port\n");
WritetoConsole(msg);
return ExtProc;
}
TNC->Port = port;
TNC->Hardware = H_TRKM;
// Set up DED addresses for streams
for (Stream = 0; Stream <= MaxStreams; Stream++)
{
TNC->Streams[Stream].DEDStream = Stream; // DED Stream = BPQ Stream (We don't use Stream 0)
}
if (TNC->PacketChannels > MaxStreams)
TNC->PacketChannels = MaxStreams;
PortEntry->MAXHOSTMODESESSIONS = TNC->PacketChannels + 1; //TNC->PacketChannels + 1;
PortEntry->PERMITGATEWAY = TRUE; // Can change ax.25 call on each stream
PortEntry->SCANCAPABILITIES = NONE; // Scan Control 3 stage/conlock
TNC->PortRecord = PortEntry;
if (PortEntry->PORTCONTROL.PORTCALL[0] == 0)
memcpy(TNC->NodeCall, MYNODECALL, 10);
else
ConvFromAX25(&PortEntry->PORTCONTROL.PORTCALL[0], TNC->NodeCall);
PortEntry->PORTCONTROL.PROTOCOL = 10;
PortEntry->PORTCONTROL.PORTQUALITY = 0;
PortEntry->PORTCONTROL.UICAPABLE = 1;
if (PortEntry->PORTCONTROL.PORTPACLEN == 0)
PortEntry->PORTCONTROL.PORTPACLEN = 100;
PortEntry->PORTCONTROL.PORTSTARTCODE = KAMStartPort;
PortEntry->PORTCONTROL.PORTSTOPCODE = KAMStopPort;
ptr=strchr(TNC->NodeCall, ' ');
if (ptr) *(ptr) = 0; // Null Terminate
// get NODECALL for RP tests
memcpy(NodeCall, MYNODECALL, 10);
ptr=strchr(NodeCall, ' ');
if (ptr) *(ptr) = 0; // Null Terminate
TempScript = malloc(1000);
strcpy(TempScript, "M UISC\r");
strcat(TempScript, "F 200\r"); // Sets SABM retry time to about 5 secs
strcat(TempScript, "%F 1500\r"); // Tones may be changed but I want this as standard
strcat(TempScript, TNC->InitScript);
free(TNC->InitScript);
TNC->InitScript = TempScript;
// Others go on end so they can't be overriden
strcat(TNC->InitScript, "Z 0\r"); // No Flow Control
sprintf(YCmd, "Y %d\r", TNC->PacketChannels);
strcat(TNC->InitScript, YCmd);
strcat(TNC->InitScript, "E 1\r"); // Echo - Restart process needs echo
sprintf(msg, "I %s\r", TNC->NodeCall);
strcat(TNC->InitScript, msg);
OpenCOMMPort(TNC,PortEntry->PORTCONTROL.SerialPortName, PortEntry->PORTCONTROL.BAUDRATE, FALSE);
TNC->InitPtr = TNC->InitScript;
WritetoConsole("\n");
return ExtProc;
}
static void DEDCheckRX(struct TNCINFO * TNC)
{
int Length, Len;
UCHAR * ptr;
UCHAR character;
UCHAR * CURSOR;
Len = ReadCOMBlock(TNC->hDevice, &TNC->RXBuffer[TNC->RXLen], 500 - TNC->RXLen);
if (Len == 0)
return; // Nothing doing
TNC->RXLen += Len;
Length = TNC->RXLen;
ptr = TNC->RXBuffer;
CURSOR = &TNC->DEDBuffer[TNC->InputLen];
if ((TNC->HostMode == 0 || TNC->ReinitState == 10) && Length > 80)
{
// Probably Signon Message
if (TNC->WRITELOG)
WriteDebugLogLine(TNC->Port, 'R', ptr, Length);
ptr[Length] = 0;
Debugprintf("TRKM %s", ptr);
TNC->RXLen = 0;
return;
}
if (TNC->HostMode == 0)
{
// If we are just restarting, and TNC is in host mode, we may get "Invalid Channel" Back
if (memcmp(ptr, "\x18\x02INVALID", 9) == 0)
{
if (TNC->WRITELOG)
WriteDebugLogLine(TNC->Port, 'R', ptr, Length);
TNC->HostMode = TRUE;
TNC->HOSTSTATE = 0;
TNC->Timeout = 0;
TNC->RXLen = 0;
return;
}
// Command is echoed as * command *
if (strstr(ptr, "*") || TNC->ReinitState == 5) // 5 is waiting for reponse to JHOST1
{
ProcessTermModeResponse(TNC);
TNC->RXLen = 0;
TNC->HOSTSTATE = 0;
return;
}
}
if (TNC->ReinitState == 10)
{
if (Length == 1 && *(ptr) == '.') // 01 echoed as .
{
// TNC is in Term Mode
if (TNC->WRITELOG)
WriteDebugLogLine(TNC->Port, 'R', ptr, Length);
TNC->ReinitState = 0;
TNC->HostMode = 0;
return;
}
}
while (Length--)
{
character = *(ptr++);
if (TNC->HostMode)
{
// n 0 Success (nothing follows)
// n 1 Success (message follows, null terminated)
// n 2 Failure (message follows, null terminated)
// n 3 Link Status (null terminated)
// n 4 Monitor Header (null terminated)
// n 5 Monitor Header (null terminated)
// n 6 Monitor Information (preceeded by length-1)
// n 7 Connect Information (preceeded by length-1)
switch(TNC->HOSTSTATE)
{
case 0: // SETCHANNEL
TNC->MSGCHANNEL = character;
TNC->HOSTSTATE++;
break;
case 1: // SETMSGTYPE
TNC->MSGTYPE = character;
if (character == 0)
{
// Success, no more info
ProcessDEDFrame(TNC);
TNC->HOSTSTATE = 0;
break;
}
if (character > 0 && character < 6)
{
// Null Terminated Response)
TNC->HOSTSTATE = 5;
CURSOR = &TNC->DEDBuffer[0];
break;
}
if (character > 5 && character < 8)
{
TNC->HOSTSTATE = 2; // Get Length
break;
}
// Invalid
Debugprintf("TRKM - Invalid MsgType %d %x %x %x", character, *(ptr), *(ptr+1), *(ptr+2));
break;
case 2: // Get Length
TNC->MSGCOUNT = character;
TNC->MSGCOUNT++; // Param is len - 1
TNC->MSGLENGTH = TNC->MSGCOUNT;
CURSOR = &TNC->DEDBuffer[0];
TNC->HOSTSTATE = 3; // Get Data
break;
case 5: // Collecting Null Terminated Response
*(CURSOR++) = character;
if (character)
continue; // MORE TO COME
ProcessDEDFrame(TNC);
TNC->HOSTSTATE = 0;
TNC->InputLen = 0;
break;
default:
// RECEIVING Counted Response
*(CURSOR++) = character;
TNC->MSGCOUNT--;
if (TNC->MSGCOUNT)
continue; // MORE TO COME
TNC->InputLen = CURSOR - TNC->DEDBuffer;
ProcessDEDFrame(TNC);
TNC->HOSTSTATE = 0;
TNC->InputLen = 0;
}
}
}
// End of Input - Save buffer position
TNC->InputLen = CURSOR - TNC->DEDBuffer;
TNC->RXLen = 0;
}
static BOOL WriteCommBlock(struct TNCINFO * TNC)
{
WriteCOMBlock(TNC->hDevice, TNC->TXBuffer, TNC->TXLen);
if (TNC->WRITELOG)
WriteDebugLogLine(TNC->Port, 'T', TNC->TXBuffer, TNC->TXLen);
TNC->Timeout = 20; // 2 secs
return TRUE;
}
static VOID DEDPoll(int Port)
{
struct TNCINFO * TNC = TNCInfo[Port];
UCHAR * Poll = TNC->TXBuffer;
int Stream = 0;
int nn;
struct STREAMINFO * STREAM;
for (Stream = 0; Stream <= MaxStreams; Stream++)
{
if (TNC->PortRecord->ATTACHEDSESSIONS[Stream] && TNC->Streams[Stream].Attached == 0)
{
// New Attach. Set call my session callsign
int calllen=0;
TNC->Streams[Stream].Attached = TRUE;
TNC->PortRecord->ATTACHEDSESSIONS[Stream]->L4USER[6] |= 0x60; // Ensure P or T aren't used on ax.25
calllen = ConvFromAX25(TNC->PortRecord->ATTACHEDSESSIONS[Stream]->L4USER, TNC->Streams[Stream].MyCall);
TNC->Streams[Stream].MyCall[calllen] = 0;
if (Stream) //Leave Stream 0 call alone
{
TNC->Streams[Stream].CmdSet = TNC->Streams[Stream].CmdSave = zalloc(100);
sprintf(TNC->Streams[Stream].CmdSet, "%c%c%cI%s", Stream, 1, 1, TNC->Streams[Stream].MyCall);
}
}
}
if (TNC->Timeout)
{
TNC->Timeout--;
if (TNC->Timeout) // Still waiting
return;
// Can't use retries, as we have no way of detecting lost chars. Have to re-init on timeout
if (TNC->HostMode == 0 || TNC->ReinitState == 10) // 10 is Recovery Mode
{
DoTermModeTimeout(TNC);
return;
}
// Timed out in host mode - Clear any connection and reinit the TNC
Debugprintf("DEDHOST - Link to TNC Lost Port %d", TNC->Port);
TNC->TNCOK = FALSE;
TNC->HostMode = 0;
TNC->ReinitState = 0;
CloseCOMPort(TNC->hDevice);
OpenCOMMPort(TNC, TNC->PortRecord->PORTCONTROL.SerialPortName, TNC->PortRecord->PORTCONTROL.BAUDRATE, TRUE);
TNC->InitPtr = TNC->InitScript;
TNC->HOSTSTATE = 0;
for (Stream = 0; Stream <= MaxStreams; Stream++)
{
if (TNC->PortRecord->ATTACHEDSESSIONS[Stream]) // Connected
{
TNC->Streams[Stream].Connected = FALSE; // Back to Command Mode
TNC->Streams[Stream].ReportDISC = TRUE; // Tell Node
}
}
}
for (Stream = 0; Stream <= MaxStreams; Stream++)
{
STREAM = &TNC->Streams[Stream];
if (STREAM->Attached)
CheckForDetach(TNC, Stream, STREAM, TidyClose, ForcedClose, CloseComplete);
if (TNC->Timeout)
return; // We've sent something
}
// if we have just restarted or TNC appears to be in terminal mode, run Initialisation Sequence
if (!TNC->HostMode)
{
DoTNCReinit(TNC);
return;
}
if (TNC->InitPtr)
{
char * start, * end;
int len;
start = TNC->InitPtr;
if (*(start) == 0) // End of Script
{
TNC->InitPtr = NULL;
Debugprintf("TRKM - Init Complete Port %d", TNC->Port);
}
else
{
end = strchr(start, 13);
len = ++end - start -1; // exclude cr
TNC->InitPtr = end;
Poll[0] = 0; // Channel
Poll[1] = 1; // Command
Poll[2] = len - 1;
memcpy(&Poll[3], start, len);
StuffAndSend(TNC, Poll, len + 3);
return;
}
}
for (Stream = 0; Stream <= MaxStreams; Stream++)
{
if (TNC->Streams[Stream].CmdSet)
{
char * start, * end;
int len;
start = TNC->Streams[Stream].CmdSet;
if (*(start + 2) == 0) // End of Script
{
free(TNC->Streams[Stream].CmdSave);
TNC->Streams[Stream].CmdSet = NULL;
}
else
{
end = strchr(start + 3, 0);
len = ++end - start -1; // exclude cr
TNC->Streams[Stream].CmdSet = end;
memcpy(&Poll[0], start, len);
Poll[2] = len - 4;
StuffAndSend(TNC, Poll, len);
return;
}
}
}
for (nn = 0; nn <= MaxStreams; nn++)
{
Stream = TNC->LastStream++;
if (TNC->LastStream > MaxStreams) TNC->LastStream = 0;
if (TNC->TNCOK && TNC->Streams[Stream].BPQtoPACTOR_Q)
{
int datalen;
PMSGWITHLEN buffptr;
char * Buffer;
buffptr=Q_REM(&TNC->Streams[Stream].BPQtoPACTOR_Q);
datalen = buffptr->Len;
Buffer = buffptr->Data; // Data portion of frame
Poll[0] = TNC->Streams[Stream].DEDStream; // Channel
if (TNC->Streams[Stream].Connected)
{
if (TNC->SwallowSignon && Stream == 0)
{
TNC->SwallowSignon = FALSE;
if (strstr(Buffer, "Connected")) // Discard *** connected
{
ReleaseBuffer(buffptr);
return;
}
}
Poll[1] = 0; // Data
TNC->Streams[Stream].BytesTXed += datalen;
Poll[2] = datalen - 1;
memcpy(&Poll[3], Buffer, datalen);
ReleaseBuffer(buffptr);
StuffAndSend(TNC, Poll, datalen + 3);
TNC->Streams[Stream].InternalCmd = TNC->Streams[Stream].Connected;
if (STREAM->Disconnecting && TNC->Streams[Stream].BPQtoPACTOR_Q == 0)
TidyClose(TNC, 0);
return;
}
// Command. Do some sanity checking and look for things to process locally
Poll[1] = 1; // Command
datalen--; // Exclude CR
if (datalen == 0) // Null Command
{
ReleaseBuffer(buffptr);
return;
}
Buffer[datalen] = 0; // Null Terminate
_strupr(Buffer);
if (_memicmp(Buffer, "D", 1) == 0)
{
TNC->Streams[Stream].ReportDISC = TRUE; // Tell Node
ReleaseBuffer(buffptr);
return;
}
if (Buffer[0] == 'C' && datalen > 2) // Connect
{
if (Stream == 0)
{
// No connects on Stream zero - for mgmt only
buffptr->Len = sprintf((UCHAR *)buffptr->Data, "TRK} Can't Connect after ATTACH\r");
C_Q_ADD(&TNC->Streams[0].PACTORtoBPQ_Q, buffptr);
return;
}
if (*(++Buffer) == ' ') Buffer++; // Space isn't needed
memcpy(TNC->Streams[Stream].RemoteCall, Buffer, 9);
TNC->Streams[Stream].Connecting = TRUE;
TNC->Streams[Stream].CmdSet = TNC->Streams[Stream].CmdSave = zalloc(100);
sprintf(TNC->Streams[Stream].CmdSet, "%c%c%cI%s%c%c%c%cC%s", Stream, 1, 1,
TNC->Streams[Stream].MyCall, 0, Stream, 1, 1, Buffer);
ReleaseBuffer(buffptr);
TNC->Streams[Stream].InternalCmd = FALSE;
return;
}
Poll[2] = datalen - 1;
memcpy(&Poll[3], Buffer, datalen);
ReleaseBuffer(buffptr);
StuffAndSend(TNC, Poll, datalen + 3);
TNC->Streams[Stream].InternalCmd = TNC->Streams[Stream].Connected;
return;
}
}
if (TNC->TNCOK && TNC->PortRecord->UI_Q)
{
int datalen;
char * Buffer;
char CCMD[80] = "C";
char Call[12] = " ";
struct _MESSAGE * buffptr;
buffptr = Q_REM(&TNC->PortRecord->UI_Q);
datalen = buffptr->LENGTH - MSGHDDRLEN;
Buffer = &buffptr->DEST[0]; // Raw Frame
Buffer[datalen] = 0;
TNC->Streams[0].CmdSet = TNC->Streams[0].CmdSave = zalloc(500);
// sprintf(TNC->Streams[Stream].CmdSet, "I%s\r%s\r", TNC->Streams[Stream].MyCall, buffptr->Data);
// Buffer has an ax.25 header, which we need to pick out and set as channel 0 Connect address
// before sending the beacon
ConvFromAX25(Buffer, &Call[1]); // Dest
strlop(&Call[1], ' ');
strcat(CCMD, Call);
Buffer += 14; // Skip Origin
datalen -= 7;
while ((Buffer[-1] & 1) == 0)
{
ConvFromAX25(Buffer, &Call[1]);
strlop(&Call[1], ' ');
strcat(CCMD, Call);
Buffer += 7; // End of addr
datalen -= 7;
}
if (Buffer[0] == 3) // UI
{
Buffer += 2;
datalen -= 2;
Poll[0] = 0; // UI Channel
Poll[1] = 1; // Data
Poll[2] = strlen(CCMD) - 1;
strcpy(&Poll[3], CCMD);
StuffAndSend(TNC, Poll, Poll[2] + 4);
sprintf(TNC->Streams[0].CmdSet, "%c%c%c%s", 0, 0, 1, Buffer);
}
ReleaseBuffer((UINT *)buffptr);
return;
}
// if frames outstanding, issue a poll (but not too often)
TNC->IntCmdDelay++;
if (TNC->IntCmdDelay > 10)
{
TNC->IntCmdDelay = 0;
Poll[0] = TNC->Streams[0].DEDStream;
Poll[1] = 0x1; // Command
TNC->Streams[0].InternalCmd = TRUE;
Poll[2] = 1; // Len-1
Poll[3] = '@';
Poll[4] = 'B'; // Buffers
StuffAndSend(TNC, Poll, 5);
return;
}
// Need to poll all channels . Just Poll zero here, the ProcessMessage will poll next
Poll[0] = 0; // Channel
Poll[1] = 0x1; // Command
Poll[2] = 0; // Len-1
Poll[3] = 'G'; // Poll
StuffAndSend(TNC, Poll, 4);
return;
Stream = TNC->StreamtoPoll;
STREAM = &TNC->Streams[Stream];
STREAM->IntCmdDelay++;
if (STREAM->IntCmdDelay > 10)
{
STREAM->IntCmdDelay = 0;
if (STREAM->FramesOutstanding)
{
Poll[0] = STREAM->DEDStream;
Poll[1] = 0x1; // Command
STREAM->InternalCmd = TRUE;
Poll[2] = 0; // Len-1
Poll[3] = 'L'; // Status
StuffAndSend(TNC, Poll, 4);
return;
}
}
Poll[0] = Stream; // Channel
Poll[1] = 0x1; // Command
Poll[2] = 0; // Len-1
Poll[3] = 'G'; // Poll
StuffAndSend(TNC, Poll, 4);
STREAM->InternalCmd = FALSE;
return;
}
static VOID DoTNCReinit(struct TNCINFO * TNC)
{
UCHAR * Poll = TNC->TXBuffer;
if (TNC->ReinitState == 0)
{
// Just Starting - Send a TNC Mode Command to see if in Terminal or Host Mode
TNC->TNCOK = FALSE;
memcpy(&TNC->TXBuffer[0], "\x18\x1b\r", 2);
TNC->TXLen = 2;
if (WriteCommBlock(TNC) == FALSE)
{
CloseCOMPort(TNC->hDevice);
OpenCOMMPort(TNC, TNC->PortRecord->PORTCONTROL.SerialPortName, TNC->PortRecord->PORTCONTROL.BAUDRATE, TRUE);
}
return;
}
if (TNC->ReinitState == 1) // Forcing back to Term
TNC->ReinitState = 0;
if (TNC->ReinitState == 2) // In Term State, Sending Initialisation Commands
{
// Put into Host Mode
memcpy(Poll, "\x18\x1bJHOST1\r", 9);
TNC->TXLen = 9;
WriteCommBlock(TNC);
TNC->ReinitState = 5;
return;
}
if (TNC->ReinitState == 5)
TNC->ReinitState = 0;
}
static VOID DoTermModeTimeout(struct TNCINFO * TNC)
{
UCHAR * Poll = TNC->TXBuffer;
if (TNC->ReinitState == 0)
{
//Checking if in Terminal Mode - Try to set back to Term Mode
TNC->ReinitState = 1;
ExitHost(TNC);
return;
}
if (TNC->ReinitState == 1)
{
// No Response to trying to enter term mode - do error recovery
Debugprintf("TRKM - Starting Resync Port %d", TNC->Port);
TNC->ReinitState = 10;
TNC->ReinitCount = 256;
TNC->HostMode = TRUE; // Must be in Host Mode if we need recovery
Poll[0] = 1;
TNC->TXLen = 1;
WriteCommBlock(TNC);
TNC->Timeout = 10; // 2 secs
return;
}
if (TNC->ReinitState == 10)
{
// Continue error recovery
TNC->ReinitCount--;
if (TNC->ReinitCount)
{
Poll[0] = 1;
TNC->TXLen = 1;
WriteCommBlock(TNC);
TNC->Timeout = 3; // 0.3 secs
return;
}
// Try Again
Debugprintf("TRKM Continuing recovery Port %d", TNC->Port);
TNC->ReinitState = 0;
// Close and re-open TNC
ExitHost(TNC);
Sleep(50);
CloseCOMPort(TNC->hDevice);
TNC->hDevice =(HANDLE) 0;
TNC->ReopenTimer = 290;
TNC->HostMode = FALSE;
return;
}
if (TNC->ReinitState == 3)
{
// Entering Host Mode
// Assume ok
TNC->HostMode = TRUE;
TNC->IntCmdDelay = 10;
return;
}
}
static VOID ExitHost(struct TNCINFO * TNC)
{
UCHAR * Poll = TNC->TXBuffer;
// Try to exit Host Mode
TNC->TXBuffer[0] = 1;
TNC->TXBuffer[1] = 1;
TNC->TXBuffer[2] = 1;
memcpy(&TNC->TXBuffer[3], "%R", 2);
StuffAndSend(TNC, Poll, 5);
return;
}
static VOID ProcessTermModeResponse(struct TNCINFO * TNC)
{
UCHAR * Poll = TNC->TXBuffer;
if (TNC->WRITELOG)
WriteDebugLogLine(TNC->Port, 'R', TNC->RXBuffer, TNC->RXLen);
if (TNC->ReinitState == 0)
{
// Testing if in Term Mode. It is, so can now send Init Commands
TNC->InitPtr = TNC->InitScript;
TNC->ReinitState = 2;
}
if (TNC->ReinitState == 1)
{
// trying to set term mode
// If already in Term Mode, TNC echos command, with control chars replaced with '.'
if (memcmp(TNC->RXBuffer, "....%R", 6) == 0)
{
// In term mode, Need to put into Host Mode
TNC->ReinitState = 2;
DoTNCReinit(TNC);
return;
}
}
if (TNC->ReinitState == 2)
{
// Sending Init Commands
DoTNCReinit(TNC); // Send Next Command
return;
}
if (TNC->ReinitState == 5) // Waiting for response to JHOST1
{
if (TNC->RXBuffer[TNC->RXLen-1] == 10 || TNC->RXBuffer[TNC->RXLen-1] == 13) // NewLine
{
TNC->HostMode = TRUE;
TNC->Timeout = 0;
}
return;
}
}
static VOID ProcessDEDFrame(struct TNCINFO * TNC)
{
PMSGWITHLEN buffptr;
char * Buffer; // Data portion of frame
UINT Stream = 0;
UCHAR * Msg = TNC->DEDBuffer;
int framelen = TNC->InputLen;
struct STREAMINFO * STREAM;
if (TNC->WRITELOG)
WriteDebugLogLine(TNC->Port, 'R', Msg, framelen);
if (TNC->ReinitState == 10)
{
// Recovering from Sync Failure
// Any Response indicates we are in host mode, and back in sync
TNC->HostMode = TRUE;
TNC->Timeout = 0;
TNC->ReinitState = 0;
TNC->RXLen = 0;
TNC->HOSTSTATE = 0;
Debugprintf("TRKM - Resync Complete");
return;
}
// Any valid frame is an ACK
TNC->Timeout = 0;
TNC->TNCOK = TRUE;
if (TNC->InitPtr) // Response to Init Script
return;
if (TNC->MSGCHANNEL > 26)
return;
Stream = TNC->MSGCHANNEL;
// See if Poll Reply or Data
if (TNC->MSGTYPE == 0)
{
// Success - Nothing Follows
if (TNC->Streams[Stream].CmdSet)
return; // Response to Command Set or Init Script
if ((TNC->TXBuffer[1] & 1) == 0) // Data
return;
// If the response to a Command, then we should convert to a text "Ok" for forward scripts, etc
if (TNC->TXBuffer[3] == 'G') // Poll
{
UCHAR * Poll = TNC->TXBuffer;
// Poll Next Channel (we need to scan all channels every DEDPOLL cycle
Stream++;
if (Stream > MaxStreams)
return;
STREAM = &TNC->Streams[Stream];
STREAM->IntCmdDelay++;
if (STREAM->IntCmdDelay > 10)
{
STREAM->IntCmdDelay = 0;
if (STREAM->FramesOutstanding)
{
Poll[0] = STREAM->DEDStream;
Poll[1] = 0x1; // Command
STREAM->InternalCmd = TRUE;
Poll[2] = 0; // Len-1
Poll[3] = 'L'; // Status
StuffAndSend(TNC, Poll, 4);
return;
}
}
Poll[0] = Stream; // Channel
Poll[1] = 0x1; // Command
Poll[2] = 0; // Len-1
Poll[3] = 'G'; // Poll
StuffAndSend(TNC, Poll, 4);
STREAM->InternalCmd = FALSE;
return;
}
if (TNC->TXBuffer[3] == 'C') // Connect - reply we need is async
return;
if (TNC->TXBuffer[3] == 'L') // Shouldnt happen!
return;
if (TNC->TXBuffer[3] == 'J') // JHOST
{
if (TNC->TXBuffer[8] == '0') // JHOST0
{
TNC->Timeout = 1; //
return;
}
}
if (TNC->MSGCHANNEL == 0) // Unproto Channel
return;
buffptr = GetBuff();
if (buffptr == NULL) return; // No buffers, so ignore
buffptr->Len = sprintf(buffptr->Data,"TRK} Ok\r");
C_Q_ADD(&TNC->Streams[Stream].PACTORtoBPQ_Q, buffptr);
return;
}
if (TNC->MSGTYPE > 0 &&TNC->MSGTYPE < 6)
{
// Success with message - null terminated
char * ptr;
int len;
Buffer = Msg;
ptr = strchr(Buffer, 0);
if (ptr == 0)
return;
*(ptr++) = 13;
*(ptr) = 0;
len = ptr - Buffer;
if (len > 256)
return;
// See if we need to process locally (Response to our command, Incoming Call, Disconencted, etc
if (TNC->MSGTYPE < 3) // 1 or 2 - Success or Fail
{
// See if a response to internal command
if (TNC->Streams[Stream].InternalCmd)
{
// Process it
char LastCmd = TNC->TXBuffer[3];
if (LastCmd == 'L') // Status
{
int s1, s2, s3, s4, s5, s6, num;
num = sscanf(Buffer, "%d %d %d %d %d %d", &s1, &s2, &s3, &s4, &s5, &s6);
TNC->Streams[Stream].FramesOutstanding = s3;
return;
}
if (LastCmd == '@') // @ Commands
{
if (TNC->TXBuffer[4]== 'B') // Buffer Status
{
TNC->Buffers = atoi(Buffer);
// SetDlgItemText(TNC->hDlg, IDC_BUFFERS, Buffer);
return;
}
}
return;
}
// Not Internal Command, so send to user
if (TNC->Streams[Stream].CmdSet)
return; // Response to Command Set
if ((TNC->TXBuffer[1] & 1) == 0) // Data
return;
// If the response to a Command, then we should convert to a text "Ok" for forward scripts, etc
if (TNC->TXBuffer[3] == 'G') // Poll
return;
if (TNC->TXBuffer[3] == 'C') // Connect - reply we need is async
return;
if (TNC->TXBuffer[3] == 'L') // Shouldnt happen!
return;
if (TNC->TXBuffer[3] == 'J') // JHOST
{
if (TNC->TXBuffer[8] == '0') // JHOST0
{
TNC->Timeout = 1; //
return;
}
}
if (TNC->MSGCHANNEL == 0) // Unproto Channel
return;
buffptr = GetBuff();
if (buffptr == NULL) return; // No buffers, so ignore
buffptr->Len = sprintf(buffptr->Data,"TRK} %s", Buffer);
C_Q_ADD(&TNC->Streams[Stream].PACTORtoBPQ_Q, buffptr);
return;
}
if (TNC->MSGTYPE == 3) // Status
{
struct STREAMINFO * STREAM = &TNC->Streams[Stream];
if (strstr(Buffer, "DISCONNECTED") || strstr(Buffer, "LINK FAILURE") || strstr(Buffer, "BUSY"))
{
if ((STREAM->Connecting | STREAM->Connected) == 0)
return;
if (STREAM->Connecting && STREAM->Disconnecting == FALSE)
{
// Connect Failed
buffptr = GetBuff();
if (buffptr == 0) return; // No buffers, so ignore
if (strstr(Buffer, "BUSY"))
buffptr->Len = sprintf(buffptr->Data, "*** Busy from %s\r", TNC->Streams[Stream].RemoteCall);
else
buffptr->Len = sprintf(buffptr->Data, "*** Failure with %s\r", TNC->Streams[Stream].RemoteCall);
C_Q_ADD(&STREAM->PACTORtoBPQ_Q, buffptr);
STREAM->Connecting = FALSE;
STREAM->Connected = FALSE; // In case!
STREAM->FramesOutstanding = 0;
STREAM->DiscWhenAllSent = 15; // Dont want to leave session attached. Causes too much confusion
return;
}
// Must Have been connected or disconnecting - Release Session
STREAM->Connecting = FALSE;
STREAM->Connected = FALSE; // Back to Command Mode
STREAM->FramesOutstanding = 0;
if (STREAM->Disconnecting == FALSE)
STREAM->ReportDISC = TRUE; // Tell Node
STREAM->Disconnecting = FALSE;
return;
}
if (strstr(Buffer, "CONNECTED"))
{
char * Call = strstr(Buffer, " to ");
char * ptr;
char MHCall[30];
Call += 4;
if (Call[1] == ':')
Call +=2;
ptr = strchr(Call, ' ');
if (ptr) *ptr = 0;
ptr = strchr(Call, 13);
if (ptr) *ptr = 0;
STREAM->Connected = TRUE; // Subsequent data to data channel
STREAM->Connecting = FALSE;
STREAM->BytesRXed = STREAM->BytesTXed = 0;
memcpy(MHCall, Call, 9);
MHCall[9] = 0;
if (TNC->PortRecord->ATTACHEDSESSIONS[Stream] == 0)
{
// Incoming Connect
// APPLCALLS * APPL;
// char * ApplPtr = &APPLS;
// int App;
// char Appl[10];
// char DestCall[10];
UpdateMH(TNC, MHCall, '+', 'I');
ProcessIncommingConnect(TNC, Call, Stream, TRUE);
if (FULL_CTEXT && HFCTEXTLEN == 0)
{
int Len = CTEXTLEN, CTPaclen = 100;
int Next = 0;
while (Len > CTPaclen) // CTEXT Paclen
{
buffptr = GetBuff();
if (buffptr == 0) return; // No buffers, so ignore
buffptr->Len = CTPaclen;
memcpy(buffptr->Data, &CTEXTMSG[Next], CTPaclen);
C_Q_ADD(&STREAM->BPQtoPACTOR_Q, buffptr);
Next += CTPaclen;
Len -= CTPaclen;
}
buffptr = GetBuff();
if (buffptr == 0) return; // No buffers, so ignore
buffptr->Len = Len;
memcpy(buffptr->Data, &CTEXTMSG[Next], Len);
C_Q_ADD(&STREAM->BPQtoPACTOR_Q, buffptr);
}
return;
}
else
{
// Connect Complete
buffptr = GetBuff();
if (buffptr == 0) return; // No buffers, so ignore
buffptr->Len = sprintf(buffptr->Data, "*** Connected to %s\r", Call);;
C_Q_ADD(&STREAM->PACTORtoBPQ_Q, buffptr);
}
}
return;
}
if (TNC->MSGTYPE == 4 || TNC->MSGTYPE == 5)
{
struct STREAMINFO * STREAM = &TNC->Streams[0]; // RP Stream
// Monitor
/*
if (TNC->UseAPPLCalls && strstr(&Msg[4], "SABM") && STREAM->Attached == FALSE)
{
// See if a call to Nodecall or one of our APPLCALLS - if so, stop scan and switch MYCALL
char DestCall[10] = "NOCALL ";
char * ptr1 = strstr(&Msg[7], "to ");
int i;
APPLCALLS * APPL;
char Appl[11];
char Status[80];
if (ptr1) memcpy(DestCall, &ptr1[3], 10);
ptr1 = strchr(DestCall, ' ');
if (ptr1) *(ptr1) = 0; // Null Terminate
Debugprintf("RP SABM Received for %s" , DestCall);
if (strcmp(TNC->NodeCall, DestCall) != 0)
{
// Not Calling NodeCall/Portcall
if (strcmp(NodeCall, DestCall) == 0)
goto SetThisCall;
// See if to one of our ApplCalls
for (i = 0; i < 32; i++)
{
APPL=&APPLCALLTABLE[i];
if (APPL->APPLCALL_TEXT[0] > ' ')
{
char * ptr;
memcpy(Appl, APPL->APPLCALL_TEXT, 10);
ptr=strchr(Appl, ' ');
if (ptr) *ptr = 0;
if (strcmp(Appl, DestCall) == 0)
{
SetThisCall:
Debugprintf("RP SABM is for NODECALL or one of our APPLCalls - setting MYCALL to %s and pausing scan", DestCall);
sprintf(Status, "%d SCANSTART 60", TNC->Port); // Pause scan for 60 secs
Rig_Command(-1, Status);
TNC->SwitchToPactor = 600; // Don't change modes for 60 secs
strcpy(STREAM->MyCall, DestCall);
STREAM->CmdSet = STREAM->CmdSave = zalloc(100);
sprintf(STREAM->CmdSet, "I%s\r", DestCall);
break;
}
}
}
}
}
*/
DoMonitorHddr(TNC, Msg, framelen, TNC->MSGTYPE);
return;
}
// 1, 2, 4, 5 - pass to Appl
if (TNC->MSGCHANNEL == 0) // Unproto Channel
return;
buffptr = GetBuff();
if (buffptr == NULL) return; // No buffers, so ignore
buffptr->Len = sprintf(buffptr->Data,"Trk} %s", &Msg[4]);
C_Q_ADD(&TNC->Streams[Stream].PACTORtoBPQ_Q, buffptr);
return;
}
if (TNC->MSGTYPE == 6)
{
// Monitor Data With length)
DoMonitorData(TNC, Msg, framelen);
return;
}
if (TNC->MSGTYPE == 7)
{
//char StatusMsg[60];
//int Status, ISS, Offset;
// Connected Data
buffptr = GetBuff();
if (buffptr == NULL) return; // No buffers, so ignore
buffptr->Len = framelen; // Length
TNC->Streams[Stream].BytesRXed += buffptr->Len;
memcpy(buffptr->Data, Msg, buffptr->Len);
C_Q_ADD(&TNC->Streams[Stream].PACTORtoBPQ_Q, buffptr);
return;
}
}
VOID TidyClose(struct TNCINFO * TNC, int Stream)
{
// Queue it as we may have just sent data
TNC->Streams[Stream].CmdSet = TNC->Streams[Stream].CmdSave = zalloc(100);
sprintf(TNC->Streams[Stream].CmdSet, "%c%c%cD", Stream, 1, 1);
}
VOID ForcedClose(struct TNCINFO * TNC, int Stream)
{
TidyClose(TNC, Stream); // I don't think Hostmode has a DD
}
VOID CloseComplete(struct TNCINFO * TNC, int Stream)
{
}