X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=senf%2FSocket%2FClientSocketHandle.ct;fp=senf%2FSocket%2FClientSocketHandle.ct;h=c6fa8fd4de22ae470902d572ce5e65b264f16bb6;hb=601d1f509f5bb24df167a4dd5a20da67a0af9af8;hp=0000000000000000000000000000000000000000;hpb=164fe477094d42463722584e527a02379ab5d985;p=senf.git diff --git a/senf/Socket/ClientSocketHandle.ct b/senf/Socket/ClientSocketHandle.ct new file mode 100644 index 0000000..c6fa8fd --- /dev/null +++ b/senf/Socket/ClientSocketHandle.ct @@ -0,0 +1,175 @@ +// $Id$ +// +// 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 +// the Free Software Foundation; either version 2 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program; if not, write to the +// Free Software Foundation, Inc., +// 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + +/** \file + \brief ClientSocketHandle non-inline template implementation + */ + +#include "ClientSocketHandle.ih" + +// Custom includes +#include +#include +#include "../Utils/Buffer.hh" + +#define prefix_ +///////////////////////////////ct.p//////////////////////////////////////// + +/////////////////////////////////////////////////////////////////////////// +// senf::detail::ReadRange + +template +prefix_ typename boost::range_iterator::type +senf::detail::ReadRange:: +read(Handle & handle, ForwardWritableRange & range) +{ + typename boost::range_size::type nread (boost::size(range)); + SENF_SCOPED_BUFFER(char, buffer, nread); + return std::copy(buffer, handle.read(buffer,buffer+nread), boost::begin(range)); +} + +template +prefix_ typename boost::range_iterator::type +senf::detail::ReadRange:: +readfrom(Handle & handle, ForwardWritableRange & range, typename Handle::Address & addr) +{ + typename boost::range_size::type nread (boost::size(range)); + SENF_SCOPED_BUFFER(char, buffer, nread); + return std::copy(buffer, handle.readfrom(buffer,buffer+nread,addr), boost::begin(range)); +} + +/////////////////////////////////////////////////////////////////////////// +// senf::detail::WriteRange + +template +prefix_ typename boost::range_const_iterator::type +senf::detail::WriteRange:: +write(Handle & handle, ForwardReadableRange & range) +{ + typename boost::range_size::type nwrite (boost::size(range)); + typename boost::range_const_iterator::type i (boost::begin(range)); + SENF_SCOPED_BUFFER(char, buffer, nwrite); + std::copy(i, boost::end(range), buffer); + std::advance(i, handle.write(std::make_pair(buffer, buffer+nwrite)) - buffer); + return i; +} + +template +prefix_ typename boost::range_const_iterator::type +senf::detail::WriteRange:: +writeto(Handle & handle, ForwardReadableRange & range, typename Handle::Address const & addr) +{ + typename boost::range_size::type nwrite (boost::size(range)); + typename boost::range_const_iterator::type i (boost::begin(range)); + SENF_SCOPED_BUFFER(char, buffer, nwrite); + std::copy(i, boost::end(range), buffer); + std::advance(i, handle.writeto(std::make_pair(buffer, buffer+nwrite), addr) - buffer); + return i; +} + +/////////////////////////////////////////////////////////////////////////// +// senf::ClientSocketHandle + +//////////////////////////////////////// +// reading and writing + +// senf::ClientSocketHandle::read + +template +prefix_ std::string senf::ClientSocketHandle::read(unsigned limit) +{ + std::string rv; + this->read(rv, limit); + return rv; +} + +template +template +prefix_ void senf::ClientSocketHandle::read(Sequence & container, unsigned limit) +{ + if (limit == 0) + limit = available(); + container.resize(limit); + container.erase(read( std::make_pair(container.begin(), container.end()) ), + container.end()); +} + +// senf::ClientSocketHandle::readfrom + +template +prefix_ std::pair +senf::ClientSocketHandle::readfrom(unsigned limit) +{ + std::string rv; + boost::value_initialized addr; + this->readfrom(rv, addr.data(), limit); + return std::make_pair(rv, addr.data()); +} + +template +template +prefix_ void senf::ClientSocketHandle::readfrom(Sequence & container, Address & from, + unsigned limit) +{ + unsigned nread (available()); + if (limit>0 && nread>limit) + nread = limit; + container.resize(nread); + container.erase(readfrom( std::make_pair(container.begin(), container.end()), from ), + container.end()); +} + +//////////////////////////////////////// +// private members + +// senf::ClientSocketHandle::available + +template +prefix_ unsigned senf::ClientSocketHandle::available() +{ + unsigned nread = this->protocol().available(); + if (nread == 0 && this->blocking()) { + // We have to block explicitly here so we can return the + // number of bytes available explicitly. If no more date can + // be expected to arive (i.e. the other end has closed the + // connection), the socket will always be in the readable + // state. This is the only case when available() will return + // 0. + this->waitReadable(); + nread = this->protocol().available(); + } + return nread; +} + +///////////////////////////////ct.e//////////////////////////////////////// +#undef prefix_ + + +// 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: