X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FUtils%2FTermlib%2FTelnet.cc;h=7b65b372d797b9e298ff8a895f1de7a8ab6f555e;hb=4101c2b818ec67e7469ebb44f030eed2185c4ab0;hp=0ce7e4554125910d7595a3520bae3d64933ddf59;hpb=9bf675b08d624cfac113a1a90dcfbd9503872b1d;p=senf.git diff --git a/senf/Utils/Termlib/Telnet.cc b/senf/Utils/Termlib/Telnet.cc index 0ce7e45..7b65b37 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 @@ -33,12 +33,12 @@ //#include "Telnet.mpp" #define prefix_ -///////////////////////////////cc.p//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// 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; @@ -437,7 +440,7 @@ prefix_ void senf::term::BaseTelnetProtocol::decrementRequestCounter() } } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::term::telnethandler::TerminalType prefix_ senf::term::telnethandler::TerminalType::TerminalType() @@ -468,7 +471,7 @@ prefix_ void senf::term::telnethandler::TerminalType::v_init() incrementRequestCounter(); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// // senf::term::telnethandler::NAWS prefix_ senf::term::telnethandler::NAWS::NAWS() @@ -494,7 +497,7 @@ senf::term::telnethandler::NAWS::v_handleOptionParameters(std::string const & da decrementRequestCounter(); } -///////////////////////////////cc.e//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_ //#include "Telnet.mpp"