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

Add debug output for the getaddrinfo based DNS lookup driver.

Browse source
This commit is contained in:
Sönke Ludwig 2017-01-23 12:17:53 +01:00
parent e55e23368a
commit e72b071057
2 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -923,6 +923,7 @@ final class EventDriverDNS_GAI(Events : EventDriverEvents, Signals : EventDriver
override DNSLookupID lookupHost(string name, DNSLookupCallback on_lookup_finished) override DNSLookupID lookupHost(string name, DNSLookupCallback on_lookup_finished)
{ {
debug (EventCoreLogDNS) print("lookup %s", name);
auto handle = getFreeHandle(); auto handle = getFreeHandle();
if (handle > m_maxHandle) m_maxHandle = handle; if (handle > m_maxHandle) m_maxHandle = handle;
@ -934,18 +935,21 @@ final class EventDriverDNS_GAI(Events : EventDriverEvents, Signals : EventDriver
auto t = task!taskFun(l, AddressFamily.UNSPEC, events, m_event); auto t = task!taskFun(l, AddressFamily.UNSPEC, events, m_event);
try taskPool.put(t); try taskPool.put(t);
catch (Exception e) return DNSLookupID.invalid; catch (Exception e) return DNSLookupID.invalid;
debug (EventCoreLogDNS) print("lookup handle: %s", handle);
return handle; return handle;
} }
/// public /// public
static void taskFun(Lookup* lookup, int af, shared(Events) events, EventID event) static void taskFun(Lookup* lookup, int af, shared(Events) events, EventID event)
{ {
debug (EventCoreLogDNS) print("lookup %s start", lookup.name);
addrinfo hints; addrinfo hints;
hints.ai_flags = AI_ADDRCONFIG; hints.ai_flags = AI_ADDRCONFIG;
version (linx) hints.ai_flags |= AI_V4MAPPED; version (linx) hints.ai_flags |= AI_V4MAPPED;
hints.ai_family = af; hints.ai_family = af;
() @trusted { lookup.retcode = getaddrinfo(lookup.name.toStringz(), null, af == AddressFamily.UNSPEC ? null : &hints, &lookup.result); } (); () @trusted { lookup.retcode = getaddrinfo(lookup.name.toStringz(), null, af == AddressFamily.UNSPEC ? null : &hints, &lookup.result); } ();
events.trigger(event, true); events.trigger(event, true);
debug (EventCoreLogDNS) print("lookup %s finished", lookup.name);
} }
override void cancelLookup(DNSLookupID handle) override void cancelLookup(DNSLookupID handle)
@ -956,11 +960,14 @@ final class EventDriverDNS_GAI(Events : EventDriverEvents, Signals : EventDriver
private void onDNSSignal(EventID event) private void onDNSSignal(EventID event)
@trusted nothrow @trusted nothrow
{ {
debug (EventCoreLogDNS) print("DNS event triggered");
m_events.wait(m_event, &onDNSSignal);
size_t lastmax; size_t lastmax;
foreach (i, ref l; m_lookups) { foreach (i, ref l; m_lookups) {
if (i > m_maxHandle) break; if (i > m_maxHandle) break;
if (l.callback) { if (l.callback) {
if (l.result || l.retcode) { if (l.result || l.retcode) {
debug (EventCoreLogDNS) print("found finished lookup %s for %s", i, l.name);
auto cb = l.callback; auto cb = l.callback;
auto ai = l.result; auto ai = l.result;
DNSStatus status; DNSStatus status;
@ -976,7 +983,7 @@ final class EventDriverDNS_GAI(Events : EventDriverEvents, Signals : EventDriver
} else lastmax = i; } else lastmax = i;
} }
} }
m_events.wait(m_event, &onDNSSignal); debug (EventCoreLogDNS) print("Max active DNS handle: %s", m_maxHandle);
} }
private DNSLookupID getFreeHandle() private DNSLookupID getFreeHandle()

1
tests/0-dns.d
View file

@ -1,6 +1,7 @@
/++ dub.sdl: /++ dub.sdl:
name "test" name "test"
dependency "eventcore" path=".." dependency "eventcore" path=".."
debugVersions "EventCoreLogDNS"
+/ +/
module test; module test;