X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FSocketHandle.cc;h=042d2671d0719557d6497980e79cbd643b28adb7;hb=6f50bf49e282c0528f51faa0a245bbfa2b867399;hp=d2ad81c4b5c2182157bfd5820bbc33c569adc96d;hpb=8d2d26f114d3df0a60c5c516fcf40671b1e55558;p=senf.git diff --git a/Socket/SocketHandle.cc b/Socket/SocketHandle.cc index d2ad81c..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 +// 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 @@ -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); }