celix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pnol...@apache.org
Subject [05/19] celix git commit: Fix building PubsubAdminUDP for OSX
Date Mon, 06 Feb 2017 18:34:17 GMT
Fix building PubsubAdminUDP for OSX

TODO: Implement epoll alternative (kqueue) for OSX


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

Branch: refs/heads/develop
Commit: 1af1ff0f52a1be23f66266cd6bf5be38d85c104d
Parents: 45ecd64
Author: Roy Lenferink <lenferinkroy@gmail.com>
Authored: Mon Feb 6 17:41:30 2017 +0100
Committer: Roy Lenferink <lenferinkroy@gmail.com>
Committed: Mon Feb 6 17:41:30 2017 +0100

----------------------------------------------------------------------
 .../publisher/private/src/pubsub_publisher.c    |  8 ++++
 .../private/src/topic_subscription.c            | 41 +++++++++++++++++++-
 2 files changed, 47 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/celix/blob/1af1ff0f/celix-pubsub/pubsub/examples/pubsub/publisher/private/src/pubsub_publisher.c
----------------------------------------------------------------------
diff --git a/celix-pubsub/pubsub/examples/pubsub/publisher/private/src/pubsub_publisher.c
b/celix-pubsub/pubsub/examples/pubsub/publisher/private/src/pubsub_publisher.c
index 94331d9..66454a0 100644
--- a/celix-pubsub/pubsub/examples/pubsub/publisher/private/src/pubsub_publisher.c
+++ b/celix-pubsub/pubsub/examples/pubsub/publisher/private/src/pubsub_publisher.c
@@ -156,7 +156,15 @@ celix_status_t publisher_publishSvcAdded(void * handle, service_reference_pt
ref
 celix_status_t publisher_publishSvcRemoved(void * handle, service_reference_pt reference,
void * service){
 	pubsub_sender_pt manager = (pubsub_sender_pt)handle;
 	celix_thread_t *tid = hashMap_get(manager->tid_map, service);
+
+#if defined(__APPLE__) && defined(__MACH__)
+	uint64_t threadid;
+	pthread_threadid_np(tid->thread, &threadid);
+	printf("PUBLISHER: publish service unexporting (%s) %llu!\n",manager->ident, threadid);
+#else
 	printf("PUBLISHER: publish service unexporting (%s) %li!\n",manager->ident, tid->thread);
+#endif
+
 	stop=true;
 	celixThread_join(*tid,NULL);
 	free(tid);

http://git-wip-us.apache.org/repos/asf/celix/blob/1af1ff0f/celix-pubsub/pubsub/pubsub_admin_udp_mc/private/src/topic_subscription.c
----------------------------------------------------------------------
diff --git a/celix-pubsub/pubsub/pubsub_admin_udp_mc/private/src/topic_subscription.c b/celix-pubsub/pubsub/pubsub_admin_udp_mc/private/src/topic_subscription.c
index 210afd4..0907f16 100644
--- a/celix-pubsub/pubsub/pubsub_admin_udp_mc/private/src/topic_subscription.c
+++ b/celix-pubsub/pubsub/pubsub_admin_udp_mc/private/src/topic_subscription.c
@@ -31,10 +31,16 @@
 
 #include <sys/types.h>
 #include <sys/socket.h>
-#include <sys/epoll.h>
 #include <netinet/in.h>
 #include <arpa/inet.h>
 
+#if defined(__APPLE__) && defined(__MACH__)
+	#include <sys/event.h>
+	#include <sys/time.h>
+#else
+	#include <sys/epoll.h>
+#endif
+
 #include "utils.h"
 #include "celix_errno.h"
 #include "constants.h"
@@ -95,7 +101,11 @@ celix_status_t pubsub_topicSubscriptionCreate(char* ifIp,bundle_context_pt
bundl
 	topic_subscription_pt ts = (topic_subscription_pt) calloc(1,sizeof(*ts));
 	ts->context = bundle_context;
 	ts->ifIpAddress = strdup(ifIp);
+#if defined(__APPLE__) && defined(__MACH__)
+	//TODO: Use kqueue for OSX
+#else
 	ts->topicEpollFd = epoll_create1(0);
+#endif
 	if(ts->topicEpollFd == -1) {
 	    status += CELIX_SERVICE_EXCEPTION;
 	}
@@ -155,7 +165,11 @@ celix_status_t pubsub_topicSubscriptionDestroy(topic_subscription_pt
ts){
 
 	hashMap_destroy(ts->socketMap,false,false);
 	largeUdp_destroy(ts->largeUdpHandle);
+#if defined(__APPLE__) && defined(__MACH__)
+	//TODO: Use kqueue for OSX
+#else
 	close(ts->topicEpollFd);
+#endif
 
 	celixThreadMutex_unlock(&ts->ts_lock);
 
@@ -257,7 +271,9 @@ celix_status_t pubsub_topicSubscriptionConnectPublisher(topic_subscription_pt
ts
 			return CELIX_SERVICE_EXCEPTION;
 		}
 
-
+#if defined(__APPLE__) && defined(__MACH__)
+    //TODO: Use kqueue for OSX
+#else
 		struct epoll_event ev;
 		memset(&ev, 0, sizeof(ev));
 		ev.events = EPOLLIN;
@@ -266,6 +282,8 @@ celix_status_t pubsub_topicSubscriptionConnectPublisher(topic_subscription_pt
ts
 			perror("epoll_ctl() EPOLL_CTL_ADD");
 			return CELIX_SERVICE_EXCEPTION;
 		}
+#endif
+
 		hashMap_put(ts->socketMap, pubURL, (void*)recvSocket);
 
 		celixThreadMutex_unlock(&ts->ts_lock);
@@ -280,6 +298,10 @@ celix_status_t pubsub_topicSubscriptionDisconnectPublisher(topic_subscription_pt
     celix_status_t status = CELIX_SUCCESS;
 
     if (hashMap_containsKey(ts->socketMap, pubURL)){
+
+#if defined(__APPLE__) && defined(__MACH__)
+    //TODO: Use kqueue for OSX
+#else
 		struct epoll_event ev;
 		memset(&ev, 0, sizeof(ev));
 
@@ -294,6 +316,8 @@ celix_status_t pubsub_topicSubscriptionDisconnectPublisher(topic_subscription_pt
 		free(s);
 
 		celixThreadMutex_unlock(&ts->ts_lock);
+#endif
+
     }
 
 	return status;
@@ -454,6 +478,18 @@ static void process_msg(topic_subscription_pt sub,pubsub_udp_msg_pt msg){
 static void* udp_recv_thread_func(void * arg) {
     topic_subscription_pt sub = (topic_subscription_pt) arg;
 
+#if defined(__APPLE__) && defined(__MACH__)
+    //TODO: use kqueue for OSX
+    //struct kevent events[MAX_EPOLL_EVENTS];
+    while (sub->running) {
+    	int nfds = 0;
+		if(nfds > 0) {
+			pubsub_udp_msg_pt udpMsg = NULL;
+			process_msg(sub, udpMsg);
+		}
+    }
+#else
+
     struct epoll_event events[MAX_EPOLL_EVENTS];
 
     while (sub->running) {
@@ -480,6 +516,7 @@ static void* udp_recv_thread_func(void * arg) {
             }
         }
     }
+#endif
 
     return NULL;
 }


Mime
View raw message