Просмотр исходного кода

*Dispatch returns CS_ERR_BAD_HANDLE only on first hdb_get

git-svn-id: http://svn.fedorahosted.org/svn/corosync/trunk@2197 fd59a12c-fef9-0310-b244-a6a79926bd2f
Jan Friesse 16 лет назад
Родитель
Сommit
204026fa0d
6 измененных файлов с 24 добавлено и 0 удалено
  1. 4 0
      lib/cfg.c
  2. 4 0
      lib/confdb.c
  3. 4 0
      lib/cpg.c
  4. 4 0
      lib/evs.c
  5. 4 0
      lib/quorum.c
  6. 4 0
      lib/votequorum.c

+ 4 - 0
lib/cfg.c

@@ -174,6 +174,10 @@ corosync_cfg_dispatch (
 			cfg_instance->handle,
 			(void **)&dispatch_data,
 			timeout);
+		if (error == CS_ERR_BAD_HANDLE) {
+			error = CS_OK;
+			goto error_put;
+		}
 		if (error != CS_OK) {
 			goto error_put;
 		}

+ 4 - 0
lib/confdb.c

@@ -307,6 +307,10 @@ cs_error_t confdb_dispatch (
 			confdb_inst->handle,
 			(void **)&dispatch_data,
 			timeout);
+		if (error == CS_ERR_BAD_HANDLE) {
+			error = CS_OK;
+			goto error_put;
+		}
 		if (error != CS_OK) {
 			goto error_put;
 		}

+ 4 - 0
lib/cpg.c

@@ -241,6 +241,10 @@ cs_error_t cpg_dispatch (
 			cpg_inst->handle,
 			(void **)&dispatch_data,
 			timeout);
+		if (error == CS_ERR_BAD_HANDLE) {
+			error = CS_OK;
+			goto error_put;
+		}
 		if (error != CS_OK) {
 			goto error_put;
 		}

+ 4 - 0
lib/evs.c

@@ -210,6 +210,10 @@ evs_error_t evs_dispatch (
 			evs_inst->handle,
 			(void **)&dispatch_data,
 			timeout);
+		if (error == CS_ERR_BAD_HANDLE) {
+			error = CS_OK;
+			goto error_put;
+		}
 		if (error != CS_OK) {
 			goto error_put;
 		}

+ 4 - 0
lib/quorum.c

@@ -358,6 +358,10 @@ cs_error_t quorum_dispatch (
 			quorum_inst->handle,
 			(void **)&dispatch_data,
 			timeout);
+		if (error == CS_ERR_BAD_HANDLE) {
+			error = CS_OK;
+			goto error_put;
+		}
 		if (error != CS_OK) {
 			goto error_put;
 		}

+ 4 - 0
lib/votequorum.c

@@ -712,6 +712,10 @@ cs_error_t votequorum_dispatch (
 			votequorum_inst->handle,
 			(void **)&dispatch_data,
 			timeout);
+		if (error == CS_ERR_BAD_HANDLE) {
+			error = CS_OK;
+			goto error_put;
+		}
 		if (error != CS_OK) {
 			goto error_put;
 		}