X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FSocketHandle.cc;h=562253b27b45d50ff96fc22ba7913b775f5ff6fa;hb=51044eb18f034c1a059ffe2fb109a422c1cbe251;hp=8365bf7e134798a2aa8ffbce18e93c92bb061d3b;hpb=31d85cd6b8e03c5ecc924ca8892906be1bab702f;p=senf.git diff --git a/Socket/SocketHandle.cc b/Socket/SocketHandle.cc index 8365bf7..562253b 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 +// 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 @@ -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"] << prettyName(typeid(protocol())); + map["socket.policy"] << prettyName(typeid(protocol().policy())); protocol().state(map,lod); } @@ -116,4 +104,5 @@ prefix_ std::ostream & senf::operator<<(std::ostream & os, SocketHandle // indent-tabs-mode: nil // ispell-local-dictionary: "american" // compile-command: "scons -u test" +// comment-column: 40 // End: