|
 |
f4df0f |
From daf723176da7bfee5baae928ff1af310a2400289 Mon Sep 17 00:00:00 2001
|
|
|
f4df0f |
From: Bob Halley <halley@dnspython.org>
|
|
|
f4df0f |
Date: Sun, 21 Feb 2016 15:22:21 -0800
|
|
|
f4df0f |
Subject: [PATCH] Set response_time to zero when exceptions occur early.
|
|
|
f4df0f |
|
|
|
f4df0f |
---
|
|
|
f4df0f |
dns/query.py | 12 ++++++++++--
|
|
|
f4df0f |
1 file changed, 10 insertions(+), 2 deletions(-)
|
|
|
f4df0f |
|
|
|
f4df0f |
diff --git a/dns/query.py b/dns/query.py
|
|
|
f4df0f |
index ad6dffd..4e8089f 100644
|
|
|
f4df0f |
--- a/dns/query.py
|
|
|
f4df0f |
+++ b/dns/query.py
|
|
|
f4df0f |
@@ -204,6 +204,7 @@ def udp(q, where, timeout=None, port=53, af=None, source=None, source_port=0,
|
|
|
f4df0f |
(af, destination, source) = _destination_and_source(af, where, port, source,
|
|
|
f4df0f |
source_port)
|
|
|
f4df0f |
s = socket.socket(af, socket.SOCK_DGRAM, 0)
|
|
|
f4df0f |
+ begin_time = None
|
|
|
f4df0f |
try:
|
|
|
f4df0f |
expiration = _compute_expiration(timeout)
|
|
|
f4df0f |
s.setblocking(0)
|
|
|
f4df0f |
@@ -224,7 +225,10 @@ def udp(q, where, timeout=None, port=53, af=None, source=None, source_port=0,
|
|
|
f4df0f |
'%s instead of %s' % (from_address,
|
|
|
f4df0f |
destination))
|
|
|
f4df0f |
finally:
|
|
|
f4df0f |
- response_time = time.time() - begin_time
|
|
|
f4df0f |
+ if begin_time is None:
|
|
|
f4df0f |
+ response_time = 0
|
|
|
f4df0f |
+ else:
|
|
|
f4df0f |
+ response_time = time.time() - begin_time
|
|
|
f4df0f |
s.close()
|
|
|
f4df0f |
r = dns.message.from_wire(wire, keyring=q.keyring, request_mac=q.mac,
|
|
|
f4df0f |
one_rr_per_rrset=one_rr_per_rrset)
|
|
|
f4df0f |
@@ -301,6 +305,7 @@ def tcp(q, where, timeout=None, port=53, af=None, source=None, source_port=0,
|
|
|
f4df0f |
(af, destination, source) = _destination_and_source(af, where, port, source,
|
|
|
f4df0f |
source_port)
|
|
|
f4df0f |
s = socket.socket(af, socket.SOCK_STREAM, 0)
|
|
|
f4df0f |
+ begin_time = None
|
|
|
f4df0f |
try:
|
|
|
f4df0f |
expiration = _compute_expiration(timeout)
|
|
|
f4df0f |
s.setblocking(0)
|
|
|
f4df0f |
@@ -320,7 +325,10 @@ def tcp(q, where, timeout=None, port=53, af=None, source=None, source_port=0,
|
|
|
f4df0f |
(l,) = struct.unpack("!H", ldata)
|
|
|
f4df0f |
wire = _net_read(s, l, expiration)
|
|
|
f4df0f |
finally:
|
|
|
f4df0f |
- response_time = time.time() - begin_time
|
|
|
f4df0f |
+ if begin_time is None:
|
|
|
f4df0f |
+ response_time = 0
|
|
|
f4df0f |
+ else:
|
|
|
f4df0f |
+ response_time = time.time() - begin_time
|
|
|
f4df0f |
s.close()
|
|
|
f4df0f |
r = dns.message.from_wire(wire, keyring=q.keyring, request_mac=q.mac,
|
|
|
f4df0f |
one_rr_per_rrset=one_rr_per_rrset)
|