Initial community commit

1 files changed, 224 insertions, 0 deletions

diff --git a/Src/replicant/component/ComponentManagerBase.cpp b/Src/replicant/component/ComponentManagerBase.cpp
new file mode 100644
index 00000000..d375f088
--- /dev/null
+++ b/Src/replicant/component/ComponentManagerBase.cpp
@@ -0,0 +1,224 @@
+#include "ComponentManagerBase.h"
+#include "foundation/error.h"
+#include "nx/nxuri.h"
+
+ComponentManagerBase::ComponentManagerBase()
+{
+	phase=PHASE_INITIALIZE;
+	service_api=0;
+	component_sync=0;
+	framework_guid = INVALID_GUID;
+	application_guid = INVALID_GUID;
+}
+
+int ComponentManagerBase::LateLoad(ifc_component *component)
+{
+	int ret;
+
+	if (phase >= PHASE_REGISTERED)
+	{
+		ret = component->RegisterServices(service_api);
+		if (ret != NErr_Success)
+		{
+			int ret2 = component->Quit(service_api);
+			if (ret2 == NErr_TryAgain)
+			{
+				component_sync->Wait(1);
+			}
+			return ret;
+		}
+	}
+
+	if (phase >= PHASE_LOADING)
+	{
+		ret = component->OnLoading(service_api);
+		if (ret != NErr_Success)
+		{
+			int ret2 = component->Quit(service_api);
+			if (ret2 == NErr_TryAgain)
+			{
+				component_sync->Wait(1);
+			}
+			return ret;
+		}
+	}
+
+	if (phase >= PHASE_LOADED)
+	{
+		ret = component->OnLoaded(service_api);
+		if (ret != NErr_Success)
+		{
+			int ret2 = component->Quit(service_api);
+			if (ret2 == NErr_TryAgain)
+			{
+				component_sync->Wait(1);
+			}
+			return ret;
+		}
+	}
+	return NErr_Success;
+}
+
+void ComponentManagerBase::SetServiceAPI(api_service *_service_api)
+{
+	this->service_api = _service_api;
+	service_api->QueryInterface(&component_sync);
+}
+
+int ComponentManagerBase::Load()
+{
+	if (phase != PHASE_INITIALIZE)
+		return NErr_Error;
+
+	int ret;
+
+	/* RegisterServices phase */
+	for (ComponentList::iterator itr=components.begin();itr!=components.end();)
+	{
+		ifc_component *component = *itr;
+		//ComponentList::iterator next=itr;
+		//next++;
+		ret = component->RegisterServices(service_api);
+		if (ret != NErr_Success)
+		{
+			int ret2 = component->Quit(service_api);
+			if (ret2 == NErr_TryAgain)
+			{
+				component_sync->Wait(1);
+			}	
+			NXURIRelease(component->component_info.filename);
+			CloseComponent(component);
+			itr = components.erase(itr);
+		}
+		else
+		{
+			itr++; // = next;
+		}
+	}
+
+	phase = PHASE_REGISTERED;
+
+	/* OnLoading phase */
+	for (ComponentList::iterator itr=components.begin();itr!=components.end();)
+	{
+		ifc_component *component = *itr;
+		//ComponentList::iterator next=itr;
+		//next++;
+		ret = component->OnLoading(service_api);
+		if (ret != NErr_Success)
+		{
+			int ret2 = component->Quit(service_api);
+			if (ret2 == NErr_TryAgain)
+			{
+				component_sync->Wait(1);
+			}	
+			NXURIRelease(component->component_info.filename);
+			CloseComponent(component);
+			itr = components.erase(itr);
+		}
+		else
+		{
+			itr++; // = next;
+		}
+	}
+
+	phase = PHASE_LOADING;
+
+	/* OnLoaded phase */
+	for (ComponentList::iterator itr = components.begin(); itr != components.end();)
+	{
+		ifc_component* component = *itr;
+		//ComponentList::iterator next = itr;
+		//next++;
+		ret = component->OnLoaded(service_api);
+		if (ret != NErr_Success)
+		{
+			int ret2 = component->Quit(service_api);
+			if (ret2 == NErr_TryAgain)
+			{
+				component_sync->Wait(1);
+			}
+			NXURIRelease(component->component_info.filename);
+			CloseComponent(component);
+			itr = components.erase(itr);
+		}
+		else
+		{
+			itr++; // = next;
+		}
+	}
+
+	phase = PHASE_LOADED;
+
+	return NErr_Success;
+}
+
+int ComponentManagerBase::AddComponent(ifc_component *component)
+{
+	int err;
+	
+	if (NULL == component)
+		return NErr_BadParameter;
+	
+	if (phase > PHASE_LOADED)
+		return NErr_Error;
+	
+	if (component->component_info.wasabi_version != wasabi2_component_version
+		|| component->component_info.nx_api_version != nx_api_version
+		|| component->component_info.nx_platform_guid != nx_platform_guid)
+	{
+		return NErr_IncompatibleVersion;
+	}
+
+	if (component->component_info.framework_guid != INVALID_GUID 
+		&& framework_guid != component->component_info.framework_guid)
+	{
+		return NErr_IncompatibleVersion;
+	}
+	
+	if (component->component_info.application_guid != INVALID_GUID 
+		&& application_guid != component->component_info.application_guid)
+	{
+		return NErr_IncompatibleVersion;
+	}
+	
+	for (ComponentList::iterator itr = components.begin(); itr != components.end(); itr++)
+	{
+		ifc_component *registered_component = *itr;
+		if (registered_component->component_info.component_guid == component->component_info.component_guid)
+			return NErr_Error;
+	}
+	
+	err = component->Initialize(service_api);
+	if (NErr_Success != err)
+		return err;
+	
+	/* if the component was added late, we'll need to run some extra stages */
+	err = LateLoad(component);
+	if (NErr_Success != err)
+		return err;
+	
+	components.push_back(component);
+	
+	return NErr_Success;
+}
+
+void ComponentManagerBase::SetFrameworkGUID(GUID guid)
+{
+	framework_guid = guid;
+}
+
+GUID ComponentManagerBase::GetFrameworkGUID()
+{
+	return framework_guid;
+}
+
+void ComponentManagerBase::SetApplicationGUID(GUID guid)
+{
+	application_guid = guid;
+}
+
+GUID ComponentManagerBase::GetApplicationGUID()
+{
+	return application_guid;
+}