[ViewVC] Diff of: cvs/IO-AIO/bin/treescan

Comparing IO-AIO/bin/treescan (file contents):
Revision 1.19 by root, Fri Aug 23 07:20:21 2019 UTC vs.
Revision 1.20 by root, Tue Dec 29 15:16:28 2020 UTC

    );
 }
 @ARGV = "." unless @ARGV;
+my @todo; # list of dirs/files still left to scan
 $opt_grep &&= qr{$opt_grep}s;
 my ($n_dirs, $n_files, $n_stats) = (0, 0, 0);
 my ($n_last, $n_start) = (Time::HiRes::time) x 2;
             aio_pathsync [$wd, $_] for @$files;
             aio_pathsync $wd;
          };
       }
-      &scan ("$path$_") for @$dirs;
+      push @todo, "$path$_"
+         for sort { $b cmp $a } @$dirs;
    };
 }
 IO::AIO::max_outstanding 100; # two fds per directory, so limit accordingly
 IO::AIO::min_parallel 20;
-for my $seed (@ARGV) {
+@todo = reverse @ARGV;
+while () {
+   if (@todo) {
+printf "(%d)",scalar @todo;$|=1;#d#
+      my $seed = pop @todo;
-   $seed =~ s/\/+$//;
+      $seed =~ s/\/+$//;
-   aio_lstat "$seed/.", sub {
+      aio_lstat "$seed/.", sub {
-      if ($_[0]) {
+         if ($_[0]) {
-         print STDERR "$seed: $!\n";
+            print STDERR "$seed: $!\n";
-      } elsif (-d _) {
+         } elsif (-d _) {
-         scan $seed;
+            scan $seed;
-      } else {
+         } else {
-         printfn "", $seed, "/";
+            printfn "", $seed, "/";
+         }
-      }
+      };
+   } else {
+print "w";$|=1;#d#
+      IO::AIO::poll_wait;
-   };
+   }
-}
-IO::AIO::flush;
+   last unless IO::AIO::nreqs;
+   IO::AIO::poll_cb;
+}

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines