Class: LS4::MDSService

Inherits:
Service show all
Extended by:
Forwardable
Defined in:
lib/ls4/service/mds.rb

Instance Method Summary collapse

Methods inherited from Service

init

Methods included from EventBus::SingletonMixin

#ebus_bind!, #ebus_connect, extended

Methods included from EventBus::BusMixin

#ebus_all_slots, #ebus_disconnect!

Methods included from EventBus::DeclarerBase::Methods

#connect, #ebus_all_slots, #ebus_call_log, #ebus_call_slots, #ebus_signal_error, #ebus_signal_log, #ebus_signal_slots

Methods included from EventBus::DeclarerBase

#call_slot, #signal_slot

Constructor Details

#initialize ⇒ MDSService

Returns a new instance of MDSService.



97
98
99
100
 
# File 'lib/ls4/service/mds.rb', line 97

def initialize
  @uri = ""
  @mds = NullMDS.new
end

Instance Method Details

#reopen(uri) ⇒ Object 



118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
 
# File 'lib/ls4/service/mds.rb', line 118

def reopen(uri)
  klass, expr = MDSSelector.select_class(uri)

  mds = klass.new
  mds.open(expr)

  old_mds = @mds
  @mds = mds

  $log.info "using MDS: #{@mds}"

  begin
    old_mds.close
  rescue
    $log.error "MDS close error: #{$!}"
    $log.error_backtrace $!.backtrace
  end
end

#run ⇒ Object 



102
103
104
105
106
107
108
109
110
 
# File 'lib/ls4/service/mds.rb', line 102

def run
  SyncBus.register_callback(SYNC_MDS_URI,
            MDSConfigService.hash_uri(@uri)) do |obj|
    uri = obj
    reopen(uri)
    @uri = uri
    MDSConfigService.hash_uri(@uri)
  end
end

#shutdown ⇒ Object 



112
113
114
115
116
 
# File 'lib/ls4/service/mds.rb', line 112

def shutdown
  if @mds
    @mds.close rescue nil
  end
end