Class: LS4::FaultDetector

Inherits:
Object
  • Object
show all
Defined in:
lib/ls4/logic/fault_detector.rb

Defined Under Namespace

Classes: Term

Instance Method Summary collapse

Constructor Details

#initialize ⇒ FaultDetector

Returns a new instance of FaultDetector.



115
116
117
118
119
120
 
# File 'lib/ls4/logic/fault_detector.rb', line 115

def initialize
	@period = 10
	@detect = 5
	@first_detect = 20  # FIXME
	@map = {}  # {nid => Term}
end

Instance Method Details

#add_nid(nid) ⇒ Object 



154
155
156
157
158
159
160
 
# File 'lib/ls4/logic/fault_detector.rb', line 154

def add_nid(nid)
	if term = @map[nid]
		return nil
	end
	@map[nid] = Term.new(@period + @first_detect)
	return true
end

#delete_nid(nid) ⇒ Object 



170
171
172
173
174
175
176
177
178
 
# File 'lib/ls4/logic/fault_detector.rb', line 170

def delete_nid(nid)
	if term = @map.delete(nid)
		if term.expired?
			on_change
		end
		return true
	end
	return nil
end

#forward_timer ⇒ Object 



190
191
192
193
194
195
196
197
198
199
200
201
202
203
 
# File 'lib/ls4/logic/fault_detector.rb', line 190

def forward_timer
	fault_nids = []
	@map.each_pair {|nid,term|
		if term.forward_timer
			fault_nids << nid
		end
	}

	if !fault_nids.empty?
		on_change
	end

	fault_nids
end

#get_fault_nids ⇒ Object 



180
181
182
183
184
185
186
187
188
 
# File 'lib/ls4/logic/fault_detector.rb', line 180

def get_fault_nids
	fault_nids = []
	@map.each_pair {|nid,term|
		if term.expired?
			fault_nids << nid
		end
	}
	fault_nids
end

#reset(nid) ⇒ Object 



145
146
147
148
149
150
151
152
 
# File 'lib/ls4/logic/fault_detector.rb', line 145

def reset(nid)
	if term = @map[nid]
		term.reset(@period + @detect)
		on_change
		return true
	end
	return nil
end

#set_init(all_nids, fault_nids) ⇒ Object 



122
123
124
125
126
127
128
129
130
131
132
133
134
 
# File 'lib/ls4/logic/fault_detector.rb', line 122

def set_init(all_nids, fault_nids)
	map = {}
	all_nids.each {|nid|
		map[nid] = Term.new(@period + @first_detect)
	}
	fault_nids.each {|nid|
		if all_nids.include?(nid)
			map[nid] = Term.new(0)
		end
	}
	@map = map
	nil
end

#set_nid(nid) ⇒ Object 



162
163
164
165
166
167
168
 
# File 'lib/ls4/logic/fault_detector.rb', line 162

def set_nid(nid)
	if @map.has_key?(nid)
		reset(nid)
	else
		add_nid(nid)
	end
end

#update(nid) ⇒ Object 



136
137
138
139
140
141
142
143
 
# File 'lib/ls4/logic/fault_detector.rb', line 136

def update(nid)
	term = @map[nid]
	if term && !term.expired?
		term.reset(@period + @detect)
		return @period
	end
	return nil
end