BIND 10 trac554, updated. 725aa66bb4eea86f29f5f851b4c188b864881e81 [trac554] Added dual socket support Now both tcp and udp are supported in IOFetch
BIND 10 source code commits
bind10-changes at lists.isc.org
Thu Feb 3 21:54:02 UTC 2011
The branch, trac554 has been updated
via 725aa66bb4eea86f29f5f851b4c188b864881e81 (commit)
from 74e4f864d436d960d5feea540e5573cb21dbe39c (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
- Log -----------------------------------------------------------------
commit 725aa66bb4eea86f29f5f851b4c188b864881e81
Author: Scott Mann <smann at isc.org>
Date: Thu Feb 3 14:52:34 2011 -0700
[trac554] Added dual socket support
Now both tcp and udp are supported in IOFetch
-----------------------------------------------------------------------
Summary of changes:
src/lib/asiolink/asiolink.cc | 3 ++-
src/lib/asiolink/iofetch.cc | 12 ++++++------
2 files changed, 8 insertions(+), 7 deletions(-)
-----------------------------------------------------------------------
diff --git a/src/lib/asiolink/asiolink.cc b/src/lib/asiolink/asiolink.cc
index 2caa41f..402eb2a 100644
--- a/src/lib/asiolink/asiolink.cc
+++ b/src/lib/asiolink/asiolink.cc
@@ -581,7 +581,8 @@ public:
InputBuffer ibuf(buffer_->getData(), buffer_->getLength());
incoming.fromWire(ibuf);
- if (message->getHeaderFlag(Message::HEADERFLAG_TC) {
+ if (incoming.getHeaderFlag(Message::HEADERFLAG_TC)) {
+ //truncate bit is set, so retry via tcp
}
diff --git a/src/lib/asiolink/iofetch.cc b/src/lib/asiolink/iofetch.cc
index bda12a4..71d737e 100644
--- a/src/lib/asiolink/iofetch.cc
+++ b/src/lib/asiolink/iofetch.cc
@@ -91,9 +91,7 @@ struct IOFetch::IOFetchProtocol {
callback(c),
stopped(false),
timer(service)
- {
-
- }
+ { }
};
@@ -101,15 +99,17 @@ struct IOFetch::IOFetchProtocol {
/// The following functions implement the \c IOFetch class.
///
/// The constructor
-IOFetch::IOFetch(io_service& io_service,
- const Question& q, const IOAddress& addr, uint16_t port,
- OutputBufferPtr buffer, Callback *callback, int timeout) :
+IOFetch::IOFetch(io_service& io_service, const Question& q,
+ const IOAddress& addr, uint16_t port,
+ OutputBufferPtr buffer, Callback *callback, int timeout) :
data_(new IOFetchProtocol(io_service,
addr.getFamily() == AF_INET ? udp::v4() : udp::v6(),
addr.getFamily() == AF_INET ? tcp::v4() : tcp::v6(),
q, buffer,
callback))
+
{
+ data_->tremote = TCPEndpoint(addr, port).getASIOEndpoint();
data_->remote = UDPEndpoint(addr, port).getASIOEndpoint();
data_->timeout = timeout;
}
More information about the bind10-changes
mailing list