X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FUtils%2FTermlib%2FTelnet.cc;h=9efb1019f4f4adcf923a7aaab2ddb6c869748f4e;hb=9bc655e14d2d8c204ed835896cb51e42d49bd68f;hp=0ce7e4554125910d7595a3520bae3d64933ddf59;hpb=9bf675b08d624cfac113a1a90dcfbd9503872b1d;p=senf.git diff --git a/senf/Utils/Termlib/Telnet.cc b/senf/Utils/Termlib/Telnet.cc index 0ce7e45..9efb101 100644 --- a/senf/Utils/Termlib/Telnet.cc +++ b/senf/Utils/Termlib/Telnet.cc @@ -1,6 +1,6 @@ // $Id$ // -// Copyright (C) 2008 +// Copyright (C) 2008 // Fraunhofer Institute for Open Communication Systems (FOKUS) // Competence Center NETwork research (NET), St. Augustin, GERMANY // Stefan Bund @@ -38,7 +38,7 @@ prefix_ senf::term::BaseTelnetProtocol::BaseTelnetProtocol(Handle handle) : handle_ (handle), charState_ (NORMAL), command_ (CMD_NONE), option_ (0), inputEvent_ ("senf::term::BaseTelnetProtocol::input", - senf::membind(&BaseTelnetProtocol::readHandler, this), handle, + senf::membind(&BaseTelnetProtocol::readHandler, this), handle, senf::scheduler::FdEvent::EV_READ), outputEvent_ ("senf::term::BaseTelnetProtocol::output", senf::membind(&BaseTelnetProtocol::writeHandler, this), handle, @@ -57,7 +57,10 @@ prefix_ senf::term::BaseTelnetProtocol::BaseTelnetProtocol() requestTimeout_ (ClockService::milliseconds(DEFAULT_REQUEST_TIMEOUT_MS)), timeout_ ("senf::term::BaseTelnetProtocol::timeout", 0) { - SENF_ASSERT( false ); + SENF_ASSERT( false, + "Missing BaseTelnetProtocol constructor call in derived class " + "(BaseTelnetProtocol is a VIRTUAL base and MUST be constructed explicitly " + "in the most derived class." ); } prefix_ void senf::term::BaseTelnetProtocol::write(std::string const & s) @@ -212,7 +215,7 @@ prefix_ void senf::term::BaseTelnetProtocol::handleCommand(char c) handleChar(c); break; } -} +} prefix_ void senf::term::BaseTelnetProtocol::handleOption(char c) { @@ -343,14 +346,14 @@ prefix_ void senf::term::BaseTelnetProtocol::readHandler(int state) } prefix_ void senf::term::BaseTelnetProtocol::writeHandler(int state) -{ +{ if (state != senf::scheduler::FdEvent::EV_WRITE) { outputEvent_.disable(); inputEvent_.disable(); v_eof(); return; } - sendQueue_.erase(sendQueue_.begin(), + sendQueue_.erase(sendQueue_.begin(), handle_.write(boost::make_iterator_range( sendQueue_.begin(), sendQueue_.end()))); if (sendQueue_.empty()) @@ -403,7 +406,7 @@ prefix_ void senf::term::BaseTelnetProtocol::response(OptInfo & info, bool enabl } else if (enabled != info.enabled) { // Request to change the current state - if (!enabled || + if (!enabled || (enabled && (info.wantState == OptInfo::WANTED || info.wantState == OptInfo::ACCEPTED))) { // accept the request info.optionState = OptInfo::ACKNOWLEDGED;