From 01f2793abb2aa2bef7762183a33f5e867ab703ee Mon Sep 17 00:00:00 2001
From: minima <minima>
Date: Wed, 28 Mar 2001 15:36:44 +0000
Subject: [PATCH] will it answer?

---
 perl/AGWMsg.pm  | 57 ++++++++++++++++++++++++++++++++++++++-----------
 perl/ExtMsg.pm  |  4 ++++
 perl/cluster.pl |  3 ++-
 3 files changed, 51 insertions(+), 13 deletions(-)

diff --git a/perl/AGWMsg.pm b/perl/AGWMsg.pm
index 8aa47dbf..23f2e1dd 100644
--- a/perl/AGWMsg.pm
+++ b/perl/AGWMsg.pm
@@ -29,7 +29,7 @@ use Msg;
 use AGWConnect;
 use DXDebug;
 
-use vars qw(@ISA $sock @outqueue $send_offset $inmsg $rproc);
+use vars qw(@ISA $sock @outqueue $send_offset $inmsg $rproc $noports $lasttime);
 
 @ISA = qw(Msg ExtMsg);
 $sock = undef;
@@ -37,6 +37,8 @@ $sock = undef;
 $send_offset = 0;
 $inmsg = '';
 $rproc = undef;
+$noports = 0;
+$lasttime = time;
 
 sub init
 {
@@ -67,9 +69,7 @@ sub init
 	_sendf('R');
 	_sendf('G');
 	_sendf('X', $main::mycall);
-	if ($monitor) {
-		_sendf('m')
-	}
+	_sendf('m') if $monitor;
 }
 
 sub finish
@@ -227,7 +227,7 @@ sub _decode
 
 	$data = '' unless defined $data;
 	if ($sort eq 'D') {
-		$data =~ s/\cR//g;
+		$data =~ s/[\cR\x00]//g;
 		dbg('agw', "AGW Data In port: $port pid: $pid '$from'->'$to' length: $len \"$data\"");
 		my $conn = Msg->conns($from eq $main::mycall ? $to : $from);
 		if ($conn) {
@@ -267,10 +267,12 @@ sub _decode
 			$conn->{agwpid} = $pid;
 			$conn->{agwport} = $port;
 			$conn->{lineend} = "\cR";
+			$conn->{incoming} = 1;
+			$conn->{agwcall} = $call;
 			$conn->to_connected($call, 'A', $conn->{csort} = 'ax25');
 		}
 	} elsif ($sort eq 'd') {
-		dbg('agw', "AGW '$from'->'$to' Disconnected");
+		dbg('agw', "AGW '$from'->'$to' port: $port Disconnected");
 		my $conn = Msg->conns($from eq $main::mycall ? $to : $from);
 		$conn->in_disconnect if $conn;
 	} elsif ($sort eq 'y') {
@@ -293,29 +295,47 @@ sub _decode
 		dbg('agw', "AGW Version $major.$minor");
 	} elsif ($sort eq 'G') {
 		my @ports = split /;/, $data;
-		dbg('agw', "AGW $ports[0] Ports available");
-		my $n = shift @ports;
-		pop @ports while @ports > $n;
+	    $noports = shift @ports || '0';
+		dbg('agw', "AGW $noports Ports available");
+		pop @ports while @ports > $noports;
 		for (@ports) {
 			next unless $_;
 			dbg('agw', "AGW Port: $_");
 		}
+		for (my $i = 0; $i < $noports; $i++) {
+			_sendf('y', undef, undef, $i );
+		}
 	} else {
 		dbg('agw', "AGW decode $sort port: $port pid: $pid '$from'->'$to' length: $len \"$data\"");
 	}
 }
 
+sub connect
+{
+	my ($conn, $line) = @_;
+
+	my ($port, $call) = split /\s+/, $line;
+	$conn->{agwpid} = ord "\xF0";
+	$conn->{agwport} = $port - 1;
+	$conn->{lineend} = "\cR";
+	$conn->{incoming} = 0;
+	$conn->{csort} = 'ax25';
+	$conn->{agwcall} = uc $call;
+	
+	_sendf('C', $main::mycall, $conn->{agwcall}, $conn->{agwport}, $conn->{agwpid});
+}
+
 sub in_disconnect
 {
 	my $conn = shift;
-	$conn->SUPER->disconnect;
+	$conn->SUPER::disconnect;
 }
 
 sub disconnect
 {
 	my $conn = shift;
-	_sendf('d', $main::mycall, $conn->{call}, $conn->{agwport});
-	$conn->SUPER->disconnect;
+	_sendf('d', $main::mycall, $conn->{agwcall}, $conn->{agwport}, $conn->{agwpid});
+	$conn->SUPER::disconnect;
 }
 
 sub enqueue
@@ -323,8 +343,21 @@ sub enqueue
 	my ($conn, $msg) = @_;
 	if ($msg =~ /^[D]/) {
 		$msg =~ s/^[-\w]+\|//;
+		_sendf('Y', $main::mycall, $conn->{call}, $conn->{agwport}, $conn->{agwpid});
 		_sendf('D', $main::mycall, $conn->{call}, $conn->{agwport}, $conn->{agwpid}, $msg . $conn->{lineend});
 	}
 }
+
+sub process
+{
+	return unless $sock;
+	if ($main::systime - $lasttime >= 60) {
+		for (my $i = 0; $i < $noports; $i++) {
+			_sendf('y', undef, undef, $i );
+#			_sendf('H', undef, undef, $i );
+		}
+		$lasttime = $main::systime;
+	}
+}
 1;
 
diff --git a/perl/ExtMsg.pm b/perl/ExtMsg.pm
index 838c74e1..de0c0bca 100644
--- a/perl/ExtMsg.pm
+++ b/perl/ExtMsg.pm
@@ -211,6 +211,10 @@ sub _doconnect
 		} else {
 			dbg('connect', "***Connect Failed to $host $port $!");
 		}
+	} elsif ($sort eq 'agw') {
+		# turn it into an AGW object
+		bless $conn, 'AGWMsg';
+		$r = $conn->connect($line);
 	} elsif ($sort eq 'ax25' || $sort eq 'prog') {
 		local $^F = 10000;		# make sure it ain't closed on exec
 		my ($a, $b) = IO::Socket->socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC);
diff --git a/perl/cluster.pl b/perl/cluster.pl
index b4cfc482..4816916c 100755
--- a/perl/cluster.pl
+++ b/perl/cluster.pl
@@ -467,7 +467,8 @@ for (;;) {
 		DXDb::process();
 		DXUser::process();
 		DXDupe::process();
-		
+		AGWMsg::process();
+				
 		eval { 
 			Local::process();       # do any localised processing
 		};
-- 
2.43.0