UnitTestUtil::createRequestMessage(request_message, Opcode::QUERY(),
default_qid, Name("example.com"),
RRClass::IN(), RRType::NS());
-
+
request_message.setHeaderFlag(Message::HEADERFLAG_AA);
createRequestPacket(request_message, IPPROTO_UDP);
- server.processMessage(*io_message, *parse_message, *response_obuffer, &dnsserv);
+ server.processMessage(*io_message, *parse_message, *response_obuffer,
+ &dnsserv);
EXPECT_NE(request_message.getRcode(), parse_message->getRcode());
}
UnitTestUtil::createRequestMessage(request_message, Opcode::QUERY(),
default_qid, Name("example.com"),
RRClass::IN(), RRType::SOA());
-
+
request_message.setHeaderFlag(Message::HEADERFLAG_AA);
createRequestPacket(request_message, IPPROTO_UDP);
- server.processMessage(*io_message, *parse_message, *response_obuffer, &dnsserv);
+ server.processMessage(*io_message, *parse_message, *response_obuffer,
+ &dnsserv);
ConstQuestionPtr question = *parse_message->beginQuestion();
- EXPECT_STRNE(question->getType().toText().c_str(),RRType::NS().toText().c_str());
+ EXPECT_STRNE(question->getType().toText().c_str(),
+ RRType::NS().toText().c_str());
}
//
// Tests for catching exceptions in various stages of the query processing
}
void addServer(uint16_t port, const asio::ip::address& address,
- const UDPVersion param_flags) {
+ const UDPVersion param_flags)
+ {
try {
- dlog(std::string("Initialize TCP server at ") + address.to_string() + ":" + boost::lexical_cast<std::string>(port));
+ dlog(std::string("Initialize TCP server at ") +
+ address.to_string() + ":" +
+ boost::lexical_cast<std::string>(port));
TCPServerPtr tcpServer(new TCPServer(io_service_.get_io_service(),
- address, port, checkin_, lookup_, answer_));
+ address, port, checkin_,
+ lookup_, answer_));
(*tcpServer)();
servers_.push_back(tcpServer);
- dlog(std::string("Initialize UDP server at ") + address.to_string() + ":" + boost::lexical_cast<std::string>(port));
- // Use param_flags to generate diff UDPServers.
- switch(param_flags) {
- case SYNC_: {
- SyncUDPServerPtr syncUdpServer(new SyncUDPServer(io_service_.get_io_service(),
- address, port, checkin_, lookup_, answer_));
- (*syncUdpServer)();
- servers_.push_back(syncUdpServer);
- break;
- }
- case ASYNC_: {
- UDPServerPtr udpServer(new UDPServer(io_service_.get_io_service(),
- address, port, checkin_, lookup_, answer_));
- (*udpServer)();
- servers_.push_back(udpServer);
- break;
- }
- default:
- // If nerther asyn UDPServer nor sync UDNServer, it throws.
- isc_throw(IOError, "Bad UDPServer Version!");
- break;
+ dlog(std::string("Initialize UDP server at ") +
+ address.to_string() + ":" +
+ boost::lexical_cast<std::string>(port));
+ // Use param_flags to generate diff UDPServers.
+ switch (param_flags) {
+ case SYNC_: {
+ SyncUDPServerPtr syncUdpServer(
+ new SyncUDPServer(io_service_.get_io_service(), address,
+ port, checkin_, lookup_, answer_));
+ (*syncUdpServer)();
+ servers_.push_back(syncUdpServer);
+ break;
}
- }
- catch (const asio::system_error& err) {
+ case ASYNC_: {
+ UDPServerPtr udpServer(
+ new UDPServer(io_service_.get_io_service(), address, port,
+ checkin_, lookup_, answer_));
+ (*udpServer)();
+ servers_.push_back(udpServer);
+ break;
+ }
+ default:
+ // If neither async UDPServer nor sync UDNServer, it throws.
+ isc_throw(IOError, "Bad UDPServer Version!");
+ break;
+ }
+ } catch (const asio::system_error& err) {
// We need to catch and convert any ASIO level exceptions.
// This can happen for unavailable address, binding a privilege port
// without the privilege, etc.
}
}
void addServer(const char& port, const asio::ip::address& address,
- const UDPVersion param_flags) {
+ const UDPVersion param_flags)
+ {
uint16_t portnum;
try {
// XXX: SunStudio with stlport4 doesn't reject some invalid
isc_throw(IOError, "Invalid port number '" << &port << "': " <<
ex.what());
}
- addServer(portnum, address,param_flags);
+ addServer(portnum, address, param_flags);
}
};
{
if (v4addr) {
- addServer(port, *v4addr,param_flags);
+ addServer(port, *v4addr, param_flags);
}
if (v6addr) {
- addServer(port, *v6addr,param_flags);
+ addServer(port, *v6addr, param_flags);
}
}
impl_(new DNSServiceImpl(io_service, port, NULL, NULL, checkin, lookup,
answer,param_flags)), io_service_(io_service)
{
- addServer(port, &address,param_flags);
+ addServer(port, &address, param_flags);
}
DNSService::DNSService(IOService& io_service,
const asio::ip::address v6addr_any =
asio::ip::address(asio::ip::address_v6::any());
const asio::ip::address* const v6addrp = use_ipv6 ? &v6addr_any : NULL;
- impl_ = new DNSServiceImpl(io_service, port, v4addrp, v6addrp, checkin, lookup, answer,param_flags);
+ impl_ = new DNSServiceImpl(io_service, port, v4addrp, v6addrp, checkin,
+ lookup, answer, param_flags);
}
DNSService::DNSService(IOService& io_service, SimpleCallback* checkin,
DNSLookup* lookup, DNSAnswer *answer,const UDPVersion param_flags) :
impl_(new DNSServiceImpl(io_service, *"0", NULL, NULL, checkin, lookup,
- answer,param_flags)), io_service_(io_service)
+ answer, param_flags)), io_service_(io_service)
{
}
}
void
-DNSService::addServer(const char& port, const std::string& address,UDPVersion param_flags) {
- impl_->addServer(port, convertAddr(address),param_flags);
+DNSService::addServer(const char& port, const std::string& address,
+ UDPVersion param_flags)
+{
+ impl_->addServer(port, convertAddr(address), param_flags);
}
void
-DNSService::addServer(uint16_t port, const std::string& address,UDPVersion param_flags) {
- impl_->addServer(port, convertAddr(address),param_flags);
+DNSService::addServer(uint16_t port, const std::string& address,
+ UDPVersion param_flags)
+{
+ impl_->addServer(port, convertAddr(address), param_flags);
}
void DNSService::addServerTCPFromFD(int fd, int af) {
impl_->addServerFromFD<DNSServiceImpl::TCPServerPtr, TCPServer>(fd, af);
}
-void DNSService::addServerUDPFromFD(int fd, int af,const UDPVersion param_flags) {
- if(SYNC_ == param_flags) {
- impl_->addServerFromFD<DNSServiceImpl::SyncUDPServerPtr, SyncUDPServer>(fd, af);
- } else if(ASYNC_ == param_flags) {
- impl_->addServerFromFD<DNSServiceImpl::UDPServerPtr, UDPServer>(fd, af);
+void DNSService::addServerUDPFromFD(int fd, int af,
+ const UDPVersion param_flags)
+{
+ if (SYNC_ == param_flags) {
+ impl_->addServerFromFD<DNSServiceImpl::SyncUDPServerPtr,
+ SyncUDPServer>(fd, af);
+ } else if (ASYNC_ == param_flags) {
+ impl_->addServerFromFD<DNSServiceImpl::UDPServerPtr, UDPServer>(
+ fd, af);
}
}