X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Examples%2FMCSniffer%2FMCSniffer.cc;h=172fea335d84be61df18ea6c8676aba1a7d7ce5d;hb=ac1dca71db955a9f19edc7ad1888bfe5bd126eac;hp=211ebaf508b9c6ac2dde3884e1b3fcc1f6e8e622;hpb=40fa3e3f1e0f639c68bd15bf469e35045f94abee;p=senf.git diff --git a/Examples/MCSniffer/MCSniffer.cc b/Examples/MCSniffer/MCSniffer.cc index 211ebaf..172fea3 100644 --- a/Examples/MCSniffer/MCSniffer.cc +++ b/Examples/MCSniffer/MCSniffer.cc @@ -38,22 +38,22 @@ //#include "MCSniffer.mpp" #define prefix_ -///////////////////////////////cc.p//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// class MCSniffer { senf::UDPv4ClientSocketHandle sock; std::ostream& stream; + senf::scheduler::FdEvent event; public: MCSniffer(senf::INet4Address addr, std::ostream& s) - : stream(s) + : stream(s), event("MCSniffer", senf::membind(&MCSniffer::dumpPacket, this), + sock, senf::scheduler::FdEvent::EV_READ) { // sock.bind(addr); sock.protocol().mcLoop(true); sock.protocol().mcAddMembership(addr); - senf::Scheduler::instance().add( - sock, senf::membind(&MCSniffer::dumpPacket, this)); } private: @@ -72,17 +72,17 @@ private: int main(int argc, char const * argv[]) -{ +{ try { std::ofstream f1 ("233.132.152.1.txt"); std::ofstream f2 ("233.132.152.2.txt"); - + MCSniffer sniffer1 ( senf::INet4Address::from_string("233.132.152.1"), f1); MCSniffer sniffer2 ( senf::INet4Address::from_string("233.132.152.2"), f2); - - senf::Scheduler::instance().process(); + + senf::scheduler::process(); } catch (std::exception const & ex) { std::cerr << senf::prettyName(typeid(ex)) << ": " << ex.what() << "\n"; @@ -90,8 +90,8 @@ int main(int argc, char const * argv[]) return 0; } - -///////////////////////////////cc.e//////////////////////////////////////// + +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_ //#include "MCSniffer.mpp"