RateAnalyzer.cc

Go to the documentation of this file.
00001 // $Id: RateAnalyzer.cc 1772 2011-03-10 12:45:21Z tho $
00002 //
00003 // Copyright (C) 2008
00004 // Fraunhofer (FOKUS)
00005 // Competence Center NETwork research (NET), St. Augustin, GERMANY
00006 //     Stefan Bund <g0dil@berlios.de>
00007 //
00008 // This program is free software; you can redistribute it and/or modify
00009 // it under the terms of the GNU General Public License as published by
00010 // the Free Software Foundation; either version 2 of the License, or
00011 // (at your option) any later version.
00012 //
00013 // This program is distributed in the hope that it will be useful,
00014 // but WITHOUT ANY WARRANTY; without even the implied warranty of
00015 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00016 // GNU General Public License for more details.
00017 //
00018 // You should have received a copy of the GNU General Public License
00019 // along with this program; if not, write to the
00020 // Free Software Foundation, Inc.,
00021 // 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
00022 
00026 #include "RateAnalyzer.hh"
00027 //#include "RateAnalyzer.ih"
00028 
00029 // Custom includes
00030 
00031 //#include "RateAnalyzer.mpp"
00032 #define prefix_
00033 //-/////////////////////////////////////////////////////////////////////////////////////////////////
00034 
00035 prefix_ senf::ppi::module::RateAnalyzer::RateAnalyzer()
00036     : packets_ (0u), bytes_ (0u), minSize_ (0u), maxSize_ (0u), factor_ (0.0f)
00037 {
00038     registerEvent(timer_, &RateAnalyzer::tick);
00039 }
00040 
00041 prefix_ void senf::ppi::module::RateAnalyzer::startStatistics(ClockService::clock_type interval)
00042 {
00043     timer_.interval(interval);
00044     factor_ = double(ClockService::in_nanoseconds(interval)) /
00045         double(ClockService::in_nanoseconds(ClockService::seconds(1)));
00046 }
00047 
00048 prefix_ void senf::ppi::module::RateAnalyzer::v_handlePacket(Packet const & p)
00049 {
00050     ++packets_;
00051     unsigned sz (p.data().size());
00052     bytes_ += sz;
00053     if (sz < minSize_ || minSize_ == 0u) minSize_ = sz;
00054     if (sz > maxSize_) maxSize_ = sz;
00055 }
00056 
00057 prefix_ void senf::ppi::module::RateAnalyzer::tick()
00058 {
00059     signals.packetsPerSecond(packets_/factor_);
00060     signals.bytesPerSecond(bytes_/factor_);
00061     signals.bytesPerPacket(minSize_, float(bytes_)/float(packets_), maxSize_);
00062 
00063     packets_ = bytes_ = minSize_ = maxSize_ = 0;
00064 }
00065 
00066 //-/////////////////////////////////////////////////////////////////////////////////////////////////
00067 #undef prefix_
00068 //#include "RateAnalyzer.mpp"
00069 
00070 
00071 // Local Variables:
00072 // mode: c++
00073 // fill-column: 100
00074 // comment-column: 40
00075 // c-file-style: "senf"
00076 // indent-tabs-mode: nil
00077 // ispell-local-dictionary: "american"
00078 // compile-command: "scons -u test"
00079 // End:
SENF Extensible Network Framework

RateAnalyzer.cc
