X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FSocketHandle.cc;h=64735f2d227f3485be058d34555ab68db6d42308;hb=1ad3873b372da6187b1fbc645bf276287d2efb54;hp=186953aa2988386cfc37d3991541d965c9adfc82;hpb=c52cd7d87dbb525c1267aad27391b8b7365dbb57;p=senf.git diff --git a/Socket/SocketHandle.cc b/Socket/SocketHandle.cc index 186953a..64735f2 100644 --- a/Socket/SocketHandle.cc +++ b/Socket/SocketHandle.cc @@ -1,6 +1,6 @@ // $Id$ // -// Copyright (C) 2006 +// Copyright (C) 2006 // Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS) // Kompetenzzentrum fuer Satelitenkommunikation (SatCom) // Stefan Bund @@ -20,7 +20,9 @@ // Free Software Foundation, Inc., // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. -// Definition of non-inline non-template functions +/** \file + \brief SocketHandle non-inline non-template implementation + */ #include "SocketHandle.hh" #include "SocketHandle.ih" @@ -28,55 +30,43 @@ // Custom includes #include #include -#include "Utils/TypeInfo.hh" +#include "../Utils/TypeInfo.hh" //#include "SocketHandle.mpp" #define prefix_ ///////////////////////////////cc.p//////////////////////////////////////// -prefix_ void satcom::lib::SocketBody::v_close() +prefix_ void senf::SocketBody::v_close() { - if (::shutdown(fd(),SHUT_RDWR) < 0) - throw SystemException(errno); - if (::close(fd()) < 0) - throw SystemException(errno); + protocol().close(); } -prefix_ void satcom::lib::SocketBody::v_terminate() +prefix_ void senf::SocketBody::v_terminate() { - struct linger ling; - ling.l_onoff = 0; - ling.l_linger = 0; - - // We purposely IGNORE any errors: this method is used to try and - // terminate the connection ignoring any possible problems - - ::setsockopt(fd(),SOL_SOCKET,SO_LINGER,&ling,sizeof(ling)); - ::shutdown(fd(),SHUT_RDWR); - ::close(fd()); + protocol().terminate(); } -prefix_ bool satcom::lib::SocketBody::v_eof() +prefix_ bool senf::SocketBody::v_eof() const { return protocol().eof(); } -prefix_ void satcom::lib::SocketBody::state(SocketStateMap & map, unsigned lod) +prefix_ void senf::SocketBody::state(SocketStateMap & map, unsigned lod) { - map["file.handle"] = fd(); - map["file.refcount"] = refcount(); - map["socket.server"] = isServer(); - map["socket.protocol"] = prettyName(typeid(protocol())); - map["socket.policy"] = prettyName(typeid(protocol().policy())); + map["file.handle"] << fd(); + map["file.refcount"] << refcount(); + map["socket.server"] << isServer(); + map["socket.protocol"] << prettyName(typeid(protocol())); + map["socket.policy"] << prettyName(typeid(protocol().policy())); protocol().state(map,lod); } /////////////////////////////////////////////////////////////////////////// -// satcom::lib::detail::StateMapOrdering +// senf::detail::StateMapOrdering namespace { - bool contains(std::string::iterator b, std::string::iterator e, char c) + bool contains(std::string::const_iterator b, std::string::const_iterator e, char c) { for (; b != e; ++b) if (*b == c) @@ -85,40 +75,7 @@ namespace { } } -prefix_ bool satcom::lib::detail::StateMapOrdering::operator()(std::string a1, std::string a2) - const -{ - std::string::iterator i1 (a1.begin()); - std::string::iterator const i1_end (a1.end()); - std::string::iterator i2 (a2.begin()); - std::string::iterator const i2_end (a2.end()); - for(; i1 != i1_end && i2 != i2_end && *i1 == *i2; ++i1, ++i2) ; - if (i1 == i1_end) { - if (i2 == i2_end) - // the strings are equal - return false; - if (contains(i2,i2_end,'.')) - // the longer string is a sub-'directory' of the shorter - return true; - return *i1 < *i2; - } - else if (i2 == i2_end) { // && i1 != i1_end - if (contains(i1,i1_end,'.')) - // the longer string is a sub-'directory' of the shorter - return false; - return *i1 < *i2; - } - if (contains(i1,i1_end,'.')) { - if (contains(i2,i2_end,'.')) - return *i1 < *i2; - return false; - } - else if (contains(i2,i2_end,'.')) - return true; - return *i1 < *i2; -} - -prefix_ std::string satcom::lib::detail::dumpState(SocketStateMap const & map) +prefix_ std::string senf::detail::dumpState(SocketStateMap const & map) { std::stringstream s; SocketStateMap::const_iterator i (map.begin()); @@ -129,7 +86,7 @@ prefix_ std::string satcom::lib::detail::dumpState(SocketStateMap const & map) } template -prefix_ std::ostream & satcom::lib::operator<<(std::ostream & os, SocketHandle handle) +prefix_ std::ostream & senf::operator<<(std::ostream & os, SocketHandle handle) { os << handle.dumpState(); return os; @@ -142,5 +99,10 @@ prefix_ std::ostream & satcom::lib::operator<<(std::ostream & os, SocketHandle