projects
/
spider.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
11e5145
)
switch off monitoring on finish
author
minima
<minima>
Tue, 27 Mar 2001 23:43:04 +0000
(23:43 +0000)
committer
minima
<minima>
Tue, 27 Mar 2001 23:43:04 +0000
(23:43 +0000)
perl/AGWMsg.pm
patch
|
blob
|
history
diff --git
a/perl/AGWMsg.pm
b/perl/AGWMsg.pm
index 26939af9140e9d9784b48684f0aba209ddc67e9c..8aa47dbfe1671f791a0d93deb041cfd09462f87d 100644
(file)
--- a/
perl/AGWMsg.pm
+++ b/
perl/AGWMsg.pm
@@
-45,7
+45,7
@@
sub init
finish();
dbg('err', "AGW initialising and connecting to $addr/$port ...");
finish();
dbg('err', "AGW initialising and connecting to $addr/$port ...");
- $sock = IO::Socket::INET->new(PeerAddr => $addr, PeerPort => $port, Proto=>'tcp');
+ $sock = IO::Socket::INET->new(PeerAddr => $addr, PeerPort => $port, Proto=>'tcp'
, Timeout => 30
);
unless ($sock) {
dbg('err', "Cannot connect to AGW Engine at $addr/$port $!");
return;
unless ($sock) {
dbg('err', "Cannot connect to AGW Engine at $addr/$port $!");
return;
@@
-63,6
+63,7
@@
sub init
# R frame for the release number
# G frame to ask for ports
# X frame to say who we are
# R frame for the release number
# G frame to ask for ports
# X frame to say who we are
+ # optional m frame to enable monitoring
_sendf('R');
_sendf('G');
_sendf('X', $main::mycall);
_sendf('R');
_sendf('G');
_sendf('X', $main::mycall);
@@
-80,6
+81,7
@@
sub finish
$_->disconnect;
}
# say we are going
$_->disconnect;
}
# say we are going
+ _sendf('m') if $monitor;
_sendf('x', $main::mycall);
Msg->sleep(2);
Msg::set_event_handler($sock, read=>undef, write=>undef, error=>undef);
_sendf('x', $main::mycall);
Msg->sleep(2);
Msg::set_event_handler($sock, read=>undef, write=>undef, error=>undef);