github.com/andrastantos.cray-sim
1
0
Fork 0
mirror of synced 2026-04-05 04:34:16 +00:00
Code Issues Releases Wiki Activity

Merge branch 'master' of https://github.com/andrastantos/cray-sim

Browse Source
This commit is contained in:
Andras Tantos
2021-08-22 09:32:12 -07:00
parent 59e8935a90 7c3d70e81c
commit 00e544f8dc
1 changed files with 7 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
simulator/sim_lib/console.cpp
View File

@@ -243,7 +243,7 @@ void Console_c::AcceptHandler(const boost::system::error_code& aError) {
SendOptionString(TelnetCodes_e::WONT, TelnetOptions_e::LINEMODE, true);
// SendOptionString(TelnetCodes_e::DO, TelnetOptions_e::SGA, true);
SendFromQueue();
mIoService.poll();
// mIoService.poll();
}
catch (boost::system::system_error &) {
CloseSocket();
@@ -399,25 +399,17 @@ void Console_c::ReadHandler(const boost::system::error_code& aError) {
void Console_c::WriteHandler(const boost::system::error_code& aError) {
const BitRange_s TypeRange(56, 63);
const BitRange_s FlagsRange(48, 55);
const BitRange_s RequestRange(40, 47);
const BitRange_s ResponseRange(32, 39);
const BitRange_s CharCountRange(23, 31); // character count
const BitRange_s DevRange(16, 22); // device identification
const BitRange_s SeqRange(8, 15); // sequence number of this packet
const BitRange_s AckRange(0, 7); // seq. number of last packet received
// std::cout << "w" << std::flush;
if (aError) {
CloseSocket();
return;
}
CRAY_ASSERT(!mTransmitQueue.empty());
bool DoNotify = mTransmitQueue.front().mDoNotify;
mTransmitQueue.pop();
SendFromQueue();
if (DoNotify) SendHandlerDetail();
if (!mTransmitQueue.empty()) {
bool DoNotify = mTransmitQueue.front().mDoNotify;
mTransmitQueue.pop();
SendFromQueue();
if (DoNotify) SendHandlerDetail();
}
}
void Console_c::AcceptIfNeeded(bool aSilent) {