X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Socket%2FProtocols%2FRaw%2FPacketSocketHandle.cc;h=f24e0b1b71c50953826a33faf0c0d29903a0bc93;hb=5443435c4c2b6e4386c5334b5b8358273f2bae93;hp=fc0c1f91fc48eadf176ce110abe6fac164e866d3;hpb=1d247d12d1759ffd77f456efe3a52f03dd289994;p=senf.git diff --git a/Socket/Protocols/Raw/PacketSocketHandle.cc b/Socket/Protocols/Raw/PacketSocketHandle.cc index fc0c1f9..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) - throw SystemException(); + 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) - throw SystemException(); + SENF_THROW_SYSTEM_EXCEPTION("::recv(socket_fd) failed."); return l; } -prefix_ bool senf::PacketProtocol::eof() +prefix_ bool senf::PacketSocketProtocol::eof() const { return false; @@ -76,6 +76,7 @@ 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) throw senf::SystemException(EINVAL); @@ -83,25 +84,39 @@ namespace { 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) + 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////////////////////////////////////////