X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;ds=sidebyside;f=perl%2FDXChannel.pm;h=8384567003685d54e1a5dfe155095e2a91e573db;hb=ec1b2a19fcc6539f071a766671b5fa5be8694362;hp=584a541c1244e44a8b3f1ae90e22b09a8b72e793;hpb=a22dbff21bb1ccb696276c23566ba830421fd3a0;p=spider.git

diff --git a/perl/DXChannel.pm b/perl/DXChannel.pm
index 584a541c..83845670 100644
--- a/perl/DXChannel.pm
+++ b/perl/DXChannel.pm
@@ -125,6 +125,7 @@ $count = 0;
 		  inqueue => '9,Input Queue,parray',
 		  next_pc92_update => '9,Next PC92 Update,atime',
 		  next_pc92_keepalive => '9,Next PC92 KeepAlive,atime',
+		  anyevents => '9,outstanding AnyEvent handles,parray',
 		 );
 
 $maxerrors = 20;				# the maximum number of concurrent errors allowed before disconnection
@@ -179,6 +180,7 @@ sub alloc
 		$self->{cq} = $dxcc[1]->cq;						
 	}
 	$self->{inqueue} = [];
+	$self->{anyevents} = [];
 
 	$count++;
 	dbg("DXChannel $self->{call} created ($count)") if isdbg('chan');
@@ -704,18 +706,16 @@ sub broadcast_list
 
 sub process
 {
-	foreach my $dxchan (get_all()) {
-
+	foreach my $dxchan (values %channels) {
+		
+		next if $dxchan->{disconnecting};
+		
 		while (my $data = shift @{$dxchan->{inqueue}}) {
 			my ($sort, $call, $line) = $dxchan->decode_input($data);
 			next unless defined $sort;
 
 			# do the really sexy console interface bit! (Who is going to do the TK interface then?)
 			dbg("<- $sort $call $line") if $sort ne 'D' && isdbg('chan');
-			if ($dxchan->{disconnecting}) {
-				dbg('In disconnection, ignored');
-				next;
-			}
 
 			# handle A records
 			my $user = $dxchan->user;
@@ -752,6 +752,25 @@ sub handle_xml
 	return $r;
 }
 
+sub anyevent_add
+{
+	my $self = shift;
+	my $handle = shift;
+	my $sort = shift || "unknown";
+
+	push @{$self->{anyevents}}, $handle;
+	dbg("anyevent: add $sort handle making " . scalar @{$self->{anyevents}} . " handles in use") if isdbg('anyevent');
+}
+
+sub anyevent_del
+{
+	my $self = shift;
+	my $handle = shift;
+	my $sort = shift || "unknown";
+	$self->{anyevents} = [ grep {$_ != $handle} @{$self->{anyevents}} ];
+	dbg("anyevent: delete $sort handle making " . scalar @{$self->{anyevents}} . " handles in use") if isdbg('anyevent');
+}
+
 #no strict;
 sub AUTOLOAD
 {