projects
/
spider.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Now add files that the previous commit refered to
[spider.git]
/
perl
/
DXCommandmode.pm
diff --git
a/perl/DXCommandmode.pm
b/perl/DXCommandmode.pm
index 9d9f60b45e90b199fda5f5c4246d064d8ef1e412..c83a7162602b2cc53c3f5cfbd2c7a816d8b19192 100644
(file)
--- a/
perl/DXCommandmode.pm
+++ b/
perl/DXCommandmode.pm
@@
-42,9
+42,10
@@
use AsyncMsg;
use JSON;
use Time::HiRes qw(gettimeofday tv_interval);
use JSON;
use Time::HiRes qw(gettimeofday tv_interval);
+use Mojo::UserAgent;
use Mojo::IOLoop;
use Mojo::IOLoop::Subprocess;
use Mojo::IOLoop;
use Mojo::IOLoop::Subprocess;
-use
Mojo::UserAgent
;
+use
DXSubprocess
;
use strict;
use vars qw(%Cache %cmd_cache $errstr %aliases $scriptbase %nothereslug
use strict;
use vars qw(%Cache %cmd_cache $errstr %aliases $scriptbase %nothereslug
@@
-1316,14
+1317,14
@@
sub spawn_cmd
return @out;
}
return @out;
}
- my $fc =
Mojo::IOLoop::
Subprocess->new;
+ my $fc =
DX
Subprocess->new;
# $fc->serializer(\&encode_json);
# $fc->deserializer(\&decode_json);
$fc->run(
sub {
my $subpro = shift;
# $fc->serializer(\&encode_json);
# $fc->deserializer(\&decode_json);
$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);
}
@@
-1357,7
+1358,7
@@
sub spawn_cmd
$dxchan->send(@res);
}
}
$dxchan->send(@res);
}
}
- diffms("by $call", $line, $t0, scalar @res) if isdbg('progress');
+ diffms(
__PACKAGE__,
"by $call", $line, $t0, scalar @res) if isdbg('progress');
});
return @out;
});
return @out;