X-Git-Url: http://g0dil.de/git?a=blobdiff_plain;f=Examples%2FMultiMCLoop%2FMultiMCLoop.cc;h=a6f07c85ff465636b211e345e49435b9606aa12c;hb=b2e4357d68ec6788b4b336171a9c613d3b2416c7;hp=cba9bb92d7145443b5838974bf04482c59d1930f;hpb=412024ed31a4ab4eaea7a4165a434f8efebee325;p=senf.git diff --git a/Examples/MultiMCLoop/MultiMCLoop.cc b/Examples/MultiMCLoop/MultiMCLoop.cc index cba9bb9..a6f07c8 100644 --- a/Examples/MultiMCLoop/MultiMCLoop.cc +++ b/Examples/MultiMCLoop/MultiMCLoop.cc @@ -1,6 +1,6 @@ // $Id$ // -// Copyright (C) 2008 +// Copyright (C) 2008 // Fraunhofer Institute for Open Communication Systems (FOKUS) // Competence Center NETwork research (NET), St. Augustin, GERMANY // Stefan Bund @@ -36,7 +36,7 @@ //#include "MultiMCLoop.mpp" #define prefix_ -///////////////////////////////cc.p//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// typedef senf::UDPv4ClientSocketHandle UDPSocket; @@ -52,10 +52,10 @@ public: MCReader(unsigned n, std::string const & name, UDPSocket::Address const & group); }; -prefix_ MCReader::MCReader(unsigned n, std::string const & name_, +prefix_ MCReader::MCReader(unsigned n, std::string const & name_, UDPSocket::Address const & group) : name (name_), socket (), - event (name, senf::membind(&MCReader::handler, this), socket, + event (name, senf::membind(&MCReader::handler, this), socket, senf::scheduler::FdEvent::EV_READ) { socket.protocol().reuseaddr(true); @@ -69,7 +69,7 @@ prefix_ void MCReader::handler(int events) std::cout << "I " << name << ": " << socket.read() << "\n"; } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// class MCWriter { @@ -81,9 +81,9 @@ class MCWriter unsigned count; void handler(); - + public: - MCWriter(std::string const & name, UDPSocket::Address const & group, + MCWriter(std::string const & name, UDPSocket::Address const & group, senf::ClockService::clock_type interval); }; @@ -103,7 +103,7 @@ prefix_ void MCWriter::handler() event.timeout(senf::scheduler::eventTime() + interval); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// class IfSetup { @@ -117,7 +117,7 @@ public: struct SystemException : public senf::Exception { SystemException() : senf::Exception("IfSetup::SystemException") {} }; - + }; prefix_ IfSetup::IfSetup(std::string const & iface_) @@ -145,21 +145,21 @@ prefix_ void IfSetup::sys(std::string const & cmd) throw SystemException() << ": code " << rv << ": " << cmd; } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// void sigintHandler(siginfo_t const &) { senf::scheduler::terminate(); } -/////////////////////////////////////////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// int main(int argc, char * argv[]) { try { boost::scoped_ptr setup ( (argc != 2 || std::string(argv[1]) != "-n") ? new IfSetup("dummy0") : 0); - + senf::scheduler::SignalEvent sigint (SIGINT, &sigintHandler); UDPSocket::Address g1 ("225.1:43434"); @@ -183,7 +183,7 @@ int main(int argc, char * argv[]) } }; -///////////////////////////////cc.e//////////////////////////////////////// +//-///////////////////////////////////////////////////////////////////////////////////////////////// #undef prefix_ //#include "MultiMCLoop.mpp"