|
|
|
|
@ -365,9 +365,8 @@ void CQnetITAP::Run(const char *cfgfile)
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (alive && (0 == memcmp(buf, "DSVT", 4)))
|
|
|
|
|
{
|
|
|
|
|
//printf("read %d bytes from QnetGateway\n", (int)len);
|
|
|
|
|
if (initialized && alive && (0 == memcmp(buf, "DSVT", 4)))
|
|
|
|
|
{ // we won't process the incoming gateway packet if the system isn't initialized and alive
|
|
|
|
|
if (ProcessGateway(len, buf))
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
@ -385,12 +384,14 @@ void CQnetITAP::Run(const char *cfgfile)
|
|
|
|
|
{
|
|
|
|
|
CFrame frame = queue.front();
|
|
|
|
|
queue.pop();
|
|
|
|
|
if (alive) {
|
|
|
|
|
SendToIcom(frame.data());
|
|
|
|
|
ackTimer.start();
|
|
|
|
|
acknowledged = false;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
else // we are waiting on an acknowledgement
|
|
|
|
|
{
|
|
|
|
|
if (ackTimer.time() >= ackwait)
|
|
|
|
|
|