/* vim: set expandtab ts=4 sw=4: */ /* * You may redistribute this program and/or modify it under the terms of * the GNU General Public License as published by the Free Software Foundation, * either version 3 of the License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ #include "util/events/libuv/UvWrapper.h" #include "memory/Allocator.h" #include "util/events/libuv/EventBase_pvt.h" #include "util/events/Event.h" #include "util/Identity.h" #include #include struct Event_pvt { struct Event pub; void (* const callback)(void* callbackContext); void* const callbackContext; uv_poll_t handler; struct Allocator* alloc; Identity }; static void handleEvent(uv_poll_t* handle, int status, int events) { struct Event_pvt* event = Identity_check((struct Event_pvt*) (((char*)handle) - offsetof(struct Event_pvt, handler))); if ((status == 0) && (events & UV_READABLE)) { event->callback(event->callbackContext); } } static void freeEvent2(uv_handle_t* handle) { Allocator_onFreeComplete((struct Allocator_OnFreeJob*)handle->data); } static int freeEvent(struct Allocator_OnFreeJob* job) { struct Event_pvt* event = Identity_check((struct Event_pvt*) job->userData); event->handler.data = job; uv_close((uv_handle_t*) &event->handler, freeEvent2); return Allocator_ONFREE_ASYNC; } struct Event* Event_socketRead(void (* const callback)(void* callbackContext), void* const callbackContext, int s, struct EventBase* eventBase, struct Allocator* allocator) { struct EventBase_pvt* base = EventBase_privatize(eventBase); struct Allocator* alloc = Allocator_child(allocator); struct Event_pvt* out = Allocator_clone(alloc, (&(struct Event_pvt) { .callback = callback, .callbackContext = callbackContext, .alloc = alloc })); Identity_set(out); // != 0 check, removed because uv_poll_init always returns 0 uv_poll_init(base->loop, &out->handler, s); // == -1 check, removed because uv_poll_start always returns 0 uv_poll_start(&out->handler, UV_READABLE, handleEvent); out->handler.data = out; Allocator_onFree(alloc, freeEvent, out); return &out->pub; }