|
@@ -83,7 +83,7 @@ public:
|
|
|
isc::cache::ResolverCache& cache)
|
|
|
{
|
|
|
assert(!rec_query_); // queryShutdown must be called first
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_INIT, RESOLVER_RECQ_SETUP);
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_INIT, RESOLVER_QUERY_SETUP);
|
|
|
rec_query_ = new RecursiveQuery(dnss,
|
|
|
nsas, cache,
|
|
|
upstream_,
|
|
@@ -99,7 +99,8 @@ public:
|
|
|
// (this is not a safety check, just to prevent logging of
|
|
|
// actions that are not performed
|
|
|
if (rec_query_) {
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_INIT, RESOLVER_RECQ_SHUTDOWN);
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_INIT,
|
|
|
+ RESOLVER_QUERY_SHUTDOWN);
|
|
|
delete rec_query_;
|
|
|
rec_query_ = NULL;
|
|
|
}
|
|
@@ -112,7 +113,7 @@ public:
|
|
|
if (dnss) {
|
|
|
if (!upstream_.empty()) {
|
|
|
BOOST_FOREACH(const AddressPair& address, upstream) {
|
|
|
- LOG_INFO(resolver_logger, RESOLVER_FWD_ADDRESS)
|
|
|
+ LOG_INFO(resolver_logger, RESOLVER_FORWARD_ADDRESS)
|
|
|
.arg(address.first).arg(address.second);
|
|
|
}
|
|
|
} else {
|
|
@@ -302,7 +303,8 @@ public:
|
|
|
|
|
|
answer_message->toWire(renderer);
|
|
|
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_DETAIL, RESOLVER_DNS_MSG_SENT)
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_DETAIL,
|
|
|
+ RESOLVER_DNS_MESSAGE_SENT)
|
|
|
.arg(renderer.getLength()).arg(*answer_message);
|
|
|
}
|
|
|
};
|
|
@@ -418,7 +420,7 @@ Resolver::processMessage(const IOMessage& io_message,
|
|
|
server->resume(true);
|
|
|
return;
|
|
|
} catch (const Exception& ex) {
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_IO, RESOLVER_PROTOCOL_ERROR)
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_IO, RESOLVER_MESSAGE_ERROR)
|
|
|
.arg(ex.what()).arg(Rcode::SERVFAIL());
|
|
|
makeErrorMessage(query_message, answer_message,
|
|
|
buffer, Rcode::SERVFAIL());
|
|
@@ -429,8 +431,8 @@ Resolver::processMessage(const IOMessage& io_message,
|
|
|
// Note: there appears to be no LOG_DEBUG for a successfully-received
|
|
|
// message. This is not an oversight - it is handled below. In the
|
|
|
// meantime, output the full message for debug purposes (if requested).
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_DETAIL, RESOLVER_DNS_MSG_RECVD)
|
|
|
- .arg(*query_message);
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_DETAIL,
|
|
|
+ RESOLVER_DNS_MESSAGE_RECEIVED).arg(*query_message);
|
|
|
|
|
|
// Perform further protocol-level validation.
|
|
|
bool sendAnswer = true;
|
|
@@ -439,20 +441,22 @@ Resolver::processMessage(const IOMessage& io_message,
|
|
|
makeErrorMessage(query_message, answer_message,
|
|
|
buffer, Rcode::NOTAUTH());
|
|
|
// Notify arrived, but we are not authoritative.
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_PROCESS, RESOLVER_NOTIFY_RECVD);
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_PROCESS,
|
|
|
+ RESOLVER_NOTIFY_RECEIVED);
|
|
|
|
|
|
} else if (query_message->getOpcode() != Opcode::QUERY()) {
|
|
|
|
|
|
// Unsupported opcode.
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_PROCESS, RESOLVER_UNSUPPORTED_OPCODE)
|
|
|
- .arg(query_message->getOpcode());
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_PROCESS,
|
|
|
+ RESOLVER_UNSUPPORTED_OPCODE).arg(query_message->getOpcode());
|
|
|
makeErrorMessage(query_message, answer_message,
|
|
|
buffer, Rcode::NOTIMP());
|
|
|
|
|
|
} else if (query_message->getRRCount(Message::SECTION_QUESTION) != 1) {
|
|
|
|
|
|
// Not one question
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_PROCESS, RESOLVER_NOT_ONE_QUEST)
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_PROCESS,
|
|
|
+ RESOLVER_NOT_ONE_QUESTION)
|
|
|
.arg(query_message->getRRCount(Message::SECTION_QUESTION));
|
|
|
makeErrorMessage(query_message, answer_message,
|
|
|
buffer, Rcode::FORMERR());
|
|
@@ -525,7 +529,7 @@ ResolverImpl::processNormalQuery(ConstMessagePtr query_message,
|
|
|
} else {
|
|
|
|
|
|
// Processing forward query
|
|
|
- LOG_DEBUG(resolver_logger, RESOLVER_DBG_IO, RESOLVER_FWD_QUERY);
|
|
|
+ LOG_DEBUG(resolver_logger, RESOLVER_DBG_IO, RESOLVER_FORWARD_QUERY);
|
|
|
rec_query_->forward(query_message, answer_message, buffer, server);
|
|
|
}
|
|
|
}
|
|
@@ -560,7 +564,8 @@ Resolver::updateConfig(ConstElementPtr config) {
|
|
|
// check for us
|
|
|
qtimeout = qtimeoutE->intValue();
|
|
|
if (qtimeout < -1) {
|
|
|
- LOG_ERROR(resolver_logger, RESOLVER_QUERY_TMO_SMALL).arg(qtimeout);
|
|
|
+ LOG_ERROR(resolver_logger, RESOLVER_QUERY_TIME_SMALL)
|
|
|
+ .arg(qtimeout);
|
|
|
isc_throw(BadValue, "Query timeout too small");
|
|
|
}
|
|
|
set_timeouts = true;
|
|
@@ -568,7 +573,8 @@ Resolver::updateConfig(ConstElementPtr config) {
|
|
|
if (ctimeoutE) {
|
|
|
ctimeout = ctimeoutE->intValue();
|
|
|
if (ctimeout < -1) {
|
|
|
- LOG_ERROR(resolver_logger, RESOLVER_CLI_TMO_SMALL).arg(ctimeout);
|
|
|
+ LOG_ERROR(resolver_logger, RESOLVER_CLIENT_TIME_SMALL)
|
|
|
+ .arg(ctimeout);
|
|
|
isc_throw(BadValue, "Client timeout too small");
|
|
|
}
|
|
|
set_timeouts = true;
|
|
@@ -576,7 +582,8 @@ Resolver::updateConfig(ConstElementPtr config) {
|
|
|
if (ltimeoutE) {
|
|
|
ltimeout = ltimeoutE->intValue();
|
|
|
if (ltimeout < -1) {
|
|
|
- LOG_ERROR(resolver_logger, RESOLVER_LKUP_TMO_SMALL).arg(ltimeout);
|
|
|
+ LOG_ERROR(resolver_logger, RESOLVER_LOOKUP_TIME_SMALL)
|
|
|
+ .arg(ltimeout);
|
|
|
isc_throw(BadValue, "Lookup timeout too small");
|
|
|
}
|
|
|
set_timeouts = true;
|
|
@@ -586,7 +593,7 @@ Resolver::updateConfig(ConstElementPtr config) {
|
|
|
// _after_ the comparison (as opposed to before it for the timeouts)
|
|
|
// because "retries" is unsigned.
|
|
|
if (retriesE->intValue() < 0) {
|
|
|
- LOG_ERROR(resolver_logger, RESOLVER_NEG_RETRIES)
|
|
|
+ LOG_ERROR(resolver_logger, RESOLVER_NEGATIVE_RETRIES)
|
|
|
.arg(retriesE->intValue());
|
|
|
isc_throw(BadValue, "Negative number of retries");
|
|
|
}
|