1 /* -*- mode: c; c-basic-offset: 8; -*-
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
19  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
20  * Boston, MA 021110-1307, USA.
68 /* this is horribly heavy-handed.  It should instead flip the file
76 	switch (o2nm_single_cluster->cl_fence_method) {  in o2quo_fence_self()
82 		WARN_ON(o2nm_single_cluster->cl_fence_method >=  in o2quo_fence_self()
111 	spin_lock(&qs->qs_lock);  in o2quo_make_decision()
113 	lowest_hb = find_first_bit(qs->qs_hb_bm, O2NM_MAX_NODES);  in o2quo_make_decision()
115 		lowest_reachable = test_bit(lowest_hb, qs->qs_conn_bm);  in o2quo_make_decision()
118 	     "lowest: %d (%sreachable)\n", qs->qs_heartbeating,  in o2quo_make_decision()
119 	     qs->qs_connected, lowest_hb, lowest_reachable ? "" : "un");  in o2quo_make_decision()
121 	if (!test_bit(o2nm_this_node(), qs->qs_hb_bm) ||  in o2quo_make_decision()
122 	    qs->qs_heartbeating == 1)  in o2quo_make_decision()
125 	if (qs->qs_heartbeating & 1) {  in o2quo_make_decision()
126 		/* the odd numbered cluster case is straight forward --  in o2quo_make_decision()
128 		quorum = (qs->qs_heartbeating + 1)/2;  in o2quo_make_decision()
129 		if (qs->qs_connected < quorum) {  in o2quo_make_decision()
133 			     qs->qs_connected, quorum,  in o2quo_make_decision()
134 			     qs->qs_heartbeating);  in o2quo_make_decision()
138 		/* the even numbered cluster adds the possibility of each half  in o2quo_make_decision()
141 		 * the lowest numbered node */  in o2quo_make_decision()
142 		quorum = qs->qs_heartbeating / 2;  in o2quo_make_decision()
143 		if (qs->qs_connected < quorum) {  in o2quo_make_decision()
147 			     qs->qs_connected, quorum,  in o2quo_make_decision()
148 			     qs->qs_heartbeating);  in o2quo_make_decision()
151 		else if ((qs->qs_connected == quorum) &&  in o2quo_make_decision()
154 			     "connected to a half-quorum of %u out of %u "  in o2quo_make_decision()
156 			     "node %u\n", quorum, qs->qs_heartbeating,  in o2quo_make_decision()
164 		spin_unlock(&qs->qs_lock);  in o2quo_make_decision()
169 			qs->qs_heartbeating, qs->qs_connected, lowest_hb,  in o2quo_make_decision()
171 		spin_unlock(&qs->qs_lock);  in o2quo_make_decision()
179 	assert_spin_locked(&qs->qs_lock);  in o2quo_set_hold()
181 	if (!test_and_set_bit(node, qs->qs_hold_bm)) {  in o2quo_set_hold()
182 		qs->qs_holds++;  in o2quo_set_hold()
183 		mlog_bug_on_msg(qs->qs_holds == O2NM_MAX_NODES,  in o2quo_set_hold()
185 		mlog(0, "node %u, %d total\n", node, qs->qs_holds);  in o2quo_set_hold()
191 	assert_spin_locked(&qs->qs_lock);  in o2quo_clear_hold()
193 	if (test_and_clear_bit(node, qs->qs_hold_bm)) {  in o2quo_clear_hold()
194 		mlog(0, "node %u, %d total\n", node, qs->qs_holds - 1);  in o2quo_clear_hold()
195 		if (--qs->qs_holds == 0) {  in o2quo_clear_hold()
196 			if (qs->qs_pending) {  in o2quo_clear_hold()
197 				qs->qs_pending = 0;  in o2quo_clear_hold()
198 				schedule_work(&qs->qs_work);  in o2quo_clear_hold()
201 		mlog_bug_on_msg(qs->qs_holds < 0, "node %u, holds %d\n",  in o2quo_clear_hold()
202 				node, qs->qs_holds);  in o2quo_clear_hold()
214 	spin_lock(&qs->qs_lock);  in o2quo_hb_up()
216 	qs->qs_heartbeating++;  in o2quo_hb_up()
217 	mlog_bug_on_msg(qs->qs_heartbeating == O2NM_MAX_NODES,  in o2quo_hb_up()
219 	mlog_bug_on_msg(test_bit(node, qs->qs_hb_bm), "node %u\n", node);  in o2quo_hb_up()
220 	set_bit(node, qs->qs_hb_bm);  in o2quo_hb_up()
222 	mlog(0, "node %u, %d total\n", node, qs->qs_heartbeating);  in o2quo_hb_up()
224 	if (!test_bit(node, qs->qs_conn_bm))  in o2quo_hb_up()
229 	spin_unlock(&qs->qs_lock);  in o2quo_hb_up()
238 	spin_lock(&qs->qs_lock);  in o2quo_hb_down()
240 	qs->qs_heartbeating--;  in o2quo_hb_down()
241 	mlog_bug_on_msg(qs->qs_heartbeating < 0,  in o2quo_hb_down()
243 			node, qs->qs_heartbeating);  in o2quo_hb_down()
244 	mlog_bug_on_msg(!test_bit(node, qs->qs_hb_bm), "node %u\n", node);  in o2quo_hb_down()
245 	clear_bit(node, qs->qs_hb_bm);  in o2quo_hb_down()
247 	mlog(0, "node %u, %d total\n", node, qs->qs_heartbeating);  in o2quo_hb_down()
251 	spin_unlock(&qs->qs_lock);  in o2quo_hb_down()
255  * even though we've lost it's conn.  it must only be called after conn_err
263 	spin_lock(&qs->qs_lock);  in o2quo_hb_still_up()
267 	qs->qs_pending = 1;  in o2quo_hb_still_up()
270 	spin_unlock(&qs->qs_lock);  in o2quo_hb_still_up()
282 	spin_lock(&qs->qs_lock);  in o2quo_conn_up()
284 	qs->qs_connected++;  in o2quo_conn_up()
285 	mlog_bug_on_msg(qs->qs_connected == O2NM_MAX_NODES,  in o2quo_conn_up()
287 	mlog_bug_on_msg(test_bit(node, qs->qs_conn_bm), "node %u\n", node);  in o2quo_conn_up()
288 	set_bit(node, qs->qs_conn_bm);  in o2quo_conn_up()
290 	mlog(0, "node %u, %d total\n", node, qs->qs_connected);  in o2quo_conn_up()
292 	if (!test_bit(node, qs->qs_hb_bm))  in o2quo_conn_up()
297 	spin_unlock(&qs->qs_lock);  in o2quo_conn_up()
308 	spin_lock(&qs->qs_lock);  in o2quo_conn_err()
310 	if (test_bit(node, qs->qs_conn_bm)) {  in o2quo_conn_err()
311 		qs->qs_connected--;  in o2quo_conn_err()
312 		mlog_bug_on_msg(qs->qs_connected < 0,  in o2quo_conn_err()
314 				node, qs->qs_connected);  in o2quo_conn_err()
316 		clear_bit(node, qs->qs_conn_bm);  in o2quo_conn_err()
318 		if (test_bit(node, qs->qs_hb_bm))  in o2quo_conn_err()
322 	mlog(0, "node %u, %d total\n", node, qs->qs_connected);  in o2quo_conn_err()
325 	spin_unlock(&qs->qs_lock);  in o2quo_conn_err()
332 	spin_lock_init(&qs->qs_lock);  in o2quo_init()
333 	INIT_WORK(&qs->qs_work, o2quo_make_decision);  in o2quo_init()
340 	flush_work(&qs->qs_work);  in o2quo_exit()