diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/dns.cpp | 17 |
1 files changed, 16 insertions, 1 deletions
diff --git a/src/dns.cpp b/src/dns.cpp index 4a3a0f883..7adbbfe15 100644 --- a/src/dns.cpp +++ b/src/dns.cpp @@ -156,6 +156,7 @@ void dns_close(int fd) { /* close query */ wantclose = 1; return; } + shutdown(fd,2); close(fd); return; } @@ -246,6 +247,7 @@ static s_connection *dns_add_query(s_header *h) { /* build DNS query, add to lis s->fd = socket(PF_INET, SOCK_DGRAM, 0); if (s->fd != -1) { if (fcntl(s->fd, F_SETFL, O_NONBLOCK) != 0) { + shutdown(s->fd,2); close(s->fd); s->fd = -1; } @@ -257,6 +259,7 @@ static s_connection *dns_add_query(s_header *h) { /* build DNS query, add to lis addr.sin_port = 0; addr.sin_addr.s_addr = INADDR_ANY; if (bind(s->fd,(sockaddr *)&addr,sizeof(addr)) != 0) { + shutdown(s->fd,2); close(s->fd); s->fd = -1; } @@ -270,6 +273,7 @@ static s_connection *dns_add_query(s_header *h) { /* build DNS query, add to lis connection_head = s; if (wantclose == 1) { + shutdown(lastcreate,2); close(lastcreate); wantclose = 0; } @@ -281,7 +285,7 @@ static int dns_build_query_payload(const char * const name, const unsigned short short payloadpos; const char * tempchr, * tempchr2; unsigned short l; - + payloadpos = 0; tempchr2 = name; @@ -458,6 +462,7 @@ char* DNS::dns_getresult_s(const int cfd, char *res) { /* retrieve result of DNS c = c->next; } if (c == NULL) { + log(DEBUG,"DNS: got a response for a query we didnt send"); return NULL; /* query not found */ } /* query found-- pull from list: */ @@ -474,22 +479,27 @@ char* DNS::dns_getresult_s(const int cfd, char *res) { /* retrieve result of DNS } dns_fill_header(&h,buffer,l - 12); if (c->id[0] != h.id[0] || c->id[1] != h.id[1]) { + log(DEBUG,"DNS: id mismatch on query"); delete c; return NULL; /* ID mismatch */ } if ((h.flags1 & FLAGS1_MASK_QR) == 0) { + log(DEBUG,"DNS: didnt get a query result"); delete c; return NULL; } if ((h.flags1 & FLAGS1_MASK_OPCODE) != 0) { + log(DEBUG,"DNS: got an OPCODE and didnt want one"); delete c; return NULL; } if ((h.flags2 & FLAGS2_MASK_RCODE) != 0) { + log(DEBUG,"DNS: got an RCODE and didnt want one"); delete c; return NULL; } if (h.ancount < 1) { /* no sense going on if we don't have any answers */ + log(DEBUG,"DNS: no answers!"); delete c; return NULL; } @@ -552,6 +562,7 @@ char* DNS::dns_getresult_s(const int cfd, char *res) { /* retrieve result of DNS switch (rr.type) { case DNS_QRY_PTR: + log(DEBUG,"DNS: got a result of type DNS_QRY_PTR"); o = 0; q = 0; while (q == 0 && i < l && o + 256 < 1023) { @@ -574,6 +585,7 @@ char* DNS::dns_getresult_s(const int cfd, char *res) { /* retrieve result of DNS res[o] = '\0'; break; case DNS_QRY_A: + log(DEBUG,"DNS: got a result of type DNS_QRY_A"); if (c->want_list) { dns_ip4list *alist = (dns_ip4list *) res; /* we have to trust that this is aligned */ while ((char *)alist - (char *)res < 700) { @@ -622,6 +634,7 @@ char* DNS::dns_getresult_s(const int cfd, char *res) { /* retrieve result of DNS break; default: defaultcase: + log(DEBUG,"DNS: doing something with result 'default'"); memcpy(res,&h.payload[i],rr.rdlength); res[rr.rdlength] = '\0'; break; @@ -717,6 +730,7 @@ std::string DNS::GetResultIP() } if (result) { + statsDnsGood++; unsigned char a = (unsigned)result[0]; unsigned char b = (unsigned)result[1]; unsigned char c = (unsigned)result[2]; @@ -726,6 +740,7 @@ std::string DNS::GetResultIP() } else { + statsDnsBad++; log(DEBUG,"DANGER WILL ROBINSON! NXDOMAIN for forward lookup, but we got a reverse lookup!"); return ""; } |