mirror of
https://github.com/ubicloud/ubicloud.git
synced 2025-10-04 05:42:15 +08:00
af2db16543
- A stripe could be fetch multiple times, and repeat fetches could overwrite changes after the earlier fetches. - If copy_on_read was false and a read spanned multiple stripes with some already fetched and others not, we incorrectly served data from the base image. This caused wrong data to be returned.
54 lines
1.6 KiB
Ruby
54 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.2.1", "x64"],
|
|
["v0.2.1", "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
|