135/netdisco
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

remove MCE :( and fix layers bug

Browse Source
This commit is contained in:
Oliver Gorwits
2014-03-10 22:27:19 +00:00
parent 140e41d7bc
commit 6838cef89a
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Netdisco/lib/App/Netdisco/Daemon/Worker/Poller/Nbtstat.pm
View File

@@ -8,9 +8,6 @@ use App::Netdisco::Util::Node 'is_nbtstatable';
use App::Netdisco::Util::Device qw/get_device is_discoverable/; use App::Netdisco::Util::Device qw/get_device is_discoverable/;
use App::Netdisco::Daemon::Util ':all'; use App::Netdisco::Daemon::Util ':all';
use MCE::Loop;
MCE::Loop::init {}; # auto chunk size
use NetAddr::IP::Lite ':lower'; use NetAddr::IP::Lite ':lower';
use Time::HiRes 'gettimeofday'; use Time::HiRes 'gettimeofday';
@@ -21,6 +18,7 @@ with 'App::Netdisco::Daemon::Worker::Poller::Common';
sub nbtstat_action { \&do_nbtstat } sub nbtstat_action { \&do_nbtstat }
sub nbtstat_filter { \&is_nbtstatable } sub nbtstat_filter { \&is_nbtstatable }
sub nbtstat_layer { 2 }
sub nbtwalk { (shift)->_walk_body('nbtstat', @_) } sub nbtwalk { (shift)->_walk_body('nbtstat', @_) }
@@ -47,13 +45,11 @@ sub nbtstat {
distinct => 1, distinct => 1,
})->ip_version(4); })->ip_version(4);
my $nodes = [$rs->get_column('ip')->all]; my @nodes = $rs->get_column('ip')->all;
my $now = 'to_timestamp('. (join '.', gettimeofday) .')'; my $now = 'to_timestamp('. (join '.', gettimeofday) .')';
mce_loop {
$self->_single_node_body('nbtstat', $_, $now) $self->_single_node_body('nbtstat', $_, $now)
for @$_; for @nodes;
} $nodes;
return job_done("Ended nbtstat for ". $host->addr); return job_done("Ended nbtstat for ". $host->addr);
} }