hamradio/spider
1
0
Fork 0
mirror of git://scm.dxcluster.org/scm/spider synced 2024-09-21 07:47:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

allow for errors on accept

Browse Source
This commit is contained in:
minima 2001-03-30 11:15:20 +00:00
parent 33f5a4eea5
commit b7e47e7229
2 changed files with 29 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Changes
View File

@ -1,3 +1,5 @@
30Mar01=======================================================================
1. fix errors on accept in EXtMsg
29Mar01=======================================================================
1. add better tracking of AGW circuits (possibly)
2. add set and unset/agwmonitor (ing) [for all the notice it seems to take]

49
perl/ExtMsg.pm
View File

@ -122,29 +122,34 @@ sub to_connected
sub new_client {
my $server_conn = shift;
my $sock = $server_conn->{sock}->accept();
my $conn = $server_conn->new($server_conn->{rproc});
$conn->{sock} = $sock;
my ($rproc, $eproc) = &{$server_conn->{rproc}} ($conn, $conn->{peerhost} = $sock->peerhost(), $conn->{peerport} = $sock->peerport());
if ($eproc) {
$conn->{eproc} = $eproc;
Msg::set_event_handler ($sock, "error" => $eproc);
if ($sock) {
my $conn = $server_conn->new($server_conn->{rproc});
$conn->{sock} = $sock;
my ($rproc, $eproc) = &{$server_conn->{rproc}} ($conn, $conn->{peerhost} = $sock->peerhost(), $conn->{peerport} = $sock->peerport());
if ($eproc) {
$conn->{eproc} = $eproc;
Msg::set_event_handler ($sock, "error" => $eproc);
}
if ($rproc) {
$conn->{rproc} = $rproc;
my $callback = sub {$conn->_rcv};
Msg::set_event_handler ($sock, "read" => $callback);
# send login prompt
$conn->{state} = 'WL';
# $conn->send_raw("\xff\xfe\x01\xff\xfc\x01\ff\fd\x22");
# $conn->send_raw("\xff\xfa\x22\x01\x01\xff\xf0");
# $conn->send_raw("\xFF\xFC\x01");
$conn->_send_file("$main::data/issue");
$conn->send_raw("login: ");
$conn->_dotimeout(60);
} else {
&{$conn->{eproc}}() if $conn->{eproc};
$conn->disconnect();
}
} else {
dbg('err', "ExtMsg: error on accept ($!)");
}
if ($rproc) {
$conn->{rproc} = $rproc;
my $callback = sub {$conn->_rcv};
Msg::set_event_handler ($sock, "read" => $callback);
# send login prompt
$conn->{state} = 'WL';
# $conn->send_raw("\xff\xfe\x01\xff\xfc\x01\ff\fd\x22");
# $conn->send_raw("\xff\xfa\x22\x01\x01\xff\xf0");
# $conn->send_raw("\xFF\xFC\x01");
$conn->_send_file("$main::data/issue");
$conn->send_raw("login: ");
$conn->_dotimeout(60);
} else {
$conn->disconnect();
}
}
sub start_connect