Module: Brush::Pipeline::POSIX

Included in:
Brush::Pipeline
Defined in:
lib/brush/pipeline.rb

Defined Under Namespace

Classes: ProcessInfo

Instance Method Summary collapse

Instance Method Details

#create_process(argv, options, close_pipes) ⇒ Object 



353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
 
# File 'lib/brush/pipeline.rb', line 353

def create_process (argv, options, close_pipes)

  # The following is used for manual specification testing to verify
  # that pipes are correctly closed after fork.  This is extremely
  # difficult to write an RSpec test for, and it is only possible on
  # platforms that have a /proc filesystem anyway.  Regardless, this
  # will be moved into an RSpec test at some point.
  #
  #$stderr.puts "===== P #{$$}: #{ %x"ls -l /proc/#{$$}/fd" }"

  pid = fork do               # child process
    [:stdin, :stdout, :stderr].each do |io_sym|
      io = options[io_sym]
      if io != Kernel.const_get(io_sym.to_s.upcase)
        Kernel.const_get(io_sym.to_s.upcase).reopen(io)
        io.close
      end
    end

    close_pipes.each { |io| io.close }
    Brush::Pipeline::PARENT_PIPES.each_key { |io| io.close }

    # This is the second half of the manual specification testing
    # started above.  See comment above for more information.
    #
    #$stderr.puts "===== C #{$$}: #{ %x"ls -l /proc/#{$$}/fd" }"

    Dir.chdir(options[:cd]) do
      exec [options[:executable], argv[0]], *argv[1..-1]
    end

    raise Error, "failed to exec"
  end

  ProcessInfo.new(pid)
end

#find_in_path(name) ⇒ Object 



390
391
392
393
394
395
396
397
398
399
400
401
 
# File 'lib/brush/pipeline.rb', line 390

def find_in_path (name)
  if name.index(File::SEPARATOR)      # Path is absolute or relative.
    return File.expand_path(name)
  else
    each_path_element do |dir|
      chkname = nil
      return chkname if File.exists?(chkname = File.join(dir, name))
    end
  end

  nil                                 # Didn't find a match. :(
end

#sys_wait(process_info) ⇒ Object 



348
349
350
351
 
# File 'lib/brush/pipeline.rb', line 348

def sys_wait (process_info)
  #system("ls -l /proc/#{$$}/fd /proc/#{process_info.process_id}/fd")
  Process.waitpid2(process_info.process_id)[1]
end