diff --git a/source/eventcore/drivers/epoll.d b/source/eventcore/drivers/epoll.d index baa8d41..78dedd8 100644 --- a/source/eventcore/drivers/epoll.d +++ b/source/eventcore/drivers/epoll.d @@ -39,7 +39,7 @@ final class EpollEventDriver : PosixEventDriver { if (timeout == Duration.max) tomsec = long.max; else tomsec = (timeout.total!"hnsecs" + 9999) / 10_000; auto ret = epoll_wait(m_epoll, m_events.ptr, cast(int)m_events.length, tomsec > int.max ? -1 : cast(int)tomsec); - print("wait done %s", ret); + //print("wait done %s", ret); if (ret > 0) { foreach (ref evt; m_events[0 .. ret]) { diff --git a/source/eventcore/drivers/posix.d b/source/eventcore/drivers/posix.d index 7b1ec29..5335f86 100644 --- a/source/eventcore/drivers/posix.d +++ b/source/eventcore/drivers/posix.d @@ -496,9 +496,9 @@ abstract class PosixEventDriver : EventDriver { { assert(event < m_fds.length, "Invalid event ID passed to triggerEvent."); if (notify_all) { - log("emitting only for this thread (%s waiters)", m_fds[event].waiters.length); + //log("emitting only for this thread (%s waiters)", m_fds[event].waiters.length); foreach (w; m_fds[event].waiters.consume) { - log("emitting waiter %s %s", cast(void*)w.funcptr, w.ptr); + //log("emitting waiter %s %s", cast(void*)w.funcptr, w.ptr); w(event); } } else { @@ -513,7 +513,7 @@ abstract class PosixEventDriver : EventDriver { auto thisus = cast(PosixEventDriver)this; assert(event < thisus.m_fds.length, "Invalid event ID passed to shared triggerEvent."); long one = 1; - log("emitting for all threads"); + //log("emitting for all threads"); if (notify_all) atomicStore(thisus.m_fds[event].triggerAll, true); () @trusted { write(event, &one, one.sizeof); } (); }