X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXDb.pm;h=2122234bf8fe9d8c8a6025d73707a3e49d698ab9;hb=5a06cd7853e8bff86a0f17854c0791bb3f85c395;hp=9251bdfdaa8ed084567b54522caba2b35dedba65;hpb=d53c6bd649c5e36ca2b7a780ebbce657f90667fd;p=spider.git

diff --git a/perl/DXDb.pm b/perl/DXDb.pm
index 9251bdfd..2122234b 100644
--- a/perl/DXDb.pm
+++ b/perl/DXDb.pm
@@ -240,67 +240,58 @@ sub normal
 #
 sub process
 {
-	my ($dxchan, $line) = @_;
-
-	# this is periodic processing
-	if (!$dxchan || !$line) {
-		if ($main::systime - $lastprocesstime >= 60) {
-			if (%avail) {
-				for (values %avail) {
-					if ($main::systime - $_->{accesst} > $opentime) {
-						$_->close;
-					}
+	if ($main::systime - $lastprocesstime >= 60) {
+		if (%avail) {
+			for (values %avail) {
+				if ($main::systime - $_->{accesst} > $opentime) {
+					$_->close;
 				}
 			}
-			$lastprocesstime = $main::systime;
 		}
-		return;
+		$lastprocesstime = $main::systime;
 	}
+}
 
-	my @f = split /\^/, $line;
-	my ($pcno) = $f[0] =~ /^PC(\d\d)/; # just get the number
+sub handle_37
+{		
 
-	# route out ones that are not for us
-	if ($f[1] eq $main::mycall) {
-		;
-	} else {
-		$dxchan->route($f[1], $line);
-		return;
-	}
+}
 
- SWITCH: {
-		if ($pcno == 37) {		# probably obsolete
-			last SWITCH;
-		}
+sub handle_44
+{	
+	my $self = shift;
 
-		if ($pcno == 44) {		# incoming DB Request
-			my @in = DXCommandmode::run_cmd($dxchan, "dbshow $f[4] $f[5]");
-			sendremote($dxchan, $f[2], $f[3], @in);
-			last SWITCH;
-		}
+	# incoming DB Request
+	my @in = DXCommandmode::run_cmd($self, "dbshow $_[4] $_[5]");
+	sendremote($self, $_[2], $_[3], @in);
+}
 
-		if ($pcno == 45) {		# incoming DB Information
-			my $n = getstream($f[3]);
-			if ($n) {
-				my $mchan = DXChannel->get($n->{call});
-				$mchan->send($f[2] . ":$f[4]") if $mchan;
-			}
-			last SWITCH;
-		}
+sub handle_45
+{		
+	my $self = shift;
 
-		if ($pcno == 46) {		# incoming DB Complete
-			delstream($f[3]);
-			last SWITCH;
-		}
+	# incoming DB Information
+	my $n = getstream($_[3]);
+	if ($n) {
+		my $mchan = DXChannel->get($n->{call});
+		$mchan->send($_[2] . ":$_[4]") if $mchan;
+	}
+}
 
-		if ($pcno == 47) {		# incoming DB Update request
-			last SWITCH;
-		}
+sub handle_46
+{		
+	my $self = shift;
 
-		if ($pcno == 48) {		# incoming DB Update request 
-			last SWITCH;
-		}
-	}	
+	# incoming DB Complete
+	delstream($_[3]);
+}
+
+sub handle_47
+{
+}
+
+sub handle_48
+{
 }
 
 # send back a trache of data to the remote