16b656757b
Otherwise, destroy -> reinstall of it won't work properly, which comes up frequently during development.
55 lines
1.6 KiB
Ruby
55 lines
1.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Prog::Storage::SetupVhostBlockBackend < Prog::Base
|
|
subject_is :sshable, :vm_host
|
|
|
|
SUPPORTED_VHOST_BLOCK_BACKEND_VERSIONS = [
|
|
["v0.1-7", "x64"],
|
|
["v0.1-7", "arm64"]
|
|
].freeze.each(&:freeze)
|
|
|
|
def self.assemble(vm_host_id, version, allocation_weight: 0)
|
|
Strand.create(
|
|
prog: "Storage::SetupVhostBlockBackend",
|
|
label: "start",
|
|
stack: [{
|
|
"subject_id" => vm_host_id,
|
|
"version" => version,
|
|
"allocation_weight" => allocation_weight
|
|
}]
|
|
)
|
|
end
|
|
|
|
label def start
|
|
version = frame["version"]
|
|
arch = vm_host.arch
|
|
fail "Unsupported version: #{version}, #{arch}" unless SUPPORTED_VHOST_BLOCK_BACKEND_VERSIONS.include? [version, arch]
|
|
|
|
VhostBlockBackend.create(
|
|
version: frame["version"],
|
|
allocation_weight: 0,
|
|
vm_host_id: vm_host.id
|
|
)
|
|
|
|
register_deadline(nil, 5 * 60)
|
|
hop_install_vhost_backend
|
|
end
|
|
|
|
label def install_vhost_backend
|
|
q_version = frame["version"].shellescape
|
|
q_name = "setup-vhost-block-backend-#{q_version}".shellescape
|
|
case sshable.cmd("common/bin/daemonizer --check #{q_name}")
|
|
when "Succeeded"
|
|
sshable.cmd("common/bin/daemonizer --clean #{q_name}")
|
|
VhostBlockBackend.first(
|
|
vm_host_id: vm_host.id, version: frame["version"]
|
|
).update(allocation_weight: frame["allocation_weight"])
|
|
pop "VhostBlockBackend was setup"
|
|
when "Failed", "NotStarted"
|
|
sshable.cmd("common/bin/daemonizer 'sudo host/bin/setup-vhost-block-backend install #{q_version}' #{q_name}")
|
|
end
|
|
|
|
nap 5
|
|
end
|
|
end
|