X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Examples%2FMCSniffer%2FMCSniffer.cc;h=fd288d2edf7ac3fcac7a5f4875c8bde56fd8a420;hb=9cd0c7d8fc22ecf342c5d2a45980c245b827a67f;hp=366b40a13596f3167b22ba758d8f3e39a873eefb;hpb=31d85cd6b8e03c5ecc924ca8892906be1bab702f;p=senf.git diff --git a/Examples/MCSniffer/MCSniffer.cc b/Examples/MCSniffer/MCSniffer.cc index 366b40a..fd288d2 100644 --- a/Examples/MCSniffer/MCSniffer.cc +++ b/Examples/MCSniffer/MCSniffer.cc @@ -28,65 +28,24 @@ #include #include #include -#include "Socket/UDPSocketHandle.hh" +#include "Socket/Protocols/INet/UDPSocketHandle.hh" #include "Scheduler/Scheduler.hh" #include "Packets/DefaultBundle/EthernetPacket.hh" #include "Utils/membind.hh" +#include "Utils/hexdump.hh" //#include "MCSniffer.mpp" #define prefix_ ///////////////////////////////cc.p//////////////////////////////////////// -namespace { - - static const unsigned BLOCK_SIZE = 16; - - template - void hexdump(Iterator i, Iterator const & i_end, std::ostream& stream) - { - unsigned offset (0); - std::string ascii; - for (; i != i_end; ++i, ++offset) { - switch (offset % BLOCK_SIZE) { - case 0: - if (!ascii.empty()) { - stream << " " << ascii << "\n"; - ascii = ""; - } - stream << " " - << std::hex << std::setw(4) << std::setfill('0') - << offset << ' '; - break; - case BLOCK_SIZE/2: - stream << " "; - ascii += ' '; - break; - } - stream << ' ' << std::hex << std::setw(2) << std::setfill('0') - << unsigned(*i); - ascii += (*i >= ' ' && *i < 126) ? *i : '.'; - } - if (!ascii.empty()) { - for (; (offset % BLOCK_SIZE) != 0; ++offset) { - if ((offset % BLOCK_SIZE) == BLOCK_SIZE/2) - stream << " "; - stream << " "; - } - stream << " " << ascii << "\n"; - } - stream << std::dec; - } -} - - class MCSniffer { senf::UDPv4ClientSocketHandle sock; std::ostream& stream; public: - MCSniffer(senf::INet4Address addr, std::ostream& s) + MCSniffer(senf::INet4SocketAddress addr, std::ostream& s) : stream(s) { sock.protocol().bind(addr); @@ -100,12 +59,11 @@ private: void dumpPacket(senf::FileHandle /* ignored */, senf::Scheduler::EventId event) { std::string data (sock.read()); - senf::EthernetPacket::ptr packet ( - senf::Packet::create( - data.begin(), data.end())); - packet->dump(stream); - hexdump(packet->last()->begin(), - packet->last()->end(), + senf::EthernetPacket packet ( + senf::EthernetPacket::create(data)); + packet.dump(stream); + senf::hexdump(packet.last().data().begin(), + packet.last().data().end(), stream); stream << "\n\n"; } @@ -119,9 +77,9 @@ int main(int argc, char const * argv[]) std::ofstream f2 ("233.132.152.2.txt"); MCSniffer sniffer1 ( - senf::INet4Address::INet4Address("233.132.152.1:22344"), f1); + senf::INet4SocketAddress("233.132.152.1:22344"), f1); MCSniffer sniffer2 ( - senf::INet4Address::INet4Address("233.132.152.2:22344"), f2); + senf::INet4SocketAddress("233.132.152.2:22344"), f2); senf::Scheduler::instance().process(); } @@ -143,5 +101,6 @@ int main(int argc, char const * argv[]) // c-file-style: "senf" // indent-tabs-mode: nil // ispell-local-dictionary: "american" -// compile-command: "scons -u test" +// compile-command: "scons -u" +// comment-column: 40 // End: