peerstatsdb_static.cc
上传用户:rrhhcc
上传日期:2015-12-11
资源大小:54129k
文件大小:4k
源码类别:

通讯编程

开发平台:

Visual C++

  1. /*
  2.  * Copyright (c) 2007 Regents of the SIGNET lab, University of Padova.
  3.  * All rights reserved.
  4.  *
  5.  * Redistribution and use in source and binary forms, with or without
  6.  * modification, are permitted provided that the following conditions
  7.  * are met:
  8.  * 1. Redistributions of source code must retain the above copyright
  9.  *    notice, this list of conditions and the following disclaimer.
  10.  * 2. Redistributions in binary form must reproduce the above copyright
  11.  *    notice, this list of conditions and the following disclaimer in the
  12.  *    documentation and/or other materials provided with the distribution.
  13.  * 3. Neither the name of the University of Padova (SIGNET lab) nor the 
  14.  *    names of its contributors may be used to endorse or promote products 
  15.  *    derived from this software without specific prior written permission.
  16.  *
  17.  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
  18.  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 
  19.  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 
  20.  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR 
  21.  * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 
  22.  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 
  23.  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 
  24.  * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 
  25.  * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 
  26.  * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 
  27.  * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  28.  */
  29. #include"peerstatsdb_static.h"
  30. static class StaticPeerStatsDBClass : public TclClass {
  31. public:
  32. StaticPeerStatsDBClass() : TclClass("PeerStatsDB/Static") {}
  33. TclObject* create(int, const char*const*) {
  34. return (new StaticPeerStatsDB);
  35. }
  36. } class_static_peer_stats_db_class;
  37. PeerStats* StaticPeerStatsDB::getPeerStats(u_int32_t src, u_int32_t dst)
  38. {
  39.   assert(src < num_peers);
  40.   assert(dst < num_peers);
  41.   assert(src>=0);
  42.   assert(dst>=0);
  43.   assert(peerstats);
  44.   
  45.   return (&(peerstats[src][dst]));
  46. }
  47. StaticPeerStatsDB::StaticPeerStatsDB()
  48.   : peerstats(0),
  49.     num_peers(0)
  50. {
  51.   bind("debug_", &debug_);
  52. }
  53. StaticPeerStatsDB::~StaticPeerStatsDB()
  54. {
  55.   deallocate();
  56. }
  57. void StaticPeerStatsDB::allocate()
  58. {
  59.   assert(num_peers>0);
  60.    try
  61.      {
  62.        peerstats = (PeerStats**) new PeerStats*[num_peers];
  63.        for (int i=0; i< num_peers; i++)
  64.  {
  65.    peerstats[i] = new PeerStats[num_peers];
  66.  }
  67.      }
  68.    catch(exception &e)
  69.      {
  70.        std::cerr << "StaticPeerStatsDB::allocate() exception caught" << std::endl;
  71.        abort();
  72.      }
  73.         
  74. }
  75. void StaticPeerStatsDB::deallocate()
  76. {
  77.     for (int i=0; i< num_peers; i++)
  78.       {
  79. delete[] peerstats[i];
  80. peerstats[i] = 0;
  81.       }
  82.     delete[] peerstats;
  83.     peerstats = 0;
  84.     
  85. }
  86. int StaticPeerStatsDB::command(int argc, const char*const* argv)
  87. {
  88.   Tcl& tcl = Tcl::instance();
  89.   if (debug_)
  90.     cerr << "StaticPeerStatsDB::command("" << argv[1] << "")" << endl;
  91.   
  92.   if (argc == 2) {
  93.     if(strcasecmp(argv[1], "dump") == 0) {
  94.       dump();
  95.       return (TCL_OK);
  96.     }      
  97.   }
  98.   if (argc == 3) {
  99.     if(strcasecmp(argv[1], "numpeers") == 0) {
  100.       deallocate();
  101.       num_peers = atoi(argv[2]);
  102.       allocate();
  103.       if (debug_) 
  104. cerr << "StaticPeerStatsDB::command   numpeers="
  105.      << num_peers << endl;
  106.       return (TCL_OK);
  107.     }      
  108.   }
  109.   return PeerStatsDB::command(argc,argv);
  110. }
  111. void  StaticPeerStatsDB::dump()
  112. {
  113.   char str[500];
  114.   
  115.   for (int src=0; src< num_peers; src++)
  116.     for (int dst=0; dst< num_peers; dst++)
  117.       {
  118. PeerStats* ps = getPeerStats(src,dst);
  119. assert(ps);
  120. //  assert(ps->macmib);
  121. //  ps->macmib->counters2string(str, 500);
  122. //  printf("%3d --> %3d %6.3f %6.3f %6.3f    %sn",
  123. //         src,
  124. //         dst,
  125. //         ps->getSnr(),
  126. //         ps->getSnir(),
  127. //         ps->getInterf(),        
  128. //         str);
  129. ps->peerstats2string(str, 500);
  130. printf("%3d <--> %3d   %sn",src, dst, str);
  131.       }
  132. }