From: minima Date: Fri, 30 Mar 2001 16:45:27 +0000 (+0000) Subject: added rinit command X-Git-Tag: R_1_47~71 X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=commitdiff_plain;h=95345d68a5a8ac618021c0786c7234258b903f6e;p=spider.git added rinit command made MSWindows blocking again moved sendfile AFTER the login to the channel added generic $main::is_win flag --- diff --git a/Changes b/Changes index 166b28ea..4e511510 100644 --- a/Changes +++ b/Changes @@ -1,6 +1,8 @@ 30Mar01======================================================================= 1. fix errors on accept in ExtMsg and in Msg 2. fix the non-blocking problems of connects (and other things in general). +non-blocking only works for unix implementations at the moment. +3. add rinit command (sends a PC20) 29Mar01======================================================================= 1. add better tracking of AGW circuits (possibly) 2. add set and unset/agwmonitor (ing) [for all the notice it seems to take] diff --git a/cmd/init.pl b/cmd/init.pl index fd3c045b..b88ed013 100644 --- a/cmd/init.pl +++ b/cmd/init.pl @@ -1,5 +1,5 @@ # -# reinit a cluster connection +# init a cluster connection # # Copyright (c) 1999 Dirk Koopman G1TLH # @@ -27,7 +27,7 @@ foreach $call (@calls) { DXProt::broadcast_ak1a(DXProt::pc21($node->call, 'Gone, re-init') , $dxchan) unless $dxchan->{isolate}; $node->del(); } - $dxchan->send(DXProt::pc38()); +# $dxchan->send(DXProt::pc38()); $dxchan->send(DXProt::pc18()); $dxchan->state('init'); push @out, $self->msg('init1', $call); diff --git a/cmd/rinit.pl b/cmd/rinit.pl new file mode 100644 index 00000000..93748ca1 --- /dev/null +++ b/cmd/rinit.pl @@ -0,0 +1,41 @@ +# +# reverse init a cluster connection +# +# Copyright (c) 1999 Dirk Koopman G1TLH +# +# $Id$ +# +my ($self, $line) = @_; +my @calls = split /\s+/, $line; +my $call; +my @out; + +return (1, $self->msg('e5')) if $self->priv < 5; + +foreach $call (@calls) { + $call = uc $call; + next if $call eq $main::mycall; + my $dxchan = DXChannel->get($call); + if ($dxchan) { + if ($dxchan->is_node) { + + # first clear out any nodes on this dxchannel + my @gonenodes = grep { $_->dxchan == $dxchan } DXNode::get_all(); + foreach my $node (@gonenodes) { + next if $node->dxchan == $DXProt::me; + next unless $node->dxchan == $dxchan; + DXProt::broadcast_ak1a(DXProt::pc21($node->call, 'Gone, re-init') , $dxchan) unless $dxchan->{isolate}; + $node->del(); + } +# $dxchan->send(DXProt::pc38()); + $dxchan->send(DXProt::pc20()); + $dxchan->state('init'); + push @out, $self->msg('init1', $call); + } + } else { + push @out, $self->msg('e10', $call); + } +} + +return (1, @out); + diff --git a/perl/DXCron.pm b/perl/DXCron.pm index 1c698f75..42dbe2a5 100644 --- a/perl/DXCron.pm +++ b/perl/DXCron.pm @@ -252,7 +252,7 @@ sub spawn for (@main::listeners) { $_->close_server; } - unless ($^O =~ /^MS/) { + unless ($main::is_win) { $SIG{HUP} = 'IGNORE'; $SIG{CHLD} = $SIG{TERM} = $SIG{INT} = $SIG{__WARN__} = 'DEFAULT'; alarm(0); diff --git a/perl/ExtMsg.pm b/perl/ExtMsg.pm index ae6c8a4c..d8e660b8 100644 --- a/perl/ExtMsg.pm +++ b/perl/ExtMsg.pm @@ -115,9 +115,8 @@ sub to_connected delete $conn->{cmd}; $conn->{timeout}->del if $conn->{timeout}; delete $conn->{timeout}; - $conn->_send_file("$main::data/connected"); - Msg->sleep(1); &{$conn->{rproc}}($conn, "$dir$call|$sort"); + $conn->_send_file("$main::data/connected"); } sub new_client { @@ -253,7 +252,7 @@ sub _doconnect *STDOUT = IO::File->new_from_fd($b, 'w') or die; *STDERR = IO::File->new_from_fd($b, 'w') or die; close $a; - unless ($^O =~ /^MS/) { + unless ($main::is_win) { # $SIG{HUP} = 'IGNORE'; $SIG{HUP} = $SIG{CHLD} = $SIG{TERM} = $SIG{INT} = 'DEFAULT'; alarm(0); @@ -364,6 +363,7 @@ sub _send_file if ($f) { while (<$f>) { chomp; + dbg('connll', $_); $conn->send_raw($_ . $conn->{lineend}); } $f->close; diff --git a/perl/Msg.pm b/perl/Msg.pm index aa5edc48..3b9dbd36 100644 --- a/perl/Msg.pm +++ b/perl/Msg.pm @@ -32,8 +32,9 @@ BEGIN { eval { require POSIX; POSIX->import(qw(O_NONBLOCK F_SETFL F_GETFL)) }; - if ($@) { + if ($@ || $main::is_win) { print STDERR "POSIX Blocking *** NOT *** supported $@\n"; + $blocking_supported = 0; } else { $blocking_supported = 1; print STDERR "POSIX Blocking enabled\n"; @@ -195,7 +196,7 @@ sub disconnect { $call ||= 'unallocated'; dbg('connll', "Connection $call disconnected"); - unless ($^O =~ /^MS/i) { + unless ($main::is_win) { kill 'TERM', $conn->{pid} if exists $conn->{pid}; } diff --git a/perl/cluster.pl b/perl/cluster.pl index 4816916c..291a751d 100755 --- a/perl/cluster.pl +++ b/perl/cluster.pl @@ -79,7 +79,7 @@ package main; use strict; use vars qw(@inqueue $systime $version $starttime $lockfn @outstanding_connects $zombies $root @listeners $lang $myalias @debug $userfn $clusteraddr - $clusterport $mycall $decease $build + $clusterport $mycall $decease $build $is_win ); @inqueue = (); # the main input queue, an array of hashes @@ -89,6 +89,8 @@ $starttime = 0; # the starting time of the cluster $lockfn = "cluster.lock"; # lock file name #@outstanding_connects = (); # list of outstanding connects @listeners = (); # list of listeners +$is_win = $^O =~ /^MS/ || $^O =~ /^OS-2/; # is it Windows? + # send a message to call on conn and disconnect @@ -374,7 +376,7 @@ AGWMsg::init(\&new_channel); dbg('err', "load badwords: " . (BadWords::load or "Ok")); # prime some signals -unless ($^O =~ /^MS/) { +unless ($is_win) { unless ($DB::VERSION) { $SIG{INT} = \&cease; $SIG{TERM} = \&cease;