Class: LS4::MembershipMemberService

Inherits:
MembershipClientService show all
Defined in:
lib/ls4/service/membership.rb

Instance Method Summary collapse

Methods inherited from MembershipClientService

#run

Methods inherited from MembershipService

#get_active_rsids, #get_all_nodes, #get_node, #get_session_nid, #is_fault, #on_fault_list_change, #on_membership_change, #run, #shutdown, #stat_fault_info, #stat_membership_info, #stat_replset_info

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 ⇒ MembershipMemberService

Returns a new instance of MembershipMemberService.



255
256
257
258
259
260
261
262
 
# File 'lib/ls4/service/membership.rb', line 255

def initialize
  super
  @self_nid = ConfigBus.self_nid
  @self_address = ConfigBus.self_address
  @self_name = ConfigBus.self_name
  @self_rsids = ConfigBus.self_rsids
  @self_location = ConfigBus.self_location
end

Instance Method Details

#register_self_blocking! ⇒ Object 



294
295
296
 
# File 'lib/ls4/service/membership.rb', line 294

def register_self_blocking!
  do_register_self.join
end

#try_register_node ⇒ Object 



264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
 
# File 'lib/ls4/service/membership.rb', line 264

def try_register_node
  begin
    node = @membership.get_node(@self_nid)
  rescue
    return register_self
  end

  if node.address != @self_address
    return register_self
  end

  if node.name != @self_name
    return register_self
  end

  if node.rsids != @self_rsids
    return register_self
  end

  if node.location != @self_location
    return register_self
  end

  if @fault_list.include?(@self_nid)
    return register_self
  end

  nil
end