incremental/afs_nightly.pl

   1 #!/afs/athena/contrib/perl/perl
   2
   3 require "/moira/bin/afs_utils.pl";
   4
   5 #
   6 # Nightly reaper - Recompute all usages/allocations.
   7 #
   8
   9 local ($key, @vos, %used,%alloc,%total, %a);
  10 local ($c,$as,$ap,$total,$used,$alloc);
  11
  12 if (open(TMP,"/afs/athena.mit.edu/service/afs_data")) {
  13     @new_data = <TMP>;
  14     close(TMP);
  15 }
  16
  17 chop(@new_data);
  18 for (@new_data) {
  19     $as = $ap = 0;
  20     if ($_ !~ /^\#/) {
  21         ($c,$as,$ap,$type) = split(/\s+/,$_);
  22         ($as) = gethostbyname($as);
  23         $c =~ tr/a-z/A-Z/;
  24         $as =~ tr/a-z/A-Z/;
  25         $ap =~ s:^([^/]):/vicep\1:;
  26     }
  27     next unless ($as && $ap);
  28
  29     &afs_lock;
  30     truncate(SRV, 0);
  31     for (@afs_data) {
  32         ($c2,$as2,$ap2) = split(/\s+/,$_);
  33         print SRV $_ unless ($c eq $c2 && $as eq $as2 && $ap eq $ap2);
  34     }
  35     &afs_unlock;
  36
  37     ($total, $used) = &afs_partinfo($as, $ap, $c);
  38     next if ($?);
  39     $alloc = 0;
  40
  41     open(VOS,"$vos listvol $as $ap -cell $c -long -noauth|");
  42     @vos = <VOS>;
  43     close(VOS);
  44     next if ($?);
  45
  46     while ($_ = shift(@vos)) {
  47         next unless /On-line/;
  48         local($vn,$id) = split(/\s+/, $_);
  49         shift(@vos);
  50         local($p,$p,$p) = split(/\s+/, shift(@vos));
  51         local($q,$q,$q) = split(/\s+/, shift(@vos));
  52         if ($id==$p || !$a{$p}) {
  53             $a{$p} = $q;
  54         }
  55     }
  56     for $p (keys %a) { $alloc += $a{$p}; delete $a{$p}; }
  57
  58     &afs_lock;
  59     seek(SRV, 0, 2);
  60     print SRV "$c $as $ap $type $total $used $alloc\n";
  61     &afs_unlock;
  62 }