Sha256: e77c471ed5c377ce68824c949f2fb19595722d52e04a22df8628c7c935c7da1f
Contents?: true
Size: 1014 Bytes
Versions: 6
Compression:
Stored size: 1014 Bytes
Contents
module Autoproj
module Ops
def self.watch_marker_path(root_dir)
File.join(root_dir, ".autoproj", "watch")
end
def self.watch_running?(root_dir)
io = File.open(watch_marker_path(root_dir))
!io.flock(File::LOCK_EX | File::LOCK_NB)
rescue Errno::ENOENT
false
ensure
io&.close
end
class WatchAlreadyRunning < RuntimeError; end
def self.watch_create_marker(root_dir)
io = File.open(watch_marker_path(root_dir), "a+")
unless io.flock(File::LOCK_EX | File::LOCK_NB)
raise WatchAlreadyRunning, "autoproj watch is already running as PID #{io.read.strip}"
end
io.truncate(0)
io.puts Process.pid
io.flush
rescue Exception
io&.close
raise
end
def self.watch_cleanup_marker(io)
FileUtils.rm_f io.path
io.close
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems