made remote timeout configurable by env

[scpubgit/System-Introspector.git] / lib / System / Introspector / Gatherer.pm

diff --git a/lib/System/Introspector/Gatherer.pm b/lib/System/Introspector/Gatherer.pm
index 43ffff4..ef43727 100644 (file)
--- a/lib/System/Introspector/Gatherer.pm
+++ b/lib/System/Introspector/Gatherer.pm
@@ -5,23 +5,32 @@ use Object::Remote::Future;
 use System::Introspector::Gatherer::Bridge;
 use Module::Runtime qw( use_module );
 
-sub gather {
-    my ($self, $class, $args) = @_;
-    return use_module("System::Introspector::Probe::$class")
-        ->new($args)
-        ->gather;
+has introspectors => (is => 'ro', required => 1);
+
+sub gather_all {
+    my ($self) = @_;
+    my %report;
+    alarm($ENV{SI_GATHER_TIMEOUT} || 60*60);
+    for my $spec (@{ $self->introspectors }) {
+        my ($base, $args) = @$spec;
+        $report{$base} = use_module("System::Introspector::Probe::$base")
+            ->new($args)
+            ->gather;
+    }
+    return \%report;
 }
 
 sub _new_direct {
-    my ($class, $remote) = @_;
-    return $class->new::on($remote);
+    my ($class, $remote, $args) = @_;
+    return $class->new::on($remote, $args || {});
 }
 
 sub _new_bridged {
-    my ($class, $bridge, $remote) = @_;
+    my ($class, $bridge, $remote, $args) = @_;
     return System::Introspector::Gatherer::Bridge->new::on($bridge,
         remote_spec  => $remote,
         remote_class => $class,
+        remote_args  => $args || {},
     );
 }
 
@@ -29,21 +38,22 @@ sub new_from_spec {
     my ($class, %arg) = @_;
     my ($user, $host, $sudo_user) = @arg{qw( user host sudo_user )};
     my $sudo = defined($sudo_user) ? sprintf('%s@', $sudo_user) : undef;
+    my $args = { introspectors => $arg{introspectors} };
     if (defined $host) {
         my $remote = join '@', grep defined, $user, $host;
         if (defined $sudo_user) {
-            return $class->_new_bridged($remote, $sudo);
+            return $class->_new_bridged($remote, $sudo, $args);
         }
         else {
-            return $class->_new_direct($remote);
+            return $class->_new_direct($remote, $args);
         }
     }
     else {
         if (defined $sudo_user) {
-            return $class->_new_direct($sudo);
+            return $class->_new_direct($sudo, $args);
         }
         else {
-            return $class->new;
+            return $class->new($args);
         }
     }
 }