projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
WIP AnyEvent version
[spider.git]
/
perl
/
cluster.pl
diff --git
a/perl/cluster.pl
b/perl/cluster.pl
index 2cf7173f9c5cea358c8267670f27d029c07f0cf4..a40a5aa5c51c274f2690984526a0de43fd5cecc8 100755
(executable)
--- a/
perl/cluster.pl
+++ b/
perl/cluster.pl
@@
-144,10
+144,9
@@
sub already_conn
{
my ($conn, $call, $mess) = @_;
{
my ($conn, $call, $mess) = @_;
- $conn->disable_read(1);
dbg("-> D $call $mess\n") if isdbg('chan');
dbg("-> D $call $mess\n") if isdbg('chan');
+ $conn->disable_read(1);
$conn->send_now("D$call|$mess");
$conn->send_now("D$call|$mess");
- sleep(2);
$conn->disconnect;
}
$conn->disconnect;
}
@@
-372,6
+371,8
@@
sub idle_loop
AGWMsg::process();
BPQMsg::process();
AGWMsg::process();
BPQMsg::process();
+ Timer::handler();
+
if (defined &Local::process) {
eval {
Local::process(); # do any localised processing
if (defined &Local::process) {
eval {
Local::process(); # do any localised processing
@@
-579,8
+580,7
@@
$script->run($main::me) if $script;
#open(DB::OUT, "|tee /tmp/aa");
#open(DB::OUT, "|tee /tmp/aa");
-my $idle_loop = AnyEvent->idle(cb => &idle_loop);
-
+my $per_sec = AnyEvent->timer(after => 0, interval => 0.010, cb => sub{idle_loop()});
# main loop
$decease->recv;
# main loop
$decease->recv;