X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FSocketHandle.cc;h=042d2671d0719557d6497980e79cbd643b28adb7;hb=6f50bf49e282c0528f51faa0a245bbfa2b867399;hp=7d9281556ec2a9a7288d729695ebd951cfa445a8;hpb=70633abc330f835e2ae9e50d2b7e8f8f710d3dc6;p=senf.git diff --git a/Socket/SocketHandle.cc b/Socket/SocketHandle.cc index 7d92815..042d267 100644 --- a/Socket/SocketHandle.cc +++ b/Socket/SocketHandle.cc @@ -1,9 +1,9 @@ // $Id$ // -// Copyright (C) 2006 -// Fraunhofer Institut fuer offene Kommunikationssysteme (FOKUS) -// Kompetenzzentrum fuer Satelitenkommunikation (SatCom) -// Stefan Bund +// Copyright (C) 2006 +// Fraunhofer Institute for Open Communication Systems (FOKUS) +// Competence Center NETwork research (NET), St. Augustin, GERMANY +// Stefan Bund // // This program is free software; you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by @@ -21,7 +21,7 @@ // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. /** \file - \brief senf::SocketHandle non-inline non-template implementation + \brief SocketHandle non-inline non-template implementation */ #include "SocketHandle.hh" @@ -30,7 +30,7 @@ // Custom includes #include #include -#include "Utils/TypeInfo.hh" +#include "../Utils/TypeInfo.hh" //#include "SocketHandle.mpp" #define prefix_ @@ -38,24 +38,12 @@ 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 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 senf::SocketBody::v_eof() @@ -66,11 +54,11 @@ prefix_ bool senf::SocketBody::v_eof() 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"] << v_protocolName(); + map["socket.protocol.policy"] << prettyName(typeid(protocol().policy())); protocol().state(map,lod); } @@ -87,42 +75,6 @@ namespace { } } -prefix_ bool senf::detail::StateMapOrdering::operator()(std::string const & a1, - std::string const & a2) - const -{ - std::string::const_iterator i1 (a1.begin()); - std::string::const_iterator const i1_end (a1.end()); - std::string::const_iterator i2 (a2.begin()); - std::string::const_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 - /** \fixme shouldn't this be *i2 == '.' ? */ - 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 - /** \fixme shouldn't this be *i1 == '.' ? */ - 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 senf::detail::dumpState(SocketStateMap const & map) { std::stringstream s; @@ -147,5 +99,10 @@ prefix_ std::ostream & senf::operator<<(std::ostream & os, SocketHandle // Local Variables: // mode: c++ +// fill-column: 100 // c-file-style: "senf" +// indent-tabs-mode: nil +// ispell-local-dictionary: "american" +// compile-command: "scons -u test" +// comment-column: 40 // End: