diff --git a/dap-sdk/net/core/dap_events_socket.c b/dap-sdk/net/core/dap_events_socket.c index adeb178b28935bd6f4e5380a2b8b7f7c04cc98cf..526fcc13bcddd84efcd031d85da07e77a0b90076 100644 --- a/dap-sdk/net/core/dap_events_socket.c +++ b/dap-sdk/net/core/dap_events_socket.c @@ -736,7 +736,7 @@ dap_events_socket_t * s_create_type_queue_ptr(dap_worker_t * a_w, dap_events_soc } #elif defined (DAP_EVENTS_CAPS_KQUEUE) // We don't create descriptor for kqueue at all - l_es->fd = l_es->fd2 = -1; + l_es->fd = l_es->fd2 = -1; #else #error "Not implemented s_create_type_queue_ptr() on your platform" @@ -1251,9 +1251,13 @@ int dap_events_socket_queue_ptr_send( dap_events_socket_t * a_es, void* a_arg) l_n = kevent(a_es->worker->kqueue_fd,&l_event,1,NULL,0,NULL); else if (a_es->proc_thread) l_n = kevent(a_es->proc_thread->kqueue_fd,&l_event,1,NULL,0,NULL); - else + else { + log_it(L_WARNING,"Trying to send pointer in queue thats not assigned to any worker or proc thread"); l_n = 0; + } + l_errno = errno; l_ret = l_n==1? sizeof(a_arg) : -1; + #else #error "Not implemented dap_events_socket_queue_ptr_send() for this platform" #endif diff --git a/dap-sdk/net/core/dap_worker.c b/dap-sdk/net/core/dap_worker.c index 298e86923143140a612ba143c5ddb7e070496670..c705989ffa97d8a3ef6dcd3fd670ebb4f61838e0 100644 --- a/dap-sdk/net/core/dap_worker.c +++ b/dap-sdk/net/core/dap_worker.c @@ -968,7 +968,6 @@ void dap_worker_add_events_socket_inter(dap_events_socket_t * a_es_input, dap_ev */ int dap_worker_add_events_socket_unsafe( dap_events_socket_t * a_esocket, dap_worker_t * a_worker ) { - #ifdef DAP_EVENTS_CAPS_EPOLL // Init events for EPOLL a_esocket->ev.events = a_esocket->ev_base_flags ; @@ -1007,8 +1006,7 @@ int dap_worker_add_events_socket_unsafe( dap_events_socket_t * a_esocket, dap_wo l_fflags |= NOTE_WRITE; EV_SET(&a_esocket->kqueue_event , a_esocket->socket, l_filter, EV_ADD| l_flags | EV_CLEAR, l_fflags,0, a_esocket); - return kevent ( a_worker->kqueue_fd,&a_esocket->kqueue_event,1,NULL,0,NULL)==1 ? 0 : -1 ; - + return kevent ( a_worker->kqueue_fd,&a_esocket->kqueue_event,1,NULL,0,NULL)==1 ? 0 : errno; #else #error "Unimplemented new esocket on worker callback for current platform" #endif