diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-13 12:15:43 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-13 12:15:43 +0000 |
commit | f5f56e1a1c4d9e9496fcb9d81131066a964ccd23 (patch) | |
tree | 49e44c6f87febed37efb953ab5485aa49f6481a7 /src/lib/asiodns | |
parent | Initial commit. (diff) | |
download | isc-kea-f5f56e1a1c4d9e9496fcb9d81131066a964ccd23.tar.xz isc-kea-f5f56e1a1c4d9e9496fcb9d81131066a964ccd23.zip |
Adding upstream version 2.4.1.upstream/2.4.1upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/lib/asiodns')
-rw-r--r-- | src/lib/asiodns/Makefile.am | 72 | ||||
-rw-r--r-- | src/lib/asiodns/Makefile.in | 1022 | ||||
-rw-r--r-- | src/lib/asiodns/README | 154 | ||||
-rw-r--r-- | src/lib/asiodns/asiodns_messages.cc | 73 | ||||
-rw-r--r-- | src/lib/asiodns/asiodns_messages.h | 40 | ||||
-rw-r--r-- | src/lib/asiodns/asiodns_messages.mes | 167 | ||||
-rw-r--r-- | src/lib/asiodns/io_fetch.cc | 402 | ||||
-rw-r--r-- | src/lib/asiodns/io_fetch.h | 246 | ||||
-rw-r--r-- | src/lib/asiodns/logger.cc | 19 | ||||
-rw-r--r-- | src/lib/asiodns/logger.h | 18 | ||||
-rw-r--r-- | src/lib/asiodns/tests/Makefile.am | 43 | ||||
-rw-r--r-- | src/lib/asiodns/tests/Makefile.in | 896 | ||||
-rw-r--r-- | src/lib/asiodns/tests/io_fetch_unittest.cc | 738 | ||||
-rw-r--r-- | src/lib/asiodns/tests/run_unittests.cc | 21 |
14 files changed, 3911 insertions, 0 deletions
diff --git a/src/lib/asiodns/Makefile.am b/src/lib/asiodns/Makefile.am new file mode 100644 index 0000000..2897989 --- /dev/null +++ b/src/lib/asiodns/Makefile.am @@ -0,0 +1,72 @@ +SUBDIRS = . tests + +AM_CPPFLAGS = -I$(top_srcdir)/src/lib -I$(top_builddir)/src/lib +AM_CPPFLAGS += $(BOOST_INCLUDES) + +AM_CXXFLAGS = $(KEA_CXXFLAGS) + +CLEANFILES = *.gcno *.gcda + +lib_LTLIBRARIES = libkea-asiodns.la + +libkea_asiodns_la_LDFLAGS = -no-undefined -version-info 35:0:0 + +libkea_asiodns_la_SOURCES = io_fetch.cc io_fetch.h +libkea_asiodns_la_SOURCES += logger.h logger.cc +libkea_asiodns_la_SOURCES += asiodns_messages.cc asiodns_messages.h + +EXTRA_DIST = asiodns_messages.mes + +# Note: the ordering matters: -Wno-... must follow -Wextra (defined in +# KEA_CXXFLAGS) +libkea_asiodns_la_CXXFLAGS = $(AM_CXXFLAGS) +libkea_asiodns_la_CPPFLAGS = $(AM_CPPFLAGS) +libkea_asiodns_la_LIBADD = $(top_builddir)/src/lib/asiolink/libkea-asiolink.la +libkea_asiodns_la_LIBADD += $(top_builddir)/src/lib/dns/libkea-dns++.la +libkea_asiodns_la_LIBADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la +libkea_asiodns_la_LIBADD += $(top_builddir)/src/lib/log/libkea-log.la +libkea_asiodns_la_LIBADD += $(top_builddir)/src/lib/util/libkea-util.la +libkea_asiodns_la_LIBADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la +libkea_asiodns_la_LIBADD += $(BOOST_LIBS) +libkea_asiodns_la_LIBADD += $(LOG4CPLUS_LIBS) + +# If we want to get rid of all generated messages files, we need to use +# make maintainer-clean. The proper way to introduce custom commands for +# that operation is to define maintainer-clean-local target. However, +# make maintainer-clean also removes Makefile, so running configure script +# is required. To make it easy to rebuild messages without going through +# reconfigure, a new target messages-clean has been added. +maintainer-clean-local: + rm -f asiodns_messages.h asiodns_messages.cc + +# To regenerate messages files, one can do: +# +# make messages-clean +# make messages +# +# This is needed only when a .mes file is modified. +messages-clean: maintainer-clean-local + +if GENERATE_MESSAGES + +# Define rule to build logging source files from message file +messages: asiodns_messages.h asiodns_messages.cc + @echo Message files regenerated + +asiodns_messages.h asiodns_messages.cc: asiodns_messages.mes + $(top_builddir)/src/lib/log/compiler/kea-msg-compiler $(top_srcdir)/src/lib/asiodns/asiodns_messages.mes + +else + +messages asiodns_messages.h asiodns_messages.cc: + @echo Messages generation disabled. Configure with --enable-generate-messages to enable it. + +endif + +# Specify the headers for copying into the installation directory tree. +libkea_asiodns_includedir = $(pkgincludedir)/asiodns +libkea_asiodns_include_HEADERS = \ + asiodns_messages.h \ + io_fetch.h \ + logger.h + diff --git a/src/lib/asiodns/Makefile.in b/src/lib/asiodns/Makefile.in new file mode 100644 index 0000000..dda9b26 --- /dev/null +++ b/src/lib/asiodns/Makefile.in @@ -0,0 +1,1022 @@ +# Makefile.in generated by automake 1.16.1 from Makefile.am. +# @configure_input@ + +# Copyright (C) 1994-2018 Free Software Foundation, Inc. + +# This Makefile.in is free software; the Free Software Foundation +# gives unlimited permission to copy and/or distribute it, +# with or without modifications, as long as this notice is preserved. + +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY, to the extent permitted by law; without +# even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. + +@SET_MAKE@ + + +VPATH = @srcdir@ +am__is_gnu_make = { \ + if test -z '$(MAKELEVEL)'; then \ + false; \ + elif test -n '$(MAKE_HOST)'; then \ + true; \ + elif test -n '$(MAKE_VERSION)' && test -n '$(CURDIR)'; then \ + true; \ + else \ + false; \ + fi; \ +} +am__make_running_with_option = \ + case $${target_option-} in \ + ?) ;; \ + *) echo "am__make_running_with_option: internal error: invalid" \ + "target option '$${target_option-}' specified" >&2; \ + exit 1;; \ + esac; \ + has_opt=no; \ + sane_makeflags=$$MAKEFLAGS; \ + if $(am__is_gnu_make); then \ + sane_makeflags=$$MFLAGS; \ + else \ + case $$MAKEFLAGS in \ + *\\[\ \ ]*) \ + bs=\\; \ + sane_makeflags=`printf '%s\n' "$$MAKEFLAGS" \ + | sed "s/$$bs$$bs[$$bs $$bs ]*//g"`;; \ + esac; \ + fi; \ + skip_next=no; \ + strip_trailopt () \ + { \ + flg=`printf '%s\n' "$$flg" | sed "s/$$1.*$$//"`; \ + }; \ + for flg in $$sane_makeflags; do \ + test $$skip_next = yes && { skip_next=no; continue; }; \ + case $$flg in \ + *=*|--*) continue;; \ + -*I) strip_trailopt 'I'; skip_next=yes;; \ + -*I?*) strip_trailopt 'I';; \ + -*O) strip_trailopt 'O'; skip_next=yes;; \ + -*O?*) strip_trailopt 'O';; \ + -*l) strip_trailopt 'l'; skip_next=yes;; \ + -*l?*) strip_trailopt 'l';; \ + -[dEDm]) skip_next=yes;; \ + -[JT]) skip_next=yes;; \ + esac; \ + case $$flg in \ + *$$target_option*) has_opt=yes; break;; \ + esac; \ + done; \ + test $$has_opt = yes +am__make_dryrun = (target_option=n; $(am__make_running_with_option)) +am__make_keepgoing = (target_option=k; $(am__make_running_with_option)) +pkgdatadir = $(datadir)/@PACKAGE@ +pkgincludedir = $(includedir)/@PACKAGE@ +pkglibdir = $(libdir)/@PACKAGE@ +pkglibexecdir = $(libexecdir)/@PACKAGE@ +am__cd = CDPATH="$${ZSH_VERSION+.}$(PATH_SEPARATOR)" && cd +install_sh_DATA = $(install_sh) -c -m 644 +install_sh_PROGRAM = $(install_sh) -c +install_sh_SCRIPT = $(install_sh) -c +INSTALL_HEADER = $(INSTALL_DATA) +transform = $(program_transform_name) +NORMAL_INSTALL = : +PRE_INSTALL = : +POST_INSTALL = : +NORMAL_UNINSTALL = : +PRE_UNINSTALL = : +POST_UNINSTALL = : +build_triplet = @build@ +host_triplet = @host@ +subdir = src/lib/asiodns +ACLOCAL_M4 = $(top_srcdir)/aclocal.m4 +am__aclocal_m4_deps = $(top_srcdir)/m4macros/ax_boost_for_kea.m4 \ + $(top_srcdir)/m4macros/ax_cpp11.m4 \ + $(top_srcdir)/m4macros/ax_cpp20.m4 \ + $(top_srcdir)/m4macros/ax_crypto.m4 \ + $(top_srcdir)/m4macros/ax_find_library.m4 \ + $(top_srcdir)/m4macros/ax_gssapi.m4 \ + $(top_srcdir)/m4macros/ax_gtest.m4 \ + $(top_srcdir)/m4macros/ax_isc_rpath.m4 \ + $(top_srcdir)/m4macros/ax_netconf.m4 \ + $(top_srcdir)/m4macros/libtool.m4 \ + $(top_srcdir)/m4macros/ltoptions.m4 \ + $(top_srcdir)/m4macros/ltsugar.m4 \ + $(top_srcdir)/m4macros/ltversion.m4 \ + $(top_srcdir)/m4macros/lt~obsolete.m4 \ + $(top_srcdir)/configure.ac +am__configure_deps = $(am__aclocal_m4_deps) $(CONFIGURE_DEPENDENCIES) \ + $(ACLOCAL_M4) +DIST_COMMON = $(srcdir)/Makefile.am $(libkea_asiodns_include_HEADERS) \ + $(am__DIST_COMMON) +mkinstalldirs = $(install_sh) -d +CONFIG_HEADER = $(top_builddir)/config.h +CONFIG_CLEAN_FILES = +CONFIG_CLEAN_VPATH_FILES = +am__vpath_adj_setup = srcdirstrip=`echo "$(srcdir)" | sed 's|.|.|g'`; +am__vpath_adj = case $$p in \ + $(srcdir)/*) f=`echo "$$p" | sed "s|^$$srcdirstrip/||"`;; \ + *) f=$$p;; \ + esac; +am__strip_dir = f=`echo $$p | sed -e 's|^.*/||'`; +am__install_max = 40 +am__nobase_strip_setup = \ + srcdirstrip=`echo "$(srcdir)" | sed 's/[].[^$$\\*|]/\\\\&/g'` +am__nobase_strip = \ + for p in $$list; do echo "$$p"; done | sed -e "s|$$srcdirstrip/||" +am__nobase_list = $(am__nobase_strip_setup); \ + for p in $$list; do echo "$$p $$p"; done | \ + sed "s| $$srcdirstrip/| |;"' / .*\//!s/ .*/ ./; s,\( .*\)/[^/]*$$,\1,' | \ + $(AWK) 'BEGIN { files["."] = "" } { files[$$2] = files[$$2] " " $$1; \ + if (++n[$$2] == $(am__install_max)) \ + { print $$2, files[$$2]; n[$$2] = 0; files[$$2] = "" } } \ + END { for (dir in files) print dir, files[dir] }' +am__base_list = \ + sed '$$!N;$$!N;$$!N;$$!N;$$!N;$$!N;$$!N;s/\n/ /g' | \ + sed '$$!N;$$!N;$$!N;$$!N;s/\n/ /g' +am__uninstall_files_from_dir = { \ + test -z "$$files" \ + || { test ! -d "$$dir" && test ! -f "$$dir" && test ! -r "$$dir"; } \ + || { echo " ( cd '$$dir' && rm -f" $$files ")"; \ + $(am__cd) "$$dir" && rm -f $$files; }; \ + } +am__installdirs = "$(DESTDIR)$(libdir)" \ + "$(DESTDIR)$(libkea_asiodns_includedir)" +LTLIBRARIES = $(lib_LTLIBRARIES) +am__DEPENDENCIES_1 = +libkea_asiodns_la_DEPENDENCIES = \ + $(top_builddir)/src/lib/asiolink/libkea-asiolink.la \ + $(top_builddir)/src/lib/dns/libkea-dns++.la \ + $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la \ + $(top_builddir)/src/lib/log/libkea-log.la \ + $(top_builddir)/src/lib/util/libkea-util.la \ + $(top_builddir)/src/lib/exceptions/libkea-exceptions.la \ + $(am__DEPENDENCIES_1) $(am__DEPENDENCIES_1) +am_libkea_asiodns_la_OBJECTS = libkea_asiodns_la-io_fetch.lo \ + libkea_asiodns_la-logger.lo \ + libkea_asiodns_la-asiodns_messages.lo +libkea_asiodns_la_OBJECTS = $(am_libkea_asiodns_la_OBJECTS) +AM_V_lt = $(am__v_lt_@AM_V@) +am__v_lt_ = $(am__v_lt_@AM_DEFAULT_V@) +am__v_lt_0 = --silent +am__v_lt_1 = +libkea_asiodns_la_LINK = $(LIBTOOL) $(AM_V_lt) --tag=CXX \ + $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=link $(CXXLD) \ + $(libkea_asiodns_la_CXXFLAGS) $(CXXFLAGS) \ + $(libkea_asiodns_la_LDFLAGS) $(LDFLAGS) -o $@ +AM_V_P = $(am__v_P_@AM_V@) +am__v_P_ = $(am__v_P_@AM_DEFAULT_V@) +am__v_P_0 = false +am__v_P_1 = : +AM_V_GEN = $(am__v_GEN_@AM_V@) +am__v_GEN_ = $(am__v_GEN_@AM_DEFAULT_V@) +am__v_GEN_0 = @echo " GEN " $@; +am__v_GEN_1 = +AM_V_at = $(am__v_at_@AM_V@) +am__v_at_ = $(am__v_at_@AM_DEFAULT_V@) +am__v_at_0 = @ +am__v_at_1 = +DEFAULT_INCLUDES = -I.@am__isrc@ -I$(top_builddir) +depcomp = $(SHELL) $(top_srcdir)/depcomp +am__maybe_remake_depfiles = depfiles +am__depfiles_remade = \ + ./$(DEPDIR)/libkea_asiodns_la-asiodns_messages.Plo \ + ./$(DEPDIR)/libkea_asiodns_la-io_fetch.Plo \ + ./$(DEPDIR)/libkea_asiodns_la-logger.Plo +am__mv = mv -f +CXXCOMPILE = $(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) \ + $(AM_CPPFLAGS) $(CPPFLAGS) $(AM_CXXFLAGS) $(CXXFLAGS) +LTCXXCOMPILE = $(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) \ + $(LIBTOOLFLAGS) --mode=compile $(CXX) $(DEFS) \ + $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) \ + $(AM_CXXFLAGS) $(CXXFLAGS) +AM_V_CXX = $(am__v_CXX_@AM_V@) +am__v_CXX_ = $(am__v_CXX_@AM_DEFAULT_V@) +am__v_CXX_0 = @echo " CXX " $@; +am__v_CXX_1 = +CXXLD = $(CXX) +CXXLINK = $(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) \ + $(LIBTOOLFLAGS) --mode=link $(CXXLD) $(AM_CXXFLAGS) \ + $(CXXFLAGS) $(AM_LDFLAGS) $(LDFLAGS) -o $@ +AM_V_CXXLD = $(am__v_CXXLD_@AM_V@) +am__v_CXXLD_ = $(am__v_CXXLD_@AM_DEFAULT_V@) +am__v_CXXLD_0 = @echo " CXXLD " $@; +am__v_CXXLD_1 = +COMPILE = $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) \ + $(CPPFLAGS) $(AM_CFLAGS) $(CFLAGS) +LTCOMPILE = $(LIBTOOL) $(AM_V_lt) --tag=CC $(AM_LIBTOOLFLAGS) \ + $(LIBTOOLFLAGS) --mode=compile $(CC) $(DEFS) \ + $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) \ + $(AM_CFLAGS) $(CFLAGS) +AM_V_CC = $(am__v_CC_@AM_V@) +am__v_CC_ = $(am__v_CC_@AM_DEFAULT_V@) +am__v_CC_0 = @echo " CC " $@; +am__v_CC_1 = +CCLD = $(CC) +LINK = $(LIBTOOL) $(AM_V_lt) --tag=CC $(AM_LIBTOOLFLAGS) \ + $(LIBTOOLFLAGS) --mode=link $(CCLD) $(AM_CFLAGS) $(CFLAGS) \ + $(AM_LDFLAGS) $(LDFLAGS) -o $@ +AM_V_CCLD = $(am__v_CCLD_@AM_V@) +am__v_CCLD_ = $(am__v_CCLD_@AM_DEFAULT_V@) +am__v_CCLD_0 = @echo " CCLD " $@; +am__v_CCLD_1 = +SOURCES = $(libkea_asiodns_la_SOURCES) +DIST_SOURCES = $(libkea_asiodns_la_SOURCES) +RECURSIVE_TARGETS = all-recursive check-recursive cscopelist-recursive \ + ctags-recursive dvi-recursive html-recursive info-recursive \ + install-data-recursive install-dvi-recursive \ + install-exec-recursive install-html-recursive \ + install-info-recursive install-pdf-recursive \ + install-ps-recursive install-recursive installcheck-recursive \ + installdirs-recursive pdf-recursive ps-recursive \ + tags-recursive uninstall-recursive +am__can_run_installinfo = \ + case $$AM_UPDATE_INFO_DIR in \ + n|no|NO) false;; \ + *) (install-info --version) >/dev/null 2>&1;; \ + esac +HEADERS = $(libkea_asiodns_include_HEADERS) +RECURSIVE_CLEAN_TARGETS = mostlyclean-recursive clean-recursive \ + distclean-recursive maintainer-clean-recursive +am__recursive_targets = \ + $(RECURSIVE_TARGETS) \ + $(RECURSIVE_CLEAN_TARGETS) \ + $(am__extra_recursive_targets) +AM_RECURSIVE_TARGETS = $(am__recursive_targets:-recursive=) TAGS CTAGS \ + distdir distdir-am +am__tagged_files = $(HEADERS) $(SOURCES) $(TAGS_FILES) $(LISP) +# Read a list of newline-separated strings from the standard input, +# and print each of them once, without duplicates. Input order is +# *not* preserved. +am__uniquify_input = $(AWK) '\ + BEGIN { nonempty = 0; } \ + { items[$$0] = 1; nonempty = 1; } \ + END { if (nonempty) { for (i in items) print i; }; } \ +' +# Make sure the list of sources is unique. This is necessary because, +# e.g., the same source file might be shared among _SOURCES variables +# for different programs/libraries. +am__define_uniq_tagged_files = \ + list='$(am__tagged_files)'; \ + unique=`for i in $$list; do \ + if test -f "$$i"; then echo $$i; else echo $(srcdir)/$$i; fi; \ + done | $(am__uniquify_input)` +ETAGS = etags +CTAGS = ctags +DIST_SUBDIRS = $(SUBDIRS) +am__DIST_COMMON = $(srcdir)/Makefile.in $(top_srcdir)/depcomp README +DISTFILES = $(DIST_COMMON) $(DIST_SOURCES) $(TEXINFOS) $(EXTRA_DIST) +am__relativize = \ + dir0=`pwd`; \ + sed_first='s,^\([^/]*\)/.*$$,\1,'; \ + sed_rest='s,^[^/]*/*,,'; \ + sed_last='s,^.*/\([^/]*\)$$,\1,'; \ + sed_butlast='s,/*[^/]*$$,,'; \ + while test -n "$$dir1"; do \ + first=`echo "$$dir1" | sed -e "$$sed_first"`; \ + if test "$$first" != "."; then \ + if test "$$first" = ".."; then \ + dir2=`echo "$$dir0" | sed -e "$$sed_last"`/"$$dir2"; \ + dir0=`echo "$$dir0" | sed -e "$$sed_butlast"`; \ + else \ + first2=`echo "$$dir2" | sed -e "$$sed_first"`; \ + if test "$$first2" = "$$first"; then \ + dir2=`echo "$$dir2" | sed -e "$$sed_rest"`; \ + else \ + dir2="../$$dir2"; \ + fi; \ + dir0="$$dir0"/"$$first"; \ + fi; \ + fi; \ + dir1=`echo "$$dir1" | sed -e "$$sed_rest"`; \ + done; \ + reldir="$$dir2" +ACLOCAL = @ACLOCAL@ +AMTAR = @AMTAR@ +AM_DEFAULT_VERBOSITY = @AM_DEFAULT_VERBOSITY@ +AR = @AR@ +ASCIIDOC = @ASCIIDOC@ +AUTOCONF = @AUTOCONF@ +AUTOHEADER = @AUTOHEADER@ +AUTOMAKE = @AUTOMAKE@ +AWK = @AWK@ +BOOST_INCLUDES = @BOOST_INCLUDES@ +BOOST_LIBS = @BOOST_LIBS@ +BOTAN_TOOL = @BOTAN_TOOL@ +CC = @CC@ +CCDEPMODE = @CCDEPMODE@ +CFLAGS = @CFLAGS@ +CONTRIB_DIR = @CONTRIB_DIR@ +CPP = @CPP@ +CPPFLAGS = @CPPFLAGS@ +CRYPTO_CFLAGS = @CRYPTO_CFLAGS@ +CRYPTO_INCLUDES = @CRYPTO_INCLUDES@ +CRYPTO_LDFLAGS = @CRYPTO_LDFLAGS@ +CRYPTO_LIBS = @CRYPTO_LIBS@ +CRYPTO_PACKAGE = @CRYPTO_PACKAGE@ +CRYPTO_RPATH = @CRYPTO_RPATH@ +CXX = @CXX@ +CXXCPP = @CXXCPP@ +CXXDEPMODE = @CXXDEPMODE@ +CXXFLAGS = @CXXFLAGS@ +CYGPATH_W = @CYGPATH_W@ +DEFS = @DEFS@ +DEPDIR = @DEPDIR@ +DISTCHECK_BOOST_CONFIGURE_FLAG = @DISTCHECK_BOOST_CONFIGURE_FLAG@ +DISTCHECK_CONTRIB_CONFIGURE_FLAG = @DISTCHECK_CONTRIB_CONFIGURE_FLAG@ +DISTCHECK_CRYPTO_CONFIGURE_FLAG = @DISTCHECK_CRYPTO_CONFIGURE_FLAG@ +DISTCHECK_GSSAPI_CONFIGURE_FLAG = @DISTCHECK_GSSAPI_CONFIGURE_FLAG@ +DISTCHECK_GTEST_CONFIGURE_FLAG = @DISTCHECK_GTEST_CONFIGURE_FLAG@ +DISTCHECK_KEA_SHELL_CONFIGURE_FLAG = @DISTCHECK_KEA_SHELL_CONFIGURE_FLAG@ +DISTCHECK_LIBYANGCPP_CONFIGURE_FLAG = @DISTCHECK_LIBYANGCPP_CONFIGURE_FLAG@ +DISTCHECK_LIBYANG_CONFIGURE_FLAG = @DISTCHECK_LIBYANG_CONFIGURE_FLAG@ +DISTCHECK_LOG4CPLUS_CONFIGURE_FLAG = @DISTCHECK_LOG4CPLUS_CONFIGURE_FLAG@ +DISTCHECK_MYSQL_CONFIGURE_FLAG = @DISTCHECK_MYSQL_CONFIGURE_FLAG@ +DISTCHECK_PERFDHCP_CONFIGURE_FLAG = @DISTCHECK_PERFDHCP_CONFIGURE_FLAG@ +DISTCHECK_PGSQL_CONFIGURE_FLAG = @DISTCHECK_PGSQL_CONFIGURE_FLAG@ +DISTCHECK_PREMIUM_CONFIGURE_FLAG = @DISTCHECK_PREMIUM_CONFIGURE_FLAG@ +DISTCHECK_SYSREPOCPP_CONFIGURE_FLAG = @DISTCHECK_SYSREPOCPP_CONFIGURE_FLAG@ +DISTCHECK_SYSREPO_CONFIGURE_FLAG = @DISTCHECK_SYSREPO_CONFIGURE_FLAG@ +DLLTOOL = @DLLTOOL@ +DSYMUTIL = @DSYMUTIL@ +DUMPBIN = @DUMPBIN@ +ECHO_C = @ECHO_C@ +ECHO_N = @ECHO_N@ +ECHO_T = @ECHO_T@ +EGREP = @EGREP@ +EXEEXT = @EXEEXT@ +FGREP = @FGREP@ +GENHTML = @GENHTML@ +GREP = @GREP@ +GSSAPI_CFLAGS = @GSSAPI_CFLAGS@ +GSSAPI_LIBS = @GSSAPI_LIBS@ +GTEST_CONFIG = @GTEST_CONFIG@ +GTEST_INCLUDES = @GTEST_INCLUDES@ +GTEST_LDADD = @GTEST_LDADD@ +GTEST_LDFLAGS = @GTEST_LDFLAGS@ +GTEST_SOURCE = @GTEST_SOURCE@ +HAVE_NETCONF = @HAVE_NETCONF@ +INSTALL = @INSTALL@ +INSTALL_DATA = @INSTALL_DATA@ +INSTALL_PROGRAM = @INSTALL_PROGRAM@ +INSTALL_SCRIPT = @INSTALL_SCRIPT@ +INSTALL_STRIP_PROGRAM = @INSTALL_STRIP_PROGRAM@ +KEA_CXXFLAGS = @KEA_CXXFLAGS@ +KEA_SRCID = @KEA_SRCID@ +KRB5_CONFIG = @KRB5_CONFIG@ +LCOV = @LCOV@ +LD = @LD@ +LDFLAGS = @LDFLAGS@ +LEX = @LEX@ +LEXLIB = @LEXLIB@ +LEX_OUTPUT_ROOT = @LEX_OUTPUT_ROOT@ +LIBOBJS = @LIBOBJS@ +LIBS = @LIBS@ +LIBTOOL = @LIBTOOL@ +LIBYANGCPP_CPPFLAGS = @LIBYANGCPP_CPPFLAGS@ +LIBYANGCPP_INCLUDEDIR = @LIBYANGCPP_INCLUDEDIR@ +LIBYANGCPP_LIBS = @LIBYANGCPP_LIBS@ +LIBYANGCPP_PREFIX = @LIBYANGCPP_PREFIX@ +LIBYANGCPP_VERSION = @LIBYANGCPP_VERSION@ +LIBYANG_CPPFLAGS = @LIBYANG_CPPFLAGS@ +LIBYANG_INCLUDEDIR = @LIBYANG_INCLUDEDIR@ +LIBYANG_LIBS = @LIBYANG_LIBS@ +LIBYANG_PREFIX = @LIBYANG_PREFIX@ +LIBYANG_VERSION = @LIBYANG_VERSION@ +LIPO = @LIPO@ +LN_S = @LN_S@ +LOG4CPLUS_INCLUDES = @LOG4CPLUS_INCLUDES@ +LOG4CPLUS_LIBS = @LOG4CPLUS_LIBS@ +LTLIBOBJS = @LTLIBOBJS@ +LT_SYS_LIBRARY_PATH = @LT_SYS_LIBRARY_PATH@ +MAKEINFO = @MAKEINFO@ +MANIFEST_TOOL = @MANIFEST_TOOL@ +MKDIR_P = @MKDIR_P@ +MYSQL_CPPFLAGS = @MYSQL_CPPFLAGS@ +MYSQL_LIBS = @MYSQL_LIBS@ +NM = @NM@ +NMEDIT = @NMEDIT@ +OBJDUMP = @OBJDUMP@ +OBJEXT = @OBJEXT@ +OTOOL = @OTOOL@ +OTOOL64 = @OTOOL64@ +PACKAGE = @PACKAGE@ +PACKAGE_BUGREPORT = @PACKAGE_BUGREPORT@ +PACKAGE_NAME = @PACKAGE_NAME@ +PACKAGE_STRING = @PACKAGE_STRING@ +PACKAGE_TARNAME = @PACKAGE_TARNAME@ +PACKAGE_URL = @PACKAGE_URL@ +PACKAGE_VERSION = @PACKAGE_VERSION@ +PACKAGE_VERSION_TYPE = @PACKAGE_VERSION_TYPE@ +PATH_SEPARATOR = @PATH_SEPARATOR@ +PDFLATEX = @PDFLATEX@ +PERL = @PERL@ +PGSQL_CPPFLAGS = @PGSQL_CPPFLAGS@ +PGSQL_LIBS = @PGSQL_LIBS@ +PKGPYTHONDIR = @PKGPYTHONDIR@ +PKG_CONFIG = @PKG_CONFIG@ +PLANTUML = @PLANTUML@ +PREMIUM_DIR = @PREMIUM_DIR@ +PYTHON = @PYTHON@ +PYTHON_EXEC_PREFIX = @PYTHON_EXEC_PREFIX@ +PYTHON_PLATFORM = @PYTHON_PLATFORM@ +PYTHON_PREFIX = @PYTHON_PREFIX@ +PYTHON_VERSION = @PYTHON_VERSION@ +RANLIB = @RANLIB@ +SED = @SED@ +SEP = @SEP@ +SET_MAKE = @SET_MAKE@ +SHELL = @SHELL@ +SPHINXBUILD = @SPHINXBUILD@ +SRPD_PLUGINS_PATH = @SRPD_PLUGINS_PATH@ +SR_PLUGINS_PATH = @SR_PLUGINS_PATH@ +SR_REPO_PATH = @SR_REPO_PATH@ +STRIP = @STRIP@ +SYSREPOCPP_CPPFLAGS = @SYSREPOCPP_CPPFLAGS@ +SYSREPOCPP_INCLUDEDIR = @SYSREPOCPP_INCLUDEDIR@ +SYSREPOCPP_LIBS = @SYSREPOCPP_LIBS@ +SYSREPOCPP_PREFIX = @SYSREPOCPP_PREFIX@ +SYSREPOCPP_VERSION = @SYSREPOCPP_VERSION@ +SYSREPO_CPPFLAGS = @SYSREPO_CPPFLAGS@ +SYSREPO_INCLUDEDIR = @SYSREPO_INCLUDEDIR@ +SYSREPO_LIBS = @SYSREPO_LIBS@ +SYSREPO_PREFIX = @SYSREPO_PREFIX@ +SYSREPO_VERSION = @SYSREPO_VERSION@ +USE_LCOV = @USE_LCOV@ +VALGRIND = @VALGRIND@ +VERSION = @VERSION@ +WARNING_GCC_44_STRICT_ALIASING_CFLAG = @WARNING_GCC_44_STRICT_ALIASING_CFLAG@ +YACC = @YACC@ +abs_builddir = @abs_builddir@ +abs_srcdir = @abs_srcdir@ +abs_top_builddir = @abs_top_builddir@ +abs_top_srcdir = @abs_top_srcdir@ +ac_ct_AR = @ac_ct_AR@ +ac_ct_CC = @ac_ct_CC@ +ac_ct_CXX = @ac_ct_CXX@ +ac_ct_DUMPBIN = @ac_ct_DUMPBIN@ +am__include = @am__include@ +am__leading_dot = @am__leading_dot@ +am__quote = @am__quote@ +am__tar = @am__tar@ +am__untar = @am__untar@ +bindir = @bindir@ +build = @build@ +build_alias = @build_alias@ +build_cpu = @build_cpu@ +build_os = @build_os@ +build_vendor = @build_vendor@ +builddir = @builddir@ +datadir = @datadir@ +datarootdir = @datarootdir@ +docdir = @docdir@ +dvidir = @dvidir@ +exec_prefix = @exec_prefix@ +host = @host@ +host_alias = @host_alias@ +host_cpu = @host_cpu@ +host_os = @host_os@ +host_vendor = @host_vendor@ +htmldir = @htmldir@ +includedir = @includedir@ +infodir = @infodir@ +install_sh = @install_sh@ +libdir = @libdir@ +libexecdir = @libexecdir@ +localedir = @localedir@ +localstatedir = @localstatedir@ +mandir = @mandir@ +mkdir_p = @mkdir_p@ +oldincludedir = @oldincludedir@ +pdfdir = @pdfdir@ +pkgpyexecdir = @pkgpyexecdir@ +pkgpythondir = @pkgpythondir@ +prefix = @prefix@ +program_transform_name = @program_transform_name@ +psdir = @psdir@ +pyexecdir = @pyexecdir@ +pythondir = @pythondir@ +runstatedir = @runstatedir@ +sbindir = @sbindir@ +sharedstatedir = @sharedstatedir@ +srcdir = @srcdir@ +sysconfdir = @sysconfdir@ +target_alias = @target_alias@ +top_build_prefix = @top_build_prefix@ +top_builddir = @top_builddir@ +top_srcdir = @top_srcdir@ +SUBDIRS = . tests +AM_CPPFLAGS = -I$(top_srcdir)/src/lib -I$(top_builddir)/src/lib \ + $(BOOST_INCLUDES) +AM_CXXFLAGS = $(KEA_CXXFLAGS) +CLEANFILES = *.gcno *.gcda +lib_LTLIBRARIES = libkea-asiodns.la +libkea_asiodns_la_LDFLAGS = -no-undefined -version-info 35:0:0 +libkea_asiodns_la_SOURCES = io_fetch.cc io_fetch.h logger.h logger.cc \ + asiodns_messages.cc asiodns_messages.h +EXTRA_DIST = asiodns_messages.mes + +# Note: the ordering matters: -Wno-... must follow -Wextra (defined in +# KEA_CXXFLAGS) +libkea_asiodns_la_CXXFLAGS = $(AM_CXXFLAGS) +libkea_asiodns_la_CPPFLAGS = $(AM_CPPFLAGS) +libkea_asiodns_la_LIBADD = \ + $(top_builddir)/src/lib/asiolink/libkea-asiolink.la \ + $(top_builddir)/src/lib/dns/libkea-dns++.la \ + $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la \ + $(top_builddir)/src/lib/log/libkea-log.la \ + $(top_builddir)/src/lib/util/libkea-util.la \ + $(top_builddir)/src/lib/exceptions/libkea-exceptions.la \ + $(BOOST_LIBS) $(LOG4CPLUS_LIBS) + +# Specify the headers for copying into the installation directory tree. +libkea_asiodns_includedir = $(pkgincludedir)/asiodns +libkea_asiodns_include_HEADERS = \ + asiodns_messages.h \ + io_fetch.h \ + logger.h + +all: all-recursive + +.SUFFIXES: +.SUFFIXES: .cc .lo .o .obj +$(srcdir)/Makefile.in: $(srcdir)/Makefile.am $(am__configure_deps) + @for dep in $?; do \ + case '$(am__configure_deps)' in \ + *$$dep*) \ + ( cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh ) \ + && { if test -f $@; then exit 0; else break; fi; }; \ + exit 1;; \ + esac; \ + done; \ + echo ' cd $(top_srcdir) && $(AUTOMAKE) --foreign src/lib/asiodns/Makefile'; \ + $(am__cd) $(top_srcdir) && \ + $(AUTOMAKE) --foreign src/lib/asiodns/Makefile +Makefile: $(srcdir)/Makefile.in $(top_builddir)/config.status + @case '$?' in \ + *config.status*) \ + cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh;; \ + *) \ + echo ' cd $(top_builddir) && $(SHELL) ./config.status $(subdir)/$@ $(am__maybe_remake_depfiles)'; \ + cd $(top_builddir) && $(SHELL) ./config.status $(subdir)/$@ $(am__maybe_remake_depfiles);; \ + esac; + +$(top_builddir)/config.status: $(top_srcdir)/configure $(CONFIG_STATUS_DEPENDENCIES) + cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh + +$(top_srcdir)/configure: $(am__configure_deps) + cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh +$(ACLOCAL_M4): $(am__aclocal_m4_deps) + cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh +$(am__aclocal_m4_deps): + +install-libLTLIBRARIES: $(lib_LTLIBRARIES) + @$(NORMAL_INSTALL) + @list='$(lib_LTLIBRARIES)'; test -n "$(libdir)" || list=; \ + list2=; for p in $$list; do \ + if test -f $$p; then \ + list2="$$list2 $$p"; \ + else :; fi; \ + done; \ + test -z "$$list2" || { \ + echo " $(MKDIR_P) '$(DESTDIR)$(libdir)'"; \ + $(MKDIR_P) "$(DESTDIR)$(libdir)" || exit 1; \ + echo " $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=install $(INSTALL) $(INSTALL_STRIP_FLAG) $$list2 '$(DESTDIR)$(libdir)'"; \ + $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=install $(INSTALL) $(INSTALL_STRIP_FLAG) $$list2 "$(DESTDIR)$(libdir)"; \ + } + +uninstall-libLTLIBRARIES: + @$(NORMAL_UNINSTALL) + @list='$(lib_LTLIBRARIES)'; test -n "$(libdir)" || list=; \ + for p in $$list; do \ + $(am__strip_dir) \ + echo " $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=uninstall rm -f '$(DESTDIR)$(libdir)/$$f'"; \ + $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=uninstall rm -f "$(DESTDIR)$(libdir)/$$f"; \ + done + +clean-libLTLIBRARIES: + -test -z "$(lib_LTLIBRARIES)" || rm -f $(lib_LTLIBRARIES) + @list='$(lib_LTLIBRARIES)'; \ + locs=`for p in $$list; do echo $$p; done | \ + sed 's|^[^/]*$$|.|; s|/[^/]*$$||; s|$$|/so_locations|' | \ + sort -u`; \ + test -z "$$locs" || { \ + echo rm -f $${locs}; \ + rm -f $${locs}; \ + } + +libkea-asiodns.la: $(libkea_asiodns_la_OBJECTS) $(libkea_asiodns_la_DEPENDENCIES) $(EXTRA_libkea_asiodns_la_DEPENDENCIES) + $(AM_V_CXXLD)$(libkea_asiodns_la_LINK) -rpath $(libdir) $(libkea_asiodns_la_OBJECTS) $(libkea_asiodns_la_LIBADD) $(LIBS) + +mostlyclean-compile: + -rm -f *.$(OBJEXT) + +distclean-compile: + -rm -f *.tab.c + +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libkea_asiodns_la-asiodns_messages.Plo@am__quote@ # am--include-marker +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libkea_asiodns_la-io_fetch.Plo@am__quote@ # am--include-marker +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libkea_asiodns_la-logger.Plo@am__quote@ # am--include-marker + +$(am__depfiles_remade): + @$(MKDIR_P) $(@D) + @echo '# dummy' >$@-t && $(am__mv) $@-t $@ + +am--depfiles: $(am__depfiles_remade) + +.cc.o: +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(CXXCOMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ $< +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Po +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='$<' object='$@' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(CXXCOMPILE) -c -o $@ $< + +.cc.obj: +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(CXXCOMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ `$(CYGPATH_W) '$<'` +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Po +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='$<' object='$@' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(CXXCOMPILE) -c -o $@ `$(CYGPATH_W) '$<'` + +.cc.lo: +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(LTCXXCOMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ $< +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Plo +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='$<' object='$@' libtool=yes @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(LTCXXCOMPILE) -c -o $@ $< + +libkea_asiodns_la-io_fetch.lo: io_fetch.cc +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=compile $(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(libkea_asiodns_la_CPPFLAGS) $(CPPFLAGS) $(libkea_asiodns_la_CXXFLAGS) $(CXXFLAGS) -MT libkea_asiodns_la-io_fetch.lo -MD -MP -MF $(DEPDIR)/libkea_asiodns_la-io_fetch.Tpo -c -o libkea_asiodns_la-io_fetch.lo `test -f 'io_fetch.cc' || echo '$(srcdir)/'`io_fetch.cc +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/libkea_asiodns_la-io_fetch.Tpo $(DEPDIR)/libkea_asiodns_la-io_fetch.Plo +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='io_fetch.cc' object='libkea_asiodns_la-io_fetch.lo' libtool=yes @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=compile $(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(libkea_asiodns_la_CPPFLAGS) $(CPPFLAGS) $(libkea_asiodns_la_CXXFLAGS) $(CXXFLAGS) -c -o libkea_asiodns_la-io_fetch.lo `test -f 'io_fetch.cc' || echo '$(srcdir)/'`io_fetch.cc + +libkea_asiodns_la-logger.lo: logger.cc +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=compile $(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(libkea_asiodns_la_CPPFLAGS) $(CPPFLAGS) $(libkea_asiodns_la_CXXFLAGS) $(CXXFLAGS) -MT libkea_asiodns_la-logger.lo -MD -MP -MF $(DEPDIR)/libkea_asiodns_la-logger.Tpo -c -o libkea_asiodns_la-logger.lo `test -f 'logger.cc' || echo '$(srcdir)/'`logger.cc +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/libkea_asiodns_la-logger.Tpo $(DEPDIR)/libkea_asiodns_la-logger.Plo +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='logger.cc' object='libkea_asiodns_la-logger.lo' libtool=yes @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=compile $(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(libkea_asiodns_la_CPPFLAGS) $(CPPFLAGS) $(libkea_asiodns_la_CXXFLAGS) $(CXXFLAGS) -c -o libkea_asiodns_la-logger.lo `test -f 'logger.cc' || echo '$(srcdir)/'`logger.cc + +libkea_asiodns_la-asiodns_messages.lo: asiodns_messages.cc +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=compile $(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(libkea_asiodns_la_CPPFLAGS) $(CPPFLAGS) $(libkea_asiodns_la_CXXFLAGS) $(CXXFLAGS) -MT libkea_asiodns_la-asiodns_messages.lo -MD -MP -MF $(DEPDIR)/libkea_asiodns_la-asiodns_messages.Tpo -c -o libkea_asiodns_la-asiodns_messages.lo `test -f 'asiodns_messages.cc' || echo '$(srcdir)/'`asiodns_messages.cc +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/libkea_asiodns_la-asiodns_messages.Tpo $(DEPDIR)/libkea_asiodns_la-asiodns_messages.Plo +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='asiodns_messages.cc' object='libkea_asiodns_la-asiodns_messages.lo' libtool=yes @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=compile $(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(libkea_asiodns_la_CPPFLAGS) $(CPPFLAGS) $(libkea_asiodns_la_CXXFLAGS) $(CXXFLAGS) -c -o libkea_asiodns_la-asiodns_messages.lo `test -f 'asiodns_messages.cc' || echo '$(srcdir)/'`asiodns_messages.cc + +mostlyclean-libtool: + -rm -f *.lo + +clean-libtool: + -rm -rf .libs _libs +install-libkea_asiodns_includeHEADERS: $(libkea_asiodns_include_HEADERS) + @$(NORMAL_INSTALL) + @list='$(libkea_asiodns_include_HEADERS)'; test -n "$(libkea_asiodns_includedir)" || list=; \ + if test -n "$$list"; then \ + echo " $(MKDIR_P) '$(DESTDIR)$(libkea_asiodns_includedir)'"; \ + $(MKDIR_P) "$(DESTDIR)$(libkea_asiodns_includedir)" || exit 1; \ + fi; \ + for p in $$list; do \ + if test -f "$$p"; then d=; else d="$(srcdir)/"; fi; \ + echo "$$d$$p"; \ + done | $(am__base_list) | \ + while read files; do \ + echo " $(INSTALL_HEADER) $$files '$(DESTDIR)$(libkea_asiodns_includedir)'"; \ + $(INSTALL_HEADER) $$files "$(DESTDIR)$(libkea_asiodns_includedir)" || exit $$?; \ + done + +uninstall-libkea_asiodns_includeHEADERS: + @$(NORMAL_UNINSTALL) + @list='$(libkea_asiodns_include_HEADERS)'; test -n "$(libkea_asiodns_includedir)" || list=; \ + files=`for p in $$list; do echo $$p; done | sed -e 's|^.*/||'`; \ + dir='$(DESTDIR)$(libkea_asiodns_includedir)'; $(am__uninstall_files_from_dir) + +# This directory's subdirectories are mostly independent; you can cd +# into them and run 'make' without going through this Makefile. +# To change the values of 'make' variables: instead of editing Makefiles, +# (1) if the variable is set in 'config.status', edit 'config.status' +# (which will cause the Makefiles to be regenerated when you run 'make'); +# (2) otherwise, pass the desired values on the 'make' command line. +$(am__recursive_targets): + @fail=; \ + if $(am__make_keepgoing); then \ + failcom='fail=yes'; \ + else \ + failcom='exit 1'; \ + fi; \ + dot_seen=no; \ + target=`echo $@ | sed s/-recursive//`; \ + case "$@" in \ + distclean-* | maintainer-clean-*) list='$(DIST_SUBDIRS)' ;; \ + *) list='$(SUBDIRS)' ;; \ + esac; \ + for subdir in $$list; do \ + echo "Making $$target in $$subdir"; \ + if test "$$subdir" = "."; then \ + dot_seen=yes; \ + local_target="$$target-am"; \ + else \ + local_target="$$target"; \ + fi; \ + ($(am__cd) $$subdir && $(MAKE) $(AM_MAKEFLAGS) $$local_target) \ + || eval $$failcom; \ + done; \ + if test "$$dot_seen" = "no"; then \ + $(MAKE) $(AM_MAKEFLAGS) "$$target-am" || exit 1; \ + fi; test -z "$$fail" + +ID: $(am__tagged_files) + $(am__define_uniq_tagged_files); mkid -fID $$unique +tags: tags-recursive +TAGS: tags + +tags-am: $(TAGS_DEPENDENCIES) $(am__tagged_files) + set x; \ + here=`pwd`; \ + if ($(ETAGS) --etags-include --version) >/dev/null 2>&1; then \ + include_option=--etags-include; \ + empty_fix=.; \ + else \ + include_option=--include; \ + empty_fix=; \ + fi; \ + list='$(SUBDIRS)'; for subdir in $$list; do \ + if test "$$subdir" = .; then :; else \ + test ! -f $$subdir/TAGS || \ + set "$$@" "$$include_option=$$here/$$subdir/TAGS"; \ + fi; \ + done; \ + $(am__define_uniq_tagged_files); \ + shift; \ + if test -z "$(ETAGS_ARGS)$$*$$unique"; then :; else \ + test -n "$$unique" || unique=$$empty_fix; \ + if test $$# -gt 0; then \ + $(ETAGS) $(ETAGSFLAGS) $(AM_ETAGSFLAGS) $(ETAGS_ARGS) \ + "$$@" $$unique; \ + else \ + $(ETAGS) $(ETAGSFLAGS) $(AM_ETAGSFLAGS) $(ETAGS_ARGS) \ + $$unique; \ + fi; \ + fi +ctags: ctags-recursive + +CTAGS: ctags +ctags-am: $(TAGS_DEPENDENCIES) $(am__tagged_files) + $(am__define_uniq_tagged_files); \ + test -z "$(CTAGS_ARGS)$$unique" \ + || $(CTAGS) $(CTAGSFLAGS) $(AM_CTAGSFLAGS) $(CTAGS_ARGS) \ + $$unique + +GTAGS: + here=`$(am__cd) $(top_builddir) && pwd` \ + && $(am__cd) $(top_srcdir) \ + && gtags -i $(GTAGS_ARGS) "$$here" +cscopelist: cscopelist-recursive + +cscopelist-am: $(am__tagged_files) + list='$(am__tagged_files)'; \ + case "$(srcdir)" in \ + [\\/]* | ?:[\\/]*) sdir="$(srcdir)" ;; \ + *) sdir=$(subdir)/$(srcdir) ;; \ + esac; \ + for i in $$list; do \ + if test -f "$$i"; then \ + echo "$(subdir)/$$i"; \ + else \ + echo "$$sdir/$$i"; \ + fi; \ + done >> $(top_builddir)/cscope.files + +distclean-tags: + -rm -f TAGS ID GTAGS GRTAGS GSYMS GPATH tags + +distdir: $(BUILT_SOURCES) + $(MAKE) $(AM_MAKEFLAGS) distdir-am + +distdir-am: $(DISTFILES) + @srcdirstrip=`echo "$(srcdir)" | sed 's/[].[^$$\\*]/\\\\&/g'`; \ + topsrcdirstrip=`echo "$(top_srcdir)" | sed 's/[].[^$$\\*]/\\\\&/g'`; \ + list='$(DISTFILES)'; \ + dist_files=`for file in $$list; do echo $$file; done | \ + sed -e "s|^$$srcdirstrip/||;t" \ + -e "s|^$$topsrcdirstrip/|$(top_builddir)/|;t"`; \ + case $$dist_files in \ + */*) $(MKDIR_P) `echo "$$dist_files" | \ + sed '/\//!d;s|^|$(distdir)/|;s,/[^/]*$$,,' | \ + sort -u` ;; \ + esac; \ + for file in $$dist_files; do \ + if test -f $$file || test -d $$file; then d=.; else d=$(srcdir); fi; \ + if test -d $$d/$$file; then \ + dir=`echo "/$$file" | sed -e 's,/[^/]*$$,,'`; \ + if test -d "$(distdir)/$$file"; then \ + find "$(distdir)/$$file" -type d ! -perm -700 -exec chmod u+rwx {} \;; \ + fi; \ + if test -d $(srcdir)/$$file && test $$d != $(srcdir); then \ + cp -fpR $(srcdir)/$$file "$(distdir)$$dir" || exit 1; \ + find "$(distdir)/$$file" -type d ! -perm -700 -exec chmod u+rwx {} \;; \ + fi; \ + cp -fpR $$d/$$file "$(distdir)$$dir" || exit 1; \ + else \ + test -f "$(distdir)/$$file" \ + || cp -p $$d/$$file "$(distdir)/$$file" \ + || exit 1; \ + fi; \ + done + @list='$(DIST_SUBDIRS)'; for subdir in $$list; do \ + if test "$$subdir" = .; then :; else \ + $(am__make_dryrun) \ + || test -d "$(distdir)/$$subdir" \ + || $(MKDIR_P) "$(distdir)/$$subdir" \ + || exit 1; \ + dir1=$$subdir; dir2="$(distdir)/$$subdir"; \ + $(am__relativize); \ + new_distdir=$$reldir; \ + dir1=$$subdir; dir2="$(top_distdir)"; \ + $(am__relativize); \ + new_top_distdir=$$reldir; \ + echo " (cd $$subdir && $(MAKE) $(AM_MAKEFLAGS) top_distdir="$$new_top_distdir" distdir="$$new_distdir" \\"; \ + echo " am__remove_distdir=: am__skip_length_check=: am__skip_mode_fix=: distdir)"; \ + ($(am__cd) $$subdir && \ + $(MAKE) $(AM_MAKEFLAGS) \ + top_distdir="$$new_top_distdir" \ + distdir="$$new_distdir" \ + am__remove_distdir=: \ + am__skip_length_check=: \ + am__skip_mode_fix=: \ + distdir) \ + || exit 1; \ + fi; \ + done +check-am: all-am +check: check-recursive +all-am: Makefile $(LTLIBRARIES) $(HEADERS) +installdirs: installdirs-recursive +installdirs-am: + for dir in "$(DESTDIR)$(libdir)" "$(DESTDIR)$(libkea_asiodns_includedir)"; do \ + test -z "$$dir" || $(MKDIR_P) "$$dir"; \ + done +install: install-recursive +install-exec: install-exec-recursive +install-data: install-data-recursive +uninstall: uninstall-recursive + +install-am: all-am + @$(MAKE) $(AM_MAKEFLAGS) install-exec-am install-data-am + +installcheck: installcheck-recursive +install-strip: + if test -z '$(STRIP)'; then \ + $(MAKE) $(AM_MAKEFLAGS) INSTALL_PROGRAM="$(INSTALL_STRIP_PROGRAM)" \ + install_sh_PROGRAM="$(INSTALL_STRIP_PROGRAM)" INSTALL_STRIP_FLAG=-s \ + install; \ + else \ + $(MAKE) $(AM_MAKEFLAGS) INSTALL_PROGRAM="$(INSTALL_STRIP_PROGRAM)" \ + install_sh_PROGRAM="$(INSTALL_STRIP_PROGRAM)" INSTALL_STRIP_FLAG=-s \ + "INSTALL_PROGRAM_ENV=STRIPPROG='$(STRIP)'" install; \ + fi +mostlyclean-generic: + +clean-generic: + -test -z "$(CLEANFILES)" || rm -f $(CLEANFILES) + +distclean-generic: + -test -z "$(CONFIG_CLEAN_FILES)" || rm -f $(CONFIG_CLEAN_FILES) + -test . = "$(srcdir)" || test -z "$(CONFIG_CLEAN_VPATH_FILES)" || rm -f $(CONFIG_CLEAN_VPATH_FILES) + +maintainer-clean-generic: + @echo "This command is intended for maintainers to use" + @echo "it deletes files that may require special tools to rebuild." +clean: clean-recursive + +clean-am: clean-generic clean-libLTLIBRARIES clean-libtool \ + mostlyclean-am + +distclean: distclean-recursive + -rm -f ./$(DEPDIR)/libkea_asiodns_la-asiodns_messages.Plo + -rm -f ./$(DEPDIR)/libkea_asiodns_la-io_fetch.Plo + -rm -f ./$(DEPDIR)/libkea_asiodns_la-logger.Plo + -rm -f Makefile +distclean-am: clean-am distclean-compile distclean-generic \ + distclean-tags + +dvi: dvi-recursive + +dvi-am: + +html: html-recursive + +html-am: + +info: info-recursive + +info-am: + +install-data-am: install-libkea_asiodns_includeHEADERS + +install-dvi: install-dvi-recursive + +install-dvi-am: + +install-exec-am: install-libLTLIBRARIES + +install-html: install-html-recursive + +install-html-am: + +install-info: install-info-recursive + +install-info-am: + +install-man: + +install-pdf: install-pdf-recursive + +install-pdf-am: + +install-ps: install-ps-recursive + +install-ps-am: + +installcheck-am: + +maintainer-clean: maintainer-clean-recursive + -rm -f ./$(DEPDIR)/libkea_asiodns_la-asiodns_messages.Plo + -rm -f ./$(DEPDIR)/libkea_asiodns_la-io_fetch.Plo + -rm -f ./$(DEPDIR)/libkea_asiodns_la-logger.Plo + -rm -f Makefile +maintainer-clean-am: distclean-am maintainer-clean-generic \ + maintainer-clean-local + +mostlyclean: mostlyclean-recursive + +mostlyclean-am: mostlyclean-compile mostlyclean-generic \ + mostlyclean-libtool + +pdf: pdf-recursive + +pdf-am: + +ps: ps-recursive + +ps-am: + +uninstall-am: uninstall-libLTLIBRARIES \ + uninstall-libkea_asiodns_includeHEADERS + +.MAKE: $(am__recursive_targets) install-am install-strip + +.PHONY: $(am__recursive_targets) CTAGS GTAGS TAGS all all-am \ + am--depfiles check check-am clean clean-generic \ + clean-libLTLIBRARIES clean-libtool cscopelist-am ctags \ + ctags-am distclean distclean-compile distclean-generic \ + distclean-libtool distclean-tags distdir dvi dvi-am html \ + html-am info info-am install install-am install-data \ + install-data-am install-dvi install-dvi-am install-exec \ + install-exec-am install-html install-html-am install-info \ + install-info-am install-libLTLIBRARIES \ + install-libkea_asiodns_includeHEADERS install-man install-pdf \ + install-pdf-am install-ps install-ps-am install-strip \ + installcheck installcheck-am installdirs installdirs-am \ + maintainer-clean maintainer-clean-generic \ + maintainer-clean-local mostlyclean mostlyclean-compile \ + mostlyclean-generic mostlyclean-libtool pdf pdf-am ps ps-am \ + tags tags-am uninstall uninstall-am uninstall-libLTLIBRARIES \ + uninstall-libkea_asiodns_includeHEADERS + +.PRECIOUS: Makefile + + +# If we want to get rid of all generated messages files, we need to use +# make maintainer-clean. The proper way to introduce custom commands for +# that operation is to define maintainer-clean-local target. However, +# make maintainer-clean also removes Makefile, so running configure script +# is required. To make it easy to rebuild messages without going through +# reconfigure, a new target messages-clean has been added. +maintainer-clean-local: + rm -f asiodns_messages.h asiodns_messages.cc + +# To regenerate messages files, one can do: +# +# make messages-clean +# make messages +# +# This is needed only when a .mes file is modified. +messages-clean: maintainer-clean-local + +# Define rule to build logging source files from message file +@GENERATE_MESSAGES_TRUE@messages: asiodns_messages.h asiodns_messages.cc +@GENERATE_MESSAGES_TRUE@ @echo Message files regenerated + +@GENERATE_MESSAGES_TRUE@asiodns_messages.h asiodns_messages.cc: asiodns_messages.mes +@GENERATE_MESSAGES_TRUE@ $(top_builddir)/src/lib/log/compiler/kea-msg-compiler $(top_srcdir)/src/lib/asiodns/asiodns_messages.mes + +@GENERATE_MESSAGES_FALSE@messages asiodns_messages.h asiodns_messages.cc: +@GENERATE_MESSAGES_FALSE@ @echo Messages generation disabled. Configure with --enable-generate-messages to enable it. + +# Tell versions [3.59,3.63) of GNU make to not export all variables. +# Otherwise a system limit (for SysV at least) may be exceeded. +.NOEXPORT: diff --git a/src/lib/asiodns/README b/src/lib/asiodns/README new file mode 100644 index 0000000..e785845 --- /dev/null +++ b/src/lib/asiodns/README @@ -0,0 +1,154 @@ +The asiodns library is intended to provide an abstraction layer between +BIND10 modules and asiolink library. + +These DNS server and client routines are written using the "stackless +coroutine" pattern invented by Chris Kohlhoff and described at +http://blog.think-async.com/2010/03/potted-guide-to-stackless-coroutines.html. +This is intended to simplify development a bit, since it allows the +routines to be written in a straightforward step-step-step fashion rather +than as a complex chain of separate handler functions. + +Coroutine objects (i.e., UDPServer, TCPServer and IOFetch) are objects +with reentrant operator() members. When an instance of one of these +classes is called as a function, it resumes at the position where it left +off. Thus, a UDPServer can issue an asynchronous I/O call and specify +itself as the handler object; when the call completes, the UDPServer +carries on at the same position. As a result, the code can look as +if it were using synchronous, not asynchronous, I/O, providing some of +the benefit of threading but with minimal switching overhead. + +So, in simplified form, the behavior of a DNS Server is: + + REENTER: + while true: + YIELD packet = read_packet + FORK + if not parent: + break + + YIELD answer = DNSLookup(packet, this) + response = DNSAnswer(answer) + YIELD send(response) + +At each "YIELD" point, the coroutine initiates an asynchronous operation, +then pauses and turns over control to some other task on the ASIO service +queue. When the operation completes, the coroutine resumes. + +DNSLookup and DNSAnswer define callback methods +used by a DNS Server to communicate with the module that called it. +They are abstract-only classes whose concrete implementations +are supplied by the calling module. + +The DNSLookup callback always runs asynchronously. Concrete +implementations must be sure to call the server's "resume" method when +it is finished. + +In an authoritative server, the DNSLookup implementation would examine +the query, look up the answer, then call "resume". (See the diagram +in doc/auth_process.jpg.) + +In a recursive server, the DNSLookup implementation would initiate a +DNSQuery, which in turn would be responsible for calling the server's +"resume" method. (See the diagram in doc/recursive_process.jpg.) + +A DNSQuery object is intended to handle resolution of a query over +the network when the local authoritative data sources or cache are not +sufficient. The plan is that it will make use of subsidiary DNSFetch +calls to get data from particular authoritative servers, and when it has +gotten a complete answer, it calls "resume". + +In current form, however, DNSQuery is much simpler; it forwards queries +to a single upstream resolver and passes the answers back to the client. +It is constructed with the address of the forward server. Queries are +initiated with the question to ask the forward server, a buffer into +which to write the answer, and a pointer to the coroutine to be resumed +when the answer has arrived. In simplified form, the DNSQuery routine is: + + REENTER: + render the question into a wire-format query packet + YIELD send(query) + YIELD response = read_packet + server->resume + +Currently, DNSQuery is only implemented for UDP queries. In future work +it will be necessary to write code to fall back to TCP when circumstances +require it. + + +Upstream Fetches +================ +Upstream fetches (queries by the resolver on behalf of a client) are made +using a slightly-modified version of the pattern described above. + +Sockets +------- +First, it will be useful to understand the class hierarchy used in the +fetch logic: + + IOSocket + | + IOAsioSocket + | + +-----+-----+ + | | +UDPSocket TCPSocket + +IOSocket is a wrapper class for a socket and is used by the authoritative +server code. It is an abstract base class, providing little more that the ability to hold the socket and to return the protocol in use. + +Built on this is IOAsioSocket, which adds the open, close, asyncSend and +asyncReceive methods. This is a template class, which takes as template +argument the class of the object that will be used as the callback when the +asynchronous operation completes. This object can be of any type, but must +include an operator() method with the signature: + + operator()(boost::system::error_code ec, size_t length) + +... the two arguments being the status of the completed I/O operation and +the number of bytes transferred. (In the case of the open method, the second +argument will be zero.) + +Finally, the TCPSocket and UDPSocket classes provide the body of the +asynchronous operations. + +Fetch Sequence +-------------- +The fetch is implemented by the IOFetch class, which takes as argument the +protocol to use. The sequence is: + + REENTER: + render the question into a wire-format query packet + open() // Open socket and optionally connect + if (! synchronous) { + YIELD; + } + YIELD asyncSend(query) // Send query + do { + YIELD asyncReceive(response) // Read response + } while (! complete(response)) + close() // Drop connection and close socket + server->resume + +The open() method opens a socket for use. On TCP, it also makes a +connection to the remote end. So under UDP the operation will complete +immediately, but under TCP it could take a long time. One solution would be +for the open operation to post an event to the I/O queue; then both cases +could be regarded as being equivalent, with the completion being signalled +by the posting of the completion event. However UDP is the most common case +and that would involve extra overhead. So the open() returns a status +indicating whether the operation completed asynchronously. If it did, the +code yields back to the coroutine; if not the yield is bypassed. + +The asynchronous send is straightforward, invoking the underlying ASIO +function. (Note that the address/port is supplied to both the open() and +asyncSend() methods - it is used by the TCPSocket in open() and by the +UDPSocket in asyncSend().) + +The asyncReceive() method issues an asynchronous read and waits for completion. +The fetch object keeps track of the amount of data received so far and when +the receive completes it calls a method on the socket to determine if the +entire message has been received. (This will always be the case for UDP. On +TCP though, the message is preceded by a count field as several reads may be +required to read all the data.) The fetch loops until all the data is read. + +Finally, the socket is closed and the server called to resume operation. diff --git a/src/lib/asiodns/asiodns_messages.cc b/src/lib/asiodns/asiodns_messages.cc new file mode 100644 index 0000000..7900294 --- /dev/null +++ b/src/lib/asiodns/asiodns_messages.cc @@ -0,0 +1,73 @@ +// File created from ../../../src/lib/asiodns/asiodns_messages.mes + +#include <cstddef> +#include <log/message_types.h> +#include <log/message_initializer.h> + +namespace isc { +namespace asiodns { + +extern const isc::log::MessageID ASIODNS_FD_ADD_TCP = "ASIODNS_FD_ADD_TCP"; +extern const isc::log::MessageID ASIODNS_FD_ADD_UDP = "ASIODNS_FD_ADD_UDP"; +extern const isc::log::MessageID ASIODNS_FETCH_COMPLETED = "ASIODNS_FETCH_COMPLETED"; +extern const isc::log::MessageID ASIODNS_FETCH_STOPPED = "ASIODNS_FETCH_STOPPED"; +extern const isc::log::MessageID ASIODNS_OPEN_SOCKET = "ASIODNS_OPEN_SOCKET"; +extern const isc::log::MessageID ASIODNS_READ_DATA = "ASIODNS_READ_DATA"; +extern const isc::log::MessageID ASIODNS_READ_TIMEOUT = "ASIODNS_READ_TIMEOUT"; +extern const isc::log::MessageID ASIODNS_SEND_DATA = "ASIODNS_SEND_DATA"; +extern const isc::log::MessageID ASIODNS_SYNC_UDP_CLOSE_FAIL = "ASIODNS_SYNC_UDP_CLOSE_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_ACCEPT_FAIL = "ASIODNS_TCP_ACCEPT_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_CLEANUP_CLOSE_FAIL = "ASIODNS_TCP_CLEANUP_CLOSE_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_CLOSE_ACCEPTOR_FAIL = "ASIODNS_TCP_CLOSE_ACCEPTOR_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_CLOSE_FAIL = "ASIODNS_TCP_CLOSE_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_CLOSE_NORESP_FAIL = "ASIODNS_TCP_CLOSE_NORESP_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_GETREMOTE_FAIL = "ASIODNS_TCP_GETREMOTE_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_READDATA_FAIL = "ASIODNS_TCP_READDATA_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_READLEN_FAIL = "ASIODNS_TCP_READLEN_FAIL"; +extern const isc::log::MessageID ASIODNS_TCP_WRITE_FAIL = "ASIODNS_TCP_WRITE_FAIL"; +extern const isc::log::MessageID ASIODNS_UDP_ASYNC_SEND_FAIL = "ASIODNS_UDP_ASYNC_SEND_FAIL"; +extern const isc::log::MessageID ASIODNS_UDP_CLOSE_FAIL = "ASIODNS_UDP_CLOSE_FAIL"; +extern const isc::log::MessageID ASIODNS_UDP_RECEIVE_FAIL = "ASIODNS_UDP_RECEIVE_FAIL"; +extern const isc::log::MessageID ASIODNS_UDP_SYNC_RECEIVE_FAIL = "ASIODNS_UDP_SYNC_RECEIVE_FAIL"; +extern const isc::log::MessageID ASIODNS_UDP_SYNC_SEND_FAIL = "ASIODNS_UDP_SYNC_SEND_FAIL"; +extern const isc::log::MessageID ASIODNS_UNKNOWN_ORIGIN = "ASIODNS_UNKNOWN_ORIGIN"; +extern const isc::log::MessageID ASIODNS_UNKNOWN_RESULT = "ASIODNS_UNKNOWN_RESULT"; + +} // namespace asiodns +} // namespace isc + +namespace { + +const char* values[] = { + "ASIODNS_FD_ADD_TCP", "adding a new TCP server by opened fd %1", + "ASIODNS_FD_ADD_UDP", "adding a new UDP server by opened fd %1", + "ASIODNS_FETCH_COMPLETED", "upstream fetch to %1(%2) has now completed", + "ASIODNS_FETCH_STOPPED", "upstream fetch to %1(%2) has been stopped", + "ASIODNS_OPEN_SOCKET", "error %1 opening %2 socket to %3(%4)", + "ASIODNS_READ_DATA", "error %1 reading %2 data from %3(%4)", + "ASIODNS_READ_TIMEOUT", "receive timeout while waiting for data from %1(%2)", + "ASIODNS_SEND_DATA", "error %1 sending data using %2 to %3(%4)", + "ASIODNS_SYNC_UDP_CLOSE_FAIL", "failed to close a DNS/UDP socket: %1", + "ASIODNS_TCP_ACCEPT_FAIL", "failed to accept TCP DNS connection: %1", + "ASIODNS_TCP_CLEANUP_CLOSE_FAIL", "failed to close a DNS/TCP socket on port cleanup: %1", + "ASIODNS_TCP_CLOSE_ACCEPTOR_FAIL", "failed to close listening TCP socket: %1", + "ASIODNS_TCP_CLOSE_FAIL", "failed to close DNS/TCP socket with a client: %1", + "ASIODNS_TCP_CLOSE_NORESP_FAIL", "failed to close DNS/TCP socket with a client: %1", + "ASIODNS_TCP_GETREMOTE_FAIL", "failed to get remote address of a DNS TCP connection: %1", + "ASIODNS_TCP_READDATA_FAIL", "failed to get DNS data on a TCP socket: %1", + "ASIODNS_TCP_READLEN_FAIL", "failed to get DNS data length on a TCP socket: %1", + "ASIODNS_TCP_WRITE_FAIL", "failed to send DNS message over a TCP socket: %1", + "ASIODNS_UDP_ASYNC_SEND_FAIL", "Error sending UDP packet to %1: %2", + "ASIODNS_UDP_CLOSE_FAIL", "failed to close a DNS/UDP socket: %1", + "ASIODNS_UDP_RECEIVE_FAIL", "failed to receive UDP DNS packet: %1", + "ASIODNS_UDP_SYNC_RECEIVE_FAIL", "failed to receive UDP DNS packet: %1", + "ASIODNS_UDP_SYNC_SEND_FAIL", "Error sending UDP packet to %1: %2", + "ASIODNS_UNKNOWN_ORIGIN", "unknown origin for ASIO error code %1 (protocol: %2, address %3)", + "ASIODNS_UNKNOWN_RESULT", "unknown result (%1) when IOFetch::stop() was executed for I/O to %2(%3)", + NULL +}; + +const isc::log::MessageInitializer initializer(values); + +} // Anonymous namespace + diff --git a/src/lib/asiodns/asiodns_messages.h b/src/lib/asiodns/asiodns_messages.h new file mode 100644 index 0000000..b3dab48 --- /dev/null +++ b/src/lib/asiodns/asiodns_messages.h @@ -0,0 +1,40 @@ +// File created from ../../../src/lib/asiodns/asiodns_messages.mes + +#ifndef ASIODNS_MESSAGES_H +#define ASIODNS_MESSAGES_H + +#include <log/message_types.h> + +namespace isc { +namespace asiodns { + +extern const isc::log::MessageID ASIODNS_FD_ADD_TCP; +extern const isc::log::MessageID ASIODNS_FD_ADD_UDP; +extern const isc::log::MessageID ASIODNS_FETCH_COMPLETED; +extern const isc::log::MessageID ASIODNS_FETCH_STOPPED; +extern const isc::log::MessageID ASIODNS_OPEN_SOCKET; +extern const isc::log::MessageID ASIODNS_READ_DATA; +extern const isc::log::MessageID ASIODNS_READ_TIMEOUT; +extern const isc::log::MessageID ASIODNS_SEND_DATA; +extern const isc::log::MessageID ASIODNS_SYNC_UDP_CLOSE_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_ACCEPT_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_CLEANUP_CLOSE_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_CLOSE_ACCEPTOR_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_CLOSE_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_CLOSE_NORESP_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_GETREMOTE_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_READDATA_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_READLEN_FAIL; +extern const isc::log::MessageID ASIODNS_TCP_WRITE_FAIL; +extern const isc::log::MessageID ASIODNS_UDP_ASYNC_SEND_FAIL; +extern const isc::log::MessageID ASIODNS_UDP_CLOSE_FAIL; +extern const isc::log::MessageID ASIODNS_UDP_RECEIVE_FAIL; +extern const isc::log::MessageID ASIODNS_UDP_SYNC_RECEIVE_FAIL; +extern const isc::log::MessageID ASIODNS_UDP_SYNC_SEND_FAIL; +extern const isc::log::MessageID ASIODNS_UNKNOWN_ORIGIN; +extern const isc::log::MessageID ASIODNS_UNKNOWN_RESULT; + +} // namespace asiodns +} // namespace isc + +#endif // ASIODNS_MESSAGES_H diff --git a/src/lib/asiodns/asiodns_messages.mes b/src/lib/asiodns/asiodns_messages.mes new file mode 100644 index 0000000..1f7f35e --- /dev/null +++ b/src/lib/asiodns/asiodns_messages.mes @@ -0,0 +1,167 @@ +# Copyright (C) 2011-2015 Internet Systems Consortium, Inc. ("ISC") +# +# This Source Code Form is subject to the terms of the Mozilla Public +# License, v. 2.0. If a copy of the MPL was not distributed with this +# file, You can obtain one at http://mozilla.org/MPL/2.0/. + +$NAMESPACE isc::asiodns + +% ASIODNS_FD_ADD_TCP adding a new TCP server by opened fd %1 +A debug message informing about installing a file descriptor as a server. +The file descriptor number is noted. + +% ASIODNS_FD_ADD_UDP adding a new UDP server by opened fd %1 +A debug message informing about installing a file descriptor as a server. +The file descriptor number is noted. + +% ASIODNS_FETCH_COMPLETED upstream fetch to %1(%2) has now completed +A debug message, this records that the upstream fetch (a query made by the +resolver on behalf of its client) to the specified address has completed. + +% ASIODNS_FETCH_STOPPED upstream fetch to %1(%2) has been stopped +An external component has requested the halting of an upstream fetch. This +is an allowed operation, and the message should only appear if debug is +enabled. + +% ASIODNS_OPEN_SOCKET error %1 opening %2 socket to %3(%4) +The asynchronous I/O code encountered an error when trying to open a socket +of the specified protocol in order to send a message to the target address. +The number of the system error that caused the problem is given in the +message. + +% ASIODNS_READ_DATA error %1 reading %2 data from %3(%4) +The asynchronous I/O code encountered an error when trying to read data from +the specified address on the given protocol. The number of the system +error that caused the problem is given in the message. + +% ASIODNS_READ_TIMEOUT receive timeout while waiting for data from %1(%2) +An upstream fetch from the specified address timed out. This may happen for +any number of reasons and is most probably a problem at the remote server +or a problem on the network. The message will only appear if debug is +enabled. + +% ASIODNS_SEND_DATA error %1 sending data using %2 to %3(%4) +The asynchronous I/O code encountered an error when trying to send data to +the specified address on the given protocol. The number of the system +error that caused the problem is given in the message. + +% ASIODNS_SYNC_UDP_CLOSE_FAIL failed to close a DNS/UDP socket: %1 +This is the same to ASIODNS_UDP_CLOSE_FAIL but happens on the +"synchronous UDP server", mainly used for the authoritative DNS server +daemon. + +% ASIODNS_TCP_ACCEPT_FAIL failed to accept TCP DNS connection: %1 +Accepting a TCP connection from a DNS client failed due to an error +that could happen but should be rare. The reason for the error is +included in the log message. The server still keeps accepting new +connections, so unless it happens often it's probably okay to ignore +this error. If the shown error indicates something like "too many +open files", it's probably because the run time environment is too +restrictive on this limitation, so consider adjusting the limit using +a tool such as ulimit. If you see other types of errors too often, +there may be something overlooked; please file a bug report in that case. + +% ASIODNS_TCP_CLEANUP_CLOSE_FAIL failed to close a DNS/TCP socket on port cleanup: %1 +A TCP DNS server tried to close a TCP socket (one created on accepting +a new connection or is already unused) as a step of cleaning up the +corresponding listening port, but it failed to do that. This is +generally an unexpected event and so is logged as an error. +See also the description of ASIODNS_TCP_CLOSE_ACCEPTOR_FAIL. + +% ASIODNS_TCP_CLOSE_ACCEPTOR_FAIL failed to close listening TCP socket: %1 +A TCP DNS server tried to close a listening TCP socket (for accepting +new connections) as a step of cleaning up the corresponding listening +port (e.g., on server shutdown or updating port configuration), but it +failed to do that. This is generally an unexpected event and so is +logged as an error. See ASIODNS_TCP_CLOSE_FAIL on the implication of +related system resources. + +% ASIODNS_TCP_CLOSE_FAIL failed to close DNS/TCP socket with a client: %1 +A TCP DNS server tried to close a TCP socket used to communicate with +a client, but it failed to do that. While closing a socket should +normally be an error-free operation, there have been known cases where +this happened with a "connection reset by peer" error. This might be +because of some odd client behavior, such as sending a TCP RST after +establishing the connection and before the server closes the socket, +but how exactly this could happen seems to be system dependent (i.e, +it's not part of the standard socket API), so it's difficult to +provide a general explanation. In any case, it is believed that an +error on closing a socket doesn't mean leaking system resources (the +kernel should clean up any internal resource related to the socket, +just reporting an error detected in the close call), but, again, it +seems to be system dependent. This message is logged at a debug level +as it's known to happen and could be triggered by a remote node and it +would be better to not be too verbose, but you might want to increase +the log level and make sure there's no resource leak or other system +level troubles when it's logged. + +% ASIODNS_TCP_CLOSE_NORESP_FAIL failed to close DNS/TCP socket with a client: %1 +A TCP DNS server tried to close a TCP socket used to communicate with +a client without returning an answer (which normally happens for zone +transfer requests), but it failed to do that. See ASIODNS_TCP_CLOSE_FAIL +for more details. + +% ASIODNS_TCP_GETREMOTE_FAIL failed to get remote address of a DNS TCP connection: %1 +A TCP DNS server tried to get the address and port of a remote client +on a connected socket but failed. It's expected to be rare but can +still happen. See also ASIODNS_TCP_READLEN_FAIL. + +% ASIODNS_TCP_READDATA_FAIL failed to get DNS data on a TCP socket: %1 +A TCP DNS server tried to read a DNS message (that follows a 2-byte +length field) but failed. It's expected to be rare but can still happen. +See also ASIODNS_TCP_READLEN_FAIL. + +% ASIODNS_TCP_READLEN_FAIL failed to get DNS data length on a TCP socket: %1 +A TCP DNS server tried to get the length field of a DNS message (the first +2 bytes of a new chunk of data) but failed. This is generally expected to +be rare but can still happen, e.g, due to an unexpected reset of the +connection. A specific reason for the failure is included in the log +message. + +% ASIODNS_TCP_WRITE_FAIL failed to send DNS message over a TCP socket: %1 +A TCP DNS server tried to send a DNS message to a remote client but +failed. It's expected to be rare but can still happen. See also +ASIODNS_TCP_READLEN_FAIL. + +% ASIODNS_UDP_ASYNC_SEND_FAIL Error sending UDP packet to %1: %2 +The low-level ASIO library reported an error when trying to send a UDP +packet in asynchronous UDP mode. This can be any error reported by +send_to(), and can indicate problems such as too high a load on the network, +or a problem in the underlying library or system. +This packet is dropped and will not be sent, but service should resume +normally. +If you see a single occurrence of this message, it probably does not +indicate any significant problem, but if it is logged often, it is probably +a good idea to inspect your network traffic. + +% ASIODNS_UDP_CLOSE_FAIL failed to close a DNS/UDP socket: %1 +A UDP DNS server tried to close its UDP socket, but failed to do that. +This is generally an unexpected event and so is logged as an error. + +% ASIODNS_UDP_RECEIVE_FAIL failed to receive UDP DNS packet: %1 +Receiving a UDP packet from a DNS client failed due to an error that +could happen but should be very rare. The server still keeps +receiving UDP packets on this socket. The reason for the error is +included in the log message. This log message is basically not +expected to appear at all in practice; if it does, there may be some +system level failure and other system logs may have to be checked. + +% ASIODNS_UDP_SYNC_RECEIVE_FAIL failed to receive UDP DNS packet: %1 +This is the same to ASIODNS_UDP_RECEIVE_FAIL but happens on the +"synchronous UDP server", mainly used for the authoritative DNS server +daemon. + +% ASIODNS_UDP_SYNC_SEND_FAIL Error sending UDP packet to %1: %2 +The low-level ASIO library reported an error when trying to send a UDP +packet in synchronous UDP mode. See ASIODNS_UDP_ASYNC_SEND_FAIL for +more information. + +% ASIODNS_UNKNOWN_ORIGIN unknown origin for ASIO error code %1 (protocol: %2, address %3) +An internal consistency check on the origin of a message from the +asynchronous I/O module failed. This may indicate an internal error; +please submit a bug report. + +% ASIODNS_UNKNOWN_RESULT unknown result (%1) when IOFetch::stop() was executed for I/O to %2(%3) +An internal error indicating that the termination method of the resolver's +upstream fetch class was called with an unknown result code (which is +given in the message). Please submit a bug report. diff --git a/src/lib/asiodns/io_fetch.cc b/src/lib/asiodns/io_fetch.cc new file mode 100644 index 0000000..980a600 --- /dev/null +++ b/src/lib/asiodns/io_fetch.cc @@ -0,0 +1,402 @@ +// Copyright (C) 2011-2022 Internet Systems Consortium, Inc. ("ISC") +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#include <config.h> +#include <asiolink/asio_wrapper.h> +#include <asiolink/io_address.h> +#include <asiolink/io_asio_socket.h> +#include <asiolink/io_endpoint.h> +#include <asiolink/io_service.h> +#include <asiolink/tcp_endpoint.h> +#include <asiolink/tcp_socket.h> +#include <asiolink/udp_endpoint.h> +#include <asiolink/udp_socket.h> +#include <asiodns/io_fetch.h> +#include <asiodns/logger.h> +#include <dns/messagerenderer.h> +#include <dns/opcode.h> +#include <dns/qid_gen.h> +#include <dns/rcode.h> +#include <util/buffer.h> + +#include <boost/scoped_ptr.hpp> +#include <boost/date_time/posix_time/posix_time_types.hpp> + +#include <functional> +#include <unistd.h> // for some IPC/network system calls +#include <netinet/in.h> +#include <stdint.h> +#include <sys/socket.h> + +using namespace boost::asio; +using namespace isc::asiolink; +using namespace isc::dns; +using namespace isc::util; +using namespace isc::log; +using namespace std; + +namespace isc { +namespace asiodns { + +// Log debug verbosity + +const int DBG_IMPORTANT = DBGLVL_TRACE_BASIC; +const int DBG_COMMON = DBGLVL_TRACE_DETAIL; +const int DBG_ALL = DBGLVL_TRACE_DETAIL + 20; + +/// \brief IOFetch Data +/// +/// The data for IOFetch is held in a separate struct pointed to by a shared_ptr +/// object. This is because the IOFetch object will be copied often (it is used +/// as a coroutine and passed as callback to many async_*() functions) and we +/// want keep the same data). Organising the data in this way keeps copying to +/// a minimum. +struct IOFetchData { + + // The first two members are shared pointers to a base class because what is + // actually instantiated depends on whether the fetch is over UDP or TCP, + // which is not known until construction of the IOFetch. Use of a shared + // pointer here is merely to ensure deletion when the data object is deleted. + boost::scoped_ptr<IOAsioSocket<IOFetch> > socket; + ///< Socket to use for I/O + boost::scoped_ptr<IOEndpoint> remote_snd;///< Where the fetch is sent + boost::scoped_ptr<IOEndpoint> remote_rcv;///< Where the response came from + OutputBufferPtr msgbuf; ///< Wire buffer for question + OutputBufferPtr received; ///< Received data put here + IOFetch::Callback* callback; ///< Called on I/O Completion + boost::asio::deadline_timer timer; ///< Timer to measure timeouts + IOFetch::Protocol protocol; ///< Protocol being used + size_t cumulative; ///< Cumulative received amount + size_t expected; ///< Expected amount of data + size_t offset; ///< Offset to receive data + bool stopped; ///< Have we stopped running? + int timeout; ///< Timeout in ms + bool packet; ///< true if packet was supplied + + // In case we need to log an error, the origin of the last asynchronous + // I/O is recorded. To save time and simplify the code, this is recorded + // as the ID of the error message that would be generated if the I/O failed. + // This means that we must make sure that all possible "origins" take the + // same arguments in their message in the same order. + isc::log::MessageID origin; ///< Origin of last asynchronous I/O + uint8_t staging[IOFetch::STAGING_LENGTH]; + ///< Temporary array for received data + isc::dns::qid_t qid; ///< The QID set in the query + + /// \brief Constructor + /// + /// Just fills in the data members of the IOFetchData structure + /// + /// \param proto Either IOFetch::TCP or IOFetch::UDP. + /// \param service I/O Service object to handle the asynchronous + /// operations. + /// \param address IP address of upstream server + /// \param port Port to use for the query + /// \param buff Output buffer into which the response (in wire format) + /// is written (if a response is received). + /// \param cb Callback object containing the callback to be called + /// when we terminate. The caller is responsible for managing this + /// object and deleting it if necessary. + /// \param wait Timeout for the fetch (in ms). + /// + /// TODO: May need to alter constructor (see comment 4 in Trac ticket #554) + IOFetchData(IOFetch::Protocol proto, IOService& service, + const IOAddress& address, uint16_t port, OutputBufferPtr& buff, + IOFetch::Callback* cb, int wait) : + socket((proto == IOFetch::UDP) ? + static_cast<IOAsioSocket<IOFetch>*>( + new UDPSocket<IOFetch>(service)) : + static_cast<IOAsioSocket<IOFetch>*>( + new TCPSocket<IOFetch>(service)) + ), + remote_snd((proto == IOFetch::UDP) ? + static_cast<IOEndpoint*>(new UDPEndpoint(address, port)) : + static_cast<IOEndpoint*>(new TCPEndpoint(address, port)) + ), + remote_rcv((proto == IOFetch::UDP) ? + static_cast<IOEndpoint*>(new UDPEndpoint(address, port)) : + static_cast<IOEndpoint*>(new TCPEndpoint(address, port)) + ), + msgbuf(new OutputBuffer(512)), + received(buff), + callback(cb), + timer(service.get_io_service()), + protocol(proto), + cumulative(0), + expected(0), + offset(0), + stopped(false), + timeout(wait), + packet(false), + origin(ASIODNS_UNKNOWN_ORIGIN), + staging(), + qid(QidGenerator::getInstance().generateQid()) + {} + + // Checks if the response we received was ok; + // - data contains the buffer we read, as well as the address + // we sent to and the address we received from. + // length is provided by the operator() in IOFetch. + // Addresses must match, number of octets read must be at least + // 2, and the first two octets must match the qid of the message + // we sent. + bool responseOK() { + return (*remote_snd == *remote_rcv && cumulative >= 2 && + readUint16(received->getData(), received->getLength()) == qid); + } +}; + +/// IOFetch Constructor - just initialize the private data + +IOFetch::IOFetch(Protocol protocol, IOService& service, + const isc::dns::Question& question, const IOAddress& address, + uint16_t port, OutputBufferPtr& buff, Callback* cb, int wait, bool edns) { + MessagePtr query_msg(new Message(Message::RENDER)); + initIOFetch(query_msg, protocol, service, question, address, port, buff, + cb, wait, edns); +} + +IOFetch::IOFetch(Protocol protocol, IOService& service, + OutputBufferPtr& outpkt, const IOAddress& address, uint16_t port, + OutputBufferPtr& buff, Callback* cb, int wait) : + data_(new IOFetchData(protocol, service, + address, port, buff, cb, wait)) { + data_->msgbuf = outpkt; + data_->packet = true; +} + +IOFetch::IOFetch(Protocol protocol, IOService& service, + ConstMessagePtr query_message, const IOAddress& address, uint16_t port, + OutputBufferPtr& buff, Callback* cb, int wait) { + MessagePtr msg(new Message(Message::RENDER)); + + msg->setHeaderFlag(Message::HEADERFLAG_RD, + query_message->getHeaderFlag(Message::HEADERFLAG_RD)); + msg->setHeaderFlag(Message::HEADERFLAG_CD, + query_message->getHeaderFlag(Message::HEADERFLAG_CD)); + + initIOFetch(msg, protocol, service, + **(query_message->beginQuestion()), + address, port, buff, cb, wait); +} + +void +IOFetch::initIOFetch(MessagePtr& query_msg, Protocol protocol, + IOService& service, + const isc::dns::Question& question, + const IOAddress& address, uint16_t port, + OutputBufferPtr& buff, Callback* cb, int wait, bool edns) { + data_ = boost::shared_ptr<IOFetchData>(new IOFetchData( + protocol, service, address, port, buff, cb, wait)); + + query_msg->setQid(data_->qid); + query_msg->setOpcode(Opcode::QUERY()); + query_msg->setRcode(Rcode::NOERROR()); + query_msg->setHeaderFlag(Message::HEADERFLAG_RD); + query_msg->addQuestion(question); + + if (edns) { + EDNSPtr edns_query(new EDNS()); + edns_query->setUDPSize(Message::DEFAULT_MAX_EDNS0_UDPSIZE); + query_msg->setEDNS(edns_query); + } + + MessageRenderer renderer; + renderer.setBuffer(data_->msgbuf.get()); + query_msg->toWire(renderer); + renderer.setBuffer(NULL); +} + +// Return protocol in use. + +IOFetch::Protocol +IOFetch::getProtocol() const { + return (data_->protocol); +} + +/// The function operator is implemented with the "stackless coroutine" +/// pattern; see boost/asio/coroutine.hpp for details. + +void +IOFetch::operator()(boost::system::error_code ec, size_t length) { + if (data_->stopped) { + return; + + // On Debian it has been often observed that boost::asio async + // operations result in EINPROGRESS. This doesn't necessarily + // indicate an issue. Thus, we continue as if no error occurred. + } else if (ec && (ec.value() != boost::asio::error::in_progress)) { + logIOFailure(ec); + return; + } + + BOOST_ASIO_CORO_REENTER (this) { + + /// Generate the upstream query and render it to wire format + /// This is done in a different scope to allow inline variable + /// declarations. + { + if (data_->packet) { + // A packet was given, overwrite the QID (which is in the + // first two bytes of the packet). + data_->msgbuf->writeUint16At(data_->qid, 0); + + } + } + + // If we timeout, we stop, which cancels outstanding I/O operations and + // shuts down everything. + if (data_->timeout != -1) { + data_->timer.expires_from_now(boost::posix_time::milliseconds( + data_->timeout)); + data_->timer.async_wait(std::bind(&IOFetch::stop, *this, + TIME_OUT)); + } + + // Open a connection to the target system. For speed, if the operation + // is synchronous (i.e. UDP operation) we bypass the yield. + data_->origin = ASIODNS_OPEN_SOCKET; + if (data_->socket->isOpenSynchronous()) { + data_->socket->open(data_->remote_snd.get(), *this); + } else { + BOOST_ASIO_CORO_YIELD data_->socket->open(data_->remote_snd.get(), *this); + } + + do { + // Begin an asynchronous send, and then yield. When the send completes, + // we will resume immediately after this point. + data_->origin = ASIODNS_SEND_DATA; + BOOST_ASIO_CORO_YIELD data_->socket->asyncSend(data_->msgbuf->getData(), + data_->msgbuf->getLength(), data_->remote_snd.get(), *this); + + // Now receive the response. Since TCP may not receive the entire + // message in one operation, we need to loop until we have received + // it. (This can't be done within the asyncReceive() method because + // each I/O operation will be done asynchronously and between each one + // we need to yield ... and we *really* don't want to set up another + // coroutine within that method.) So after each receive (and yield), + // we check if the operation is complete and if not, loop to read again. + // + // Another concession to TCP is that the amount of is contained in the + // first two bytes. This leads to two problems: + // + // a) We don't want those bytes in the return buffer. + // b) They may not both arrive in the first I/O. + // + // So... we need to loop until we have at least two bytes, then store + // the expected amount of data. Then we need to loop until we have + // received all the data before copying it back to the user's buffer. + // And we want to minimize the amount of copying... + + data_->origin = ASIODNS_READ_DATA; + data_->cumulative = 0; // No data yet received + data_->offset = 0; // First data into start of buffer + data_->received->clear(); // Clear the receive buffer + do { + BOOST_ASIO_CORO_YIELD data_->socket->asyncReceive(data_->staging, + static_cast<size_t>(STAGING_LENGTH), + data_->offset, + data_->remote_rcv.get(), *this); + } while (!data_->socket->processReceivedData(data_->staging, length, + data_->cumulative, data_->offset, + data_->expected, data_->received)); + } while (!data_->responseOK()); + + // Finished with this socket, so close it. This will not generate an + // I/O error, but reset the origin to unknown in case we change this. + data_->origin = ASIODNS_UNKNOWN_ORIGIN; + data_->socket->close(); + + /// We are done + stop(SUCCESS); + } +} + +// Function that stops the coroutine sequence. It is called either when the +// query finishes or when the timer times out. Either way, it sets the +// "stopped_" flag and cancels anything that is in progress. +// +// As the function may be entered multiple times as things wind down, it checks +// if the stopped_ flag is already set. If it is, the call is a no-op. + +void +IOFetch::stop(Result result) { + if (!data_->stopped) { + + // Mark the fetch as stopped to prevent other completion callbacks + // (invoked because of the calls to cancel()) from executing the + // cancel calls again. + // + // In a single threaded environment, the callbacks won't be invoked + // until this one completes. In a multi-threaded environment, they may + // well be, in which case the testing (and setting) of the stopped_ + // variable should be done inside a mutex (and the stopped_ variable + // declared as "volatile"). + // + // TODO: Update testing of stopped_ if threads are used. + data_->stopped = true; + switch (result) { + case TIME_OUT: + LOG_DEBUG(logger, DBG_COMMON, ASIODNS_READ_TIMEOUT). + arg(data_->remote_snd->getAddress().toText()). + arg(data_->remote_snd->getPort()); + break; + + case SUCCESS: + LOG_DEBUG(logger, DBG_ALL, ASIODNS_FETCH_COMPLETED). + arg(data_->remote_rcv->getAddress().toText()). + arg(data_->remote_rcv->getPort()); + break; + + case STOPPED: + // Fetch has been stopped for some other reason. This is + // allowed but as it is unusual it is logged, but with a lower + // debug level than a timeout (which is totally normal). + LOG_DEBUG(logger, DBG_IMPORTANT, ASIODNS_FETCH_STOPPED). + arg(data_->remote_snd->getAddress().toText()). + arg(data_->remote_snd->getPort()); + break; + + default: + LOG_ERROR(logger, ASIODNS_UNKNOWN_RESULT). + arg(data_->remote_snd->getAddress().toText()). + arg(data_->remote_snd->getPort()); + } + + // Stop requested, cancel and I/O's on the socket and shut it down, + // and cancel the timer. + data_->socket->cancel(); + data_->socket->close(); + + data_->timer.cancel(); + + // Execute the I/O completion callback (if present). + if (data_->callback) { + (*(data_->callback))(result); + } + } +} + +// Log an error - called on I/O failure + +void IOFetch::logIOFailure(boost::system::error_code ec) { + // Should only get here with a known error code. + if ((data_->origin != ASIODNS_OPEN_SOCKET) && + (data_->origin != ASIODNS_SEND_DATA) && + (data_->origin != ASIODNS_READ_DATA) && + (data_->origin != ASIODNS_UNKNOWN_ORIGIN)) { + isc_throw(isc::Unexpected, "impossible error code " << data_->origin); + } + + LOG_ERROR(logger, data_->origin).arg(ec.value()). + arg((data_->remote_snd->getProtocol() == IPPROTO_TCP) ? + "TCP" : "UDP"). + arg(data_->remote_snd->getAddress().toText()). + arg(data_->remote_snd->getPort()); +} + +} // namespace asiodns +} // namespace isc { diff --git a/src/lib/asiodns/io_fetch.h b/src/lib/asiodns/io_fetch.h new file mode 100644 index 0000000..4b247ab --- /dev/null +++ b/src/lib/asiodns/io_fetch.h @@ -0,0 +1,246 @@ +// Copyright (C) 2010-2021 Internet Systems Consortium, Inc. ("ISC") +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#ifndef IO_FETCH_H +#define IO_FETCH_H 1 + +#include <config.h> + +#include <boost/shared_array.hpp> +#include <boost/shared_ptr.hpp> +#include <boost/date_time/posix_time/posix_time_types.hpp> + +// We want to use coroutine.hpp from the system's boost headers if possible. +// However, very old Boost versions (provided by RHEL 7 or CentOS 7) didn't have +// this header. So we can resort to our bundled version, but only if necessary. +#ifdef HAVE_BOOST_ASIO_COROUTINE_HPP +#include <boost/asio/coroutine.hpp> +#else +#include <ext/coroutine/coroutine.hpp> +#endif + +#include <boost/system/error_code.hpp> +#include <asiolink/io_address.h> +#include <asiolink/io_service.h> + +#include <util/buffer.h> +#include <dns/question.h> +#include <dns/message.h> + +namespace isc { +namespace asiodns { + +// Forward declarations +struct IOFetchData; + +/// \brief Upstream Fetch Processing +/// +/// IOFetch is the class used to send upstream fetches and to handle responses. +/// +/// \param E Endpoint type to use. + +class IOFetch : public boost::asio::coroutine { +public: + /// \brief Protocol to use on the fetch + enum Protocol { + UDP = 0, + TCP = 1 + }; + + /// \brief Origin of Asynchronous I/O Call + /// + /// Indicates what initiated an asynchronous I/O call and used in deciding + /// what error message to output if the I/O fails. + enum Origin { + NONE = 0, ///< No asynchronous call outstanding + OPEN = 1, + SEND = 2, + RECEIVE = 3, + CLOSE = 4 + }; + + /// \brief Result of Upstream Fetch + /// + /// Note that this applies to the status of I/Os in the fetch - a fetch + /// that resulted in a packet being received from the server is a SUCCESS, + /// even if the contents of the packet indicate that some error occurred. + enum Result { + SUCCESS = 0, ///< Success, fetch completed + TIME_OUT = 1, ///< Failure, fetch timed out + STOPPED = 2, ///< Control code, fetch has been stopped + NOTSET = 3 ///< For testing, indicates value not set + }; + + // The next enum is a "trick" to allow constants to be defined in a class + // declaration. + + /// \brief Integer Constants + enum { + STAGING_LENGTH = 8192 ///< Size of staging buffer + }; + + /// \brief I/O Fetch Callback + /// + /// Class of callback object for when the fetch itself has completed - an + /// object of this class is passed to the IOFetch constructor and its + /// operator() method called when the fetch completes. + /// + /// Note the difference between the two operator() methods: + /// - IOFetch::operator() callback is called when an asynchronous I/O has + /// completed. + /// - IOFetch::Callback::operator() is called when an upstream fetch - which + /// may have involved several asynchronous I/O operations - has completed. + /// + /// This is an abstract class. + class Callback { + public: + /// \brief Default Constructor + Callback() + {} + + /// \brief Virtual Destructor + virtual ~Callback() + {} + + /// \brief Callback method + /// + /// This is the method called when the fetch completes. + /// + /// \param result Result of the fetch + virtual void operator()(Result result) = 0; + }; + + /// \brief Constructor. + /// + /// Creates the object that will handle the upstream fetch. + /// + /// \param protocol Fetch protocol, either IOFetch::TCP or IOFetch::UDP + /// \param service I/O Service object to handle the asynchronous + /// operations. + /// \param question DNS question to send to the upstream server. + /// \param address IP address of upstream server + /// \param port Port to which to connect on the upstream server + /// \param buff Output buffer into which the response (in wire format) + /// is written (if a response is received). + /// \param cb Callback object containing the callback to be called when we + /// terminate. The caller is responsible for managing this object + /// and deleting it if necessary. + /// \param wait Timeout for the fetch (in ms). The default value of + /// -1 indicates no timeout. + /// \param edns true if the request should be EDNS. The default value is + /// true. + IOFetch(Protocol protocol, isc::asiolink::IOService& service, + const isc::dns::Question& question, + const isc::asiolink::IOAddress& address, + uint16_t port, isc::util::OutputBufferPtr& buff, Callback* cb, + int wait = -1, + bool edns = true); + + /// \brief Constructor + /// This constructor has one parameter "query_message", which + /// is the shared_ptr to a full query message. It's different + /// with above constructor which has only question section. All + /// other parameters are same. + /// + /// \param protocol Fetch protocol, either IOFetch::TCP or IOFetch::UDP + /// \param service I/O Service object to handle the asynchronous + /// operations. + /// \param query_message the shared_ptr to a full query message + /// got from a query client. + /// \param address IP address of upstream server + /// \param port Port to which to connect on the upstream server + /// \param buff Output buffer into which the response (in wire format) + /// is written (if a response is received). + /// \param cb Callback object containing the callback to be called when we + /// terminate. The caller is responsible for managing this object + /// and deleting it if necessary. + /// \param wait Timeout for the fetch (in ms). The default value of + /// -1 indicates no timeout. + IOFetch(Protocol protocol, isc::asiolink::IOService& service, + isc::dns::ConstMessagePtr query_message, + const isc::asiolink::IOAddress& address, + uint16_t port, isc::util::OutputBufferPtr& buff, Callback* cb, + int wait = -1); + + /// \brief Constructor. + /// + /// Creates the object that will handle the upstream fetch. + /// + /// \param protocol Fetch protocol, either IOFetch::TCP or IOFetch::UDP + /// \param service I/O Service object to handle the asynchronous + /// operations. + /// \param outpkt Packet to send to upstream server. Note that the + /// QID (first two bytes of the packet) may be altered in the sending. + /// \param buff Output buffer into which the response (in wire format) + /// is written (if a response is received). + /// \param cb Callback object containing the callback to be called + /// when we terminate. The caller is responsible for managing this + /// object and deleting it if necessary. + /// \param address IP address of upstream server + /// \param port Port to which to connect on the upstream server + /// (default = 53) + /// \param wait Timeout for the fetch (in ms). The default value of + /// -1 indicates no timeout. + IOFetch(Protocol protocol, isc::asiolink::IOService& service, + isc::util::OutputBufferPtr& outpkt, + const isc::asiolink::IOAddress& address, + uint16_t port, isc::util::OutputBufferPtr& buff, Callback* cb, + int wait = -1); + + /// \brief Return Current Protocol + /// + /// \return Protocol associated with this IOFetch object. + Protocol getProtocol() const; + + /// \brief Coroutine entry point + /// + /// The operator() method is the method in which the coroutine code enters + /// this object when an operation has been completed. + /// + /// \param ec Error code, the result of the last asynchronous I/O operation. + /// \param length Amount of data received on the last asynchronous read + void operator()(boost::system::error_code ec = boost::system::error_code(), size_t length = 0); + + /// \brief Terminate query + /// + /// This method can be called at any point. It terminates the current + /// query with the specified reason. + /// + /// \param reason Reason for terminating the query + void stop(Result reason = STOPPED); + +private: + /// \brief IOFetch Initialization Function. + /// All the parameters are same with the constructor, except + /// parameter "query_message" + /// \param query_message the message to be sent out. + void initIOFetch(isc::dns::MessagePtr& query_message, Protocol protocol, + isc::asiolink::IOService& service, + const isc::dns::Question& question, + const isc::asiolink::IOAddress& address, uint16_t port, + isc::util::OutputBufferPtr& buff, Callback* cb, int wait, + bool edns = true); + + /// \brief Log I/O Failure + /// + /// Records an I/O failure to the log file + /// + /// \param ec ASIO error code + void logIOFailure(boost::system::error_code ec); + + // Member variables. All data is in a structure pointed to by a shared + // pointer. The IOFetch object is copied a number of times during its + // life, and only requiring a pointer to be copied reduces overhead. + boost::shared_ptr<IOFetchData> data_; ///< Private data +}; + +/// \brief Defines a pointer to an IOFetch. +typedef boost::shared_ptr<IOFetch> IOFetchPtr; + +} // namespace asiodns +} // namespace isc + +#endif // IO_FETCH_H diff --git a/src/lib/asiodns/logger.cc b/src/lib/asiodns/logger.cc new file mode 100644 index 0000000..b14701c --- /dev/null +++ b/src/lib/asiodns/logger.cc @@ -0,0 +1,19 @@ +// Copyright (C) 2012-2015 Internet Systems Consortium, Inc. ("ISC") +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#include <config.h> + +#include <asiodns/logger.h> + +namespace isc { +namespace asiodns { + +/// Use the ASIO logger + +isc::log::Logger logger("asiodns"); + +} +} diff --git a/src/lib/asiodns/logger.h b/src/lib/asiodns/logger.h new file mode 100644 index 0000000..e2d88e2 --- /dev/null +++ b/src/lib/asiodns/logger.h @@ -0,0 +1,18 @@ +// Copyright (C) 2012-2015 Internet Systems Consortium, Inc. ("ISC") +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#include <log/logger.h> +#include <log/macros.h> +#include <log/log_dbglevels.h> +#include <asiodns/asiodns_messages.h> + +namespace isc { +namespace asiodns { + +extern isc::log::Logger logger; + +} +} diff --git a/src/lib/asiodns/tests/Makefile.am b/src/lib/asiodns/tests/Makefile.am new file mode 100644 index 0000000..74517c1 --- /dev/null +++ b/src/lib/asiodns/tests/Makefile.am @@ -0,0 +1,43 @@ +AM_CPPFLAGS = -I$(top_srcdir)/src/lib -I$(top_builddir)/src/lib +AM_CPPFLAGS += $(BOOST_INCLUDES) + +AM_CXXFLAGS = $(KEA_CXXFLAGS) + +if USE_STATIC_LINK +AM_LDFLAGS = -static +endif + +CLEANFILES = *.gcno *.gcda + +TESTS_ENVIRONMENT = $(LIBTOOL) --mode=execute $(VALGRIND_COMMAND) + +TESTS = +if HAVE_GTEST +TESTS += run_unittests +run_unittests_SOURCES = run_unittests.cc +run_unittests_SOURCES += io_fetch_unittest.cc + +run_unittests_CPPFLAGS = $(AM_CPPFLAGS) $(GTEST_INCLUDES) + +run_unittests_LDADD = $(top_builddir)/src/lib/asiodns/libkea-asiodns.la +run_unittests_LDADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la +run_unittests_LDADD += $(top_builddir)/src/lib/dns/libkea-dns++.la +run_unittests_LDADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la +run_unittests_LDADD += $(top_builddir)/src/lib/log/libkea-log.la +run_unittests_LDADD += $(top_builddir)/src/lib/util/unittests/libutil_unittests.la +run_unittests_LDADD += $(top_builddir)/src/lib/util/libkea-util.la +run_unittests_LDADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la +run_unittests_LDADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) +run_unittests_LDADD += $(BOOST_LIBS) $(GTEST_LDADD) + +run_unittests_LDFLAGS = $(AM_LDFLAGS) $(CRYPTO_LDFLAGS) $(GTEST_LDFLAGS) + +# Note: the ordering matters: -Wno-... must follow -Wextra (defined in +# KEA_CXXFLAGS) +run_unittests_CXXFLAGS = $(AM_CXXFLAGS) +if USE_GXX +run_unittests_CXXFLAGS += -Wno-unused-parameter +endif +endif + +noinst_PROGRAMS = $(TESTS) diff --git a/src/lib/asiodns/tests/Makefile.in b/src/lib/asiodns/tests/Makefile.in new file mode 100644 index 0000000..56728c7 --- /dev/null +++ b/src/lib/asiodns/tests/Makefile.in @@ -0,0 +1,896 @@ +# Makefile.in generated by automake 1.16.1 from Makefile.am. +# @configure_input@ + +# Copyright (C) 1994-2018 Free Software Foundation, Inc. + +# This Makefile.in is free software; the Free Software Foundation +# gives unlimited permission to copy and/or distribute it, +# with or without modifications, as long as this notice is preserved. + +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY, to the extent permitted by law; without +# even the implied warranty of MERCHANTABILITY or FITNESS FOR A +# PARTICULAR PURPOSE. + +@SET_MAKE@ + +VPATH = @srcdir@ +am__is_gnu_make = { \ + if test -z '$(MAKELEVEL)'; then \ + false; \ + elif test -n '$(MAKE_HOST)'; then \ + true; \ + elif test -n '$(MAKE_VERSION)' && test -n '$(CURDIR)'; then \ + true; \ + else \ + false; \ + fi; \ +} +am__make_running_with_option = \ + case $${target_option-} in \ + ?) ;; \ + *) echo "am__make_running_with_option: internal error: invalid" \ + "target option '$${target_option-}' specified" >&2; \ + exit 1;; \ + esac; \ + has_opt=no; \ + sane_makeflags=$$MAKEFLAGS; \ + if $(am__is_gnu_make); then \ + sane_makeflags=$$MFLAGS; \ + else \ + case $$MAKEFLAGS in \ + *\\[\ \ ]*) \ + bs=\\; \ + sane_makeflags=`printf '%s\n' "$$MAKEFLAGS" \ + | sed "s/$$bs$$bs[$$bs $$bs ]*//g"`;; \ + esac; \ + fi; \ + skip_next=no; \ + strip_trailopt () \ + { \ + flg=`printf '%s\n' "$$flg" | sed "s/$$1.*$$//"`; \ + }; \ + for flg in $$sane_makeflags; do \ + test $$skip_next = yes && { skip_next=no; continue; }; \ + case $$flg in \ + *=*|--*) continue;; \ + -*I) strip_trailopt 'I'; skip_next=yes;; \ + -*I?*) strip_trailopt 'I';; \ + -*O) strip_trailopt 'O'; skip_next=yes;; \ + -*O?*) strip_trailopt 'O';; \ + -*l) strip_trailopt 'l'; skip_next=yes;; \ + -*l?*) strip_trailopt 'l';; \ + -[dEDm]) skip_next=yes;; \ + -[JT]) skip_next=yes;; \ + esac; \ + case $$flg in \ + *$$target_option*) has_opt=yes; break;; \ + esac; \ + done; \ + test $$has_opt = yes +am__make_dryrun = (target_option=n; $(am__make_running_with_option)) +am__make_keepgoing = (target_option=k; $(am__make_running_with_option)) +pkgdatadir = $(datadir)/@PACKAGE@ +pkgincludedir = $(includedir)/@PACKAGE@ +pkglibdir = $(libdir)/@PACKAGE@ +pkglibexecdir = $(libexecdir)/@PACKAGE@ +am__cd = CDPATH="$${ZSH_VERSION+.}$(PATH_SEPARATOR)" && cd +install_sh_DATA = $(install_sh) -c -m 644 +install_sh_PROGRAM = $(install_sh) -c +install_sh_SCRIPT = $(install_sh) -c +INSTALL_HEADER = $(INSTALL_DATA) +transform = $(program_transform_name) +NORMAL_INSTALL = : +PRE_INSTALL = : +POST_INSTALL = : +NORMAL_UNINSTALL = : +PRE_UNINSTALL = : +POST_UNINSTALL = : +build_triplet = @build@ +host_triplet = @host@ +TESTS = $(am__EXEEXT_1) +@HAVE_GTEST_TRUE@am__append_1 = run_unittests +@HAVE_GTEST_TRUE@@USE_GXX_TRUE@am__append_2 = -Wno-unused-parameter +noinst_PROGRAMS = $(am__EXEEXT_2) +subdir = src/lib/asiodns/tests +ACLOCAL_M4 = $(top_srcdir)/aclocal.m4 +am__aclocal_m4_deps = $(top_srcdir)/m4macros/ax_boost_for_kea.m4 \ + $(top_srcdir)/m4macros/ax_cpp11.m4 \ + $(top_srcdir)/m4macros/ax_cpp20.m4 \ + $(top_srcdir)/m4macros/ax_crypto.m4 \ + $(top_srcdir)/m4macros/ax_find_library.m4 \ + $(top_srcdir)/m4macros/ax_gssapi.m4 \ + $(top_srcdir)/m4macros/ax_gtest.m4 \ + $(top_srcdir)/m4macros/ax_isc_rpath.m4 \ + $(top_srcdir)/m4macros/ax_netconf.m4 \ + $(top_srcdir)/m4macros/libtool.m4 \ + $(top_srcdir)/m4macros/ltoptions.m4 \ + $(top_srcdir)/m4macros/ltsugar.m4 \ + $(top_srcdir)/m4macros/ltversion.m4 \ + $(top_srcdir)/m4macros/lt~obsolete.m4 \ + $(top_srcdir)/configure.ac +am__configure_deps = $(am__aclocal_m4_deps) $(CONFIGURE_DEPENDENCIES) \ + $(ACLOCAL_M4) +DIST_COMMON = $(srcdir)/Makefile.am $(am__DIST_COMMON) +mkinstalldirs = $(install_sh) -d +CONFIG_HEADER = $(top_builddir)/config.h +CONFIG_CLEAN_FILES = +CONFIG_CLEAN_VPATH_FILES = +@HAVE_GTEST_TRUE@am__EXEEXT_1 = run_unittests$(EXEEXT) +am__EXEEXT_2 = $(am__EXEEXT_1) +PROGRAMS = $(noinst_PROGRAMS) +am__run_unittests_SOURCES_DIST = run_unittests.cc io_fetch_unittest.cc +@HAVE_GTEST_TRUE@am_run_unittests_OBJECTS = \ +@HAVE_GTEST_TRUE@ run_unittests-run_unittests.$(OBJEXT) \ +@HAVE_GTEST_TRUE@ run_unittests-io_fetch_unittest.$(OBJEXT) +run_unittests_OBJECTS = $(am_run_unittests_OBJECTS) +am__DEPENDENCIES_1 = +@HAVE_GTEST_TRUE@run_unittests_DEPENDENCIES = $(top_builddir)/src/lib/asiodns/libkea-asiodns.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/asiolink/libkea-asiolink.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/dns/libkea-dns++.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/log/libkea-log.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/util/unittests/libutil_unittests.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/util/libkea-util.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/exceptions/libkea-exceptions.la \ +@HAVE_GTEST_TRUE@ $(am__DEPENDENCIES_1) $(am__DEPENDENCIES_1) \ +@HAVE_GTEST_TRUE@ $(am__DEPENDENCIES_1) $(am__DEPENDENCIES_1) +AM_V_lt = $(am__v_lt_@AM_V@) +am__v_lt_ = $(am__v_lt_@AM_DEFAULT_V@) +am__v_lt_0 = --silent +am__v_lt_1 = +run_unittests_LINK = $(LIBTOOL) $(AM_V_lt) --tag=CXX \ + $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=link $(CXXLD) \ + $(run_unittests_CXXFLAGS) $(CXXFLAGS) $(run_unittests_LDFLAGS) \ + $(LDFLAGS) -o $@ +AM_V_P = $(am__v_P_@AM_V@) +am__v_P_ = $(am__v_P_@AM_DEFAULT_V@) +am__v_P_0 = false +am__v_P_1 = : +AM_V_GEN = $(am__v_GEN_@AM_V@) +am__v_GEN_ = $(am__v_GEN_@AM_DEFAULT_V@) +am__v_GEN_0 = @echo " GEN " $@; +am__v_GEN_1 = +AM_V_at = $(am__v_at_@AM_V@) +am__v_at_ = $(am__v_at_@AM_DEFAULT_V@) +am__v_at_0 = @ +am__v_at_1 = +DEFAULT_INCLUDES = -I.@am__isrc@ -I$(top_builddir) +depcomp = $(SHELL) $(top_srcdir)/depcomp +am__maybe_remake_depfiles = depfiles +am__depfiles_remade = ./$(DEPDIR)/run_unittests-io_fetch_unittest.Po \ + ./$(DEPDIR)/run_unittests-run_unittests.Po +am__mv = mv -f +CXXCOMPILE = $(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) \ + $(AM_CPPFLAGS) $(CPPFLAGS) $(AM_CXXFLAGS) $(CXXFLAGS) +LTCXXCOMPILE = $(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) \ + $(LIBTOOLFLAGS) --mode=compile $(CXX) $(DEFS) \ + $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) \ + $(AM_CXXFLAGS) $(CXXFLAGS) +AM_V_CXX = $(am__v_CXX_@AM_V@) +am__v_CXX_ = $(am__v_CXX_@AM_DEFAULT_V@) +am__v_CXX_0 = @echo " CXX " $@; +am__v_CXX_1 = +CXXLD = $(CXX) +CXXLINK = $(LIBTOOL) $(AM_V_lt) --tag=CXX $(AM_LIBTOOLFLAGS) \ + $(LIBTOOLFLAGS) --mode=link $(CXXLD) $(AM_CXXFLAGS) \ + $(CXXFLAGS) $(AM_LDFLAGS) $(LDFLAGS) -o $@ +AM_V_CXXLD = $(am__v_CXXLD_@AM_V@) +am__v_CXXLD_ = $(am__v_CXXLD_@AM_DEFAULT_V@) +am__v_CXXLD_0 = @echo " CXXLD " $@; +am__v_CXXLD_1 = +SOURCES = $(run_unittests_SOURCES) +DIST_SOURCES = $(am__run_unittests_SOURCES_DIST) +am__can_run_installinfo = \ + case $$AM_UPDATE_INFO_DIR in \ + n|no|NO) false;; \ + *) (install-info --version) >/dev/null 2>&1;; \ + esac +am__tagged_files = $(HEADERS) $(SOURCES) $(TAGS_FILES) $(LISP) +# Read a list of newline-separated strings from the standard input, +# and print each of them once, without duplicates. Input order is +# *not* preserved. +am__uniquify_input = $(AWK) '\ + BEGIN { nonempty = 0; } \ + { items[$$0] = 1; nonempty = 1; } \ + END { if (nonempty) { for (i in items) print i; }; } \ +' +# Make sure the list of sources is unique. This is necessary because, +# e.g., the same source file might be shared among _SOURCES variables +# for different programs/libraries. +am__define_uniq_tagged_files = \ + list='$(am__tagged_files)'; \ + unique=`for i in $$list; do \ + if test -f "$$i"; then echo $$i; else echo $(srcdir)/$$i; fi; \ + done | $(am__uniquify_input)` +ETAGS = etags +CTAGS = ctags +am__tty_colors_dummy = \ + mgn= red= grn= lgn= blu= brg= std=; \ + am__color_tests=no +am__tty_colors = { \ + $(am__tty_colors_dummy); \ + if test "X$(AM_COLOR_TESTS)" = Xno; then \ + am__color_tests=no; \ + elif test "X$(AM_COLOR_TESTS)" = Xalways; then \ + am__color_tests=yes; \ + elif test "X$$TERM" != Xdumb && { test -t 1; } 2>/dev/null; then \ + am__color_tests=yes; \ + fi; \ + if test $$am__color_tests = yes; then \ + red='[0;31m'; \ + grn='[0;32m'; \ + lgn='[1;32m'; \ + blu='[1;34m'; \ + mgn='[0;35m'; \ + brg='[1m'; \ + std='[m'; \ + fi; \ +} +am__DIST_COMMON = $(srcdir)/Makefile.in $(top_srcdir)/depcomp +DISTFILES = $(DIST_COMMON) $(DIST_SOURCES) $(TEXINFOS) $(EXTRA_DIST) +ACLOCAL = @ACLOCAL@ +AMTAR = @AMTAR@ +AM_DEFAULT_VERBOSITY = @AM_DEFAULT_VERBOSITY@ +AR = @AR@ +ASCIIDOC = @ASCIIDOC@ +AUTOCONF = @AUTOCONF@ +AUTOHEADER = @AUTOHEADER@ +AUTOMAKE = @AUTOMAKE@ +AWK = @AWK@ +BOOST_INCLUDES = @BOOST_INCLUDES@ +BOOST_LIBS = @BOOST_LIBS@ +BOTAN_TOOL = @BOTAN_TOOL@ +CC = @CC@ +CCDEPMODE = @CCDEPMODE@ +CFLAGS = @CFLAGS@ +CONTRIB_DIR = @CONTRIB_DIR@ +CPP = @CPP@ +CPPFLAGS = @CPPFLAGS@ +CRYPTO_CFLAGS = @CRYPTO_CFLAGS@ +CRYPTO_INCLUDES = @CRYPTO_INCLUDES@ +CRYPTO_LDFLAGS = @CRYPTO_LDFLAGS@ +CRYPTO_LIBS = @CRYPTO_LIBS@ +CRYPTO_PACKAGE = @CRYPTO_PACKAGE@ +CRYPTO_RPATH = @CRYPTO_RPATH@ +CXX = @CXX@ +CXXCPP = @CXXCPP@ +CXXDEPMODE = @CXXDEPMODE@ +CXXFLAGS = @CXXFLAGS@ +CYGPATH_W = @CYGPATH_W@ +DEFS = @DEFS@ +DEPDIR = @DEPDIR@ +DISTCHECK_BOOST_CONFIGURE_FLAG = @DISTCHECK_BOOST_CONFIGURE_FLAG@ +DISTCHECK_CONTRIB_CONFIGURE_FLAG = @DISTCHECK_CONTRIB_CONFIGURE_FLAG@ +DISTCHECK_CRYPTO_CONFIGURE_FLAG = @DISTCHECK_CRYPTO_CONFIGURE_FLAG@ +DISTCHECK_GSSAPI_CONFIGURE_FLAG = @DISTCHECK_GSSAPI_CONFIGURE_FLAG@ +DISTCHECK_GTEST_CONFIGURE_FLAG = @DISTCHECK_GTEST_CONFIGURE_FLAG@ +DISTCHECK_KEA_SHELL_CONFIGURE_FLAG = @DISTCHECK_KEA_SHELL_CONFIGURE_FLAG@ +DISTCHECK_LIBYANGCPP_CONFIGURE_FLAG = @DISTCHECK_LIBYANGCPP_CONFIGURE_FLAG@ +DISTCHECK_LIBYANG_CONFIGURE_FLAG = @DISTCHECK_LIBYANG_CONFIGURE_FLAG@ +DISTCHECK_LOG4CPLUS_CONFIGURE_FLAG = @DISTCHECK_LOG4CPLUS_CONFIGURE_FLAG@ +DISTCHECK_MYSQL_CONFIGURE_FLAG = @DISTCHECK_MYSQL_CONFIGURE_FLAG@ +DISTCHECK_PERFDHCP_CONFIGURE_FLAG = @DISTCHECK_PERFDHCP_CONFIGURE_FLAG@ +DISTCHECK_PGSQL_CONFIGURE_FLAG = @DISTCHECK_PGSQL_CONFIGURE_FLAG@ +DISTCHECK_PREMIUM_CONFIGURE_FLAG = @DISTCHECK_PREMIUM_CONFIGURE_FLAG@ +DISTCHECK_SYSREPOCPP_CONFIGURE_FLAG = @DISTCHECK_SYSREPOCPP_CONFIGURE_FLAG@ +DISTCHECK_SYSREPO_CONFIGURE_FLAG = @DISTCHECK_SYSREPO_CONFIGURE_FLAG@ +DLLTOOL = @DLLTOOL@ +DSYMUTIL = @DSYMUTIL@ +DUMPBIN = @DUMPBIN@ +ECHO_C = @ECHO_C@ +ECHO_N = @ECHO_N@ +ECHO_T = @ECHO_T@ +EGREP = @EGREP@ +EXEEXT = @EXEEXT@ +FGREP = @FGREP@ +GENHTML = @GENHTML@ +GREP = @GREP@ +GSSAPI_CFLAGS = @GSSAPI_CFLAGS@ +GSSAPI_LIBS = @GSSAPI_LIBS@ +GTEST_CONFIG = @GTEST_CONFIG@ +GTEST_INCLUDES = @GTEST_INCLUDES@ +GTEST_LDADD = @GTEST_LDADD@ +GTEST_LDFLAGS = @GTEST_LDFLAGS@ +GTEST_SOURCE = @GTEST_SOURCE@ +HAVE_NETCONF = @HAVE_NETCONF@ +INSTALL = @INSTALL@ +INSTALL_DATA = @INSTALL_DATA@ +INSTALL_PROGRAM = @INSTALL_PROGRAM@ +INSTALL_SCRIPT = @INSTALL_SCRIPT@ +INSTALL_STRIP_PROGRAM = @INSTALL_STRIP_PROGRAM@ +KEA_CXXFLAGS = @KEA_CXXFLAGS@ +KEA_SRCID = @KEA_SRCID@ +KRB5_CONFIG = @KRB5_CONFIG@ +LCOV = @LCOV@ +LD = @LD@ +LDFLAGS = @LDFLAGS@ +LEX = @LEX@ +LEXLIB = @LEXLIB@ +LEX_OUTPUT_ROOT = @LEX_OUTPUT_ROOT@ +LIBOBJS = @LIBOBJS@ +LIBS = @LIBS@ +LIBTOOL = @LIBTOOL@ +LIBYANGCPP_CPPFLAGS = @LIBYANGCPP_CPPFLAGS@ +LIBYANGCPP_INCLUDEDIR = @LIBYANGCPP_INCLUDEDIR@ +LIBYANGCPP_LIBS = @LIBYANGCPP_LIBS@ +LIBYANGCPP_PREFIX = @LIBYANGCPP_PREFIX@ +LIBYANGCPP_VERSION = @LIBYANGCPP_VERSION@ +LIBYANG_CPPFLAGS = @LIBYANG_CPPFLAGS@ +LIBYANG_INCLUDEDIR = @LIBYANG_INCLUDEDIR@ +LIBYANG_LIBS = @LIBYANG_LIBS@ +LIBYANG_PREFIX = @LIBYANG_PREFIX@ +LIBYANG_VERSION = @LIBYANG_VERSION@ +LIPO = @LIPO@ +LN_S = @LN_S@ +LOG4CPLUS_INCLUDES = @LOG4CPLUS_INCLUDES@ +LOG4CPLUS_LIBS = @LOG4CPLUS_LIBS@ +LTLIBOBJS = @LTLIBOBJS@ +LT_SYS_LIBRARY_PATH = @LT_SYS_LIBRARY_PATH@ +MAKEINFO = @MAKEINFO@ +MANIFEST_TOOL = @MANIFEST_TOOL@ +MKDIR_P = @MKDIR_P@ +MYSQL_CPPFLAGS = @MYSQL_CPPFLAGS@ +MYSQL_LIBS = @MYSQL_LIBS@ +NM = @NM@ +NMEDIT = @NMEDIT@ +OBJDUMP = @OBJDUMP@ +OBJEXT = @OBJEXT@ +OTOOL = @OTOOL@ +OTOOL64 = @OTOOL64@ +PACKAGE = @PACKAGE@ +PACKAGE_BUGREPORT = @PACKAGE_BUGREPORT@ +PACKAGE_NAME = @PACKAGE_NAME@ +PACKAGE_STRING = @PACKAGE_STRING@ +PACKAGE_TARNAME = @PACKAGE_TARNAME@ +PACKAGE_URL = @PACKAGE_URL@ +PACKAGE_VERSION = @PACKAGE_VERSION@ +PACKAGE_VERSION_TYPE = @PACKAGE_VERSION_TYPE@ +PATH_SEPARATOR = @PATH_SEPARATOR@ +PDFLATEX = @PDFLATEX@ +PERL = @PERL@ +PGSQL_CPPFLAGS = @PGSQL_CPPFLAGS@ +PGSQL_LIBS = @PGSQL_LIBS@ +PKGPYTHONDIR = @PKGPYTHONDIR@ +PKG_CONFIG = @PKG_CONFIG@ +PLANTUML = @PLANTUML@ +PREMIUM_DIR = @PREMIUM_DIR@ +PYTHON = @PYTHON@ +PYTHON_EXEC_PREFIX = @PYTHON_EXEC_PREFIX@ +PYTHON_PLATFORM = @PYTHON_PLATFORM@ +PYTHON_PREFIX = @PYTHON_PREFIX@ +PYTHON_VERSION = @PYTHON_VERSION@ +RANLIB = @RANLIB@ +SED = @SED@ +SEP = @SEP@ +SET_MAKE = @SET_MAKE@ +SHELL = @SHELL@ +SPHINXBUILD = @SPHINXBUILD@ +SRPD_PLUGINS_PATH = @SRPD_PLUGINS_PATH@ +SR_PLUGINS_PATH = @SR_PLUGINS_PATH@ +SR_REPO_PATH = @SR_REPO_PATH@ +STRIP = @STRIP@ +SYSREPOCPP_CPPFLAGS = @SYSREPOCPP_CPPFLAGS@ +SYSREPOCPP_INCLUDEDIR = @SYSREPOCPP_INCLUDEDIR@ +SYSREPOCPP_LIBS = @SYSREPOCPP_LIBS@ +SYSREPOCPP_PREFIX = @SYSREPOCPP_PREFIX@ +SYSREPOCPP_VERSION = @SYSREPOCPP_VERSION@ +SYSREPO_CPPFLAGS = @SYSREPO_CPPFLAGS@ +SYSREPO_INCLUDEDIR = @SYSREPO_INCLUDEDIR@ +SYSREPO_LIBS = @SYSREPO_LIBS@ +SYSREPO_PREFIX = @SYSREPO_PREFIX@ +SYSREPO_VERSION = @SYSREPO_VERSION@ +USE_LCOV = @USE_LCOV@ +VALGRIND = @VALGRIND@ +VERSION = @VERSION@ +WARNING_GCC_44_STRICT_ALIASING_CFLAG = @WARNING_GCC_44_STRICT_ALIASING_CFLAG@ +YACC = @YACC@ +abs_builddir = @abs_builddir@ +abs_srcdir = @abs_srcdir@ +abs_top_builddir = @abs_top_builddir@ +abs_top_srcdir = @abs_top_srcdir@ +ac_ct_AR = @ac_ct_AR@ +ac_ct_CC = @ac_ct_CC@ +ac_ct_CXX = @ac_ct_CXX@ +ac_ct_DUMPBIN = @ac_ct_DUMPBIN@ +am__include = @am__include@ +am__leading_dot = @am__leading_dot@ +am__quote = @am__quote@ +am__tar = @am__tar@ +am__untar = @am__untar@ +bindir = @bindir@ +build = @build@ +build_alias = @build_alias@ +build_cpu = @build_cpu@ +build_os = @build_os@ +build_vendor = @build_vendor@ +builddir = @builddir@ +datadir = @datadir@ +datarootdir = @datarootdir@ +docdir = @docdir@ +dvidir = @dvidir@ +exec_prefix = @exec_prefix@ +host = @host@ +host_alias = @host_alias@ +host_cpu = @host_cpu@ +host_os = @host_os@ +host_vendor = @host_vendor@ +htmldir = @htmldir@ +includedir = @includedir@ +infodir = @infodir@ +install_sh = @install_sh@ +libdir = @libdir@ +libexecdir = @libexecdir@ +localedir = @localedir@ +localstatedir = @localstatedir@ +mandir = @mandir@ +mkdir_p = @mkdir_p@ +oldincludedir = @oldincludedir@ +pdfdir = @pdfdir@ +pkgpyexecdir = @pkgpyexecdir@ +pkgpythondir = @pkgpythondir@ +prefix = @prefix@ +program_transform_name = @program_transform_name@ +psdir = @psdir@ +pyexecdir = @pyexecdir@ +pythondir = @pythondir@ +runstatedir = @runstatedir@ +sbindir = @sbindir@ +sharedstatedir = @sharedstatedir@ +srcdir = @srcdir@ +sysconfdir = @sysconfdir@ +target_alias = @target_alias@ +top_build_prefix = @top_build_prefix@ +top_builddir = @top_builddir@ +top_srcdir = @top_srcdir@ +AM_CPPFLAGS = -I$(top_srcdir)/src/lib -I$(top_builddir)/src/lib \ + $(BOOST_INCLUDES) +AM_CXXFLAGS = $(KEA_CXXFLAGS) +@USE_STATIC_LINK_TRUE@AM_LDFLAGS = -static +CLEANFILES = *.gcno *.gcda +TESTS_ENVIRONMENT = $(LIBTOOL) --mode=execute $(VALGRIND_COMMAND) +@HAVE_GTEST_TRUE@run_unittests_SOURCES = run_unittests.cc \ +@HAVE_GTEST_TRUE@ io_fetch_unittest.cc +@HAVE_GTEST_TRUE@run_unittests_CPPFLAGS = $(AM_CPPFLAGS) $(GTEST_INCLUDES) +@HAVE_GTEST_TRUE@run_unittests_LDADD = $(top_builddir)/src/lib/asiodns/libkea-asiodns.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/asiolink/libkea-asiolink.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/dns/libkea-dns++.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/log/libkea-log.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/util/unittests/libutil_unittests.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/util/libkea-util.la \ +@HAVE_GTEST_TRUE@ $(top_builddir)/src/lib/exceptions/libkea-exceptions.la \ +@HAVE_GTEST_TRUE@ $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) \ +@HAVE_GTEST_TRUE@ $(BOOST_LIBS) $(GTEST_LDADD) +@HAVE_GTEST_TRUE@run_unittests_LDFLAGS = $(AM_LDFLAGS) $(CRYPTO_LDFLAGS) $(GTEST_LDFLAGS) + +# Note: the ordering matters: -Wno-... must follow -Wextra (defined in +# KEA_CXXFLAGS) +@HAVE_GTEST_TRUE@run_unittests_CXXFLAGS = $(AM_CXXFLAGS) \ +@HAVE_GTEST_TRUE@ $(am__append_2) +all: all-am + +.SUFFIXES: +.SUFFIXES: .cc .lo .o .obj +$(srcdir)/Makefile.in: $(srcdir)/Makefile.am $(am__configure_deps) + @for dep in $?; do \ + case '$(am__configure_deps)' in \ + *$$dep*) \ + ( cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh ) \ + && { if test -f $@; then exit 0; else break; fi; }; \ + exit 1;; \ + esac; \ + done; \ + echo ' cd $(top_srcdir) && $(AUTOMAKE) --foreign src/lib/asiodns/tests/Makefile'; \ + $(am__cd) $(top_srcdir) && \ + $(AUTOMAKE) --foreign src/lib/asiodns/tests/Makefile +Makefile: $(srcdir)/Makefile.in $(top_builddir)/config.status + @case '$?' in \ + *config.status*) \ + cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh;; \ + *) \ + echo ' cd $(top_builddir) && $(SHELL) ./config.status $(subdir)/$@ $(am__maybe_remake_depfiles)'; \ + cd $(top_builddir) && $(SHELL) ./config.status $(subdir)/$@ $(am__maybe_remake_depfiles);; \ + esac; + +$(top_builddir)/config.status: $(top_srcdir)/configure $(CONFIG_STATUS_DEPENDENCIES) + cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh + +$(top_srcdir)/configure: $(am__configure_deps) + cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh +$(ACLOCAL_M4): $(am__aclocal_m4_deps) + cd $(top_builddir) && $(MAKE) $(AM_MAKEFLAGS) am--refresh +$(am__aclocal_m4_deps): + +clean-noinstPROGRAMS: + @list='$(noinst_PROGRAMS)'; test -n "$$list" || exit 0; \ + echo " rm -f" $$list; \ + rm -f $$list || exit $$?; \ + test -n "$(EXEEXT)" || exit 0; \ + list=`for p in $$list; do echo "$$p"; done | sed 's/$(EXEEXT)$$//'`; \ + echo " rm -f" $$list; \ + rm -f $$list + +run_unittests$(EXEEXT): $(run_unittests_OBJECTS) $(run_unittests_DEPENDENCIES) $(EXTRA_run_unittests_DEPENDENCIES) + @rm -f run_unittests$(EXEEXT) + $(AM_V_CXXLD)$(run_unittests_LINK) $(run_unittests_OBJECTS) $(run_unittests_LDADD) $(LIBS) + +mostlyclean-compile: + -rm -f *.$(OBJEXT) + +distclean-compile: + -rm -f *.tab.c + +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/run_unittests-io_fetch_unittest.Po@am__quote@ # am--include-marker +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/run_unittests-run_unittests.Po@am__quote@ # am--include-marker + +$(am__depfiles_remade): + @$(MKDIR_P) $(@D) + @echo '# dummy' >$@-t && $(am__mv) $@-t $@ + +am--depfiles: $(am__depfiles_remade) + +.cc.o: +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(CXXCOMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ $< +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Po +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='$<' object='$@' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(CXXCOMPILE) -c -o $@ $< + +.cc.obj: +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(CXXCOMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ `$(CYGPATH_W) '$<'` +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Po +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='$<' object='$@' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(CXXCOMPILE) -c -o $@ `$(CYGPATH_W) '$<'` + +.cc.lo: +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(LTCXXCOMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ $< +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Plo +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='$<' object='$@' libtool=yes @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(LTCXXCOMPILE) -c -o $@ $< + +run_unittests-run_unittests.o: run_unittests.cc +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(run_unittests_CPPFLAGS) $(CPPFLAGS) $(run_unittests_CXXFLAGS) $(CXXFLAGS) -MT run_unittests-run_unittests.o -MD -MP -MF $(DEPDIR)/run_unittests-run_unittests.Tpo -c -o run_unittests-run_unittests.o `test -f 'run_unittests.cc' || echo '$(srcdir)/'`run_unittests.cc +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/run_unittests-run_unittests.Tpo $(DEPDIR)/run_unittests-run_unittests.Po +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='run_unittests.cc' object='run_unittests-run_unittests.o' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(run_unittests_CPPFLAGS) $(CPPFLAGS) $(run_unittests_CXXFLAGS) $(CXXFLAGS) -c -o run_unittests-run_unittests.o `test -f 'run_unittests.cc' || echo '$(srcdir)/'`run_unittests.cc + +run_unittests-run_unittests.obj: run_unittests.cc +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(run_unittests_CPPFLAGS) $(CPPFLAGS) $(run_unittests_CXXFLAGS) $(CXXFLAGS) -MT run_unittests-run_unittests.obj -MD -MP -MF $(DEPDIR)/run_unittests-run_unittests.Tpo -c -o run_unittests-run_unittests.obj `if test -f 'run_unittests.cc'; then $(CYGPATH_W) 'run_unittests.cc'; else $(CYGPATH_W) '$(srcdir)/run_unittests.cc'; fi` +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/run_unittests-run_unittests.Tpo $(DEPDIR)/run_unittests-run_unittests.Po +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='run_unittests.cc' object='run_unittests-run_unittests.obj' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(run_unittests_CPPFLAGS) $(CPPFLAGS) $(run_unittests_CXXFLAGS) $(CXXFLAGS) -c -o run_unittests-run_unittests.obj `if test -f 'run_unittests.cc'; then $(CYGPATH_W) 'run_unittests.cc'; else $(CYGPATH_W) '$(srcdir)/run_unittests.cc'; fi` + +run_unittests-io_fetch_unittest.o: io_fetch_unittest.cc +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(run_unittests_CPPFLAGS) $(CPPFLAGS) $(run_unittests_CXXFLAGS) $(CXXFLAGS) -MT run_unittests-io_fetch_unittest.o -MD -MP -MF $(DEPDIR)/run_unittests-io_fetch_unittest.Tpo -c -o run_unittests-io_fetch_unittest.o `test -f 'io_fetch_unittest.cc' || echo '$(srcdir)/'`io_fetch_unittest.cc +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/run_unittests-io_fetch_unittest.Tpo $(DEPDIR)/run_unittests-io_fetch_unittest.Po +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='io_fetch_unittest.cc' object='run_unittests-io_fetch_unittest.o' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(run_unittests_CPPFLAGS) $(CPPFLAGS) $(run_unittests_CXXFLAGS) $(CXXFLAGS) -c -o run_unittests-io_fetch_unittest.o `test -f 'io_fetch_unittest.cc' || echo '$(srcdir)/'`io_fetch_unittest.cc + +run_unittests-io_fetch_unittest.obj: io_fetch_unittest.cc +@am__fastdepCXX_TRUE@ $(AM_V_CXX)$(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(run_unittests_CPPFLAGS) $(CPPFLAGS) $(run_unittests_CXXFLAGS) $(CXXFLAGS) -MT run_unittests-io_fetch_unittest.obj -MD -MP -MF $(DEPDIR)/run_unittests-io_fetch_unittest.Tpo -c -o run_unittests-io_fetch_unittest.obj `if test -f 'io_fetch_unittest.cc'; then $(CYGPATH_W) 'io_fetch_unittest.cc'; else $(CYGPATH_W) '$(srcdir)/io_fetch_unittest.cc'; fi` +@am__fastdepCXX_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/run_unittests-io_fetch_unittest.Tpo $(DEPDIR)/run_unittests-io_fetch_unittest.Po +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ $(AM_V_CXX)source='io_fetch_unittest.cc' object='run_unittests-io_fetch_unittest.obj' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCXX_FALSE@ DEPDIR=$(DEPDIR) $(CXXDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCXX_FALSE@ $(AM_V_CXX@am__nodep@)$(CXX) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(run_unittests_CPPFLAGS) $(CPPFLAGS) $(run_unittests_CXXFLAGS) $(CXXFLAGS) -c -o run_unittests-io_fetch_unittest.obj `if test -f 'io_fetch_unittest.cc'; then $(CYGPATH_W) 'io_fetch_unittest.cc'; else $(CYGPATH_W) '$(srcdir)/io_fetch_unittest.cc'; fi` + +mostlyclean-libtool: + -rm -f *.lo + +clean-libtool: + -rm -rf .libs _libs + +ID: $(am__tagged_files) + $(am__define_uniq_tagged_files); mkid -fID $$unique +tags: tags-am +TAGS: tags + +tags-am: $(TAGS_DEPENDENCIES) $(am__tagged_files) + set x; \ + here=`pwd`; \ + $(am__define_uniq_tagged_files); \ + shift; \ + if test -z "$(ETAGS_ARGS)$$*$$unique"; then :; else \ + test -n "$$unique" || unique=$$empty_fix; \ + if test $$# -gt 0; then \ + $(ETAGS) $(ETAGSFLAGS) $(AM_ETAGSFLAGS) $(ETAGS_ARGS) \ + "$$@" $$unique; \ + else \ + $(ETAGS) $(ETAGSFLAGS) $(AM_ETAGSFLAGS) $(ETAGS_ARGS) \ + $$unique; \ + fi; \ + fi +ctags: ctags-am + +CTAGS: ctags +ctags-am: $(TAGS_DEPENDENCIES) $(am__tagged_files) + $(am__define_uniq_tagged_files); \ + test -z "$(CTAGS_ARGS)$$unique" \ + || $(CTAGS) $(CTAGSFLAGS) $(AM_CTAGSFLAGS) $(CTAGS_ARGS) \ + $$unique + +GTAGS: + here=`$(am__cd) $(top_builddir) && pwd` \ + && $(am__cd) $(top_srcdir) \ + && gtags -i $(GTAGS_ARGS) "$$here" +cscopelist: cscopelist-am + +cscopelist-am: $(am__tagged_files) + list='$(am__tagged_files)'; \ + case "$(srcdir)" in \ + [\\/]* | ?:[\\/]*) sdir="$(srcdir)" ;; \ + *) sdir=$(subdir)/$(srcdir) ;; \ + esac; \ + for i in $$list; do \ + if test -f "$$i"; then \ + echo "$(subdir)/$$i"; \ + else \ + echo "$$sdir/$$i"; \ + fi; \ + done >> $(top_builddir)/cscope.files + +distclean-tags: + -rm -f TAGS ID GTAGS GRTAGS GSYMS GPATH tags + +check-TESTS: $(TESTS) + @failed=0; all=0; xfail=0; xpass=0; skip=0; \ + srcdir=$(srcdir); export srcdir; \ + list=' $(TESTS) '; \ + $(am__tty_colors); \ + if test -n "$$list"; then \ + for tst in $$list; do \ + if test -f ./$$tst; then dir=./; \ + elif test -f $$tst; then dir=; \ + else dir="$(srcdir)/"; fi; \ + if $(TESTS_ENVIRONMENT) $${dir}$$tst $(AM_TESTS_FD_REDIRECT); then \ + all=`expr $$all + 1`; \ + case " $(XFAIL_TESTS) " in \ + *[\ \ ]$$tst[\ \ ]*) \ + xpass=`expr $$xpass + 1`; \ + failed=`expr $$failed + 1`; \ + col=$$red; res=XPASS; \ + ;; \ + *) \ + col=$$grn; res=PASS; \ + ;; \ + esac; \ + elif test $$? -ne 77; then \ + all=`expr $$all + 1`; \ + case " $(XFAIL_TESTS) " in \ + *[\ \ ]$$tst[\ \ ]*) \ + xfail=`expr $$xfail + 1`; \ + col=$$lgn; res=XFAIL; \ + ;; \ + *) \ + failed=`expr $$failed + 1`; \ + col=$$red; res=FAIL; \ + ;; \ + esac; \ + else \ + skip=`expr $$skip + 1`; \ + col=$$blu; res=SKIP; \ + fi; \ + echo "$${col}$$res$${std}: $$tst"; \ + done; \ + if test "$$all" -eq 1; then \ + tests="test"; \ + All=""; \ + else \ + tests="tests"; \ + All="All "; \ + fi; \ + if test "$$failed" -eq 0; then \ + if test "$$xfail" -eq 0; then \ + banner="$$All$$all $$tests passed"; \ + else \ + if test "$$xfail" -eq 1; then failures=failure; else failures=failures; fi; \ + banner="$$All$$all $$tests behaved as expected ($$xfail expected $$failures)"; \ + fi; \ + else \ + if test "$$xpass" -eq 0; then \ + banner="$$failed of $$all $$tests failed"; \ + else \ + if test "$$xpass" -eq 1; then passes=pass; else passes=passes; fi; \ + banner="$$failed of $$all $$tests did not behave as expected ($$xpass unexpected $$passes)"; \ + fi; \ + fi; \ + dashes="$$banner"; \ + skipped=""; \ + if test "$$skip" -ne 0; then \ + if test "$$skip" -eq 1; then \ + skipped="($$skip test was not run)"; \ + else \ + skipped="($$skip tests were not run)"; \ + fi; \ + test `echo "$$skipped" | wc -c` -le `echo "$$banner" | wc -c` || \ + dashes="$$skipped"; \ + fi; \ + report=""; \ + if test "$$failed" -ne 0 && test -n "$(PACKAGE_BUGREPORT)"; then \ + report="Please report to $(PACKAGE_BUGREPORT)"; \ + test `echo "$$report" | wc -c` -le `echo "$$banner" | wc -c` || \ + dashes="$$report"; \ + fi; \ + dashes=`echo "$$dashes" | sed s/./=/g`; \ + if test "$$failed" -eq 0; then \ + col="$$grn"; \ + else \ + col="$$red"; \ + fi; \ + echo "$${col}$$dashes$${std}"; \ + echo "$${col}$$banner$${std}"; \ + test -z "$$skipped" || echo "$${col}$$skipped$${std}"; \ + test -z "$$report" || echo "$${col}$$report$${std}"; \ + echo "$${col}$$dashes$${std}"; \ + test "$$failed" -eq 0; \ + else :; fi + +distdir: $(BUILT_SOURCES) + $(MAKE) $(AM_MAKEFLAGS) distdir-am + +distdir-am: $(DISTFILES) + @srcdirstrip=`echo "$(srcdir)" | sed 's/[].[^$$\\*]/\\\\&/g'`; \ + topsrcdirstrip=`echo "$(top_srcdir)" | sed 's/[].[^$$\\*]/\\\\&/g'`; \ + list='$(DISTFILES)'; \ + dist_files=`for file in $$list; do echo $$file; done | \ + sed -e "s|^$$srcdirstrip/||;t" \ + -e "s|^$$topsrcdirstrip/|$(top_builddir)/|;t"`; \ + case $$dist_files in \ + */*) $(MKDIR_P) `echo "$$dist_files" | \ + sed '/\//!d;s|^|$(distdir)/|;s,/[^/]*$$,,' | \ + sort -u` ;; \ + esac; \ + for file in $$dist_files; do \ + if test -f $$file || test -d $$file; then d=.; else d=$(srcdir); fi; \ + if test -d $$d/$$file; then \ + dir=`echo "/$$file" | sed -e 's,/[^/]*$$,,'`; \ + if test -d "$(distdir)/$$file"; then \ + find "$(distdir)/$$file" -type d ! -perm -700 -exec chmod u+rwx {} \;; \ + fi; \ + if test -d $(srcdir)/$$file && test $$d != $(srcdir); then \ + cp -fpR $(srcdir)/$$file "$(distdir)$$dir" || exit 1; \ + find "$(distdir)/$$file" -type d ! -perm -700 -exec chmod u+rwx {} \;; \ + fi; \ + cp -fpR $$d/$$file "$(distdir)$$dir" || exit 1; \ + else \ + test -f "$(distdir)/$$file" \ + || cp -p $$d/$$file "$(distdir)/$$file" \ + || exit 1; \ + fi; \ + done +check-am: all-am + $(MAKE) $(AM_MAKEFLAGS) check-TESTS +check: check-am +all-am: Makefile $(PROGRAMS) +installdirs: +install: install-am +install-exec: install-exec-am +install-data: install-data-am +uninstall: uninstall-am + +install-am: all-am + @$(MAKE) $(AM_MAKEFLAGS) install-exec-am install-data-am + +installcheck: installcheck-am +install-strip: + if test -z '$(STRIP)'; then \ + $(MAKE) $(AM_MAKEFLAGS) INSTALL_PROGRAM="$(INSTALL_STRIP_PROGRAM)" \ + install_sh_PROGRAM="$(INSTALL_STRIP_PROGRAM)" INSTALL_STRIP_FLAG=-s \ + install; \ + else \ + $(MAKE) $(AM_MAKEFLAGS) INSTALL_PROGRAM="$(INSTALL_STRIP_PROGRAM)" \ + install_sh_PROGRAM="$(INSTALL_STRIP_PROGRAM)" INSTALL_STRIP_FLAG=-s \ + "INSTALL_PROGRAM_ENV=STRIPPROG='$(STRIP)'" install; \ + fi +mostlyclean-generic: + +clean-generic: + -test -z "$(CLEANFILES)" || rm -f $(CLEANFILES) + +distclean-generic: + -test -z "$(CONFIG_CLEAN_FILES)" || rm -f $(CONFIG_CLEAN_FILES) + -test . = "$(srcdir)" || test -z "$(CONFIG_CLEAN_VPATH_FILES)" || rm -f $(CONFIG_CLEAN_VPATH_FILES) + +maintainer-clean-generic: + @echo "This command is intended for maintainers to use" + @echo "it deletes files that may require special tools to rebuild." +clean: clean-am + +clean-am: clean-generic clean-libtool clean-noinstPROGRAMS \ + mostlyclean-am + +distclean: distclean-am + -rm -f ./$(DEPDIR)/run_unittests-io_fetch_unittest.Po + -rm -f ./$(DEPDIR)/run_unittests-run_unittests.Po + -rm -f Makefile +distclean-am: clean-am distclean-compile distclean-generic \ + distclean-tags + +dvi: dvi-am + +dvi-am: + +html: html-am + +html-am: + +info: info-am + +info-am: + +install-data-am: + +install-dvi: install-dvi-am + +install-dvi-am: + +install-exec-am: + +install-html: install-html-am + +install-html-am: + +install-info: install-info-am + +install-info-am: + +install-man: + +install-pdf: install-pdf-am + +install-pdf-am: + +install-ps: install-ps-am + +install-ps-am: + +installcheck-am: + +maintainer-clean: maintainer-clean-am + -rm -f ./$(DEPDIR)/run_unittests-io_fetch_unittest.Po + -rm -f ./$(DEPDIR)/run_unittests-run_unittests.Po + -rm -f Makefile +maintainer-clean-am: distclean-am maintainer-clean-generic + +mostlyclean: mostlyclean-am + +mostlyclean-am: mostlyclean-compile mostlyclean-generic \ + mostlyclean-libtool + +pdf: pdf-am + +pdf-am: + +ps: ps-am + +ps-am: + +uninstall-am: + +.MAKE: check-am install-am install-strip + +.PHONY: CTAGS GTAGS TAGS all all-am am--depfiles check check-TESTS \ + check-am clean clean-generic clean-libtool \ + clean-noinstPROGRAMS cscopelist-am ctags ctags-am distclean \ + distclean-compile distclean-generic distclean-libtool \ + distclean-tags distdir dvi dvi-am html html-am info info-am \ + install install-am install-data install-data-am install-dvi \ + install-dvi-am install-exec install-exec-am install-html \ + install-html-am install-info install-info-am install-man \ + install-pdf install-pdf-am install-ps install-ps-am \ + install-strip installcheck installcheck-am installdirs \ + maintainer-clean maintainer-clean-generic mostlyclean \ + mostlyclean-compile mostlyclean-generic mostlyclean-libtool \ + pdf pdf-am ps ps-am tags tags-am uninstall uninstall-am + +.PRECIOUS: Makefile + + +# Tell versions [3.59,3.63) of GNU make to not export all variables. +# Otherwise a system limit (for SysV at least) may be exceeded. +.NOEXPORT: diff --git a/src/lib/asiodns/tests/io_fetch_unittest.cc b/src/lib/asiodns/tests/io_fetch_unittest.cc new file mode 100644 index 0000000..628e8fd --- /dev/null +++ b/src/lib/asiodns/tests/io_fetch_unittest.cc @@ -0,0 +1,738 @@ +// Copyright (C) 2011-2020 Internet Systems Consortium, Inc. ("ISC") +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#include <config.h> +#include <asiolink/asio_wrapper.h> +#include <asiolink/io_address.h> +#include <asiolink/io_endpoint.h> +#include <asiolink/io_service.h> +#include <asiodns/io_fetch.h> +#include <dns/question.h> +#include <dns/message.h> +#include <dns/messagerenderer.h> +#include <dns/opcode.h> +#include <dns/name.h> +#include <dns/rcode.h> +#include <util/buffer.h> +#include <util/io_utilities.h> + +#include <gtest/gtest.h> +#include <boost/date_time/posix_time/posix_time_types.hpp> + +#include <algorithm> +#include <cstdlib> +#include <functional> +#include <string> +#include <iostream> +#include <iomanip> +#include <iterator> +#include <vector> + +using namespace boost::asio::ip; +using namespace boost::asio; +using namespace isc::asiolink; +using namespace isc::dns; +using namespace isc::util; +using namespace std; +namespace ph = std::placeholders; + +namespace isc { +namespace asiodns { + +const boost::asio::ip::address TEST_HOST(boost::asio::ip::address::from_string("127.0.0.1")); +const uint16_t TEST_PORT(5301); +const int SEND_INTERVAL = 250; // Interval in ms between TCP sends +const size_t MAX_SIZE = 64 * 1024; // Should be able to take 64kB + +// The tests are complex, so debug output has been left in (although disabled). +// Set this to true to enable it. +const bool DEBUG = false; + +/// \brief Test fixture for the asiolink::IOFetch. +class IOFetchTest : public virtual ::testing::Test, public virtual IOFetch::Callback +{ +public: + IOService service_; ///< Service to run the query + IOFetch::Result expected_; ///< Expected result of the callback + bool run_; ///< Did the callback run already? + Question question_; ///< What to ask + OutputBufferPtr result_buff_; ///< Buffer to hold result of fetch + OutputBufferPtr msgbuf_; ///< Buffer corresponding to known question + IOFetch udp_fetch_; ///< For UDP query test + IOFetch tcp_fetch_; ///< For TCP query test + IOFetch::Protocol protocol_; ///< Protocol being tested + size_t cumulative_; ///< Cumulative data received by "server". + deadline_timer timer_; ///< Timer to measure timeouts + + // The next member is the buffer in which the "server" (implemented by the + // response handler methods in this class) receives the question sent by the + // fetch object. + uint8_t receive_buffer_[MAX_SIZE]; ///< Server receive buffer + OutputBufferPtr expected_buffer_; ///< Data we expect to receive + vector<uint8_t> send_buffer_; ///< Server send buffer + uint16_t send_cumulative_; ///< Data sent so far + + // Other data. + string return_data_; ///< Data returned by server + string test_data_; ///< Large string - here for convenience + bool debug_; ///< true to enable debug output + size_t tcp_send_size_; ///< Max size of TCP send + uint8_t qid_0; ///< First octet of qid + uint8_t qid_1; ///< Second octet of qid + + bool tcp_short_send_; ///< If set to true, we do not send + /// all data in the tcp response + + /// \brief Constructor + IOFetchTest() : + service_(), + expected_(IOFetch::NOTSET), + run_(false), + question_(Name("example.net"), RRClass::IN(), RRType::A()), + result_buff_(new OutputBuffer(512)), + msgbuf_(new OutputBuffer(512)), + udp_fetch_(IOFetch::UDP, service_, question_, IOAddress(TEST_HOST), + TEST_PORT, result_buff_, this, 100), + tcp_fetch_(IOFetch::TCP, service_, question_, IOAddress(TEST_HOST), + TEST_PORT, result_buff_, this, (24 * SEND_INTERVAL)), + // Timeout interval chosen to ensure no timeout + protocol_(IOFetch::TCP), // for initialization - will be changed + cumulative_(0), + timer_(service_.get_io_service()), + receive_buffer_(), + expected_buffer_(new OutputBuffer(512)), + send_buffer_(), + send_cumulative_(0), + return_data_(""), + test_data_(""), + debug_(DEBUG), + tcp_send_size_(0), + qid_0(0), + qid_1(0), + tcp_short_send_(false) + { + // Construct the data buffer for question we expect to receive. + Message msg(Message::RENDER); + msg.setQid(0); + msg.setOpcode(Opcode::QUERY()); + msg.setRcode(Rcode::NOERROR()); + msg.setHeaderFlag(Message::HEADERFLAG_RD); + msg.addQuestion(question_); + EDNSPtr msg_edns(new EDNS()); + msg_edns->setUDPSize(Message::DEFAULT_MAX_EDNS0_UDPSIZE); + msg.setEDNS(msg_edns); + + MessageRenderer renderer; + renderer.setBuffer(msgbuf_.get()); + msg.toWire(renderer); + renderer.setBuffer(NULL); + + renderer.setBuffer(expected_buffer_.get()); + msg.toWire(renderer); + renderer.setBuffer(NULL); + + // Initialize the test data to be returned: tests will return a + // substring of this data. (It's convenient to have this as a member of + // the class.) + // + // We could initialize the data with a single character, but as an added + // check we'll make ssre that it has some structure. + + test_data_.clear(); + test_data_.reserve(MAX_SIZE); + while (test_data_.size() < MAX_SIZE) { + test_data_ += "A message to be returned to the client that has " + "some sort of structure."; + } + } + + /// \brief UDP Response handler (the "remote UDP DNS server") + /// + /// When IOFetch is sending data, this response handler emulates the remote + /// DNS server. It checks that the data sent by the IOFetch object is what + /// was expected to have been sent, then sends back a known buffer of data. + /// + /// \param remote Endpoint to which to send the answer + /// \param socket Socket to use to send the answer + /// \param ec ASIO error code, completion code of asynchronous I/O issued + /// by the "server" to receive data. + /// \param bad_qid If set to true, the QID in the response will be mangled + /// \param second_send If set to true, (and bad_qid is too), after the + /// mangled qid response has been sent, a second packet will be + /// sent with the correct QID. + /// \param length Amount of data received. + void udpReceiveHandler(udp::endpoint* remote, udp::socket* socket, + boost::system::error_code ec = boost::system::error_code(), + size_t length = 0, bool bad_qid = false, + bool second_send = false) + { + if (debug_) { + cout << "udpReceiveHandler(): error = " << ec.value() << + ", length = " << length << endl; + } + + // The QID in the incoming data is random so set it to 0 for the + // data comparison check. (It is set to 0 in the buffer containing + // the expected data.) + qid_0 = receive_buffer_[0]; + qid_1 = receive_buffer_[1]; + receive_buffer_[0] = receive_buffer_[1] = 0; + + // Check that length of the received data and the expected data are + // identical, then check that the data is identical as well. + EXPECT_EQ(msgbuf_->getLength(), length); + EXPECT_TRUE(equal(receive_buffer_, (receive_buffer_ + length - 1), + static_cast<const uint8_t*>(msgbuf_->getData()))); + + // Return a message back to the IOFetch object. + if (!bad_qid) { + expected_buffer_->writeUint8At(qid_0, 0); + expected_buffer_->writeUint8At(qid_1, 1); + } else { + expected_buffer_->writeUint8At(qid_0 + 1, 0); + expected_buffer_->writeUint8At(qid_1 + 1, 1); + } + socket->send_to(boost::asio::buffer(expected_buffer_->getData(), length), *remote); + + if (bad_qid && second_send) { + expected_buffer_->writeUint8At(qid_0, 0); + expected_buffer_->writeUint8At(qid_1, 1); + socket->send_to(boost::asio::buffer(expected_buffer_->getData(), + expected_buffer_->getLength()), *remote); + } + if (debug_) { + cout << "udpReceiveHandler(): returned " << expected_buffer_->getLength() << + " bytes to the client" << endl; + } + } + + /// \brief Completion Handler for accepting TCP data + /// + /// Called when the remote system connects to the "server". It issues + /// an asynchronous read on the socket to read data. + /// + /// \param socket Socket on which data will be received + /// \param ec Boost error code, value should be zero. + void tcpAcceptHandler(tcp::socket* socket, + boost::system::error_code ec = boost::system::error_code()) + { + if (debug_) { + cout << "tcpAcceptHandler(): error = " << ec.value() << endl; + } + + // Expect that the accept completed without a problem. + EXPECT_EQ(0, ec.value()); + + // Work out the maximum size of data we can send over it when we + // respond, then subtract 1kB or so for safety. + tcp::socket::send_buffer_size send_size; + socket->get_option(send_size); + if (send_size.value() < (2 * 1024)) { + FAIL() << "TCP send size is less than 2kB"; + } else { + tcp_send_size_ = send_size.value() - 1024; + if (debug_) { + cout << "tcpacceptHandler(): will use send size = " << tcp_send_size_ << endl; + } + } + + // Initiate a read on the socket. + cumulative_ = 0; + socket->async_receive(boost::asio::buffer(receive_buffer_, sizeof(receive_buffer_)), + std::bind(&IOFetchTest::tcpReceiveHandler, this, socket, ph::_1, ph::_2)); + } + + /// \brief Completion handler for receiving TCP data + /// + /// When IOFetch is sending data, this response handler emulates the remote + /// DNS server. It that all the data sent by the IOFetch object has been + /// received, issuing another read if not. If the data is complete, it is + /// compared to what is expected and a reply sent back to the IOFetch. + /// + /// \param socket Socket to use to send the answer + /// \param ec ASIO error code, completion code of asynchronous I/O issued + /// by the "server" to receive data. + /// \param length Amount of data received. + void tcpReceiveHandler(tcp::socket* socket, + boost::system::error_code ec = boost::system::error_code(), + size_t length = 0) + { + if (debug_) { + cout << "tcpReceiveHandler(): error = " << ec.value() << + ", length = " << length << endl; + } + // Expect that the receive completed without a problem. + EXPECT_EQ(0, ec.value()); + + // If we haven't received all the data, issue another read. + cumulative_ += length; + bool complete = false; + if (cumulative_ > 2) { + uint16_t dns_length = readUint16(receive_buffer_, + sizeof(receive_buffer_)); + complete = ((dns_length + 2) == cumulative_); + } + + if (!complete) { + socket->async_receive(boost::asio::buffer((receive_buffer_ + cumulative_), + (sizeof(receive_buffer_) - cumulative_)), + std::bind(&IOFetchTest::tcpReceiveHandler, this, socket, ph::_1, ph::_2)); + return; + } + + // Check that length of the DNS message received is that expected, then + // compare buffers, zeroing the QID in the received buffer to match + // that set in our expected question. Note that due to the length + // field the QID in the received buffer is in the third and fourth + // bytes. + EXPECT_EQ(msgbuf_->getLength() + 2, cumulative_); + qid_0 = receive_buffer_[2]; + qid_1 = receive_buffer_[3]; + + receive_buffer_[2] = receive_buffer_[3] = 0; + EXPECT_TRUE(equal((receive_buffer_ + 2), (receive_buffer_ + cumulative_ - 2), + static_cast<const uint8_t*>(msgbuf_->getData()))); + + // ... and return a message back. This has to be preceded by a two-byte + // count field. + + send_buffer_.clear(); + send_buffer_.push_back(0); + send_buffer_.push_back(0); + // send_buffer_.capacity() seems more logical below, but the + // code above fills in the first two bytes and size() becomes 2 + // (sizeof uint16_t). + writeUint16(return_data_.size(), &send_buffer_[0], send_buffer_.size()); + copy(return_data_.begin(), return_data_.end(), back_inserter(send_buffer_)); + if (return_data_.size() >= 2) { + send_buffer_[2] = qid_0; + send_buffer_[3] = qid_1; + } + // Send the data. This is done in multiple writes with a delay between + // each to check that the reassembly of TCP packets from fragments works. + send_cumulative_ = 0; + tcpSendData(socket); + } + + /// \brief Sent Data Over TCP + /// + /// Send the TCP data back to the IOFetch object. The data is sent in + /// three chunks - two of 16 bytes and the remainder, with a 250ms gap + /// between each. (Amounts of data smaller than one 32 bytes are sent in + /// one or two packets.) + /// + /// \param socket Socket over which send should take place + void tcpSendData(tcp::socket* socket) { + if (debug_) { + cout << "tcpSendData()" << endl; + } + + // Decide what to send based on the cumulative count. At most we'll do + // two chunks of 16 bytes (with a 250ms gap between) and then the + // remainder. + uint8_t* send_ptr = &send_buffer_[send_cumulative_]; + // Pointer to data to send + size_t amount = 16; // Amount of data to send + if (send_cumulative_ < (2 * amount)) { + + // First or second time through, send at most 16 bytes + amount = min(amount, (send_buffer_.size() - send_cumulative_)); + + } else { + + // For all subsequent times, send the remainder, maximised to + // whatever we have chosen for the maximum send size. + amount = min(tcp_send_size_, + (send_buffer_.size() - send_cumulative_)); + } + + // This is for the short send test; reduce the actual amount of + // data we send + if (tcp_short_send_) { + if (debug_) { + cout << "tcpSendData(): sending incomplete data (" << + (amount - 1) << " of " << amount << " bytes)" << + endl; + } + --amount; + } else { + if (debug_) { + cout << "tcpSendData(): sending " << amount << " bytes" << endl; + } + } + + // ... and send it. The amount sent is also passed as the first + // argument of the send callback, as a check. + socket->async_send(boost::asio::buffer(send_ptr, amount), + std::bind(&IOFetchTest::tcpSendHandler, this, + amount, socket, ph::_1, ph::_2)); + } + + /// \brief Completion Handler for Sending TCP data + /// + /// Called when the asynchronous send of data back to the IOFetch object + /// by the TCP "server" in this class has completed. (This send has to + /// be asynchronous because control needs to return to the caller in order + /// for the IOService "run()" method to be called to run the handlers.) + /// + /// If not all the data has been sent, a short delay is instigated (during + /// which control returns to the IOService). This should force the queued + /// data to actually be sent and the IOFetch receive handler to be triggered. + /// In this way, the ability of IOFetch to handle fragmented TCP packets + /// should be checked. + /// + /// \param expected Number of bytes that were expected to have been sent. + /// \param socket Socket over which the send took place. Only used to + /// pass back to the send method. + /// \param ec Boost error code, value should be zero. + /// \param length Number of bytes sent. + void tcpSendHandler(size_t expected, tcp::socket* socket, + boost::system::error_code ec = boost::system::error_code(), + size_t length = 0) + { + if (debug_) { + cout << "tcpSendHandler(): error = " << ec.value() << + ", length = " << length << endl; + } + + EXPECT_EQ(0, ec.value()); // Expect no error + EXPECT_EQ(expected, length); // And that amount sent is as expected + + // Do we need to send more? + send_cumulative_ += length; + if (send_cumulative_ < send_buffer_.size()) { + + // Yes - set up a timer: the callback handler for the timer is + // tcpSendData, which will then send the next chunk. We pass the + // socket over which data should be sent as an argument to that + // function. + timer_.expires_from_now(boost::posix_time::milliseconds(SEND_INTERVAL)); + timer_.async_wait(std::bind(&IOFetchTest::tcpSendData, this, + socket)); + } + } + + /// \brief Fetch completion callback + /// + /// This is the callback's operator() method which is called when the fetch + /// is complete. It checks that the data received is the wire format of the + /// data sent back by the server. + /// + /// \param result Result indicated by the callback + void operator()(IOFetch::Result result) { + if (debug_) { + cout << "operator()(): result = " << result << endl; + } + + EXPECT_EQ(expected_, result); // Check correct result returned + EXPECT_FALSE(run_); // Check it is run only once + run_ = true; // Note success + + // If the expected result for SUCCESS, then this should have been called + // when one of the "servers" in this class has sent back return_data_. + // Check the data is as expected/ + if (expected_ == IOFetch::SUCCESS) { + // In the case of UDP, we actually send back a real looking packet + // in the case of TCP, we send back a 'random' string + if (protocol_ == IOFetch::UDP) { + EXPECT_EQ(expected_buffer_->getLength(), result_buff_->getLength()); + EXPECT_EQ(0, memcmp(expected_buffer_->getData(), result_buff_->getData(), + expected_buffer_->getLength())); + } else { + EXPECT_EQ(return_data_.size(), result_buff_->getLength()); + // Overwrite the random qid with our own data for the + // comparison to succeed + if (result_buff_->getLength() >= 2) { + result_buff_->writeUint8At(return_data_[0], 0); + result_buff_->writeUint8At(return_data_[1], 1); + } + const uint8_t* start = static_cast<const uint8_t*>(result_buff_->getData()); + EXPECT_TRUE(equal(return_data_.begin(), return_data_.end(), start)); + } + } + + // ... and cause the run loop to exit. + service_.stop(); + } + + // The next set of methods are the tests themselves. A number of the TCP + // and UDP tests are very similar. + + /// \brief Check for stop() + /// + /// Test that when we run the query and stop it after it was run, it returns + /// "stopped" correctly. (That is why stop() is posted to the service_ as + /// well instead of calling it.) + /// + /// \param protocol Test protocol + /// \param fetch Fetch object being tested + void stopTest(IOFetch::Protocol protocol, IOFetch& fetch) { + protocol_ = protocol; + expected_ = IOFetch::STOPPED; + + // Post the query + service_.get_io_service().post(fetch); + + // Post query_.stop() (yes, the std::bind thing is just + // query_.stop()). + service_.get_io_service().post( + std::bind(&IOFetch::stop, fetch, IOFetch::STOPPED)); + + // Run both of them. run() returns when everything in the I/O service + // queue has completed. + service_.run(); + EXPECT_TRUE(run_); + } + + /// \brief Premature stop test + /// + /// Test that when we queue the query to service_ and call stop() before it + /// gets executed, it acts sanely as well (eg. has the same result as + /// running stop() after - calls the callback). + /// + /// \param protocol Test protocol + /// \param fetch Fetch object being tested + void prematureStopTest(IOFetch::Protocol protocol, IOFetch& fetch) { + protocol_ = protocol; + expected_ = IOFetch::STOPPED; + + // Stop before it is started + fetch.stop(); + service_.get_io_service().post(fetch); + + service_.run(); + EXPECT_TRUE(run_); + } + + /// \brief Timeout test + /// + /// Test that fetch times out when no answer arrives. + /// + /// \param protocol Test protocol + /// \param fetch Fetch object being tested + void timeoutTest(IOFetch::Protocol protocol, IOFetch& fetch) { + protocol_ = protocol; + expected_ = IOFetch::TIME_OUT; + + service_.get_io_service().post(fetch); + service_.run(); + EXPECT_TRUE(run_); + } + + /// \brief Send/Receive Test + /// + /// Send a query to the server then receives a response. + /// + /// \param Test data to return to client + /// \param short_send If true, do not send all data + /// (should result in timeout) + void tcpSendReturnTest(const std::string& return_data, bool short_send = false) { + if (debug_) { + cout << "tcpSendReturnTest(): data size = " << return_data.size() << endl; + } + return_data_ = return_data; + protocol_ = IOFetch::TCP; + if (short_send) { + tcp_short_send_ = true; + expected_ = IOFetch::TIME_OUT; + } else { + expected_ = IOFetch::SUCCESS; + } + + // Socket into which the connection will be accepted. + tcp::socket socket(service_.get_io_service()); + + // Acceptor object - called when the connection is made, the handler + // will initiate a read on the socket. + tcp::acceptor acceptor(service_.get_io_service(), + tcp::endpoint(tcp::v4(), TEST_PORT)); + acceptor.async_accept(socket, + std::bind(&IOFetchTest::tcpAcceptHandler, this, &socket, ph::_1)); + + // Post the TCP fetch object to send the query and receive the response. + service_.get_io_service().post(tcp_fetch_); + + // ... and execute all the callbacks. This exits when the fetch + // completes. + service_.run(); + EXPECT_TRUE(run_); // Make sure the callback did execute + + // Tidy up + socket.close(); + } + + /// Perform a send/receive test over UDP + /// + /// \param bad_qid If true, do the test where the QID is mangled + /// in the response + /// \param second_send If true, do the test where the QID is + /// mangled in the response, but a second + /// (correct) packet is used + void udpSendReturnTest(bool bad_qid, bool second_send) { + protocol_ = IOFetch::UDP; + + // Set up the server. + udp::socket socket(service_.get_io_service(), udp::v4()); + socket.set_option(socket_base::reuse_address(true)); + socket.bind(udp::endpoint(TEST_HOST, TEST_PORT)); + return_data_ = "Message returned to the client"; + + udp::endpoint remote; + socket.async_receive_from(boost::asio::buffer(receive_buffer_, + sizeof(receive_buffer_)), + remote, + std::bind(&IOFetchTest::udpReceiveHandler, + this, &remote, &socket, + ph::_1, ph::_2, bad_qid, second_send)); + service_.get_io_service().post(udp_fetch_); + if (debug_) { + cout << "udpSendReceive: async_receive_from posted," + "waiting for callback" << endl; + } + service_.run(); + + socket.close(); + + EXPECT_TRUE(run_); + } +}; + +// Check the protocol +TEST_F(IOFetchTest, Protocol) { + EXPECT_EQ(IOFetch::UDP, udp_fetch_.getProtocol()); + EXPECT_EQ(IOFetch::TCP, tcp_fetch_.getProtocol()); +} + +// UDP Stop test - see IOFetchTest::stopTest() header. +TEST_F(IOFetchTest, UdpStop) { + stopTest(IOFetch::UDP, udp_fetch_); +} + +// UDP premature stop test - see IOFetchTest::prematureStopTest() header. +TEST_F(IOFetchTest, UdpPrematureStop) { + prematureStopTest(IOFetch::UDP, udp_fetch_); +} + +// UDP premature stop test - see IOFetchTest::timeoutTest() header. +TEST_F(IOFetchTest, UdpTimeout) { + timeoutTest(IOFetch::UDP, udp_fetch_); +} + +// UDP SendReceive test. Set up a UDP server then ports a UDP fetch object. +// This will send question_ to the server and receive the answer back from it. +TEST_F(IOFetchTest, UdpSendReceive) { + expected_ = IOFetch::SUCCESS; + + udpSendReturnTest(false, false); + + EXPECT_TRUE(run_);; +} + +TEST_F(IOFetchTest, UdpSendReceiveBadQid) { + expected_ = IOFetch::TIME_OUT; + + udpSendReturnTest(true, false); + + EXPECT_TRUE(run_);; +} + +TEST_F(IOFetchTest, UdpSendReceiveBadQidResend) { + expected_ = IOFetch::SUCCESS; + + udpSendReturnTest(true, true); + + EXPECT_TRUE(run_);; +} + +// Do the same tests for TCP transport + +TEST_F(IOFetchTest, TcpStop) { + stopTest(IOFetch::TCP, tcp_fetch_); +} + +TEST_F(IOFetchTest, TcpPrematureStop) { + prematureStopTest(IOFetch::TCP, tcp_fetch_); +} + +TEST_F(IOFetchTest, TcpTimeout) { + timeoutTest(IOFetch::TCP, tcp_fetch_); +} + +// Test with values at or near 2, then at or near the chunk size (16 and 32 +// bytes, the sizes of the first two packets) then up to 65535. These are done +// in separate tests because in practice a new IOFetch is created for each +// query/response exchange and we don't want to confuse matters in the test +// by running the test with an IOFetch that has already done one exchange. +// +// Don't do 0 or 1; the server would not accept the packet +// (since the length is too short to check the qid) +TEST_F(IOFetchTest, TcpSendReceive2) { + tcpSendReturnTest(test_data_.substr(0, 2)); +} + +TEST_F(IOFetchTest, TcpSendReceive3) { + tcpSendReturnTest(test_data_.substr(0, 3)); +} + +TEST_F(IOFetchTest, TcpSendReceive15) { + tcpSendReturnTest(test_data_.substr(0, 15)); +} + +TEST_F(IOFetchTest, TcpSendReceive16) { + tcpSendReturnTest(test_data_.substr(0, 16)); +} + +TEST_F(IOFetchTest, TcpSendReceive17) { + tcpSendReturnTest(test_data_.substr(0, 17)); +} + +TEST_F(IOFetchTest, TcpSendReceive31) { + tcpSendReturnTest(test_data_.substr(0, 31)); +} + +TEST_F(IOFetchTest, TcpSendReceive32) { + tcpSendReturnTest(test_data_.substr(0, 32)); +} + +TEST_F(IOFetchTest, TcpSendReceive33) { + tcpSendReturnTest(test_data_.substr(0, 33)); +} + +TEST_F(IOFetchTest, TcpSendReceive4096) { + tcpSendReturnTest(test_data_.substr(0, 4096)); +} + +TEST_F(IOFetchTest, TcpSendReceive8192) { + tcpSendReturnTest(test_data_.substr(0, 8192)); +} + +TEST_F(IOFetchTest, TcpSendReceive16384) { + tcpSendReturnTest(test_data_.substr(0, 16384)); +} + +TEST_F(IOFetchTest, TcpSendReceive32768) { + tcpSendReturnTest(test_data_.substr(0, 32768)); +} + +TEST_F(IOFetchTest, TcpSendReceive65535) { + tcpSendReturnTest(test_data_.substr(0, 65535)); +} + +TEST_F(IOFetchTest, TcpSendReceive2ShortSend) { + tcpSendReturnTest(test_data_.substr(0, 2), true); +} + +TEST_F(IOFetchTest, TcpSendReceive15ShortSend) { + tcpSendReturnTest(test_data_.substr(0, 15), true); +} + +TEST_F(IOFetchTest, TcpSendReceive8192ShortSend) { + tcpSendReturnTest(test_data_.substr(0, 8192), true); +} + + +} // namespace asiodns +} // namespace isc diff --git a/src/lib/asiodns/tests/run_unittests.cc b/src/lib/asiodns/tests/run_unittests.cc new file mode 100644 index 0000000..5d71cc9 --- /dev/null +++ b/src/lib/asiodns/tests/run_unittests.cc @@ -0,0 +1,21 @@ +// Copyright (C) 2009-2015 Internet Systems Consortium, Inc. ("ISC") +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#include <config.h> + +#include <gtest/gtest.h> +#include <util/unittests/run_all.h> + +#include <log/logger_support.h> + +int +main(int argc, char* argv[]) +{ + ::testing::InitGoogleTest(&argc, argv); // Initialize Google test + isc::log::initLogger(); // Initialize logging + + return (isc::util::unittests::run_all()); +} |