monikop

   1 #! /usr/bin/perl
   2 use strict;
   3 use warnings;
   4 use integer;
   5 use File::Rsync;
   6 use File::Basename;
   7 use Thread 'async';
   8 use threads::shared;
   9 use Curses;
  10
  11 my @monikop_banner = (
  12   "    _/      _/    _/_/    _/      _/  _/_/_/  _/    _/    _/_/    _/_/_/ ",
  13   "   _/_/  _/_/  _/    _/  _/_/    _/    _/    _/  _/    _/    _/  _/    _/",
  14   "  _/  _/  _/  _/    _/  _/  _/  _/    _/    _/_/      _/    _/  _/_/_/   ",
  15   " _/      _/  _/    _/  _/    _/_/    _/    _/  _/    _/    _/  _/        ",
  16   "_/      _/    _/_/    _/      _/  _/_/_/  _/    _/    _/_/    _/         ",
  17   );
  18
  19 # Version number. Should agree with Pokinom's one.
  20 # Format: v<1>.<2>.<3> where
  21 #         <3> = bug fix,
  22 #         <2> = new feature,
  23 #         <1> = incompatible change.
  24 my $version = 'v0.1.0';
  25
  26 # Debug mode:
  27 # 0 = clean UI; 1 = lots of scrolling junk; anything else = both (pipe to file).
  28 my $debug = 0;
  29 $debug = $ARGV[1] if $ARGV[1];
  30
  31 # Where to read local configuration:
  32 my $monikop_config = '~/monikop/monikop.config';
  33 $monikop_config = $ARGV[0] if $ARGV[0];
  34
  35 ########################################
  36 # Settings
  37 ########################################
  38 # Possible data sources, and by what directory name to represent them in
  39 # destination.
  40 # When the latter is not unique, care must be taken that all pathnames in the
  41 # respective sources are unique.
  42 my %sources;
  43
  44 # Possible mount points of data destinations. Must be unique.
  45 my @usable_mount_points;
  46
  47 # Common directory (under a mount point) to put new data in.
  48 # Must agree with Pokinom's setting.
  49 my $path_under_mount_point;
  50
  51 # Directories (under any mount point) of this name will be deleted
  52 # Must agree with Pokinom's setting.
  53 my $path_under_mount_point_backed_up;
  54
  55 # Directory name (under a mount point) while being deleted.
  56 # Must agree with Pokinom's setting.
  57 my $path_under_mount_point_being_deleted;
  58
  59 # Path and file name prefix of rsync's raw logs:
  60 my $rsync_log_prefix;
  61
  62 # Path and file name prefix of the list of successfully rsynced files:
  63 my $finished_prefix;
  64
  65 # How to suffix the name of the duplicate of a safe file:
  66 my $safe_file_backup_suffix;
  67
  68 # How to suffix the name of an unfinished safe file:
  69 my $safe_file_unfinished_suffix;
  70
  71 # What to do (shutdown) when F3 has been pressed:
  72 my $key_f3_action;
  73
  74 # What to do (reboot) when F6 has been pressed:
  75 my $key_f6_action;
  76
  77 # Rsyncs time (in seconds) to wait for a response:
  78 my $rsync_timeout;
  79
  80 # Rsyncs directory (relative to destination) for partially transferred files.
  81 # Must agree with Pokinom's setting.
  82 my $rsync_partial_dir_name;
  83
  84 # Put actual values into the above.
  85 eval `cat $monikop_config`;
  86
  87 # Time in seconds before rsync is restarted and user information is
  88 # recalculated:
  89 my $coffee_break = 10;
  90
  91 # Places to store run-time information to share between threads:
  92 my %speeds :shared; # rsync output
  93 my %progress_ratios :shared; # rsync output
  94 my %destination_usages :shared; # i.e. used/unused
  95 my %destination_usage_ratios :shared;
  96 my %destination_source_is_writing_to :shared;
  97 my %reachable :shared;
  98
  99 sub debug_print { if ($debug) { print @_; } };
 100
 101 # Return the hash referenced by argument, which is sorted if accessed as an
 102 # array:
 103 sub sort_hash {
 104     my %hash_table = @_;
 105     my @sorted_hash = ();
 106     foreach my $key (sort keys %hash_table) {
 107         push @sorted_hash, $key, $hash_table{$key};
 108     }
 109     @sorted_hash;
 110 }
 111
 112 # Turn a path into a legal perl identifier:
 113 sub make_key_from_path {
 114     my $path = shift;
 115     ($path) =~ s/\/?(.*)\/?/$1/g;
 116     ($path) =~ s/\W/_/g;
 117     $path;
 118 }
 119
 120 my %source_roots;
 121 map {
 122     $source_roots{make_key_from_path $_} = $_
 123 } keys %sources;
 124
 125 my %source_dirs_in_destination;
 126 map {
 127     $source_dirs_in_destination{make_key_from_path $_} = $sources{$_}
 128 } keys %sources;
 129
 130 # Crudely turn date string(s) into a number. Chronological order is preserved.
 131 sub normalize_date {
 132     my $date = join '', @_;
 133     $date =~  tr/ \/:-//d;
 134     $date;
 135 }
 136
 137 # Return sorted intersection of arrays which are supposed to have unique
 138 # elements:
 139 sub intersection {
 140     my @intersection = ();
 141     my %count = ();
 142     my $element;
 143     foreach $element (@_) { $count{$element}++ }
 144     foreach $element (keys %count) {
 145         push @intersection, $element if $count{$element} > 1;
 146     }
 147     sort @intersection;
 148 }
 149
 150 # Write @content to a file with name $filename or a name starting with
 151 # $filename and ending with $safe_file_backup_suffix. Leave at least one such
 152 # file, even if interrupted.
 153 sub safe_write {
 154     my ($filename, @content) = @_;
 155     my $filename_a = $filename;
 156     my $filename_b = $filename . $safe_file_backup_suffix;
 157     my $filename_unfinished = $filename . $safe_file_unfinished_suffix;
 158     local (*FILE_UNFINISHED);
 159     open FILE_UNFINISHED, '>', $filename_unfinished
 160         or die "[" . $$ . "] open $filename_unfinished failed: $!\n";
 161     print FILE_UNFINISHED @content;
 162     close FILE_UNFINISHED;
 163     qx(cp $filename_unfinished $filename_b);
 164     qx(mv $filename_unfinished $filename_a);
 165 }
 166
 167 # Put contents of $filename into an array:
 168 sub read_list {
 169     my ($filename) = @_;
 170     local (*FILE);
 171     open FILE, '<', $filename
 172         or warn "[" . $$ . "] open $filename failed: $!\n";
 173     my @value = <FILE>;
 174     close FILE;
 175     @value;
 176 }
 177
 178 # Read a file written by safe_write
 179 sub safe_read {
 180     my ($filename) = @_;
 181     my $filename_a = $filename;
 182     my $filename_b = $filename . $safe_file_backup_suffix;
 183     if (stat $filename_a) { $filename = $filename_a }
 184     elsif (stat $filename_b) { $filename = $filename_b }
 185     else { return () }
 186     debug_print "SAFE_READ: $filename";
 187     read_list $filename;
 188 }
 189
 190 my @destination_roots;
 191 my %rsync_outfun;
 192 my %rsync;
 193 my %rsync_exec_form;
 194 my %rsync_dir;
 195 my %rsync_dir_exec_form;
 196 my %rsync_dir_err_form;
 197 my %rsync_worker_thread;
 198 my %being_deleted_thread;
 199 my $destinations_monitor_thread;
 200 my $display_thread;
 201
 202 sub rsync_preparation_form {
 203     my ($source) = @_;
 204     $speeds{$source} = "-";
 205     join ( '',
 206            "\n",
 207 ##########  Capture rsync's status messages for use by UI
 208            '$rsync_outfun{\'', $source, '\'} = sub {',
 209            '    my ($outline, $outputchannel) = @_ ; ',
 210            '    my ($speed) = $outline =~ /\d+\s+\d+%\s+(\S+)/; ',
 211            '    my ($progress_ratio) = ',
 212            '        $outline =~ /.+to-check=(\d+\/\d+)\)$/; ',
 213            '    if ($speed and $outputchannel eq \'out\') {',
 214            '        $speeds{\'', $source, '\'} = $speed;',
 215            '    } else {',
 216            '        $speeds{\'', $source, '\'} = "-";',
 217            '    };',
 218            '    if ($progress_ratio and $outputchannel eq \'out\') {',
 219            '        $progress_ratios{\'', $source, '\'} = $progress_ratio;',
 220            '    } ;',
 221            '};',
 222            "\n",
 223 ##########  Run rsync: main worker
 224            '$rsync{\'', $source, '\'} = File::Rsync->new; ',
 225 ##########  Return fodder for another eval
 226            '$rsync_exec_form{\'', $source, '\'} = sub {',
 227            '    my ($complete_destination) = @_;',
 228            '    \'$rsync{\\\'', $source, '\\\'}->exec(',
 229            '        {',
 230            '            src => \\\'', $source_roots{$source}, '/\\\', ',
 231            '            dest => \\\'\' . $complete_destination . \'/\\\', ',
 232            '            outfun => $rsync_outfun{\\\'', $source, '\\\'}, ',
 233            '            progress => 1, debug => 0, verbose => 0, ',
 234            '            filter => [\\\'merge,- ', $finished_prefix, $source,
 235            '\\\'], ',
 236            '            literal => [',
 237            '                        \\\'--recursive\\\', \\\'--times\\\', ',
 238            '                        \\\'--partial-dir=',
 239            $rsync_partial_dir_name, '\\\', ',
 240            '                        \\\'--timeout=', $rsync_timeout, '\\\', ',
 241            '                        \\\'--prune-empty-dirs\\\', ',
 242            '                        \\\'--log-file-format=%i %b %l %M %n\\\', ',
 243                             join (', ',
 244                                   map {
 245                                       '\\\'--compare-dest=' . $_ . '/'
 246                                           . $path_under_mount_point . '/'.
 247                                           $source_dirs_in_destination{$source}
 248                                       . '/\\\''
 249                                   }
 250                                   ( @destination_roots )),
 251            '                      , \\\'--log-file=', $rsync_log_prefix, $source, '\\\'] ',
 252            '        }',
 253            '    );\' ',
 254            '};',
 255            "\n",
 256 ##########  Run rsync: get directory from source
 257            '$rsync_dir{\'', $source, '\'} = File::Rsync->new; ',
 258 ##########  Return fodder for another eval: dir
 259            '$rsync_dir_exec_form{\'', $source, '\'} = sub {',
 260            '    \'$rsync_dir{\\\'', $source, '\\\'}->list(',
 261            '        {',
 262            '            src => \\\'', $source_roots{$source}, '/\\\', ',
 263            '            literal => [ \\\'--recursive\\\', ',
 264            '                         \\\'--timeout=', $rsync_timeout, '\\\'] ',
 265            '        }',
 266            '    );\' ',
 267            '};',
 268            "\n",
 269 ##########  Return fodder for another eval: error code from last rsync call
 270            '$rsync_dir_err_form{\'', $source, '\'} = sub {',
 271            '    \'$rsync_dir{\\\'', $source, '\\\'}->err();\' ',
 272            '}',
 273            "\n"
 274         )};
 275
 276 sub act_on_keypress {
 277     my ($pressed_key) = @_;
 278     if ($pressed_key eq 267) { qx($key_f3_action) }
 279     elsif ($pressed_key eq 270) { qx($key_f6_action); }
 280 }
 281
 282 # Run rsync for one $source, try all destinations:
 283 sub rsync_someplace {
 284     my ($source, @destinations) = @_;
 285     my $success;
 286
 287     my $rsync_log_name = $rsync_log_prefix . $source;
 288     my $finished_name = $finished_prefix . $source;
 289     foreach (@destinations) {
 290         $destination_source_is_writing_to{$source} = $_;
 291         my $common_destination = $_ . '/' . $path_under_mount_point;
 292         my $complete_destination = $common_destination . '/'
 293             . $source_dirs_in_destination{$source};
 294         qx(mkdir -p $common_destination);
 295         if ($?) { die "Fatal: $common_destination is not writable."}
 296         if (eval ($rsync_exec_form{$source} ($complete_destination))) {
 297             debug_print "EVAL RSYNC_EXEC_FORM (successful) $source,\ $complete_destination: $@ \n";
 298             $success = 1;
 299             last; # unnecessary reruns would put empty
 300             #       dirs into otherwise unused destinations
 301         } else {
 302             debug_print "EVAL RSYNC_EXEC_FORM (failed) $source, $complete_destination: $@ \n";
 303             $success = 0;
 304         }
 305     }
 306     $success;
 307 }
 308
 309 $SIG{TERM} = sub {
 310     $display_thread->kill('TERM')->join;
 311     die "Caught signal $_[0]";
 312 };
 313
 314
 315 # Preparations done; sleeves up!
 316
 317 # Make sure we have dirs to put our logs in:
 318 map {
 319     my ($filename, $directory) = fileparse $_;
 320     qx(mkdir -p $directory);
 321 } ( $rsync_log_prefix, $finished_prefix );
 322
 323 # Find usable destinations:
 324 my @raw_mount_points = grep (s/\S+ on (.*) type .*/$1/, qx/mount/);
 325 chomp @raw_mount_points;
 326 @destination_roots = intersection @raw_mount_points, @usable_mount_points;
 327 debug_print "DESTINATION_ROOTS:\n";
 328 debug_print @destination_roots;
 329
 330 # Clean up destinations:
 331 map {
 332     my $p_i_d = $_ . '/' . $path_under_mount_point;
 333     my $p_i_d_backed_up =  $_ . '/' . $path_under_mount_point_backed_up;
 334     my $p_i_d_being_deleted =  $_ . '/' . $path_under_mount_point_being_deleted;
 335     if (-d $p_i_d_backed_up and -d $p_i_d_being_deleted) {
 336         warn "[" . $$ . "] " .
 337             "Both $p_i_d_backed_up and $ p_i_d_being_deleted exist.\n" .
 338             "This does not normally happen.\n" .
 339             "I'm deleting $p_i_d_being_deleted. Be patient.\n";
 340         qx(rm -rf $p_i_d_being_deleted);
 341     }
 342     qx(mv -f $p_i_d_backed_up $p_i_d_being_deleted 2> /dev/null);
 343     $being_deleted_thread{$_} = async {
 344         $SIG{TERM} = sub { threads->exit() };
 345         qx(rm -rf $p_i_d_being_deleted); };
 346 } @destination_roots;
 347
 348 if (scalar @destination_roots) {
 349 # Set up and start things per source_root:
 350     map {
 351         # rotate for crude load balancing:
 352         push (@destination_roots, shift (@destination_roots));
 353         $progress_ratios{$_} = "?"; # Initialize for UI
 354         $rsync_worker_thread{$_} = async {
 355             $SIG{TERM} = sub { threads->exit() };
 356             my $rsync_log_name = $rsync_log_prefix . $_;
 357             my $finished_name = $finished_prefix . $_;
 358             debug_print 'rsync_preparation_form:' .
 359                 rsync_preparation_form ($_). "\n";
 360             eval rsync_preparation_form $_;
 361             debug_print "EVAL RSYNC_PREPARATION_FORM $_: $@ \n";
 362             while (1) {
 363                 debug_print 'rsync_dir_exec_form $_:'.
 364                     $rsync_dir_exec_form{$_} () . "\n";
 365                 my @rsync_ls = eval $rsync_dir_exec_form{$_}();
 366                 $reachable{$_} = eval $rsync_dir_err_form{$_}() ? 0 : 1;
 367                 debug_print "REACHABLE: $reachable{$_}\n";
 368                 if ($reachable{$_}) {
 369                     my %old_finished = safe_read $finished_name;
 370                     if (-f $rsync_log_name) {
 371                         my @rsync_log = read_list $rsync_log_name;
 372                         foreach (@rsync_log) {
 373                             my ($file_length, $modification_time, $filename) =
 374                                 /[\d\/\s:\[\]]+ [>c\.][fd]\S{9} \d+ (\d+) ([\d\/:-]+) (.*)$/;
 375                             if ($filename) {
 376                                 $old_finished{$filename . "\n"} =
 377                                     "### " . $modification_time . " " .
 378                                     $file_length . "\n";
 379                             }
 380                         }
 381                         safe_write $finished_name, sort_hash %old_finished;
 382                         unlink $rsync_log_name unless $debug;
 383                     }
 384                     my %finished = ();
 385                     # Delete from %old_finished what has to be re-rsynced.
 386                     foreach (@rsync_ls) {
 387                         my ($ls_size, $ls_modification_date,
 388                             $ls_modification_time, $ls_filename) =
 389                                 /[drwx-]+\s+(\d+) ([\d\/]+) ([\d:]+) (.*)/;
 390                         if ($ls_filename &&
 391                             exists $old_finished{$ls_filename . "\n"}) {
 392                             my ($finished_modification_date, $finished_size) =
 393                                 $old_finished{$ls_filename . "\n"} =~
 394                                 /### (\S+) (\d+)$/;
 395                             if ( ($finished_size eq $ls_size)
 396                                  && (normalize_date
 397                                      ($finished_modification_date)
 398                                      eq normalize_date
 399                                      ($ls_modification_date,
 400                                       $ls_modification_time)) )
 401                             {
 402                                 $finished{$ls_filename . "\n"} =
 403                                     $old_finished{$ls_filename . "\n"};
 404                             }
 405                         }
 406                     }
 407                     safe_write $finished_name, %finished;
 408                     if (rsync_someplace $_, @destination_roots) {
 409                         $progress_ratios{$_} = '0'; # Clean staleness for UI
 410                     }
 411                     sleep $coffee_break;
 412                 }
 413             }
 414         }
 415     } keys %source_roots;
 416 }
 417
 418 # Provide some reassuring user information:
 419 $destinations_monitor_thread = async {
 420     $SIG{TERM} = sub { threads->exit() };
 421     while () {
 422         map {
 423             my $destination_root = $_;
 424             my $destination_usage = 0;
 425             map {
 426                 my $source_root = $_;
 427                 my $complete_destination = $destination_root . '/'
 428                     . $path_under_mount_point . '/'
 429                     . $source_dirs_in_destination{$source_root};
 430                 my @dir = qx(ls -A $complete_destination/ 2> /dev/null);
 431                 $destination_usage = 1 if scalar @dir; # 0 = no new data
 432             } keys %source_roots;
 433             $destination_usages{$destination_root} = $destination_usage;
 434             my @destination_usage_ratio =
 435                 grep s/\S+\s+\S+\s+\S+\s+\S+\s+(\d*)%\s+\S+/$1/, qx(df -P $_);
 436             chomp @destination_usage_ratio;
 437             ($destination_usage_ratios{$_}) = @destination_usage_ratio;
 438         } @destination_roots;
 439         sleep $coffee_break;
 440     }
 441 };
 442
 443 unless ($debug == 1) {
 444 # Talk to the user.
 445     $display_thread = async {
 446         $SIG{TERM} = sub {
 447             endwin(); # Leave a usable terminal.
 448             threads->exit()
 449         };
 450
 451         my $redraw_window_count = 0;
 452         initscr();
 453         cbreak();
 454         noecho();
 455         curs_set(0);
 456         my $window_left = newwin(LINES() -8, 29, 0, 0);
 457         my $window_right = newwin(LINES() -8, 50, 0, 29);
 458         my $window_center = newwin(5, 79, LINES() -8, 0);
 459         my $window_bottom = newwin(3, 79, LINES() -3, 0);
 460         $window_bottom->keypad(1);
 461         $window_bottom->nodelay(1);
 462         start_color;
 463         init_pair 1, COLOR_MAGENTA, COLOR_BLACK;
 464         init_pair 2, COLOR_RED, COLOR_BLACK;
 465         init_pair 3, COLOR_CYAN, COLOR_BLACK;
 466         init_pair 4, COLOR_YELLOW, COLOR_BLACK;
 467         my $MAGENTA = COLOR_PAIR(1);
 468         my $RED = COLOR_PAIR(2);
 469         my $CYAN = COLOR_PAIR(3);
 470         my $YELLOW = COLOR_PAIR(4);
 471
 472         while (1) {
 473             $window_left->attron($CYAN);
 474             $window_left->box(0, 0);
 475             $window_left->addstr(0, 6, "Data Destinations");
 476             $window_left->attroff($CYAN);
 477             my $destinations_format = "%-18s%-6s%-3s";
 478             $window_left->attron(A_BOLD);
 479             $window_left->addstr(1, 1, sprintf($destinations_format,
 480                                                "Removable", "Fresh", "Usg"));
 481             $window_left->addstr(2, 1, sprintf($destinations_format,
 482                                                "Disk", "Data?", "%"));
 483             $window_left->attroff(A_BOLD);
 484             my $destination_usage;
 485             my $line_number = 3;
 486             map {
 487                 if ($destination_usages{$_}) {
 488                     $window_left->attron($RED);
 489                     $destination_usage = "yes";
 490                 } else {
 491                     $window_left->attron($CYAN);
 492                     $destination_usage = "no";
 493                 }
 494                 $window_left->
 495                     addstr($line_number, 1,
 496                            sprintf($destinations_format,
 497                                    substr($_, -17, 17),
 498                                    substr($destination_usage, -6, 6),
 499                                    substr($destination_usage_ratios{$_}
 500                                           ? $destination_usage_ratios{$_}
 501                                           : "?",
 502                                           -3, 3)));
 503                 ++ $line_number;
 504                 $window_left->attroff($RED);
 505                 $window_left->attroff($CYAN);
 506             } sort @destination_roots;
 507
 508             $window_right->attron($MAGENTA);
 509             $window_right->box(0,0);
 510             $window_right->addstr(0, 19, "Data Sources");
 511             $window_right->attroff($MAGENTA);
 512             my $sources_format = "%-15s%-11s%-9s%-13s";
 513             $window_right->attron(A_BOLD);
 514             $window_right->
 515                 addstr(1, 1, sprintf ($sources_format,
 516                                       "Data", "", "Files", " Writing"));
 517             $window_right->
 518                 addstr(2, 1, sprintf ($sources_format,
 519                                       "Source", "Speed", "To Copy", " To"));
 520             $window_right->attroff(A_BOLD);
 521             $line_number = 3;
 522             $window_right->attron($MAGENTA);
 523             map {
 524                 my $source = $_;
 525                 my $current_destination = '?';
 526                 my $progress_ratio = $progress_ratios{$source};
 527                 if (length $progress_ratio > 9) {
 528                     $progress_ratio = eval ("100*" . $progress_ratio) . "%";
 529                 }
 530                 if (exists $destination_source_is_writing_to{$source}) {
 531                     $current_destination =
 532                         $destination_source_is_writing_to{$source};
 533                 }
 534                 if ($reachable{$source}) {
 535                     $window_right->
 536                         addstr($line_number, 1,
 537                                sprintf($sources_format,
 538                                        substr($source_roots{$source}, 0, 14),
 539                                        substr($speeds{$source}, 0, 11),
 540                                        substr($progress_ratio,
 541                                               -9, 9),
 542                                        substr($current_destination, -13, 13)));
 543                     ++ $line_number;
 544                 }
 545                 $window_right->
 546                     addstr($line_number, 1,
 547                            sprintf($sources_format, "", "", "", ""));
 548             } sort (keys %source_roots);
 549             $window_right->attroff($MAGENTA);
 550
 551             $line_number = 0;
 552             map {
 553                 $window_center->addstr($line_number, 2, $_);
 554                 ++ $line_number;
 555             } @monikop_banner;
 556             $window_center->addstr(4, 78 - length $version, "$version");
 557             $window_center->move(0, 0);
 558
 559             $window_bottom->box(0,0);
 560             $window_bottom->attron(A_BOLD);
 561             $window_bottom->addstr(1, 3, "[F3]: Turn off computer.");
 562             $window_bottom->addstr(1, 53, "[F6]: Restart computer.");
 563             $window_bottom->attroff(A_BOLD);
 564
 565             $window_left->noutrefresh();
 566             $window_right->noutrefresh();
 567             $window_bottom->noutrefresh();
 568             $window_center->noutrefresh(); # Last window gets the cursor.
 569             act_on_keypress($window_bottom->getch());
 570             sleep 2;
 571             if (++ $redraw_window_count > 5) {
 572                 $redraw_window_count = 0;
 573                 redrawwin();
 574             }
 575             doupdate();
 576         }
 577     endwin();
 578     };
 579 }
 580
 581 sleep;
 582
 583 # Tidy up. (Except we don't reach this.)
 584 map {
 585     $being_deleted_thread{$_}->join if $being_deleted_thread{$_};
 586 } @destination_roots;
 587
 588 map {
 589     $rsync_worker_thread{$_}->join if $rsync_worker_thread{$_};
 590 } keys %source_roots;
 591
 592 $destinations_monitor_thread->join if $destinations_monitor_thread;
 593
 594 $display_thread->join if $display_thread;
 595
 596 __END__