Method: LS4::DataServerService#on_timer

Defined in:
lib/ls4/service/data_server.rb

#on_timer ⇒ Object 



127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
 
# File 'lib/ls4/service/data_server.rb', line 127

def on_timer
	nids = []
	@self_rsids.each {|rsid|
		begin
			nids.concat MasterSelectBus.select_master_static(rsid)
		rescue
		end
	}
	done = [@self_nid]
	nids.each {|nid|
		if !done.include?(nid) && !MembershipBus.is_fault(nid)
			session = MembershipBus.get_session_nid(nid)
			SlaveBus.try_replicate(nid, session)
			done << nid
		end
	}
end