c4e8e26b68
We use number of hugepages used when installing & removing an SPDK installation. Although this is mostly static, but it is possible that we decide to change number of hugepages used when installing a new SPDK in future. In which case, we should remember what value used for older installations to update VmHost records correctly when removing them. This mismatch already happened in production last week, so making this change to avoid it in future.
49 lines
1.2 KiB
Ruby
49 lines
1.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class Prog::Storage::RemoveSpdk < Prog::Base
|
|
subject_is :spdk_installation
|
|
|
|
def self.assemble(spdk_installation_id)
|
|
Strand.create_with_id(
|
|
prog: "Storage::RemoveSpdk",
|
|
label: "start",
|
|
stack: [{
|
|
"subject_id" => spdk_installation_id
|
|
}]
|
|
)
|
|
end
|
|
|
|
label def start
|
|
vm_host = spdk_installation.vm_host
|
|
|
|
fail "Can't remove SPDK from hosts with less than 2 SPDK installations" if vm_host.spdk_installations.length < 2
|
|
|
|
spdk_installation.update(allocation_weight: 0)
|
|
|
|
hop_wait_volumes
|
|
end
|
|
|
|
label def wait_volumes
|
|
nap 30 if spdk_installation.vm_storage_volumes.length > 0
|
|
hop_remove_spdk
|
|
end
|
|
|
|
label def remove_spdk
|
|
version = spdk_installation.version
|
|
sshable = spdk_installation.vm_host.sshable
|
|
sshable.cmd("sudo host/bin/setup-spdk remove #{version.shellescape}")
|
|
|
|
hop_update_database
|
|
end
|
|
|
|
label def update_database
|
|
vm_host = spdk_installation.vm_host
|
|
VmHost.where(id: vm_host.id).update(
|
|
used_hugepages_1g: Sequel[:used_hugepages_1g] - spdk_installation.hugepages
|
|
)
|
|
spdk_installation.destroy
|
|
|
|
pop "SPDK installation was removed"
|
|
end
|
|
end
|