X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FClientSocketHandle.cti;h=cba6c6fbf3e853cea9c48e9b9c894f9d6910538e;hb=8fe6cb767a1b2acfec8b1017ea54a97a5b6863d3;hp=116a0608d147c63ec712406aa02967a4f309088c;hpb=f73fa16ed5abdce272ac77f8b8b9ef2b9922c266;p=senf.git diff --git a/Socket/ClientSocketHandle.cti b/Socket/ClientSocketHandle.cti index 116a060..cba6c6f 100644 --- a/Socket/ClientSocketHandle.cti +++ b/Socket/ClientSocketHandle.cti @@ -1,8 +1,8 @@ // $Id$ // // Copyright (C) 2006 -// Fraunhofer Institute for Open Communication Systems (FOKUS) -// Competence Center NETwork research (NET), St. Augustin, GERMANY +// 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 @@ -97,72 +97,69 @@ writeto(Handle & handle, ForwardReadableRange & range, typename Handle::Address //////////////////////////////////////// // structors -template -prefix_ senf::ClientSocketHandle::ClientSocketHandle() +template +prefix_ senf::ClientSocketHandle::ClientSocketHandle() {} #ifndef DOXYGEN -template +template template -prefix_ senf::ClientSocketHandle:: +prefix_ senf::ClientSocketHandle:: ClientSocketHandle(ClientSocketHandle other, - typename SocketHandle::template IsCompatible::type *) - : SocketHandle(other,true) + typename SocketHandle::template IsCompatible::type *) + : SocketHandle(other,true) {} #else -template +template template -prefix_ senf::ClientSocketHandle:: +prefix_ senf::ClientSocketHandle:: ClientSocketHandle(ClientSocketHandle other) {} #endif -template -prefix_ senf::ClientSocketHandle::ClientSocketHandle(FileHandle other, bool isChecked) - : SocketHandle(other, isChecked) +template +prefix_ senf::ClientSocketHandle::ClientSocketHandle(FileHandle other, bool isChecked) + : SocketHandle(other, isChecked) {} -template +template prefix_ -senf::ClientSocketHandle::ClientSocketHandle(std::auto_ptr protocol, - int fd) - : SocketHandle(protocol,false) -{ - this->body().fd(fd); -} +senf::ClientSocketHandle::ClientSocketHandle(std::auto_ptr body) + : SocketHandle(body) +{} #ifndef DOXYGEN -template +template template -prefix_ typename senf::SocketHandle::template IsCompatible::type const & -senf::ClientSocketHandle::operator=(ClientSocketHandle other) +prefix_ typename senf::SocketHandle::template IsCompatible::type const & +senf::ClientSocketHandle::operator=(ClientSocketHandle other) { assign(other); return *this; } #else -template +template template prefix_ OtherPolicy const & -senf::ClientSocketHandle::operator=(ClientSocketHandle other) +senf::ClientSocketHandle::operator=(ClientSocketHandle other) {} #endif //////////////////////////////////////// // reading and writing -// senf::ClientSocketHandle::read +// senf::ClientSocketHandle::read #ifndef DOXYGEN -template +template template prefix_ typename boost::range_iterator::type -senf::ClientSocketHandle:: +senf::ClientSocketHandle:: read(ForwardWritableRange const & range, typename boost::disable_if< boost::is_convertible >::type *) { return detail::ReadRange< - ClientSocketHandle, + ClientSocketHandle, ForwardWritableRange const, contiguous_storage_iterator< typename boost::range_iterator::type @@ -170,24 +167,24 @@ read(ForwardWritableRange const & range, >::read(*this, range); } #else -template +template template prefix_ typename boost::range_iterator::type -senf::ClientSocketHandle:: +senf::ClientSocketHandle:: read(ForwardWritableRange const & range) {} #endif #ifndef DOXYGEN -template +template template prefix_ typename boost::range_iterator::type -senf::ClientSocketHandle:: +senf::ClientSocketHandle:: read(ForwardWritableRange & range, typename boost::disable_if< boost::is_convertible >::type *) { return detail::ReadRange< - ClientSocketHandle, + ClientSocketHandle, ForwardWritableRange, contiguous_storage_iterator< typename boost::range_iterator::type @@ -195,29 +192,29 @@ read(ForwardWritableRange & range, >::read(*this, range); } #else -template +template template prefix_ typename boost::range_iterator::type -senf::ClientSocketHandle:: +senf::ClientSocketHandle:: read(ForwardWritableRange & range) {} #endif -template -prefix_ char * senf::ClientSocketHandle::read(char * start, char * end) +template +prefix_ char * senf::ClientSocketHandle::read(char * start, char * end) { - return start + Policy::ReadPolicy::read(*this, start, end-start); + return start + SPolicy::ReadPolicy::read(*this, start, end-start); } -// senf::ClientSocketHandle::readfrom +// senf::ClientSocketHandle::readfrom -template +template template prefix_ typename boost::range_iterator::type -senf::ClientSocketHandle::readfrom(ForwardWritableRange const & range, Address & from) +senf::ClientSocketHandle::readfrom(ForwardWritableRange const & range, Address & from) { return detail::ReadRange< - ClientSocketHandle, + ClientSocketHandle, ForwardWritableRange const, contiguous_storage_iterator< typename boost::range_iterator::type @@ -225,13 +222,13 @@ senf::ClientSocketHandle::readfrom(ForwardWritableRange const & range, A >::readfrom(*this, range, from); } -template +template template prefix_ typename boost::range_iterator::type -senf::ClientSocketHandle::readfrom(ForwardWritableRange & range, Address & from) +senf::ClientSocketHandle::readfrom(ForwardWritableRange & range, Address & from) { return detail::ReadRange< - ClientSocketHandle, + ClientSocketHandle, ForwardWritableRange, contiguous_storage_iterator< typename boost::range_iterator::type @@ -239,22 +236,22 @@ senf::ClientSocketHandle::readfrom(ForwardWritableRange & range, Address >::readfrom(*this, range, from); } -template -prefix_ char * senf::ClientSocketHandle::readfrom(char * start, char * end, +template +prefix_ char * senf::ClientSocketHandle::readfrom(char * start, char * end, Address & from) { - return start + Policy::ReadPolicy::readfrom(*this, start, end-start, from); + return start + SPolicy::ReadPolicy::readfrom(*this, start, end-start, from); } -// senf::ClientSocketHandle::write +// senf::ClientSocketHandle::write -template +template template prefix_ typename boost::range_const_iterator::type -senf::ClientSocketHandle::write(ForwardReadableRange const & range) +senf::ClientSocketHandle::write(ForwardReadableRange const & range) { return detail::WriteRange< - ClientSocketHandle, + ClientSocketHandle, ForwardReadableRange const, contiguous_storage_iterator< typename boost::range_iterator::type @@ -262,21 +259,21 @@ senf::ClientSocketHandle::write(ForwardReadableRange const & range) >::write(*this, range); } -template -prefix_ char const * senf::ClientSocketHandle::write(char const * start, char const * end) +template +prefix_ char const * senf::ClientSocketHandle::write(char const * start, char const * end) { - return start + Policy::WritePolicy::write(*this, start, end-start); + return start + SPolicy::WritePolicy::write(*this, start, end-start); } -// senf::ClientSocketHandle::writeto +// senf::ClientSocketHandle::writeto -template +template template prefix_ typename boost::range_const_iterator::type -senf::ClientSocketHandle::writeto(AddressParam addr, ForwardReadableRange const & range) +senf::ClientSocketHandle::writeto(AddressParam addr, ForwardReadableRange const & range) { return detail::WriteRange< - ClientSocketHandle, + ClientSocketHandle, ForwardReadableRange const, contiguous_storage_iterator< typename boost::range_iterator::type @@ -284,116 +281,85 @@ senf::ClientSocketHandle::writeto(AddressParam addr, ForwardReadableRang >::writeto(*this, range, addr); } -template -prefix_ char const * senf::ClientSocketHandle::writeto(AddressParam addr, +template +prefix_ char const * senf::ClientSocketHandle::writeto(AddressParam addr, char const * start, char const * end) { - return start + Policy::WritePolicy::writeto(*this, addr, start, end-start); + return start + SPolicy::WritePolicy::writeto(*this, addr, start, end-start); } //////////////////////////////////////// // addressing -// senf::ClientSocketHandle::peer +// senf::ClientSocketHandle::peer -template -prefix_ typename Policy::AddressingPolicy::Address -senf::ClientSocketHandle::peer() +template +prefix_ typename SPolicy::AddressingPolicy::Address +senf::ClientSocketHandle::peer() { - typename Policy::AddressingPolicy::Address addr; + typename SPolicy::AddressingPolicy::Address addr; this->peer(addr); return addr; } -template -prefix_ void senf::ClientSocketHandle:: -peer(typename Policy::AddressingPolicy::Address & addr) +template +prefix_ void senf::ClientSocketHandle:: +peer(typename SPolicy::AddressingPolicy::Address & addr) { - Policy::AddressingPolicy::peer(*this,addr); + SPolicy::AddressingPolicy::peer(*this,addr); } -// senf::ClientSocketHandle::local +// senf::ClientSocketHandle::local -template -prefix_ typename Policy::AddressingPolicy::Address -senf::ClientSocketHandle::local() +template +prefix_ typename SPolicy::AddressingPolicy::Address +senf::ClientSocketHandle::local() { - typename Policy::AddressingPolicy::Address addr; + typename SPolicy::AddressingPolicy::Address addr; this->local(addr); return addr; } -template -prefix_ void senf::ClientSocketHandle:: -local(typename Policy::AddressingPolicy::Address & addr) -{ - Policy::AddressingPolicy::local(*this,addr); -} - -// senf::ClientSocketHandle::connect - -template -prefix_ void senf::ClientSocketHandle::connect(AddressParam addr) +template +prefix_ void senf::ClientSocketHandle:: +local(typename SPolicy::AddressingPolicy::Address & addr) { - Policy::AddressingPolicy::connect(*this,addr); + SPolicy::AddressingPolicy::local(*this,addr); } -// senf::ClientSocketHandle::bind +// senf::ClientSocketHandle::connect -template -prefix_ void senf::ClientSocketHandle:: -bind(typename boost::call_traits::param_type addr) +template +prefix_ void senf::ClientSocketHandle::connect(AddressParam addr) { - Policy::AddressingPolicy::bind(*this,addr); + SPolicy::AddressingPolicy::connect(*this,addr); } -//////////////////////////////////////// -// Buffering - -// senf::ClientSocketHandle::rcvbuf - -template -prefix_ unsigned senf::ClientSocketHandle::rcvbuf() -{ - return Policy::BufferingPolicy::rcvbuf(*this); -} - -template -prefix_ void senf::ClientSocketHandle::rcvbuf(unsigned size) -{ - Policy::BufferingPolicy::rcvbuf(*this,size); -} - -// senf::ClientSocketHandle::sndbuf - -template -prefix_ unsigned senf::ClientSocketHandle::sndbuf() -{ - return Policy::BufferingPolicy::sndbuf(*this); -} +// senf::ClientSocketHandle::bind -template -prefix_ void senf::ClientSocketHandle::sndbuf(unsigned size) +template +prefix_ void senf::ClientSocketHandle:: +bind(typename boost::call_traits::param_type addr) { - Policy::BufferingPolicy::sndbuf(*this,size); + SPolicy::AddressingPolicy::bind(*this,addr); } //////////////////////////////////////// // Casting -template -prefix_ senf::ClientSocketHandle -senf::ClientSocketHandle::cast_static(FileHandle handle) +template +prefix_ senf::ClientSocketHandle +senf::ClientSocketHandle::cast_static(FileHandle handle) { return ClientSocketHandle(handle, true); } -template -prefix_ senf::ClientSocketHandle -senf::ClientSocketHandle::cast_dynamic(FileHandle handle) +template +prefix_ senf::ClientSocketHandle +senf::ClientSocketHandle::cast_dynamic(FileHandle handle) { - SocketHandle h (SocketHandle::cast_dynamic(handle)); + SocketHandle h (SocketHandle::cast_dynamic(handle)); if (static_cast(FileHandle::body(h)).isServer()) throw std::bad_cast(); return cast_static(handle); @@ -402,15 +368,15 @@ senf::ClientSocketHandle::cast_dynamic(FileHandle handle) //////////////////////////////////////// // State information -template -prefix_ void senf::ClientSocketHandle::state(SocketStateMap & map, unsigned lod) +template +prefix_ void senf::ClientSocketHandle::state(SocketStateMap & map, unsigned lod) { map["handle"] = prettyName(typeid(*this)); this->body().state(map,lod); } -template -prefix_ std::string senf::ClientSocketHandle::dumpState(unsigned lod) +template +prefix_ std::string senf::ClientSocketHandle::dumpState(unsigned lod) { SocketStateMap map; state(map,lod);