File corosync-sync-barrier.patch of Package corosync

Overview Repositories Revisions Requests Users Attributes Meta

File corosync-sync-barrier.patch of Package corosync (Revision d155b39639f2b518e5b65542e71dddc3)

Currently displaying revision d155b39639f2b518e5b65542e71dddc3 , Show latest

Index: syncv2.c
===================================================================
--- corosync-1.2.1/exec/syncv2.c	(revision 2739)
+++ corosync-1.2.1/exec/syncv2.c	(working copy)
@@ -244,6 +244,11 @@
 		}
 	}
 	if (barrier_reached) {
+		log_printf (LOGSYS_LEVEL_DEBUG, "Committing synchronization for %s\n",
+			my_service_list[my_processing_idx].name);
+		my_service_list[my_processing_idx].state = ACTIVATE;
+		my_service_list[my_processing_idx].sync_activate ();
+
 		my_processing_idx += 1;
 		if (my_service_list_entries == my_processing_idx) {
 			my_memb_determine_list_entries = 0;
@@ -551,19 +556,12 @@
 	if (my_service_list[my_processing_idx].state == PROCESS) {
 		my_service_list[my_processing_idx].state = PROCESS;
 		res = my_service_list[my_processing_idx].sync_process ();
-		if (res != -1) {
-			my_service_list[my_processing_idx].state = ACTIVATE;
+		if (res == 0) {
+			sync_barrier_enter();
 		} else {
 			return (-1);
 		}
 	}
-	if (my_service_list[my_processing_idx].state == ACTIVATE) {
-		my_service_list[my_processing_idx].state = ACTIVATE;
-		my_service_list[my_processing_idx].sync_activate ();
-		log_printf (LOGSYS_LEVEL_DEBUG, "Committing synchronization for %s\n",
-			my_service_list[my_processing_idx].name);
-		sync_barrier_enter();
-	}
 	return (0);
 }

Places

File corosync-sync-barrier.patch of Package corosync (Revision d155b39639f2b518e5b65542e71dddc3)

Places