#

# shell/builtin-command.rb -

# $Revision$

# $Date$

#

# --

#

end

end

class Echo < BuiltInCommand

def initialize(sh, *strings)

super sh

super sh

@pattern = pattern

end

def each(rs = nil)

rs = @shell.record_separator unless rs

yield f+rs

end

end

#

# shell/command-controller.rb -

# $Revision$

# $Date$

#

# --

#

#

# initialize of Shell and related classes.

#

def self.initialize

install_builtin_commands

# Dir#open (when path is directory)

# mode has an effect only when path is a file

#

path = expand_path(path)

if File.directory?(path)

else

end

end

end

# File#unlink (when path is file)

#

def unlink(path)

path = expand_path(path)

if File.directory?(path)

Dir.unlink(path)

else

IO.unlink(path)

end

end

#

# sh[:exists?, "foo"]

# sh["exists?", "foo"]

#

def test(command, file1, file2=nil)

file1 = expand_path(file1)

file2 = expand_path(file2) if file2

case command

when Integer

when String

if command.size == 1

if file2

# same as Dir.mkdir()

#

def mkdir(*path)

for dir in path

end

end

#

# same as Dir.rmdir()

#

def rmdir(*path)

for dir in path

Dir.rmdir(expand_path(dir))

end

end

#

# %pwd, %cwd -> @pwd

def notify(*opts, &block)

end

#

# private functions

#

def find_system_command(command)

return command if /^\// =~ command

case path = @system_commands[command]

for p in @shell.system_path

path = join(p, command)

@system_commands[command] = path

return path

end

#

# shell/error.rb -

# $Revision$

# $Date$

#

# --

#

#

# shell/process-controller.rb -

# $Revision$

# $Date$

#

# --

#

#

#

require "sync"

class Shell

class ProcessController

@ProcessControllers = {}

class<<self

end

end

if @ProcessControllers[pc]

if (@ProcessControllers[pc] -= 1) == 0

@ProcessControllers.delete(pc)

end

end

end

end

end

end

end

def initialize(shell)

@job_condition = ConditionVariable.new

end

def jobs

jobs = []

@jobs_sync.synchronize(:SH) do

@waiting_jobs.delete command

else

command = @waiting_jobs.shift

return unless command

end

@active_jobs.push command

command.start

# start all jobs that input from the job

start_job(job) if job.input == command

end

end

end

@active_jobs.delete command

ProcessController.inactivate(self)

if @active_jobs.empty?

start_job

end

end

# kill a job

def kill_job(sig, command)

if @waiting_jobs.delete command

ProcessController.inactivate(self)

return

begin

while !jobs.empty?

@job_condition.wait(@job_monitor)

end

ensure

redo unless jobs.empty?

def sfork(command, &block)

pipe_me_in, pipe_peer_out = IO.pipe

pipe_peer_in, pipe_me_out = IO.pipe

end

end

begin

_pid = nil

command.notify("job(%id) start to waiting finish.", @shell.debug?)

_pid = Process.waitpid(pid, nil)

rescue Errno::ECHILD

command.notify "warn: job(%id) was done already waitipd."

_pid = true

ensure

# when the process ends, wait until the command termintes

else

command.notify("notice: Process finishing...",

"wait for Job[%id] to finish.",

"You can use Shell#transact or Shell#check_point for more safe execution.")

redo

end

end

end

return pid, pipe_me_in, pipe_me_out

end

end

#

# shell/system-command.rb -

# $Revision$

# $Date$

#

# --

#

#

# version.rb - shell version definition file

# $Revision$

# $Date$

#

# --

#

#

class Shell

end