Explorar o código

Fix error with revision 2415.

git-svn-id: http://svn.fedorahosted.org/svn/corosync/trunk@2416 fd59a12c-fef9-0310-b244-a6a79926bd2f
Steven Dake %!s(int64=16) %!d(string=hai) anos
pai
achega
f170a431ce
Modificáronse 6 ficheiros con 24 adicións e 18 borrados
  1. 4 3
      lib/cfg.c
  2. 4 3
      lib/confdb.c
  3. 4 3
      lib/cpg.c
  4. 4 3
      lib/evs.c
  5. 4 3
      lib/quorum.c
  6. 4 3
      lib/votequorum.c

+ 4 - 3
lib/cfg.c

@@ -178,16 +178,17 @@ corosync_cfg_dispatch (
 			error = CS_OK;
 			error = CS_OK;
 			goto error_put;
 			goto error_put;
 		}
 		}
-		if (error != CS_OK) {
-			goto error_put;
-		}
 		if (error == CS_ERR_TRY_AGAIN) {
 		if (error == CS_ERR_TRY_AGAIN) {
+			error = CS_OK;
 			if (dispatch_flags == CPG_DISPATCH_ALL) {
 			if (dispatch_flags == CPG_DISPATCH_ALL) {
 				break; /* exit do while cont is 1 loop */
 				break; /* exit do while cont is 1 loop */
 			} else {
 			} else {
 				continue; /* next poll */
 				continue; /* next poll */
 			}
 			}
 		}
 		}
+		if (error != CS_OK) {
+			goto error_put;
+		}
 
 
 		/*
 		/*
 		 * Make copy of callbacks, message data, unlock instance, and call callback
 		 * Make copy of callbacks, message data, unlock instance, and call callback

+ 4 - 3
lib/confdb.c

@@ -313,16 +313,17 @@ cs_error_t confdb_dispatch (
 			error = CS_OK;
 			error = CS_OK;
 			goto error_put;
 			goto error_put;
 		}
 		}
-		if (error != CS_OK) {
-			goto error_put;
-		}
 		if (error == CS_ERR_TRY_AGAIN) {
 		if (error == CS_ERR_TRY_AGAIN) {
+			error = CS_OK;
 			if (dispatch_types == CONFDB_DISPATCH_ALL) {
 			if (dispatch_types == CONFDB_DISPATCH_ALL) {
 				break; /* exit do while cont is 1 loop */
 				break; /* exit do while cont is 1 loop */
 			} else {
 			} else {
 				continue; /* next poll */
 				continue; /* next poll */
 			}
 			}
 		}
 		}
+		if (error != CS_OK) {
+			goto error_put;
+		}
 
 
 
 
 		/*
 		/*

+ 4 - 3
lib/cpg.c

@@ -289,16 +289,17 @@ cs_error_t cpg_dispatch (
 			error = CS_OK;
 			error = CS_OK;
 			goto error_put;
 			goto error_put;
 		}
 		}
-		if (error != CS_OK) {
-			goto error_put;
-		}
 		if (error == CS_ERR_TRY_AGAIN) {
 		if (error == CS_ERR_TRY_AGAIN) {
+			error = CS_OK;
 			if (dispatch_types == CPG_DISPATCH_ALL) {
 			if (dispatch_types == CPG_DISPATCH_ALL) {
 				break; /* exit do while cont is 1 loop */
 				break; /* exit do while cont is 1 loop */
 			} else {
 			} else {
 				continue; /* next poll */
 				continue; /* next poll */
 			}
 			}
 		}
 		}
+		if (error != CS_OK) {
+			goto error_put;
+		}
 
 
 		/*
 		/*
 		 * Make copy of callbacks, message data, unlock instance, and call callback
 		 * Make copy of callbacks, message data, unlock instance, and call callback

+ 4 - 3
lib/evs.c

@@ -255,16 +255,17 @@ evs_error_t evs_dispatch (
 			error = CS_OK;
 			error = CS_OK;
 			goto error_put;
 			goto error_put;
 		}
 		}
-		if (error != CS_OK) {
-			goto error_put;
-		}
 		if (error == CS_ERR_TRY_AGAIN) {
 		if (error == CS_ERR_TRY_AGAIN) {
+			error = CS_OK;
 			if (dispatch_types == CPG_DISPATCH_ALL) {
 			if (dispatch_types == CPG_DISPATCH_ALL) {
 				break; /* exit do while cont is 1 loop */
 				break; /* exit do while cont is 1 loop */
 			} else {
 			} else {
 				continue; /* next poll */
 				continue; /* next poll */
 			}
 			}
 		}
 		}
+		if (error != CS_OK) {
+			goto error_put;
+		}
 
 
 		/*
 		/*
 		 * Make copy of callbacks, message data, unlock instance, and call callback
 		 * Make copy of callbacks, message data, unlock instance, and call callback

+ 4 - 3
lib/quorum.c

@@ -362,16 +362,17 @@ cs_error_t quorum_dispatch (
 			error = CS_OK;
 			error = CS_OK;
 			goto error_put;
 			goto error_put;
 		}
 		}
-		if (error != CS_OK) {
-			goto error_put;
-		}
 		if (error == CS_ERR_TRY_AGAIN) {
 		if (error == CS_ERR_TRY_AGAIN) {
+			error = CS_OK;
 			if (dispatch_types == CPG_DISPATCH_ALL) {
 			if (dispatch_types == CPG_DISPATCH_ALL) {
 				break; /* exit do while cont is 1 loop */
 				break; /* exit do while cont is 1 loop */
 			} else {
 			} else {
 				continue; /* next poll */
 				continue; /* next poll */
 			}
 			}
 		}
 		}
+		if (error != CS_OK) {
+			goto error_put;
+		}
 
 
 		/*
 		/*
 		 * Make copy of callbacks, message data, unlock instance, and call callback
 		 * Make copy of callbacks, message data, unlock instance, and call callback

+ 4 - 3
lib/votequorum.c

@@ -716,16 +716,17 @@ cs_error_t votequorum_dispatch (
 			error = CS_OK;
 			error = CS_OK;
 			goto error_put;
 			goto error_put;
 		}
 		}
-		if (error != CS_OK) {
-			goto error_put;
-		}
 		if (error == CS_ERR_TRY_AGAIN) {
 		if (error == CS_ERR_TRY_AGAIN) {
+			error = CS_OK;
 			if (dispatch_types == CPG_DISPATCH_ALL) {
 			if (dispatch_types == CPG_DISPATCH_ALL) {
 				break; /* exit do while cont is 1 loop */
 				break; /* exit do while cont is 1 loop */
 			} else {
 			} else {
 				continue; /* next poll */
 				continue; /* next poll */
 			}
 			}
 		}
 		}
+		if (error != CS_OK) {
+			goto error_put;
+		}
 
 
 		/*
 		/*
 		 * Make copy of callbacks, message data, unlock instance, and call callback
 		 * Make copy of callbacks, message data, unlock instance, and call callback