Open Mash Cross Reference
mash/tcl/degas/degasmonitor/aglp-monitor.tcl

   import AnnounceListenManager
   Class AGLPMonitor -superclass AnnounceListenManager
   
   AGLPMonitor instproc init { group } {
           $self instvar log_ total_ prev_total_ total_rate_ count_ first_ 
           $self next $group 4096
   
           set log_ [open "aglp-monitor.log" w]
           set total_ 0
          set prev_total_ 0
          set total_rate_ 0
          set count_ 0
          set first_ 0
  
          $self log
  }
  
  AGLPMonitor instproc recv_announcement { addr post msg length } {
          $self instvar total_ prev_total_ first_
          puts "$addr:$msg"
  
          global bps
          set prev_total_ $total_
          incr total_ $length
          set bps $total_
  
  #   Stop collecting after 5 minutes
          if {$first_ == 0} {
  
                  global bps
                  rate_variable bps 0.1
                  set bps 0
  
                  after [expr 10*60*1000] exit
  
                  set first_ 1
          }
  }
  
  AGLPMonitor instproc log { } {
          global bps
          $self instvar log_ total_ prev_total_ total_rate_ count_ first_
  
          after 5000 "$self log"
  
          if {$first_ == 0} {
                  return
          }
  
          incr count_
          set total_rate_ [expr $total_rate_ + $bps]
  
  
          if {$prev_total_ != $total_} {
                  puts $log_ "[expr [clock seconds] - 978535100] $bps $total_ [expr $total_rate_/$count_]"
                  flush $log_
          }
  }