X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FProtocols%2FRaw%2FPacketSocketHandle.cc;h=f24e0b1b71c50953826a33faf0c0d29903a0bc93;hb=3863d46dd898b7bc35ea8c6ccd8563b18762a6b6;hp=05eef453add6b1291aad4046d7e041edefae4a3f;hpb=a1a6c76a214ad1935032826713cabaf9ac57bf07;p=senf.git diff --git a/Socket/Protocols/Raw/PacketSocketHandle.cc b/Socket/Protocols/Raw/PacketSocketHandle.cc index 05eef45..f24e0b1 100644 --- a/Socket/Protocols/Raw/PacketSocketHandle.cc +++ b/Socket/Protocols/Raw/PacketSocketHandle.cc @@ -21,7 +21,7 @@ // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. /** \file - \brief PacketProtocol and PacketSocketHandle non-inline non-template implementation + \brief PacketSocketProtocol and PacketSocketHandle non-inline non-template implementation */ #include "PacketSocketHandle.hh" @@ -40,7 +40,7 @@ #define prefix_ ///////////////////////////////cc.p//////////////////////////////////////// -prefix_ void senf::PacketProtocol::init_client(SocketType type, int protocol) +prefix_ void senf::PacketSocketProtocol::init_client(SocketType type, int protocol) const { int socktype = SOCK_RAW; @@ -50,22 +50,22 @@ prefix_ void senf::PacketProtocol::init_client(SocketType type, int protocol) protocol = ETH_P_ALL; int sock = ::socket(PF_PACKET, socktype, htons(protocol)); if (sock < 0) - throwErrno(); + SENF_THROW_SYSTEM_EXCEPTION("::socket(...) failed."); fd(sock); } -prefix_ unsigned senf::PacketProtocol::available() +prefix_ unsigned senf::PacketSocketProtocol::available() const { if (! fh().readable()) return 0; ssize_t l = ::recv(fd(),0,0,MSG_PEEK | MSG_TRUNC); if (l < 0) - throwErrno(); + SENF_THROW_SYSTEM_EXCEPTION("::recv(socket_fd) failed."); return l; } -prefix_ bool senf::PacketProtocol::eof() +prefix_ bool senf::PacketSocketProtocol::eof() const { return false; @@ -76,32 +76,47 @@ namespace { void do_mc(int fd, std::string const & interface, senf::MACAddress address, bool add) { struct packet_mreq mreq; + ::memset(&mreq, 0, sizeof(mreq)); mreq.mr_ifindex = ::if_nametoindex(interface.c_str()); if (mreq.mr_ifindex == 0) - senf::throwErrno(EINVAL); + throw senf::SystemException(EINVAL); mreq.mr_type = PACKET_MR_MULTICAST; mreq.mr_alen = 6; std::copy(address.begin(), address.end(), &mreq.mr_address[0]); if (::setsockopt(fd, SOL_PACKET, - add ? PACKET_ADD_MEMBERSHIP : PACKET_DROP_MEMBERSHIP, - &mreq, sizeof(mreq)) < 0) - senf::throwErrno(); + add ? PACKET_ADD_MEMBERSHIP : PACKET_DROP_MEMBERSHIP, + &mreq, sizeof(mreq)) < 0) + throw senf::SystemException(); } - } -prefix_ void senf::PacketProtocol::mcAdd(std::string const & interface, +prefix_ void senf::PacketSocketProtocol::mcAdd(std::string const & interface, MACAddress const & address) const { - do_mc(fd(),interface,address,true); + do_mc(fd(), interface, address, true); } -prefix_ void senf::PacketProtocol::mcDrop(std::string const & interface, +prefix_ void senf::PacketSocketProtocol::mcDrop(std::string const & interface, MACAddress const & address) const { - do_mc(fd(),interface,address,false); + do_mc(fd(), interface, address, false); +} + +prefix_ void senf::PacketSocketProtocol::promisc(std::string const & interface, bool mode) + const +{ + struct packet_mreq mreq; + ::memset(&mreq, 0, sizeof(mreq)); + mreq.mr_ifindex = ::if_nametoindex(interface.c_str()); + if (mreq.mr_ifindex == 0) + throw senf::SystemException(EINVAL); + mreq.mr_type = PACKET_MR_PROMISC; + if (::setsockopt(fd(), SOL_PACKET, + mode ? PACKET_ADD_MEMBERSHIP : PACKET_DROP_MEMBERSHIP, + &mreq, sizeof(mreq)) < 0) + throw senf::SystemException(); } ///////////////////////////////cc.e////////////////////////////////////////