gotEOT = true;
recvdDCN = true;
return (false);
- break;
case 0x69:
protoTrace("Control channel retrain");
// wait for the control channel to reappear
gotresponse = waitForDCEChannel(true);
gotRTNC = true;
return ((awaitctrl ? gotresponse : false));
- break;
case 0x6B:
protoTrace("Primary channel selected");
gotCTRL = false;
continue;
- break;
case 0x6D:
protoTrace("Control channel selected");
gotCTRL = true;
continue;
- break;
case 0x6E: // 1200 bit/s
case 0x6F: // 2400 bit/s
// control rate indication
}
if (awaitctrl) gotresponse = true;
continue;
- break;
case 0x70: // 2400 bit/s
case 0x71: // 4800 bit/s
case 0x72: // 7200 bit/s
}
if (!awaitctrl) gotresponse = true;
continue;
- break;
default:
// unexpected <DLE><command>, deem as garbage
garbage.append(DLE);
gotEOT = true;
recvdDCN = true;
return (false);
- break;
case 0x69:
protoTrace("Control channel retrain");
// wait for the control channel to reappear
waitForDCEChannel(true);
gotRTNC = true;
return (false);
- break;
default:
// unexpected <DLE><command>, deem as garbage
garbage.append(DLE);
gotEOT = true;
recvdDCN = true;
return (false);
- break;
case DLE: // <DLE><DLE> => <DLE>
break;
case SUB: // <DLE><SUB> => <DLE><DLE>
gotEOT = true;
recvdDCN = true;
continue;
- break;
default:
// The message is not ECM-specific: fall out of ECM receive, and let
// the earlier message-handling routines try to cope with the signal.
prevPage--; // counteract the forthcoming increment
// maybe we should save an unconfirmed page here?
return (true);
- break;
}
if (!sendERR) { // as long as we're not trying to send the ERR signal (set above)
if (useV34) gotprimary = waitForDCEChannel(false);
prevPage--; // counteract the forthcoming increment
// maybe we should save an unconfirmed page here?
return (true);
- break;
}
} else {
emsg = "T.30 T2 timeout, expected signal not received";
emsg = "COMREC invalid response received to RR.";
protoTrace(emsg);
return (false);
- break;
}
} while (!gotppr);
}
emsg = "COMREC invalid response received to RR.";
protoTrace(emsg);
return (false);
- break;
}
} while (!goterr);
}
fxStr cmd(dynamicConfig | quote | getModemDevice() | enquote | callid_formatted);
traceServer("DynamicConfig: %s", (const char*)cmd);
fxStr localid = "";
- int pipefd[2], idlength, status;
+ int pipefd[2], status;
char line[1024];
pipe(pipefd);
pid_t pid = fork();
Sys::now() + random() % requeueInterval);
delete req;
return false;
- break;
default: // parent, setup handler to wait
job.startPrepare(pid);
delete req; // must reread after preparation
job.breq = NULL;
Trigger::post(Trigger::JOB_PREP_BEGIN, job);
return true;
- break;
}
}
status = Job::failed;
} else
status >>= 8;
- bool abort = true;
if (job.suspendPending) { // co-thread waiting
job.suspendPending = false;
releaseModem(job);
{
u_int byte = 0;
while (dcs[0] != '\0' && dcs[1] != '\0') {
- u_char value = 0;
- value = 2;
m_bits[byte] = ((dcs[0] - (dcs[0] > 64 ? 55 : 48)) << 4) + (dcs[1] - (dcs[1] > 64 ? 55 : 48));
setExtendBits(byte++);
dcs += 2;