celix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pnol...@apache.org
Subject [38/50] celix git commit: CELIX-272: fixed race conditions during shutdown
Date Tue, 27 Oct 2015 15:21:43 GMT
CELIX-272: fixed race conditions during shutdown


Project: http://git-wip-us.apache.org/repos/asf/celix/repo
Commit: http://git-wip-us.apache.org/repos/asf/celix/commit/fabe6674
Tree: http://git-wip-us.apache.org/repos/asf/celix/tree/fabe6674
Diff: http://git-wip-us.apache.org/repos/asf/celix/diff/fabe6674

Branch: refs/heads/feature/CELIX-230_Refactoring_of_the_shell_command_service
Commit: fabe66747a592af5fa1305e7b339d8e709bd544b
Parents: 0e7da3c
Author: Bjoern Petri <bpetri@apache.org>
Authored: Mon Oct 19 14:52:06 2015 +0200
Committer: Bjoern Petri <bpetri@apache.org>
Committed: Mon Oct 19 14:52:06 2015 +0200

----------------------------------------------------------------------
 framework/private/include/framework_private.h |  1 +
 framework/private/src/framework.c             | 25 +++++++++++-----------
 2 files changed, 14 insertions(+), 12 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/celix/blob/fabe6674/framework/private/include/framework_private.h
----------------------------------------------------------------------
diff --git a/framework/private/include/framework_private.h b/framework/private/include/framework_private.h
index 4e50e90..b3430f8 100644
--- a/framework/private/include/framework_private.h
+++ b/framework/private/include/framework_private.h
@@ -85,6 +85,7 @@ struct framework {
     celix_thread_cond_t dispatcher;
     celix_thread_mutex_t dispatcherLock;
     celix_thread_t dispatcherThread;
+    celix_thread_t shutdownThread;
 
     framework_logger_pt logger;
 };

http://git-wip-us.apache.org/repos/asf/celix/blob/fabe6674/framework/private/src/framework.c
----------------------------------------------------------------------
diff --git a/framework/private/src/framework.c b/framework/private/src/framework.c
index 7cfb9f1..a042343 100644
--- a/framework/private/src/framework.c
+++ b/framework/private/src/framework.c
@@ -2067,6 +2067,9 @@ celix_status_t framework_waitForStop(framework_pt framework) {
 		fw_log(framework->logger, OSGI_FRAMEWORK_LOG_ERROR, "Error unlocking the framework.");
 		return CELIX_FRAMEWORK_EXCEPTION;
 	}
+
+	celixThread_join(framework->shutdownThread, NULL);
+
 	fw_log(framework->logger, OSGI_FRAMEWORK_LOG_INFO, "FRAMEWORK: Successful shutdown");
 	return CELIX_SUCCESS;
 }
@@ -2101,6 +2104,13 @@ static void *framework_shutdown(void *framework) {
 	hashMapIterator_destroy(iter);
 	celixThreadMutex_unlock(&fw->installedBundleMapLock);
 
+    err = celixThreadMutex_lock(&fw->mutex);
+    if (err != 0) {
+        fw_log(fw->logger, OSGI_FRAMEWORK_LOG_ERROR,  "Error locking the framework, cannot
exit clean.");
+        celixThread_exit(NULL);
+        return NULL;
+    }
+
 	if (celixThreadMutex_lock(&fw->dispatcherLock) != CELIX_SUCCESS) {
 		fw_log(fw->logger, OSGI_FRAMEWORK_LOG_ERROR, "Error locking the dispatcherThread.");
 	}
@@ -2118,12 +2128,7 @@ static void *framework_shutdown(void *framework) {
 		celixThread_join(fw->dispatcherThread, NULL);
 	}
 
-	err = celixThreadMutex_lock(&fw->mutex);
-	if (err != 0) {
-		fw_log(fw->logger, OSGI_FRAMEWORK_LOG_ERROR,  "Error locking the framework, cannot exit
clean.");
-		celixThread_exit(NULL);
-		return NULL;
-	}
+
 	err = celixThreadCondition_broadcast(&fw->shutdownGate);
 	if (err != 0) {
 		fw_log(fw->logger, OSGI_FRAMEWORK_LOG_ERROR,  "Error waking the shutdown gate, cannot
exit clean.");
@@ -2260,6 +2265,7 @@ static void *fw_eventDispatcher(void *fw) {
 		}
 
 		if (size == 0 && framework->shutdown) {
+		    celixThreadMutex_unlock(&framework->dispatcherLock);
 			celixThread_exit(NULL);
 			return NULL;
 		}
@@ -2361,17 +2367,12 @@ static celix_status_t frameworkActivator_start(void * userData, bundle_context_p
 
 static celix_status_t frameworkActivator_stop(void * userData, bundle_context_pt context)
{
     celix_status_t status = CELIX_SUCCESS;
-
-	celix_thread_t shutdownThread;
 	framework_pt framework;
 
 	if (bundleContext_getFramework(context, &framework) == CELIX_SUCCESS) {
 
 	    fw_log(framework->logger, OSGI_FRAMEWORK_LOG_INFO, "FRAMEWORK: Start shutdownthread");
-	    if (celixThread_create(&shutdownThread, NULL, &framework_shutdown, framework)
== CELIX_SUCCESS) {
-//            celixThread_join(&status, shutdownThread);
-	        celixThread_detach(shutdownThread);
-	    } else {
+	    if (celixThread_create(&framework->shutdownThread, NULL, &framework_shutdown,
framework) != CELIX_SUCCESS) {
             fw_log(framework->logger, OSGI_FRAMEWORK_LOG_ERROR,  "Could not create shutdown
thread, normal exit not possible.");
 	        status = CELIX_FRAMEWORK_EXCEPTION;
 	    }


Mime
View raw message