]> dxcluster.net Git - spider.git/commitdiff
added logging
authordjk <djk>
Fri, 13 Nov 1998 18:35:47 +0000 (18:35 +0000)
committerdjk <djk>
Fri, 13 Nov 1998 18:35:47 +0000 (18:35 +0000)
made the Spots as near the same as possible to ak1a

perl/DXCommandmode.pm
perl/DXLog.pm
perl/DXMsg.pm
perl/DXProt.pm
perl/Julian.pm
perl/Spot.pm
perl/client.pl
perl/cluster.pl

index 522200da3b8249cb74f3bc492a92fa1862d17331..aa4cb1a37a4fb287f9245612ec0b9d88e1c8c346 100644 (file)
@@ -17,6 +17,7 @@ use DXUser;
 use DXVars;
 use DXDebug;
 use DXM;
+use DXLog;
 use CmdAlias;
 use FileHandle;
 use Carp;
@@ -74,6 +75,7 @@ sub start
   my $nchan = DXChannel->get($main::mycall);
   my @pc16 = DXProt::pc16($nchan, $cuser);
   DXProt::broadcast_ak1a(@pc16);
+  Log('DXCommand', "$call connected");
 }
 
 #
@@ -192,7 +194,8 @@ sub finish
   my $nchan = DXChannel->get($main::mycall);
   my $pc17 = $nchan->pc17($self);
   DXProt::broadcast_ak1a($pc17);
-  
+
+  Log('DXCommand', "$call disconnected");
   $ref->del() if $ref;
 }
 
index 5b5914b4e6b2472d5130d44b39c580bc67ff938e..e4f228035194c42dea45ab9b9129c5e5f7666e6c 100644 (file)
@@ -72,7 +72,8 @@ sub open
                delete $self->{mode};
        }
        
-       $self->{fn} = sprintf "$self->{prefix}/$year/%03d", $thing;
+       $self->{fn} = sprintf "$self->{prefix}/$year/%02d", $thing if $self->{sort} eq 'm';
+       $self->{fn} = sprintf "$self->{prefix}/$year/%03d", $thing if $self->{sort} eq 'd';
        $self->{fn} .= ".$self->{suffix}" if $self->{suffix};
        
        $mode = 'r' if !$mode;
@@ -144,7 +145,8 @@ sub write
 sub writenow
 {
        my ($self, $line) = @_;
-       my @date = $self->unixtoj(time);
+       my $t = time;
+       my @date = $self->unixtoj($t);
        return $self->write(@date, $line);
 }
 
@@ -171,7 +173,8 @@ sub close
 # The user is responsible for making sense of this!
 sub Log
 {
-       $log->writeunix($main::systime, join('^', $main::systime, @_) );
+       my $t = time;
+       $log->writeunix($t, join('^', $t, @_) );
 }
 
 sub DESTROY                                            # catch undefs and do what is required further do the tree
index 9316c374444ca0eff24087994b181f17c1fb7978..6a6f104aa346073dc0a6eb5e979b7beee023ed72 100644 (file)
@@ -19,6 +19,7 @@ use DXCluster;
 use DXProtVars;
 use DXProtout;
 use DXDebug;
+use DXLog;
 use FileHandle;
 use Carp;
 
@@ -268,6 +269,7 @@ sub store
          }
          $fh->close;
          dbg('msg', "file $ref->{to} stored\n");
+         Log('msg', "file $ref->{to} from $ref->{from} stored" );
     } else {
       confess "can't open file $ref->{to} $!";  
     }
@@ -294,6 +296,7 @@ sub store
          }
          $fh->close;
          dbg('msg', "msg $ref->{msgno} stored\n");
+         Log('msg', "msg $ref->{msgno} from $ref->{from} to $ref->{to} stored" );
     } else {
       confess "can't open msg file $fn $!";  
     }
index 8985e8ab4a640a6f8409d213e4cef974a03d5999..ab9e0e33fd0af91dbf9b83e8b45d53672d212cac 100644 (file)
@@ -18,6 +18,7 @@ use DXM;
 use DXCluster;
 use DXProtVars;
 use DXCommandmode;
+use DXLog;
 use Spot;
 use DXProtout;
 use Carp;
@@ -68,6 +69,7 @@ sub start
   $self->send(pc18());
   $self->state('init');
   $self->pc50_t(time);
+  Log('DXProt', "$call connected");
 }
 
 #
@@ -427,6 +429,7 @@ sub finish
 
   # now broadcast to all other ak1a nodes that I have gone
   broadcast_ak1a(pc21($self->call, 'Gone.'), $self);
+  Log('DXProt', $self->call . " Disconnected");
   $ref->del() if $ref;
 }
 
index 5616542b3667dd859e25827dd61d13e693305033..c770e4a964731410c1559eff9fb0b8eb572b102f 100644 (file)
@@ -19,13 +19,13 @@ my @days = (31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31);
 # take a unix date and transform it into a julian day (ie (1998, 13) = 13th day of 1998)
 sub unixtoj
 {
-  my $t = shift;
-  my ($year, $day) = (gmtime($t))[5,7];
-  
-  if ($year < 100) {
-    $year += ($year < 50) ? 2000 : 1900;
-  }
-  return ($year, $day+1);
+       my $t = shift;
+       my ($year, $day) = (gmtime($t))[5,7];
+       
+       if ($year < 100) {
+               $year += ($year < 50) ? 2000 : 1900;
+       }
+       return ($year, $day+1);
 }
 
 # take a unix and return a julian month from it
@@ -33,71 +33,74 @@ sub unixtojm
 {
        my $t = shift;
        my ($mon, $year) = (gmtime($t))[4..5];
-       return ($year, $mon);
+       if ($year < 100) {
+               $year += ($year < 50) ? 2000 : 1900;
+       }
+       return ($year, $mon + 1);
 }
 
 # take a julian date and subtract a number of days from it, returning the julian date
 sub sub
 {
-  my ($year, $day, $amount) = @_;
-  my $diny = isleap($year) ? 366 : 365;
-  $day -= $amount;
-  while ($day <= 0) {
-    $day += $diny;
-       $year -= 1;
-       $diny = isleap($year) ? 366 : 365;
-  }
-  return ($year, $day);
+       my ($year, $day, $amount) = @_;
+       my $diny = isleap($year) ? 366 : 365;
+       $day -= $amount;
+       while ($day <= 0) {
+               $day += $diny;
+               $year -= 1;
+               $diny = isleap($year) ? 366 : 365;
+       }
+       return ($year, $day);
 }
 
 sub add
 {
-  my ($year, $day, $amount) = @_;
-  my $diny = isleap($year) ? 366 : 365;
-  $day += $amount;
-  while ($day > $diny) {
-    $day -= $diny;
-       $year += 1;
-       $diny = isleap($year) ? 366 : 365;
-  }
-  return ($year, $day);
+       my ($year, $day, $amount) = @_;
+       my $diny = isleap($year) ? 366 : 365;
+       $day += $amount;
+       while ($day > $diny) {
+               $day -= $diny;
+               $year += 1;
+               $diny = isleap($year) ? 366 : 365;
+       }
+       return ($year, $day);
 } 
 
 # take a julian month and subtract a number of months from it, returning the julian month
 sub subm
 {
-  my ($year, $mon, $amount) = @_;
-  $mon -= $amount;
-  while ($mon <= 0) {
-    $mon += 12;
-       $year -= 1;
-  }
-  return ($year, $mon);
+       my ($year, $mon, $amount) = @_;
+       $mon -= $amount;
+       while ($mon <= 0) {
+               $mon += 12;
+               $year -= 1;
+       }
+       return ($year, $mon);
 }
 
 sub addm
 {
-  my ($year, $mon, $amount) = @_;
-  $mon += $amount;
-  while ($mon > 12) {
-    $mon -= 12;
-       $year += 1;
-  }
-  return ($year, $mon);
+       my ($year, $mon, $amount) = @_;
+       $mon += $amount;
+       while ($mon > 12) {
+               $mon -= 12;
+               $year += 1;
+       }
+       return ($year, $mon);
 } 
 
 sub cmp
 {
-  my ($y1, $d1, $y2, $d2) = @_;
-  return $d1 - $d2 if ($y1 == $y2);
-  return $y1 - $y2;
+       my ($y1, $d1, $y2, $d2) = @_;
+       return $d1 - $d2 if ($y1 == $y2);
+       return $y1 - $y2;
 }
 
 # is it a leap year?
 sub isleap
 {
-  my $year = shift;
-  return ($year % 4 == 0 && ($year % 100 != 0 || $year % 400 == 0)) ? 1 : 0; 
+       my $year = shift;
+       return ($year % 4 == 0 && ($year % 100 != 0 || $year % 400 == 0)) ? 1 : 0; 
 }
 
 
index dca646884b730b499e07d357efb5096df568c894..e53880e1d48f6db0070a35d7482b03821809ff24 100644 (file)
@@ -162,7 +162,7 @@ sub formatb
 {
   my @dx = @_;
   my $t = ztime($dx[2]);
-  return sprintf "DX de %-7.7s: %13.1f %-12.12s %-30s<%s>", $dx[4], $dx[0], $dx[1], $dx[3], $t ;
+  return sprintf "DX de %-7.7s%11.1f  %-12.12s %-30s %s", "$dx[4]:", $dx[0], $dx[1], $dx[3], $t ;
 }
 
 # format a spot for user output in list mode
@@ -171,7 +171,7 @@ sub formatl
   my @dx = @_;
   my $t = ztime($dx[2]);
   my $d = cldate($dx[2]);
-  return sprintf "%9.1f %-12s %s %s %-30s<%s>", $dx[0], $dx[1], $d, $t, $dx[3], $dx[4] ;
-}
+  return sprintf "%8.1f  %-11s %s %s  %-28.28s%7s>", $dx[0], $dx[1], $d, $t, $dx[3], "<$dx[4]" ;
+} 
 
 1;
index b8129cbb384cd0d7c8d8ea7872460586b9e3f627..cff140b2eb41dba45ee142f7f08891f3066f2e44 100755 (executable)
@@ -102,7 +102,7 @@ sub rec_socket
           my $snl = $mynl;
           my $newsavenl = "";
           $snl = "" if $mode == 0;
-          if ($mode && $line =~ />$/) {
+          if ($mode == 2 && $line =~ />$/) {
             $newsavenl = $snl;
                 $snl = ' ';
           }
index 4c65e86858acb7c7711152562579c06d0384276f..848131f70ba8d28906a98f43d685391a03cc893c 100755 (executable)
@@ -47,7 +47,7 @@ package main;
 
 @inqueue = ();                                 # the main input queue, an array of hashes
 $systime = 0;                                  # the time now (in seconds)
-$version = 1.3;                                        # the version no of the software
+$version = 1.4;                                        # the version no of the software
 
 # handle disconnections
 sub disconnect
@@ -129,6 +129,7 @@ sub cease
        foreach $dxchan (DXChannel->get_all()) {
                disconnect($dxchan);
        }
+       Log('cluster', "DXSpider V$version stopped");
        exit(0);
 }
 
@@ -176,6 +177,8 @@ foreach (@debug) {
 }
 STDOUT->autoflush(1);
 
+Log('cluster', "DXSpider V$version started");
+
 # banner
 print "DXSpider DX Cluster Version $version\nCopyright (c) 1998 Dirk Koopman G1TLH\n";