X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/1a613db714afd5f1c5a14a807fea02e125a4a75b..b5c15775caf865d8fed5d4839d4a082f6518bba4:/services/api/app/models/node.rb diff --git a/services/api/app/models/node.rb b/services/api/app/models/node.rb index 0a10be80e6..f384ba582b 100644 --- a/services/api/app/models/node.rb +++ b/services/api/app/models/node.rb @@ -20,10 +20,14 @@ class Node < ArvadosModel # Only a controller can figure out whether or not the current API tokens # have access to the associated Job. They're expected to set # job_readable=true if the Job UUID can be included in the API response. - belongs_to(:job, foreign_key: :job_uuid, primary_key: :uuid) + belongs_to :job, + foreign_key: 'job_uuid', + primary_key: 'uuid', + optional: true attr_accessor :job_readable UNUSED_NODE_IP = '127.40.4.0' + MAX_VMS = 3 api_accessible :user, :extend => :common do |t| t.add :hostname @@ -39,7 +43,7 @@ class Node < ArvadosModel api_accessible :superuser, :extend => :user do |t| t.add :first_ping_at t.add :info - t.add lambda { |x| Rails.configuration.Containers["SLURM"]["Managed"]["ComputeNodeNameservers"] }, :as => :nameservers + t.add lambda { |x| Rails.configuration.Containers.SLURM.Managed.ComputeNodeNameservers.keys }, :as => :nameservers end after_initialize do @@ -47,7 +51,7 @@ class Node < ArvadosModel end def domain - super || Rails.configuration.Containers["SLURM"]["Managed"]["ComputeNodeDomain"] + super || Rails.configuration.Containers.SLURM.Managed.ComputeNodeDomain end def api_job_uuid @@ -143,7 +147,7 @@ class Node < ArvadosModel protected def assign_hostname - if self.hostname.nil? and Rails.configuration.Containers["SLURM"]["Managed"]["AssignNodeHostname"] + if self.hostname.nil? and Rails.configuration.Containers.SLURM.Managed.AssignNodeHostname self.hostname = self.class.hostname_for_slot(self.slot_number) end end @@ -158,8 +162,8 @@ class Node < ArvadosModel LIMIT 1', # query label: 'Node.available_slot_number', - # [col_id, val] for $1 vars: - [[nil, Rails.configuration.Containers["MaxComputeVMs"]]], + # bind vars: + [MAX_VMS], ).rows.first.andand.first end @@ -168,20 +172,20 @@ class Node < ArvadosModel end def dns_server_update - if ip_address_changed? && ip_address + if saved_change_to_ip_address? && ip_address Node.where('id != ? and ip_address = ?', id, ip_address).each do |stale_node| # One or more(!) stale node records have the same IP address # as the new node. Clear the ip_address field on the stale # nodes. Otherwise, we (via SLURM) might inadvertently connect # to the new node using the old node's hostname. - stale_node.update_attributes!(ip_address: nil) + stale_node.update!(ip_address: nil) end end - if hostname_was && hostname_changed? - self.class.dns_server_update(hostname_was, UNUSED_NODE_IP) + if hostname_before_last_save && saved_change_to_hostname? + self.class.dns_server_update(hostname_before_last_save, UNUSED_NODE_IP) end - if hostname && (hostname_changed? || ip_address_changed?) + if hostname && (saved_change_to_hostname? || saved_change_to_ip_address?) self.class.dns_server_update(hostname, ip_address || UNUSED_NODE_IP) end end @@ -199,20 +203,20 @@ class Node < ArvadosModel ptr_domain: ptr_domain, } - if (!Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfDir"].to_s.empty? and - !Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfTemplate"].to_s.empty?) + if (!Rails.configuration.Containers.SLURM.Managed.DNSServerConfDir.to_s.empty? and + !Rails.configuration.Containers.SLURM.Managed.DNSServerConfTemplate.to_s.empty?) tmpfile = nil begin begin - template = IO.read(Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfTemplate"]) + template = IO.read(Rails.configuration.Containers.SLURM.Managed.DNSServerConfTemplate) rescue IOError, SystemCallError => e - logger.error "Reading #{Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfTemplate"]}: #{e.message}" + logger.error "Reading #{Rails.configuration.Containers.SLURM.Managed.DNSServerConfTemplate}: #{e.message}" raise end - hostfile = File.join Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfDir"], "#{hostname}.conf" + hostfile = File.join Rails.configuration.Containers.SLURM.Managed.DNSServerConfDir, "#{hostname}.conf" Tempfile.open(["#{hostname}-", ".conf.tmp"], - Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfDir"]) do |f| + Rails.configuration.Containers.SLURM.Managed.DNSServerConfDir) do |f| tmpfile = f.path f.puts template % template_vars end @@ -228,21 +232,21 @@ class Node < ArvadosModel end end - if !Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerUpdateCommand"].empty? - cmd = Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerUpdateCommand"] % template_vars + if !Rails.configuration.Containers.SLURM.Managed.DNSServerUpdateCommand.empty? + cmd = Rails.configuration.Containers.SLURM.Managed.DNSServerUpdateCommand % template_vars if not system cmd logger.error "dns_server_update_command #{cmd.inspect} failed: #{$?}" ok = false end end - if (!Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfDir"].to_s.empty? and - !Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerReloadCommand"].to_s.empty?) - restartfile = File.join(Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfDir"], 'restart.txt') + if (!Rails.configuration.Containers.SLURM.Managed.DNSServerConfDir.to_s.empty? and + !Rails.configuration.Containers.SLURM.Managed.DNSServerReloadCommand.to_s.empty?) + restartfile = File.join(Rails.configuration.Containers.SLURM.Managed.DNSServerConfDir, 'restart.txt') begin File.open(restartfile, 'w') do |f| # Typically, this is used to trigger a dns server restart - f.puts Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerReloadCommand"] + f.puts Rails.configuration.Containers.SLURM.Managed.DNSServerReloadCommand end rescue IOError, SystemCallError => e logger.error "Unable to write #{restartfile}: #{e.message}" @@ -254,7 +258,7 @@ class Node < ArvadosModel end def self.hostname_for_slot(slot_number) - config = Rails.configuration.Containers["SLURM"]["Managed"]["AssignNodeHostname"] + config = Rails.configuration.Containers.SLURM.Managed.AssignNodeHostname return nil if !config @@ -263,13 +267,13 @@ class Node < ArvadosModel # At startup, make sure all DNS entries exist. Otherwise, slurmctld # will refuse to start. - if (!Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfDir"].to_s.empty? and - !Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfTemplate"].to_s.empty? and - !Rails.configuration.Containers["SLURM"]["Managed"]["AssignNodeHostname"].empty?) + if (!Rails.configuration.Containers.SLURM.Managed.DNSServerConfDir.to_s.empty? and + !Rails.configuration.Containers.SLURM.Managed.DNSServerConfTemplate.to_s.empty? and + !Rails.configuration.Containers.SLURM.Managed.AssignNodeHostname.empty?) - (0..Rails.configuration.Containers["MaxComputeVMs"]-1).each do |slot_number| + (0..MAX_VMS-1).each do |slot_number| hostname = hostname_for_slot(slot_number) - hostfile = File.join Rails.configuration.Containers["SLURM"]["Managed"]["DNSServerConfDir"], "#{hostname}.conf" + hostfile = File.join Rails.configuration.Containers.SLURM.Managed.DNSServerConfDir, "#{hostname}.conf" if !File.exist? hostfile n = Node.where(:slot_number => slot_number).first if n.nil? or n.ip_address.nil?