class Orocos::RubyTasks::ProcessManager

This is a drop-in replacement for ProcessClient. It creates Ruby tasks in the local process, based on the deployment models

Attributes

deployments[R]

loader[R]

task_context_class[R]

The task context class that should be used on the client side

Defaults to {TaskContext}, another option is {StubTaskContext}

@return [Class]

terminated_deployments[R]

Public Class Methods

new(loader = Orocos.default_loader, task_context_class: TaskContext) click to toggle source

# File lib/orocos/ruby_tasks/process_manager.rb, line 32
def initialize(loader = Orocos.default_loader, task_context_class: TaskContext)
    @loader = loader
    @deployments = Hash.new
    @terminated_deployments = Hash.new
    @task_context_class = task_context_class
end

Public Instance Methods

create_log_dir(log_dir, time_tag, metadata = Hash.new) click to toggle source

Creates a new log dir, and save the given time tag in it (used later on by #save_log_dir)

# File lib/orocos/ruby_tasks/process_manager.rb, line 73
def create_log_dir(log_dir, time_tag, metadata = Hash.new)
end

dead_deployment(deployment_name, status = Status.new(exit_code: 0)) click to toggle source

# File lib/orocos/ruby_tasks/process_manager.rb, line 98
def dead_deployment(deployment_name, status = Status.new(exit_code: 0))
    if deployment = deployments.delete(deployment_name)
        terminated_deployments[deployment] = status
    end
end

disconnect() click to toggle source

# File lib/orocos/ruby_tasks/process_manager.rb, line 39
def disconnect
end

register_deployment_model(model) click to toggle source

# File lib/orocos/ruby_tasks/process_manager.rb, line 42
def register_deployment_model(model)
    loader.register_deployment_model(model)
end

save_log_dir(log_dir, results_dir) click to toggle source

Requests that the process server moves the log directory at log_dir to results_dir

# File lib/orocos/ruby_tasks/process_manager.rb, line 68
def save_log_dir(log_dir, results_dir)
end

start(name, deployment_name, name_mappings, options) click to toggle source

# File lib/orocos/ruby_tasks/process_manager.rb, line 46
def start(name, deployment_name, name_mappings, options)
    model = if deployment_name.respond_to?(:to_str)
                loader.deployment_model_from_name(deployment_name)
            else deployment_name
            end
    if deployments[name]
        raise ArgumentError, "#{name} is already started in #{self}"
    end

    prefix_mappings = Orocos::ProcessBase.resolve_prefix(model, options.delete(:prefix))
    name_mappings = prefix_mappings.merge(name_mappings)

    task_context_class = options.fetch(:task_context_class, self.task_context_class)
    ruby_deployment = Process.new(self, name, model,
                                  task_context_class: task_context_class)
    ruby_deployment.name_mappings = name_mappings
    ruby_deployment.spawn
    deployments[name] = ruby_deployment
end

stop(deployment_name) click to toggle source

Requests to stop the given deployment

The call does not block until the process has quit. You will have to call wait_termination to wait for the process end.

# File lib/orocos/ruby_tasks/process_manager.rb, line 92
def stop(deployment_name)
    if deployment = deployments[deployment_name]
        deployment.kill
    end
end

wait_termination(timeout = nil) click to toggle source

Waits for processes to terminate. timeout is the number of milliseconds we should wait. If set to nil, the call will block until a process terminates

Returns a hash that maps deployment names to the Status object that represents their exit status.

# File lib/orocos/ruby_tasks/process_manager.rb, line 82
def wait_termination(timeout = nil)
    result, @terminated_deployments =
       terminated_deployments, Hash.new
    result
end