Initial community commit

1 files changed, 183 insertions, 0 deletions

diff --git a/Src/nu/ServiceWatcher.cpp b/Src/nu/ServiceWatcher.cpp
new file mode 100644
index 00000000..dcf8e096
--- /dev/null
+++ b/Src/nu/ServiceWatcher.cpp
@@ -0,0 +1,183 @@
+#include "ServiceWatcher.h"
+#include <api/service/waservicefactory.h>
+
+
+static void *GetService(api_service *p_serviceManager, GUID p_serviceGUID)
+{
+	waServiceFactory *sf = p_serviceManager->service_getServiceByGuid( p_serviceGUID);
+	if (sf)
+		return sf->getInterface();
+	else
+		return 0;
+}
+
+static void ReleaseService(api_service *p_serviceManager, GUID p_serviceGUID, void *p_service)
+{
+	waServiceFactory *sf = p_serviceManager->service_getServiceByGuid( p_serviceGUID);
+	if (sf)
+		sf->releaseInterface( p_service);
+}
+
+void ServiceWatcher::WatchWith(api_service *_serviceApi) 
+{ 
+	serviceManager =_serviceApi;
+	systemCallbacks=(api_syscb*)GetService( serviceManager, syscbApiServiceGuid);
+}
+
+void ServiceWatcher::StopWatching()
+{
+	if (systemCallbacks)
+	{
+		systemCallbacks->syscb_deregisterCallback(this);
+		ReleaseService( serviceManager, syscbApiServiceGuid, systemCallbacks);
+	}
+	systemCallbacks=0;
+}
+void ServiceWatcher::Clear() 
+{
+	//watchList.Reset();
+	watchList.clear();
+}
+
+ServiceWatcher::~ServiceWatcher()
+{
+	//StopWatching();
+}
+
+void ServiceWatcher::WatchForT(void **ptr, GUID watchGUID)
+{
+	watchList[watchGUID]=ptr;
+	if (!*ptr) // try to get it if we need it
+	{
+		*ptr = GetService( serviceManager, watchGUID);
+	}
+}
+
+int ServiceWatcher::Notify(int msg, intptr_t param1, intptr_t param2)
+{
+	switch (msg)
+	{
+		case SvcCallback::ONREGISTER:
+		{
+			waServiceFactory *sf = reinterpret_cast<waServiceFactory*>(param2);
+			GUID serviceGUID = sf->getGuid();
+			if (serviceGUID != INVALID_GUID)
+			{
+				WatchList::iterator itr = watchList.find(serviceGUID);
+				if (itr!=watchList.end())
+				{
+					void **ptr = itr->second;
+					if (ptr && !*ptr) // don't re-retrieve service if we already have it
+					{
+						*ptr = sf->getInterface();
+					}
+				}
+			}
+		}
+		break;
+		case SvcCallback::ONDEREGISTER:
+		{
+			waServiceFactory *sf = reinterpret_cast<waServiceFactory*>(param2);
+			GUID serviceGUID = sf->getGuid();
+			if (serviceGUID != INVALID_GUID)
+			{
+				WatchList::iterator itr = watchList.find(serviceGUID);
+				if (itr!=watchList.end())
+				{
+					void **ptr = itr->second;
+					if (ptr && *ptr)
+					{
+						// benski> probably not safe to do, so i'll leave it commented out: sf->releaseInterface(*ptr);
+						*ptr = 0;
+					}
+				}
+			}
+		}
+		break;
+		default: return 0;
+	}
+	return 1;
+}
+
+#define CBCLASS ServiceWatcher
+START_DISPATCH;
+CB(SYSCALLBACK_GETEVENTTYPE, GetEventType);
+CB(SYSCALLBACK_NOTIFY, Notify);
+END_DISPATCH;
+#undef CBCLASS
+
+ServiceWatcherSingle::~ServiceWatcherSingle()
+{
+	//StopWatching();
+}
+
+void ServiceWatcherSingle::StopWatching()
+{
+	if (systemCallbacks)
+	{
+		systemCallbacks->syscb_deregisterCallback(this);
+		ReleaseService( serviceManager, syscbApiServiceGuid, systemCallbacks);
+	}
+	systemCallbacks=0;
+}
+
+void ServiceWatcherSingle::WatchWith(api_service *_serviceApi) 
+{
+	serviceManager =_serviceApi;
+	systemCallbacks=(api_syscb*)GetService( serviceManager, syscbApiServiceGuid);
+}
+
+void ServiceWatcherSingle::WatchForT(void **ptr, GUID watchGUID)
+{
+	service=ptr;
+	serviceGUID=watchGUID;
+	if (ptr && !*ptr) // try to get it if we need it
+	{
+		*ptr = GetService( serviceManager, watchGUID);
+		if (*ptr)
+			OnRegister();
+	}
+}
+
+int ServiceWatcherSingle::Notify(int msg, intptr_t param1, intptr_t param2)
+{
+	switch (msg)
+	{
+		case SvcCallback::ONREGISTER:
+		{
+			if (service && !*service) // don't re-retrieve service if we already have it
+			{
+				waServiceFactory *sf = reinterpret_cast<waServiceFactory*>(param2);
+				if (sf && sf->getGuid() == serviceGUID)
+				{
+					*service = sf->getInterface();
+					if (*service)
+					OnRegister();
+				}
+			}
+		}
+		break;
+		case SvcCallback::ONDEREGISTER:
+		{
+			if (service && *service)
+			{
+				waServiceFactory *sf = reinterpret_cast<waServiceFactory*>(param2);
+				if (serviceGUID == sf->getGuid())
+				{
+					OnDeregister();
+					*service=0;
+				}
+			}
+		}
+		break;
+		default: return 0;
+	}
+	return 1;
+}
+
+#define CBCLASS ServiceWatcherSingle
+START_DISPATCH;
+CB(SYSCALLBACK_GETEVENTTYPE, GetEventType);
+CB(SYSCALLBACK_NOTIFY, Notify);
+END_DISPATCH;
+#undef CBCLASS
\ No newline at end of file