Class: Rubu::Step

Inherits:

Move

• Object
• Move
• Rubu::Step

show all

Includes:

MoveStyles

Defined in:

lib/rubu.rb

Overview

Instance Attribute Summary (collapse)

• - (Object) sources readonly

  Returns the value of attribute sources.

• - (Object) targets readonly

  Returns the value of attribute targets.

Attributes inherited from Move

#errmsg, #output, #status, #subs

Class Method Summary (collapse)

• + (Object) use(sources = [], targets = [])

  Create Move and register.

• + (Object) usezip(sources, targets)

  Combine list of sources and targets to source/target pairs and register.

• + (Object) zip(sources, targets)

  Combine list of sources and targets to source/target pairs.

Instance Method Summary (collapse)

• - (Boolean) date_update?

  Check for date (timestamp) based update needs.

• - (Object) fork(&blk)

  Execute commands (from block) in parallel.

• - (Step) initialize(sources = [], targets = []) constructor

  Create Step object.

• - (Boolean) mark_update?

  Check for mark (checksum) based update needs.

• - (Object) rbrun(desc = nil, &cmd)

  Define and run Ruby command.

• - (Object) rbuse(desc = nil, &cmd)

  Define and register Ruby command.

• - (Object) run

  Run Step and capture status.

• - (Object) setup

  Setup variables for Step.

• - (Object) shrun(cmd)

  Define and run Shell command.

• - (Object) shuse(cmd)

  Define and register Shell command.

• - (Object) source

  Main/only (first) source file.

• - (Object) target

  Main/only (first) target file.

• - (Boolean) update?

  Default update.

• - (Object) walk(&blk)

  Execute commands (from block) in sequence.

Methods included from MoveStyles

#parallel_run, #serial_run

Methods inherited from Move

#display, #error, #host, #host_in, #host_out, #use

500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516

# File 'lib/rubu.rb', line 500

def initialize( sources = [], targets = [] )
    super()

    unless sources.kind_of? Array
        @sources = [ sources ]
    else
        @sources = sources
    end

    unless targets.kind_of? Array
        @targets = [ targets ]
    else
        @targets = targets
    end

    setup
end

493
494
495

# File 'lib/rubu.rb', line 493

def sources
  @sources
end

494
495
496

# File 'lib/rubu.rb', line 494

def targets
  @targets
end

467
468
469

# File 'lib/rubu.rb', line 467

def self.use( sources = [], targets = [] )
    self.new( sources, targets ).use
end

486
487
488
489
490

# File 'lib/rubu.rb', line 486

def self.usezip( sources, targets )
    sources.zip( targets ).map do |pair|
        self.new( *pair ).use
    end
end

475
476
477
478
479

# File 'lib/rubu.rb', line 475

def self.zip( sources, targets )
    sources.zip( targets ).map do |pair|
        self.new( *pair )
    end
end

543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569

# File 'lib/rubu.rb', line 543

def date_update?

    # Check if targets are missing.
    @targets.each do |target|
        unless target.exist?
            return true
        end
    end

    # Check if source(s) are newer than target(s).

    newest_source = Time.new( 0 )
    @sources.each do |source|
        if source.time > newest_source && !source.skip
            newest_source = source.time
        end
    end

    oldest_target = Time.now
    @targets.each do |target|
        if target.time < oldest_target
            oldest_target = target.time
        end
    end

    return newest_source > oldest_target
end

640
641
642
643
644
645

# File 'lib/rubu.rb', line 640

def fork( &blk )
    host_in
    instance_eval &blk
    host_out
    parallel_run
end

573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600

# File 'lib/rubu.rb', line 573

def mark_update?

    unless date_update?
        return false
    end

    # Check if targets are missing.
    unless target.exist?
        return true
    end

    old_verbose = Order[ :verbose ]
    Order[ :verbose ] = false
    step
    Order[ :verbose ] = old_verbose

    unless target.exist?
        error "file generation failure"
        exit false
    end

    unless State.md5_check_and_update?( target.rpath )
        target.skip = true
        return false
    end

    true
end

627
628
629

# File 'lib/rubu.rb', line 627

def rbrun( desc = nil, &cmd )
    RubyCommand.new( desc, &cmd ).run
end

634
635
636
637

# File 'lib/rubu.rb', line 634

def rbuse( desc = nil, &cmd )
    rb = RubyCommand.new( desc, &cmd )
    rb.use
end

526
527
528
529
530
531
532
533

# File 'lib/rubu.rb', line 526

def run
    if update?
        step
    else
        @status = :success
    end
    self
end

521
522

# File 'lib/rubu.rb', line 521

def setup
end

614
615
616

# File 'lib/rubu.rb', line 614

def shrun( cmd )
    ShellCommand.new( cmd ).run
end

619
620
621
622

# File 'lib/rubu.rb', line 619

def shuse( cmd )
    sh = ShellCommand.new( cmd )
    sh.use
end

604
605
606

# File 'lib/rubu.rb', line 604

def source
    @sources[0]
end

609
610
611

# File 'lib/rubu.rb', line 609

def target
    @targets[0]
end

537
538
539

# File 'lib/rubu.rb', line 537

def update?
    true
end

648
649
650
651
652
653

# File 'lib/rubu.rb', line 648

def walk( &blk )
    host_in
    instance_eval &blk
    host_out
    serial_run
end