Sha256: 6792a5bfda5efbfdd9a2147efb4c1057f3754b2423065255dbe4ed80b68457d2
Contents?: true
Size: 1.87 KB
Versions: 17
Compression:
Stored size: 1.87 KB
Contents
module Vedeu
module Distributed
# @example
# Vedeu::TestApplication.build
#
class Subprocess
# @param (see #initialize)
def self.execute!(application)
new(application).execute!
end
# Returns a new instance of Vedeu::Distributed::Subprocess.
#
# @param application [Vedeu::TestApplication]
# @return [Vedeu::Distributed::Subprocess]
def initialize(application)
@application = application
@pid = nil
end
# :nocov:
# @return [Array]
def execute!
file_open && file_write && file_close
@pid = fork do
exec(file_path)
end
Process.detach(@pid)
self
end
# :nocov:
# Sends the KILL signal to the process.
#
# @return [void]
def kill
Process.kill('KILL', pid)
file_unlink
end
protected
# @!attribute [r] application
# @return [Vedeu::TestApplication]
attr_reader :application
# @!attribute [r] pid
# @return [Fixnum]
attr_reader :pid
private
# @return [String]
def command
"ruby #{file_path}"
end
# @return [Fixnum] The number of bytes written.
def file_write
file.write(application)
end
# @return [NilClass]
def file_close
file.close
end
# @return [Fixnum] The number of files removed; 1.
def file_unlink
File.unlink("/tmp/foo_#{timestamp}")
end
# return [String]
def file_path
file.path
end
# @return [File]
def file_open
@file ||= File.new("/tmp/foo_#{timestamp}", 'w', 0755)
end
alias_method :file, :file_open
# return [Fixnum]
def timestamp
@timestamp ||= Time.now.to_i
end
end # Subprocess
end # Distributed
end # Vedeu
Version data entries
17 entries across 17 versions & 1 rubygems