Lines Matching refs:opt
50 } elsif ($opt::X or $opt::m or $opt::xargs) {
60 if($opt::pipepart) {
63 @fhlist = map { open_or_exit($_) } @opt::a;
64 if(not @fhlist and not $opt::pipe) {
69 if($opt::skip_first_line) {
74 if($opt::header and not $opt::pipe) {
78 my $delimiter = $opt::colsep;
105 if($opt::filter_hosts and (@opt::sshlogin or @opt::sshloginfile)) {
110 if($opt::nonall or $opt::onall) {
121 if($opt::eta or $opt::bar) {
125 if($opt::pipepart) {
126 @Global::cat_partials = map { pipe_part_files($_) } @opt::a;
144 if(not $opt::pipepart) {
145 if($opt::pipe) {
154 if($opt::pipe and @opt::a) {
171 if($opt::halt_on_error) {
188 my @pos = find_split_positions($file,$opt::blocksize,length $header);
212 if($opt::header) {
213 if($opt::header eq ":") { $opt::header = "(.*\n)"; }
215 $opt::header =~ s/^(\d+)$/"(.*\n)"x$1/e;
216 while(read($fh,substr($$buf_ref,length $$buf_ref,0),$opt::blocksize)) {
217 if($$buf_ref=~s/^($opt::header)//) {
251 if($opt::regexp) {
311 my $blocksize = $opt::blocksize;
322 if($opt::r) {
342 } elsif($opt::regexp) {
404 if($opt::roundrobin) {
435 if(defined($opt::recstart) and defined($opt::recend)) {
437 $recstart = $opt::recstart;
438 $recend = $opt::recend;
439 } elsif(defined($opt::recstart)) {
441 $recstart = $opt::recstart;
443 } elsif(defined($opt::recend)) {
446 $recend = $opt::recend;
449 if($opt::regexp) {
533 if($opt::roundrobin) {
555 if($opt::remove_rec_sep) {
603 ("debug|D=s" => \$opt::D,
604 "xargs" => \$opt::xargs,
605 "m" => \$opt::m,
607 "v" => \@opt::v,
608 "joblog=s" => \$opt::joblog,
609 "results|result|res=s" => \$opt::results,
610 "resume" => \$opt::resume,
611 "resume-failed|resumefailed" => \$opt::resume_failed,
612 "silent" => \$opt::silent,
614 "keep-order|keeporder|k" => \$opt::keeporder,
615 "group" => \$opt::group,
616 "g" => \$opt::retired,
617 "ungroup|u" => \$opt::ungroup,
618 "linebuffer|linebuffered|line-buffer|line-buffered" => \$opt::linebuffer,
619 "tmux" => \$opt::tmux,
620 "null|0" => \$opt::0,
621 "quote|q" => \$opt::q,
624 "rpl=s" => \@opt::rpl,
625 "plus" => \$opt::plus,
626 "I=s" => \$opt::I,
627 "extensionreplace|er=s" => \$opt::U,
628 "U=s" => \$opt::retired,
629 "basenamereplace|bnr=s" => \$opt::basenamereplace,
630 "dirnamereplace|dnr=s" => \$opt::dirnamereplace,
631 "basenameextensionreplace|bner=s" => \$opt::basenameextensionreplace,
632 "seqreplace=s" => \$opt::seqreplace,
633 "slotreplace=s" => \$opt::slotreplace,
634 "jobs|j=s" => \$opt::jobs,
635 "delay=f" => \$opt::delay,
636 "sshdelay=f" => \$opt::sshdelay,
637 "load=s" => \$opt::load,
638 "noswap" => \$opt::noswap,
639 "max-line-length-allowed" => \$opt::max_line_length_allowed,
640 "number-of-cpus" => \$opt::number_of_cpus,
641 "number-of-cores" => \$opt::number_of_cores,
642 "use-cpus-instead-of-cores" => \$opt::use_cpus_instead_of_cores,
643 "shellquote|shell_quote|shell-quote" => \$opt::shellquote,
644 "nice=i" => \$opt::nice,
645 "timeout=s" => \$opt::timeout,
646 "tag" => \$opt::tag,
647 "tagstring|tag-string=s" => \$opt::tagstring,
648 "onall" => \$opt::onall,
649 "nonall" => \$opt::nonall,
650 "filter-hosts|filterhosts|filter-host" => \$opt::filter_hosts,
651 "sshlogin|S=s" => \@opt::sshlogin,
652 "sshloginfile|slf=s" => \@opt::sshloginfile,
653 "controlmaster|M" => \$opt::controlmaster,
654 "return=s" => \@opt::return,
655 "trc=s" => \@opt::trc,
656 "transfer" => \$opt::transfer,
657 "cleanup" => \$opt::cleanup,
658 "basefile|bf=s" => \@opt::basefile,
659 "B=s" => \$opt::retired,
660 "ctrlc|ctrl-c" => \$opt::ctrlc,
661 "noctrlc|no-ctrlc|no-ctrl-c" => \$opt::noctrlc,
662 "workdir|work-dir|wd=s" => \$opt::workdir,
663 "W=s" => \$opt::retired,
664 "tmpdir=s" => \$opt::tmpdir,
665 "tempdir=s" => \$opt::tmpdir,
666 "use-compress-program|compress-program=s" => \$opt::compress_program,
667 "use-decompress-program|decompress-program=s" => \$opt::decompress_program,
668 "compress" => \$opt::compress,
669 "tty" => \$opt::tty,
670 "T" => \$opt::retired,
671 "halt-on-error|halt=s" => \$opt::halt_on_error,
672 "H=i" => \$opt::retired,
673 "retries=i" => \$opt::retries,
674 "dry-run|dryrun" => \$opt::dryrun,
675 "progress" => \$opt::progress,
676 "eta" => \$opt::eta,
677 "bar" => \$opt::bar,
678 "arg-sep|argsep=s" => \$opt::arg_sep,
679 "arg-file-sep|argfilesep=s" => \$opt::arg_file_sep,
680 "trim=s" => \$opt::trim,
681 "env=s" => \@opt::env,
682 "recordenv|record-env" => \$opt::record_env,
683 "plain" => \$opt::plain,
684 "profile|J=s" => \@opt::profile,
685 "pipe|spreadstdin" => \$opt::pipe,
686 "robin|round-robin|roundrobin" => \$opt::roundrobin,
687 "recstart=s" => \$opt::recstart,
688 "recend=s" => \$opt::recend,
689 "regexp|regex" => \$opt::regexp,
690 "remove-rec-sep|removerecsep|rrs" => \$opt::remove_rec_sep,
691 "files|output-as-files|outputasfiles" => \$opt::files,
692 "block|block-size|blocksize=s" => \$opt::blocksize,
693 "tollef" => \$opt::retired,
694 "gnu" => \$opt::gnu,
695 "xapply" => \$opt::xapply,
696 "bibtex" => \$opt::bibtex,
697 "nn|nonotice|no-notice" => \$opt::no_notice,
699 "max-procs|P=s" => \$opt::jobs,
700 "delimiter|d=s" => \$opt::d,
701 "max-chars|s=i" => \$opt::max_chars,
702 "arg-file|a=s" => \@opt::a,
703 "no-run-if-empty|r" => \$opt::r,
704 "replace|i:s" => \$opt::i,
705 "E=s" => \$opt::eof,
706 "eof|e:s" => \$opt::eof,
707 "max-args|n=i" => \$opt::max_args,
708 "max-replace-args|N=i" => \$opt::max_replace_args,
709 "colsep|col-sep|C=s" => \$opt::colsep,
710 "help|h" => \$opt::help,
711 "L=f" => \$opt::L,
712 "max-lines|l:f" => \$opt::max_lines,
713 "interactive|p" => \$opt::p,
714 "verbose|t" => \$opt::verbose,
715 "version|V" => \$opt::version,
716 "minversion|min-version=i" => \$opt::minversion,
717 "show-limits|showlimits" => \$opt::show_limits,
718 "exit|x" => \$opt::x,
720 "semaphore" => \$opt::semaphore,
721 "semaphoretimeout=i" => \$opt::semaphoretimeout,
722 "semaphorename|id=s" => \$opt::semaphorename,
723 "fg" => \$opt::fg,
724 "bg" => \$opt::bg,
725 "wait" => \$opt::wait,
727 "shebang|hashbang" => \$opt::shebang,
728 "internal-pipe-means-argfiles" => \$opt::internal_pipe_means_argfiles,
729 "Y" => \$opt::retired,
730 "skip-first-line" => \$opt::skip_first_line,
731 "header=s" => \$opt::header,
732 "cat" => \$opt::cat,
733 "fifo" => \$opt::fifo,
734 "pipepart|pipe-part" => \$opt::pipepart,
735 "hgrp|hostgroup|hostgroups" => \$opt::hostgroups,
835 if(@opt::v) { $Global::verbose = $#opt::v+1; } # Convert -v -v to v=2
836 $Global::debug = $opt::D;
838 if(defined $opt::X) { $Global::ContextReplace = 1; }
839 if(defined $opt::silent) { $Global::verbose = 0; }
840 if(defined $opt::0) { $/ = "\0"; }
841 if(defined $opt::d) { my $e="sprintf \"$opt::d\""; $/ = eval $e; }
842 if(defined $opt::p) { $Global::interactive = $opt::p; }
843 if(defined $opt::q) { $Global::quoting = 1; }
845 if(defined $opt::verbose) { $Global::stderr_verbose = 1; }
856 if(defined $opt::parens) { $Global::parens = $opt::parens; }
860 if(defined $opt::plus) { %Global::rpl = (%Global::plus,%Global::rpl); }
861 if(defined $opt::I) { rpl('{}',$opt::I); }
862 if(defined $opt::U) { rpl('{.}',$opt::U); }
863 if(defined $opt::i and $opt::i) { rpl('{}',$opt::i); }
864 if(defined $opt::basenamereplace) { rpl('{/}',$opt::basenamereplace); }
865 if(defined $opt::dirnamereplace) { rpl('{//}',$opt::dirnamereplace); }
866 if(defined $opt::seqreplace) { rpl('{#}',$opt::seqreplace); }
867 if(defined $opt::slotreplace) { rpl('{%}',$opt::slotreplace); }
868 if(defined $opt::basenameextensionreplace) {
869 rpl('{/.}',$opt::basenameextensionreplace);
871 for(@opt::rpl) {
877 if(defined $opt::eof) { $Global::end_of_file_string = $opt::eof; }
878 if(defined $opt::max_args) { $Global::max_number_of_args = $opt::max_args; }
879 if(defined $opt::timeout) { $Global::timeoutq = TimeoutQueue->new($opt::timeout); }
880 if(defined $opt::tmpdir) { $ENV{'TMPDIR'} = $opt::tmpdir; }
881 if(defined $opt::help) { die_usage(); }
882 if(defined $opt::colsep) { $Global::trim = 'lr'; }
883 if(defined $opt::header) { $opt::colsep = defined $opt::colsep ? $opt::colsep : "\t"; }
884 if(defined $opt::trim) { $Global::trim = $opt::trim; }
885 if(defined $opt::arg_sep) { $Global::arg_sep = $opt::arg_sep; }
886 if(defined $opt::arg_file_sep) { $Global::arg_file_sep = $opt::arg_file_sep; }
887 if(defined $opt::number_of_cpus) { print SSHLogin::no_of_cpus(),"\n"; wait_and_exit(0); }
888 if(defined $opt::number_of_cores) {
891 if(defined $opt::max_line_length_allowed) {
894 if(defined $opt::version) { version(); wait_and_exit(0); }
895 if(defined $opt::bibtex) { bibtex(); wait_and_exit(0); }
896 if(defined $opt::record_env) { record_env(); wait_and_exit(0); }
897 if(defined $opt::show_limits) { show_limits(); }
898 if(@opt::sshlogin) { @Global::sshlogin = @opt::sshlogin; }
899 if(@opt::sshloginfile) { read_sshloginfiles(@opt::sshloginfile); }
900 if(@opt::return) { push @Global::ret_files, @opt::return; }
901 if(not defined $opt::recstart and
902 not defined $opt::recend) { $opt::recend = "\n"; }
903 if(not defined $opt::blocksize) { $opt::blocksize = "1M"; }
904 $opt::blocksize = multiply_binary_prefix($opt::blocksize);
905 if(defined $opt::controlmaster) { $opt::noctrlc = 1; }
906 if(defined $opt::semaphore) { $Global::semaphore = 1; }
907 if(defined $opt::semaphoretimeout) { $Global::semaphore = 1; }
908 if(defined $opt::semaphorename) { $Global::semaphore = 1; }
909 if(defined $opt::fg) { $Global::semaphore = 1; }
910 if(defined $opt::bg) { $Global::semaphore = 1; }
911 if(defined $opt::wait) { $Global::semaphore = 1; }
912 if(defined $opt::halt_on_error and
913 $opt::halt_on_error=~/%/) { $opt::halt_on_error /= 100; }
914 if(defined $opt::timeout and $opt::timeout !~ /^\d+(\.\d+)?%?$/) {
918 if(defined $opt::minversion) {
920 if($Global::version < $opt::minversion) {
926 if(not defined $opt::delay) {
928 $opt::delay = $opt::sshdelay;
930 if($opt::compress_program) {
931 $opt::compress = 1;
932 $opt::decompress_program ||= $opt::compress_program." -dc";
934 if($opt::compress) {
936 $opt::compress_program ||= $compress;
937 $opt::decompress_program ||= $decompress;
939 if(defined $opt::nonall) {
943 if(defined $opt::tty) {
946 if(not defined $opt::jobs) {
947 $opt::jobs = 1;
949 if(not defined $opt::group) {
950 $opt::ungroup = 0;
953 if(@opt::trc) {
954 push @Global::ret_files, @opt::trc;
955 $opt::transfer = 1;
956 $opt::cleanup = 1;
958 if(defined $opt::max_lines) {
959 if($opt::max_lines eq "-0") {
961 $opt::max_lines = 1;
962 $opt::0 = 1;
964 } elsif ($opt::max_lines == 0) {
966 $opt::max_lines = 1;
968 $Global::max_lines = $opt::max_lines;
969 if(not $opt::pipe) {
976 if(defined $opt::L) {
977 $Global::max_lines = $opt::L;
978 if(not $opt::pipe) {
983 if(defined $opt::max_replace_args) {
984 $Global::max_number_of_args = $opt::max_replace_args;
987 if((defined $opt::L or defined $opt::max_replace_args)
989 not ($opt::xargs or $opt::m)) {
992 if(defined $opt::tag and not defined $opt::tagstring) {
993 $opt::tagstring = "\257<\257>"; # Default = {}
995 if(defined $opt::pipepart and
996 (defined $opt::L or defined $opt::max_lines
997 or defined $opt::max_replace_args)) {
1013 @opt::a = ("/dev/null");
1015 $Semaphore::timeout = $opt::semaphoretimeout || 0;
1016 if(defined $opt::semaphorename) {
1017 $Semaphore::name = $opt::semaphorename;
1022 $Semaphore::fg = $opt::fg;
1023 $Semaphore::wait = $opt::wait;
1025 if(not defined $opt::jobs) {
1026 $opt::jobs = 1;
1028 if($Global::interactive and $opt::bg) {
1034 if(defined $opt::eta) {
1035 $opt::progress = $opt::eta;
1037 if(defined $opt::bar) {
1038 $opt::progress = $opt::bar;
1040 if(defined $opt::retired) {
1056 if(remote_hosts() and ($opt::X or $opt::m or $opt::xargs)) {
1063 if(not defined $opt::jobs) {
1064 $opt::jobs = "100%";
1113 for my $varstring (@opt::env) {
1205 if(($opt::resume or $opt::resume_failed)
1207 not ($opt::joblog or $opt::results)) {
1211 if($opt::joblog) {
1212 if($opt::resume || $opt::resume_failed) {
1213 if(open(my $joblog_fh, "<", $opt::joblog)) {
1217 if($opt::resume_failed) {
1230 ::error("Format of '$opt::joblog' is wrong: $_");
1239 if(not open($Global::joblog, ">>", $opt::joblog)) {
1240 ::error("Cannot append to --joblog $opt::joblog.\n");
1244 if($opt::joblog eq "-") {
1247 } elsif(not open($Global::joblog, ">", $opt::joblog)) {
1249 ::error("Cannot write to --joblog $opt::joblog.\n");
1297 $opt::shebang_wrap = ($ARGV[0] =~ s/^--shebang-?wrap *//);
1299 $opt::shebang = ($ARGV[0] =~ s/^--shebang *//);
1301 $opt::shebang .= ($ARGV[0] =~ s/^--hashbang *//);
1302 if($opt::shebang) {
1307 if($opt::shebang_wrap) {
1338 if(not $opt::plain) {
1345 if(@opt::profile) {
1348 for my $profile (@opt::profile) {
1427 or ($opt::internal_pipe_means_argfiles and $opt::pipe)
1431 push @opt::a, @group;
1442 push @opt::a, $outfh;
1462 if(@opt::basefile) { cleanup_basefile(); }
1576 if(not $opt::ungroup) {
1636 if(@opt::basefile) { setup_basefile(); }
1684 if(@opt::sshloginfile) {
1686 for my $slf (@opt::sshloginfile) {
1704 $opt::filter_hosts and filter_hosts();
1716 if($Global::JobQueue->empty() and not $opt::pipe) {
1723 if($opt::load and $sshlogin->loadavg_too_high()) {
1727 if($opt::noswap and $sshlogin->swapping()) {
1735 if($opt::delay and $opt::delay > ::now() - $Global::newest_starttime) {
1786 if($Global::JobQueue->empty() and not $opt::pipe) {
1804 ($opt::results and $opt::resume and $job->is_already_in_results()));
1808 if($opt::pipe) {
1849 if($opt::bar) {
1868 if($opt::progress) {
1877 if($opt::pipe) {
1883 if($opt::progress) {
1922 if($opt::progress) {
1935 $opt::progress = not $opt::progress;
1936 if($opt::progress) {
1951 if($opt::bar) {
1956 if($opt::eta) {
2178 if ($opt::hostgroups) {
2214 if($opt::retries and $clean_command and
2353 if($opt::transfer or @opt::return or $opt::cleanup or @opt::basefile) {
2356 if(@opt::trc) {
2358 } elsif (defined $opt::transfer) {
2360 } elsif (@opt::return) {
2362 } elsif (defined $opt::cleanup) {
2364 } elsif (@opt::basefile) {
2387 for my $file (@opt::basefile) {
2388 if($file !~ m:^/: and $opt::workdir eq "...") {
2408 for my $file (@opt::basefile) {
2531 if($opt::use_cpus_instead_of_cores) {
2572 if(@opt::basefile) { setup_basefile(); }
2580 ((defined $opt::jobs) ? "-P $opt::jobs" : ""),
2581 ((defined $opt::linebuffer) ? "--linebuffer" : ""),
2582 ((defined $opt::ungroup) ? "-u" : ""),
2583 ((defined $opt::group) ? "-g" : ""),
2584 ((defined $opt::keeporder) ? "--keeporder" : ""),
2585 ((defined $opt::D) ? "-D $opt::D" : ""),
2586 ((defined $opt::plain) ? "--plain" : ""),
2587 ((defined $opt::max_chars) ? "--max-chars ".$opt::max_chars : ""),
2591 ((defined $opt::ungroup) ? "-u" : ""),
2592 ((defined $opt::linebuffer) ? "--linebuffer" : ""),
2593 ((defined $opt::group) ? "-g" : ""),
2594 ((defined $opt::files) ? "--files" : ""),
2595 ((defined $opt::keeporder) ? "--keeporder" : ""),
2596 ((defined $opt::colsep) ? "--colsep ".shell_quote($opt::colsep) : ""),
2597 ((@opt::v) ? "-vv" : ""),
2598 ((defined $opt::D) ? "-D $opt::D" : ""),
2599 ((defined $opt::timeout) ? "--timeout ".$opt::timeout : ""),
2600 ((defined $opt::plain) ? "--plain" : ""),
2601 ((defined $opt::retries) ? "--retries ".$opt::retries : ""),
2602 ((defined $opt::max_chars) ? "--max-chars ".$opt::max_chars : ""),
2603 ((defined $opt::arg_sep) ? "--arg-sep ".$opt::arg_sep : ""),
2604 ((defined $opt::arg_file_sep) ? "--arg-file-sep ".$opt::arg_file_sep : ""),
2605 (@opt::env ? map { "--env ".::shell_quote_scalar($_) } @opt::env : ""),
2613 my $joblog = tmp_joblog($opt::joblog);
2618 my $quad = $opt::arg_file_sep || "::::";
2620 ((defined $opt::tag) ?
2625 ((defined $opt::tag) ?
2633 if(@opt::basefile) { cleanup_basefile(); }
2653 $SIG{INT} = sub { if($opt::tmux) { qx { tmux kill-session -t p$$ }; }
2655 $SIG{TERM} = sub { if($opt::tmux) { qx { tmux kill-session -t p$$ }; }
2709 if($opt::timeout) {
2714 my $print_now = ($opt::halt_on_error and $opt::halt_on_error == 2
2716 if($opt::keeporder and not $print_now) {
2743 if($opt::halt_on_error) {
2744 if($opt::halt_on_error == 1
2746 ($opt::halt_on_error < 1 and $Global::total_failed > 3
2748 $Global::total_failed / $Global::total_started > $opt::halt_on_error)) {
2758 } elsif($opt::halt_on_error == 2) {
2866 if($opt::no_notice
2868 $opt::plain
2923 if($opt::tollef and not $opt::gnu) {
2943 if($opt::tollef and not $opt::gnu) {
3183 if($opt::timeout) {
3188 if($opt::linebuffer) {
3798 $self->compute_max_loadavg($opt::load);
3868 my $nproc = $self->compute_number_of_processes($opt::jobs);
3950 if($Global::semaphore or $opt::pipe) {
3952 } elsif(defined $opt::retries and $count_jobs_already_read) {
3957 if($opt::X or $opt::m) {
4104 my $sshdelay = $opt::sshdelay ? "sleep $opt::sshdelay;" : "";
4175 if($opt::use_cpus_instead_of_cores) {
4183 if($opt::use_cpus_instead_of_cores) {
4658 if($opt::controlmaster) {
4763 if(defined $opt::workdir and $opt::workdir eq "...") {
4857 $opt::eta && ::warning("Consider removing --eta.\n");
4858 $opt::bar && ::warning("Consider removing --bar.\n");
5003 if($opt::results) {
5006 my $dir = $opt::results."/".$args_as_dirname;
5013 max_file_name_length($opt::results);
5016 $dir = $opt::results."/".$args_as_dirname;
5033 } elsif(not $opt::ungroup) {
5038 } elsif($opt::files) {
5065 if($opt::compress) {
5071 my $wpid = open(my $fdw,"|-","$opt::compress_program >>".
5076 $opt::decompress_program, $wpid,
5081 } elsif(not $opt::ungroup) {
5094 if($opt::linebuffer) {
5174 if($opt::remove_rec_sep) {
5453 if($opt::shellquote) {
5459 if($opt::nice) {
5463 $command = '\nice'. " -n". $opt::nice. " ".
5467 if($opt::cat) {
5475 } elsif($opt::fifo) {
5492 } elsif($opt::pipe) {
5507 if($opt::tmux) {
5568 if(($opt::pipe or $opt::pipepart) and $opt::ctrlc
5570 not ($opt::pipe or $opt::pipepart) and not $opt::noctrlc) {
5583 if($opt::workdir) {
5633 if($opt::transfer) {
5744 if(defined $opt::workdir and $opt::workdir eq "...") {
5754 if($opt::cleanup) {
5769 if(defined $opt::workdir) {
5770 if($opt::workdir eq ".") {
5799 } elsif($opt::workdir eq "...") {
5803 $workdir = $opt::workdir;
5860 if(($opt::dryrun or $Global::verbose) and $opt::ungroup) {
5868 if($opt::dryrun) {
5875 if($opt::pipe) {
5884 } elsif(@opt::a and not $Global::stdin_in_opt_a and $job->seq() == 1
5898 } elsif ($opt::tty and not $Global::tty_taken and -c "/dev/tty" and
5925 if($opt::timeout) {
5981 my $dir = $opt::results."/".$args_as_dirname;
6002 if (not $opt::retries) {
6012 if($self->total_failed() == $opt::retries) {
6031 if($opt::dryrun) {
6036 if($opt::pipe and $self->virgin()) {
6045 $opt::ungroup and return;
6049 if(($opt::dryrun or $Global::verbose)
6077 if($opt::files) {
6081 if($opt::pipe and $self->virgin()) {
6091 } elsif($opt::linebuffer) {
6099 if($opt::tag or defined $opt::tagstring) {
6145 if($opt::compress) {
6179 if($opt::tag or defined $opt::tagstring) {
6195 if($$partial and ($opt::tag or defined $opt::tagstring)) {
6234 replace_placeholders([$opt::tagstring],0,0)."\t";
6394 if($opt::cat or $opt::fifo) {
6438 if(($opt::m or $opt::X) and not $CommandLine::already_spread
6662 if($opt::nice) {
6672 if($opt::shellquote) {
6884 if(defined $opt::tagstring) {
6885 for($opt::tagstring) {
6898 if(defined $opt::tagstring) {
6899 $opt::tagstring =~ s/\{(-?\d+)\Q$posrpl\E/\257<$1 $perlexpr\257>/g;
6929 if($opt::tagstring) {
6930 my $t = $opt::tagstring;
6952 } elsif(($opt::pipe or $opt::pipepart)
6953 and not $opt::fifo and not $opt::cat) {
6967 'arg_queue' => RecordQueue->new($read_from,$opt::colsep),
6996 if($opt::pipe or $opt::pipepart) {
7086 if($opt::max_chars) {
7087 if($opt::max_chars <= $cached_limit) {
7088 $Limits::Command::line_max_len = $opt::max_chars;
7237 for my $s (split /$opt::colsep/o, $line, -1) {
7287 if($opt::xapply) {
7503 if($opt::hostgroups) {
7752 if(defined($opt::timeout) and
7753 $start_time + $opt::timeout > time) {
7894 if($opt::semaphoretimeout) {
7895 if($total_sleep/1000 > $opt::semaphoretimeout) {
7935 $opt::x = $Semaphore::timeout = $Semaphore::wait =