You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@celix.apache.org by GitBox <gi...@apache.org> on 2021/01/17 20:02:11 UTC
[GitHub] [celix] pnoltes opened a new pull request #313: Feature/refactor c dep man service trackers
pnoltes opened a new pull request #313:
URL: https://github.com/apache/celix/pull/313
Refactors the dependency manager to use the celix_ api and when possible async api.
This is more a complete rewrite than a refactor of the C dependency manager.
The dependency manager did not use the celix_ api and as result was not thread safe and was designed to be extended with a separate dependency manager event thread (which never was added).
The changed dependency manager creates and stop service trackers async, registers services async and uses the celix_bundleContext_registerService for service registration. All in all this should now be a thread safe implementation.
Because the async api is used for destruction of the dep man C objects, these functions are now also async. There are still sync variants and they use the celix_framework_waitForEvents function to synchronize till the destruction is completed on the Celix event thread.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568607313
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -282,78 +304,72 @@ celix_status_t component_removeServiceDependency(celix_dm_component_t *component
return celix_dmComponent_removeServiceDependency(component, dependency);
}
-celix_status_t celix_dmComponent_removeServiceDependency(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- executor_executeTask(component->executor, component, component_removeTask, dependency);
-
- return status;
-}
-
-static celix_status_t component_removeTask(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- arrayList_removeElement(component->dependencies, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- if (component->state != DM_CMP_STATE_INACTIVE) {
- serviceDependency_stop(dependency);
+celix_status_t celix_private_dmComponent_enable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (!component->isEnabled) {
+ component->isEnabled = true;
}
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
Review comment:
not really needed, handle change will do (effectually) nothing. But it does generate unneeded events. So I updated this.
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -282,78 +304,72 @@ celix_status_t component_removeServiceDependency(celix_dm_component_t *component
return celix_dmComponent_removeServiceDependency(component, dependency);
}
-celix_status_t celix_dmComponent_removeServiceDependency(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- executor_executeTask(component->executor, component, component_removeTask, dependency);
-
- return status;
-}
-
-static celix_status_t component_removeTask(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- arrayList_removeElement(component->dependencies, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- if (component->state != DM_CMP_STATE_INACTIVE) {
- serviceDependency_stop(dependency);
+celix_status_t celix_private_dmComponent_enable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (!component->isEnabled) {
+ component->isEnabled = true;
}
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
+ return CELIX_SUCCESS;
+}
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_remove(component->dependencyEvents, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_destroy(&dependency);
-
- while (!arrayList_isEmpty(events)) {
- dm_event_pt event = arrayList_remove(events, 0);
- event_destroy(&event);
+static celix_status_t celix_dmComponent_disable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (component->isEnabled) {
+ component->isEnabled = false;
}
- arrayList_destroy(events);
-
- component_handleChange(component);
-
- return status;
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
Review comment:
same
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568601296
##########
File path: libs/framework/include/requirement.h
##########
@@ -31,6 +24,7 @@ typedef struct requirement *requirement_pt;
#include "capability.h"
#include "hash_map.h"
+#include "celix_version_range.h"
#include "version_range.h"
Review comment:
yes
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568604388
##########
File path: libs/framework/gtest/src/DependencyManagerTestSuite.cc
##########
@@ -63,6 +65,87 @@ TEST_F(DependencyManagerTestSuite, DmCreateComponent) {
ASSERT_TRUE(celix_dependencyManager_allComponentsActive(mng));
}
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemove) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_add(mng, cmp);
+ ASSERT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_remove(mng, cmp);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ auto *cmp3 = celix_dmComponent_create(ctx, "test3");
+ celix_dependencyManager_add(mng, cmp2);
+ celix_dependencyManager_add(mng, cmp3);
+ ASSERT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_removeAllComponents(mng);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+}
+
+
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemoveAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_addAsync(mng, cmp1);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ auto cb = [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ };
+
+ celix_dependencyManager_removeAsync(mng, cmp1, &count, cb);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, DmComponentRemoveAllAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ celix_dependencyManager_add(mng, cmp1);
+ celix_dependencyManager_add(mng, cmp2);
+ EXPECT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ celix_dependencyManager_removeAllComponentsAsync(mng, &count, [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ });
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, CDmGetInfo) {
+ auto* mng = celix_bundleContext_getDependencyManager(ctx);
+ auto* cmp = celix_dmComponent_create(ctx, "test1");
+
+ auto* p = celix_properties_create();
+ celix_properties_set(p, "key", "value");
+ celix_dmComponent_addInterface(cmp, "test-interface", nullptr, (void*)0x42, p);
+
+ auto* dep = celix_dmServiceDependency_create();
+ celix_dmServiceDependency_setService(dep, "test-interface", nullptr, nullptr);
+ celix_dmComponent_addServiceDependency(cmp, dep);
+
+ celix_dependencyManager_add(mng, cmp);
+
+ auto* infos = celix_dependencyManager_createInfos(mng);
+ ASSERT_EQ(1, celix_arrayList_size(infos));
+ auto* dmInfo = (celix_dependency_manager_info_t*)celix_arrayList_get(infos, 0);
+ ASSERT_EQ(1, celix_arrayList_size(dmInfo->components));
+ auto *info = (celix_dm_component_info_t*)celix_arrayList_get(dmInfo->components, 0);
+ EXPECT_EQ(1, celix_arrayList_size(info->interfaces));
Review comment:
done
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568604663
##########
File path: libs/framework/include/celix/dm/ServiceDependency.h
##########
@@ -78,14 +70,29 @@ namespace celix { namespace dm {
/**
* Whether the service dependency is valid.
+ *
+ * Depcrated -> will always return true.
Review comment:
done
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] Webserver28 commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
Webserver28 commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r561992328
##########
File path: libs/framework/gtest/src/DependencyManagerTestSuite.cc
##########
@@ -63,6 +65,87 @@ TEST_F(DependencyManagerTestSuite, DmCreateComponent) {
ASSERT_TRUE(celix_dependencyManager_allComponentsActive(mng));
}
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemove) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_add(mng, cmp);
+ ASSERT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_remove(mng, cmp);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ auto *cmp3 = celix_dmComponent_create(ctx, "test3");
+ celix_dependencyManager_add(mng, cmp2);
+ celix_dependencyManager_add(mng, cmp3);
+ ASSERT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_removeAllComponents(mng);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+}
+
+
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemoveAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_addAsync(mng, cmp1);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ auto cb = [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ };
+
+ celix_dependencyManager_removeAsync(mng, cmp1, &count, cb);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, DmComponentRemoveAllAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ celix_dependencyManager_add(mng, cmp1);
+ celix_dependencyManager_add(mng, cmp2);
+ EXPECT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ celix_dependencyManager_removeAllComponentsAsync(mng, &count, [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ });
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, CDmGetInfo) {
+ auto* mng = celix_bundleContext_getDependencyManager(ctx);
+ auto* cmp = celix_dmComponent_create(ctx, "test1");
+
+ auto* p = celix_properties_create();
+ celix_properties_set(p, "key", "value");
+ celix_dmComponent_addInterface(cmp, "test-interface", nullptr, (void*)0x42, p);
Review comment:
Magic number, maybe make variable or add comments
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] codecov-io edited a comment on pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
codecov-io edited a comment on pull request #313:
URL: https://github.com/apache/celix/pull/313#issuecomment-761871836
# [Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=h1) Report
> Merging [#313](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=desc) (9e2b47b) into [master](https://codecov.io/gh/apache/celix/commit/afdb357a6c86773acf51840021ebbac1a2618ebd?el=desc) (afdb357) will **increase** coverage by `0.90%`.
> The diff coverage is `78.82%`.
[](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=tree)
```diff
@@ Coverage Diff @@
## master #313 +/- ##
==========================================
+ Coverage 68.69% 69.59% +0.90%
==========================================
Files 149 152 +3
Lines 30639 30217 -422
==========================================
- Hits 21046 21029 -17
+ Misses 9593 9188 -405
```
| [Impacted Files](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [bundles/shell/shell/src/dm\_shell\_list\_command.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-YnVuZGxlcy9zaGVsbC9zaGVsbC9zcmMvZG1fc2hlbGxfbGlzdF9jb21tYW5kLmM=) | `0.00% <0.00%> (ø)` | |
| [...ibs/framework/include/celix/dm/DependencyManager.h](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvaW5jbHVkZS9jZWxpeC9kbS9EZXBlbmRlbmN5TWFuYWdlci5o) | `100.00% <ø> (ø)` | |
| [libs/framework/include/celix/dm/ProvidedService.h](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvaW5jbHVkZS9jZWxpeC9kbS9Qcm92aWRlZFNlcnZpY2UuaA==) | `100.00% <ø> (ø)` | |
| [libs/framework/src/bundle.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2J1bmRsZS5j) | `64.97% <0.00%> (-3.34%)` | :arrow_down: |
| [libs/framework/src/celix\_bundle\_state.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2NlbGl4X2J1bmRsZV9zdGF0ZS5j) | `0.00% <0.00%> (ø)` | |
| [libs/framework/src/requirement.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3JlcXVpcmVtZW50LmM=) | `0.00% <0.00%> (ø)` | |
| [libs/framework/src/service\_tracker.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3NlcnZpY2VfdHJhY2tlci5j) | `71.62% <0.00%> (-10.37%)` | :arrow_down: |
| [...framework/src/framework\_bundle\_lifecycle\_handler.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2ZyYW1ld29ya19idW5kbGVfbGlmZWN5Y2xlX2hhbmRsZXIuYw==) | `25.35% <25.35%> (ø)` | |
| [libs/framework/src/service\_registry.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3NlcnZpY2VfcmVnaXN0cnkuYw==) | `74.16% <66.66%> (+0.29%)` | :arrow_up: |
| [libs/framework/src/framework.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2ZyYW1ld29yay5j) | `75.60% <76.79%> (+0.94%)` | :arrow_up: |
| ... and [37 more](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree-more) | |
------
[Continue to review full report at Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=continue).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=footer). Last update [afdb357...9e2b47b](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=lastupdated). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] Oipo commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
Oipo commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r559449882
##########
File path: libs/utils/include/version_range.h
##########
@@ -53,7 +54,7 @@ typedef struct versionRange *version_range_pt;
*/
celix_status_t
versionRange_createVersionRange(version_pt low, bool isLowInclusive, version_pt high, bool isHighInclusive,
- version_range_pt *versionRange);
+ version_range_pt *versionRange) ;
Review comment:
Can all instances of `) ;` be replaced with `);` in this file?
##########
File path: libs/framework/include/requirement.h
##########
@@ -31,6 +24,7 @@ typedef struct requirement *requirement_pt;
#include "capability.h"
#include "hash_map.h"
+#include "celix_version_range.h"
#include "version_range.h"
Review comment:
Can `version_range.h` be removed?
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -282,78 +304,72 @@ celix_status_t component_removeServiceDependency(celix_dm_component_t *component
return celix_dmComponent_removeServiceDependency(component, dependency);
}
-celix_status_t celix_dmComponent_removeServiceDependency(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- executor_executeTask(component->executor, component, component_removeTask, dependency);
-
- return status;
-}
-
-static celix_status_t component_removeTask(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- arrayList_removeElement(component->dependencies, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- if (component->state != DM_CMP_STATE_INACTIVE) {
- serviceDependency_stop(dependency);
+celix_status_t celix_private_dmComponent_enable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (!component->isEnabled) {
+ component->isEnabled = true;
}
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
Review comment:
Shouldn't `celix_dmComponent_handleChange` only be called if `isEnabled` actually changed?
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -282,78 +304,72 @@ celix_status_t component_removeServiceDependency(celix_dm_component_t *component
return celix_dmComponent_removeServiceDependency(component, dependency);
}
-celix_status_t celix_dmComponent_removeServiceDependency(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- executor_executeTask(component->executor, component, component_removeTask, dependency);
-
- return status;
-}
-
-static celix_status_t component_removeTask(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- arrayList_removeElement(component->dependencies, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- if (component->state != DM_CMP_STATE_INACTIVE) {
- serviceDependency_stop(dependency);
+celix_status_t celix_private_dmComponent_enable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (!component->isEnabled) {
+ component->isEnabled = true;
}
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
+ return CELIX_SUCCESS;
+}
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_remove(component->dependencyEvents, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_destroy(&dependency);
-
- while (!arrayList_isEmpty(events)) {
- dm_event_pt event = arrayList_remove(events, 0);
- event_destroy(&event);
+static celix_status_t celix_dmComponent_disable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (component->isEnabled) {
+ component->isEnabled = false;
}
- arrayList_destroy(events);
-
- component_handleChange(component);
-
- return status;
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
Review comment:
Shouldn't `celix_dmComponent_handleChange` only be called if `isEnabled` actually changed?
##########
File path: libs/utils/src/version_range.c
##########
@@ -16,116 +16,42 @@
* specific language governing permissions and limitations
* under the License.
*/
-/**
- * version_range.c
- *
- * \date Jul 12, 2010
- * \author <a href="mailto:dev@celix.apache.org">Apache Celix Project Team</a>
- * \copyright Apache License, Version 2.0
- */
+
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <assert.h>
#include "version_private.h"
+#include "version_range.h"
+#include "celix_version_range.h"
#include "version_range_private.h"
+#include "celix_version_range.h"
celix_status_t versionRange_createVersionRange(version_pt low, bool isLowInclusive,
version_pt high, bool isHighInclusive, version_range_pt *range) {
- assert(low != high);
- celix_status_t status = CELIX_SUCCESS;
- *range = (version_range_pt) malloc(sizeof(**range));
- if (!*range) {
- status = CELIX_ENOMEM;
- } else {
- (*range)->low = low;
- (*range)->isLowInclusive = isLowInclusive;
- (*range)->high = high;
- (*range)->isHighInclusive = isHighInclusive;
- }
-
- return status;
+ *range = celix_versionRange_createVersionRange(low, isLowInclusive, high, isHighInclusive);
+ return CELIX_SUCCESS;
}
celix_status_t versionRange_destroy(version_range_pt range) {
- if (range->high != NULL) {
- version_destroy(range->high);
- }
- if (range->low != NULL) {
- version_destroy(range->low);
- }
-
- range->high = NULL;
- range->isHighInclusive = false;
- range->low = NULL;
- range->isLowInclusive = false;
-
- free(range);
-
+ celix_versionRange_destroy(range);
return CELIX_SUCCESS;
}
celix_status_t versionRange_createInfiniteVersionRange(version_range_pt *range) {
- celix_status_t status;
-
- version_pt version = NULL;
- status = version_createEmptyVersion(&version);
- if (status == CELIX_SUCCESS) {
- status = versionRange_createVersionRange(version, true, NULL, true, range);
- }
-
- return status;
+ *range = celix_versionRange_createInfiniteVersionRange();
+ return CELIX_SUCCESS;
}
celix_status_t versionRange_isInRange(version_range_pt versionRange, version_pt version, bool *inRange) {
- celix_status_t status;
- if (versionRange->high == NULL) {
- int cmp;
- status = version_compareTo(version, versionRange->low, &cmp);
- if (status == CELIX_SUCCESS) {
- *inRange = (cmp >= 0);
- }
- } else if (versionRange->isLowInclusive && versionRange->isHighInclusive) {
- int low, high;
- status = version_compareTo(version, versionRange->low, &low);
- if (status == CELIX_SUCCESS) {
- status = version_compareTo(version, versionRange->high, &high);
- if (status == CELIX_SUCCESS) {
- *inRange = (low >= 0) && (high <= 0);
- }
- }
- } else if (versionRange->isHighInclusive) {
- int low, high;
- status = version_compareTo(version, versionRange->low, &low);
- if (status == CELIX_SUCCESS) {
- status = version_compareTo(version, versionRange->high, &high);
- if (status == CELIX_SUCCESS) {
- *inRange = (low > 0) && (high <= 0);
- }
- }
- } else if (versionRange->isLowInclusive) {
- int low, high;
- status = version_compareTo(version, versionRange->low, &low);
- if (status == CELIX_SUCCESS) {
- status = version_compareTo(version, versionRange->high, &high);
- if (status == CELIX_SUCCESS) {
- *inRange = (low >= 0) && (high < 0);
- }
- }
+ if (versionRange != NULL && version != NULL) {
+ *inRange = celix_versionRange_isInRange(versionRange, version);
+ return CELIX_SUCCESS;
} else {
- int low, high;
- status = version_compareTo(version, versionRange->low, &low);
- if (status == CELIX_SUCCESS) {
- status = version_compareTo(version, versionRange->high, &high);
- if (status == CELIX_SUCCESS) {
- *inRange = (low > 0) && (high < 0);
- }
- }
+ return CELIX_ILLEGAL_ARGUMENT;
}
-
- return status;
}
celix_status_t versionRange_getLowVersion(version_range_pt versionRange, version_pt *lowVersion) {
Review comment:
Shouldn't this also refer to `celix_versionRange_getLowVersion`?
##########
File path: libs/framework/include/celix_dependency_manager.h
##########
@@ -30,22 +30,78 @@
extern "C" {
#endif
+/**
+ * The `celix_dependencyManager_add`, `celix_dependencyManager_remove` and `celix_dependencyManager_removeAllComponents`
+ * funcions for celix_dependency_manager_t should be called outside the Celix event thread.
Review comment:
`funcions` -> `functions`
##########
File path: libs/framework/include/celix/dm/ServiceDependency.h
##########
@@ -78,14 +70,29 @@ namespace celix { namespace dm {
/**
* Whether the service dependency is valid.
+ *
+ * Depcrated -> will always return true.
Review comment:
typo in `Depcrated` -> `Deprecated`
##########
File path: libs/framework/gtest/src/DependencyManagerTestSuite.cc
##########
@@ -63,6 +65,87 @@ TEST_F(DependencyManagerTestSuite, DmCreateComponent) {
ASSERT_TRUE(celix_dependencyManager_allComponentsActive(mng));
}
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemove) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_add(mng, cmp);
+ ASSERT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_remove(mng, cmp);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ auto *cmp3 = celix_dmComponent_create(ctx, "test3");
+ celix_dependencyManager_add(mng, cmp2);
+ celix_dependencyManager_add(mng, cmp3);
+ ASSERT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_removeAllComponents(mng);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+}
+
+
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemoveAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_addAsync(mng, cmp1);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ auto cb = [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ };
+
+ celix_dependencyManager_removeAsync(mng, cmp1, &count, cb);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, DmComponentRemoveAllAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ celix_dependencyManager_add(mng, cmp1);
+ celix_dependencyManager_add(mng, cmp2);
+ EXPECT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ celix_dependencyManager_removeAllComponentsAsync(mng, &count, [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ });
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, CDmGetInfo) {
+ auto* mng = celix_bundleContext_getDependencyManager(ctx);
+ auto* cmp = celix_dmComponent_create(ctx, "test1");
+
+ auto* p = celix_properties_create();
+ celix_properties_set(p, "key", "value");
+ celix_dmComponent_addInterface(cmp, "test-interface", nullptr, (void*)0x42, p);
+
+ auto* dep = celix_dmServiceDependency_create();
+ celix_dmServiceDependency_setService(dep, "test-interface", nullptr, nullptr);
+ celix_dmComponent_addServiceDependency(cmp, dep);
+
+ celix_dependencyManager_add(mng, cmp);
+
+ auto* infos = celix_dependencyManager_createInfos(mng);
+ ASSERT_EQ(1, celix_arrayList_size(infos));
+ auto* dmInfo = (celix_dependency_manager_info_t*)celix_arrayList_get(infos, 0);
+ ASSERT_EQ(1, celix_arrayList_size(dmInfo->components));
+ auto *info = (celix_dm_component_info_t*)celix_arrayList_get(dmInfo->components, 0);
+ EXPECT_EQ(1, celix_arrayList_size(info->interfaces));
Review comment:
Add check if `celix_properties_size(info->interfaces[0]->properties) == 1`, but then with `celix_arrayList_get` instead of C++ arrays.
##########
File path: libs/framework/include/celix_bundle_context.h
##########
@@ -1143,8 +1178,29 @@ void celix_bundleContext_waitForEvents(celix_bundle_context_t* ctx);
*/
celix_bundle_t* celix_bundleContext_getBundle(const celix_bundle_context_t *ctx);
+
+/**
+ * Returns the bundle if for the bundle of this bundle context.
+ */
+long celix_bundleContext_getBundleId(const celix_bundle_context_t *ctx);
+
celix_framework_t* celix_bundleContext_getFramework(const celix_bundle_context_t* ctx);
+/**
+ * Logs a message to Celix framework logger with the provided log level.
+ * @param ctx The bundle context
+ * @param level The log level to use
+ * @param format printf style format string
+ * @param ... printf style format arguments
+ */
+void celix_bundleContext_log(const celix_bundle_context_t* ctx, celix_log_level_e level, const char* format, ...);
Review comment:
:+1:
Can be used in some older pubsub files where a celix loghelper is not available, without refactoring everything.
##########
File path: libs/framework/include/celix_bundle_context.h
##########
@@ -177,6 +177,10 @@ typedef struct celix_service_registration_options {
/**
* Async callback. Will be called after the a service is registered in the service registry using a async call.
* Will be called on the Celix event loop.
+ *
+ * If a asyns service registration is combined with a _sync_ service unregistration, it can happen that
Review comment:
shift+r entire file `asyns` -> `async`.
##########
File path: libs/utils/src/utils.c
##########
@@ -61,6 +61,10 @@ bool celix_utils_stringEquals(const char* a, const char* b) {
}
}
+bool celix_utils_isStringNullOrEmpty(const char* s) {
+ return s == NULL || strlen(s) == 0;
Review comment:
Probably better to replace this line with `return s == NULL || s[0] == '\0'`
##########
File path: libs/framework/include/celix/dm/DependencyManager_Impl.h
##########
@@ -88,3 +117,81 @@ inline std::size_t DependencyManager::getNrOfComponents() const {
return celix_dependencyManager_nrOfComponents(cDepMan.get());
}
+template<typename T>
+inline std::shared_ptr<Component<T>> DependencyManager::findComponent(const std::string& uuid) const {
+ std::lock_guard<std::mutex> lck{mutex};
+ std::shared_ptr<BaseComponent> found{nullptr};
+ for (const auto& cmp : components) {
+ if (cmp->getUUID() == uuid) {
+ found = cmp;
Review comment:
add `break;`
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -889,402 +689,158 @@ static celix_status_t component_calculateNewState(celix_dm_component_t *componen
return status;
}
-static celix_status_t component_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
- celix_status_t status = CELIX_SUCCESS;
- //printf("performing transition for %s in thread %i from %i to %i\n", component->name, (int) pthread_self(), oldState, newState);
-
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
if (oldState == newState) {
*transition = false;
- } else if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- component_startDependencies(component, component->dependencies);
+ return CELIX_SUCCESS;
+ }
+
+ celix_bundleContext_log(component->context,
+ CELIX_LOG_LEVEL_TRACE,
+ "performing transition for component '%s' (uuid=%s) from state %s to state %s",
+ component->name,
+ component->uuid,
+ celix_dmComponent_stateToString(oldState),
+ celix_dmComponent_stateToString(newState));
+
+ celix_status_t status = CELIX_SUCCESS;
+ if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
+ celix_dmComponent_enableDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_invokeAddRequiredDependencies(component);
- component_invokeAutoConfigDependencies(component);
if (component->callbackInit) {
status = component->callbackInit(component->implementation);
}
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_TRACKING_OPTIONAL) {
- component_invokeAddRequiredInstanceBoundDependencies(component);
- component_invokeAutoConfigInstanceBoundDependencies(component);
- component_invokeAddOptionalDependencies(component);
if (component->callbackStart) {
status = component->callbackStart(component->implementation);
}
- component_registerServices(component);
+ celix_dmComponent_registerServices(component, false);
+ component->nrOfTimesStarted += 1;
*transition = true;
} else if (oldState == DM_CMP_STATE_TRACKING_OPTIONAL && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_unregisterServices(component);
+ celix_dmComponent_unregisterServices(component, false);
if (component->callbackStop) {
status = component->callbackStop(component->implementation);
}
- component_invokeRemoveOptionalDependencies(component);
- component_invokeRemoveInstanceBoundDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- if (component->callbackDeinit) {
- status = component->callbackDeinit(component->implementation);
- }
- component_invokeRemoveRequiredDependencies(component);
+ if (component->callbackDeinit) {
+ status = component->callbackDeinit(component->implementation);
+ }
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INACTIVE) {
- component_stopDependencies(component);
+ celix_dmComponent_disableDependencies(component);
*transition = true;
}
return status;
}
-static celix_status_t component_allRequiredAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_allInstanceBoundAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddRequiredDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && !instanceBound) {
- component_configureImplementation(component, dependency);
+/**
+ * Check if all required dependencies are resolved. This function should be called with the component->mutex locked.
+ */
+static bool celix_dmComponent_areAllRequiredServiceDependenciesResolved(celix_dm_component_t *component) {
+ bool allResolved = true;
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = celix_arrayList_get(component->dependencies, i);
+ bool started = celix_dmServiceDependency_isTrackerOpen(dependency);
+ bool required = celix_dmServiceDependency_isRequired(dependency);
+ bool available = celix_dmServiceDependency_isAvailable(dependency);
+ if (!started) {
+ allResolved = false;
+ break;
}
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && instanceBound) {
- component_configureImplementation(component, dependency);
+ if (required && !available) {
+ allResolved = false;
+ break;
}
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return allResolved;
}
-static celix_status_t component_invokeAddRequiredInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (instanceBound && required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+/**
+ * Register component services (if not already registered).
+ * If needLock is false, this function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_registerServices(celix_dm_component_t *component, bool needLock) {
+ if (needLock) {
+ celixThreadMutex_lock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddOptionalDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
-
- serviceDependency_isRequired(dependency, &required);
-
- if (!required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+ for (int i = 0; i < celix_arrayList_size(component->providedInterfaces); i++) {
+ dm_interface_t *interface = arrayList_get(component->providedInterfaces, i);
+ if (interface->svcId == -1L) {
+ celix_properties_t *regProps = celix_properties_copy(interface->properties);
+ celix_service_registration_options_t opts = CELIX_EMPTY_SERVICE_REGISTRATION_OPTIONS;
+ opts.properties = regProps;
+ opts.svc = (void*)interface->service;
+ opts.serviceName = interface->serviceName;
+ opts.serviceLanguage = celix_properties_get(regProps, CELIX_FRAMEWORK_SERVICE_LANGUAGE, NULL);
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Async registering service %s for component %s (uuid=%s)",
+ interface->serviceName,
+ component->name,
+ component->uuid);
+ long svcId = celix_bundleContext_registerServiceWithOptionsAsync(component->context, &opts);
+ interface->svcId = svcId;
+ }
+ }
+ if (needLock) {
+ celixThreadMutex_unlock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_invokeRemoveOptionalDependencies(celix_dm_component_t *component) {
+/**
+ * Unregister component services. This function should be called with the component->mutex locked.
+ * If needLock is false, this function should be called with the component->mutex locked.
Review comment:
Add comment that this function unlocks mutex in case of found ids, even if `needLock` is false.
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -416,466 +432,250 @@ celix_status_t celix_dmComponent_removeInterface(celix_dm_component_t *component
celix_status_t status = CELIX_ILLEGAL_ARGUMENT;
celixThreadMutex_lock(&component->mutex);
- int nof_interfaces = arrayList_size(component->dm_interfaces);
- for (unsigned int i = 0; i < nof_interfaces; ++i) {
- dm_interface_t *interface = (dm_interface_t *) arrayList_get(component->dm_interfaces, i);
+ int nof_interfaces = celix_arrayList_size(component->providedInterfaces);
+ dm_interface_t* removedInterface = NULL;
+ for (int i = 0; i < nof_interfaces; ++i) {
+ dm_interface_t *interface = celix_arrayList_get(component->providedInterfaces, i);
if (interface->service == service) {
- arrayList_remove(component->dm_interfaces, i);
- if (component->state == DM_CMP_STATE_TRACKING_OPTIONAL) {
- celixThreadMutex_unlock(&component->mutex);
- component_unregisterServices(component);
- component_registerServices(component);
- celixThreadMutex_lock(&component->mutex);
- }
- status = CELIX_SUCCESS;
+ celix_arrayList_removeAt(component->providedInterfaces, i);
+ removedInterface = interface;
break;
}
}
celixThreadMutex_unlock(&component->mutex);
+ if (removedInterface != NULL) {
+ celix_bundleContext_unregisterService(component->context, removedInterface->svcId);
+ free(removedInterface->serviceName);
+ free(removedInterface);
+ }
+
return status;
}
-celix_status_t component_getInterfaces(celix_dm_component_t *component, array_list_pt *out) {
+celix_status_t component_getInterfaces(celix_dm_component_t *component, celix_array_list_t **out) {
return celix_dmComponent_getInterfaces(component, out);
}
-celix_status_t celix_dmComponent_getInterfaces(celix_dm_component_t *component, array_list_pt *out) {
- celix_status_t status = CELIX_SUCCESS;
- array_list_pt names = NULL;
- arrayList_create(&names);
+celix_status_t celix_dmComponent_getInterfaces(celix_dm_component_t *component, celix_array_list_t **out) {
+ celix_array_list_t* names = celix_arrayList_create();
+
celixThreadMutex_lock(&component->mutex);
- int size = arrayList_size(component->dm_interfaces);
- int i;
- for (i = 0; i < size; i += 1) {
- dm_interface_info_pt info = calloc(1, sizeof(*info));
- dm_interface_t *interface = arrayList_get(component->dm_interfaces, i);
- info->name = strdup(interface->serviceName);
- properties_copy(interface->properties, &info->properties);
- arrayList_add(names, info);
+ int size = celix_arrayList_size(component->providedInterfaces);
+ for (int i = 0; i < size; i += 1) {
+ dm_interface_info_t* info = calloc(1, sizeof(*info));
+ dm_interface_t *interface = celix_arrayList_get(component->providedInterfaces, i);
+ info->name = celix_utils_strdup(interface->serviceName);
+ info->properties = celix_properties_copy(interface->properties);
+ celix_arrayList_add(names, info);
}
celixThreadMutex_unlock(&component->mutex);
+ *out = names;
- if (status == CELIX_SUCCESS) {
- *out = names;
- }
-
- return status;
-}
-
-celix_status_t celix_private_dmComponent_handleEvent(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- dm_handle_event_type_pt data = calloc(1, sizeof(*data));
- data->dependency = dependency;
- data->event = event;
- data->newEvent = NULL;
-
- status = executor_executeTask(component->executor, component, component_handleEventTask, data);
-// component_handleEventTask(component, data);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleEventTask(celix_dm_component_t *component, dm_handle_event_type_pt data) {
- celix_status_t status = CELIX_SUCCESS;
-
- switch (data->event->event_type) {
- case DM_EVENT_ADDED:
- component_handleAdded(component,data->dependency, data->event);
- break;
- case DM_EVENT_CHANGED:
- component_handleChanged(component,data->dependency, data->event);
- break;
- case DM_EVENT_REMOVED:
- component_handleRemoved(component,data->dependency, data->event);
- break;
- case DM_EVENT_SWAPPED:
- component_handleSwapped(component,data->dependency, data->event, data->newEvent);
- break;
- default:
- break;
- }
-
- free(data);
-
- return status;
+celix_status_t celix_private_dmComponent_handleEvent(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ celix_status_t status = CELIX_SUCCESS;
+ switch (event->eventType) {
+ case CELIX_DM_EVENT_SVC_ADD:
+ celix_dmComponent_handleAdd(component, event);
+ break;
+ case CELIX_DM_EVENT_SVC_REM:
+ celix_dmComponent_handleRemove(component, event);
+ break;
+ case CELIX_DM_EVENT_SVC_SET:
+ celix_dmComponent_handleSet(component, event);
+ break;
+ default:
+ break;
+ }
+ return status;
}
-static celix_status_t component_suspend(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
+static celix_status_t celix_dmComponent_suspend(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
celix_status_t status = CELIX_SUCCESS;
-
- dm_service_dependency_strategy_t strategy;
- serviceDependency_getStrategy(dependency, &strategy);
+ dm_service_dependency_strategy_t strategy = celix_dmServiceDependency_getStrategy(dependency);
if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStop != NULL) {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Suspending component %s (uuid=%s)",
+ component->name,
+ component->uuid);
+ celix_dmComponent_unregisterServices(component, true);
status = component->callbackStop(component->implementation);
}
-
return status;
}
-static celix_status_t component_resume(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
+static celix_status_t celix_dmComponent_resume(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
celix_status_t status = CELIX_SUCCESS;
-
- dm_service_dependency_strategy_t strategy;
- serviceDependency_getStrategy(dependency, &strategy);
- if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStop != NULL) {
- status = component->callbackStart(component->implementation);
+ dm_service_dependency_strategy_t strategy = celix_dmServiceDependency_getStrategy(dependency);
+ if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStart != NULL) {
+ //ensure that the current state is still TRACKING_OPTION. Else during a add/rem/set call a required svc dep has been added.
+ celixThreadMutex_lock(&component->mutex);
+ celix_dm_component_state_t currentState = component->state;
+ celixThreadMutex_unlock(&component->mutex);
+ if (currentState == DM_CMP_STATE_TRACKING_OPTIONAL) {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Resuming component %s (uuid=%s)",
+ component->name,
+ component->uuid);
+ celix_dmComponent_registerServices(component, true);
+ status = component->callbackStart(component->implementation);
+ component->nrOfTimesResumed += 1;
+ } else {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Skipping resume because cmp state is now %s",
+ celix_dmComponent_stateToString(currentState));
+ }
}
-
return status;
}
-static celix_status_t component_handleAdded(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- arrayList_add(events, event);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_setAvailable(dependency, true);
-
+static celix_status_t celix_dmComponent_handleEvent(celix_dm_component_t *component, const celix_dm_event_t* event, celix_status_t (*setAddOrRemFp)(celix_dm_service_dependency_t *dependency, void* svc, const celix_properties_t* props), const char *invokeName) {
+ bool needSuspend = false;
+ celixThreadMutex_lock(&component->mutex);
switch (component->state) {
- case DM_CMP_STATE_WAITING_FOR_REQUIRED: {
- serviceDependency_invokeSet(dependency, event);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- component_handleChange(component);
- }
- break;
- }
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (!instanceBound) {
- if (required) {
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeAdd(dependency, event);
- }
- dm_event_pt event = NULL;
- component_getDependencyEvent(component, dependency, &event);
- component_updateInstance(component, dependency, event, false, true);
- }
-
- if (required) {
- component_handleChange(component);
- }
- break;
- }
case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeAdd(dependency, event);
- component_resume(component,dependency);
- dm_event_pt event = NULL;
- component_getDependencyEvent(component, dependency, &event);
- component_updateInstance(component, dependency, event, false, true);
+ needSuspend = true;
break;
- default:
+ default: //DM_CMP_STATE_INACTIVE
break;
}
-
- return status;
-}
-
-static celix_status_t component_handleChanged(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- arrayList_add(events, event);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_invokeSet(dependency, event);
- switch (component->state) {
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeChange(dependency, event);
- component_resume(component,dependency);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, true, false);
- break;
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- serviceDependency_invokeChange(dependency, event);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, true, false);
- }
- break;
- }
- default:
- break;
- }
-
- event_destroy(&old);
- }
-
- return status;
+ celixThreadMutex_unlock(&component->mutex);
+ if (needSuspend) {
+ celix_dmComponent_suspend(component, event->dep);
+ }
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Calling %s service for component %s (uuid=%s) on service dependency with type %s",
+ invokeName,
+ component->name,
+ component->uuid,
+ event->dep->serviceName);
+ setAddOrRemFp(event->dep, event->svc, event->props);
+ //note that after after a set/add/rem a new svc dependency can be added, removed, etc
+ if (needSuspend) {
+ celix_dmComponent_resume(component, event->dep);
+ }
+ celix_dmComponent_handleChange(component);
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleRemoved(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int size = arrayList_size(events);
- if (arrayList_contains(events, event)) {
- size--;
- }
- pthread_mutex_unlock(&component->mutex);
- serviceDependency_setAvailable(dependency, size > 0);
- component_handleChange(component);
-
- pthread_mutex_lock(&component->mutex);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- pthread_mutex_unlock(&component->mutex);
-
-
- switch (component->state) {
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- serviceDependency_invokeSet(dependency, event);
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- serviceDependency_invokeRemove(dependency, event);
- }
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, false, false);
- }
- break;
- }
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeRemove(dependency, event);
- component_resume(component,dependency);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, false, false);
- break;
- default:
- break;
- }
-
- event_destroy(&event);
- if (old) {
- event_destroy(&old);
- }
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleAdd(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeAdd, "add");
}
-static celix_status_t component_handleSwapped(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event, dm_event_pt newEvent) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- arrayList_add(events, newEvent);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_invokeSet(dependency, event);
-
- switch (component->state) {
- case DM_CMP_STATE_WAITING_FOR_REQUIRED:
- break;
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- serviceDependency_invokeSwap(dependency, event, newEvent);
- }
- }
- break;
- }
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSwap(dependency, event, newEvent);
- component_resume(component,dependency);
- break;
- default:
- break;
- }
-
- event_destroy(&event);
- if (old) {
- event_destroy(&old);
- }
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleRemove(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeRemove, "remove");
}
-static celix_status_t component_updateInstance(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event, bool update, bool add) {
- celix_status_t status = CELIX_SUCCESS;
-
- bool autoConfig = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
-
- if (autoConfig) {
- const void *service = NULL;
- const void **field = NULL;
-
- if (event != NULL) {
- event_getService(event, &service);
- }
- serviceDependency_getAutoConfig(dependency, &field);
- serviceDependency_lock(dependency);
- *field = service;
- serviceDependency_unlock(dependency);
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleSet(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeSet, "set");
}
-static celix_status_t component_startDependencies(celix_dm_component_t *component __attribute__((unused)), array_list_pt dependencies) {
- celix_status_t status = CELIX_SUCCESS;
- array_list_pt required_dependencies = NULL;
- arrayList_create(&required_dependencies);
-
- for (unsigned int i = 0; i < arrayList_size(dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(dependencies, i);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- arrayList_add(required_dependencies, dependency);
- continue;
- }
-
- serviceDependency_start(dependency);
- }
-
- for (unsigned int i = 0; i < arrayList_size(required_dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(required_dependencies, i);
- serviceDependency_start(dependency);
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_enableDependencies(celix_dm_component_t *component) {
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
+ celix_dmServiceDependency_enable(dependency);
}
-
- arrayList_destroy(required_dependencies);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_stopDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_disableDependencies(celix_dm_component_t *component) {
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- pthread_mutex_unlock(&component->mutex);
- serviceDependency_stop(dependency);
- pthread_mutex_lock(&component->mutex);
+ celix_dmServiceDependency_disable(dependency);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleChange(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
+/**
+ * Calculate and handle state change. This function should be called with the component->mutex locked.
Review comment:
Comment says that mutex should already be locked. But function also locks mutex. One of the two is incorrect.
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -889,402 +689,158 @@ static celix_status_t component_calculateNewState(celix_dm_component_t *componen
return status;
}
-static celix_status_t component_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
- celix_status_t status = CELIX_SUCCESS;
- //printf("performing transition for %s in thread %i from %i to %i\n", component->name, (int) pthread_self(), oldState, newState);
-
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
if (oldState == newState) {
*transition = false;
- } else if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- component_startDependencies(component, component->dependencies);
+ return CELIX_SUCCESS;
+ }
+
+ celix_bundleContext_log(component->context,
+ CELIX_LOG_LEVEL_TRACE,
+ "performing transition for component '%s' (uuid=%s) from state %s to state %s",
+ component->name,
+ component->uuid,
+ celix_dmComponent_stateToString(oldState),
+ celix_dmComponent_stateToString(newState));
+
+ celix_status_t status = CELIX_SUCCESS;
+ if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
+ celix_dmComponent_enableDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_invokeAddRequiredDependencies(component);
- component_invokeAutoConfigDependencies(component);
if (component->callbackInit) {
status = component->callbackInit(component->implementation);
}
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_TRACKING_OPTIONAL) {
- component_invokeAddRequiredInstanceBoundDependencies(component);
- component_invokeAutoConfigInstanceBoundDependencies(component);
- component_invokeAddOptionalDependencies(component);
if (component->callbackStart) {
status = component->callbackStart(component->implementation);
}
- component_registerServices(component);
+ celix_dmComponent_registerServices(component, false);
+ component->nrOfTimesStarted += 1;
*transition = true;
} else if (oldState == DM_CMP_STATE_TRACKING_OPTIONAL && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_unregisterServices(component);
+ celix_dmComponent_unregisterServices(component, false);
if (component->callbackStop) {
status = component->callbackStop(component->implementation);
}
- component_invokeRemoveOptionalDependencies(component);
- component_invokeRemoveInstanceBoundDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- if (component->callbackDeinit) {
- status = component->callbackDeinit(component->implementation);
- }
- component_invokeRemoveRequiredDependencies(component);
+ if (component->callbackDeinit) {
+ status = component->callbackDeinit(component->implementation);
+ }
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INACTIVE) {
- component_stopDependencies(component);
+ celix_dmComponent_disableDependencies(component);
*transition = true;
}
return status;
}
-static celix_status_t component_allRequiredAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_allInstanceBoundAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddRequiredDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && !instanceBound) {
- component_configureImplementation(component, dependency);
+/**
+ * Check if all required dependencies are resolved. This function should be called with the component->mutex locked.
+ */
+static bool celix_dmComponent_areAllRequiredServiceDependenciesResolved(celix_dm_component_t *component) {
+ bool allResolved = true;
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = celix_arrayList_get(component->dependencies, i);
+ bool started = celix_dmServiceDependency_isTrackerOpen(dependency);
+ bool required = celix_dmServiceDependency_isRequired(dependency);
+ bool available = celix_dmServiceDependency_isAvailable(dependency);
+ if (!started) {
+ allResolved = false;
+ break;
}
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && instanceBound) {
- component_configureImplementation(component, dependency);
+ if (required && !available) {
+ allResolved = false;
+ break;
}
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return allResolved;
}
-static celix_status_t component_invokeAddRequiredInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (instanceBound && required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+/**
+ * Register component services (if not already registered).
+ * If needLock is false, this function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_registerServices(celix_dm_component_t *component, bool needLock) {
+ if (needLock) {
+ celixThreadMutex_lock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddOptionalDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
-
- serviceDependency_isRequired(dependency, &required);
-
- if (!required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+ for (int i = 0; i < celix_arrayList_size(component->providedInterfaces); i++) {
+ dm_interface_t *interface = arrayList_get(component->providedInterfaces, i);
+ if (interface->svcId == -1L) {
+ celix_properties_t *regProps = celix_properties_copy(interface->properties);
+ celix_service_registration_options_t opts = CELIX_EMPTY_SERVICE_REGISTRATION_OPTIONS;
+ opts.properties = regProps;
+ opts.svc = (void*)interface->service;
+ opts.serviceName = interface->serviceName;
+ opts.serviceLanguage = celix_properties_get(regProps, CELIX_FRAMEWORK_SERVICE_LANGUAGE, NULL);
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Async registering service %s for component %s (uuid=%s)",
+ interface->serviceName,
+ component->name,
+ component->uuid);
+ long svcId = celix_bundleContext_registerServiceWithOptionsAsync(component->context, &opts);
+ interface->svcId = svcId;
+ }
+ }
+ if (needLock) {
+ celixThreadMutex_unlock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_invokeRemoveOptionalDependencies(celix_dm_component_t *component) {
+/**
+ * Unregister component services. This function should be called with the component->mutex locked.
Review comment:
Redundant sentence about locking mutex, `needLock` comment is clear enough.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568601685
##########
File path: libs/utils/include/version_range.h
##########
@@ -53,7 +54,7 @@ typedef struct versionRange *version_range_pt;
*/
celix_status_t
versionRange_createVersionRange(version_pt low, bool isLowInclusive, version_pt high, bool isHighInclusive,
- version_range_pt *versionRange);
+ version_range_pt *versionRange) ;
Review comment:
done
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] codecov-io commented on pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
codecov-io commented on pull request #313:
URL: https://github.com/apache/celix/pull/313#issuecomment-761871836
# [Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=h1) Report
> Merging [#313](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=desc) (962c874) into [master](https://codecov.io/gh/apache/celix/commit/afdb357a6c86773acf51840021ebbac1a2618ebd?el=desc) (afdb357) will **increase** coverage by `1.02%`.
> The diff coverage is `84.05%`.
[](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=tree)
```diff
@@ Coverage Diff @@
## master #313 +/- ##
==========================================
+ Coverage 68.69% 69.71% +1.02%
==========================================
Files 149 150 +1
Lines 30639 30166 -473
==========================================
- Hits 21046 21029 -17
+ Misses 9593 9137 -456
```
| [Impacted Files](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [bundles/shell/shell/src/dm\_shell\_list\_command.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-YnVuZGxlcy9zaGVsbC9zaGVsbC9zcmMvZG1fc2hlbGxfbGlzdF9jb21tYW5kLmM=) | `0.00% <0.00%> (ø)` | |
| [...ibs/framework/include/celix/dm/DependencyManager.h](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvaW5jbHVkZS9jZWxpeC9kbS9EZXBlbmRlbmN5TWFuYWdlci5o) | `100.00% <ø> (ø)` | |
| [libs/framework/src/requirement.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3JlcXVpcmVtZW50LmM=) | `0.00% <0.00%> (ø)` | |
| [libs/framework/src/service\_tracker.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3NlcnZpY2VfdHJhY2tlci5j) | `71.62% <0.00%> (-10.37%)` | :arrow_down: |
| [libs/framework/src/celix\_launcher.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2NlbGl4X2xhdW5jaGVyLmM=) | `27.73% <50.00%> (ø)` | |
| [libs/framework/src/bundle.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2J1bmRsZS5j) | `64.89% <53.84%> (-3.42%)` | :arrow_down: |
| [libs/framework/src/service\_registry.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3NlcnZpY2VfcmVnaXN0cnkuYw==) | `74.16% <66.66%> (+0.29%)` | :arrow_up: |
| [libs/framework/src/dm\_component\_impl.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2RtX2NvbXBvbmVudF9pbXBsLmM=) | `75.53% <83.51%> (+18.49%)` | :arrow_up: |
| [libs/framework/src/framework.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2ZyYW1ld29yay5j) | `75.73% <83.78%> (+1.06%)` | :arrow_up: |
| [libs/framework/src/dm\_service\_dependency.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2RtX3NlcnZpY2VfZGVwZW5kZW5jeS5j) | `69.69% <84.10%> (+17.67%)` | :arrow_up: |
| ... and [28 more](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree-more) | |
------
[Continue to review full report at Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=continue).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=footer). Last update [afdb357...962c874](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=lastupdated). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] Webserver28 commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
Webserver28 commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r561992328
##########
File path: libs/framework/gtest/src/DependencyManagerTestSuite.cc
##########
@@ -63,6 +65,87 @@ TEST_F(DependencyManagerTestSuite, DmCreateComponent) {
ASSERT_TRUE(celix_dependencyManager_allComponentsActive(mng));
}
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemove) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_add(mng, cmp);
+ ASSERT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_remove(mng, cmp);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ auto *cmp3 = celix_dmComponent_create(ctx, "test3");
+ celix_dependencyManager_add(mng, cmp2);
+ celix_dependencyManager_add(mng, cmp3);
+ ASSERT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_removeAllComponents(mng);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+}
+
+
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemoveAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_addAsync(mng, cmp1);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ auto cb = [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ };
+
+ celix_dependencyManager_removeAsync(mng, cmp1, &count, cb);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, DmComponentRemoveAllAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ celix_dependencyManager_add(mng, cmp1);
+ celix_dependencyManager_add(mng, cmp2);
+ EXPECT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ celix_dependencyManager_removeAllComponentsAsync(mng, &count, [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ });
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, CDmGetInfo) {
+ auto* mng = celix_bundleContext_getDependencyManager(ctx);
+ auto* cmp = celix_dmComponent_create(ctx, "test1");
+
+ auto* p = celix_properties_create();
+ celix_properties_set(p, "key", "value");
+ celix_dmComponent_addInterface(cmp, "test-interface", nullptr, (void*)0x42, p);
Review comment:
Magic number, maybe make variable or add comments
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes merged pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes merged pull request #313:
URL: https://github.com/apache/celix/pull/313
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] codecov-io edited a comment on pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
codecov-io edited a comment on pull request #313:
URL: https://github.com/apache/celix/pull/313#issuecomment-761871836
# [Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=h1) Report
> Merging [#313](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=desc) (9e2b47b) into [master](https://codecov.io/gh/apache/celix/commit/afdb357a6c86773acf51840021ebbac1a2618ebd?el=desc) (afdb357) will **increase** coverage by `0.90%`.
> The diff coverage is `78.82%`.
[](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=tree)
```diff
@@ Coverage Diff @@
## master #313 +/- ##
==========================================
+ Coverage 68.69% 69.59% +0.90%
==========================================
Files 149 152 +3
Lines 30639 30217 -422
==========================================
- Hits 21046 21030 -16
+ Misses 9593 9187 -406
```
| [Impacted Files](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [bundles/shell/shell/src/dm\_shell\_list\_command.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-YnVuZGxlcy9zaGVsbC9zaGVsbC9zcmMvZG1fc2hlbGxfbGlzdF9jb21tYW5kLmM=) | `0.00% <0.00%> (ø)` | |
| [...ibs/framework/include/celix/dm/DependencyManager.h](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvaW5jbHVkZS9jZWxpeC9kbS9EZXBlbmRlbmN5TWFuYWdlci5o) | `100.00% <ø> (ø)` | |
| [libs/framework/include/celix/dm/ProvidedService.h](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvaW5jbHVkZS9jZWxpeC9kbS9Qcm92aWRlZFNlcnZpY2UuaA==) | `100.00% <ø> (ø)` | |
| [libs/framework/src/bundle.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2J1bmRsZS5j) | `64.97% <0.00%> (-3.34%)` | :arrow_down: |
| [libs/framework/src/celix\_bundle\_state.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2NlbGl4X2J1bmRsZV9zdGF0ZS5j) | `0.00% <0.00%> (ø)` | |
| [libs/framework/src/requirement.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3JlcXVpcmVtZW50LmM=) | `0.00% <0.00%> (ø)` | |
| [libs/framework/src/service\_tracker.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3NlcnZpY2VfdHJhY2tlci5j) | `71.62% <0.00%> (-10.37%)` | :arrow_down: |
| [...framework/src/framework\_bundle\_lifecycle\_handler.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2ZyYW1ld29ya19idW5kbGVfbGlmZWN5Y2xlX2hhbmRsZXIuYw==) | `25.35% <25.35%> (ø)` | |
| [libs/framework/src/service\_registry.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3NlcnZpY2VfcmVnaXN0cnkuYw==) | `74.16% <66.66%> (+0.29%)` | :arrow_up: |
| [libs/framework/src/framework.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2ZyYW1ld29yay5j) | `75.60% <76.79%> (+0.94%)` | :arrow_up: |
| ... and [38 more](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree-more) | |
------
[Continue to review full report at Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=continue).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=footer). Last update [afdb357...9e2b47b](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=lastupdated). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568611096
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -416,466 +432,250 @@ celix_status_t celix_dmComponent_removeInterface(celix_dm_component_t *component
celix_status_t status = CELIX_ILLEGAL_ARGUMENT;
celixThreadMutex_lock(&component->mutex);
- int nof_interfaces = arrayList_size(component->dm_interfaces);
- for (unsigned int i = 0; i < nof_interfaces; ++i) {
- dm_interface_t *interface = (dm_interface_t *) arrayList_get(component->dm_interfaces, i);
+ int nof_interfaces = celix_arrayList_size(component->providedInterfaces);
+ dm_interface_t* removedInterface = NULL;
+ for (int i = 0; i < nof_interfaces; ++i) {
+ dm_interface_t *interface = celix_arrayList_get(component->providedInterfaces, i);
if (interface->service == service) {
- arrayList_remove(component->dm_interfaces, i);
- if (component->state == DM_CMP_STATE_TRACKING_OPTIONAL) {
- celixThreadMutex_unlock(&component->mutex);
- component_unregisterServices(component);
- component_registerServices(component);
- celixThreadMutex_lock(&component->mutex);
- }
- status = CELIX_SUCCESS;
+ celix_arrayList_removeAt(component->providedInterfaces, i);
+ removedInterface = interface;
break;
}
}
celixThreadMutex_unlock(&component->mutex);
+ if (removedInterface != NULL) {
+ celix_bundleContext_unregisterService(component->context, removedInterface->svcId);
+ free(removedInterface->serviceName);
+ free(removedInterface);
+ }
+
return status;
}
-celix_status_t component_getInterfaces(celix_dm_component_t *component, array_list_pt *out) {
+celix_status_t component_getInterfaces(celix_dm_component_t *component, celix_array_list_t **out) {
return celix_dmComponent_getInterfaces(component, out);
}
-celix_status_t celix_dmComponent_getInterfaces(celix_dm_component_t *component, array_list_pt *out) {
- celix_status_t status = CELIX_SUCCESS;
- array_list_pt names = NULL;
- arrayList_create(&names);
+celix_status_t celix_dmComponent_getInterfaces(celix_dm_component_t *component, celix_array_list_t **out) {
+ celix_array_list_t* names = celix_arrayList_create();
+
celixThreadMutex_lock(&component->mutex);
- int size = arrayList_size(component->dm_interfaces);
- int i;
- for (i = 0; i < size; i += 1) {
- dm_interface_info_pt info = calloc(1, sizeof(*info));
- dm_interface_t *interface = arrayList_get(component->dm_interfaces, i);
- info->name = strdup(interface->serviceName);
- properties_copy(interface->properties, &info->properties);
- arrayList_add(names, info);
+ int size = celix_arrayList_size(component->providedInterfaces);
+ for (int i = 0; i < size; i += 1) {
+ dm_interface_info_t* info = calloc(1, sizeof(*info));
+ dm_interface_t *interface = celix_arrayList_get(component->providedInterfaces, i);
+ info->name = celix_utils_strdup(interface->serviceName);
+ info->properties = celix_properties_copy(interface->properties);
+ celix_arrayList_add(names, info);
}
celixThreadMutex_unlock(&component->mutex);
+ *out = names;
- if (status == CELIX_SUCCESS) {
- *out = names;
- }
-
- return status;
-}
-
-celix_status_t celix_private_dmComponent_handleEvent(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- dm_handle_event_type_pt data = calloc(1, sizeof(*data));
- data->dependency = dependency;
- data->event = event;
- data->newEvent = NULL;
-
- status = executor_executeTask(component->executor, component, component_handleEventTask, data);
-// component_handleEventTask(component, data);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleEventTask(celix_dm_component_t *component, dm_handle_event_type_pt data) {
- celix_status_t status = CELIX_SUCCESS;
-
- switch (data->event->event_type) {
- case DM_EVENT_ADDED:
- component_handleAdded(component,data->dependency, data->event);
- break;
- case DM_EVENT_CHANGED:
- component_handleChanged(component,data->dependency, data->event);
- break;
- case DM_EVENT_REMOVED:
- component_handleRemoved(component,data->dependency, data->event);
- break;
- case DM_EVENT_SWAPPED:
- component_handleSwapped(component,data->dependency, data->event, data->newEvent);
- break;
- default:
- break;
- }
-
- free(data);
-
- return status;
+celix_status_t celix_private_dmComponent_handleEvent(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ celix_status_t status = CELIX_SUCCESS;
+ switch (event->eventType) {
+ case CELIX_DM_EVENT_SVC_ADD:
+ celix_dmComponent_handleAdd(component, event);
+ break;
+ case CELIX_DM_EVENT_SVC_REM:
+ celix_dmComponent_handleRemove(component, event);
+ break;
+ case CELIX_DM_EVENT_SVC_SET:
+ celix_dmComponent_handleSet(component, event);
+ break;
+ default:
+ break;
+ }
+ return status;
}
-static celix_status_t component_suspend(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
+static celix_status_t celix_dmComponent_suspend(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
celix_status_t status = CELIX_SUCCESS;
-
- dm_service_dependency_strategy_t strategy;
- serviceDependency_getStrategy(dependency, &strategy);
+ dm_service_dependency_strategy_t strategy = celix_dmServiceDependency_getStrategy(dependency);
if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStop != NULL) {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Suspending component %s (uuid=%s)",
+ component->name,
+ component->uuid);
+ celix_dmComponent_unregisterServices(component, true);
status = component->callbackStop(component->implementation);
}
-
return status;
}
-static celix_status_t component_resume(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
+static celix_status_t celix_dmComponent_resume(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
celix_status_t status = CELIX_SUCCESS;
-
- dm_service_dependency_strategy_t strategy;
- serviceDependency_getStrategy(dependency, &strategy);
- if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStop != NULL) {
- status = component->callbackStart(component->implementation);
+ dm_service_dependency_strategy_t strategy = celix_dmServiceDependency_getStrategy(dependency);
+ if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStart != NULL) {
+ //ensure that the current state is still TRACKING_OPTION. Else during a add/rem/set call a required svc dep has been added.
+ celixThreadMutex_lock(&component->mutex);
+ celix_dm_component_state_t currentState = component->state;
+ celixThreadMutex_unlock(&component->mutex);
+ if (currentState == DM_CMP_STATE_TRACKING_OPTIONAL) {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Resuming component %s (uuid=%s)",
+ component->name,
+ component->uuid);
+ celix_dmComponent_registerServices(component, true);
+ status = component->callbackStart(component->implementation);
+ component->nrOfTimesResumed += 1;
+ } else {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Skipping resume because cmp state is now %s",
+ celix_dmComponent_stateToString(currentState));
+ }
}
-
return status;
}
-static celix_status_t component_handleAdded(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- arrayList_add(events, event);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_setAvailable(dependency, true);
-
+static celix_status_t celix_dmComponent_handleEvent(celix_dm_component_t *component, const celix_dm_event_t* event, celix_status_t (*setAddOrRemFp)(celix_dm_service_dependency_t *dependency, void* svc, const celix_properties_t* props), const char *invokeName) {
+ bool needSuspend = false;
+ celixThreadMutex_lock(&component->mutex);
switch (component->state) {
- case DM_CMP_STATE_WAITING_FOR_REQUIRED: {
- serviceDependency_invokeSet(dependency, event);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- component_handleChange(component);
- }
- break;
- }
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (!instanceBound) {
- if (required) {
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeAdd(dependency, event);
- }
- dm_event_pt event = NULL;
- component_getDependencyEvent(component, dependency, &event);
- component_updateInstance(component, dependency, event, false, true);
- }
-
- if (required) {
- component_handleChange(component);
- }
- break;
- }
case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeAdd(dependency, event);
- component_resume(component,dependency);
- dm_event_pt event = NULL;
- component_getDependencyEvent(component, dependency, &event);
- component_updateInstance(component, dependency, event, false, true);
+ needSuspend = true;
break;
- default:
+ default: //DM_CMP_STATE_INACTIVE
break;
}
-
- return status;
-}
-
-static celix_status_t component_handleChanged(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- arrayList_add(events, event);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_invokeSet(dependency, event);
- switch (component->state) {
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeChange(dependency, event);
- component_resume(component,dependency);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, true, false);
- break;
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- serviceDependency_invokeChange(dependency, event);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, true, false);
- }
- break;
- }
- default:
- break;
- }
-
- event_destroy(&old);
- }
-
- return status;
+ celixThreadMutex_unlock(&component->mutex);
+ if (needSuspend) {
+ celix_dmComponent_suspend(component, event->dep);
+ }
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Calling %s service for component %s (uuid=%s) on service dependency with type %s",
+ invokeName,
+ component->name,
+ component->uuid,
+ event->dep->serviceName);
+ setAddOrRemFp(event->dep, event->svc, event->props);
+ //note that after after a set/add/rem a new svc dependency can be added, removed, etc
+ if (needSuspend) {
+ celix_dmComponent_resume(component, event->dep);
+ }
+ celix_dmComponent_handleChange(component);
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleRemoved(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int size = arrayList_size(events);
- if (arrayList_contains(events, event)) {
- size--;
- }
- pthread_mutex_unlock(&component->mutex);
- serviceDependency_setAvailable(dependency, size > 0);
- component_handleChange(component);
-
- pthread_mutex_lock(&component->mutex);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- pthread_mutex_unlock(&component->mutex);
-
-
- switch (component->state) {
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- serviceDependency_invokeSet(dependency, event);
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- serviceDependency_invokeRemove(dependency, event);
- }
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, false, false);
- }
- break;
- }
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeRemove(dependency, event);
- component_resume(component,dependency);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, false, false);
- break;
- default:
- break;
- }
-
- event_destroy(&event);
- if (old) {
- event_destroy(&old);
- }
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleAdd(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeAdd, "add");
}
-static celix_status_t component_handleSwapped(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event, dm_event_pt newEvent) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- arrayList_add(events, newEvent);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_invokeSet(dependency, event);
-
- switch (component->state) {
- case DM_CMP_STATE_WAITING_FOR_REQUIRED:
- break;
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- serviceDependency_invokeSwap(dependency, event, newEvent);
- }
- }
- break;
- }
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSwap(dependency, event, newEvent);
- component_resume(component,dependency);
- break;
- default:
- break;
- }
-
- event_destroy(&event);
- if (old) {
- event_destroy(&old);
- }
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleRemove(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeRemove, "remove");
}
-static celix_status_t component_updateInstance(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event, bool update, bool add) {
- celix_status_t status = CELIX_SUCCESS;
-
- bool autoConfig = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
-
- if (autoConfig) {
- const void *service = NULL;
- const void **field = NULL;
-
- if (event != NULL) {
- event_getService(event, &service);
- }
- serviceDependency_getAutoConfig(dependency, &field);
- serviceDependency_lock(dependency);
- *field = service;
- serviceDependency_unlock(dependency);
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleSet(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeSet, "set");
}
-static celix_status_t component_startDependencies(celix_dm_component_t *component __attribute__((unused)), array_list_pt dependencies) {
- celix_status_t status = CELIX_SUCCESS;
- array_list_pt required_dependencies = NULL;
- arrayList_create(&required_dependencies);
-
- for (unsigned int i = 0; i < arrayList_size(dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(dependencies, i);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- arrayList_add(required_dependencies, dependency);
- continue;
- }
-
- serviceDependency_start(dependency);
- }
-
- for (unsigned int i = 0; i < arrayList_size(required_dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(required_dependencies, i);
- serviceDependency_start(dependency);
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_enableDependencies(celix_dm_component_t *component) {
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
+ celix_dmServiceDependency_enable(dependency);
}
-
- arrayList_destroy(required_dependencies);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_stopDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_disableDependencies(celix_dm_component_t *component) {
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- pthread_mutex_unlock(&component->mutex);
- serviceDependency_stop(dependency);
- pthread_mutex_lock(&component->mutex);
+ celix_dmServiceDependency_disable(dependency);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleChange(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
+/**
+ * Calculate and handle state change. This function should be called with the component->mutex locked.
Review comment:
comment is incorrect, removed.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] Oipo commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
Oipo commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r572007077
##########
File path: libs/utils/src/version_range.c
##########
@@ -182,61 +108,139 @@ celix_status_t versionRange_isHighInclusive(version_range_pt versionRange, bool
celix_status_t versionRange_parse(const char * rangeStr, version_range_pt *range) {
- celix_status_t status;
- if (strchr(rangeStr, ',') != NULL) {
- int vlowL = strcspn(rangeStr+1, ",");
- char * vlow = (char *) malloc(sizeof(char) * (vlowL + 1));
- if (!vlow) {
- status = CELIX_ENOMEM;
- } else {
- int vhighL;
- char * vhigh;
- vlow = strncpy(vlow, rangeStr+1, vlowL);
- vlow[vlowL] = '\0';
- vhighL = strlen(rangeStr+1) - vlowL - 2;
- vhigh = (char *) malloc(sizeof(char) * (vhighL+1));
- if (!vhigh) {
- status = CELIX_ENOMEM;
- } else {
- version_pt versionLow = NULL;
- int rangeL = strlen(rangeStr);
- char start = rangeStr[0];
- char end = rangeStr[rangeL-1];
-
- vhigh = strncpy(vhigh, rangeStr+vlowL+2, vhighL);
- vhigh[vhighL] = '\0';
- status = version_createVersionFromString(vlow, &versionLow);
- if (status == CELIX_SUCCESS) {
- version_pt versionHigh = NULL;
- status = version_createVersionFromString(vhigh, &versionHigh);
- if (status == CELIX_SUCCESS) {
- status = versionRange_createVersionRange(
- versionLow,
- start == '[',
- versionHigh,
- end ==']',
- range
- );
- }
- }
- free(vhigh);
- }
- free(vlow);
+ *range = celix_versionRange_parse(rangeStr);
+ if (*range == NULL) {
+ return CELIX_ILLEGAL_ARGUMENT;
+ } else {
+ return CELIX_SUCCESS;
+ }
+}
+char* versionRange_createLDAPFilter(version_range_pt range, const char *serviceVersionAttributeName) {
+ return celix_versionRange_createLDAPFilter(range, serviceVersionAttributeName);
+}
+
+
+
+bool versionRange_createLDAPFilterInPlace(version_range_pt range, const char *serviceVersionAttributeName, char* buffer, size_t bufferLength) {
+ return celix_versionRange_createLDAPFilterInPlace(range, serviceVersionAttributeName, buffer, bufferLength);
+}
+
+celix_version_range_t* celix_versionRange_createVersionRange(celix_version_t* low, bool isLowInclusive, celix_version_t* high, bool isHighInclusive) {
+ assert(low != high);
+ celix_version_range_t* range = malloc(sizeof(*range));
+ range->low = low;
+ range->isLowInclusive = isLowInclusive;
+ range->high = high;
+ range->isHighInclusive = isHighInclusive;
+ return range;
+}
+
+
+celix_version_range_t* celix_versionRange_createInfiniteVersionRange() {
+ return celix_versionRange_createVersionRange(celix_version_createEmptyVersion(), true, NULL, true);
+}
+
+void celix_versionRange_destroy(celix_version_range_t* range) {
+ if (range->high != NULL) {
+ celix_version_destroy(range->high);
+ }
+ if (range->low != NULL) {
+ celix_version_destroy(range->low);
+ }
+ free(range);
+}
+
+
+bool celix_versionRange_isInRange(const celix_version_range_t* versionRange, const celix_version_t* version) {
+ bool inRange = false;
+ int high;
+ int low;
Review comment:
Compiler warnings on these two uninitialized variables:
```
/home/oipo-unencrypted/Programming/celix-apache/libs/utils/src/version_range.c:167:17: error: ‘low’ may be used uninitialized in this function [-Werror=maybe-uninitialized]
167 | inRange = (low >= 0);
| ~~~~~~~~^~~~~~~~~~~~
/home/oipo-unencrypted/Programming/celix-apache/libs/utils/src/version_range.c:157:9: error: ‘high’ may be used uninitialized in this function [-Werror=maybe-uninitialized]
157 | int high;
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r572783249
##########
File path: libs/utils/src/version_range.c
##########
@@ -182,61 +108,139 @@ celix_status_t versionRange_isHighInclusive(version_range_pt versionRange, bool
celix_status_t versionRange_parse(const char * rangeStr, version_range_pt *range) {
- celix_status_t status;
- if (strchr(rangeStr, ',') != NULL) {
- int vlowL = strcspn(rangeStr+1, ",");
- char * vlow = (char *) malloc(sizeof(char) * (vlowL + 1));
- if (!vlow) {
- status = CELIX_ENOMEM;
- } else {
- int vhighL;
- char * vhigh;
- vlow = strncpy(vlow, rangeStr+1, vlowL);
- vlow[vlowL] = '\0';
- vhighL = strlen(rangeStr+1) - vlowL - 2;
- vhigh = (char *) malloc(sizeof(char) * (vhighL+1));
- if (!vhigh) {
- status = CELIX_ENOMEM;
- } else {
- version_pt versionLow = NULL;
- int rangeL = strlen(rangeStr);
- char start = rangeStr[0];
- char end = rangeStr[rangeL-1];
-
- vhigh = strncpy(vhigh, rangeStr+vlowL+2, vhighL);
- vhigh[vhighL] = '\0';
- status = version_createVersionFromString(vlow, &versionLow);
- if (status == CELIX_SUCCESS) {
- version_pt versionHigh = NULL;
- status = version_createVersionFromString(vhigh, &versionHigh);
- if (status == CELIX_SUCCESS) {
- status = versionRange_createVersionRange(
- versionLow,
- start == '[',
- versionHigh,
- end ==']',
- range
- );
- }
- }
- free(vhigh);
- }
- free(vlow);
+ *range = celix_versionRange_parse(rangeStr);
+ if (*range == NULL) {
+ return CELIX_ILLEGAL_ARGUMENT;
+ } else {
+ return CELIX_SUCCESS;
+ }
+}
+char* versionRange_createLDAPFilter(version_range_pt range, const char *serviceVersionAttributeName) {
+ return celix_versionRange_createLDAPFilter(range, serviceVersionAttributeName);
+}
+
+
+
+bool versionRange_createLDAPFilterInPlace(version_range_pt range, const char *serviceVersionAttributeName, char* buffer, size_t bufferLength) {
+ return celix_versionRange_createLDAPFilterInPlace(range, serviceVersionAttributeName, buffer, bufferLength);
+}
+
+celix_version_range_t* celix_versionRange_createVersionRange(celix_version_t* low, bool isLowInclusive, celix_version_t* high, bool isHighInclusive) {
+ assert(low != high);
+ celix_version_range_t* range = malloc(sizeof(*range));
+ range->low = low;
+ range->isLowInclusive = isLowInclusive;
+ range->high = high;
+ range->isHighInclusive = isHighInclusive;
+ return range;
+}
+
+
+celix_version_range_t* celix_versionRange_createInfiniteVersionRange() {
+ return celix_versionRange_createVersionRange(celix_version_createEmptyVersion(), true, NULL, true);
+}
+
+void celix_versionRange_destroy(celix_version_range_t* range) {
+ if (range->high != NULL) {
+ celix_version_destroy(range->high);
+ }
+ if (range->low != NULL) {
+ celix_version_destroy(range->low);
+ }
+ free(range);
+}
+
+
+bool celix_versionRange_isInRange(const celix_version_range_t* versionRange, const celix_version_t* version) {
+ bool inRange = false;
+ int high;
+ int low;
Review comment:
done
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] codecov-io edited a comment on pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
codecov-io edited a comment on pull request #313:
URL: https://github.com/apache/celix/pull/313#issuecomment-761871836
# [Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=h1) Report
> Merging [#313](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=desc) (e55d9c4) into [master](https://codecov.io/gh/apache/celix/commit/8c5871439db9bf7308a762dce71be9806a8663e8?el=desc) (8c58714) will **increase** coverage by `0.93%`.
> The diff coverage is `79.55%`.
[](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=tree)
```diff
@@ Coverage Diff @@
## master #313 +/- ##
==========================================
+ Coverage 69.17% 70.10% +0.93%
==========================================
Files 151 154 +3
Lines 30697 30401 -296
==========================================
+ Hits 21235 21314 +79
+ Misses 9462 9087 -375
```
| [Impacted Files](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [bundles/shell/shell/src/dm\_shell\_list\_command.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-YnVuZGxlcy9zaGVsbC9zaGVsbC9zcmMvZG1fc2hlbGxfbGlzdF9jb21tYW5kLmM=) | `0.00% <0.00%> (ø)` | |
| [...ibs/framework/include/celix/dm/DependencyManager.h](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvaW5jbHVkZS9jZWxpeC9kbS9EZXBlbmRlbmN5TWFuYWdlci5o) | `100.00% <ø> (ø)` | |
| [libs/framework/include/celix/dm/ProvidedService.h](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvaW5jbHVkZS9jZWxpeC9kbS9Qcm92aWRlZFNlcnZpY2UuaA==) | `100.00% <ø> (ø)` | |
| [libs/framework/src/bundle.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2J1bmRsZS5j) | `66.94% <0.00%> (-3.19%)` | :arrow_down: |
| [libs/framework/src/celix\_bundle\_state.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2NlbGl4X2J1bmRsZV9zdGF0ZS5j) | `0.00% <0.00%> (ø)` | |
| [libs/framework/src/requirement.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3JlcXVpcmVtZW50LmM=) | `0.00% <0.00%> (ø)` | |
| [...framework/src/framework\_bundle\_lifecycle\_handler.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL2ZyYW1ld29ya19idW5kbGVfbGlmZWN5Y2xlX2hhbmRsZXIuYw==) | `25.35% <25.35%> (ø)` | |
| [libs/framework/include/celix/dm/Component.h](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvaW5jbHVkZS9jZWxpeC9kbS9Db21wb25lbnQuaA==) | `72.72% <64.70%> (-27.28%)` | :arrow_down: |
| [libs/framework/src/service\_registry.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3NlcnZpY2VfcmVnaXN0cnkuYw==) | `75.19% <66.66%> (+0.16%)` | :arrow_up: |
| [libs/framework/src/service\_tracker.c](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree#diff-bGlicy9mcmFtZXdvcmsvc3JjL3NlcnZpY2VfdHJhY2tlci5j) | `71.46% <70.00%> (-10.75%)` | :arrow_down: |
| ... and [40 more](https://codecov.io/gh/apache/celix/pull/313/diff?src=pr&el=tree-more) | |
------
[Continue to review full report at Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=continue).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=footer). Last update [8c58714...e55d9c4](https://codecov.io/gh/apache/celix/pull/313?src=pr&el=lastupdated). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568602078
##########
File path: libs/utils/src/utils.c
##########
@@ -61,6 +61,10 @@ bool celix_utils_stringEquals(const char* a, const char* b) {
}
}
+bool celix_utils_isStringNullOrEmpty(const char* s) {
+ return s == NULL || strlen(s) == 0;
Review comment:
done
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568608432
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -889,402 +689,158 @@ static celix_status_t component_calculateNewState(celix_dm_component_t *componen
return status;
}
-static celix_status_t component_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
- celix_status_t status = CELIX_SUCCESS;
- //printf("performing transition for %s in thread %i from %i to %i\n", component->name, (int) pthread_self(), oldState, newState);
-
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
if (oldState == newState) {
*transition = false;
- } else if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- component_startDependencies(component, component->dependencies);
+ return CELIX_SUCCESS;
+ }
+
+ celix_bundleContext_log(component->context,
+ CELIX_LOG_LEVEL_TRACE,
+ "performing transition for component '%s' (uuid=%s) from state %s to state %s",
+ component->name,
+ component->uuid,
+ celix_dmComponent_stateToString(oldState),
+ celix_dmComponent_stateToString(newState));
+
+ celix_status_t status = CELIX_SUCCESS;
+ if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
+ celix_dmComponent_enableDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_invokeAddRequiredDependencies(component);
- component_invokeAutoConfigDependencies(component);
if (component->callbackInit) {
status = component->callbackInit(component->implementation);
}
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_TRACKING_OPTIONAL) {
- component_invokeAddRequiredInstanceBoundDependencies(component);
- component_invokeAutoConfigInstanceBoundDependencies(component);
- component_invokeAddOptionalDependencies(component);
if (component->callbackStart) {
status = component->callbackStart(component->implementation);
}
- component_registerServices(component);
+ celix_dmComponent_registerServices(component, false);
+ component->nrOfTimesStarted += 1;
*transition = true;
} else if (oldState == DM_CMP_STATE_TRACKING_OPTIONAL && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_unregisterServices(component);
+ celix_dmComponent_unregisterServices(component, false);
if (component->callbackStop) {
status = component->callbackStop(component->implementation);
}
- component_invokeRemoveOptionalDependencies(component);
- component_invokeRemoveInstanceBoundDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- if (component->callbackDeinit) {
- status = component->callbackDeinit(component->implementation);
- }
- component_invokeRemoveRequiredDependencies(component);
+ if (component->callbackDeinit) {
+ status = component->callbackDeinit(component->implementation);
+ }
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INACTIVE) {
- component_stopDependencies(component);
+ celix_dmComponent_disableDependencies(component);
*transition = true;
}
return status;
}
-static celix_status_t component_allRequiredAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_allInstanceBoundAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddRequiredDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && !instanceBound) {
- component_configureImplementation(component, dependency);
+/**
+ * Check if all required dependencies are resolved. This function should be called with the component->mutex locked.
+ */
+static bool celix_dmComponent_areAllRequiredServiceDependenciesResolved(celix_dm_component_t *component) {
+ bool allResolved = true;
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = celix_arrayList_get(component->dependencies, i);
+ bool started = celix_dmServiceDependency_isTrackerOpen(dependency);
+ bool required = celix_dmServiceDependency_isRequired(dependency);
+ bool available = celix_dmServiceDependency_isAvailable(dependency);
+ if (!started) {
+ allResolved = false;
+ break;
}
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && instanceBound) {
- component_configureImplementation(component, dependency);
+ if (required && !available) {
+ allResolved = false;
+ break;
}
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return allResolved;
}
-static celix_status_t component_invokeAddRequiredInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (instanceBound && required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+/**
+ * Register component services (if not already registered).
+ * If needLock is false, this function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_registerServices(celix_dm_component_t *component, bool needLock) {
+ if (needLock) {
+ celixThreadMutex_lock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddOptionalDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
-
- serviceDependency_isRequired(dependency, &required);
-
- if (!required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+ for (int i = 0; i < celix_arrayList_size(component->providedInterfaces); i++) {
+ dm_interface_t *interface = arrayList_get(component->providedInterfaces, i);
+ if (interface->svcId == -1L) {
+ celix_properties_t *regProps = celix_properties_copy(interface->properties);
+ celix_service_registration_options_t opts = CELIX_EMPTY_SERVICE_REGISTRATION_OPTIONS;
+ opts.properties = regProps;
+ opts.svc = (void*)interface->service;
+ opts.serviceName = interface->serviceName;
+ opts.serviceLanguage = celix_properties_get(regProps, CELIX_FRAMEWORK_SERVICE_LANGUAGE, NULL);
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Async registering service %s for component %s (uuid=%s)",
+ interface->serviceName,
+ component->name,
+ component->uuid);
+ long svcId = celix_bundleContext_registerServiceWithOptionsAsync(component->context, &opts);
+ interface->svcId = svcId;
+ }
+ }
+ if (needLock) {
+ celixThreadMutex_unlock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_invokeRemoveOptionalDependencies(celix_dm_component_t *component) {
+/**
+ * Unregister component services. This function should be called with the component->mutex locked.
Review comment:
removed
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568610023
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -889,402 +689,158 @@ static celix_status_t component_calculateNewState(celix_dm_component_t *componen
return status;
}
-static celix_status_t component_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
- celix_status_t status = CELIX_SUCCESS;
- //printf("performing transition for %s in thread %i from %i to %i\n", component->name, (int) pthread_self(), oldState, newState);
-
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
if (oldState == newState) {
*transition = false;
- } else if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- component_startDependencies(component, component->dependencies);
+ return CELIX_SUCCESS;
+ }
+
+ celix_bundleContext_log(component->context,
+ CELIX_LOG_LEVEL_TRACE,
+ "performing transition for component '%s' (uuid=%s) from state %s to state %s",
+ component->name,
+ component->uuid,
+ celix_dmComponent_stateToString(oldState),
+ celix_dmComponent_stateToString(newState));
+
+ celix_status_t status = CELIX_SUCCESS;
+ if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
+ celix_dmComponent_enableDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_invokeAddRequiredDependencies(component);
- component_invokeAutoConfigDependencies(component);
if (component->callbackInit) {
status = component->callbackInit(component->implementation);
}
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_TRACKING_OPTIONAL) {
- component_invokeAddRequiredInstanceBoundDependencies(component);
- component_invokeAutoConfigInstanceBoundDependencies(component);
- component_invokeAddOptionalDependencies(component);
if (component->callbackStart) {
status = component->callbackStart(component->implementation);
}
- component_registerServices(component);
+ celix_dmComponent_registerServices(component, false);
+ component->nrOfTimesStarted += 1;
*transition = true;
} else if (oldState == DM_CMP_STATE_TRACKING_OPTIONAL && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_unregisterServices(component);
+ celix_dmComponent_unregisterServices(component, false);
if (component->callbackStop) {
status = component->callbackStop(component->implementation);
}
- component_invokeRemoveOptionalDependencies(component);
- component_invokeRemoveInstanceBoundDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- if (component->callbackDeinit) {
- status = component->callbackDeinit(component->implementation);
- }
- component_invokeRemoveRequiredDependencies(component);
+ if (component->callbackDeinit) {
+ status = component->callbackDeinit(component->implementation);
+ }
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INACTIVE) {
- component_stopDependencies(component);
+ celix_dmComponent_disableDependencies(component);
*transition = true;
}
return status;
}
-static celix_status_t component_allRequiredAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_allInstanceBoundAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddRequiredDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && !instanceBound) {
- component_configureImplementation(component, dependency);
+/**
+ * Check if all required dependencies are resolved. This function should be called with the component->mutex locked.
+ */
+static bool celix_dmComponent_areAllRequiredServiceDependenciesResolved(celix_dm_component_t *component) {
+ bool allResolved = true;
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = celix_arrayList_get(component->dependencies, i);
+ bool started = celix_dmServiceDependency_isTrackerOpen(dependency);
+ bool required = celix_dmServiceDependency_isRequired(dependency);
+ bool available = celix_dmServiceDependency_isAvailable(dependency);
+ if (!started) {
+ allResolved = false;
+ break;
}
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && instanceBound) {
- component_configureImplementation(component, dependency);
+ if (required && !available) {
+ allResolved = false;
+ break;
}
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return allResolved;
}
-static celix_status_t component_invokeAddRequiredInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (instanceBound && required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+/**
+ * Register component services (if not already registered).
+ * If needLock is false, this function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_registerServices(celix_dm_component_t *component, bool needLock) {
+ if (needLock) {
+ celixThreadMutex_lock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddOptionalDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
-
- serviceDependency_isRequired(dependency, &required);
-
- if (!required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+ for (int i = 0; i < celix_arrayList_size(component->providedInterfaces); i++) {
+ dm_interface_t *interface = arrayList_get(component->providedInterfaces, i);
+ if (interface->svcId == -1L) {
+ celix_properties_t *regProps = celix_properties_copy(interface->properties);
+ celix_service_registration_options_t opts = CELIX_EMPTY_SERVICE_REGISTRATION_OPTIONS;
+ opts.properties = regProps;
+ opts.svc = (void*)interface->service;
+ opts.serviceName = interface->serviceName;
+ opts.serviceLanguage = celix_properties_get(regProps, CELIX_FRAMEWORK_SERVICE_LANGUAGE, NULL);
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Async registering service %s for component %s (uuid=%s)",
+ interface->serviceName,
+ component->name,
+ component->uuid);
+ long svcId = celix_bundleContext_registerServiceWithOptionsAsync(component->context, &opts);
+ interface->svcId = svcId;
+ }
+ }
+ if (needLock) {
+ celixThreadMutex_unlock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_invokeRemoveOptionalDependencies(celix_dm_component_t *component) {
+/**
+ * Unregister component services. This function should be called with the component->mutex locked.
+ * If needLock is false, this function should be called with the component->mutex locked.
Review comment:
function is not present anymore
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568600557
##########
File path: libs/framework/gtest/src/DependencyManagerTestSuite.cc
##########
@@ -63,6 +65,87 @@ TEST_F(DependencyManagerTestSuite, DmCreateComponent) {
ASSERT_TRUE(celix_dependencyManager_allComponentsActive(mng));
}
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemove) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_add(mng, cmp);
+ ASSERT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_remove(mng, cmp);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ auto *cmp3 = celix_dmComponent_create(ctx, "test3");
+ celix_dependencyManager_add(mng, cmp2);
+ celix_dependencyManager_add(mng, cmp3);
+ ASSERT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_removeAllComponents(mng);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+}
+
+
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemoveAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_addAsync(mng, cmp1);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ auto cb = [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ };
+
+ celix_dependencyManager_removeAsync(mng, cmp1, &count, cb);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, DmComponentRemoveAllAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ celix_dependencyManager_add(mng, cmp1);
+ celix_dependencyManager_add(mng, cmp2);
+ EXPECT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ celix_dependencyManager_removeAllComponentsAsync(mng, &count, [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ });
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, CDmGetInfo) {
+ auto* mng = celix_bundleContext_getDependencyManager(ctx);
+ auto* cmp = celix_dmComponent_create(ctx, "test1");
+
+ auto* p = celix_properties_create();
+ celix_properties_set(p, "key", "value");
+ celix_dmComponent_addInterface(cmp, "test-interface", nullptr, (void*)0x42, p);
Review comment:
done
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [celix] pnoltes commented on a change in pull request #313: Feature/refactor c dep man service trackers
Posted by GitBox <gi...@apache.org>.
pnoltes commented on a change in pull request #313:
URL: https://github.com/apache/celix/pull/313#discussion_r568600557
##########
File path: libs/framework/gtest/src/DependencyManagerTestSuite.cc
##########
@@ -63,6 +65,87 @@ TEST_F(DependencyManagerTestSuite, DmCreateComponent) {
ASSERT_TRUE(celix_dependencyManager_allComponentsActive(mng));
}
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemove) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_add(mng, cmp);
+ ASSERT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_remove(mng, cmp);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ auto *cmp3 = celix_dmComponent_create(ctx, "test3");
+ celix_dependencyManager_add(mng, cmp2);
+ celix_dependencyManager_add(mng, cmp3);
+ ASSERT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_removeAllComponents(mng);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+}
+
+
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemoveAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_addAsync(mng, cmp1);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ auto cb = [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ };
+
+ celix_dependencyManager_removeAsync(mng, cmp1, &count, cb);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, DmComponentRemoveAllAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ celix_dependencyManager_add(mng, cmp1);
+ celix_dependencyManager_add(mng, cmp2);
+ EXPECT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ celix_dependencyManager_removeAllComponentsAsync(mng, &count, [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ });
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, CDmGetInfo) {
+ auto* mng = celix_bundleContext_getDependencyManager(ctx);
+ auto* cmp = celix_dmComponent_create(ctx, "test1");
+
+ auto* p = celix_properties_create();
+ celix_properties_set(p, "key", "value");
+ celix_dmComponent_addInterface(cmp, "test-interface", nullptr, (void*)0x42, p);
Review comment:
done
##########
File path: libs/framework/include/requirement.h
##########
@@ -31,6 +24,7 @@ typedef struct requirement *requirement_pt;
#include "capability.h"
#include "hash_map.h"
+#include "celix_version_range.h"
#include "version_range.h"
Review comment:
yes
##########
File path: libs/utils/include/version_range.h
##########
@@ -53,7 +54,7 @@ typedef struct versionRange *version_range_pt;
*/
celix_status_t
versionRange_createVersionRange(version_pt low, bool isLowInclusive, version_pt high, bool isHighInclusive,
- version_range_pt *versionRange);
+ version_range_pt *versionRange) ;
Review comment:
done
##########
File path: libs/utils/src/utils.c
##########
@@ -61,6 +61,10 @@ bool celix_utils_stringEquals(const char* a, const char* b) {
}
}
+bool celix_utils_isStringNullOrEmpty(const char* s) {
+ return s == NULL || strlen(s) == 0;
Review comment:
done
##########
File path: libs/framework/gtest/src/DependencyManagerTestSuite.cc
##########
@@ -63,6 +65,87 @@ TEST_F(DependencyManagerTestSuite, DmCreateComponent) {
ASSERT_TRUE(celix_dependencyManager_allComponentsActive(mng));
}
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemove) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_add(mng, cmp);
+ ASSERT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_remove(mng, cmp);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ auto *cmp3 = celix_dmComponent_create(ctx, "test3");
+ celix_dependencyManager_add(mng, cmp2);
+ celix_dependencyManager_add(mng, cmp3);
+ ASSERT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ celix_dependencyManager_removeAllComponents(mng);
+ ASSERT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+}
+
+
+TEST_F(DependencyManagerTestSuite, DmComponentAddRemoveAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ celix_dependencyManager_addAsync(mng, cmp1);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(1, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ auto cb = [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ };
+
+ celix_dependencyManager_removeAsync(mng, cmp1, &count, cb);
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, DmComponentRemoveAllAsync) {
+ auto *mng = celix_bundleContext_getDependencyManager(ctx);
+ auto *cmp1 = celix_dmComponent_create(ctx, "test1");
+ auto *cmp2 = celix_dmComponent_create(ctx, "test2");
+ celix_dependencyManager_add(mng, cmp1);
+ celix_dependencyManager_add(mng, cmp2);
+ EXPECT_EQ(2, celix_dependencyManager_nrOfComponents(mng));
+
+ std::atomic<std::size_t> count{0};
+ celix_dependencyManager_removeAllComponentsAsync(mng, &count, [](void *data) {
+ auto* c = static_cast<std::atomic<std::size_t>*>(data);
+ c->fetch_add(1);
+ });
+ celix_dependencyManager_wait(mng);
+ EXPECT_EQ(0, celix_dependencyManager_nrOfComponents(mng));
+ EXPECT_EQ(1, count.load());
+}
+
+TEST_F(DependencyManagerTestSuite, CDmGetInfo) {
+ auto* mng = celix_bundleContext_getDependencyManager(ctx);
+ auto* cmp = celix_dmComponent_create(ctx, "test1");
+
+ auto* p = celix_properties_create();
+ celix_properties_set(p, "key", "value");
+ celix_dmComponent_addInterface(cmp, "test-interface", nullptr, (void*)0x42, p);
+
+ auto* dep = celix_dmServiceDependency_create();
+ celix_dmServiceDependency_setService(dep, "test-interface", nullptr, nullptr);
+ celix_dmComponent_addServiceDependency(cmp, dep);
+
+ celix_dependencyManager_add(mng, cmp);
+
+ auto* infos = celix_dependencyManager_createInfos(mng);
+ ASSERT_EQ(1, celix_arrayList_size(infos));
+ auto* dmInfo = (celix_dependency_manager_info_t*)celix_arrayList_get(infos, 0);
+ ASSERT_EQ(1, celix_arrayList_size(dmInfo->components));
+ auto *info = (celix_dm_component_info_t*)celix_arrayList_get(dmInfo->components, 0);
+ EXPECT_EQ(1, celix_arrayList_size(info->interfaces));
Review comment:
done
##########
File path: libs/framework/include/celix/dm/ServiceDependency.h
##########
@@ -78,14 +70,29 @@ namespace celix { namespace dm {
/**
* Whether the service dependency is valid.
+ *
+ * Depcrated -> will always return true.
Review comment:
done
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -282,78 +304,72 @@ celix_status_t component_removeServiceDependency(celix_dm_component_t *component
return celix_dmComponent_removeServiceDependency(component, dependency);
}
-celix_status_t celix_dmComponent_removeServiceDependency(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- executor_executeTask(component->executor, component, component_removeTask, dependency);
-
- return status;
-}
-
-static celix_status_t component_removeTask(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- arrayList_removeElement(component->dependencies, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- if (component->state != DM_CMP_STATE_INACTIVE) {
- serviceDependency_stop(dependency);
+celix_status_t celix_private_dmComponent_enable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (!component->isEnabled) {
+ component->isEnabled = true;
}
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
Review comment:
not really needed, handle change will do (effectually) nothing. But it does generate unneeded events. So I updated this.
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -282,78 +304,72 @@ celix_status_t component_removeServiceDependency(celix_dm_component_t *component
return celix_dmComponent_removeServiceDependency(component, dependency);
}
-celix_status_t celix_dmComponent_removeServiceDependency(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- executor_executeTask(component->executor, component, component_removeTask, dependency);
-
- return status;
-}
-
-static celix_status_t component_removeTask(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- arrayList_removeElement(component->dependencies, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- if (component->state != DM_CMP_STATE_INACTIVE) {
- serviceDependency_stop(dependency);
+celix_status_t celix_private_dmComponent_enable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (!component->isEnabled) {
+ component->isEnabled = true;
}
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
+ return CELIX_SUCCESS;
+}
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_remove(component->dependencyEvents, dependency);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_destroy(&dependency);
-
- while (!arrayList_isEmpty(events)) {
- dm_event_pt event = arrayList_remove(events, 0);
- event_destroy(&event);
+static celix_status_t celix_dmComponent_disable(celix_dm_component_t *component) {
+ celixThreadMutex_lock(&component->mutex);
+ if (component->isEnabled) {
+ component->isEnabled = false;
}
- arrayList_destroy(events);
-
- component_handleChange(component);
-
- return status;
+ celixThreadMutex_unlock(&component->mutex);
+ celix_dmComponent_handleChange(component);
Review comment:
same
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -889,402 +689,158 @@ static celix_status_t component_calculateNewState(celix_dm_component_t *componen
return status;
}
-static celix_status_t component_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
- celix_status_t status = CELIX_SUCCESS;
- //printf("performing transition for %s in thread %i from %i to %i\n", component->name, (int) pthread_self(), oldState, newState);
-
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
if (oldState == newState) {
*transition = false;
- } else if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- component_startDependencies(component, component->dependencies);
+ return CELIX_SUCCESS;
+ }
+
+ celix_bundleContext_log(component->context,
+ CELIX_LOG_LEVEL_TRACE,
+ "performing transition for component '%s' (uuid=%s) from state %s to state %s",
+ component->name,
+ component->uuid,
+ celix_dmComponent_stateToString(oldState),
+ celix_dmComponent_stateToString(newState));
+
+ celix_status_t status = CELIX_SUCCESS;
+ if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
+ celix_dmComponent_enableDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_invokeAddRequiredDependencies(component);
- component_invokeAutoConfigDependencies(component);
if (component->callbackInit) {
status = component->callbackInit(component->implementation);
}
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_TRACKING_OPTIONAL) {
- component_invokeAddRequiredInstanceBoundDependencies(component);
- component_invokeAutoConfigInstanceBoundDependencies(component);
- component_invokeAddOptionalDependencies(component);
if (component->callbackStart) {
status = component->callbackStart(component->implementation);
}
- component_registerServices(component);
+ celix_dmComponent_registerServices(component, false);
+ component->nrOfTimesStarted += 1;
*transition = true;
} else if (oldState == DM_CMP_STATE_TRACKING_OPTIONAL && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_unregisterServices(component);
+ celix_dmComponent_unregisterServices(component, false);
if (component->callbackStop) {
status = component->callbackStop(component->implementation);
}
- component_invokeRemoveOptionalDependencies(component);
- component_invokeRemoveInstanceBoundDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- if (component->callbackDeinit) {
- status = component->callbackDeinit(component->implementation);
- }
- component_invokeRemoveRequiredDependencies(component);
+ if (component->callbackDeinit) {
+ status = component->callbackDeinit(component->implementation);
+ }
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INACTIVE) {
- component_stopDependencies(component);
+ celix_dmComponent_disableDependencies(component);
*transition = true;
}
return status;
}
-static celix_status_t component_allRequiredAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_allInstanceBoundAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddRequiredDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && !instanceBound) {
- component_configureImplementation(component, dependency);
+/**
+ * Check if all required dependencies are resolved. This function should be called with the component->mutex locked.
+ */
+static bool celix_dmComponent_areAllRequiredServiceDependenciesResolved(celix_dm_component_t *component) {
+ bool allResolved = true;
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = celix_arrayList_get(component->dependencies, i);
+ bool started = celix_dmServiceDependency_isTrackerOpen(dependency);
+ bool required = celix_dmServiceDependency_isRequired(dependency);
+ bool available = celix_dmServiceDependency_isAvailable(dependency);
+ if (!started) {
+ allResolved = false;
+ break;
}
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && instanceBound) {
- component_configureImplementation(component, dependency);
+ if (required && !available) {
+ allResolved = false;
+ break;
}
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return allResolved;
}
-static celix_status_t component_invokeAddRequiredInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (instanceBound && required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+/**
+ * Register component services (if not already registered).
+ * If needLock is false, this function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_registerServices(celix_dm_component_t *component, bool needLock) {
+ if (needLock) {
+ celixThreadMutex_lock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddOptionalDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
-
- serviceDependency_isRequired(dependency, &required);
-
- if (!required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+ for (int i = 0; i < celix_arrayList_size(component->providedInterfaces); i++) {
+ dm_interface_t *interface = arrayList_get(component->providedInterfaces, i);
+ if (interface->svcId == -1L) {
+ celix_properties_t *regProps = celix_properties_copy(interface->properties);
+ celix_service_registration_options_t opts = CELIX_EMPTY_SERVICE_REGISTRATION_OPTIONS;
+ opts.properties = regProps;
+ opts.svc = (void*)interface->service;
+ opts.serviceName = interface->serviceName;
+ opts.serviceLanguage = celix_properties_get(regProps, CELIX_FRAMEWORK_SERVICE_LANGUAGE, NULL);
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Async registering service %s for component %s (uuid=%s)",
+ interface->serviceName,
+ component->name,
+ component->uuid);
+ long svcId = celix_bundleContext_registerServiceWithOptionsAsync(component->context, &opts);
+ interface->svcId = svcId;
+ }
+ }
+ if (needLock) {
+ celixThreadMutex_unlock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_invokeRemoveOptionalDependencies(celix_dm_component_t *component) {
+/**
+ * Unregister component services. This function should be called with the component->mutex locked.
Review comment:
removed
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -889,402 +689,158 @@ static celix_status_t component_calculateNewState(celix_dm_component_t *componen
return status;
}
-static celix_status_t component_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
- celix_status_t status = CELIX_SUCCESS;
- //printf("performing transition for %s in thread %i from %i to %i\n", component->name, (int) pthread_self(), oldState, newState);
-
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_performTransition(celix_dm_component_t *component, celix_dm_component_state_t oldState, celix_dm_component_state_t newState, bool *transition) {
if (oldState == newState) {
*transition = false;
- } else if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- component_startDependencies(component, component->dependencies);
+ return CELIX_SUCCESS;
+ }
+
+ celix_bundleContext_log(component->context,
+ CELIX_LOG_LEVEL_TRACE,
+ "performing transition for component '%s' (uuid=%s) from state %s to state %s",
+ component->name,
+ component->uuid,
+ celix_dmComponent_stateToString(oldState),
+ celix_dmComponent_stateToString(newState));
+
+ celix_status_t status = CELIX_SUCCESS;
+ if (oldState == DM_CMP_STATE_INACTIVE && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
+ celix_dmComponent_enableDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_invokeAddRequiredDependencies(component);
- component_invokeAutoConfigDependencies(component);
if (component->callbackInit) {
status = component->callbackInit(component->implementation);
}
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_TRACKING_OPTIONAL) {
- component_invokeAddRequiredInstanceBoundDependencies(component);
- component_invokeAutoConfigInstanceBoundDependencies(component);
- component_invokeAddOptionalDependencies(component);
if (component->callbackStart) {
status = component->callbackStart(component->implementation);
}
- component_registerServices(component);
+ celix_dmComponent_registerServices(component, false);
+ component->nrOfTimesStarted += 1;
*transition = true;
} else if (oldState == DM_CMP_STATE_TRACKING_OPTIONAL && newState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED) {
- component_unregisterServices(component);
+ celix_dmComponent_unregisterServices(component, false);
if (component->callbackStop) {
status = component->callbackStop(component->implementation);
}
- component_invokeRemoveOptionalDependencies(component);
- component_invokeRemoveInstanceBoundDependencies(component);
*transition = true;
} else if (oldState == DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_WAITING_FOR_REQUIRED) {
- if (component->callbackDeinit) {
- status = component->callbackDeinit(component->implementation);
- }
- component_invokeRemoveRequiredDependencies(component);
+ if (component->callbackDeinit) {
+ status = component->callbackDeinit(component->implementation);
+ }
*transition = true;
} else if (oldState == DM_CMP_STATE_WAITING_FOR_REQUIRED && newState == DM_CMP_STATE_INACTIVE) {
- component_stopDependencies(component);
+ celix_dmComponent_disableDependencies(component);
*transition = true;
}
return status;
}
-static celix_status_t component_allRequiredAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_allInstanceBoundAvailable(celix_dm_component_t *component, bool *available) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- *available = true;
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && instanceBound) {
- bool isAvailable = false;
- serviceDependency_isAvailable(dependency, &isAvailable);
- if (!isAvailable) {
- *available = false;
- break;
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddRequiredDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (required && !instanceBound) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && !instanceBound) {
- component_configureImplementation(component, dependency);
+/**
+ * Check if all required dependencies are resolved. This function should be called with the component->mutex locked.
+ */
+static bool celix_dmComponent_areAllRequiredServiceDependenciesResolved(celix_dm_component_t *component) {
+ bool allResolved = true;
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = celix_arrayList_get(component->dependencies, i);
+ bool started = celix_dmServiceDependency_isTrackerOpen(dependency);
+ bool required = celix_dmServiceDependency_isRequired(dependency);
+ bool available = celix_dmServiceDependency_isAvailable(dependency);
+ if (!started) {
+ allResolved = false;
+ break;
}
- }
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAutoConfigInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool autoConfig = false;
- bool instanceBound = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (autoConfig && instanceBound) {
- component_configureImplementation(component, dependency);
+ if (required && !available) {
+ allResolved = false;
+ break;
}
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return allResolved;
}
-static celix_status_t component_invokeAddRequiredInstanceBoundDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
- bool instanceBound = false;
-
- serviceDependency_isRequired(dependency, &required);
- serviceDependency_isInstanceBound(dependency, &instanceBound);
-
- if (instanceBound && required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+/**
+ * Register component services (if not already registered).
+ * If needLock is false, this function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_registerServices(celix_dm_component_t *component, bool needLock) {
+ if (needLock) {
+ celixThreadMutex_lock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
-}
-
-static celix_status_t component_invokeAddOptionalDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
-
- bool required = false;
-
- serviceDependency_isRequired(dependency, &required);
-
- if (!required) {
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- if (events) {
- for (unsigned int j = 0; j < arrayList_size(events); j++) {
- dm_event_pt event = arrayList_get(events, j);
- serviceDependency_invokeAdd(dependency, event);
- }
- }
- }
+ for (int i = 0; i < celix_arrayList_size(component->providedInterfaces); i++) {
+ dm_interface_t *interface = arrayList_get(component->providedInterfaces, i);
+ if (interface->svcId == -1L) {
+ celix_properties_t *regProps = celix_properties_copy(interface->properties);
+ celix_service_registration_options_t opts = CELIX_EMPTY_SERVICE_REGISTRATION_OPTIONS;
+ opts.properties = regProps;
+ opts.svc = (void*)interface->service;
+ opts.serviceName = interface->serviceName;
+ opts.serviceLanguage = celix_properties_get(regProps, CELIX_FRAMEWORK_SERVICE_LANGUAGE, NULL);
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Async registering service %s for component %s (uuid=%s)",
+ interface->serviceName,
+ component->name,
+ component->uuid);
+ long svcId = celix_bundleContext_registerServiceWithOptionsAsync(component->context, &opts);
+ interface->svcId = svcId;
+ }
+ }
+ if (needLock) {
+ celixThreadMutex_unlock(&component->mutex);
}
- pthread_mutex_unlock(&component->mutex);
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_invokeRemoveOptionalDependencies(celix_dm_component_t *component) {
+/**
+ * Unregister component services. This function should be called with the component->mutex locked.
+ * If needLock is false, this function should be called with the component->mutex locked.
Review comment:
function is not present anymore
##########
File path: libs/framework/src/dm_component_impl.c
##########
@@ -416,466 +432,250 @@ celix_status_t celix_dmComponent_removeInterface(celix_dm_component_t *component
celix_status_t status = CELIX_ILLEGAL_ARGUMENT;
celixThreadMutex_lock(&component->mutex);
- int nof_interfaces = arrayList_size(component->dm_interfaces);
- for (unsigned int i = 0; i < nof_interfaces; ++i) {
- dm_interface_t *interface = (dm_interface_t *) arrayList_get(component->dm_interfaces, i);
+ int nof_interfaces = celix_arrayList_size(component->providedInterfaces);
+ dm_interface_t* removedInterface = NULL;
+ for (int i = 0; i < nof_interfaces; ++i) {
+ dm_interface_t *interface = celix_arrayList_get(component->providedInterfaces, i);
if (interface->service == service) {
- arrayList_remove(component->dm_interfaces, i);
- if (component->state == DM_CMP_STATE_TRACKING_OPTIONAL) {
- celixThreadMutex_unlock(&component->mutex);
- component_unregisterServices(component);
- component_registerServices(component);
- celixThreadMutex_lock(&component->mutex);
- }
- status = CELIX_SUCCESS;
+ celix_arrayList_removeAt(component->providedInterfaces, i);
+ removedInterface = interface;
break;
}
}
celixThreadMutex_unlock(&component->mutex);
+ if (removedInterface != NULL) {
+ celix_bundleContext_unregisterService(component->context, removedInterface->svcId);
+ free(removedInterface->serviceName);
+ free(removedInterface);
+ }
+
return status;
}
-celix_status_t component_getInterfaces(celix_dm_component_t *component, array_list_pt *out) {
+celix_status_t component_getInterfaces(celix_dm_component_t *component, celix_array_list_t **out) {
return celix_dmComponent_getInterfaces(component, out);
}
-celix_status_t celix_dmComponent_getInterfaces(celix_dm_component_t *component, array_list_pt *out) {
- celix_status_t status = CELIX_SUCCESS;
- array_list_pt names = NULL;
- arrayList_create(&names);
+celix_status_t celix_dmComponent_getInterfaces(celix_dm_component_t *component, celix_array_list_t **out) {
+ celix_array_list_t* names = celix_arrayList_create();
+
celixThreadMutex_lock(&component->mutex);
- int size = arrayList_size(component->dm_interfaces);
- int i;
- for (i = 0; i < size; i += 1) {
- dm_interface_info_pt info = calloc(1, sizeof(*info));
- dm_interface_t *interface = arrayList_get(component->dm_interfaces, i);
- info->name = strdup(interface->serviceName);
- properties_copy(interface->properties, &info->properties);
- arrayList_add(names, info);
+ int size = celix_arrayList_size(component->providedInterfaces);
+ for (int i = 0; i < size; i += 1) {
+ dm_interface_info_t* info = calloc(1, sizeof(*info));
+ dm_interface_t *interface = celix_arrayList_get(component->providedInterfaces, i);
+ info->name = celix_utils_strdup(interface->serviceName);
+ info->properties = celix_properties_copy(interface->properties);
+ celix_arrayList_add(names, info);
}
celixThreadMutex_unlock(&component->mutex);
+ *out = names;
- if (status == CELIX_SUCCESS) {
- *out = names;
- }
-
- return status;
-}
-
-celix_status_t celix_private_dmComponent_handleEvent(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- dm_handle_event_type_pt data = calloc(1, sizeof(*data));
- data->dependency = dependency;
- data->event = event;
- data->newEvent = NULL;
-
- status = executor_executeTask(component->executor, component, component_handleEventTask, data);
-// component_handleEventTask(component, data);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleEventTask(celix_dm_component_t *component, dm_handle_event_type_pt data) {
- celix_status_t status = CELIX_SUCCESS;
-
- switch (data->event->event_type) {
- case DM_EVENT_ADDED:
- component_handleAdded(component,data->dependency, data->event);
- break;
- case DM_EVENT_CHANGED:
- component_handleChanged(component,data->dependency, data->event);
- break;
- case DM_EVENT_REMOVED:
- component_handleRemoved(component,data->dependency, data->event);
- break;
- case DM_EVENT_SWAPPED:
- component_handleSwapped(component,data->dependency, data->event, data->newEvent);
- break;
- default:
- break;
- }
-
- free(data);
-
- return status;
+celix_status_t celix_private_dmComponent_handleEvent(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ celix_status_t status = CELIX_SUCCESS;
+ switch (event->eventType) {
+ case CELIX_DM_EVENT_SVC_ADD:
+ celix_dmComponent_handleAdd(component, event);
+ break;
+ case CELIX_DM_EVENT_SVC_REM:
+ celix_dmComponent_handleRemove(component, event);
+ break;
+ case CELIX_DM_EVENT_SVC_SET:
+ celix_dmComponent_handleSet(component, event);
+ break;
+ default:
+ break;
+ }
+ return status;
}
-static celix_status_t component_suspend(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
+static celix_status_t celix_dmComponent_suspend(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
celix_status_t status = CELIX_SUCCESS;
-
- dm_service_dependency_strategy_t strategy;
- serviceDependency_getStrategy(dependency, &strategy);
+ dm_service_dependency_strategy_t strategy = celix_dmServiceDependency_getStrategy(dependency);
if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStop != NULL) {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Suspending component %s (uuid=%s)",
+ component->name,
+ component->uuid);
+ celix_dmComponent_unregisterServices(component, true);
status = component->callbackStop(component->implementation);
}
-
return status;
}
-static celix_status_t component_resume(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
+static celix_status_t celix_dmComponent_resume(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency) {
celix_status_t status = CELIX_SUCCESS;
-
- dm_service_dependency_strategy_t strategy;
- serviceDependency_getStrategy(dependency, &strategy);
- if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStop != NULL) {
- status = component->callbackStart(component->implementation);
+ dm_service_dependency_strategy_t strategy = celix_dmServiceDependency_getStrategy(dependency);
+ if (strategy == DM_SERVICE_DEPENDENCY_STRATEGY_SUSPEND && component->callbackStart != NULL) {
+ //ensure that the current state is still TRACKING_OPTION. Else during a add/rem/set call a required svc dep has been added.
+ celixThreadMutex_lock(&component->mutex);
+ celix_dm_component_state_t currentState = component->state;
+ celixThreadMutex_unlock(&component->mutex);
+ if (currentState == DM_CMP_STATE_TRACKING_OPTIONAL) {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Resuming component %s (uuid=%s)",
+ component->name,
+ component->uuid);
+ celix_dmComponent_registerServices(component, true);
+ status = component->callbackStart(component->implementation);
+ component->nrOfTimesResumed += 1;
+ } else {
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Skipping resume because cmp state is now %s",
+ celix_dmComponent_stateToString(currentState));
+ }
}
-
return status;
}
-static celix_status_t component_handleAdded(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- arrayList_add(events, event);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_setAvailable(dependency, true);
-
+static celix_status_t celix_dmComponent_handleEvent(celix_dm_component_t *component, const celix_dm_event_t* event, celix_status_t (*setAddOrRemFp)(celix_dm_service_dependency_t *dependency, void* svc, const celix_properties_t* props), const char *invokeName) {
+ bool needSuspend = false;
+ celixThreadMutex_lock(&component->mutex);
switch (component->state) {
- case DM_CMP_STATE_WAITING_FOR_REQUIRED: {
- serviceDependency_invokeSet(dependency, event);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- component_handleChange(component);
- }
- break;
- }
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (!instanceBound) {
- if (required) {
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeAdd(dependency, event);
- }
- dm_event_pt event = NULL;
- component_getDependencyEvent(component, dependency, &event);
- component_updateInstance(component, dependency, event, false, true);
- }
-
- if (required) {
- component_handleChange(component);
- }
- break;
- }
case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeAdd(dependency, event);
- component_resume(component,dependency);
- dm_event_pt event = NULL;
- component_getDependencyEvent(component, dependency, &event);
- component_updateInstance(component, dependency, event, false, true);
+ needSuspend = true;
break;
- default:
+ default: //DM_CMP_STATE_INACTIVE
break;
}
-
- return status;
-}
-
-static celix_status_t component_handleChanged(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- arrayList_add(events, event);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_invokeSet(dependency, event);
- switch (component->state) {
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeChange(dependency, event);
- component_resume(component,dependency);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, true, false);
- break;
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- serviceDependency_invokeChange(dependency, event);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, true, false);
- }
- break;
- }
- default:
- break;
- }
-
- event_destroy(&old);
- }
-
- return status;
+ celixThreadMutex_unlock(&component->mutex);
+ if (needSuspend) {
+ celix_dmComponent_suspend(component, event->dep);
+ }
+ celix_bundleContext_log(component->context, CELIX_LOG_LEVEL_TRACE,
+ "Calling %s service for component %s (uuid=%s) on service dependency with type %s",
+ invokeName,
+ component->name,
+ component->uuid,
+ event->dep->serviceName);
+ setAddOrRemFp(event->dep, event->svc, event->props);
+ //note that after after a set/add/rem a new svc dependency can be added, removed, etc
+ if (needSuspend) {
+ celix_dmComponent_resume(component, event->dep);
+ }
+ celix_dmComponent_handleChange(component);
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleRemoved(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int size = arrayList_size(events);
- if (arrayList_contains(events, event)) {
- size--;
- }
- pthread_mutex_unlock(&component->mutex);
- serviceDependency_setAvailable(dependency, size > 0);
- component_handleChange(component);
-
- pthread_mutex_lock(&component->mutex);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- pthread_mutex_unlock(&component->mutex);
-
-
- switch (component->state) {
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- serviceDependency_invokeSet(dependency, event);
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- serviceDependency_invokeRemove(dependency, event);
- }
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, false, false);
- }
- break;
- }
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSet(dependency, event);
- serviceDependency_invokeRemove(dependency, event);
- component_resume(component,dependency);
- dm_event_pt hevent = NULL;
- component_getDependencyEvent(component, dependency, &hevent);
- component_updateInstance(component, dependency, hevent, false, false);
- break;
- default:
- break;
- }
-
- event_destroy(&event);
- if (old) {
- event_destroy(&old);
- }
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleAdd(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeAdd, "add");
}
-static celix_status_t component_handleSwapped(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event, dm_event_pt newEvent) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- array_list_pt events = hashMap_get(component->dependencyEvents, dependency);
- int index = arrayList_indexOf(events, event);
- if (index < 0) {
- pthread_mutex_unlock(&component->mutex);
- status = CELIX_BUNDLE_EXCEPTION;
- } else {
- dm_event_pt old = arrayList_remove(events, (unsigned int) index);
- arrayList_add(events, newEvent);
- pthread_mutex_unlock(&component->mutex);
-
- serviceDependency_invokeSet(dependency, event);
-
- switch (component->state) {
- case DM_CMP_STATE_WAITING_FOR_REQUIRED:
- break;
- case DM_CMP_STATE_INSTANTIATED_AND_WAITING_FOR_REQUIRED: {
- bool instanceBound = false;
- serviceDependency_isInstanceBound(dependency, &instanceBound);
- if (!instanceBound) {
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- serviceDependency_invokeSwap(dependency, event, newEvent);
- }
- }
- break;
- }
- case DM_CMP_STATE_TRACKING_OPTIONAL:
- component_suspend(component,dependency);
- serviceDependency_invokeSwap(dependency, event, newEvent);
- component_resume(component,dependency);
- break;
- default:
- break;
- }
-
- event_destroy(&event);
- if (old) {
- event_destroy(&old);
- }
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleRemove(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeRemove, "remove");
}
-static celix_status_t component_updateInstance(celix_dm_component_t *component, celix_dm_service_dependency_t *dependency, dm_event_pt event, bool update, bool add) {
- celix_status_t status = CELIX_SUCCESS;
-
- bool autoConfig = false;
-
- serviceDependency_isAutoConfig(dependency, &autoConfig);
-
- if (autoConfig) {
- const void *service = NULL;
- const void **field = NULL;
-
- if (event != NULL) {
- event_getService(event, &service);
- }
- serviceDependency_getAutoConfig(dependency, &field);
- serviceDependency_lock(dependency);
- *field = service;
- serviceDependency_unlock(dependency);
- }
-
- return status;
+static celix_status_t celix_dmComponent_handleSet(celix_dm_component_t *component, const celix_dm_event_t* event) {
+ return celix_dmComponent_handleEvent(component, event, celix_dmServiceDependency_invokeSet, "set");
}
-static celix_status_t component_startDependencies(celix_dm_component_t *component __attribute__((unused)), array_list_pt dependencies) {
- celix_status_t status = CELIX_SUCCESS;
- array_list_pt required_dependencies = NULL;
- arrayList_create(&required_dependencies);
-
- for (unsigned int i = 0; i < arrayList_size(dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(dependencies, i);
- bool required = false;
- serviceDependency_isRequired(dependency, &required);
- if (required) {
- arrayList_add(required_dependencies, dependency);
- continue;
- }
-
- serviceDependency_start(dependency);
- }
-
- for (unsigned int i = 0; i < arrayList_size(required_dependencies); i++) {
- celix_dm_service_dependency_t *dependency = arrayList_get(required_dependencies, i);
- serviceDependency_start(dependency);
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_enableDependencies(celix_dm_component_t *component) {
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
+ celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
+ celix_dmServiceDependency_enable(dependency);
}
-
- arrayList_destroy(required_dependencies);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_stopDependencies(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
-
- pthread_mutex_lock(&component->mutex);
- for (unsigned int i = 0; i < arrayList_size(component->dependencies); i++) {
+/**
+ * perform state transition. This function should be called with the component->mutex locked.
+ */
+static celix_status_t celix_dmComponent_disableDependencies(celix_dm_component_t *component) {
+ for (int i = 0; i < celix_arrayList_size(component->dependencies); i++) {
celix_dm_service_dependency_t *dependency = arrayList_get(component->dependencies, i);
- pthread_mutex_unlock(&component->mutex);
- serviceDependency_stop(dependency);
- pthread_mutex_lock(&component->mutex);
+ celix_dmServiceDependency_disable(dependency);
}
- pthread_mutex_unlock(&component->mutex);
-
- return status;
+ return CELIX_SUCCESS;
}
-static celix_status_t component_handleChange(celix_dm_component_t *component) {
- celix_status_t status = CELIX_SUCCESS;
+/**
+ * Calculate and handle state change. This function should be called with the component->mutex locked.
Review comment:
comment is incorrect, removed.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org