projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
add connect time/uptime for links cmd
[spider.git]
/
perl
/
DXProt.pm
diff --git
a/perl/DXProt.pm
b/perl/DXProt.pm
index dc5dc0b99e5bc08198e96831a7853db07dea0807..5afb6716fcc8846aa825163964cd3ddb39f7d607 100644
(file)
--- a/
perl/DXProt.pm
+++ b/
perl/DXProt.pm
@@
-36,6
+36,7
@@
use DXProtHandle;
use Time::HiRes qw(gettimeofday tv_interval);
use Mojo::IOLoop::Subprocess;
use Time::HiRes qw(gettimeofday tv_interval);
use Mojo::IOLoop::Subprocess;
+use DXSubprocess;
use strict;
use strict;
@@
-1216,7
+1217,7
@@
sub spawn_cmd
no strict 'refs';
no strict 'refs';
- my $fc =
Mojo::IOLoop::
Subprocess->new;
+ my $fc =
DX
Subprocess->new;
# just behave normally if something has set the "one-shot" _nospawn in the channel
if ($self->{_nospawn}) {
# just behave normally if something has set the "one-shot" _nospawn in the channel
if ($self->{_nospawn}) {
@@
-1233,8
+1234,8
@@
sub spawn_cmd
$fc->run(
sub {
my $subpro = shift;
$fc->run(
sub {
my $subpro = shift;
- if (isdbg('
progress
')) {
- my $s =
qq{
line: "$line"};
+ if (isdbg('
spawn
')) {
+ my $s =
__PACKAGE__ . qq{
line: "$line"};
$s .= ", args: " . join(', ', map { defined $_ ? qq{'$_'} : q{'undef'} } @$args) if $args && @$args;
dbg($s);
}
$s .= ", args: " . join(', ', map { defined $_ ? qq{'$_'} : q{'undef'} } @$args) if $args && @$args;
dbg($s);
}
@@
-1272,7
+1273,7
@@
sub spawn_cmd
$self->send(@res);
}
}
$self->send(@res);
}
}
- diffms(
"
rcmd from $user on $call", $line, $t0, scalar @res) if isdbg('progress');
+ diffms(
__PACKAGE__, "
rcmd from $user on $call", $line, $t0, scalar @res) if isdbg('progress');
});
return @out;
});
return @out;