diff options
Diffstat (limited to 'src/dv')
| -rw-r--r-- | src/dv/Makefile.am | 79 | ||||
| -rw-r--r-- | src/dv/Makefile.in | 955 | ||||
| -rw-r--r-- | src/dv/dv.conf.in | 18 | ||||
| -rw-r--r-- | src/dv/dv.h | 275 | ||||
| -rw-r--r-- | src/dv/dv_api.c | 628 | ||||
| -rw-r--r-- | src/dv/gnunet-service-dv.c | 3335 | ||||
| -rw-r--r-- | src/dv/plugin_transport_dv.c | 452 | ||||
| -rw-r--r-- | src/dv/test_transport_api_dv.c | 1247 | ||||
| -rw-r--r-- | src/dv/test_transport_dv_data.conf | 79 |
9 files changed, 7068 insertions, 0 deletions
diff --git a/src/dv/Makefile.am b/src/dv/Makefile.am new file mode 100644 index 0000000..e0cd2e4 --- /dev/null +++ b/src/dv/Makefile.am @@ -0,0 +1,79 @@ +INCLUDES = -I$(top_srcdir)/src/include + +if MINGW + WINFLAGS = -Wl,--no-undefined -Wl,--export-all-symbols +endif + +if USE_COVERAGE + AM_CFLAGS = --coverage -O0 + XLIB = -lgcov +endif + +plugindir = $(libdir)/gnunet + +pkgcfgdir= $(pkgdatadir)/config.d/ + +pkgcfg_DATA = \ + dv.conf + +lib_LTLIBRARIES = libgnunetdv.la + +plugin_LTLIBRARIES = libgnunet_plugin_transport_dv.la + +libgnunetdv_la_SOURCES = \ + dv_api.c dv.h +libgnunetdv_la_LIBADD = \ + $(top_builddir)/src/util/libgnunetutil.la \ + $(top_builddir)/src/core/libgnunetcore.la \ + $(GN_LIBINTL) $(XLIB) +libgnunetdv_la_LDFLAGS = \ + $(GN_LIB_LDFLAGS) $(WINFLAGS) \ + -version-info 0:0:0 + + +bin_PROGRAMS = \ + gnunet-service-dv + +gnunet_service_dv_SOURCES = \ + gnunet-service-dv.c +gnunet_service_dv_LDADD = \ + $(top_builddir)/src/statistics/libgnunetstatistics.la \ + $(top_builddir)/src/dv/libgnunetdv.la \ + $(top_builddir)/src/core/libgnunetcore.la \ + $(top_builddir)/src/hello/libgnunethello.la \ + $(top_builddir)/src/peerinfo/libgnunetpeerinfo.la \ + $(top_builddir)/src/util/libgnunetutil.la \ + $(GN_LIBINTL) +gnunet_service_dv_DEPENDENCIES = \ + libgnunetdv.la + +libgnunet_plugin_transport_dv_la_SOURCES = \ + plugin_transport_dv.c +libgnunet_plugin_transport_dv_la_LIBADD = \ + $(top_builddir)/src/hello/libgnunethello.la \ + $(top_builddir)/src/dv/libgnunetdv.la \ + $(top_builddir)/src/peerinfo/libgnunetpeerinfo.la \ + $(top_builddir)/src/util/libgnunetutil.la +libgnunet_plugin_transport_dv_la_LDFLAGS = \ + $(GN_PLUGIN_LDFLAGS) +libgnunet_plugin_transport_dv_la_DEPENDENCIES = \ + libgnunetdv.la + +check_PROGRAMS = \ + test_transport_api_dv +# test_dv_topology + +if ENABLE_TEST_RUN +TESTS = $(check_PROGRAMS) $(check_SCRIPTS) +endif + +test_transport_api_dv_SOURCES = \ + test_transport_api_dv.c +test_transport_api_dv_LDADD = \ + $(top_builddir)/src/core/libgnunetcore.la \ + $(top_builddir)/src/transport/libgnunettransport.la \ + $(top_builddir)/src/util/libgnunetutil.la \ + $(top_builddir)/src/testing/libgnunettesting.la + +EXTRA_DIST = \ + test_transport_dv_data.conf diff --git a/src/dv/Makefile.in b/src/dv/Makefile.in new file mode 100644 index 0000000..93f5228 --- /dev/null +++ b/src/dv/Makefile.in @@ -0,0 +1,955 @@ +# Makefile.in generated by automake 1.11.1 from Makefile.am. +# @configure_input@ + +# Copyright (C) 1994, 1995, 1996, 1997, 1998, 1999, 2000, 2001, 2002, +# 2003, 2004, 2005, 2006, 2007, 2008, 2009 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@ +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@ +target_triplet = @target@ +bin_PROGRAMS = gnunet-service-dv$(EXEEXT) +check_PROGRAMS = test_transport_api_dv$(EXEEXT) +@ENABLE_TEST_RUN_TRUE@TESTS = $(check_PROGRAMS) +subdir = src/dv +DIST_COMMON = $(srcdir)/Makefile.am $(srcdir)/Makefile.in \ + $(srcdir)/dv.conf.in +ACLOCAL_M4 = $(top_srcdir)/aclocal.m4 +am__aclocal_m4_deps = $(top_srcdir)/m4/absolute-header.m4 \ + $(top_srcdir)/m4/align.m4 $(top_srcdir)/m4/argz.m4 \ + $(top_srcdir)/m4/gettext.m4 $(top_srcdir)/m4/iconv.m4 \ + $(top_srcdir)/m4/lib-ld.m4 $(top_srcdir)/m4/lib-link.m4 \ + $(top_srcdir)/m4/lib-prefix.m4 $(top_srcdir)/m4/libcurl.m4 \ + $(top_srcdir)/m4/libgcrypt.m4 $(top_srcdir)/m4/libtool.m4 \ + $(top_srcdir)/m4/libunistring.m4 $(top_srcdir)/m4/ltdl.m4 \ + $(top_srcdir)/m4/ltoptions.m4 $(top_srcdir)/m4/ltsugar.m4 \ + $(top_srcdir)/m4/ltversion.m4 $(top_srcdir)/m4/lt~obsolete.m4 \ + $(top_srcdir)/m4/nls.m4 $(top_srcdir)/m4/po.m4 \ + $(top_srcdir)/m4/progtest.m4 $(top_srcdir)/acinclude.m4 \ + $(top_srcdir)/configure.ac +am__configure_deps = $(am__aclocal_m4_deps) $(CONFIGURE_DEPENDENCIES) \ + $(ACLOCAL_M4) +mkinstalldirs = $(install_sh) -d +CONFIG_HEADER = $(top_builddir)/gnunet_config.h +CONFIG_CLEAN_FILES = dv.conf +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__installdirs = "$(DESTDIR)$(libdir)" "$(DESTDIR)$(plugindir)" \ + "$(DESTDIR)$(bindir)" "$(DESTDIR)$(pkgcfgdir)" +LTLIBRARIES = $(lib_LTLIBRARIES) $(plugin_LTLIBRARIES) +am_libgnunet_plugin_transport_dv_la_OBJECTS = plugin_transport_dv.lo +libgnunet_plugin_transport_dv_la_OBJECTS = \ + $(am_libgnunet_plugin_transport_dv_la_OBJECTS) +AM_V_lt = $(am__v_lt_$(V)) +am__v_lt_ = $(am__v_lt_$(AM_DEFAULT_VERBOSITY)) +am__v_lt_0 = --silent +libgnunet_plugin_transport_dv_la_LINK = $(LIBTOOL) $(AM_V_lt) --tag=CC \ + $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=link $(CCLD) \ + $(AM_CFLAGS) $(CFLAGS) \ + $(libgnunet_plugin_transport_dv_la_LDFLAGS) $(LDFLAGS) -o $@ +am__DEPENDENCIES_1 = +libgnunetdv_la_DEPENDENCIES = \ + $(top_builddir)/src/util/libgnunetutil.la \ + $(top_builddir)/src/core/libgnunetcore.la \ + $(am__DEPENDENCIES_1) $(am__DEPENDENCIES_1) +am_libgnunetdv_la_OBJECTS = dv_api.lo +libgnunetdv_la_OBJECTS = $(am_libgnunetdv_la_OBJECTS) +libgnunetdv_la_LINK = $(LIBTOOL) $(AM_V_lt) --tag=CC \ + $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=link $(CCLD) \ + $(AM_CFLAGS) $(CFLAGS) $(libgnunetdv_la_LDFLAGS) $(LDFLAGS) -o \ + $@ +PROGRAMS = $(bin_PROGRAMS) +am_gnunet_service_dv_OBJECTS = gnunet-service-dv.$(OBJEXT) +gnunet_service_dv_OBJECTS = $(am_gnunet_service_dv_OBJECTS) +am_test_transport_api_dv_OBJECTS = test_transport_api_dv.$(OBJEXT) +test_transport_api_dv_OBJECTS = $(am_test_transport_api_dv_OBJECTS) +test_transport_api_dv_DEPENDENCIES = \ + $(top_builddir)/src/core/libgnunetcore.la \ + $(top_builddir)/src/transport/libgnunettransport.la \ + $(top_builddir)/src/util/libgnunetutil.la \ + $(top_builddir)/src/testing/libgnunettesting.la +DEFAULT_INCLUDES = -I.@am__isrc@ -I$(top_builddir) +depcomp = $(SHELL) $(top_srcdir)/depcomp +am__depfiles_maybe = depfiles +am__mv = mv -f +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_$(V)) +am__v_CC_ = $(am__v_CC_$(AM_DEFAULT_VERBOSITY)) +am__v_CC_0 = @echo " CC " $@; +AM_V_at = $(am__v_at_$(V)) +am__v_at_ = $(am__v_at_$(AM_DEFAULT_VERBOSITY)) +am__v_at_0 = @ +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_$(V)) +am__v_CCLD_ = $(am__v_CCLD_$(AM_DEFAULT_VERBOSITY)) +am__v_CCLD_0 = @echo " CCLD " $@; +AM_V_GEN = $(am__v_GEN_$(V)) +am__v_GEN_ = $(am__v_GEN_$(AM_DEFAULT_VERBOSITY)) +am__v_GEN_0 = @echo " GEN " $@; +SOURCES = $(libgnunet_plugin_transport_dv_la_SOURCES) \ + $(libgnunetdv_la_SOURCES) $(gnunet_service_dv_SOURCES) \ + $(test_transport_api_dv_SOURCES) +DIST_SOURCES = $(libgnunet_plugin_transport_dv_la_SOURCES) \ + $(libgnunetdv_la_SOURCES) $(gnunet_service_dv_SOURCES) \ + $(test_transport_api_dv_SOURCES) +DATA = $(pkgcfg_DATA) +ETAGS = etags +CTAGS = ctags +am__tty_colors = \ +red=; grn=; lgn=; blu=; std= +DISTFILES = $(DIST_COMMON) $(DIST_SOURCES) $(TEXINFOS) $(EXTRA_DIST) +ACLOCAL = @ACLOCAL@ +AMTAR = @AMTAR@ +AM_DEFAULT_VERBOSITY = @AM_DEFAULT_VERBOSITY@ +AR = @AR@ +ARGZ_H = @ARGZ_H@ +AS = @AS@ +AUTOCONF = @AUTOCONF@ +AUTOHEADER = @AUTOHEADER@ +AUTOMAKE = @AUTOMAKE@ +AWK = @AWK@ +CC = @CC@ +CCDEPMODE = @CCDEPMODE@ +CFLAGS = @CFLAGS@ +CPP = @CPP@ +CPPFLAGS = @CPPFLAGS@ +CXX = @CXX@ +CXXCPP = @CXXCPP@ +CXXDEPMODE = @CXXDEPMODE@ +CXXFLAGS = @CXXFLAGS@ +CYGPATH_W = @CYGPATH_W@ +DEFAULT_INTERFACE = @DEFAULT_INTERFACE@ +DEFS = @DEFS@ +DEPDIR = @DEPDIR@ +DLLDIR = @DLLDIR@ +DLLTOOL = @DLLTOOL@ +DSYMUTIL = @DSYMUTIL@ +DUMPBIN = @DUMPBIN@ +ECHO_C = @ECHO_C@ +ECHO_N = @ECHO_N@ +ECHO_T = @ECHO_T@ +EGREP = @EGREP@ +EXEEXT = @EXEEXT@ +EXT_LIBS = @EXT_LIBS@ +EXT_LIB_PATH = @EXT_LIB_PATH@ +FGREP = @FGREP@ +GMSGFMT = @GMSGFMT@ +GMSGFMT_015 = @GMSGFMT_015@ +GNUNETDNS_GROUP = @GNUNETDNS_GROUP@ +GN_DAEMON_CONFIG_DIR = @GN_DAEMON_CONFIG_DIR@ +GN_DAEMON_HOME_DIR = @GN_DAEMON_HOME_DIR@ +GN_INTLINCL = @GN_INTLINCL@ +GN_LIBINTL = @GN_LIBINTL@ +GN_LIB_LDFLAGS = @GN_LIB_LDFLAGS@ +GN_PLUGIN_LDFLAGS = @GN_PLUGIN_LDFLAGS@ +GN_USER_HOME_DIR = @GN_USER_HOME_DIR@ +GREP = @GREP@ +HAVE_LIBUNISTRING = @HAVE_LIBUNISTRING@ +INCLTDL = @INCLTDL@ +INSTALL = @INSTALL@ +INSTALL_DATA = @INSTALL_DATA@ +INSTALL_PROGRAM = @INSTALL_PROGRAM@ +INSTALL_SCRIPT = @INSTALL_SCRIPT@ +INSTALL_STRIP_PROGRAM = @INSTALL_STRIP_PROGRAM@ +INTLLIBS = @INTLLIBS@ +INTL_MACOSX_LIBS = @INTL_MACOSX_LIBS@ +LD = @LD@ +LDFLAGS = @LDFLAGS@ +LIBADD_DL = @LIBADD_DL@ +LIBADD_DLD_LINK = @LIBADD_DLD_LINK@ +LIBADD_DLOPEN = @LIBADD_DLOPEN@ +LIBADD_SHL_LOAD = @LIBADD_SHL_LOAD@ +LIBCURL = @LIBCURL@ +LIBCURL_CPPFLAGS = @LIBCURL_CPPFLAGS@ +LIBGCRYPT_CFLAGS = @LIBGCRYPT_CFLAGS@ +LIBGCRYPT_CONFIG = @LIBGCRYPT_CONFIG@ +LIBGCRYPT_LIBS = @LIBGCRYPT_LIBS@ +LIBICONV = @LIBICONV@ +LIBINTL = @LIBINTL@ +LIBLTDL = @LIBLTDL@ +LIBOBJS = @LIBOBJS@ +LIBPREFIX = @LIBPREFIX@ +LIBS = @LIBS@ +LIBTOOL = @LIBTOOL@ +LIBUNISTRING = @LIBUNISTRING@ +LIPO = @LIPO@ +LN_S = @LN_S@ +LTDLDEPS = @LTDLDEPS@ +LTDLINCL = @LTDLINCL@ +LTDLOPEN = @LTDLOPEN@ +LTLIBICONV = @LTLIBICONV@ +LTLIBINTL = @LTLIBINTL@ +LTLIBOBJS = @LTLIBOBJS@ +LTLIBUNISTRING = @LTLIBUNISTRING@ +LT_CONFIG_H = @LT_CONFIG_H@ +LT_DLLOADERS = @LT_DLLOADERS@ +LT_DLPREOPEN = @LT_DLPREOPEN@ +MAKEINFO = @MAKEINFO@ +MKDIR_P = @MKDIR_P@ +MSGFMT = @MSGFMT@ +MSGFMT_015 = @MSGFMT_015@ +MSGMERGE = @MSGMERGE@ +MYSQL_CPPFLAGS = @MYSQL_CPPFLAGS@ +MYSQL_LDFLAGS = @MYSQL_LDFLAGS@ +NM = @NM@ +NMEDIT = @NMEDIT@ +OBJC = @OBJC@ +OBJCDEPMODE = @OBJCDEPMODE@ +OBJCFLAGS = @OBJCFLAGS@ +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@ +PATH_SEPARATOR = @PATH_SEPARATOR@ +POSTGRES_CPPFLAGS = @POSTGRES_CPPFLAGS@ +POSTGRES_LDFLAGS = @POSTGRES_LDFLAGS@ +POSUB = @POSUB@ +PYTHON = @PYTHON@ +PYTHON_EXEC_PREFIX = @PYTHON_EXEC_PREFIX@ +PYTHON_PLATFORM = @PYTHON_PLATFORM@ +PYTHON_PREFIX = @PYTHON_PREFIX@ +PYTHON_VERSION = @PYTHON_VERSION@ +RANLIB = @RANLIB@ +SED = @SED@ +SET_MAKE = @SET_MAKE@ +SHELL = @SHELL@ +SQLITE_CPPFLAGS = @SQLITE_CPPFLAGS@ +SQLITE_LDFLAGS = @SQLITE_LDFLAGS@ +STRIP = @STRIP@ +SUDO_BINARY = @SUDO_BINARY@ +UNIXONLY = @UNIXONLY@ +USE_NLS = @USE_NLS@ +VERSION = @VERSION@ +XGETTEXT = @XGETTEXT@ +XGETTEXT_015 = @XGETTEXT_015@ +XMKMF = @XMKMF@ +X_CFLAGS = @X_CFLAGS@ +X_EXTRA_LIBS = @X_EXTRA_LIBS@ +X_LIBS = @X_LIBS@ +X_PRE_LIBS = @X_PRE_LIBS@ +_libcurl_config = @_libcurl_config@ +abs_builddir = @abs_builddir@ +abs_srcdir = @abs_srcdir@ +abs_top_builddir = @abs_top_builddir@ +abs_top_srcdir = @abs_top_srcdir@ +ac_ct_CC = @ac_ct_CC@ +ac_ct_CXX = @ac_ct_CXX@ +ac_ct_DUMPBIN = @ac_ct_DUMPBIN@ +ac_ct_OBJC = @ac_ct_OBJC@ +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_target = @build_target@ +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@ +lt_ECHO = @lt_ECHO@ +ltdl_LIBOBJS = @ltdl_LIBOBJS@ +ltdl_LTLIBOBJS = @ltdl_LTLIBOBJS@ +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@ +sbindir = @sbindir@ +sharedstatedir = @sharedstatedir@ +srcdir = @srcdir@ +subdirs = @subdirs@ +sys_symbol_underscore = @sys_symbol_underscore@ +sysconfdir = @sysconfdir@ +target = @target@ +target_alias = @target_alias@ +target_cpu = @target_cpu@ +target_os = @target_os@ +target_vendor = @target_vendor@ +top_build_prefix = @top_build_prefix@ +top_builddir = @top_builddir@ +top_srcdir = @top_srcdir@ +INCLUDES = -I$(top_srcdir)/src/include +@MINGW_TRUE@WINFLAGS = -Wl,--no-undefined -Wl,--export-all-symbols +@USE_COVERAGE_TRUE@AM_CFLAGS = --coverage -O0 +@USE_COVERAGE_TRUE@XLIB = -lgcov +plugindir = $(libdir)/gnunet +pkgcfgdir = $(pkgdatadir)/config.d/ +pkgcfg_DATA = \ + dv.conf + +lib_LTLIBRARIES = libgnunetdv.la +plugin_LTLIBRARIES = libgnunet_plugin_transport_dv.la +libgnunetdv_la_SOURCES = \ + dv_api.c dv.h + +libgnunetdv_la_LIBADD = \ + $(top_builddir)/src/util/libgnunetutil.la \ + $(top_builddir)/src/core/libgnunetcore.la \ + $(GN_LIBINTL) $(XLIB) + +libgnunetdv_la_LDFLAGS = \ + $(GN_LIB_LDFLAGS) $(WINFLAGS) \ + -version-info 0:0:0 + +gnunet_service_dv_SOURCES = \ + gnunet-service-dv.c + +gnunet_service_dv_LDADD = \ + $(top_builddir)/src/statistics/libgnunetstatistics.la \ + $(top_builddir)/src/dv/libgnunetdv.la \ + $(top_builddir)/src/core/libgnunetcore.la \ + $(top_builddir)/src/hello/libgnunethello.la \ + $(top_builddir)/src/peerinfo/libgnunetpeerinfo.la \ + $(top_builddir)/src/util/libgnunetutil.la \ + $(GN_LIBINTL) + +gnunet_service_dv_DEPENDENCIES = \ + libgnunetdv.la + +libgnunet_plugin_transport_dv_la_SOURCES = \ + plugin_transport_dv.c + +libgnunet_plugin_transport_dv_la_LIBADD = \ + $(top_builddir)/src/hello/libgnunethello.la \ + $(top_builddir)/src/dv/libgnunetdv.la \ + $(top_builddir)/src/peerinfo/libgnunetpeerinfo.la \ + $(top_builddir)/src/util/libgnunetutil.la + +libgnunet_plugin_transport_dv_la_LDFLAGS = \ + $(GN_PLUGIN_LDFLAGS) + +libgnunet_plugin_transport_dv_la_DEPENDENCIES = \ + libgnunetdv.la + +test_transport_api_dv_SOURCES = \ + test_transport_api_dv.c + +test_transport_api_dv_LDADD = \ + $(top_builddir)/src/core/libgnunetcore.la \ + $(top_builddir)/src/transport/libgnunettransport.la \ + $(top_builddir)/src/util/libgnunetutil.la \ + $(top_builddir)/src/testing/libgnunettesting.la + +EXTRA_DIST = \ + test_transport_dv_data.conf + +all: all-am + +.SUFFIXES: +.SUFFIXES: .c .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) --gnu src/dv/Makefile'; \ + $(am__cd) $(top_srcdir) && \ + $(AUTOMAKE) --gnu src/dv/Makefile +.PRECIOUS: 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__depfiles_maybe)'; \ + cd $(top_builddir) && $(SHELL) ./config.status $(subdir)/$@ $(am__depfiles_maybe);; \ + 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): +dv.conf: $(top_builddir)/config.status $(srcdir)/dv.conf.in + cd $(top_builddir) && $(SHELL) ./config.status $(subdir)/$@ +install-libLTLIBRARIES: $(lib_LTLIBRARIES) + @$(NORMAL_INSTALL) + test -z "$(libdir)" || $(MKDIR_P) "$(DESTDIR)$(libdir)" + @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 " $(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)'; for p in $$list; do \ + dir="`echo $$p | sed -e 's|/[^/]*$$||'`"; \ + test "$$dir" != "$$p" || dir=.; \ + echo "rm -f \"$${dir}/so_locations\""; \ + rm -f "$${dir}/so_locations"; \ + done +install-pluginLTLIBRARIES: $(plugin_LTLIBRARIES) + @$(NORMAL_INSTALL) + test -z "$(plugindir)" || $(MKDIR_P) "$(DESTDIR)$(plugindir)" + @list='$(plugin_LTLIBRARIES)'; test -n "$(plugindir)" || list=; \ + list2=; for p in $$list; do \ + if test -f $$p; then \ + list2="$$list2 $$p"; \ + else :; fi; \ + done; \ + test -z "$$list2" || { \ + echo " $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=install $(INSTALL) $(INSTALL_STRIP_FLAG) $$list2 '$(DESTDIR)$(plugindir)'"; \ + $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=install $(INSTALL) $(INSTALL_STRIP_FLAG) $$list2 "$(DESTDIR)$(plugindir)"; \ + } + +uninstall-pluginLTLIBRARIES: + @$(NORMAL_UNINSTALL) + @list='$(plugin_LTLIBRARIES)'; test -n "$(plugindir)" || list=; \ + for p in $$list; do \ + $(am__strip_dir) \ + echo " $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=uninstall rm -f '$(DESTDIR)$(plugindir)/$$f'"; \ + $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=uninstall rm -f "$(DESTDIR)$(plugindir)/$$f"; \ + done + +clean-pluginLTLIBRARIES: + -test -z "$(plugin_LTLIBRARIES)" || rm -f $(plugin_LTLIBRARIES) + @list='$(plugin_LTLIBRARIES)'; for p in $$list; do \ + dir="`echo $$p | sed -e 's|/[^/]*$$||'`"; \ + test "$$dir" != "$$p" || dir=.; \ + echo "rm -f \"$${dir}/so_locations\""; \ + rm -f "$${dir}/so_locations"; \ + done +libgnunet_plugin_transport_dv.la: $(libgnunet_plugin_transport_dv_la_OBJECTS) $(libgnunet_plugin_transport_dv_la_DEPENDENCIES) + $(AM_V_CCLD)$(libgnunet_plugin_transport_dv_la_LINK) -rpath $(plugindir) $(libgnunet_plugin_transport_dv_la_OBJECTS) $(libgnunet_plugin_transport_dv_la_LIBADD) $(LIBS) +libgnunetdv.la: $(libgnunetdv_la_OBJECTS) $(libgnunetdv_la_DEPENDENCIES) + $(AM_V_CCLD)$(libgnunetdv_la_LINK) -rpath $(libdir) $(libgnunetdv_la_OBJECTS) $(libgnunetdv_la_LIBADD) $(LIBS) +install-binPROGRAMS: $(bin_PROGRAMS) + @$(NORMAL_INSTALL) + test -z "$(bindir)" || $(MKDIR_P) "$(DESTDIR)$(bindir)" + @list='$(bin_PROGRAMS)'; test -n "$(bindir)" || list=; \ + for p in $$list; do echo "$$p $$p"; done | \ + sed 's/$(EXEEXT)$$//' | \ + while read p p1; do if test -f $$p || test -f $$p1; \ + then echo "$$p"; echo "$$p"; else :; fi; \ + done | \ + sed -e 'p;s,.*/,,;n;h' -e 's|.*|.|' \ + -e 'p;x;s,.*/,,;s/$(EXEEXT)$$//;$(transform);s/$$/$(EXEEXT)/' | \ + sed 'N;N;N;s,\n, ,g' | \ + $(AWK) 'BEGIN { files["."] = ""; dirs["."] = 1 } \ + { d=$$3; if (dirs[d] != 1) { print "d", d; dirs[d] = 1 } \ + if ($$2 == $$4) files[d] = files[d] " " $$1; \ + else { print "f", $$3 "/" $$4, $$1; } } \ + END { for (d in files) print "f", d, files[d] }' | \ + while read type dir files; do \ + if test "$$dir" = .; then dir=; else dir=/$$dir; fi; \ + test -z "$$files" || { \ + echo " $(INSTALL_PROGRAM_ENV) $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=install $(INSTALL_PROGRAM) $$files '$(DESTDIR)$(bindir)$$dir'"; \ + $(INSTALL_PROGRAM_ENV) $(LIBTOOL) $(AM_LIBTOOLFLAGS) $(LIBTOOLFLAGS) --mode=install $(INSTALL_PROGRAM) $$files "$(DESTDIR)$(bindir)$$dir" || exit $$?; \ + } \ + ; done + +uninstall-binPROGRAMS: + @$(NORMAL_UNINSTALL) + @list='$(bin_PROGRAMS)'; test -n "$(bindir)" || list=; \ + files=`for p in $$list; do echo "$$p"; done | \ + sed -e 'h;s,^.*/,,;s/$(EXEEXT)$$//;$(transform)' \ + -e 's/$$/$(EXEEXT)/' `; \ + test -n "$$list" || exit 0; \ + echo " ( cd '$(DESTDIR)$(bindir)' && rm -f" $$files ")"; \ + cd "$(DESTDIR)$(bindir)" && rm -f $$files + +clean-binPROGRAMS: + @list='$(bin_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 + +clean-checkPROGRAMS: + @list='$(check_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 +gnunet-service-dv$(EXEEXT): $(gnunet_service_dv_OBJECTS) $(gnunet_service_dv_DEPENDENCIES) + @rm -f gnunet-service-dv$(EXEEXT) + $(AM_V_CCLD)$(LINK) $(gnunet_service_dv_OBJECTS) $(gnunet_service_dv_LDADD) $(LIBS) +test_transport_api_dv$(EXEEXT): $(test_transport_api_dv_OBJECTS) $(test_transport_api_dv_DEPENDENCIES) + @rm -f test_transport_api_dv$(EXEEXT) + $(AM_V_CCLD)$(LINK) $(test_transport_api_dv_OBJECTS) $(test_transport_api_dv_LDADD) $(LIBS) + +mostlyclean-compile: + -rm -f *.$(OBJEXT) + +distclean-compile: + -rm -f *.tab.c + +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/dv_api.Plo@am__quote@ +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/gnunet-service-dv.Po@am__quote@ +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/plugin_transport_dv.Plo@am__quote@ +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/test_transport_api_dv.Po@am__quote@ + +.c.o: +@am__fastdepCC_TRUE@ $(AM_V_CC)$(COMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ $< +@am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Po +@am__fastdepCC_FALSE@ $(AM_V_CC) @AM_BACKSLASH@ +@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='$<' object='$@' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCC_FALSE@ $(COMPILE) -c $< + +.c.obj: +@am__fastdepCC_TRUE@ $(AM_V_CC)$(COMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ `$(CYGPATH_W) '$<'` +@am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Po +@am__fastdepCC_FALSE@ $(AM_V_CC) @AM_BACKSLASH@ +@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='$<' object='$@' libtool=no @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCC_FALSE@ $(COMPILE) -c `$(CYGPATH_W) '$<'` + +.c.lo: +@am__fastdepCC_TRUE@ $(AM_V_CC)$(LTCOMPILE) -MT $@ -MD -MP -MF $(DEPDIR)/$*.Tpo -c -o $@ $< +@am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) $(DEPDIR)/$*.Tpo $(DEPDIR)/$*.Plo +@am__fastdepCC_FALSE@ $(AM_V_CC) @AM_BACKSLASH@ +@AMDEP_TRUE@@am__fastdepCC_FALSE@ source='$<' object='$@' libtool=yes @AMDEPBACKSLASH@ +@AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@ +@am__fastdepCC_FALSE@ $(LTCOMPILE) -c -o $@ $< + +mostlyclean-libtool: + -rm -f *.lo + +clean-libtool: + -rm -rf .libs _libs +install-pkgcfgDATA: $(pkgcfg_DATA) + @$(NORMAL_INSTALL) + test -z "$(pkgcfgdir)" || $(MKDIR_P) "$(DESTDIR)$(pkgcfgdir)" + @list='$(pkgcfg_DATA)'; test -n "$(pkgcfgdir)" || list=; \ + 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_DATA) $$files '$(DESTDIR)$(pkgcfgdir)'"; \ + $(INSTALL_DATA) $$files "$(DESTDIR)$(pkgcfgdir)" || exit $$?; \ + done + +uninstall-pkgcfgDATA: + @$(NORMAL_UNINSTALL) + @list='$(pkgcfg_DATA)'; test -n "$(pkgcfgdir)" || list=; \ + files=`for p in $$list; do echo $$p; done | sed -e 's|^.*/||'`; \ + test -n "$$files" || exit 0; \ + echo " ( cd '$(DESTDIR)$(pkgcfgdir)' && rm -f" $$files ")"; \ + cd "$(DESTDIR)$(pkgcfgdir)" && rm -f $$files + +ID: $(HEADERS) $(SOURCES) $(LISP) $(TAGS_FILES) + list='$(SOURCES) $(HEADERS) $(LISP) $(TAGS_FILES)'; \ + unique=`for i in $$list; do \ + if test -f "$$i"; then echo $$i; else echo $(srcdir)/$$i; fi; \ + done | \ + $(AWK) '{ files[$$0] = 1; nonempty = 1; } \ + END { if (nonempty) { for (i in files) print i; }; }'`; \ + mkid -fID $$unique +tags: TAGS + +TAGS: $(HEADERS) $(SOURCES) $(TAGS_DEPENDENCIES) \ + $(TAGS_FILES) $(LISP) + set x; \ + here=`pwd`; \ + list='$(SOURCES) $(HEADERS) $(LISP) $(TAGS_FILES)'; \ + unique=`for i in $$list; do \ + if test -f "$$i"; then echo $$i; else echo $(srcdir)/$$i; fi; \ + done | \ + $(AWK) '{ files[$$0] = 1; nonempty = 1; } \ + END { if (nonempty) { for (i in files) print i; }; }'`; \ + 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 +CTAGS: $(HEADERS) $(SOURCES) $(TAGS_DEPENDENCIES) \ + $(TAGS_FILES) $(LISP) + list='$(SOURCES) $(HEADERS) $(LISP) $(TAGS_FILES)'; \ + unique=`for i in $$list; do \ + if test -f "$$i"; then echo $$i; else echo $(srcdir)/$$i; fi; \ + done | \ + $(AWK) '{ files[$$0] = 1; nonempty = 1; } \ + END { if (nonempty) { for (i in files) print i; }; }'`; \ + 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" + +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; 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 \ + echo "$$grn$$dashes"; \ + else \ + echo "$$red$$dashes"; \ + fi; \ + echo "$$banner"; \ + test -z "$$skipped" || echo "$$skipped"; \ + test -z "$$report" || echo "$$report"; \ + echo "$$dashes$$std"; \ + test "$$failed" -eq 0; \ + else :; fi + +distdir: $(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_PROGRAMS) + $(MAKE) $(AM_MAKEFLAGS) check-TESTS +check: check-am +all-am: Makefile $(LTLIBRARIES) $(PROGRAMS) $(DATA) +install-binPROGRAMS: install-libLTLIBRARIES + +installdirs: + for dir in "$(DESTDIR)$(libdir)" "$(DESTDIR)$(plugindir)" "$(DESTDIR)$(bindir)" "$(DESTDIR)$(pkgcfgdir)"; do \ + test -z "$$dir" || $(MKDIR_P) "$$dir"; \ + done +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: + $(MAKE) $(AM_MAKEFLAGS) INSTALL_PROGRAM="$(INSTALL_STRIP_PROGRAM)" \ + install_sh_PROGRAM="$(INSTALL_STRIP_PROGRAM)" INSTALL_STRIP_FLAG=-s \ + `test -z '$(STRIP)' || \ + echo "INSTALL_PROGRAM_ENV=STRIPPROG='$(STRIP)'"` install +mostlyclean-generic: + +clean-generic: + +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-binPROGRAMS clean-checkPROGRAMS clean-generic \ + clean-libLTLIBRARIES clean-libtool clean-pluginLTLIBRARIES \ + mostlyclean-am + +distclean: distclean-am + -rm -rf ./$(DEPDIR) + -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-pkgcfgDATA install-pluginLTLIBRARIES + +install-dvi: install-dvi-am + +install-dvi-am: + +install-exec-am: install-binPROGRAMS install-libLTLIBRARIES + +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 -rf ./$(DEPDIR) + -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: uninstall-binPROGRAMS uninstall-libLTLIBRARIES \ + uninstall-pkgcfgDATA uninstall-pluginLTLIBRARIES + +.MAKE: check-am install-am install-strip + +.PHONY: CTAGS GTAGS all all-am check check-TESTS check-am clean \ + clean-binPROGRAMS clean-checkPROGRAMS clean-generic \ + clean-libLTLIBRARIES clean-libtool clean-pluginLTLIBRARIES \ + ctags distclean distclean-compile distclean-generic \ + distclean-libtool distclean-tags distdir dvi dvi-am html \ + html-am info info-am install install-am install-binPROGRAMS \ + 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-man install-pdf install-pdf-am install-pkgcfgDATA \ + install-pluginLTLIBRARIES 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 uninstall uninstall-am \ + uninstall-binPROGRAMS uninstall-libLTLIBRARIES \ + uninstall-pkgcfgDATA uninstall-pluginLTLIBRARIES + + +# 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/dv/dv.conf.in b/src/dv/dv.conf.in new file mode 100644 index 0000000..93278df --- /dev/null +++ b/src/dv/dv.conf.in @@ -0,0 +1,18 @@ +[dv] +AUTOSTART = YES +DEBUG = NO +ACCEPT_FROM6 = ::1; +ACCEPT_FROM = 127.0.0.1; +BINARY = gnunet-service-dv +CONFIG = $DEFAULTCONFIG +HOME = $SERVICEHOME +HOSTNAME = localhost +@UNIXONLY@ PORT = 2571 +UNIXPATH = /tmp/gnunet-service-dv.sock +UNIX_MATCH_UID = YES +UNIX_MATCH_GID = YES +# ACCEPT_FROM = +# ACCEPT_FROM6 = +# REJECT_FROM = +# REJECT_FROM6 = +# BINDTO = diff --git a/src/dv/dv.h b/src/dv/dv.h new file mode 100644 index 0000000..0d42505 --- /dev/null +++ b/src/dv/dv.h @@ -0,0 +1,275 @@ +/* + This file is part of GNUnet. + (C) 2001, 2002, 2003, 2004, 2009 Christian Grothoff (and other contributing authors) + + GNUnet is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published + by the Free Software Foundation; either version 3, or (at your + option) any later version. + + GNUnet is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with GNUnet; see the file COPYING. If not, write to the + Free Software Foundation, Inc., 59 Temple Place - Suite 330, + Boston, MA 02111-1307, USA. +*/ + +/** + * @author Christian Grothoff + * @author NOT Nathan Evans + * @file dv/dv.h + */ +#ifndef DV_H +#define DV_H + +#include "gnunet_common.h" + +#define DEBUG_DV_GOSSIP GNUNET_EXTRA_LOGGING +#define DEBUG_DV_GOSSIP_SEND GNUNET_EXTRA_LOGGING +#define DEBUG_DV_GOSSIP_RECEIPT GNUNET_EXTRA_LOGGING +#define DEBUG_DV_MESSAGES GNUNET_EXTRA_LOGGING +#define DEBUG_DV GNUNET_EXTRA_LOGGING +#define DEBUG_DV_PEER_NUMBERS GNUNET_EXTRA_LOGGING +#define DEBUG_MESSAGE_DROP GNUNET_EXTRA_LOGGING + +typedef void (*GNUNET_DV_MessageReceivedHandler) (void *cls, + struct GNUNET_PeerIdentity * + sender, char *msg, + size_t msg_len, + uint32_t distance, + char *sender_address, + size_t sender_address_len); + +GNUNET_NETWORK_STRUCT_BEGIN + +/** + * DV Message, contains a message that was received + * via DV for this peer! Internal. + * + * Sender address is copied to the end of this struct, + * followed by the actual message received. + */ +struct GNUNET_DV_MessageReceived +{ + /** + * Type: GNUNET_MESSAGE_TYPE_TRANSPORT_DV_MESSAGE + */ + struct GNUNET_MessageHeader header; + + /** + * The sender of the message + */ + struct GNUNET_PeerIdentity sender; + + /** + * The length of the message that was sent (appended to this end of struct) + */ + uint32_t msg_len; + + /** + * The distance to the peer that we received the message from + */ + uint32_t distance; + +}; + + +/** + * DV Message, indicates that we have learned of a new DV level peer. + * Internal. + * + * Sender address is copied to the end of this struct. + */ +struct GNUNET_DV_ConnectMessage +{ + /** + * Type: GNUNET_MESSAGE_TYPE_TRANSPORT_DV_MESSAGE + */ + struct GNUNET_MessageHeader header; + + /** + * The sender of the message + */ + struct GNUNET_PeerIdentity *sender; + + /** + * The message that was sent + */ + struct GNUNET_MessageHeader *msg; + + /** + * The distance to the peer that we received the message from + */ + uint32_t distance; + + /** + * Length of the sender address, appended to end of this message + */ + uint32_t sender_address_len; + +}; + +/** + * Message to return result from a send attempt. + * Internal. + */ +struct GNUNET_DV_SendResultMessage +{ + /** + * Type: GNUNET_MESSAGE_TYPE_DV_SEND_RESULT + */ + struct GNUNET_MessageHeader header; + + /** + * Unique ID for attempted sent message. + */ + uint32_t uid; + + /** + * Result of attempted send, 0 for send okay, + * 1 for failure of any reason. + */ + uint32_t result; +}; + +/** + * Message to send a message over DV via a specific peer. + * Internal. + */ +struct GNUNET_DV_SendMessage +{ + /** + * Type: GNUNET_MESSAGE_TYPE_DV_SEND + */ + struct GNUNET_MessageHeader header; + + /** + * Intended final recipient of this message + */ + struct GNUNET_PeerIdentity target; + + /** + * Message priority + */ + uint32_t priority; + + /** + * Unique ID for this message, for confirm callback. + */ + uint32_t uid; + + /** + * How long can we delay sending? + */ + struct GNUNET_TIME_Relative timeout; + + /** + * Size of the address (appended to end of struct) + */ + uint32_t addrlen; + + /** + * The message(s) to be sent. + */ + char *msgbuf; + + /* + * Sender, appended to end of struct tells via whom + * to send this message. + */ + +}; + +/** + * Message that gets sent between nodes updating dv infos + */ +typedef struct +{ + /* Message Header */ + struct GNUNET_MessageHeader header; + + /** + * Cost from received from node to neighbor node, takes distance into account + */ + uint32_t cost GNUNET_PACKED; + + /** + * Identity of neighbor we learned information about + */ + struct GNUNET_PeerIdentity neighbor; + + /** + * PublicKey of neighbor. + */ + struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded pkey; + + /** + * Neighbor ID to use when sending to this peer + */ + uint32_t neighbor_id GNUNET_PACKED; + +} p2p_dv_MESSAGE_NeighborInfo; + +/** + * Message that gets sent between nodes carrying information + */ +typedef struct +{ + struct GNUNET_MessageHeader header; + + /** + * Unique ID for this message. Will be zero unless + * message tracking is desired. + */ + uint32_t uid GNUNET_PACKED; + + /** + * Identity of peer that ultimately sent the message. + * Should be looked up in the set of 'neighbor_id's of + * the referring peer. + */ + uint32_t sender GNUNET_PACKED; + + /** + * Identity of neighbor this message is going to. Should + * be looked up in the set of our own identifiers for + * neighbors! + */ + uint32_t recipient GNUNET_PACKED; + +} p2p_dv_MESSAGE_Data; + +/** + * Message that gets sent between nodes indicating a peer + * was disconnected. + */ +typedef struct +{ + struct GNUNET_MessageHeader header; + + /** + * Identity of neighbor that was disconnected. + */ + uint32_t peer_id GNUNET_PACKED; + +} p2p_dv_MESSAGE_Disconnect; +GNUNET_NETWORK_STRUCT_END + +struct GNUNET_DV_Handle * +GNUNET_DV_connect (const struct GNUNET_CONFIGURATION_Handle *cfg, + GNUNET_DV_MessageReceivedHandler receive_handler, + void *receive_handler_cls); + +/** + * Disconnect from the DV service + * + * @param handle the current handle to the service to disconnect + */ +void +GNUNET_DV_disconnect (struct GNUNET_DV_Handle *handle); + +#endif diff --git a/src/dv/dv_api.c b/src/dv/dv_api.c new file mode 100644 index 0000000..876282e --- /dev/null +++ b/src/dv/dv_api.c @@ -0,0 +1,628 @@ +/* + This file is part of GNUnet. + (C) 2009, 2010 Christian Grothoff (and other contributing authors) + + GNUnet is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published + by the Free Software Foundation; either version 3, or (at your + option) any later version. + + GNUnet is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with GNUnet; see the file COPYING. If not, write to the + Free Software Foundation, Inc., 59 Temple Place - Suite 330, + Boston, MA 02111-1307, USA. +*/ + +/** + * @file dv/dv_api.c + * @brief library to access the DV service + * @author Christian Grothoff + * @author Nathan Evans + */ +#include "platform.h" +#include "gnunet_bandwidth_lib.h" +#include "gnunet_client_lib.h" +#include "gnunet_constants.h" +#include "gnunet_container_lib.h" +#include "gnunet_arm_service.h" +#include "gnunet_hello_lib.h" +#include "gnunet_protocols.h" +#include "gnunet_server_lib.h" +#include "gnunet_time_lib.h" +#include "gnunet_dv_service.h" +#include "dv.h" +#include "gnunet_transport_plugin.h" + +#define LOG(kind,...) GNUNET_log_from (kind, "dv-api",__VA_ARGS__) + +/** + * Store ready to send messages + */ +struct PendingMessages +{ + /** + * Linked list of pending messages + */ + struct PendingMessages *next; + + /** + * Message that is pending + */ + struct GNUNET_DV_SendMessage *msg; + + /** + * Timeout for this message + */ + struct GNUNET_TIME_Absolute timeout; + +}; + +/** + * Handle for the service. + */ +struct GNUNET_DV_Handle +{ + + /** + * Configuration to use. + */ + const struct GNUNET_CONFIGURATION_Handle *cfg; + + /** + * Socket (if available). + */ + struct GNUNET_CLIENT_Connection *client; + + /** + * Currently pending transmission request. + */ + struct GNUNET_CLIENT_TransmitHandle *th; + + /** + * List of the currently pending messages for the DV service. + */ + struct PendingMessages *pending_list; + + /** + * Message we are currently sending. + */ + struct PendingMessages *current; + + /** + * Handler for messages we receive from the DV service + */ + GNUNET_DV_MessageReceivedHandler receive_handler; + + /** + * Closure for the receive handler + */ + void *receive_cls; + + /** + * Current unique ID + */ + uint32_t uid_gen; + + /** + * Hashmap containing outstanding send requests awaiting confirmation. + */ + struct GNUNET_CONTAINER_MultiHashMap *send_callbacks; + +}; + + +struct StartContext +{ + /** + * Start message + */ + struct GNUNET_MessageHeader *message; + + /** + * Handle to service, in case of timeout + */ + struct GNUNET_DV_Handle *handle; +}; + +struct SendCallbackContext +{ + /** + * The continuation to call once a message is confirmed sent (or failed) + */ + GNUNET_TRANSPORT_TransmitContinuation cont; + + /** + * Closure to call with send continuation. + */ + void *cont_cls; + + /** + * Target of the message. + */ + struct GNUNET_PeerIdentity target; +}; + +/** + * Convert unique ID to hash code. + * + * @param uid unique ID to convert + * @param hash set to uid (extended with zeros) + */ +static void +hash_from_uid (uint32_t uid, GNUNET_HashCode * hash) +{ + memset (hash, 0, sizeof (GNUNET_HashCode)); + *((uint32_t *) hash) = uid; +} + +/** + * Try to (re)connect to the dv service. + * + * @param ret handle to the (disconnected) dv service + * + * @return GNUNET_YES on success, GNUNET_NO on failure. + */ +static int +try_connect (struct GNUNET_DV_Handle *ret) +{ + if (ret->client != NULL) + return GNUNET_OK; + ret->client = GNUNET_CLIENT_connect ("dv", ret->cfg); + if (ret->client != NULL) + return GNUNET_YES; +#if DEBUG_DV_MESSAGES + LOG (GNUNET_ERROR_TYPE_DEBUG, _("Failed to connect to the dv service!\n")); +#endif + return GNUNET_NO; +} + +static void +process_pending_message (struct GNUNET_DV_Handle *handle); + +/** + * Send complete, schedule next + * + * @param handle handle to the dv service + * @param code return code for send (unused) + */ +static void +finish (struct GNUNET_DV_Handle *handle, int code) +{ + struct PendingMessages *pos = handle->current; + + handle->current = NULL; + process_pending_message (handle); + + GNUNET_free (pos->msg); + GNUNET_free (pos); +} + +/** + * Notification that we can send data + * + * @param cls handle to the dv service (struct GNUNET_DV_Handle) + * @param size how many bytes can we send + * @param buf where to copy the message to send + * + * @return how many bytes we copied to buf + */ +static size_t +transmit_pending (void *cls, size_t size, void *buf) +{ + struct GNUNET_DV_Handle *handle = cls; + size_t ret; + size_t tsize; + +#if DEBUG_DV + if (handle->current != NULL) + LOG (GNUNET_ERROR_TYPE_DEBUG, + "DV API: Transmit pending called with message type %d\n", + ntohs (handle->current->msg->header.type)); +#endif + + if (buf == NULL) + { +#if DEBUG_DV + LOG (GNUNET_ERROR_TYPE_DEBUG, "DV API: Transmit pending FAILED!\n\n\n"); +#endif + finish (handle, GNUNET_SYSERR); + return 0; + } + handle->th = NULL; + + ret = 0; + + if (handle->current != NULL) + { + tsize = ntohs (handle->current->msg->header.size); + if (size >= tsize) + { + memcpy (buf, handle->current->msg, tsize); +#if DEBUG_DV + LOG (GNUNET_ERROR_TYPE_DEBUG, + "DV API: Copied %d bytes into buffer!\n\n\n", tsize); +#endif + finish (handle, GNUNET_OK); + return tsize; + } + + } + + return ret; +} + +/** + * Try to send messages from list of messages to send + * + * @param handle handle to the distance vector service + */ +static void +process_pending_message (struct GNUNET_DV_Handle *handle) +{ + + if (handle->current != NULL) + return; /* action already pending */ + if (GNUNET_YES != try_connect (handle)) + { + finish (handle, GNUNET_SYSERR); + return; + } + + /* schedule next action */ + handle->current = handle->pending_list; + if (NULL == handle->current) + { + return; + } + handle->pending_list = handle->pending_list->next; + handle->current->next = NULL; + + if (NULL == + (handle->th = + GNUNET_CLIENT_notify_transmit_ready (handle->client, + ntohs (handle->current->msg-> + header.size), + handle->current->msg->timeout, + GNUNET_YES, &transmit_pending, + handle))) + { +#if DEBUG_DV + LOG (GNUNET_ERROR_TYPE_DEBUG, + "Failed to transmit request to dv service.\n"); +#endif + finish (handle, GNUNET_SYSERR); + } +} + +/** + * Add a pending message to the linked list + * + * @param handle handle to the specified DV api + * @param msg the message to add to the list + */ +static void +add_pending (struct GNUNET_DV_Handle *handle, struct GNUNET_DV_SendMessage *msg) +{ + struct PendingMessages *new_message; + struct PendingMessages *pos; + struct PendingMessages *last; + + new_message = GNUNET_malloc (sizeof (struct PendingMessages)); + new_message->msg = msg; + + if (handle->pending_list != NULL) + { + pos = handle->pending_list; + while (pos != NULL) + { + last = pos; + pos = pos->next; + } + last->next = new_message; + } + else + { + handle->pending_list = new_message; + } + + process_pending_message (handle); +} + +/** + * Handles a message sent from the DV service to us. + * Parse it out and give it to the plugin. + * + * @param cls the handle to the DV API + * @param msg the message that was received + */ +void +handle_message_receipt (void *cls, const struct GNUNET_MessageHeader *msg) +{ + struct GNUNET_DV_Handle *handle = cls; + struct GNUNET_DV_MessageReceived *received_msg; + struct GNUNET_DV_SendResultMessage *send_result_msg; + size_t packed_msg_len; + size_t sender_address_len; + char *sender_address; + char *packed_msg; + char *packed_msg_start; + GNUNET_HashCode uidhash; + struct SendCallbackContext *send_ctx; + + if (msg == NULL) + { +#if DEBUG_DV_MESSAGES + LOG (GNUNET_ERROR_TYPE_DEBUG, "DV_API receive: connection closed\n"); +#endif + return; /* Connection closed? */ + } + + GNUNET_assert ((ntohs (msg->type) == GNUNET_MESSAGE_TYPE_TRANSPORT_DV_RECEIVE) + || (ntohs (msg->type) == + GNUNET_MESSAGE_TYPE_TRANSPORT_DV_SEND_RESULT)); + + switch (ntohs (msg->type)) + { + case GNUNET_MESSAGE_TYPE_TRANSPORT_DV_RECEIVE: + if (ntohs (msg->size) < sizeof (struct GNUNET_DV_MessageReceived)) + return; + + received_msg = (struct GNUNET_DV_MessageReceived *) msg; + packed_msg_len = ntohl (received_msg->msg_len); + sender_address_len = + ntohs (msg->size) - packed_msg_len - + sizeof (struct GNUNET_DV_MessageReceived); + GNUNET_assert (sender_address_len > 0); + sender_address = GNUNET_malloc (sender_address_len); + memcpy (sender_address, &received_msg[1], sender_address_len); + packed_msg_start = (char *) &received_msg[1]; + packed_msg = GNUNET_malloc (packed_msg_len); + memcpy (packed_msg, &packed_msg_start[sender_address_len], packed_msg_len); + +#if DEBUG_DV_MESSAGES + LOG (GNUNET_ERROR_TYPE_DEBUG, + "DV_API receive: packed message type: %d or %d\n", + ntohs (((struct GNUNET_MessageHeader *) packed_msg)->type), + ((struct GNUNET_MessageHeader *) packed_msg)->type); + LOG (GNUNET_ERROR_TYPE_DEBUG, + "DV_API receive: message sender reported as %s\n", + GNUNET_i2s (&received_msg->sender)); + LOG (GNUNET_ERROR_TYPE_DEBUG, "DV_API receive: distance is %u\n", + ntohl (received_msg->distance)); +#endif + + handle->receive_handler (handle->receive_cls, &received_msg->sender, + packed_msg, packed_msg_len, + ntohl (received_msg->distance), sender_address, + sender_address_len); + + GNUNET_free (sender_address); + break; + case GNUNET_MESSAGE_TYPE_TRANSPORT_DV_SEND_RESULT: + if (ntohs (msg->size) < sizeof (struct GNUNET_DV_SendResultMessage)) + return; + + send_result_msg = (struct GNUNET_DV_SendResultMessage *) msg; + hash_from_uid (ntohl (send_result_msg->uid), &uidhash); + send_ctx = + GNUNET_CONTAINER_multihashmap_get (handle->send_callbacks, &uidhash); + + if ((send_ctx != NULL) && (send_ctx->cont != NULL)) + { + if (ntohl (send_result_msg->result) == 0) + { + send_ctx->cont (send_ctx->cont_cls, &send_ctx->target, GNUNET_OK); + } + else + { + send_ctx->cont (send_ctx->cont_cls, &send_ctx->target, GNUNET_SYSERR); + } + } + GNUNET_free_non_null (send_ctx); + break; + default: + break; + } + GNUNET_CLIENT_receive (handle->client, &handle_message_receipt, handle, + GNUNET_TIME_UNIT_FOREVER_REL); +} + +/** + * Send a message from the plugin to the DV service indicating that + * a message should be sent via DV to some peer. + * + * @param dv_handle the handle to the DV api + * @param target the final target of the message + * @param msgbuf the msg(s) to send + * @param msgbuf_size the size of msgbuf + * @param priority priority to pass on to core when sending the message + * @param timeout how long can this message be delayed (pass through to core) + * @param addr the address of this peer (internally known to DV) + * @param addrlen the length of the peer address + * @param cont continuation to call once the message has been sent (or failed) + * @param cont_cls closure for continuation + * + */ +int +GNUNET_DV_send (struct GNUNET_DV_Handle *dv_handle, + const struct GNUNET_PeerIdentity *target, const char *msgbuf, + size_t msgbuf_size, unsigned int priority, + struct GNUNET_TIME_Relative timeout, const void *addr, + size_t addrlen, GNUNET_TRANSPORT_TransmitContinuation cont, + void *cont_cls) +{ + struct GNUNET_DV_SendMessage *msg; + struct SendCallbackContext *send_ctx; + char *end_of_message; + GNUNET_HashCode uidhash; + int msize; + +#if DEBUG_DV_MESSAGES + dv_handle->uid_gen = + GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_STRONG, UINT32_MAX); +#else + dv_handle->uid_gen++; +#endif + + msize = sizeof (struct GNUNET_DV_SendMessage) + addrlen + msgbuf_size; + msg = GNUNET_malloc (msize); + msg->header.size = htons (msize); + msg->header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_DV_SEND); + memcpy (&msg->target, target, sizeof (struct GNUNET_PeerIdentity)); + msg->priority = htonl (priority); + msg->timeout = timeout; + msg->addrlen = htonl (addrlen); + msg->uid = htonl (dv_handle->uid_gen); + memcpy (&msg[1], addr, addrlen); + end_of_message = (char *) &msg[1]; + end_of_message = &end_of_message[addrlen]; + memcpy (end_of_message, msgbuf, msgbuf_size); + add_pending (dv_handle, msg); + send_ctx = GNUNET_malloc (sizeof (struct SendCallbackContext)); + send_ctx->cont = cont; + send_ctx->cont_cls = cont_cls; + memcpy (&send_ctx->target, target, sizeof (struct GNUNET_PeerIdentity)); + hash_from_uid (dv_handle->uid_gen, &uidhash); + GNUNET_CONTAINER_multihashmap_put (dv_handle->send_callbacks, &uidhash, + send_ctx, + GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE); + + return GNUNET_OK; +} + +/** + * Callback to transmit a start message to + * the DV service, once we can send + * + * @param cls struct StartContext + * @param size how much can we send + * @param buf where to copy the message + * + * @return number of bytes copied to buf + */ +static size_t +transmit_start (void *cls, size_t size, void *buf) +{ + struct StartContext *start_context = cls; + struct GNUNET_DV_Handle *handle = start_context->handle; + size_t tsize; + +#if DEBUG_DV + LOG (GNUNET_ERROR_TYPE_DEBUG, "DV API: sending start request to service\n"); +#endif + if (buf == NULL) + { + GNUNET_free (start_context->message); + GNUNET_free (start_context); + GNUNET_DV_disconnect (handle); + return 0; + } + + tsize = ntohs (start_context->message->size); + if (size >= tsize) + { + memcpy (buf, start_context->message, tsize); + GNUNET_free (start_context->message); + GNUNET_free (start_context); + GNUNET_CLIENT_receive (handle->client, &handle_message_receipt, handle, + GNUNET_TIME_UNIT_FOREVER_REL); + + + return tsize; + } + + return 0; +} + +/** + * Connect to the DV service + * + * @param cfg the configuration to use + * @param receive_handler method call when on receipt from the service + * @param receive_handler_cls closure for receive_handler + * + * @return handle to the DV service + */ +struct GNUNET_DV_Handle * +GNUNET_DV_connect (const struct GNUNET_CONFIGURATION_Handle *cfg, + GNUNET_DV_MessageReceivedHandler receive_handler, + void *receive_handler_cls) +{ + struct GNUNET_DV_Handle *handle; + struct GNUNET_MessageHeader *start_message; + struct StartContext *start_context; + + handle = GNUNET_malloc (sizeof (struct GNUNET_DV_Handle)); + + handle->cfg = cfg; + handle->pending_list = NULL; + handle->current = NULL; + handle->th = NULL; + handle->client = GNUNET_CLIENT_connect ("dv", cfg); + handle->receive_handler = receive_handler; + handle->receive_cls = receive_handler_cls; + + if (handle->client == NULL) + { + GNUNET_free (handle); + return NULL; + } + + start_message = GNUNET_malloc (sizeof (struct GNUNET_MessageHeader)); + start_message->size = htons (sizeof (struct GNUNET_MessageHeader)); + start_message->type = htons (GNUNET_MESSAGE_TYPE_DV_START); + + start_context = GNUNET_malloc (sizeof (struct StartContext)); + start_context->handle = handle; + start_context->message = start_message; + GNUNET_CLIENT_notify_transmit_ready (handle->client, + sizeof (struct GNUNET_MessageHeader), + GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_SECONDS, 60), + GNUNET_YES, &transmit_start, + start_context); + + handle->send_callbacks = GNUNET_CONTAINER_multihashmap_create (100); + + return handle; +} + +/** + * Disconnect from the DV service + * + * @param handle the current handle to the service to disconnect + */ +void +GNUNET_DV_disconnect (struct GNUNET_DV_Handle *handle) +{ + struct PendingMessages *pos; + + GNUNET_assert (handle != NULL); + + if (handle->th != NULL) /* We have a live transmit request in the Aether */ + { + GNUNET_CLIENT_notify_transmit_ready_cancel (handle->th); + handle->th = NULL; + } + if (handle->current != NULL) /* We are trying to send something now, clean it up */ + GNUNET_free (handle->current); + while (NULL != (pos = handle->pending_list)) /* Remove all pending sends from the list */ + { + handle->pending_list = pos->next; + GNUNET_free (pos); + } + if (handle->client != NULL) /* Finally, disconnect from the service */ + { + GNUNET_CLIENT_disconnect (handle->client, GNUNET_NO); + handle->client = NULL; + } + + GNUNET_free (handle); +} + +/* end of dv_api.c */ diff --git a/src/dv/gnunet-service-dv.c b/src/dv/gnunet-service-dv.c new file mode 100644 index 0000000..50aac09 --- /dev/null +++ b/src/dv/gnunet-service-dv.c @@ -0,0 +1,3335 @@ +/* + This file is part of GNUnet. + (C) 2009 Christian Grothoff (and other contributing authors) + + GNUnet is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published + by the Free Software Foundation; either version 3, or (at your + option) any later version. + + GNUnet is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with GNUnet; see the file COPYING. If not, write to the + Free Software Foundation, Inc., 59 Temple Place - Suite 330, + Boston, MA 02111-1307, USA. +*/ + +/** + * @file dv/gnunet-service-dv.c + * @brief the distance vector service, primarily handles gossip of nearby + * peers and sending/receiving DV messages from core and decapsulating + * them + * + * @author Christian Grothoff + * @author Nathan Evans + * + */ +#include "platform.h" +#include "gnunet_client_lib.h" +#include "gnunet_getopt_lib.h" +#include "gnunet_os_lib.h" +#include "gnunet_protocols.h" +#include "gnunet_service_lib.h" +#include "gnunet_core_service.h" +#include "gnunet_signal_lib.h" +#include "gnunet_util_lib.h" +#include "gnunet_hello_lib.h" +#include "gnunet_peerinfo_service.h" +#include "gnunet_crypto_lib.h" +#include "gnunet_statistics_service.h" +#include "dv.h" + +/** + * For testing mostly, remember only the + * shortest path to a distant neighbor. + */ +#define AT_MOST_ONE GNUNET_NO + +#define USE_PEER_ID GNUNET_YES + +/** + * How many outstanding messages (unknown sender) will we allow per peer? + */ +#define MAX_OUTSTANDING_MESSAGES 5 + +/** + * How often do we check about sending out more peer information (if + * we are connected to no peers previously). + */ +#define GNUNET_DV_DEFAULT_SEND_INTERVAL GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MILLISECONDS, 500000) + +/** + * How long do we wait at most between sending out information? + */ +#define GNUNET_DV_MAX_SEND_INTERVAL GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MILLISECONDS, 500000) + +/** + * How long can we have not heard from a peer and + * still have it in our tables? + */ +#define GNUNET_DV_PEER_EXPIRATION_TIME GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 1000)) + +/** + * Priority for gossip. + */ +#define GNUNET_DV_DHT_GOSSIP_PRIORITY (GNUNET_EXTREME_PRIORITY / 10) + +/** + * How often should we check if expiration time has elapsed for + * some peer? + */ +#define GNUNET_DV_MAINTAIN_FREQUENCY GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 5)) + +/** + * How long to allow a message to be delayed? + */ +#define DV_DELAY GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 5)) + +/** + * Priority to use for DV data messages. + */ +#define DV_PRIORITY 0 + +/** + * The cost to a direct neighbor. We used to use 0, but 1 makes more sense. + */ +#define DIRECT_NEIGHBOR_COST 1 + +/** + * The default number of direct connections to store in DV (max) + */ +#define DEFAULT_DIRECT_CONNECTIONS 50 + +/** + * The default size of direct + extended peers in DV (max) + */ +#define DEFAULT_DV_SIZE 100 + +/** + * The default fisheye depth, from how many hops away will + * we keep peers? + */ +#define DEFAULT_FISHEYE_DEPTH 4 + +/** + * Linked list of messages to send to clients. + */ +struct PendingMessage +{ + /** + * Pointer to next item in the list + */ + struct PendingMessage *next; + + /** + * Pointer to previous item in the list + */ + struct PendingMessage *prev; + + /** + * The PeerIdentity to send to + */ + struct GNUNET_PeerIdentity recipient; + + /** + * The result of message sending. + */ + struct GNUNET_DV_SendResultMessage *send_result; + + /** + * Message importance level. + */ + unsigned int importance; + + /** + * Size of message. + */ + unsigned int msg_size; + + /** + * How long to wait before sending message. + */ + struct GNUNET_TIME_Relative timeout; + + /** + * Actual message to be sent; // avoid allocation + */ + const struct GNUNET_MessageHeader *msg; // msg = (cast) &pm[1]; // memcpy (&pm[1], data, len); + +}; + +struct FastGossipNeighborList +{ + /** + * Next element of DLL + */ + struct FastGossipNeighborList *next; + + /** + * Prev element of DLL + */ + struct FastGossipNeighborList *prev; + + /** + * The neighbor to gossip about + */ + struct DistantNeighbor *about; +}; + +/** + * Context created whenever a direct peer connects to us, + * used to gossip other peers to it. + */ +struct NeighborSendContext +{ + /** + * The peer we will gossip to. + */ + struct DirectNeighbor *toNeighbor; + + /** + * The task associated with this context. + */ + GNUNET_SCHEDULER_TaskIdentifier task; + + /** + * Head of DLL of peers to gossip about + * as fast as possible to this peer, for initial + * set up. + */ + struct FastGossipNeighborList *fast_gossip_list_head; + + /** + * Tail of DLL of peers to gossip about + * as fast as possible to this peer, for initial + * set up. + */ + struct FastGossipNeighborList *fast_gossip_list_tail; + +}; + + +/** + * Struct to hold information for updating existing neighbors + */ +struct NeighborUpdateInfo +{ + /** + * Cost + */ + unsigned int cost; + + /** + * The existing neighbor + */ + struct DistantNeighbor *neighbor; + + /** + * The referrer of the possibly existing peer + */ + struct DirectNeighbor *referrer; + + /** + * The time we heard about this peer + */ + struct GNUNET_TIME_Absolute now; + + /** + * Peer id this peer uses to refer to neighbor. + */ + unsigned int referrer_peer_id; + +}; + +/** + * Struct to store a single message received with + * an unknown sender. + */ +struct UnknownSenderMessage +{ + /** + * Message sender (immediate) + */ + struct GNUNET_PeerIdentity sender; + + /** + * The actual message received + */ + struct GNUNET_MessageHeader *message; + + /** + * Latency of connection + */ + struct GNUNET_TIME_Relative latency; + + /** + * Distance to destination + */ + uint32_t distance; + + /** + * Unknown sender id + */ + uint32_t sender_id; +}; + +/** + * Struct where actual neighbor information is stored, + * referenced by min_heap and max_heap. Freeing dealt + * with when items removed from hashmap. + */ +struct DirectNeighbor +{ + /** + * Identity of neighbor. + */ + struct GNUNET_PeerIdentity identity; + + /** + * PublicKey of neighbor. + */ + struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded pkey; + + /** + * Head of DLL of nodes that this direct neighbor referred to us. + */ + struct DistantNeighbor *referee_head; + + /** + * Tail of DLL of nodes that this direct neighbor referred to us. + */ + struct DistantNeighbor *referee_tail; + + /** + * The sending context for gossiping peers to this neighbor. + */ + struct NeighborSendContext *send_context; + + /** + * Is this one of the direct neighbors that we are "hiding" + * from DV? + */ + int hidden; + + /** + * Save messages immediately from this direct neighbor from a + * distan peer we don't know on the chance that it will be + * gossiped about and we can deliver the message. + */ + struct UnknownSenderMessage pending_messages[MAX_OUTSTANDING_MESSAGES]; +}; + + +/** + * Struct where actual neighbor information is stored, + * referenced by min_heap and max_heap. Freeing dealt + * with when items removed from hashmap. + */ +struct DistantNeighbor +{ + /** + * We keep distant neighbor's of the same referrer in a DLL. + */ + struct DistantNeighbor *next; + + /** + * We keep distant neighbor's of the same referrer in a DLL. + */ + struct DistantNeighbor *prev; + + /** + * Node in min heap + */ + struct GNUNET_CONTAINER_HeapNode *min_loc; + + /** + * Node in max heap + */ + struct GNUNET_CONTAINER_HeapNode *max_loc; + + /** + * Identity of referrer (next hop towards 'neighbor'). + */ + struct DirectNeighbor *referrer; + + /** + * Identity of neighbor. + */ + struct GNUNET_PeerIdentity identity; + + /** + * PublicKey of neighbor. + */ + struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded *pkey; + + /** + * Last time we received routing information from this peer + */ + struct GNUNET_TIME_Absolute last_activity; + + /** + * Last time we sent routing information about this peer + */ + struct GNUNET_TIME_Absolute last_gossip; + + /** + * Cost to neighbor, used for actual distance vector computations + */ + unsigned int cost; + + /** + * Random identifier *we* use for this peer, to be used as shortcut + * instead of sending full peer id for each message + */ + unsigned int our_id; + + /** + * Random identifier the *referrer* uses for this peer. + */ + unsigned int referrer_id; + + /** + * Is this one of the direct neighbors that we are "hiding" + * from DV? + */ + int hidden; + +}; + +struct PeerIteratorContext +{ + /** + * The actual context, to be freed later. + */ + struct GNUNET_PEERINFO_IteratorContext *ic; + + /** + * The neighbor about which we are concerned. + */ + struct DirectNeighbor *neighbor; + + /** + * The distant neighbor entry for this direct neighbor. + */ + struct DistantNeighbor *distant; + +}; + +/** + * Context used for creating hello messages when + * gossips are received. + */ +struct HelloContext +{ + /** + * Identity of distant neighbor. + */ + struct GNUNET_PeerIdentity distant_peer; + + /** + * Identity of direct neighbor, via which we send this message. + */ + const struct GNUNET_PeerIdentity *direct_peer; + + /** + * How many addresses do we need to add (always starts at 1, then set to 0) + */ + int addresses_to_add; + +}; + +struct DV_SendContext +{ + /** + * The distant peer (should always match) + */ + struct GNUNET_PeerIdentity *distant_peer; + + /** + * The direct peer, we need to verify the referrer of. + */ + struct GNUNET_PeerIdentity *direct_peer; + + /** + * The message to be sent + */ + struct GNUNET_MessageHeader *message; + + /** + * The pre-built send result message. Simply needs to be queued + * and freed once send has been called! + */ + struct GNUNET_DV_SendResultMessage *send_result; + + /** + * The size of the message being sent, may be larger + * than message->header.size because it's multiple + * messages packed into one! + */ + size_t message_size; + + /** + * How important is this message? + */ + unsigned int importance; + + /** + * Timeout for this message + */ + struct GNUNET_TIME_Relative timeout; + + /** + * Unique ID for DV message + */ + unsigned int uid; +}; + +struct FindDestinationContext +{ + unsigned int tid; + struct DistantNeighbor *dest; +}; + +struct FindIDContext +{ + unsigned int tid; + struct GNUNET_PeerIdentity *dest; + const struct GNUNET_PeerIdentity *via; +}; + +struct DisconnectContext +{ + /** + * Distant neighbor to get pid from. + */ + struct DistantNeighbor *distant; + + /** + * Direct neighbor that disconnected. + */ + struct DirectNeighbor *direct; +}; + +struct TokenizedMessageContext +{ + /** + * Immediate sender of this message + */ + const struct GNUNET_PeerIdentity *peer; + + /** + * Distant sender of the message + */ + struct DistantNeighbor *distant; + + /** + * Uid for this set of messages + */ + uint32_t uid; +}; + +/** + * Context for finding the least cost peer to send to. + * Transport selection can only go so far. + */ +struct FindLeastCostContext +{ + struct DistantNeighbor *target; + unsigned int least_cost; +}; + +/** + * Handle to the core service api. + */ +static struct GNUNET_CORE_Handle *coreAPI; + +/** + * Stream tokenizer to handle messages coming in from core. + */ +static struct GNUNET_SERVER_MessageStreamTokenizer *coreMST; + +/** + * The identity of our peer. + */ +static struct GNUNET_PeerIdentity my_identity; + +/** + * The configuration for this service. + */ +static const struct GNUNET_CONFIGURATION_Handle *cfg; + + +/** + * The client, the DV plugin connected to us. Hopefully + * this client will never change, although if the plugin dies + * and returns for some reason it may happen. + */ +static struct GNUNET_SERVER_Client *client_handle; + +/** + * Task to run when we shut down, cleaning up all our trash + */ +static GNUNET_SCHEDULER_TaskIdentifier cleanup_task; + +static size_t default_dv_priority = 0; + +static char *my_short_id; + +/** + * Transmit handle to the plugin. + */ +static struct GNUNET_CONNECTION_TransmitHandle *plugin_transmit_handle; + +/** + * Head of DLL for client messages + */ +static struct PendingMessage *plugin_pending_head; + +/** + * Tail of DLL for client messages + */ +static struct PendingMessage *plugin_pending_tail; + +/** + * Handle to the peerinfo service + */ +static struct GNUNET_PEERINFO_Handle *peerinfo_handle; + +/** + * Transmit handle to core service. + */ +static struct GNUNET_CORE_TransmitHandle *core_transmit_handle; + +/** + * Head of DLL for core messages + */ +static struct PendingMessage *core_pending_head; + +/** + * Tail of DLL for core messages + */ +static struct PendingMessage *core_pending_tail; + +/** + * Map of PeerIdentifiers to 'struct GNUNET_dv_neighbor*'s for all + * directly connected peers. + */ +static struct GNUNET_CONTAINER_MultiHashMap *direct_neighbors; + +/** + * Map of PeerIdentifiers to 'struct GNUNET_dv_neighbor*'s for + * peers connected via DV (extended neighborhood). Does ALSO + * include any peers that are in 'direct_neighbors'; for those + * peers, the cost will be zero and the referrer all zeros. + */ +static struct GNUNET_CONTAINER_MultiHashMap *extended_neighbors; + +/** + * We use the min heap (min refers to cost) to prefer + * gossipping about peers with small costs. + */ +static struct GNUNET_CONTAINER_Heap *neighbor_min_heap; + +/** + * We use the max heap (max refers to cost) for general + * iterations over all peers and to remove the most costly + * connection if we have too many. + */ +static struct GNUNET_CONTAINER_Heap *neighbor_max_heap; + +/** + * Handle for the statistics service. + */ +struct GNUNET_STATISTICS_Handle *stats; + +/** + * How far out to keep peers we learn about. + */ +static unsigned long long fisheye_depth; + +/** + * How many peers to store at most. + */ +static unsigned long long max_table_size; + +/** + * We've been given a target ID based on the random numbers that + * we assigned to our DV-neighborhood. Find the entry for the + * respective neighbor. + */ +static int +find_destination (void *cls, struct GNUNET_CONTAINER_HeapNode *node, + void *element, GNUNET_CONTAINER_HeapCostType cost) +{ + struct FindDestinationContext *fdc = cls; + struct DistantNeighbor *dn = element; + + if (fdc->tid != dn->our_id) + return GNUNET_YES; + fdc->dest = dn; + return GNUNET_NO; +} + + +/** + * We've been given a target ID based on the random numbers that + * we assigned to our DV-neighborhood. Find the entry for the + * respective neighbor. + */ +static int +find_specific_id (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct FindIDContext *fdc = cls; + struct DistantNeighbor *dn = value; + + if (memcmp + (&dn->referrer->identity, fdc->via, + sizeof (struct GNUNET_PeerIdentity)) == 0) + { + fdc->tid = dn->referrer_id; + return GNUNET_NO; + } + return GNUNET_YES; +} + +/** + * Find a distant peer whose referrer_id matches what we're + * looking for. For looking up a peer we've gossipped about + * but is now disconnected. Need to do this because we don't + * want to remove those that may be accessible via a different + * route. + */ +static int +find_distant_peer (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct FindDestinationContext *fdc = cls; + struct DistantNeighbor *distant = value; + + if (fdc->tid == distant->referrer_id) + { + fdc->dest = distant; + return GNUNET_NO; + } + return GNUNET_YES; +} + +/** + * Function called to notify a client about the socket + * begin ready to queue more data. "buf" will be + * NULL and "size" zero if the socket was closed for + * writing in the meantime. + * + * @param cls closure + * @param size number of bytes available in buf + * @param buf where the callee should write the message + * @return number of bytes written to buf + */ +size_t +transmit_to_plugin (void *cls, size_t size, void *buf) +{ + char *cbuf = buf; + struct PendingMessage *reply; + size_t off; + size_t msize; + + if (buf == NULL) + { + /* client disconnected */ +#if DEBUG_DV_MESSAGES + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: %s buffer was NULL (client disconnect?)\n", my_short_id, + "transmit_to_plugin"); +#endif + return 0; + } + plugin_transmit_handle = NULL; + off = 0; + while ((NULL != (reply = plugin_pending_head)) && + (size >= off + (msize = ntohs (reply->msg->size)))) + { + GNUNET_CONTAINER_DLL_remove (plugin_pending_head, plugin_pending_tail, + reply); + memcpy (&cbuf[off], reply->msg, msize); + GNUNET_free (reply); + off += msize; + } + + if (plugin_pending_head != NULL) + plugin_transmit_handle = + GNUNET_SERVER_notify_transmit_ready (client_handle, + ntohs (plugin_pending_head->msg-> + size), + GNUNET_TIME_UNIT_FOREVER_REL, + &transmit_to_plugin, NULL); + + return off; +} + +/** + * Send a message to the dv plugin. + * + * @param sender the direct sender of the message + * @param message the message to send to the plugin + * (may be an encapsulated type) + * @param message_size the size of the message to be sent + * @param distant_neighbor the original sender of the message + * @param cost the cost to the original sender of the message + */ +void +send_to_plugin (const struct GNUNET_PeerIdentity *sender, + const struct GNUNET_MessageHeader *message, size_t message_size, + struct GNUNET_PeerIdentity *distant_neighbor, size_t cost) +{ + struct GNUNET_DV_MessageReceived *received_msg; + struct PendingMessage *pending_message; + char *sender_address; + size_t sender_address_len; + char *packed_msg_start; + int size; + +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "send_to_plugin called with peer %s as sender\n", + GNUNET_i2s (distant_neighbor)); +#endif + + if (memcmp (sender, distant_neighbor, sizeof (struct GNUNET_PeerIdentity)) != + 0) + { + sender_address_len = sizeof (struct GNUNET_PeerIdentity) * 2; + sender_address = GNUNET_malloc (sender_address_len); + memcpy (sender_address, distant_neighbor, + sizeof (struct GNUNET_PeerIdentity)); + memcpy (&sender_address[sizeof (struct GNUNET_PeerIdentity)], sender, + sizeof (struct GNUNET_PeerIdentity)); + } + else + { + sender_address_len = sizeof (struct GNUNET_PeerIdentity); + sender_address = GNUNET_malloc (sender_address_len); + memcpy (sender_address, sender, sizeof (struct GNUNET_PeerIdentity)); + } + + size = + sizeof (struct GNUNET_DV_MessageReceived) + sender_address_len + + message_size; + received_msg = GNUNET_malloc (size); + received_msg->header.size = htons (size); + received_msg->header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_DV_RECEIVE); + received_msg->distance = htonl (cost); + received_msg->msg_len = htonl (message_size); + /* Set the sender in this message to be the original sender! */ + memcpy (&received_msg->sender, distant_neighbor, + sizeof (struct GNUNET_PeerIdentity)); + /* Copy the intermediate sender to the end of the message, this is how the transport identifies this peer */ + memcpy (&received_msg[1], sender_address, sender_address_len); + GNUNET_free (sender_address); + /* Copy the actual message after the sender */ + packed_msg_start = (char *) &received_msg[1]; + packed_msg_start = &packed_msg_start[sender_address_len]; + memcpy (packed_msg_start, message, message_size); + pending_message = GNUNET_malloc (sizeof (struct PendingMessage) + size); + pending_message->msg = (struct GNUNET_MessageHeader *) &pending_message[1]; + memcpy (&pending_message[1], received_msg, size); + GNUNET_free (received_msg); + + GNUNET_CONTAINER_DLL_insert_after (plugin_pending_head, plugin_pending_tail, + plugin_pending_tail, pending_message); + + if (client_handle != NULL) + { + if (plugin_transmit_handle == NULL) + { + plugin_transmit_handle = + GNUNET_SERVER_notify_transmit_ready (client_handle, size, + GNUNET_TIME_UNIT_FOREVER_REL, + &transmit_to_plugin, NULL); + } + } + else + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Failed to queue message for plugin, client_handle not yet set (how?)!\n"); + } +} + +/* Declare here so retry_core_send is aware of it */ +size_t +core_transmit_notify (void *cls, size_t size, void *buf); + +/** + * Try to send another message from our core sending list + */ +static void +try_core_send (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + struct PendingMessage *pending; + + pending = core_pending_head; + + if (core_transmit_handle != NULL) + return; /* Message send already in progress */ + + if ((pending != NULL) && (coreAPI != NULL)) + core_transmit_handle = + GNUNET_CORE_notify_transmit_ready (coreAPI, GNUNET_YES, + pending->importance, + pending->timeout, + &pending->recipient, + pending->msg_size, + &core_transmit_notify, NULL); +} + + +/** + * Function called to notify a client about the socket + * being ready to queue more data. "buf" will be + * NULL and "size" zero if the socket was closed for + * writing in the meantime. + * + * @param cls closure (NULL) + * @param size number of bytes available in buf + * @param buf where the callee should write the message + * @return number of bytes written to buf + */ +size_t +core_transmit_notify (void *cls, size_t size, void *buf) +{ + char *cbuf = buf; + struct PendingMessage *pending; + struct PendingMessage *client_reply; + size_t off; + size_t msize; + + if (buf == NULL) + { + /* client disconnected */ +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "`%s': buffer was NULL\n", "DHT"); +#endif + return 0; + } + + core_transmit_handle = NULL; + off = 0; + pending = core_pending_head; + if ((pending != NULL) && (size >= (msize = ntohs (pending->msg->size)))) + { +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "`%s' : transmit_notify (core) called with size %d\n", + "dv service", msize); +#endif + GNUNET_CONTAINER_DLL_remove (core_pending_head, core_pending_tail, pending); + if (pending->send_result != NULL) /* Will only be non-null if a real client asked for this send */ + { + client_reply = + GNUNET_malloc (sizeof (struct PendingMessage) + + sizeof (struct GNUNET_DV_SendResultMessage)); + client_reply->msg = (struct GNUNET_MessageHeader *) &client_reply[1]; + memcpy (&client_reply[1], pending->send_result, + sizeof (struct GNUNET_DV_SendResultMessage)); + GNUNET_free (pending->send_result); + + GNUNET_CONTAINER_DLL_insert_after (plugin_pending_head, + plugin_pending_tail, + plugin_pending_tail, client_reply); + if (client_handle != NULL) + { + if (plugin_transmit_handle == NULL) + { + plugin_transmit_handle = + GNUNET_SERVER_notify_transmit_ready (client_handle, + sizeof (struct + GNUNET_DV_SendResultMessage), + GNUNET_TIME_UNIT_FOREVER_REL, + &transmit_to_plugin, NULL); + } + else + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Failed to queue message for plugin, must be one in progress already!!\n"); + } + } + } + memcpy (&cbuf[off], pending->msg, msize); + GNUNET_free (pending); + off += msize; + } + /*reply = core_pending_head; */ + + GNUNET_SCHEDULER_add_now (&try_core_send, NULL); + /*if (reply != NULL) + * core_transmit_handle = GNUNET_CORE_notify_transmit_ready(coreAPI, GNUNET_YES, reply->importance, reply->timeout, &reply->recipient, reply->msg_size, &core_transmit_notify, NULL); */ + + return off; +} + + +/** + * Send a DV data message via DV. + * + * @param sender the original sender of the message + * @param recipient the next hop recipient, may be our direct peer, maybe not + * @param send_context the send context + */ +static int +send_message_via (const struct GNUNET_PeerIdentity *sender, + const struct GNUNET_PeerIdentity *recipient, + struct DV_SendContext *send_context) +{ + p2p_dv_MESSAGE_Data *toSend; + unsigned int msg_size; + unsigned int recipient_id; + unsigned int sender_id; + struct DistantNeighbor *source; + struct PendingMessage *pending_message; + struct FindIDContext find_context; + +#if DEBUG_DV + char shortname[5]; +#endif + + msg_size = send_context->message_size + sizeof (p2p_dv_MESSAGE_Data); + + find_context.dest = send_context->distant_peer; + find_context.via = recipient; + find_context.tid = 0; + GNUNET_CONTAINER_multihashmap_get_multiple (extended_neighbors, + &send_context-> + distant_peer->hashPubKey, + &find_specific_id, &find_context); + + if (find_context.tid == 0) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s: find_specific_id failed to find peer!\n", my_short_id); + /* target unknown to us, drop! */ + return GNUNET_SYSERR; + } + recipient_id = find_context.tid; + + if (0 == (memcmp (&my_identity, sender, sizeof (struct GNUNET_PeerIdentity)))) + { + sender_id = 0; + source = + GNUNET_CONTAINER_multihashmap_get (extended_neighbors, + &sender->hashPubKey); + if (source != NULL) + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s: send_message_via found %s, myself in extended peer list???\n", + my_short_id, GNUNET_i2s (&source->identity)); + } + else + { + source = + GNUNET_CONTAINER_multihashmap_get (extended_neighbors, + &sender->hashPubKey); + if (source == NULL) + { + /* sender unknown to us, drop! */ + return GNUNET_SYSERR; + } + sender_id = source->our_id; + } + + pending_message = GNUNET_malloc (sizeof (struct PendingMessage) + msg_size); + pending_message->msg = (struct GNUNET_MessageHeader *) &pending_message[1]; + pending_message->send_result = send_context->send_result; + memcpy (&pending_message->recipient, recipient, + sizeof (struct GNUNET_PeerIdentity)); + pending_message->msg_size = msg_size; + pending_message->importance = send_context->importance; + pending_message->timeout = send_context->timeout; + toSend = (p2p_dv_MESSAGE_Data *) pending_message->msg; + toSend->header.size = htons (msg_size); + toSend->header.type = htons (GNUNET_MESSAGE_TYPE_DV_DATA); + toSend->sender = htonl (sender_id); + toSend->recipient = htonl (recipient_id); +#if DEBUG_DV_MESSAGES + toSend->uid = send_context->uid; /* Still sent around in network byte order */ +#else + toSend->uid = htonl (0); +#endif + + memcpy (&toSend[1], send_context->message, send_context->message_size); + +#if DEBUG_DV + memcpy (&shortname, GNUNET_i2s (send_context->distant_peer), 4); + shortname[4] = '\0'; + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Notifying core of send to destination `%s' via `%s' size %u\n", + "DV", &shortname, GNUNET_i2s (recipient), msg_size); +#endif + + GNUNET_CONTAINER_DLL_insert_after (core_pending_head, core_pending_tail, + core_pending_tail, pending_message); + + GNUNET_SCHEDULER_add_now (try_core_send, NULL); + + return GNUNET_YES; +} + +/** + * Given a FindLeastCostContext, and a set + * of peers that match the target, return the cheapest. + * + * @param cls closure, a struct FindLeastCostContext + * @param key the key identifying the target peer + * @param value the target peer + * + * @return GNUNET_YES to continue iteration, GNUNET_NO to stop + */ +static int +find_least_cost_peer (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct FindLeastCostContext *find_context = cls; + struct DistantNeighbor *dn = value; + + if (dn->cost < find_context->least_cost) + { + find_context->target = dn; + } + if (dn->cost == DIRECT_NEIGHBOR_COST) + return GNUNET_NO; + return GNUNET_YES; +} + +/** + * Send a DV data message via DV. + * + * @param recipient the ultimate recipient of this message + * @param sender the original sender of the message + * @param specific_neighbor the specific neighbor to send this message via + * @param message the packed message + * @param message_size size of the message + * @param importance what priority to send this message with + * @param uid the unique identifier of this message (or 0 for none) + * @param timeout how long to possibly delay sending this message + */ +static int +send_message (const struct GNUNET_PeerIdentity *recipient, + const struct GNUNET_PeerIdentity *sender, + const struct DistantNeighbor *specific_neighbor, + const struct GNUNET_MessageHeader *message, size_t message_size, + unsigned int importance, unsigned int uid, + struct GNUNET_TIME_Relative timeout) +{ + p2p_dv_MESSAGE_Data *toSend; + unsigned int msg_size; + unsigned int cost; + unsigned int recipient_id; + unsigned int sender_id; + struct DistantNeighbor *target; + struct DistantNeighbor *source; + struct PendingMessage *pending_message; + struct FindLeastCostContext find_least_ctx; + +#if DEBUG_DV_PEER_NUMBERS + struct GNUNET_CRYPTO_HashAsciiEncoded encPeerFrom; + struct GNUNET_CRYPTO_HashAsciiEncoded encPeerTo; + struct GNUNET_CRYPTO_HashAsciiEncoded encPeerVia; +#endif + msg_size = message_size + sizeof (p2p_dv_MESSAGE_Data); + + find_least_ctx.least_cost = -1; + find_least_ctx.target = NULL; + /* + * Need to find the least cost peer, lest the transport selection keep + * picking the same DV route for the same destination which results + * in messages looping forever. Relatively cheap, we don't iterate + * over all known peers, just those that apply. + */ + GNUNET_CONTAINER_multihashmap_get_multiple (extended_neighbors, + &recipient->hashPubKey, + &find_least_cost_peer, + &find_least_ctx); + target = find_least_ctx.target; + + if (target == NULL) + { + /* target unknown to us, drop! */ + return GNUNET_SYSERR; + } + recipient_id = target->referrer_id; + + source = + GNUNET_CONTAINER_multihashmap_get (extended_neighbors, + &sender->hashPubKey); + if (source == NULL) + { + if (0 != + (memcmp (&my_identity, sender, sizeof (struct GNUNET_PeerIdentity)))) + { + /* sender unknown to us, drop! */ + return GNUNET_SYSERR; + } + sender_id = 0; /* 0 == us */ + } + else + { + /* find out the number that we use when we gossip about + * the sender */ + sender_id = source->our_id; + } + +#if DEBUG_DV_PEER_NUMBERS + GNUNET_CRYPTO_hash_to_enc (&source->identity.hashPubKey, &encPeerFrom); + GNUNET_CRYPTO_hash_to_enc (&target->referrer->identity.hashPubKey, + &encPeerVia); + encPeerFrom.encoding[4] = '\0'; + encPeerVia.encoding[4] = '\0'; +#endif + if ((sender_id != 0) && + (0 == + memcmp (&source->identity, &target->referrer->identity, + sizeof (struct GNUNET_PeerIdentity)))) + { + return 0; + } + + cost = target->cost; + pending_message = GNUNET_malloc (sizeof (struct PendingMessage) + msg_size); + pending_message->msg = (struct GNUNET_MessageHeader *) &pending_message[1]; + pending_message->send_result = NULL; + pending_message->importance = importance; + pending_message->timeout = timeout; + memcpy (&pending_message->recipient, &target->referrer->identity, + sizeof (struct GNUNET_PeerIdentity)); + pending_message->msg_size = msg_size; + toSend = (p2p_dv_MESSAGE_Data *) pending_message->msg; + toSend->header.size = htons (msg_size); + toSend->header.type = htons (GNUNET_MESSAGE_TYPE_DV_DATA); + toSend->sender = htonl (sender_id); + toSend->recipient = htonl (recipient_id); +#if DEBUG_DV_MESSAGES + toSend->uid = htonl (uid); +#else + toSend->uid = htonl (0); +#endif + +#if DEBUG_DV_PEER_NUMBERS + GNUNET_CRYPTO_hash_to_enc (&target->identity.hashPubKey, &encPeerTo); + encPeerTo.encoding[4] = '\0'; + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Sending DATA message. Sender id %u, source %s, destination %s, via %s\n", + GNUNET_i2s (&my_identity), sender_id, &encPeerFrom, &encPeerTo, + &encPeerVia); +#endif + memcpy (&toSend[1], message, message_size); + if ((source != NULL) && (source->pkey == NULL)) /* Test our hypothesis about message failures! */ + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s: Sending message, but anticipate recipient will not know sender!!!\n\n\n", + my_short_id); + } + GNUNET_CONTAINER_DLL_insert_after (core_pending_head, core_pending_tail, + core_pending_tail, pending_message); +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Notifying core of send size %d to destination `%s'\n", + "DV SEND MESSAGE", msg_size, GNUNET_i2s (recipient)); +#endif + + GNUNET_SCHEDULER_add_now (try_core_send, NULL); + return (int) cost; +} + +#if USE_PEER_ID +struct CheckPeerContext +{ + /** + * Peer we found + */ + struct DistantNeighbor *peer; + + /** + * Sender id to search for + */ + unsigned int sender_id; +}; + +/** + * Iterator over hash map entries. + * + * @param cls closure + * @param key current key code + * @param value value in the hash map + * @return GNUNET_YES if we should continue to + * iterate, + * GNUNET_NO if not. + */ +int +checkPeerID (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct CheckPeerContext *ctx = cls; + struct DistantNeighbor *distant = value; + + if (memcmp (key, &ctx->sender_id, sizeof (unsigned int)) == 0) + { + ctx->peer = distant; + return GNUNET_NO; + } + return GNUNET_YES; + +} +#endif + + +/** + * Handler for messages parsed out by the tokenizer from + * DV DATA received for this peer. + * + * @param cls NULL + * @param client the TokenizedMessageContext which contains message information + * @param message the actual message + */ +void +tokenized_message_handler (void *cls, void *client, + const struct GNUNET_MessageHeader *message) +{ + struct TokenizedMessageContext *ctx = client; + + GNUNET_break_op (ntohs (message->type) != GNUNET_MESSAGE_TYPE_DV_GOSSIP); + GNUNET_break_op (ntohs (message->type) != GNUNET_MESSAGE_TYPE_DV_DATA); + if ((ntohs (message->type) != GNUNET_MESSAGE_TYPE_DV_GOSSIP) && + (ntohs (message->type) != GNUNET_MESSAGE_TYPE_DV_DATA)) + { +#if DEBUG_DV_MESSAGES + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Receives %s message for me, uid %u, size %d, type %d cost %u from %s!\n", + my_short_id, "DV DATA", ctx->uid, ntohs (message->size), + ntohs (message->type), ctx->distant->cost, + GNUNET_i2s (&ctx->distant->identity)); +#endif + GNUNET_assert (memcmp + (ctx->peer, &ctx->distant->identity, + sizeof (struct GNUNET_PeerIdentity)) != 0); + send_to_plugin (ctx->peer, message, ntohs (message->size), + &ctx->distant->identity, ctx->distant->cost); + } +} + +#if DELAY_FORWARDS +struct DelayedMessageContext +{ + struct GNUNET_PeerIdentity dest; + struct GNUNET_PeerIdentity sender; + struct GNUNET_MessageHeader *message; + size_t message_size; + uint32_t uid; +}; + +void +send_message_delayed (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + struct DelayedMessageContext *msg_ctx = cls; + + if (msg_ctx != NULL) + { + send_message (&msg_ctx->dest, &msg_ctx->sender, NULL, msg_ctx->message, + msg_ctx->message_size, default_dv_priority, msg_ctx->uid, + GNUNET_TIME_relative_get_forever ()); + GNUNET_free (msg_ctx->message); + GNUNET_free (msg_ctx); + } +} +#endif + +/** + * Get distance information from 'atsi'. + * + * @param atsi performance data + * @param atsi_count number of entries in atsi + * @return connected transport distance + */ +static uint32_t +get_atsi_distance (const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + unsigned int i; + + for (i = 0; i < atsi_count; i++) + if (ntohl (atsi[i].type) == GNUNET_ATS_QUALITY_NET_DISTANCE) + return ntohl (atsi->value); + /* FIXME: we do not have distance data? Assume direct neighbor. */ + return DIRECT_NEIGHBOR_COST; +} + +/** + * Find latency information in 'atsi'. + * + * @param atsi performance data + * @param atsi_count number of entries in atsi + * @return connection latency + */ +static struct GNUNET_TIME_Relative +get_atsi_latency (const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + unsigned int i; + + for (i = 0; i < atsi_count; i++) + if (ntohl (atsi[i].type) == GNUNET_ATS_QUALITY_NET_DELAY) + return GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS, + ntohl (atsi->value)); + GNUNET_break (0); + /* how can we not have latency data? */ + return GNUNET_TIME_UNIT_SECONDS; +} + +/** + * Core handler for dv data messages. Whatever this message + * contains all we really have to do is rip it out of its + * DV layering and give it to our pal the DV plugin to report + * in with. + * + * @param cls closure + * @param peer peer which sent the message (immediate sender) + * @param message the message + * @param atsi transport ATS information (latency, distance, etc.) + * @param atsi_count number of entries in atsi + */ +static int +handle_dv_data_message (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_MessageHeader *message, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + const p2p_dv_MESSAGE_Data *incoming = (const p2p_dv_MESSAGE_Data *) message; + const struct GNUNET_MessageHeader *packed_message; + struct DirectNeighbor *dn; + struct DistantNeighbor *pos; + unsigned int sid; /* Sender id */ + unsigned int tid; /* Target id */ + struct GNUNET_PeerIdentity *original_sender; + struct GNUNET_PeerIdentity *destination; + struct FindDestinationContext fdc; + struct TokenizedMessageContext tkm_ctx; + int i; + int found_pos; + +#if DELAY_FORWARDS + struct DelayedMessageContext *delayed_context; +#endif +#if USE_PEER_ID + struct CheckPeerContext checkPeerCtx; +#endif +#if DEBUG_DV_MESSAGES + char *sender_id; +#endif + int ret; + size_t packed_message_size; + char *cbuf; + uint32_t distance; /* Distance information */ + struct GNUNET_TIME_Relative latency; /* Latency information */ + + packed_message_size = + ntohs (incoming->header.size) - sizeof (p2p_dv_MESSAGE_Data); +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Receives DATA message from %s size %d, packed size %d!\n", + my_short_id, GNUNET_i2s (peer), ntohs (incoming->header.size), + packed_message_size); +#endif + + if (ntohs (incoming->header.size) < + sizeof (p2p_dv_MESSAGE_Data) + sizeof (struct GNUNET_MessageHeader)) + { +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "`%s': Message sizes don't add up, total size %u, expected at least %u!\n", + "dv service", ntohs (incoming->header.size), + sizeof (p2p_dv_MESSAGE_Data) + + sizeof (struct GNUNET_MessageHeader)); +#endif + return GNUNET_SYSERR; + } + + /* Iterate over ATS_Information to get distance and latency */ + latency = get_atsi_latency (atsi, atsi_count); + distance = get_atsi_distance (atsi, atsi_count); + dn = GNUNET_CONTAINER_multihashmap_get (direct_neighbors, &peer->hashPubKey); + if (dn == NULL) + return GNUNET_OK; + + sid = ntohl (incoming->sender); +#if USE_PEER_ID + if (sid != 0) + { + checkPeerCtx.sender_id = sid; + checkPeerCtx.peer = NULL; + GNUNET_CONTAINER_multihashmap_iterate (extended_neighbors, &checkPeerID, + &checkPeerCtx); + pos = checkPeerCtx.peer; + } + else + { + pos = + GNUNET_CONTAINER_multihashmap_get (extended_neighbors, + &peer->hashPubKey); + } +#else + pos = dn->referee_head; + while ((NULL != pos) && (pos->referrer_id != sid)) + pos = pos->next; +#endif + + if (pos == NULL) + { +#if DEBUG_DV_MESSAGES + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: unknown sender (%u), Message uid %u from %s!\n", + my_short_id, ntohl (incoming->sender), ntohl (incoming->uid), + GNUNET_i2s (&dn->identity)); + pos = dn->referee_head; + while ((NULL != pos) && (pos->referrer_id != sid)) + { + sender_id = GNUNET_strdup (GNUNET_i2s (&pos->identity)); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "I know sender %u %s\n", + pos->referrer_id, sender_id); + GNUNET_free (sender_id); + pos = pos->next; + } +#endif + + found_pos = -1; + for (i = 0; i < MAX_OUTSTANDING_MESSAGES; i++) + { + if (dn->pending_messages[i].sender_id == 0) + { + found_pos = i; + break; + } + } + + if (found_pos == -1) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s: Too many unknown senders (%u), ignoring message! Message uid %llu from %s!\n", + my_short_id, ntohl (incoming->sender), ntohl (incoming->uid), + GNUNET_i2s (&dn->identity)); + } + else + { + dn->pending_messages[found_pos].message = + GNUNET_malloc (ntohs (message->size)); + memcpy (dn->pending_messages[found_pos].message, message, + ntohs (message->size)); + dn->pending_messages[found_pos].distance = distance; + dn->pending_messages[found_pos].latency = latency; + memcpy (&dn->pending_messages[found_pos].sender, peer, + sizeof (struct GNUNET_PeerIdentity)); + dn->pending_messages[found_pos].sender_id = sid; + } + /* unknown sender */ + return GNUNET_OK; + } + original_sender = &pos->identity; + tid = ntohl (incoming->recipient); + if (tid == 0) + { + /* 0 == us */ + cbuf = (char *) &incoming[1]; + + tkm_ctx.peer = peer; + tkm_ctx.distant = pos; + tkm_ctx.uid = ntohl (incoming->uid); + if (GNUNET_OK != + GNUNET_SERVER_mst_receive (coreMST, &tkm_ctx, cbuf, packed_message_size, + GNUNET_NO, GNUNET_NO)) + { + GNUNET_break_op (0); + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s: %s Received corrupt data, discarding!", my_short_id, + "DV SERVICE"); + } + return GNUNET_OK; + } + else + { + packed_message = (struct GNUNET_MessageHeader *) &incoming[1]; + } + + /* FIXME: this is the *only* per-request operation we have in DV + * that is O(n) in relation to the number of connected peers; a + * hash-table lookup could easily solve this (minor performance + * issue) */ + fdc.tid = tid; + fdc.dest = NULL; + GNUNET_CONTAINER_heap_iterate (neighbor_max_heap, &find_destination, &fdc); + +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Receives %s message for someone else!\n", "dv", "DV DATA"); +#endif + + if (fdc.dest == NULL) + { +#if DEBUG_DV_MESSAGES + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Receives %s message uid %u for someone we don't know (id %u)!\n", + my_short_id, "DV DATA", ntohl (incoming->uid), tid); +#endif + return GNUNET_OK; + } + destination = &fdc.dest->identity; + + if (0 == memcmp (destination, peer, sizeof (struct GNUNET_PeerIdentity))) + { + /* FIXME: create stat: routing loop-discard! */ + +#if DEBUG_DV_MESSAGES + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: DROPPING MESSAGE uid %u type %d, routing loop! Message immediately from %s!\n", + my_short_id, ntohl (incoming->uid), + ntohs (packed_message->type), GNUNET_i2s (&dn->identity)); +#endif + return GNUNET_OK; + } + + /* At this point we have a message, and we need to forward it on to the + * next DV hop. + */ +#if DEBUG_DV_MESSAGES + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: FORWARD %s message for %s, uid %u, size %d type %d, cost %u!\n", + my_short_id, "DV DATA", GNUNET_i2s (destination), + ntohl (incoming->uid), ntohs (packed_message->size), + ntohs (packed_message->type), pos->cost); +#endif + +#if DELAY_FORWARDS + if (GNUNET_TIME_absolute_get_duration (pos->last_gossip).abs_value < + GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 2).abs_value) + { + delayed_context = GNUNET_malloc (sizeof (struct DelayedMessageContext)); + memcpy (&delayed_context->dest, destination, + sizeof (struct GNUNET_PeerIdentity)); + memcpy (&delayed_context->sender, original_sender, + sizeof (struct GNUNET_PeerIdentity)); + delayed_context->message = GNUNET_malloc (packed_message_size); + memcpy (delayed_context->message, packed_message, packed_message_size); + delayed_context->message_size = packed_message_size; + delayed_context->uid = ntohl (incoming->uid); + GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_MILLISECONDS, 2500), + &send_message_delayed, delayed_context); + return GNUNET_OK; + } + else +#endif + { + ret = + send_message (destination, original_sender, NULL, packed_message, + packed_message_size, default_dv_priority, + ntohl (incoming->uid), + GNUNET_TIME_relative_get_forever ()); + } + if (ret != GNUNET_SYSERR) + return GNUNET_OK; + else + { +#if DEBUG_MESSAGE_DROP + char *direct_id = GNUNET_strdup (GNUNET_i2s (&dn->identity)); + + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: DROPPING MESSAGE type %d, forwarding failed! Message immediately from %s!\n", + GNUNET_i2s (&my_identity), + ntohs (((struct GNUNET_MessageHeader *) &incoming[1])->type), + direct_id); + GNUNET_free (direct_id); +#endif + return GNUNET_SYSERR; + } +} + +#if DEBUG_DV +/** + * Iterator over hash map entries. + * + * @param cls closure (NULL) + * @param key current key code + * @param value value in the hash map (DistantNeighbor) + * @return GNUNET_YES if we should continue to + * iterate, + * GNUNET_NO if not. + */ +int +print_neighbors (void *cls, const GNUNET_HashCode * key, void *abs_value) +{ + struct DistantNeighbor *distant_neighbor = abs_value; + char my_shortname[5]; + char referrer_shortname[5]; + + memcpy (&my_shortname, GNUNET_i2s (&my_identity), 4); + my_shortname[4] = '\0'; + memcpy (&referrer_shortname, + GNUNET_i2s (&distant_neighbor->referrer->identity), 4); + referrer_shortname[4] = '\0'; + + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "`%s' %s: Peer `%s', distance %d, referrer `%s' pkey: %s\n", + &my_shortname, "DV", GNUNET_i2s (&distant_neighbor->identity), + distant_neighbor->cost, &referrer_shortname, + distant_neighbor->pkey == NULL ? "no" : "yes"); + return GNUNET_YES; +} +#endif + +/** + * Scheduled task which gossips about known direct peers to other connected + * peers. Will run until called with reason shutdown. + */ +static void +neighbor_send_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + struct NeighborSendContext *send_context = cls; + +#if DEBUG_DV_GOSSIP_SEND + char *encPeerAbout; + char *encPeerTo; +#endif + struct DistantNeighbor *about; + struct DirectNeighbor *to; + struct FastGossipNeighborList *about_list; + + p2p_dv_MESSAGE_NeighborInfo *message; + struct PendingMessage *pending_message; + + if ((tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) + { +#if DEBUG_DV_GOSSIP + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Called with reason shutdown, shutting down!\n", + GNUNET_i2s (&my_identity)); +#endif + return; + } + + if (send_context->fast_gossip_list_head != NULL) + { + about_list = send_context->fast_gossip_list_head; + about = about_list->about; + GNUNET_CONTAINER_DLL_remove (send_context->fast_gossip_list_head, + send_context->fast_gossip_list_tail, + about_list); + GNUNET_free (about_list); + } + else + { + /* FIXME: this may become a problem, because the heap walk has only one internal "walker". This means + * that if two neighbor_send_tasks are operating in lockstep (which is quite possible, given default + * values for all connected peers) there may be a serious bias as to which peers get gossiped about! + * Probably the *best* way to fix would be to have an opaque pointer to the walk position passed as + * part of the walk_get_next call. Then the heap would have to keep a list of walks, or reset the walk + * whenever a modification has been detected. Yuck either way. Perhaps we could iterate over the heap + * once to get a list of peers to gossip about and gossip them over time... But then if one goes away + * in the mean time that becomes nasty. For now we'll just assume that the walking is done + * asynchronously enough to avoid major problems (-; + * + * NOTE: probably fixed once we decided send rate based on allowed bandwidth. + */ + about = GNUNET_CONTAINER_heap_walk_get_next (neighbor_min_heap); + } + to = send_context->toNeighbor; + + if ((about != NULL) && (to != about->referrer /* split horizon */ ) && +#if SUPPORT_HIDING + (about->hidden == GNUNET_NO) && +#endif + (to != NULL) && + (0 != + memcmp (&about->identity, &to->identity, + sizeof (struct GNUNET_PeerIdentity))) && (about->pkey != NULL)) + { +#if DEBUG_DV_GOSSIP_SEND + encPeerAbout = GNUNET_strdup (GNUNET_i2s (&about->identity)); + encPeerTo = GNUNET_strdup (GNUNET_i2s (&to->identity)); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Sending info about peer %s id %u to directly connected peer %s\n", + GNUNET_i2s (&my_identity), encPeerAbout, about->our_id, + encPeerTo); + GNUNET_free (encPeerAbout); + GNUNET_free (encPeerTo); +#endif + about->last_gossip = GNUNET_TIME_absolute_get (); + pending_message = + GNUNET_malloc (sizeof (struct PendingMessage) + + sizeof (p2p_dv_MESSAGE_NeighborInfo)); + pending_message->msg = (struct GNUNET_MessageHeader *) &pending_message[1]; + pending_message->importance = default_dv_priority; + pending_message->timeout = GNUNET_TIME_relative_get_forever (); + memcpy (&pending_message->recipient, &to->identity, + sizeof (struct GNUNET_PeerIdentity)); + pending_message->msg_size = sizeof (p2p_dv_MESSAGE_NeighborInfo); + message = (p2p_dv_MESSAGE_NeighborInfo *) pending_message->msg; + message->header.size = htons (sizeof (p2p_dv_MESSAGE_NeighborInfo)); + message->header.type = htons (GNUNET_MESSAGE_TYPE_DV_GOSSIP); + message->cost = htonl (about->cost); + message->neighbor_id = htonl (about->our_id); + + memcpy (&message->pkey, about->pkey, + sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); + memcpy (&message->neighbor, &about->identity, + sizeof (struct GNUNET_PeerIdentity)); + + GNUNET_CONTAINER_DLL_insert_after (core_pending_head, core_pending_tail, + core_pending_tail, pending_message); + + GNUNET_SCHEDULER_add_now (try_core_send, NULL); + /*if (core_transmit_handle == NULL) + * core_transmit_handle = GNUNET_CORE_notify_transmit_ready(coreAPI, GNUNET_YES, default_dv_priority, GNUNET_TIME_relative_get_forever(), &to->identity, sizeof(p2p_dv_MESSAGE_NeighborInfo), &core_transmit_notify, NULL); */ + + } + + if (send_context->fast_gossip_list_head != NULL) /* If there are other peers in the fast list, schedule right away */ + { +#if DEBUG_DV_PEER_NUMBERS + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "DV SERVICE: still in fast send mode\n"); +#endif + send_context->task = + GNUNET_SCHEDULER_add_now (&neighbor_send_task, send_context); + } + else + { +#if DEBUG_DV_PEER_NUMBERS + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "DV SERVICE: entering slow send mode\n"); +#endif + send_context->task = + GNUNET_SCHEDULER_add_delayed (GNUNET_DV_DEFAULT_SEND_INTERVAL, + &neighbor_send_task, send_context); + } + + return; +} + + +/** + * Handle START-message. This is the first message sent to us + * by the client (can only be one!). + * + * @param cls closure (always NULL) + * @param client identification of the client + * @param message the actual message + */ +static void +handle_start (void *cls, struct GNUNET_SERVER_Client *client, + const struct GNUNET_MessageHeader *message) +{ + +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received `%s' request from client\n", + "START"); +#endif + + client_handle = client; + + GNUNET_SERVER_client_keep (client_handle); + GNUNET_SERVER_receive_done (client, GNUNET_OK); +} + +#if UNSIMPLER +/** + * Iterate over hash map entries for a distant neighbor, + * if direct neighbor matches context call send message + * + * @param cls closure, a DV_SendContext + * @param key current key code + * @param value value in the hash map + * @return GNUNET_YES if we should continue to + * iterate, + * GNUNET_NO if not. + */ +int +send_iterator (void *cls, const GNUNET_HashCode * key, void *abs_value) +{ + struct DV_SendContext *send_context = cls; + struct DistantNeighbor *distant_neighbor = abs_value; + + if (memcmp (distant_neighbor->referrer, send_context->direct_peer, sizeof (struct GNUNET_PeerIdentity)) == 0) /* They match, send and free */ + { + send_message_via (&my_identity, distant_neighbor, send_context); + return GNUNET_NO; + } + return GNUNET_YES; +} +#endif + +/** + * Service server's handler for message send requests (which come + * bubbling up to us through the DV plugin). + * + * @param cls closure + * @param client identification of the client + * @param message the actual message + */ +void +handle_dv_send_message (void *cls, struct GNUNET_SERVER_Client *client, + const struct GNUNET_MessageHeader *message) +{ + struct GNUNET_DV_SendMessage *send_msg; + struct GNUNET_DV_SendResultMessage *send_result_msg; + struct PendingMessage *pending_message; + size_t address_len; + size_t message_size; + struct GNUNET_PeerIdentity *destination; + struct GNUNET_PeerIdentity *direct; + struct GNUNET_MessageHeader *message_buf; + char *temp_pos; + int offset; + static struct GNUNET_CRYPTO_HashAsciiEncoded dest_hash; + struct DV_SendContext *send_context; + +#if DEBUG_DV_MESSAGES + char *cbuf; + struct GNUNET_MessageHeader *packed_message; +#endif + + if (client_handle == NULL) + { + client_handle = client; + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Setting initial client handle, never received `%s' message?\n", + "dv", "START"); + } + else if (client_handle != client) + { + client_handle = client; + /* What should we do in this case, assert fail or just log the warning? */ +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Setting client handle (was a different client!)!\n", "dv"); +#endif + } + + GNUNET_assert (ntohs (message->size) > sizeof (struct GNUNET_DV_SendMessage)); + send_msg = (struct GNUNET_DV_SendMessage *) message; + + address_len = ntohl (send_msg->addrlen); + GNUNET_assert (address_len == sizeof (struct GNUNET_PeerIdentity) * 2); + message_size = + ntohs (message->size) - sizeof (struct GNUNET_DV_SendMessage) - + address_len; + destination = GNUNET_malloc (sizeof (struct GNUNET_PeerIdentity)); + direct = GNUNET_malloc (sizeof (struct GNUNET_PeerIdentity)); + message_buf = GNUNET_malloc (message_size); + + temp_pos = (char *) &send_msg[1]; /* Set pointer to end of message */ + offset = 0; /* Offset starts at zero */ + + memcpy (destination, &temp_pos[offset], sizeof (struct GNUNET_PeerIdentity)); + offset += sizeof (struct GNUNET_PeerIdentity); + + memcpy (direct, &temp_pos[offset], sizeof (struct GNUNET_PeerIdentity)); + offset += sizeof (struct GNUNET_PeerIdentity); + + + memcpy (message_buf, &temp_pos[offset], message_size); + if (memcmp + (&send_msg->target, destination, + sizeof (struct GNUNET_PeerIdentity)) != 0) + { + GNUNET_CRYPTO_hash_to_enc (&destination->hashPubKey, &dest_hash); /* GNUNET_i2s won't properly work, need to hash one ourselves */ + dest_hash.encoding[4] = '\0'; + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s: asked to send message to `%s', but address is for `%s'!", + "DV SERVICE", GNUNET_i2s (&send_msg->target), + (const char *) &dest_hash.encoding); + } + +#if DEBUG_DV_MESSAGES + cbuf = (char *) message_buf; + offset = 0; + while (offset < message_size) + { + packed_message = (struct GNUNET_MessageHeader *) &cbuf[offset]; + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: DV PLUGIN SEND uid %u type %d to %s\n", my_short_id, + ntohl (send_msg->uid), ntohs (packed_message->type), + GNUNET_i2s (destination)); + offset += ntohs (packed_message->size); + } + /*GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "%s: DV PLUGIN SEND uid %u type %d to %s\n", my_short_id, ntohl(send_msg->uid), ntohs(message_buf->type), GNUNET_i2s(destination)); */ +#endif + GNUNET_CRYPTO_hash_to_enc (&destination->hashPubKey, &dest_hash); /* GNUNET_i2s won't properly work, need to hash one ourselves */ + dest_hash.encoding[4] = '\0'; + send_context = GNUNET_malloc (sizeof (struct DV_SendContext)); + + send_result_msg = GNUNET_malloc (sizeof (struct GNUNET_DV_SendResultMessage)); + send_result_msg->header.size = + htons (sizeof (struct GNUNET_DV_SendResultMessage)); + send_result_msg->header.type = + htons (GNUNET_MESSAGE_TYPE_TRANSPORT_DV_SEND_RESULT); + send_result_msg->uid = send_msg->uid; /* No need to ntohl->htonl this */ + + send_context->importance = ntohl (send_msg->priority); + send_context->timeout = send_msg->timeout; + send_context->direct_peer = direct; + send_context->distant_peer = destination; + send_context->message = message_buf; + send_context->message_size = message_size; + send_context->send_result = send_result_msg; +#if DEBUG_DV_MESSAGES + send_context->uid = send_msg->uid; +#endif + + if (send_message_via (&my_identity, direct, send_context) != GNUNET_YES) + { + send_result_msg->result = htons (1); + pending_message = + GNUNET_malloc (sizeof (struct PendingMessage) + + sizeof (struct GNUNET_DV_SendResultMessage)); + pending_message->msg = (struct GNUNET_MessageHeader *) &pending_message[1]; + memcpy (&pending_message[1], send_result_msg, + sizeof (struct GNUNET_DV_SendResultMessage)); + GNUNET_free (send_result_msg); + + GNUNET_CONTAINER_DLL_insert_after (plugin_pending_head, plugin_pending_tail, + plugin_pending_tail, pending_message); + + if (client_handle != NULL) + { + if (plugin_transmit_handle == NULL) + { + plugin_transmit_handle = + GNUNET_SERVER_notify_transmit_ready (client_handle, + sizeof (struct + GNUNET_DV_SendResultMessage), + GNUNET_TIME_UNIT_FOREVER_REL, + &transmit_to_plugin, NULL); + } + else + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Failed to queue message for plugin, must be one in progress already!!\n"); + } + } + GNUNET_CRYPTO_hash_to_enc (&destination->hashPubKey, &dest_hash); /* GNUNET_i2s won't properly work, need to hash one ourselves */ + dest_hash.encoding[4] = '\0'; + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s DV SEND failed to send message to destination `%s' via `%s'\n", + my_short_id, (const char *) &dest_hash.encoding, + GNUNET_i2s (direct)); + } + + /* In bizarro world GNUNET_SYSERR indicates that we succeeded */ +#if UNSIMPLER + if (GNUNET_SYSERR != + GNUNET_CONTAINER_multihashmap_get_multiple (extended_neighbors, + &destination->hashPubKey, + &send_iterator, send_context)) + { + send_result_msg->result = htons (1); + pending_message = + GNUNET_malloc (sizeof (struct PendingMessage) + + sizeof (struct GNUNET_DV_SendResultMessage)); + pending_message->msg = (struct GNUNET_MessageHeader *) &pending_message[1]; + memcpy (&pending_message[1], send_result_msg, + sizeof (struct GNUNET_DV_SendResultMessage)); + GNUNET_free (send_result_msg); + + GNUNET_CONTAINER_DLL_insert_after (plugin_pending_head, plugin_pending_tail, + plugin_pending_tail, pending_message); + + if (client_handle != NULL) + { + if (plugin_transmit_handle == NULL) + { + plugin_transmit_handle = + GNUNET_SERVER_notify_transmit_ready (client_handle, + sizeof (struct + GNUNET_DV_SendResultMessage), + GNUNET_TIME_UNIT_FOREVER_REL, + &transmit_to_plugin, NULL); + } + else + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Failed to queue message for plugin, must be one in progress already!!\n"); + } + } + GNUNET_CRYPTO_hash_to_enc (&destination->hashPubKey, &dest_hash); /* GNUNET_i2s won't properly work, need to hash one ourselves */ + dest_hash.encoding[4] = '\0'; + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s DV SEND failed to send message to destination `%s' via `%s'\n", + my_short_id, (const char *) &dest_hash.encoding, + GNUNET_i2s (direct)); + } +#endif + GNUNET_free (message_buf); + GNUNET_free (send_context); + GNUNET_free (direct); + GNUNET_free (destination); + + GNUNET_SERVER_receive_done (client, GNUNET_OK); +} + +/** Forward declarations **/ +static int +handle_dv_gossip_message (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_MessageHeader *message, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count); + +static int +handle_dv_disconnect_message (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_MessageHeader *message, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count); +/** End forward declarations **/ + + +/** + * List of handlers for the messages understood by this + * service. + * + * Hmm... will we need to register some handlers with core and + * some handlers with our server here? Because core should be + * getting the incoming DV messages (from whichever lower level + * transport) and then our server should be getting messages + * from the dv_plugin, right? + */ +static struct GNUNET_CORE_MessageHandler core_handlers[] = { + {&handle_dv_data_message, GNUNET_MESSAGE_TYPE_DV_DATA, 0}, + {&handle_dv_gossip_message, GNUNET_MESSAGE_TYPE_DV_GOSSIP, 0}, + {&handle_dv_disconnect_message, GNUNET_MESSAGE_TYPE_DV_DISCONNECT, 0}, + {NULL, 0, 0} +}; + +static struct GNUNET_SERVER_MessageHandler plugin_handlers[] = { + {&handle_dv_send_message, NULL, GNUNET_MESSAGE_TYPE_TRANSPORT_DV_SEND, 0}, + {&handle_start, NULL, GNUNET_MESSAGE_TYPE_DV_START, 0}, + {NULL, NULL, 0, 0} +}; + +/** + * Free a DistantNeighbor node, including removing it + * from the referer's list. + */ +static void +distant_neighbor_free (struct DistantNeighbor *referee) +{ + struct DirectNeighbor *referrer; + + referrer = referee->referrer; + if (referrer != NULL) + { + GNUNET_CONTAINER_DLL_remove (referrer->referee_head, referrer->referee_tail, + referee); + } + GNUNET_CONTAINER_heap_remove_node (referee->max_loc); + GNUNET_CONTAINER_heap_remove_node (referee->min_loc); + GNUNET_CONTAINER_multihashmap_remove_all (extended_neighbors, + &referee->identity.hashPubKey); + GNUNET_free_non_null (referee->pkey); + GNUNET_free (referee); +} + +/** + * Free a DirectNeighbor node, including removing it + * from the referer's list. + */ +static void +direct_neighbor_free (struct DirectNeighbor *direct) +{ + struct NeighborSendContext *send_context; + struct FastGossipNeighborList *about_list; + struct FastGossipNeighborList *prev_about; + + send_context = direct->send_context; + + if (send_context->task != GNUNET_SCHEDULER_NO_TASK) + GNUNET_SCHEDULER_cancel (send_context->task); + + about_list = send_context->fast_gossip_list_head; + while (about_list != NULL) + { + GNUNET_CONTAINER_DLL_remove (send_context->fast_gossip_list_head, + send_context->fast_gossip_list_tail, + about_list); + prev_about = about_list; + about_list = about_list->next; + GNUNET_free (prev_about); + } + GNUNET_free (send_context); + GNUNET_free (direct); +} + +/** + * Multihashmap iterator for sending out disconnect messages + * for a peer. + * + * @param cls the peer that was disconnected + * @param key key value stored under + * @param value the direct neighbor to send disconnect to + * + * @return GNUNET_YES to continue iteration, GNUNET_NO to stop + */ +static int +schedule_disconnect_messages (void *cls, const GNUNET_HashCode * key, + void *value) +{ + struct DisconnectContext *disconnect_context = cls; + struct DirectNeighbor *disconnected = disconnect_context->direct; + struct DirectNeighbor *notify = value; + struct PendingMessage *pending_message; + p2p_dv_MESSAGE_Disconnect *disconnect_message; + + if (memcmp + (¬ify->identity, &disconnected->identity, + sizeof (struct GNUNET_PeerIdentity)) == 0) + return GNUNET_YES; /* Don't send disconnect message to peer that disconnected! */ + + pending_message = + GNUNET_malloc (sizeof (struct PendingMessage) + + sizeof (p2p_dv_MESSAGE_Disconnect)); + pending_message->msg = (struct GNUNET_MessageHeader *) &pending_message[1]; + pending_message->importance = default_dv_priority; + pending_message->timeout = GNUNET_TIME_relative_get_forever (); + memcpy (&pending_message->recipient, ¬ify->identity, + sizeof (struct GNUNET_PeerIdentity)); + pending_message->msg_size = sizeof (p2p_dv_MESSAGE_Disconnect); + disconnect_message = (p2p_dv_MESSAGE_Disconnect *) pending_message->msg; + disconnect_message->header.size = htons (sizeof (p2p_dv_MESSAGE_Disconnect)); + disconnect_message->header.type = htons (GNUNET_MESSAGE_TYPE_DV_DISCONNECT); + disconnect_message->peer_id = htonl (disconnect_context->distant->our_id); + + GNUNET_CONTAINER_DLL_insert_after (core_pending_head, core_pending_tail, + core_pending_tail, pending_message); + + GNUNET_SCHEDULER_add_now (try_core_send, NULL); + /*if (core_transmit_handle == NULL) + * core_transmit_handle = GNUNET_CORE_notify_transmit_ready(coreAPI, GNUNET_YES, default_dv_priority, GNUNET_TIME_relative_get_forever(), ¬ify->identity, sizeof(p2p_dv_MESSAGE_Disconnect), &core_transmit_notify, NULL); */ + + return GNUNET_YES; +} + +/** + * Multihashmap iterator for freeing extended neighbors. + * + * @param cls NULL + * @param key key value stored under + * @param value the distant neighbor to be freed + * + * @return GNUNET_YES to continue iteration, GNUNET_NO to stop + */ +static int +free_extended_neighbors (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct DistantNeighbor *distant = value; + + distant_neighbor_free (distant); + return GNUNET_YES; +} + +/** + * Multihashmap iterator for freeing direct neighbors. + * + * @param cls NULL + * @param key key value stored under + * @param value the direct neighbor to be freed + * + * @return GNUNET_YES to continue iteration, GNUNET_NO to stop + */ +static int +free_direct_neighbors (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct DirectNeighbor *direct = value; + + direct_neighbor_free (direct); + return GNUNET_YES; +} + + +/** + * Task run during shutdown. + * + * @param cls unused + * @param tc unused + */ +static void +shutdown_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "calling CORE_DISCONNECT\n"); + GNUNET_CONTAINER_multihashmap_iterate (extended_neighbors, &print_neighbors, + NULL); +#endif + GNUNET_CONTAINER_multihashmap_iterate (extended_neighbors, + &free_extended_neighbors, NULL); + GNUNET_CONTAINER_multihashmap_destroy (extended_neighbors); + GNUNET_CONTAINER_multihashmap_iterate (direct_neighbors, + &free_direct_neighbors, NULL); + GNUNET_CONTAINER_multihashmap_destroy (direct_neighbors); + + GNUNET_CONTAINER_heap_destroy (neighbor_max_heap); + GNUNET_CONTAINER_heap_destroy (neighbor_min_heap); + + GNUNET_CORE_disconnect (coreAPI); + coreAPI = NULL; + GNUNET_PEERINFO_disconnect (peerinfo_handle); + GNUNET_SERVER_mst_destroy (coreMST); + GNUNET_free_non_null (my_short_id); +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "CORE_DISCONNECT completed\n"); +#endif +} + +/** + * To be called on core init/fail. + */ +void +core_init (void *cls, struct GNUNET_CORE_Handle *server, + const struct GNUNET_PeerIdentity *identity) +{ + + if (server == NULL) + { + GNUNET_SCHEDULER_cancel (cleanup_task); + GNUNET_SCHEDULER_add_now (&shutdown_task, NULL); + return; + } +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Core connection initialized, I am peer: %s\n", "dv", + GNUNET_i2s (identity)); +#endif + memcpy (&my_identity, identity, sizeof (struct GNUNET_PeerIdentity)); + my_short_id = GNUNET_strdup (GNUNET_i2s (&my_identity)); + coreAPI = server; +} + + +#if PKEY_NO_NEIGHBOR_ON_ADD +/** + * Iterator over hash map entries. + * + * @param cls closure + * @param key current key code + * @param value value in the hash map + * @return GNUNET_YES if we should continue to + * iterate, + * GNUNET_NO if not. + */ +static int +add_pkey_to_extended (void *cls, const GNUNET_HashCode * key, void *abs_value) +{ + struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded *pkey = cls; + struct DistantNeighbor *distant_neighbor = abs_value; + + if (distant_neighbor->pkey == NULL) + { + distant_neighbor->pkey = + GNUNET_malloc (sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); + memcpy (distant_neighbor->pkey, pkey, + sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); + } + + return GNUNET_YES; +} +#endif + +/** + * Iterator over hash map entries. + * + * @param cls closure + * @param key current key code + * @param value value in the hash map + * @return GNUNET_YES if we should continue to + * iterate, + * GNUNET_NO if not. + */ +static int +update_matching_neighbors (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct NeighborUpdateInfo *update_info = cls; + struct DistantNeighbor *distant_neighbor = value; + + if (update_info->referrer == distant_neighbor->referrer) /* Direct neighbor matches, update it's info and return GNUNET_NO */ + { + /* same referrer, cost change! */ + GNUNET_CONTAINER_heap_update_cost (neighbor_max_heap, + update_info->neighbor->max_loc, + update_info->cost); + GNUNET_CONTAINER_heap_update_cost (neighbor_min_heap, + update_info->neighbor->min_loc, + update_info->cost); + update_info->neighbor->last_activity = update_info->now; + update_info->neighbor->cost = update_info->cost; + update_info->neighbor->referrer_id = update_info->referrer_peer_id; + return GNUNET_NO; + } + + return GNUNET_YES; +} + + +/** + * Iterate over all current direct peers, add DISTANT newly connected + * peer to the fast gossip list for that peer so we get DV routing + * information out as fast as possible! + * + * @param cls the newly connected neighbor we will gossip about + * @param key the hashcode of the peer + * @param value the direct neighbor we should gossip to + * + * @return GNUNET_YES to continue iteration, GNUNET_NO otherwise + */ +static int +add_distant_all_direct_neighbors (void *cls, const GNUNET_HashCode * key, + void *value) +{ + struct DirectNeighbor *direct = (struct DirectNeighbor *) value; + struct DistantNeighbor *distant = (struct DistantNeighbor *) cls; + struct NeighborSendContext *send_context = direct->send_context; + struct FastGossipNeighborList *gossip_entry; + +#if DEBUG_DV + char *encPeerAbout; + char *encPeerTo; +#endif + + if (distant == NULL) + { + return GNUNET_YES; + } + + if (memcmp + (&direct->identity, &distant->identity, + sizeof (struct GNUNET_PeerIdentity)) == 0) + { + return GNUNET_YES; /* Don't gossip to a peer about itself! */ + } + +#if SUPPORT_HIDING + if (distant->hidden == GNUNET_YES) + return GNUNET_YES; /* This peer should not be gossipped about (hidden) */ +#endif + gossip_entry = GNUNET_malloc (sizeof (struct FastGossipNeighborList)); + gossip_entry->about = distant; + + GNUNET_CONTAINER_DLL_insert_after (send_context->fast_gossip_list_head, + send_context->fast_gossip_list_tail, + send_context->fast_gossip_list_tail, + gossip_entry); +#if DEBUG_DV + encPeerAbout = GNUNET_strdup (GNUNET_i2s (&distant->identity)); + encPeerTo = GNUNET_strdup (GNUNET_i2s (&direct->identity)); + + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Fast send info about peer %s id %u for directly connected peer %s\n", + GNUNET_i2s (&my_identity), encPeerAbout, distant->our_id, + encPeerTo); + GNUNET_free (encPeerAbout); + GNUNET_free (encPeerTo); +#endif + /*if (send_context->task != GNUNET_SCHEDULER_NO_TASK) + * GNUNET_SCHEDULER_cancel(send_context->task); */ + + send_context->task = + GNUNET_SCHEDULER_add_now (&neighbor_send_task, send_context); + return GNUNET_YES; +} + +/** + * Callback for hello address creation. + * + * @param cls closure, a struct HelloContext + * @param max maximum number of bytes that can be written to buf + * @param buf where to write the address information + * + * @return number of bytes written, 0 to signal the + * end of the iteration. + */ +static size_t +generate_hello_address (void *cls, size_t max, void *buf) +{ + struct HelloContext *hello_context = cls; + struct GNUNET_HELLO_Address hello_address; + char *addr_buffer; + size_t offset; + size_t size; + size_t ret; + + if (hello_context->addresses_to_add == 0) + return 0; + + /* Hello "address" will be concatenation of distant peer and direct peer identities */ + size = 2 * sizeof (struct GNUNET_PeerIdentity); + GNUNET_assert (max >= size); + + addr_buffer = GNUNET_malloc (size); + offset = 0; + /* Copy the distant peer identity to buffer */ + memcpy (addr_buffer, &hello_context->distant_peer, + sizeof (struct GNUNET_PeerIdentity)); + offset += sizeof (struct GNUNET_PeerIdentity); + /* Copy the direct peer identity to buffer */ + memcpy (&addr_buffer[offset], hello_context->direct_peer, + sizeof (struct GNUNET_PeerIdentity)); + memset (&hello_address.peer, 0, sizeof (struct GNUNET_PeerIdentity)); + hello_address.address = addr_buffer; + hello_address.transport_name = "dv"; + hello_address.address_length = size; + ret = + GNUNET_HELLO_add_address (&hello_address, + GNUNET_TIME_relative_to_absolute + (GNUNET_TIME_UNIT_HOURS), buf, max); + + hello_context->addresses_to_add--; + + GNUNET_free (addr_buffer); + return ret; +} + + +/** + * Handles when a peer is either added due to being newly connected + * or having been gossiped about, also called when the cost for a neighbor + * needs to be updated. + * + * @param peer identity of the peer whose info is being added/updated + * @param pkey public key of the peer whose info is being added/updated + * @param referrer_peer_id id to use when sending to 'peer' + * @param referrer if this is a gossiped peer, who did we hear it from? + * @param cost the cost of communicating with this peer via 'referrer' + * + * @return the added neighbor, the updated neighbor or NULL (neighbor + * not added) + */ +static struct DistantNeighbor * +addUpdateNeighbor (const struct GNUNET_PeerIdentity *peer, + struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded *pkey, + unsigned int referrer_peer_id, + struct DirectNeighbor *referrer, unsigned int cost) +{ + struct DistantNeighbor *neighbor; + struct DistantNeighbor *max; + struct GNUNET_TIME_Absolute now; + struct NeighborUpdateInfo *neighbor_update; + struct HelloContext *hello_context; + struct GNUNET_HELLO_Message *hello_msg; + unsigned int our_id; + char *addr1; + char *addr2; + int i; + +#if DEBUG_DV_PEER_NUMBERS + char *encAbout; + + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "%s Received sender id (%u)!\n", + "DV SERVICE", referrer_peer_id); +#endif + + now = GNUNET_TIME_absolute_get (); + neighbor = + GNUNET_CONTAINER_multihashmap_get (extended_neighbors, &peer->hashPubKey); + neighbor_update = GNUNET_malloc (sizeof (struct NeighborUpdateInfo)); + neighbor_update->neighbor = neighbor; + neighbor_update->cost = cost; + neighbor_update->now = now; + neighbor_update->referrer = referrer; + neighbor_update->referrer_peer_id = referrer_peer_id; + + if (neighbor != NULL) + { +#if USE_PEER_ID + memcpy (&our_id, &neighbor->identity, sizeof (unsigned int)); +#else + our_id = neighbor->our_id; +#endif + } + else + { +#if USE_PEER_ID + memcpy (&our_id, peer, sizeof (unsigned int)); +#else + our_id = + GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_STRONG, + RAND_MAX - 1) + 1; +#endif + } + + /* Either we do not know this peer, or we already do but via a different immediate peer */ + if ((neighbor == NULL) || + (GNUNET_CONTAINER_multihashmap_get_multiple + (extended_neighbors, &peer->hashPubKey, &update_matching_neighbors, + neighbor_update) != GNUNET_SYSERR)) + { +#if AT_MOST_ONE + if ((neighbor != NULL) && (cost < neighbor->cost)) /* New cost is less than old, remove old */ + { + distant_neighbor_free (neighbor); + } + else if (neighbor != NULL) /* Only allow one DV connection to each peer */ + { + return NULL; + } +#endif + /* new neighbor! */ + if (cost > fisheye_depth) + { + /* too costly */ + GNUNET_free (neighbor_update); + return NULL; + } + +#if DEBUG_DV_PEER_NUMBERS + encAbout = GNUNET_strdup (GNUNET_i2s (peer)); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: %s Chose NEW id (%u) for peer %s!\n", + GNUNET_i2s (&my_identity), "DV SERVICE", our_id, encAbout); + GNUNET_free (encAbout); +#endif + + if (max_table_size <= + GNUNET_CONTAINER_multihashmap_size (extended_neighbors)) + { + /* remove most expensive entry */ + max = GNUNET_CONTAINER_heap_peek (neighbor_max_heap); + GNUNET_assert (max != NULL); + if (cost > max->cost) + { + /* new entry most expensive, don't create */ + GNUNET_free (neighbor_update); + return NULL; + } + if (max->cost > 1) + { + /* only free if this is not a direct connection; + * we could theoretically have more direct + * connections than DV entries allowed total! */ + distant_neighbor_free (max); + } + } + + neighbor = GNUNET_malloc (sizeof (struct DistantNeighbor)); + GNUNET_CONTAINER_DLL_insert (referrer->referee_head, referrer->referee_tail, + neighbor); + neighbor->max_loc = + GNUNET_CONTAINER_heap_insert (neighbor_max_heap, neighbor, cost); + neighbor->min_loc = + GNUNET_CONTAINER_heap_insert (neighbor_min_heap, neighbor, cost); + neighbor->referrer = referrer; + memcpy (&neighbor->identity, peer, sizeof (struct GNUNET_PeerIdentity)); + if (pkey != NULL) /* pkey will be null on direct neighbor addition */ + { + neighbor->pkey = + GNUNET_malloc (sizeof + (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); + memcpy (neighbor->pkey, pkey, + sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); + } + else + neighbor->pkey = pkey; + + neighbor->last_activity = now; + neighbor->cost = cost; + neighbor->referrer_id = referrer_peer_id; + neighbor->our_id = our_id; + neighbor->hidden = + (cost == + DIRECT_NEIGHBOR_COST) + ? (GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 4) == + 0) : GNUNET_NO; + + GNUNET_CONTAINER_multihashmap_put (extended_neighbors, &peer->hashPubKey, + neighbor, + GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE); + if (referrer_peer_id != 0) + { + for (i = 0; i < MAX_OUTSTANDING_MESSAGES; i++) + { + if (referrer->pending_messages[i].sender_id == referrer_peer_id) /* We have a queued message from just learned about peer! */ + { +#if DEBUG_DV_MESSAGES + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: learned about peer %llu from which we have a previous unknown message, processing!\n", + my_short_id, referrer_peer_id); +#endif + struct GNUNET_ATS_Information atsi[2]; + + atsi[0].type = htonl (GNUNET_ATS_QUALITY_NET_DISTANCE); + atsi[0].value = htonl (referrer->pending_messages[i].distance); + atsi[1].type = htonl (GNUNET_ATS_QUALITY_NET_DELAY); + atsi[1].value = + htonl ((uint32_t) referrer->pending_messages[i]. + latency.rel_value); + handle_dv_data_message (NULL, &referrer->pending_messages[i].sender, + referrer->pending_messages[i].message, atsi, + 2); + GNUNET_free (referrer->pending_messages[i].message); + referrer->pending_messages[i].sender_id = 0; + } + } + } + if ((cost != DIRECT_NEIGHBOR_COST) && (neighbor->pkey != NULL)) + { + /* Added neighbor, now send HELLO to transport */ + hello_context = GNUNET_malloc (sizeof (struct HelloContext)); + hello_context->direct_peer = &referrer->identity; + memcpy (&hello_context->distant_peer, peer, + sizeof (struct GNUNET_PeerIdentity)); + hello_context->addresses_to_add = 1; + hello_msg = + GNUNET_HELLO_create (pkey, &generate_hello_address, hello_context); + GNUNET_assert (memcmp + (hello_context->direct_peer, &hello_context->distant_peer, + sizeof (struct GNUNET_PeerIdentity)) != 0); + addr1 = GNUNET_strdup (GNUNET_i2s (hello_context->direct_peer)); + addr2 = GNUNET_strdup (GNUNET_i2s (&hello_context->distant_peer)); +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: GIVING HELLO size %d for %s via %s to TRANSPORT\n", + my_short_id, GNUNET_HELLO_size (hello_msg), addr2, addr1); +#endif + GNUNET_free (addr1); + GNUNET_free (addr2); + send_to_plugin (hello_context->direct_peer, + GNUNET_HELLO_get_header (hello_msg), + GNUNET_HELLO_size (hello_msg), + &hello_context->distant_peer, cost); + GNUNET_free (hello_context); + GNUNET_free (hello_msg); + } + + } + else + { +#if DEBUG_DV_GOSSIP + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Already know peer %s distance %d, referrer id %d!\n", "dv", + GNUNET_i2s (peer), cost, referrer_peer_id); +#endif + } +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "%s: Size of extended_neighbors is %d\n", + "dv", GNUNET_CONTAINER_multihashmap_size (extended_neighbors)); +#endif + + GNUNET_free (neighbor_update); + return neighbor; +} + + +/** + * Core handler for dv disconnect messages. These will be used + * by us to tell transport via the dv plugin that a peer can + * no longer be contacted by us via a certain address. We should + * then propagate these messages on, given that the distance to + * the peer indicates we would have gossiped about it to others. + * + * @param cls closure + * @param peer peer which sent the message (immediate sender) + * @param message the message + * @param atsi performance data + * @param atsi_count number of entries in atsi + */ +static int +handle_dv_disconnect_message (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_MessageHeader *message, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + struct DirectNeighbor *referrer; + struct DistantNeighbor *distant; + p2p_dv_MESSAGE_Disconnect *enc_message = + (p2p_dv_MESSAGE_Disconnect *) message; + + if (ntohs (message->size) < sizeof (p2p_dv_MESSAGE_Disconnect)) + { + return GNUNET_SYSERR; /* invalid message */ + } + + referrer = + GNUNET_CONTAINER_multihashmap_get (direct_neighbors, &peer->hashPubKey); + if (referrer == NULL) + return GNUNET_OK; + + distant = referrer->referee_head; + while (distant != NULL) + { + if (distant->referrer_id == ntohl (enc_message->peer_id)) + { + distant_neighbor_free (distant); + distant = referrer->referee_head; + } + else + distant = distant->next; + } + + return GNUNET_OK; +} + + +/** + * Core handler for dv gossip messages. These will be used + * by us to create a HELLO message for the newly peer containing + * which direct peer we can connect through, and what the cost + * is. This HELLO will then be scheduled for validation by the + * transport service so that it can be used by all others. + * + * @param cls closure + * @param peer peer which sent the message (immediate sender) + * @param message the message + * @param atsi performance data + * @param atsi_count number of entries in atsi + */ +static int +handle_dv_gossip_message (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_MessageHeader *message, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + struct DirectNeighbor *referrer; + p2p_dv_MESSAGE_NeighborInfo *enc_message = + (p2p_dv_MESSAGE_NeighborInfo *) message; + + if (ntohs (message->size) < sizeof (p2p_dv_MESSAGE_NeighborInfo)) + { + return GNUNET_SYSERR; /* invalid message */ + } + +#if DEBUG_DV_GOSSIP_RECEIPT + char *encPeerAbout; + char *encPeerFrom; + + encPeerAbout = GNUNET_strdup (GNUNET_i2s (&enc_message->neighbor)); + encPeerFrom = GNUNET_strdup (GNUNET_i2s (peer)); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Received %s message from peer %s about peer %s id %u distance %d!\n", + GNUNET_i2s (&my_identity), "DV GOSSIP", encPeerFrom, encPeerAbout, + ntohl (enc_message->neighbor_id), ntohl (enc_message->cost) + 1); + GNUNET_free (encPeerAbout); + GNUNET_free (encPeerFrom); +#endif + + referrer = + GNUNET_CONTAINER_multihashmap_get (direct_neighbors, &peer->hashPubKey); + if (referrer == NULL) + return GNUNET_OK; + + addUpdateNeighbor (&enc_message->neighbor, &enc_message->pkey, + ntohl (enc_message->neighbor_id), referrer, + ntohl (enc_message->cost) + 1); + + return GNUNET_OK; +} + + +/** + * Iterate over all currently known peers, add them to the + * fast gossip list for this peer so we get DV routing information + * out as fast as possible! + * + * @param cls the direct neighbor we will gossip to + * @param key the hashcode of the peer + * @param value the distant neighbor we should add to the list + * + * @return GNUNET_YES to continue iteration, GNUNET_NO otherwise + */ +static int +add_all_extended_peers (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct NeighborSendContext *send_context = (struct NeighborSendContext *) cls; + struct DistantNeighbor *distant = (struct DistantNeighbor *) value; + struct FastGossipNeighborList *gossip_entry; + + if (memcmp + (&send_context->toNeighbor->identity, &distant->identity, + sizeof (struct GNUNET_PeerIdentity)) == 0) + return GNUNET_YES; /* Don't gossip to a peer about itself! */ + +#if SUPPORT_HIDING + if (distant->hidden == GNUNET_YES) + return GNUNET_YES; /* This peer should not be gossipped about (hidden) */ +#endif + gossip_entry = GNUNET_malloc (sizeof (struct FastGossipNeighborList)); + gossip_entry->about = distant; + + GNUNET_CONTAINER_DLL_insert_after (send_context->fast_gossip_list_head, + send_context->fast_gossip_list_tail, + send_context->fast_gossip_list_tail, + gossip_entry); + + return GNUNET_YES; +} + +#if INSANE_GOSSIP +/** + * Iterator over hash map entries. + * + * @param cls closure + * @param key current key code + * @param value value in the hash map + * @return GNUNET_YES if we should continue to + * iterate, + * GNUNET_NO if not. + */ +static int +gossip_all_to_all_iterator (void *cls, const GNUNET_HashCode * key, + void *abs_value) +{ + struct DirectNeighbor *direct = abs_value; + + GNUNET_CONTAINER_multihashmap_iterate (extended_neighbors, + &add_all_extended_peers, + direct->send_context); + + if (direct->send_context->task != GNUNET_SCHEDULER_NO_TASK) + GNUNET_SCHEDULER_cancel (direct->send_context->task); + + direct->send_context->task = + GNUNET_SCHEDULER_add_now (&neighbor_send_task, direct->send_context); + return GNUNET_YES; +} + +/** + * Task run during shutdown. + * + * @param cls unused + * @param tc unused + */ +static void +gossip_all_to_all (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + GNUNET_CONTAINER_multihashmap_iterate (direct_neighbors, + &gossip_all_to_all_iterator, NULL); + + GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_SECONDS, 5), + &gossip_all_to_all, NULL); + +} +#endif +/** + * Iterate over all current direct peers, add newly connected peer + * to the fast gossip list for that peer so we get DV routing + * information out as fast as possible! + * + * @param cls the newly connected neighbor we will gossip about + * @param key the hashcode of the peer + * @param value the direct neighbor we should gossip to + * + * @return GNUNET_YES to continue iteration, GNUNET_NO otherwise + */ +static int +add_all_direct_neighbors (void *cls, const GNUNET_HashCode * key, void *value) +{ + struct DirectNeighbor *direct = (struct DirectNeighbor *) value; + struct DirectNeighbor *to = (struct DirectNeighbor *) cls; + struct DistantNeighbor *distant; + struct NeighborSendContext *send_context = direct->send_context; + struct FastGossipNeighborList *gossip_entry; + char *direct_id; + + + distant = + GNUNET_CONTAINER_multihashmap_get (extended_neighbors, + &to->identity.hashPubKey); + if (distant == NULL) + { + return GNUNET_YES; + } + + if (memcmp + (&direct->identity, &to->identity, + sizeof (struct GNUNET_PeerIdentity)) == 0) + { + return GNUNET_YES; /* Don't gossip to a peer about itself! */ + } + +#if SUPPORT_HIDING + if (distant->hidden == GNUNET_YES) + return GNUNET_YES; /* This peer should not be gossipped about (hidden) */ +#endif + direct_id = GNUNET_strdup (GNUNET_i2s (&direct->identity)); +#if DEBUG_DV_GOSSIP + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "%s: adding peer %s to fast send list for %s\n", my_short_id, + GNUNET_i2s (&distant->identity), direct_id); +#endif + GNUNET_free (direct_id); + gossip_entry = GNUNET_malloc (sizeof (struct FastGossipNeighborList)); + gossip_entry->about = distant; + + GNUNET_CONTAINER_DLL_insert_after (send_context->fast_gossip_list_head, + send_context->fast_gossip_list_tail, + send_context->fast_gossip_list_tail, + gossip_entry); + if (send_context->task != GNUNET_SCHEDULER_NO_TASK) + GNUNET_SCHEDULER_cancel (send_context->task); + + send_context->task = + GNUNET_SCHEDULER_add_now (&neighbor_send_task, send_context); + //tc.reason = GNUNET_SCHEDULER_REASON_TIMEOUT; + //neighbor_send_task(send_context, &tc); + return GNUNET_YES; +} + +/** + * Type of an iterator over the hosts. Note that each + * host will be called with each available protocol. + * + * @param cls closure + * @param peer id of the peer, NULL for last call + * @param hello hello message for the peer (can be NULL) + * @param err_msg NULL if successful, otherwise contains error message + */ +static void +process_peerinfo (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_HELLO_Message *hello, const char *err_msg) +{ + struct PeerIteratorContext *peerinfo_iterator = cls; + struct DirectNeighbor *neighbor = peerinfo_iterator->neighbor; + struct DistantNeighbor *distant = peerinfo_iterator->distant; + +#if DEBUG_DV_PEER_NUMBERS + char *neighbor_pid; +#endif + int sent; + + if (err_msg != NULL) + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + _("Error in communication with PEERINFO service\n")); + /* return; */ + } + if (peer == NULL) + { + if (distant->pkey == NULL) + { +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Failed to get peerinfo information for this peer, retrying!\n"); +#endif + peerinfo_iterator->ic = + GNUNET_PEERINFO_iterate (peerinfo_handle, + &peerinfo_iterator->neighbor->identity, + GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_SECONDS, 3), + &process_peerinfo, peerinfo_iterator); + } + else + { + GNUNET_free (peerinfo_iterator); + } + return; + } + + if (memcmp + (&neighbor->identity, peer, sizeof (struct GNUNET_PeerIdentity) != 0)) + return; + + if ((hello != NULL) && + (GNUNET_HELLO_get_key (hello, &neighbor->pkey) == GNUNET_OK)) + { + if (distant->pkey == NULL) + { + distant->pkey = + GNUNET_malloc (sizeof + (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); + memcpy (distant->pkey, &neighbor->pkey, + sizeof (struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded)); + } + + sent = + GNUNET_CONTAINER_multihashmap_iterate (extended_neighbors, + &add_all_extended_peers, + neighbor->send_context); + if (stats != NULL) + { + GNUNET_STATISTICS_update (stats, + "# distant peers gossiped to direct neighbors", + sent, GNUNET_NO); + } +#if DEBUG_DV_PEER_NUMBERS + neighbor_pid = GNUNET_strdup (GNUNET_i2s (&neighbor->identity)); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Gossipped %d extended peers to %s\n", + GNUNET_i2s (&my_identity), sent, neighbor_pid); +#endif + sent = + GNUNET_CONTAINER_multihashmap_iterate (direct_neighbors, + &add_all_direct_neighbors, + neighbor); + if (stats != NULL) + { + GNUNET_STATISTICS_update (stats, + "# direct peers gossiped to direct neighbors", + sent, GNUNET_NO); + } +#if DEBUG_DV_PEER_NUMBERS + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Gossipped about %s to %d direct peers\n", + GNUNET_i2s (&my_identity), neighbor_pid, sent); + GNUNET_free (neighbor_pid); +#endif + neighbor->send_context->task = + GNUNET_SCHEDULER_add_now (&neighbor_send_task, neighbor->send_context); + } +} + + +/** + * Method called whenever a peer connects. + * + * @param cls closure + * @param peer peer identity this notification is about + * @param atsi performance data + * @param atsi_count number of entries in atsi + */ +static void +handle_core_connect (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + struct DirectNeighbor *neighbor; + struct DistantNeighbor *about; + struct PeerIteratorContext *peerinfo_iterator; + int sent; + + uint32_t distance; + + /* Check for connect to self message */ + if (0 == memcmp (&my_identity, peer, sizeof (struct GNUNET_PeerIdentity))) + return; + + distance = get_atsi_distance (atsi, atsi_count); + if ((distance == DIRECT_NEIGHBOR_COST) && + (GNUNET_CONTAINER_multihashmap_get (direct_neighbors, &peer->hashPubKey) + == NULL)) + { + peerinfo_iterator = GNUNET_malloc (sizeof (struct PeerIteratorContext)); + neighbor = GNUNET_malloc (sizeof (struct DirectNeighbor)); + neighbor->send_context = + GNUNET_malloc (sizeof (struct NeighborSendContext)); + neighbor->send_context->toNeighbor = neighbor; + memcpy (&neighbor->identity, peer, sizeof (struct GNUNET_PeerIdentity)); + + GNUNET_assert (GNUNET_SYSERR != + GNUNET_CONTAINER_multihashmap_put (direct_neighbors, + &peer->hashPubKey, + neighbor, + GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); + about = addUpdateNeighbor (peer, NULL, 0, neighbor, DIRECT_NEIGHBOR_COST); + peerinfo_iterator->distant = about; + peerinfo_iterator->neighbor = neighbor; + peerinfo_iterator->ic = + GNUNET_PEERINFO_iterate (peerinfo_handle, peer, + GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_SECONDS, 3), + &process_peerinfo, peerinfo_iterator); + + if ((about != NULL) && (about->pkey == NULL)) + { +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Newly added peer %s has NULL pkey!\n", GNUNET_i2s (peer)); +#endif + } + else if (about != NULL) + { + GNUNET_free (peerinfo_iterator); + } + } + else + { + about = + GNUNET_CONTAINER_multihashmap_get (extended_neighbors, + &peer->hashPubKey); + if ((GNUNET_CONTAINER_multihashmap_get (direct_neighbors, &peer->hashPubKey) + == NULL) && (about != NULL)) + { + sent = + GNUNET_CONTAINER_multihashmap_iterate (direct_neighbors, + &add_distant_all_direct_neighbors, + about); + if (stats != NULL) + GNUNET_STATISTICS_update (stats, + "# direct peers gossiped to new direct neighbors", + sent, GNUNET_NO); + } +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Distance (%d) greater than %d or already know about peer (%s), not re-adding!\n", + "dv", distance, DIRECT_NEIGHBOR_COST, GNUNET_i2s (peer)); +#endif + return; + } +} + +/** + * Method called whenever a given peer disconnects. + * + * @param cls closure + * @param peer peer identity this notification is about + */ +void +handle_core_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) +{ + struct DirectNeighbor *neighbor; + struct DistantNeighbor *referee; + struct FindDestinationContext fdc; + struct DisconnectContext disconnect_context; + struct PendingMessage *pending_pos; + +#if DEBUG_DV + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Receives core peer disconnect message!\n", "dv"); +#endif + + /* Check for disconnect from self message */ + if (0 == memcmp (&my_identity, peer, sizeof (struct GNUNET_PeerIdentity))) + return; + + neighbor = + GNUNET_CONTAINER_multihashmap_get (direct_neighbors, &peer->hashPubKey); + + if (neighbor == NULL) + { + return; + } + + pending_pos = core_pending_head; + while (NULL != pending_pos) + { + if (0 == + memcmp (&pending_pos->recipient, &neighbor->identity, + sizeof (struct GNUNET_PeerIdentity))) + { + GNUNET_CONTAINER_DLL_remove (core_pending_head, core_pending_tail, + pending_pos); + pending_pos = core_pending_head; + } + else + pending_pos = pending_pos->next; + } + + while (NULL != (referee = neighbor->referee_head)) + distant_neighbor_free (referee); + + fdc.dest = NULL; + fdc.tid = 0; + + GNUNET_CONTAINER_multihashmap_iterate (extended_neighbors, &find_distant_peer, + &fdc); + + if (fdc.dest != NULL) + { + disconnect_context.direct = neighbor; + disconnect_context.distant = fdc.dest; + GNUNET_CONTAINER_multihashmap_iterate (direct_neighbors, + &schedule_disconnect_messages, + &disconnect_context); + } + + GNUNET_assert (neighbor->referee_tail == NULL); + if (GNUNET_NO == + GNUNET_CONTAINER_multihashmap_remove (direct_neighbors, &peer->hashPubKey, + neighbor)) + { + GNUNET_break (0); + } + if ((neighbor->send_context != NULL) && + (neighbor->send_context->task != GNUNET_SCHEDULER_NO_TASK)) + GNUNET_SCHEDULER_cancel (neighbor->send_context->task); + GNUNET_free (neighbor); +} + + +/** + * Process dv requests. + * + * @param cls closure + * @param server the initialized server + * @param c configuration to use + */ +static void +run (void *cls, struct GNUNET_SERVER_Handle *server, + const struct GNUNET_CONFIGURATION_Handle *c) +{ + unsigned long long max_hosts; + + cfg = c; + + /* FIXME: Read from config, or calculate, or something other than this! */ + max_hosts = DEFAULT_DIRECT_CONNECTIONS; + max_table_size = DEFAULT_DV_SIZE; + fisheye_depth = DEFAULT_FISHEYE_DEPTH; + + if (GNUNET_CONFIGURATION_have_value (cfg, "dv", "max_direct_connections")) + GNUNET_assert (GNUNET_OK == + GNUNET_CONFIGURATION_get_value_number (cfg, "dv", + "max_direct_connections", + &max_hosts)); + + if (GNUNET_CONFIGURATION_have_value (cfg, "dv", "max_total_connections")) + GNUNET_assert (GNUNET_OK == + GNUNET_CONFIGURATION_get_value_number (cfg, "dv", + "max_total_connections", + &max_table_size)); + + + if (GNUNET_CONFIGURATION_have_value (cfg, "dv", "fisheye_depth")) + GNUNET_assert (GNUNET_OK == + GNUNET_CONFIGURATION_get_value_number (cfg, "dv", + "fisheye_depth", + &fisheye_depth)); + + neighbor_min_heap = + GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MIN); + neighbor_max_heap = + GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MAX); + + direct_neighbors = GNUNET_CONTAINER_multihashmap_create (max_hosts); + extended_neighbors = + GNUNET_CONTAINER_multihashmap_create (max_table_size * 3); + + GNUNET_SERVER_add_handlers (server, plugin_handlers); + coreAPI = GNUNET_CORE_connect (cfg, 1, NULL, /* FIXME: anything we want to pass around? */ + &core_init, &handle_core_connect, + &handle_core_disconnect, NULL, GNUNET_NO, NULL, + GNUNET_NO, core_handlers); + + if (coreAPI == NULL) + return; + + coreMST = GNUNET_SERVER_mst_create (&tokenized_message_handler, NULL); + + peerinfo_handle = GNUNET_PEERINFO_connect (cfg); + + if (peerinfo_handle == NULL) + { + GNUNET_CORE_disconnect (coreAPI); + return; + } + + /* Scheduled the task to clean up when shutdown is called */ + cleanup_task = + GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_FOREVER_REL, + &shutdown_task, NULL); +} + + +/** + * The main function for the dv service. + * + * @param argc number of arguments from the command line + * @param argv command line arguments + * @return 0 ok, 1 on error + */ +int +main (int argc, char *const *argv) +{ + return (GNUNET_OK == + GNUNET_SERVICE_run (argc, argv, "dv", GNUNET_SERVICE_OPTION_NONE, + &run, NULL)) ? 0 : 1; +} diff --git a/src/dv/plugin_transport_dv.c b/src/dv/plugin_transport_dv.c new file mode 100644 index 0000000..8ee49c5 --- /dev/null +++ b/src/dv/plugin_transport_dv.c @@ -0,0 +1,452 @@ +/* + This file is part of GNUnet + (C) 2002, 2003, 2004, 2005, 2006, 2007, 2008, 2009 Christian Grothoff (and other contributing authors) + + GNUnet is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published + by the Free Software Foundation; either version 3, or (at your + option) any later version. + + GNUnet is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with GNUnet; see the file COPYING. If not, write to the + Free Software Foundation, Inc., 59 Temple Place - Suite 330, + Boston, MA 02111-1307, USA. +*/ + +/** + * @file dv/plugin_transport_dv.c + * @brief DV transport service, takes incoming DV requests and deals with + * the DV service + * @author Nathan Evans + * @author Christian Grothoff + */ + +#include "platform.h" +#include "gnunet_protocols.h" +#include "gnunet_connection_lib.h" +#include "gnunet_server_lib.h" +#include "gnunet_service_lib.h" +#include "gnunet_statistics_service.h" +#include "gnunet_dv_service.h" +#include "gnunet_transport_service.h" +#include "gnunet_transport_plugin.h" +#include "dv.h" + +#define DEBUG_TEMPLATE GNUNET_EXTRA_LOGGING + +/** + * Encapsulation of all of the state of the plugin. + */ +struct Plugin; + + +/** + * Session handle for connections. + */ +struct Session +{ + + /** + * Stored in a linked list. + */ + struct Session *next; + + /** + * Pointer to the global plugin struct. + */ + struct Plugin *plugin; + + /** + * The client (used to identify this connection) + */ + /* void *client; */ + + /** + * Continuation function to call once the transmission buffer + * has again space available. NULL if there is no + * continuation to call. + */ + GNUNET_TRANSPORT_TransmitContinuation transmit_cont; + + /** + * Closure for transmit_cont. + */ + void *transmit_cont_cls; + + /** + * To whom are we talking to (set to our identity + * if we are still waiting for the welcome message) + */ + struct GNUNET_PeerIdentity sender; + + /** + * At what time did we reset last_received last? + */ + struct GNUNET_TIME_Absolute last_quota_update; + + /** + * How many bytes have we received since the "last_quota_update" + * timestamp? + */ + uint64_t last_received; + + /** + * Number of bytes per ms that this peer is allowed + * to send to us. + */ + uint32_t quota; + +}; + +/** + * Encapsulation of all of the state of the plugin. + */ +struct Plugin +{ + /** + * Our environment. + */ + struct GNUNET_TRANSPORT_PluginEnvironment *env; + + /** + * List of open sessions. + */ + struct Session *sessions; + + /** + * Our server. + */ + //struct GNUNET_SERVER_Handle *server; + + /* + * Handle to the running service. + */ + //struct GNUNET_SERVICE_Context *service; + + /** + * Copy of the handler array where the closures are + * set to this struct's instance. + */ + struct GNUNET_SERVER_MessageHandler *handlers; + + /** + * Handle to the DV service + */ + struct GNUNET_DV_Handle *dv_handle; + +}; + +/** + * Handler for messages received from the DV service. + */ +void +handle_dv_message_received (void *cls, struct GNUNET_PeerIdentity *sender, + char *msg, size_t msg_len, uint32_t distance, + char *sender_address, size_t sender_address_len) +{ + struct Plugin *plugin = cls; + +#if DEBUG_DV_MESSAGES + char *my_id; + + my_id = GNUNET_strdup (GNUNET_i2s (plugin->env->my_identity)); + GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "plugin_transport_dv", + _("%s Received message from %s of type %d, distance %u!\n"), + my_id, GNUNET_i2s (sender), + ntohs (((struct GNUNET_MessageHeader *) msg)->type), + distance); + if (sender_address_len == (2 * sizeof (struct GNUNET_PeerIdentity))) + { + GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, "plugin_transport_dv", + "Parsed sender address: %s:%s\n", + GNUNET_i2s ((struct GNUNET_PeerIdentity *) sender_address), + GNUNET_h2s (& + ((struct GNUNET_PeerIdentity *) + &sender_address[sizeof + (struct + GNUNET_PeerIdentity)])->hashPubKey)); + } + + GNUNET_free_non_null (my_id); +#endif + struct GNUNET_ATS_Information ats[1]; + + ats[0].type = htonl (GNUNET_ATS_QUALITY_NET_DISTANCE); + ats[0].value = htonl (distance); + + plugin->env->receive (plugin->env->cls, sender, + (struct GNUNET_MessageHeader *) msg, + (const struct GNUNET_ATS_Information *) &ats, 1, NULL, + sender_address, sender_address_len); + +} + + +/* Question: how does the transport service learn of a newly connected (gossipped about) + * DV peer? Should the plugin (here) create a HELLO for that peer and send it along, + * or should the DV service create a HELLO and send it to us via the other part? + */ + +/** + * Function that can be used by the transport service to transmit + * a message using the plugin. + * + * @param cls closure + * @param session the session used + * @param priority how important is the message + * @param msgbuf the message to transmit + * @param msgbuf_size number of bytes in 'msgbuf' + * @param timeout when should we time out + * @param cont continuation to call once the message has + * been transmitted (or if the transport is ready + * for the next transmission call; or if the + * peer disconnected...) + * @param cont_cls closure for cont + * @return number of bytes used (on the physical network, with overheads); + * -1 on hard errors (i.e. address invalid); 0 is a legal value + * and does NOT mean that the message was not transmitted (DV) + */ +static ssize_t +dv_plugin_send (void *cls, + struct Session *session, + const char *msgbuf, size_t msgbuf_size, unsigned int priority, + struct GNUNET_TIME_Relative timeout, + GNUNET_TRANSPORT_TransmitContinuation cont, void *cont_cls) +{ + int ret = -1; +#if 0 + struct Plugin *plugin = cls; + + ret = + GNUNET_DV_send (plugin->dv_handle, &session->sender, + msgbuf, msgbuf_size, priority, + timeout, addr, addrlen, cont, cont_cls); +#endif + return ret; +} + + + +/** + * Function that can be used to force the plugin to disconnect + * from the given peer and cancel all previous transmissions + * (and their continuations). + * + * @param cls closure + * @param target peer from which to disconnect + */ +static void +dv_plugin_disconnect (void *cls, const struct GNUNET_PeerIdentity *target) +{ + // struct Plugin *plugin = cls; + // TODO: Add message type to send to dv service to "disconnect" a peer +} + + +/** + * Convert the transports address to a nice, human-readable + * format. + * + * @param cls closure + * @param type name of the transport that generated the address + * @param addr one of the addresses of the host, NULL for the last address + * the specific address format depends on the transport + * @param addrlen length of the address + * @param numeric should (IP) addresses be displayed in numeric form? + * @param timeout after how long should we give up? + * @param asc function to call on each string + * @param asc_cls closure for asc + */ +static void +dv_plugin_address_pretty_printer (void *cls, const char *type, const void *addr, + size_t addrlen, int numeric, + struct GNUNET_TIME_Relative timeout, + GNUNET_TRANSPORT_AddressStringCallback asc, + void *asc_cls) +{ + char *dest_peer; + char *via_peer; + char *print_string; + char *addr_buf = (char *) addr; + + if (addrlen != sizeof (struct GNUNET_PeerIdentity) * 2) + { + asc (asc_cls, NULL); + } + else + { + dest_peer = + GNUNET_strdup (GNUNET_i2s ((struct GNUNET_PeerIdentity *) addr)); + via_peer = + GNUNET_strdup (GNUNET_i2s + ((struct GNUNET_PeerIdentity *) + &addr_buf[sizeof (struct GNUNET_PeerIdentity)])); + GNUNET_asprintf (&print_string, "DV Peer `%s' via peer`%s'", dest_peer, + via_peer); + asc (asc_cls, print_string); + asc (asc_cls, NULL); + GNUNET_free (via_peer); + GNUNET_free (dest_peer); + GNUNET_free (print_string); + } +} + +/** + * Convert the DV address to a pretty string. + * + * @param cls closure + * @param addr the (hopefully) DV address + * @param addrlen the length of the address + * + * @return string representing the DV address + */ +static const char * +address_to_string (void *cls, const void *addr, size_t addrlen) +{ + static char return_buffer[2 * 4 + 2]; // Two four character peer identity prefixes a ':' and '\0' + + struct GNUNET_CRYPTO_HashAsciiEncoded peer_hash; + struct GNUNET_CRYPTO_HashAsciiEncoded via_hash; + struct GNUNET_PeerIdentity *peer; + struct GNUNET_PeerIdentity *via; + char *addr_buf = (char *) addr; + + if (addrlen == (2 * sizeof (struct GNUNET_PeerIdentity))) + { + peer = (struct GNUNET_PeerIdentity *) addr_buf; + via = + (struct GNUNET_PeerIdentity *) + &addr_buf[sizeof (struct GNUNET_PeerIdentity)]; + + GNUNET_CRYPTO_hash_to_enc (&peer->hashPubKey, &peer_hash); + peer_hash.encoding[4] = '\0'; + GNUNET_CRYPTO_hash_to_enc (&via->hashPubKey, &via_hash); + via_hash.encoding[4] = '\0'; + GNUNET_snprintf (return_buffer, sizeof (return_buffer), "%s:%s", &peer_hash, + &via_hash); + } + else + return NULL; + + return return_buffer; +} + +/** + * Another peer has suggested an address for this peer and transport + * plugin. Check that this could be a valid address. This function + * is not expected to 'validate' the address in the sense of trying to + * connect to it but simply to see if the binary format is technically + * legal for establishing a connection to this peer (and make sure that + * the address really corresponds to our network connection/settings + * and not some potential man-in-the-middle). + * + * @param cls closure + * @param addr pointer to the address + * @param addrlen length of addr + * @return GNUNET_OK if this is a plausible address for this peer + * and transport, GNUNET_SYSERR if not + * + */ +static int +dv_plugin_check_address (void *cls, const void *addr, size_t addrlen) +{ + struct Plugin *plugin = cls; + + /* Verify that the first peer of this address matches our peer id! */ + if ((addrlen != (2 * sizeof (struct GNUNET_PeerIdentity))) || + (0 != + memcmp (addr, plugin->env->my_identity, + sizeof (struct GNUNET_PeerIdentity)))) + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "%s: Address not correct size or identity doesn't match ours!\n", + GNUNET_i2s (plugin->env->my_identity)); + if (addrlen == (2 * sizeof (struct GNUNET_PeerIdentity))) + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer in address is %s\n", + GNUNET_i2s (addr)); + } + return GNUNET_SYSERR; + } + + return GNUNET_OK; +} + + + +/** + * Create a new session to transmit data to the target + * This session will used to send data to this peer and the plugin will + * notify us by calling the env->session_end function + * + * @param cls the plugin + * @param target the neighbour id + * @param addr pointer to the address + * @param addrlen length of addr + * @return the session if the address is valid, NULL otherwise + */ +static struct Session * +dv_get_session (void *cls, + const struct GNUNET_HELLO_Address *address) +{ + return NULL; +} + + +/** + * Entry point for the plugin. + */ +void * +libgnunet_plugin_transport_dv_init (void *cls) +{ + struct GNUNET_TRANSPORT_PluginEnvironment *env = cls; + struct GNUNET_TRANSPORT_PluginFunctions *api; + struct Plugin *plugin; + + plugin = GNUNET_malloc (sizeof (struct Plugin)); + plugin->env = env; + + plugin->dv_handle = + GNUNET_DV_connect (env->cfg, &handle_dv_message_received, plugin); + + if (plugin->dv_handle == NULL) + { + GNUNET_free (plugin); + return NULL; + } + + api = GNUNET_malloc (sizeof (struct GNUNET_TRANSPORT_PluginFunctions)); + api->cls = plugin; + api->send = &dv_plugin_send; + api->disconnect = &dv_plugin_disconnect; + api->address_pretty_printer = &dv_plugin_address_pretty_printer; + api->check_address = &dv_plugin_check_address; + api->address_to_string = &address_to_string; + api->get_session = dv_get_session; + return api; +} + + +/** + * Exit point from the plugin. + */ +void * +libgnunet_plugin_transport_dv_done (void *cls) +{ + struct GNUNET_TRANSPORT_PluginFunctions *api = cls; + struct Plugin *plugin = api->cls; + + if (plugin->dv_handle != NULL) + GNUNET_DV_disconnect (plugin->dv_handle); + + GNUNET_free (plugin); + GNUNET_free (api); + return NULL; +} + +/* end of plugin_transport_dv.c */ diff --git a/src/dv/test_transport_api_dv.c b/src/dv/test_transport_api_dv.c new file mode 100644 index 0000000..386ea5f --- /dev/null +++ b/src/dv/test_transport_api_dv.c @@ -0,0 +1,1247 @@ +/* + This file is part of GNUnet. + (C) 2009 Christian Grothoff (and other contributing authors) + + GNUnet is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published + by the Free Software Foundation; either version 3, or (at your + option) any later version. + + GNUnet is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with GNUnet; see the file COPYING. If not, write to the + Free Software Foundation, Inc., 59 Temple Place - Suite 330, + Boston, MA 02111-1307, USA. +*/ +/** + * @file dv/test_transport_api_dv.c + * @brief base testcase for testing distance vector transport + */ +#include "platform.h" +#include "gnunet_testing_lib.h" +#include "gnunet_core_service.h" + +#define VERBOSE 1 + +#define TEST_ALL GNUNET_NO + +/** + * How long until we fail the whole testcase? + */ +#define TEST_TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 600) + +/** + * How long until we give up on starting the peers? + */ +#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 500) + +#define DEFAULT_NUM_PEERS 4 + +#define DEFAULT_ADDITIONAL_MESSAGES 2 + +#define MAX_OUTSTANDING_CONNECTIONS 100 + +static float fail_percentage = 0.00; + +static int ok; + +static unsigned long long num_additional_messages; + +static unsigned long long num_peers; + +static unsigned int total_connections; + +static unsigned int failed_connections; + +static unsigned int total_server_connections; + +static unsigned int total_messages_received; + +static unsigned int total_other_expected_messages; + +static unsigned int temp_total_other_messages; + +static unsigned int total_other_messages; + +static unsigned int expected_messages; + +static unsigned int expected_connections; + +static unsigned long long peers_left; + +static struct GNUNET_TESTING_PeerGroup *pg; + +const struct GNUNET_CONFIGURATION_Handle *main_cfg; + +static GNUNET_SCHEDULER_TaskIdentifier die_task; + +static char *dotOutFileName = "topology.dot"; + +static FILE *dotOutFile; + +static char *blacklist_transports; + +static int transmit_ready_scheduled; + +static int transmit_ready_failed; + +static int transmit_ready_called; + +static enum GNUNET_TESTING_Topology topology; + +static enum GNUNET_TESTING_Topology blacklist_topology = GNUNET_TESTING_TOPOLOGY_NONE; /* Don't do any blacklisting */ + +static enum GNUNET_TESTING_Topology connection_topology = GNUNET_TESTING_TOPOLOGY_NONE; /* NONE actually means connect all allowed peers */ + +static enum GNUNET_TESTING_TopologyOption connect_topology_option = + GNUNET_TESTING_TOPOLOGY_OPTION_ALL; + +static double connect_topology_option_modifier = 0.0; + +static char *test_directory; + +struct GNUNET_CONTAINER_MultiHashMap *peer_daemon_hash; + +#define MTYPE 12345 + +GNUNET_NETWORK_STRUCT_BEGIN + +struct GNUNET_TestMessage +{ + /** + * Header of the message + */ + struct GNUNET_MessageHeader header; + + /** + * Unique identifier for this message. + */ + uint32_t uid; +}; +GNUNET_NETWORK_STRUCT_END + +struct PeerContext +{ + /* This is a linked list */ + struct PeerContext *next; + + /** + * Handle to the daemon + */ + struct GNUNET_TESTING_Daemon *daemon; + + /* Handle to the peer core */ + struct GNUNET_CORE_Handle *peer_handle; +}; + +static struct PeerContext *all_peers; + +struct TestMessageContext +{ + /* This is a linked list */ + struct TestMessageContext *next; + + /* Handle to the sending peer core */ + struct GNUNET_CORE_Handle *peer1handle; + + /* Handle to the receiving peer core */ + struct GNUNET_CORE_Handle *peer2handle; + + /* Handle to the sending peer daemon */ + struct GNUNET_TESTING_Daemon *peer1; + + /* Handle to the receiving peer daemon */ + struct GNUNET_TESTING_Daemon *peer2; + + /* Identifier for this message, so we don't disconnect other peers! */ + uint32_t uid; + + /* Task for disconnecting cores, allow task to be cancelled on shutdown */ + GNUNET_SCHEDULER_TaskIdentifier disconnect_task; +}; + +static struct TestMessageContext *test_messages; + +static struct TestMessageContext *other_test_messages; + +/** + * Check whether peers successfully shut down. + */ +void +shutdown_callback (void *cls, const char *emsg) +{ + if (emsg != NULL) + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Shutdown of peers failed!\n"); +#endif + if (ok == 0) + ok = 666; + } + else + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All peers successfully shut down!\n"); +#endif + } +} + +static void +finish_testing (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + GNUNET_assert (pg != NULL); + struct PeerContext *peer_pos; + struct PeerContext *free_peer_pos; + struct TestMessageContext *pos; + struct TestMessageContext *free_pos; + + die_task = GNUNET_SCHEDULER_NO_TASK; +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Called finish testing, stopping daemons.\n"); +#endif + peer_pos = all_peers; + while (peer_pos != NULL) + { + if (peer_pos->peer_handle != NULL) + GNUNET_CORE_disconnect (peer_pos->peer_handle); + free_peer_pos = peer_pos; + peer_pos = peer_pos->next; + GNUNET_free (free_peer_pos); + } + all_peers = NULL; + + pos = test_messages; + while (pos != NULL) + { + if (pos->peer1handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer1handle); + pos->peer1handle = NULL; + } + if (pos->peer2handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer2handle); + pos->peer2handle = NULL; + } + free_pos = pos; + pos = pos->next; + if (free_pos->disconnect_task != GNUNET_SCHEDULER_NO_TASK) + { + GNUNET_SCHEDULER_cancel (free_pos->disconnect_task); + } + GNUNET_free (free_pos); + } + + pos = other_test_messages; + while (pos != NULL) + { + if (pos->peer1handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer1handle); + pos->peer1handle = NULL; + } + if (pos->peer2handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer2handle); + pos->peer2handle = NULL; + } + free_pos = pos; + pos = pos->next; + if (free_pos->disconnect_task != GNUNET_SCHEDULER_NO_TASK) + { + GNUNET_SCHEDULER_cancel (free_pos->disconnect_task); + } + GNUNET_free (free_pos); + } +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "transmit_ready's scheduled %d, failed %d, transmit_ready's called %d\n", + transmit_ready_scheduled, transmit_ready_failed, + transmit_ready_called); +#endif + +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Calling daemons_stop\n"); +#endif + GNUNET_TESTING_daemons_stop (pg, TIMEOUT, &shutdown_callback, NULL); +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "daemons_stop finished\n"); +#endif + if (dotOutFile != NULL) + { + FPRINTF (dotOutFile, "%s", "}"); + FCLOSE (dotOutFile); + } + + ok = 0; +} + + +static void +disconnect_cores (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + struct TestMessageContext *pos = cls; + + /* Disconnect from the respective cores */ +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from peer 1 `%4s'\n", + GNUNET_i2s (&pos->peer1->id)); +#endif + if (pos->peer1handle != NULL) + GNUNET_CORE_disconnect (pos->peer1handle); +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Disconnecting from peer 2 `%4s'\n", + GNUNET_i2s (&pos->peer2->id)); +#endif + if (pos->peer2handle != NULL) + GNUNET_CORE_disconnect (pos->peer2handle); + /* Set handles to NULL so test case can be ended properly */ + pos->peer1handle = NULL; + pos->peer2handle = NULL; + pos->disconnect_task = GNUNET_SCHEDULER_NO_TASK; + /* Decrement total connections so new can be established */ + total_server_connections -= 2; +} + +static void +end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + char *msg = cls; + struct TestMessageContext *pos; + struct TestMessageContext *free_pos; + struct PeerContext *peer_pos; + struct PeerContext *free_peer_pos; + + die_task = GNUNET_SCHEDULER_NO_TASK; + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "End badly was called (%s)... stopping daemons.\n", msg); + + peer_pos = all_peers; + while (peer_pos != NULL) + { + if (peer_pos->peer_handle != NULL) + GNUNET_CORE_disconnect (peer_pos->peer_handle); + free_peer_pos = peer_pos; + peer_pos = peer_pos->next; + GNUNET_free (free_peer_pos); + } + all_peers = NULL; + + pos = test_messages; + while (pos != NULL) + { + if (pos->peer1handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer1handle); + pos->peer1handle = NULL; + } + if (pos->peer2handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer2handle); + pos->peer2handle = NULL; + } + free_pos = pos; + pos = pos->next; + GNUNET_free (free_pos); + } + + pos = other_test_messages; + while (pos != NULL) + { + if (pos->peer1handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer1handle); + pos->peer1handle = NULL; + } + if (pos->peer2handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer2handle); + pos->peer2handle = NULL; + } + free_pos = pos; + pos = pos->next; + if (free_pos->disconnect_task != GNUNET_SCHEDULER_NO_TASK) + { + GNUNET_SCHEDULER_cancel (free_pos->disconnect_task); + } + GNUNET_free (free_pos); + } + + if (pg != NULL) + { + GNUNET_TESTING_daemons_stop (pg, TIMEOUT, &shutdown_callback, NULL); + ok = 7331; /* Opposite of leet */ + } + else + ok = 401; /* Never got peers started */ + + if (dotOutFile != NULL) + { + FPRINTF (dotOutFile, "%s", "}"); + FCLOSE (dotOutFile); + } +} + +static void +send_other_messages (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc); + +/** + * Get distance information from 'atsi'. + * + * @param atsi performance data + * @return connected transport distance + */ +static uint32_t +get_atsi_distance (const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + unsigned int i; + + for (i = 0; i < atsi_count; i++) + { + if (ntohl (atsi->type) == GNUNET_ATS_QUALITY_NET_DISTANCE) + return ntohl (atsi->value); + } + + GNUNET_break (0); + /* FIXME: we do not have distance data? Assume direct neighbor. */ + return 1; +} + + +static int +process_mtype (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_MessageHeader *message, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + struct TestMessageContext *pos = cls; + struct GNUNET_TestMessage *msg = (struct GNUNET_TestMessage *) message; + +#if VERBOSE + uint32_t distance; +#endif + if (pos->uid != ntohl (msg->uid)) + return GNUNET_OK; + +#if VERBOSE + distance = get_atsi_distance (atsi, atsi_count); +#endif + GNUNET_assert (0 == + memcmp (peer, &pos->peer1->id, + sizeof (struct GNUNET_PeerIdentity))); + if (total_other_expected_messages == 0) + { + total_messages_received++; +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Received message from `%4s', type %d, uid %u, distance %u.\n", + GNUNET_i2s (peer), ntohs (message->type), ntohl (msg->uid), + distance); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Total messages received %d, expected %d.\n", + total_messages_received, expected_messages); +#endif + } + else + { + total_other_messages++; +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Received message from `%4s', type %d, uid %u, distance %u.\n", + GNUNET_i2s (peer), ntohs (message->type), ntohl (msg->uid), + distance); + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Total OTHER messages received %d, expected %d.\n", + total_other_messages, total_other_expected_messages); +#endif + } + + if ((total_messages_received == expected_messages) && + (total_other_messages == 0)) + { + GNUNET_SCHEDULER_cancel (die_task); +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Scheduling timeout from DV connections.\n"); +#endif + die_task = + GNUNET_SCHEDULER_add_delayed (TEST_TIMEOUT, &end_badly, + "waiting for DV peers to connect!"); + } + else if ((total_other_expected_messages > 0) && + (total_other_messages == total_other_expected_messages)) + { + GNUNET_SCHEDULER_cancel (die_task); + die_task = GNUNET_SCHEDULER_add_now (&finish_testing, NULL); + } + else + { + pos->disconnect_task = GNUNET_SCHEDULER_add_now (&disconnect_cores, pos); + } + + return GNUNET_OK; +} + +static size_t +transmit_ready (void *cls, size_t size, void *buf) +{ + struct GNUNET_TestMessage *m; + struct TestMessageContext *pos = cls; + + GNUNET_assert (buf != NULL); + m = (struct GNUNET_TestMessage *) buf; + m->header.type = htons (MTYPE); + m->header.size = htons (sizeof (struct GNUNET_TestMessage)); + m->uid = htonl (pos->uid); + transmit_ready_called++; +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "transmit ready for peer %s\ntransmit_ready's scheduled %d, transmit_ready's called %d\n", + GNUNET_i2s (&pos->peer1->id), transmit_ready_scheduled, + transmit_ready_called); +#endif + return sizeof (struct GNUNET_TestMessage); +} + + +static struct GNUNET_CORE_MessageHandler no_handlers[] = { + {NULL, 0, 0} +}; + +static struct GNUNET_CORE_MessageHandler handlers[] = { + {&process_mtype, MTYPE, sizeof (struct GNUNET_TestMessage)}, + {NULL, 0, 0} +}; + +/** + * Notify of all peer1's peers, once peer 2 is found, schedule connect + * to peer two for message send. + * + * @param cls closure + * @param peer peer identity this notification is about + * @param atsi performance data for the connection + * @param atsi_count number of ATS information included + */ +static void +connect_notify_peer2 (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + struct TestMessageContext *pos = cls; + + if (0 == memcmp (&pos->peer1->id, peer, sizeof (struct GNUNET_PeerIdentity))) + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Core connection from `%s' to `%4s' verfied, sending message!\n", + GNUNET_i2s (&pos->peer2->id), GNUNET_h2s (&peer->hashPubKey)); +#endif + if (NULL == + GNUNET_CORE_notify_transmit_ready (pos->peer1handle, GNUNET_YES, 0, + TIMEOUT, &pos->peer2->id, + sizeof (struct GNUNET_TestMessage), + &transmit_ready, pos)) + { + /* This probably shouldn't happen, but it does (timing issue?) */ + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "RECEIVED NULL when asking core (1) for transmission to peer `%4s'\n", + GNUNET_i2s (&pos->peer2->id)); + transmit_ready_failed++; + total_other_expected_messages--; + } + else + { + transmit_ready_scheduled++; + } + } +} + +static void +init_notify_peer2 (void *cls, struct GNUNET_CORE_Handle *server, + const struct GNUNET_PeerIdentity *my_identity) +{ +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Core connection to `%4s' established, awaiting connections.\n", + GNUNET_i2s (my_identity)); +#endif + total_server_connections++; +} + +/** + * Notify of all peer1's peers, once peer 2 is found, schedule connect + * to peer two for message send. + * + * @param cls closure + * @param peer peer identity this notification is about + * @param atsi performance data for the connection + * @param atsi_count number of atsi datums + */ +static void +connect_notify_peer1 (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + struct TestMessageContext *pos = cls; + + if (0 == memcmp (&pos->peer2->id, peer, sizeof (struct GNUNET_PeerIdentity))) + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Core connection from `%s' to `%4s' verified.\n", + GNUNET_i2s (&pos->peer1->id), GNUNET_h2s (&peer->hashPubKey)); +#endif + /* + * Connect to the receiving peer + */ + pos->peer2handle = + GNUNET_CORE_connect (pos->peer2->cfg, 1, pos, &init_notify_peer2, + &connect_notify_peer2, NULL, NULL, GNUNET_YES, + NULL, GNUNET_YES, handlers); + } +} + +static void +init_notify_peer1 (void *cls, struct GNUNET_CORE_Handle *server, + const struct GNUNET_PeerIdentity *my_identity) +{ + total_server_connections++; +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Core connection to `%4s' established, awaiting connections...\n", + GNUNET_i2s (my_identity)); +#endif +} + + +static void +send_test_messages (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + struct TestMessageContext *pos = cls; + + if (((tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) || (cls == NULL)) + return; + + if (die_task == GNUNET_SCHEDULER_NO_TASK) + { + die_task = + GNUNET_SCHEDULER_add_delayed (TEST_TIMEOUT, &end_badly, + "from create topology (timeout)"); + } + + if (total_server_connections >= MAX_OUTSTANDING_CONNECTIONS) + { + GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_SECONDS, 1), + &send_test_messages, pos); + return; /* Otherwise we'll double schedule messages here! */ + } +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Attempting to send test message from %s to %s\n", + pos->peer1->shortname, pos->peer2->shortname); +#endif + /* + * Connect to the sending peer + */ + pos->peer1handle = + GNUNET_CORE_connect (pos->peer1->cfg, 1, pos, &init_notify_peer1, + &connect_notify_peer1, NULL, NULL, GNUNET_NO, NULL, + GNUNET_NO, no_handlers); + + GNUNET_assert (pos->peer1handle != NULL); + + if (total_server_connections < MAX_OUTSTANDING_CONNECTIONS) + { + GNUNET_SCHEDULER_add_now (&send_test_messages, pos->next); + } + else + { + GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_SECONDS, 1), + &send_test_messages, pos->next); + } +} + +static void +send_other_messages (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +{ + struct TestMessageContext *pos; + struct TestMessageContext *free_pos; + struct PeerContext *peer_pos; + +#if TEST_ALL + struct PeerContext *inner_peer_pos; + struct TestMessageContext *temp_context; +#endif + peer_pos = all_peers; + while (peer_pos != NULL) + { + if (peer_pos->peer_handle != NULL) + { + GNUNET_CORE_disconnect (peer_pos->peer_handle); + peer_pos->peer_handle = NULL; + } +#if TEST_ALL + inner_peer_pos = all_peers; + while (inner_peer_pos != NULL) + { + if (inner_peer_pos != peer_pos) + { + temp_total_other_messages++; + temp_context = GNUNET_malloc (sizeof (struct TestMessageContext)); + temp_context->peer1 = peer_pos->daemon; + temp_context->peer2 = inner_peer_pos->daemon; + temp_context->next = other_test_messages; + temp_context->uid = total_connections + temp_total_other_messages; + temp_context->disconnect_task = GNUNET_SCHEDULER_NO_TASK; + other_test_messages = temp_context; + } + inner_peer_pos = inner_peer_pos->next; + } +#endif + peer_pos = peer_pos->next; + } + all_peers = NULL; + + pos = test_messages; + while (pos != NULL) + { + if (pos->peer1handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer1handle); + pos->peer1handle = NULL; + } + if (pos->peer2handle != NULL) + { + GNUNET_CORE_disconnect (pos->peer2handle); + pos->peer2handle = NULL; + } + free_pos = pos; + pos = pos->next; + if (free_pos->disconnect_task != GNUNET_SCHEDULER_NO_TASK) + { + GNUNET_SCHEDULER_cancel (free_pos->disconnect_task); + } + GNUNET_free (free_pos); + } + test_messages = NULL; + + total_other_expected_messages = temp_total_other_messages; + if (total_other_expected_messages == 0) + { + GNUNET_SCHEDULER_add_now (&end_badly, + "send_other_messages had 0 messages to send, no DV connections made!"); + } +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Preparing to send %d other test messages\n", + total_other_expected_messages); +#endif + + GNUNET_SCHEDULER_add_now (&send_test_messages, other_test_messages); + if (GNUNET_SCHEDULER_NO_TASK != die_task) + GNUNET_SCHEDULER_cancel (die_task); + die_task = + GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_SECONDS, 250), &end_badly, + "from send_other_messages"); +} + +static void +topology_callback (void *cls, const struct GNUNET_PeerIdentity *first, + const struct GNUNET_PeerIdentity *second, uint32_t distance, + const struct GNUNET_CONFIGURATION_Handle *first_cfg, + const struct GNUNET_CONFIGURATION_Handle *second_cfg, + struct GNUNET_TESTING_Daemon *first_daemon, + struct GNUNET_TESTING_Daemon *second_daemon, + const char *emsg) +{ + struct TestMessageContext *temp_context; + + if (emsg == NULL) + { + total_connections++; +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "connected peer %s to peer %s, distance %u\n", + first_daemon->shortname, second_daemon->shortname, distance); +#endif + temp_context = GNUNET_malloc (sizeof (struct TestMessageContext)); + temp_context->peer1 = first_daemon; + temp_context->peer2 = second_daemon; + temp_context->next = test_messages; + temp_context->uid = total_connections; + temp_context->disconnect_task = GNUNET_SCHEDULER_NO_TASK; + test_messages = temp_context; + expected_messages++; + } +#if VERBOSE + else + { + failed_connections++; + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Failed to connect peer %s to peer %s with error :\n%s\n", + first_daemon->shortname, second_daemon->shortname, emsg); + } +#endif + + if (total_connections == expected_connections) + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Created %u total connections, which is our target number! Calling send messages.\n", + total_connections); +#endif + if (GNUNET_SCHEDULER_NO_TASK != die_task) + GNUNET_SCHEDULER_cancel (die_task); + die_task = GNUNET_SCHEDULER_NO_TASK; + GNUNET_SCHEDULER_add_now (&send_test_messages, test_messages); + } + else if (total_connections + failed_connections == expected_connections) + { + if (failed_connections < + (unsigned int) (fail_percentage * total_connections)) + { + GNUNET_SCHEDULER_cancel (die_task); + die_task = GNUNET_SCHEDULER_NO_TASK; + /* FIXME: ret value!? */ GNUNET_SCHEDULER_add_now (&send_test_messages, + test_messages); + } + else + { + if (die_task != GNUNET_SCHEDULER_NO_TASK) + GNUNET_SCHEDULER_cancel (die_task); + die_task = + GNUNET_SCHEDULER_add_now (&end_badly, + "from topology_callback (too many failed connections)"); + } + } + else + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Have %d total connections, %d failed connections, Want %d (at least %d)\n", + total_connections, failed_connections, expected_connections, + expected_connections - + (unsigned int) (fail_percentage * expected_connections)); +#endif + } +} + + +/** + * Method called whenever a given peer connects. + * + * @param cls closure + * @param peer peer identity this notification is about + * @param atsi performance data about this peer's connection + * @param atsi_count number of atsi datums + * + */ +static void +all_connect_handler (void *cls, const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_ATS_Information *atsi, + unsigned int atsi_count) +{ + struct GNUNET_TESTING_Daemon *d = cls; + struct GNUNET_TESTING_Daemon *second_daemon; + char *second_shortname; + +#if !TEST_ALL + struct TestMessageContext *temp_context; +#endif + uint32_t distance; + + if (0 == memcmp (&d->id, peer, sizeof (struct GNUNET_PeerIdentity))) + return; + second_shortname = GNUNET_strdup (GNUNET_i2s (peer)); + distance = get_atsi_distance (atsi, atsi_count); + +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "connected peer %s to peer %s, distance %u\n", d->shortname, + second_shortname, distance); +#endif + + second_daemon = + GNUNET_CONTAINER_multihashmap_get (peer_daemon_hash, &peer->hashPubKey); + + if (second_daemon == NULL) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Couldn't find second peer!\n"); + GNUNET_free (second_shortname); + return; + } +#if !TEST_ALL + if (distance > 1) + { + temp_total_other_messages++; + temp_context = GNUNET_malloc (sizeof (struct TestMessageContext)); + temp_context->peer1 = d; + temp_context->peer2 = second_daemon; + temp_context->next = other_test_messages; + temp_context->uid = total_connections + temp_total_other_messages; + temp_context->disconnect_task = GNUNET_SCHEDULER_NO_TASK; + other_test_messages = temp_context; + } +#endif + + if (dotOutFile != NULL) + { + if (distance == 1) + FPRINTF (dotOutFile, "\tn%s -- n%s;\n", d->shortname, second_shortname); + else if (distance == 2) + FPRINTF (dotOutFile, "\tn%s -- n%s [color=blue];\n", d->shortname, + second_shortname); + else if (distance == 3) + FPRINTF (dotOutFile, "\tn%s -- n%s [color=red];\n", d->shortname, + second_shortname); + else if (distance == 4) + FPRINTF (dotOutFile, "\tn%s -- n%s [color=green];\n", d->shortname, + second_shortname); + else + FPRINTF (dotOutFile, "\tn%s -- n%s [color=brown];\n", d->shortname, + second_shortname); + } + GNUNET_free (second_shortname); + + if (temp_total_other_messages == num_additional_messages) + { + /* FIXME: ret value!? */ GNUNET_SCHEDULER_add_now (&send_other_messages, + NULL); + } +} + +static void +peers_started_callback (void *cls, const struct GNUNET_PeerIdentity *id, + const struct GNUNET_CONFIGURATION_Handle *cfg, + struct GNUNET_TESTING_Daemon *d, const char *emsg) +{ + struct PeerContext *new_peer; + + if (emsg != NULL) + { + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Failed to start daemon with error: `%s'\n", emsg); + return; + } + GNUNET_assert (id != NULL); +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Started daemon %llu out of %llu\n", + (num_peers - peers_left) + 1, num_peers); +#endif + GNUNET_assert (GNUNET_SYSERR != + GNUNET_CONTAINER_multihashmap_put (peer_daemon_hash, + &id->hashPubKey, d, + GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); + + new_peer = GNUNET_malloc (sizeof (struct PeerContext)); + new_peer->peer_handle = + GNUNET_CORE_connect (cfg, 1, d, NULL, &all_connect_handler, NULL, NULL, + GNUNET_NO, NULL, GNUNET_NO, no_handlers); + new_peer->daemon = d; + new_peer->next = all_peers; + all_peers = new_peer; + peers_left--; + + if (peers_left == 0) + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "All %d daemons started, now creating topology!\n", num_peers); +#endif + GNUNET_SCHEDULER_cancel (die_task); + die_task = GNUNET_SCHEDULER_NO_TASK; + expected_connections = -1; + if ((pg != NULL) && (peers_left == 0)) + { + expected_connections = + GNUNET_TESTING_connect_topology (pg, connection_topology, + connect_topology_option, + connect_topology_option_modifier, + TIMEOUT, 12, NULL, NULL); +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Have %d expected connections\n", + expected_connections); +#endif + } + + if (expected_connections == GNUNET_SYSERR) + { + die_task = + GNUNET_SCHEDULER_add_now (&end_badly, + "from connect topology (bad return)"); + } + else + { + /* Set up task in case topology creation doesn't finish + * within a reasonable amount of time */ + die_task = + GNUNET_SCHEDULER_add_delayed (TEST_TIMEOUT, &end_badly, + "from connect topology (timeout)"); + } + ok = 0; + } +} + +/** + * Callback indicating that the hostkey was created for a peer. + * + * @param cls NULL + * @param id the peer identity + * @param d the daemon handle (pretty useless at this point, remove?) + * @param emsg non-null on failure + */ +static void +hostkey_callback (void *cls, const struct GNUNET_PeerIdentity *id, + struct GNUNET_TESTING_Daemon *d, const char *emsg) +{ + if (emsg != NULL) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Hostkey callback received error: %s\n", emsg); + } + +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Hostkey created for peer `%s'\n", + GNUNET_i2s (id)); +#endif + peers_left--; + if (peers_left == 0) + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "All %d hostkeys created, now creating topology!\n", num_peers); +#endif + if (GNUNET_SCHEDULER_NO_TASK != die_task) + { + GNUNET_SCHEDULER_cancel (die_task); + die_task = GNUNET_SCHEDULER_NO_TASK; + } + /* create topology */ + peers_left = num_peers; /* Reset counter */ + if (GNUNET_TESTING_create_topology + (pg, topology, blacklist_topology, + blacklist_transports) != GNUNET_SYSERR) + { +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Topology set up, now starting peers!\n"); +#endif + GNUNET_TESTING_daemons_continue_startup (pg); + /* Set up task in case topology creation doesn't finish + * within a reasonable amount of time */ + die_task = + GNUNET_SCHEDULER_add_delayed (TEST_TIMEOUT, &end_badly, + "from continue startup (timeout)"); + } + else + { + die_task = + GNUNET_SCHEDULER_add_now (&end_badly, + "from create topology (bad return)"); + } + ok = 0; + } +} + +static void +run (void *cls, char *const *args, const char *cfgfile, + const struct GNUNET_CONFIGURATION_Handle *cfg) +{ + char *topology_str; + char *connect_topology_str; + char *blacklist_topology_str; + char *connect_topology_option_str; + char *connect_topology_option_modifier_string; + + ok = 1; + + dotOutFile = fopen (dotOutFileName, "w"); + if (dotOutFile != NULL) + { + FPRINTF (dotOutFile, "%s", "strict graph G {\n"); + } + +#if VERBOSE + GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, + "Starting daemons based on config file %s\n", cfgfile); +#endif + + if (GNUNET_YES != + GNUNET_CONFIGURATION_get_value_string (cfg, "paths", "servicehome", + &test_directory)) + { + ok = 404; + return; + } + + if ((GNUNET_YES == + GNUNET_CONFIGURATION_get_value_string (cfg, "testing", "topology", + &topology_str)) && + (GNUNET_NO == GNUNET_TESTING_topology_get (&topology, topology_str))) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Invalid topology `%s' given for section %s option %s\n", + topology_str, "TESTING", "TOPOLOGY"); + topology = GNUNET_TESTING_TOPOLOGY_CLIQUE; /* Defaults to NONE, so set better default here */ + } + + if ((GNUNET_YES == + GNUNET_CONFIGURATION_get_value_string (cfg, "testing", + "connect_topology", + &connect_topology_str)) && + (GNUNET_NO == + GNUNET_TESTING_topology_get (&connection_topology, + connect_topology_str))) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Invalid connect topology `%s' given for section %s option %s\n", + connect_topology_str, "TESTING", "CONNECT_TOPOLOGY"); + } + GNUNET_free_non_null (connect_topology_str); + if ((GNUNET_YES == + GNUNET_CONFIGURATION_get_value_string (cfg, "testing", + "connect_topology_option", + &connect_topology_option_str)) && + (GNUNET_NO == + GNUNET_TESTING_topology_option_get (&connect_topology_option, + connect_topology_option_str))) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Invalid connect topology option `%s' given for section %s option %s\n", + connect_topology_option_str, "TESTING", + "CONNECT_TOPOLOGY_OPTION"); + connect_topology_option = GNUNET_TESTING_TOPOLOGY_OPTION_ALL; /* Defaults to NONE, set to ALL */ + } + GNUNET_free_non_null (connect_topology_option_str); + if (GNUNET_YES == + GNUNET_CONFIGURATION_get_value_string (cfg, "testing", + "connect_topology_option_modifier", + &connect_topology_option_modifier_string)) + { + if (sscanf + (connect_topology_option_modifier_string, "%lf", + &connect_topology_option_modifier) != 1) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + _ + ("Invalid value `%s' for option `%s' in section `%s': expected float\n"), + connect_topology_option_modifier_string, + "connect_topology_option_modifier", "TESTING"); + } + GNUNET_free (connect_topology_option_modifier_string); + } + + if (GNUNET_YES != + GNUNET_CONFIGURATION_get_value_string (cfg, "testing", + "blacklist_transports", + &blacklist_transports)) + blacklist_transports = NULL; + + if ((GNUNET_YES == + GNUNET_CONFIGURATION_get_value_string (cfg, "testing", + "blacklist_topology", + &blacklist_topology_str)) && + (GNUNET_NO == + GNUNET_TESTING_topology_get (&blacklist_topology, + blacklist_topology_str))) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Invalid topology `%s' given for section %s option %s\n", + topology_str, "TESTING", "BLACKLIST_TOPOLOGY"); + } + GNUNET_free_non_null (topology_str); + GNUNET_free_non_null (blacklist_topology_str); + if (GNUNET_SYSERR == + GNUNET_CONFIGURATION_get_value_number (cfg, "testing", "num_peers", + &num_peers)) + num_peers = DEFAULT_NUM_PEERS; + + if (GNUNET_SYSERR == + GNUNET_CONFIGURATION_get_value_number (cfg, "testing", + "additional_messages", + &num_additional_messages)) + num_additional_messages = DEFAULT_ADDITIONAL_MESSAGES; + + main_cfg = cfg; + + GNUNET_assert (num_peers > 0 && num_peers < (unsigned int) -1); + peers_left = num_peers; + + /* Set up a task to end testing if peer start fails */ + die_task = + GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_MINUTES, 5), &end_badly, + "didn't start all daemons in reasonable amount of time!!!"); + + peer_daemon_hash = GNUNET_CONTAINER_multihashmap_create (peers_left); + pg = GNUNET_TESTING_daemons_start (cfg, peers_left, /* Total number of peers */ + peers_left, /* Number of outstanding connections */ + peers_left, /* Number of parallel ssh connections, or peers being started at once */ + TIMEOUT, &hostkey_callback, NULL, + &peers_started_callback, NULL, + &topology_callback, NULL, NULL); + +} + +static int +check () +{ + int ret; + + char *const argv[] = { "test-transport-dv", + "-c", + "test_transport_dv_data.conf", +#if VERBOSE + "-L", "DEBUG", +#endif + NULL + }; + struct GNUNET_GETOPT_CommandLineOption options[] = { + GNUNET_GETOPT_OPTION_END + }; + ret = + GNUNET_PROGRAM_run ((sizeof (argv) / sizeof (char *)) - 1, argv, + "test-transport-dv", "nohelp", options, &run, &ok); + if (ret != GNUNET_OK) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "`test-transport-dv': Failed with error code %d\n", ret); + } + return ok; +} + +int +main (int argc, char *argv[]) +{ + int ret; + + GNUNET_log_setup ("test-transport-dv", +#if VERBOSE + "DEBUG", +#else + "WARNING", +#endif + NULL); + ret = check (); + /** + * Need to remove base directory, subdirectories taken care + * of by the testing framework. + */ + if (GNUNET_DISK_directory_remove (test_directory) != GNUNET_OK) + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + "Failed to remove testing directory %s\n", test_directory); + } + return ret; +} + +/* end of test_transport_api_dv.c */ diff --git a/src/dv/test_transport_dv_data.conf b/src/dv/test_transport_dv_data.conf new file mode 100644 index 0000000..80eb873 --- /dev/null +++ b/src/dv/test_transport_dv_data.conf @@ -0,0 +1,79 @@ +[PATHS] +SERVICEHOME = /tmp/test-gnunet-dv-testing/ +DEFAULTCONFIG = test_transport_dv_data.conf + +[resolver] +PORT = 2564 + +[transport] +DEBUG = YES +PORT = 2565 +PLUGINS = tcp dv +BLACKLIST_FILE = $SERVICEHOME/blacklist +BINARY = gnunet-service-transport +USE_LOCALADDR = NO + +[arm] +PORT = 2566 +DEFAULTSERVICES = + +[statistics] +PORT = 2567 + +[transport-tcp] +PORT = 2568 +BINDTO = 127.0.0.1 + +[transport-udp] +PORT = 2568 + +[peerinfo] +PORT = 2569 + +[core] +PORT = 2570 + +[dv] +AUTOSTART = YES +DEBUG = NO +ACCEPT_FROM6 = ::1; +ACCEPT_FROM = 127.0.0.1; +BINARY = gnunet-service-dv +CONFIG = $DEFAULTCONFIG +HOME = $SERVICEHOME +HOSTNAME = localhost +PORT = 2571 + +[testing] +NUM_PEERS = 3 +ADDITIONAL_MESSAGES = 10 +DEBUG = NO +WEAKRANDOM = YES +TOPOLOGY = CLIQUE +CONNECT_TOPOLOGY = LINE +BLACKLIST_TOPOLOGY = LINE +BLACKLIST_TRANSPORTS = tcp +F2F = YES +HOSTKEYSFILE = ../../contrib/testing_hostkeys.dat + +[fs] +AUTOSTART = NO + +[nat] +DISABLEV6 = YES +ENABLE_UPNP = NO +BEHIND_NAT = NO +ALLOW_NAT = NO +INTERNAL_ADDRESS = 127.0.0.1 +EXTERNAL_ADDRESS = 127.0.0.1 +USE_LOCALADDR = NO + +[dns] +AUTOSTART = NO + + + +[nse] +AUTOSTART = NO + + |