Contents

# -*- coding: utf-8 -*-
require 'isono'

module Dcmgr
  module NodeModules
    class StaTgtInitializer < Isono::NodeModules::Base
      include Dcmgr::Helpers::CliHelper
      include Dcmgr::Logger

      initialize_hook do
        
        manifest.config.initiator_address ||= 'ALL'

        EM.defer do
          myinstance.register_volumes
        end
      end
      
      terminate_hook do
      end

      def register_volumes
        volumes = rpc.request('sta-collector', 'get_available_volumes', node.node_id)
        iscsit = Dcmgr::Drivers::IscsiTarget.select_iscsi_target(self.node.manifest.config.iscsi_target, self.node)
        volumes.each { |volume|
          iscsit.register(volume)
        }
      end
      
      def rpc
        @rpc ||= Isono::NodeModules::RpcChannel.new(@node)
      end 
    end 
  end
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version	Path
wakame-vdc-agents-11.12.0	lib/dcmgr/node_modules/sta_tgt_initializer.rb
wakame-vdc-dcmgr-11.12.0	lib/dcmgr/node_modules/sta_tgt_initializer.rb