debian-packages/eventcore
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Avoid log noise.

Browse source
This commit is contained in:
Sönke Ludwig 2016-06-17 22:28:52 +02:00
parent bae3761924
commit b05354416f
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
source/eventcore/drivers/epoll.d
View file

@ -39,7 +39,7 @@ final class EpollEventDriver : PosixEventDriver {
if (timeout == Duration.max) tomsec = long.max; if (timeout == Duration.max) tomsec = long.max;
else tomsec = (timeout.total!"hnsecs" + 9999) / 10_000; 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); 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) { if (ret > 0) {
foreach (ref evt; m_events[0 .. ret]) { foreach (ref evt; m_events[0 .. ret]) {

6
source/eventcore/drivers/posix.d
View file

@ -496,9 +496,9 @@ abstract class PosixEventDriver : EventDriver {
{ {
assert(event < m_fds.length, "Invalid event ID passed to triggerEvent."); assert(event < m_fds.length, "Invalid event ID passed to triggerEvent.");
if (notify_all) { 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) { 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); w(event);
} }
} else { } else {
@ -513,7 +513,7 @@ abstract class PosixEventDriver : EventDriver {
auto thisus = cast(PosixEventDriver)this; auto thisus = cast(PosixEventDriver)this;
assert(event < thisus.m_fds.length, "Invalid event ID passed to shared triggerEvent."); assert(event < thisus.m_fds.length, "Invalid event ID passed to shared triggerEvent.");
long one = 1; long one = 1;
log("emitting for all threads"); //log("emitting for all threads");
if (notify_all) atomicStore(thisus.m_fds[event].triggerAll, true); if (notify_all) atomicStore(thisus.m_fds[event].triggerAll, true);
() @trusted { write(event, &one, one.sizeof); } (); () @trusted { write(event, &one, one.sizeof); } ();
} }