[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r34401 - in gnunet: m4 po src/include src/transport
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] r34401 - in gnunet: m4 po src/include src/transport |
|
Date: |
Fri, 7 Nov 2014 17:33:42 +0100 |
Author: grothoff
Date: 2014-11-07 17:33:42 +0100 (Fri, 07 Nov 2014)
New Revision: 34401
Added:
gnunet/src/transport/transport_api_monitor_plugins.c
Modified:
gnunet/m4/libgcrypt.m4
gnunet/po/POTFILES.in
gnunet/src/include/gnunet_transport_plugin.h
gnunet/src/include/gnunet_transport_service.h
gnunet/src/transport/Makefile.am
gnunet/src/transport/gnunet-service-transport_clients.c
gnunet/src/transport/plugin_transport_http_client.c
gnunet/src/transport/plugin_transport_http_server.c
gnunet/src/transport/plugin_transport_tcp.c
gnunet/src/transport/plugin_transport_udp.c
gnunet/src/transport/plugin_transport_unix.c
gnunet/src/transport/plugin_transport_wlan.c
gnunet/src/transport/transport.h
gnunet/src/transport/transport_api_monitor_peers.c
Log:
implementing plugin session monitoring API (#3452)
Modified: gnunet/m4/libgcrypt.m4
===================================================================
--- gnunet/m4/libgcrypt.m4 2014-11-03 13:36:49 UTC (rev 34400)
+++ gnunet/m4/libgcrypt.m4 2014-11-07 16:33:42 UTC (rev 34401)
@@ -1,5 +1,5 @@
dnl Autoconf macros for libgcrypt
-dnl Copyright (C) 2002, 2004 Free Software Foundation, Inc.
+dnl Copyright (C) 2002, 2004, 2011 Free Software Foundation, Inc.
dnl
dnl This file is free software; as a special exception the author gives
dnl unlimited permission to copy and/or distribute it, with or without
@@ -15,13 +15,14 @@
dnl Test for libgcrypt and define LIBGCRYPT_CFLAGS and LIBGCRYPT_LIBS.
dnl MINIMUN-VERSION is a string with the version number optionalliy prefixed
dnl with the API version to also check the API compatibility. Example:
-dnl a MINIMUN-VERSION of 1:1.2.5 won't pass the test unless the installed
+dnl a MINIMUN-VERSION of 1:1.2.5 won't pass the test unless the installed
dnl version of libgcrypt is at least 1.2.5 *and* the API number is 1. Using
dnl this features allows to prevent build against newer versions of libgcrypt
dnl with a changed API.
dnl
AC_DEFUN([AM_PATH_LIBGCRYPT],
-[ AC_ARG_WITH(libgcrypt-prefix,
+[ AC_REQUIRE([AC_CANONICAL_HOST])
+ AC_ARG_WITH(libgcrypt-prefix,
AC_HELP_STRING([--with-libgcrypt-prefix=PFX],
[prefix where LIBGCRYPT is installed (optional)]),
libgcrypt_config_prefix="$withval", libgcrypt_config_prefix="")
@@ -31,7 +32,7 @@
fi
fi
- AC_PATH_PROG(LIBGCRYPT_CONFIG, libgcrypt-config, no)
+ AC_PATH_TOOL(LIBGCRYPT_CONFIG, libgcrypt-config, no)
tmp=ifelse([$1], ,1:1.2.0,$1)
if echo "$tmp" | grep ':' >/dev/null 2>/dev/null ; then
req_libgcrypt_api=`echo "$tmp" | sed 's/\(.*\):\(.*\)/\1/'`
@@ -59,7 +60,7 @@
sed 's/\([[0-9]]*\)\.\([[0-9]]*\)\.\([[0-9]]*\).*/\3/'`
if test "$major" -gt "$req_major"; then
ok=yes
- else
+ else
if test "$major" -eq "$req_major"; then
if test "$minor" -gt "$req_minor"; then
ok=yes
@@ -74,7 +75,7 @@
fi
fi
if test $ok = yes; then
- AC_MSG_RESULT(yes)
+ AC_MSG_RESULT([yes ($libgcrypt_config_version)])
else
AC_MSG_RESULT(no)
fi
@@ -86,10 +87,10 @@
if test "$tmp" -gt 0 ; then
AC_MSG_CHECKING([LIBGCRYPT API version])
if test "$req_libgcrypt_api" -eq "$tmp" ; then
- AC_MSG_RESULT(okay)
+ AC_MSG_RESULT([okay])
else
ok=no
- AC_MSG_RESULT([does not match (want=$req_libgcrypt_api got=$tmp)])
+ AC_MSG_RESULT([does not match. want=$req_libgcrypt_api got=$tmp])
fi
fi
fi
@@ -98,6 +99,19 @@
LIBGCRYPT_CFLAGS=`$LIBGCRYPT_CONFIG --cflags`
LIBGCRYPT_LIBS=`$LIBGCRYPT_CONFIG --libs`
ifelse([$2], , :, [$2])
+ libgcrypt_config_host=`$LIBGCRYPT_CONFIG --host 2>/dev/null || echo none`
+ if test x"$libgcrypt_config_host" != xnone ; then
+ if test x"$libgcrypt_config_host" != x"$host" ; then
+ AC_MSG_WARN([[
+***
+*** The config script $LIBGCRYPT_CONFIG was
+*** built for $libgcrypt_config_host and thus may not match the
+*** used host $host.
+*** You may want to use the configure option --with-libgcrypt-prefix
+*** to specify a matching config script.
+***]])
+ fi
+ fi
else
LIBGCRYPT_CFLAGS=""
LIBGCRYPT_LIBS=""
Modified: gnunet/po/POTFILES.in
===================================================================
--- gnunet/po/POTFILES.in 2014-11-03 13:36:49 UTC (rev 34400)
+++ gnunet/po/POTFILES.in 2014-11-07 16:33:42 UTC (rev 34401)
@@ -3,19 +3,11 @@
src/arm/gnunet-arm.c
src/arm/gnunet-service-arm.c
src/arm/mockup-service.c
-src/ats-tests/ats-testing-experiment.c
-src/ats-tests/ats-testing-log.c
-src/ats-tests/ats-testing-preferences.c
-src/ats-tests/ats-testing-traffic.c
-src/ats-tests/ats-testing.c
-src/ats-tests/gnunet-ats-sim.c
-src/ats-tests/gnunet-solver-eval.c
-src/ats-tool/gnunet-ats.c
src/ats/ats_api_performance.c
src/ats/ats_api_scheduling.c
src/ats/gnunet-ats-solver-eval.c
+src/ats/gnunet-service-ats_addresses.c
src/ats/gnunet-service-ats.c
-src/ats/gnunet-service-ats_addresses.c
src/ats/gnunet-service-ats_normalization.c
src/ats/gnunet-service-ats_performance.c
src/ats/gnunet-service-ats_reservations.c
@@ -23,6 +15,14 @@
src/ats/plugin_ats_mlp.c
src/ats/plugin_ats_proportional.c
src/ats/plugin_ats_ril.c
+src/ats-tests/ats-testing.c
+src/ats-tests/ats-testing-experiment.c
+src/ats-tests/ats-testing-log.c
+src/ats-tests/ats-testing-preferences.c
+src/ats-tests/ats-testing-traffic.c
+src/ats-tests/gnunet-ats-sim.c
+src/ats-tests/gnunet-solver-eval.c
+src/ats-tool/gnunet-ats.c
src/block/block.c
src/block/plugin_block_template.c
src/block/plugin_block_test.c
@@ -31,8 +31,8 @@
src/cadet/cadet_path.c
src/cadet/cadet_test_lib.c
src/cadet/cadet_tunnel_tree.c
+src/cadet/gnunet-cadet.c
src/cadet/gnunet-cadet-profiler.c
-src/cadet/gnunet-cadet.c
src/cadet/gnunet-service-cadet.c
src/cadet/gnunet-service-cadet_channel.c
src/cadet/gnunet-service-cadet_connection.c
@@ -46,12 +46,12 @@
src/consensus/gnunet-service-consensus.c
src/conversation/conversation_api.c
src/conversation/conversation_api_call.c
+src/conversation/gnunet-conversation.c
src/conversation/gnunet-conversation-test.c
-src/conversation/gnunet-conversation.c
+src/conversation/gnunet-helper-audio-playback.c
src/conversation/gnunet-helper-audio-playback-gst.c
-src/conversation/gnunet-helper-audio-playback.c
+src/conversation/gnunet-helper-audio-record.c
src/conversation/gnunet-helper-audio-record-gst.c
-src/conversation/gnunet-helper-audio-record.c
src/conversation/gnunet-service-conversation.c
src/conversation/microphone.c
src/conversation/plugin_gnsrecord_conversation.c
@@ -82,6 +82,7 @@
src/dht/dht_test_lib.c
src/dht/gnunet-dht-get.c
src/dht/gnunet-dht-monitor.c
+src/dht/gnunet_dht_profiler.c
src/dht/gnunet-dht-put.c
src/dht/gnunet-service-dht.c
src/dht/gnunet-service-dht_clients.c
@@ -97,7 +98,6 @@
src/dht/gnunet-service-xdht_neighbours.c
src/dht/gnunet-service-xdht_nse.c
src/dht/gnunet-service-xdht_routing.c
-src/dht/gnunet_dht_profiler.c
src/dht/plugin_block_dht.c
src/dns/dns_api.c
src/dns/dnsparser.c
@@ -113,8 +113,8 @@
src/dv/plugin_transport_dv.c
src/env/env.c
src/exit/gnunet-daemon-exit.c
+src/exit/gnunet-helper-exit.c
src/exit/gnunet-helper-exit-windows.c
-src/exit/gnunet-helper-exit.c
src/experimentation/gnunet-daemon-experimentation.c
src/experimentation/gnunet-daemon-experimentation_capabilities.c
src/experimentation/gnunet-daemon-experimentation_experiments.c
@@ -145,8 +145,8 @@
src/fs/gnunet-daemon-fsprofiler.c
src/fs/gnunet-directory.c
src/fs/gnunet-download.c
+src/fs/gnunet-fs.c
src/fs/gnunet-fs-profiler.c
-src/fs/gnunet-fs.c
src/fs/gnunet-helper-fs-publish.c
src/fs/gnunet-publish.c
src/fs/gnunet-search.c
@@ -165,10 +165,10 @@
src/gns/gns_api.c
src/gns/gnunet-bcd.c
src/gns/gnunet-dns2gns.c
+src/gns/gnunet-gns.c
src/gns/gnunet-gns-helper-service-w32.c
src/gns/gnunet-gns-import.c
src/gns/gnunet-gns-proxy.c
-src/gns/gnunet-gns.c
src/gns/gnunet-service-gns.c
src/gns/gnunet-service-gns_interceptor.c
src/gns/gnunet-service-gns_resolver.c
@@ -177,15 +177,15 @@
src/gns/nss/nss_gns_query.c
src/gns/plugin_block_gns.c
src/gns/plugin_gnsrecord_gns.c
-src/gns/w32nsp-install.c
-src/gns/w32nsp-resolve.c
-src/gns/w32nsp-uninstall.c
-src/gns/w32nsp.c
src/gnsrecord/gnsrecord.c
src/gnsrecord/gnsrecord_crypto.c
src/gnsrecord/gnsrecord_misc.c
src/gnsrecord/gnsrecord_serialization.c
src/gnsrecord/plugin_gnsrecord_dns.c
+src/gns/w32nsp.c
+src/gns/w32nsp-install.c
+src/gns/w32nsp-resolve.c
+src/gns/w32nsp-uninstall.c
src/hello/address.c
src/hello/gnunet-hello.c
src/hello/hello.c
@@ -205,31 +205,31 @@
src/namecache/namecache_api.c
src/namecache/plugin_namecache_postgres.c
src/namecache/plugin_namecache_sqlite.c
+src/namestore/gnunet-namestore.c
src/namestore/gnunet-namestore-fcfsd.c
-src/namestore/gnunet-namestore.c
src/namestore/gnunet-service-namestore.c
src/namestore/namestore_api.c
src/namestore/namestore_api_monitor.c
src/namestore/plugin_namestore_postgres.c
src/namestore/plugin_namestore_sqlite.c
+src/nat/gnunet-helper-nat-client.c
src/nat/gnunet-helper-nat-client-windows.c
-src/nat/gnunet-helper-nat-client.c
+src/nat/gnunet-helper-nat-server.c
src/nat/gnunet-helper-nat-server-windows.c
-src/nat/gnunet-helper-nat-server.c
src/nat/gnunet-nat-server.c
+src/nat/nat_auto.c
src/nat/nat.c
-src/nat/nat_auto.c
src/nat/nat_mini.c
src/nat/nat_test.c
+src/nse/gnunet-nse.c
src/nse/gnunet-nse-profiler.c
-src/nse/gnunet-nse.c
src/nse/gnunet-service-nse.c
src/nse/nse_api.c
-src/peerinfo-tool/gnunet-peerinfo.c
-src/peerinfo-tool/gnunet-peerinfo_plugins.c
src/peerinfo/gnunet-service-peerinfo.c
src/peerinfo/peerinfo_api.c
src/peerinfo/peerinfo_api_notify.c
+src/peerinfo-tool/gnunet-peerinfo.c
+src/peerinfo-tool/gnunet-peerinfo_plugins.c
src/peerstore/gnunet-peerstore.c
src/peerstore/gnunet-service-peerstore.c
src/peerstore/peerstore_api.c
@@ -266,10 +266,12 @@
src/secretsharing/gnunet-service-secretsharing.c
src/secretsharing/secretsharing_api.c
src/secretsharing/secretsharing_common.c
+src/sensordashboard/gnunet-sensordashboard.c
+src/sensordashboard/gnunet-service-sensordashboard.c
+src/sensor/gnunet-sensor.c
src/sensor/gnunet-sensor-profiler.c
-src/sensor/gnunet-sensor.c
+src/sensor/gnunet-service-sensor_analysis.c
src/sensor/gnunet-service-sensor.c
-src/sensor/gnunet-service-sensor_analysis.c
src/sensor/gnunet-service-sensor_monitoring.c
src/sensor/gnunet-service-sensor_reporting.c
src/sensor/gnunet-service-sensor_update.c
@@ -277,8 +279,6 @@
src/sensor/sensor_api.c
src/sensor/sensor_util_lib.c
src/sensor/sensor_util_lib_crypto.c
-src/sensordashboard/gnunet-sensordashboard.c
-src/sensordashboard/gnunet-service-sensordashboard.c
src/set/gnunet-service-set.c
src/set/gnunet-service-set_intersection.c
src/set/gnunet-service-set_union.c
@@ -299,30 +299,30 @@
src/testbed/gnunet-daemon-testbed-blacklist.c
src/testbed/gnunet-daemon-testbed-underlay.c
src/testbed/gnunet-helper-testbed.c
+src/testbed/gnunet_mpi_test.c
src/testbed/gnunet-service-test-barriers.c
-src/testbed/gnunet-service-testbed-logger.c
+src/testbed/gnunet-service-testbed_barriers.c
src/testbed/gnunet-service-testbed.c
-src/testbed/gnunet-service-testbed_barriers.c
src/testbed/gnunet-service-testbed_cache.c
src/testbed/gnunet-service-testbed_connectionpool.c
src/testbed/gnunet-service-testbed_cpustatus.c
src/testbed/gnunet-service-testbed_links.c
+src/testbed/gnunet-service-testbed-logger.c
src/testbed/gnunet-service-testbed_meminfo.c
src/testbed/gnunet-service-testbed_oc.c
src/testbed/gnunet-service-testbed_peers.c
+src/testbed/gnunet_testbed_mpi_spawn.c
src/testbed/gnunet-testbed-profiler.c
-src/testbed/gnunet_mpi_test.c
-src/testbed/gnunet_testbed_mpi_spawn.c
+src/testbed/testbed_api_barriers.c
src/testbed/testbed_api.c
-src/testbed/testbed_api_barriers.c
src/testbed/testbed_api_hosts.c
src/testbed/testbed_api_operations.c
src/testbed/testbed_api_peers.c
src/testbed/testbed_api_sd.c
src/testbed/testbed_api_services.c
src/testbed/testbed_api_statistics.c
+src/testbed/testbed_api_testbed.c
src/testbed/testbed_api_test.c
-src/testbed/testbed_api_testbed.c
src/testbed/testbed_api_topology.c
src/testbed/testbed_api_underlay.c
src/testbed/testbed_logger_api.c
@@ -332,37 +332,37 @@
src/topology/friends.c
src/topology/gnunet-daemon-topology.c
src/transport/gnunet-helper-transport-bluetooth.c
+src/transport/gnunet-helper-transport-wlan.c
src/transport/gnunet-helper-transport-wlan-dummy.c
-src/transport/gnunet-helper-transport-wlan.c
+src/transport/gnunet-service-transport_blacklist.c
src/transport/gnunet-service-transport.c
-src/transport/gnunet-service-transport_blacklist.c
src/transport/gnunet-service-transport_clients.c
src/transport/gnunet-service-transport_hello.c
src/transport/gnunet-service-transport_manipulation.c
src/transport/gnunet-service-transport_neighbours.c
src/transport/gnunet-service-transport_plugins.c
src/transport/gnunet-service-transport_validation.c
+src/transport/gnunet-transport.c
src/transport/gnunet-transport-certificate-creation.c
src/transport/gnunet-transport-profiler.c
src/transport/gnunet-transport-wlan-receiver.c
src/transport/gnunet-transport-wlan-sender.c
-src/transport/gnunet-transport.c
src/transport/plugin_transport_http_client.c
src/transport/plugin_transport_http_common.c
src/transport/plugin_transport_http_server.c
src/transport/plugin_transport_smtp.c
src/transport/plugin_transport_tcp.c
src/transport/plugin_transport_template.c
+src/transport/plugin_transport_udp_broadcasting.c
src/transport/plugin_transport_udp.c
-src/transport/plugin_transport_udp_broadcasting.c
src/transport/plugin_transport_unix.c
src/transport/plugin_transport_wlan.c
-src/transport/transport-testing.c
-src/transport/transport_api.c
src/transport/transport_api_address_to_string.c
src/transport/transport_api_blacklist.c
+src/transport/transport_api.c
src/transport/transport_api_monitor_peers.c
src/transport/transport_api_monitor_validation.c
+src/transport/transport-testing.c
src/tun/regex.c
src/tun/tun.c
src/util/bandwidth.c
@@ -377,8 +377,8 @@
src/util/container_bloomfilter.c
src/util/container_heap.c
src/util/container_meta_data.c
+src/util/container_multihashmap32.c
src/util/container_multihashmap.c
-src/util/container_multihashmap32.c
src/util/container_multipeermap.c
src/util/container_slist.c
src/util/crypto_crc.c
@@ -393,8 +393,8 @@
src/util/disk.c
src/util/getopt.c
src/util/getopt_helpers.c
+src/util/gnunet-config.c
src/util/gnunet-config-diff.c
-src/util/gnunet-config.c
src/util/gnunet-ecc.c
src/util/gnunet-helper-w32-console.c
src/util/gnunet-resolver.c
@@ -425,8 +425,8 @@
src/util/w32cat.c
src/util/win.c
src/util/winproc.c
+src/vpn/gnunet-helper-vpn.c
src/vpn/gnunet-helper-vpn-windows.c
-src/vpn/gnunet-helper-vpn.c
src/vpn/gnunet-service-vpn.c
src/vpn/gnunet-vpn.c
src/vpn/vpn_api.c
Modified: gnunet/src/include/gnunet_transport_plugin.h
===================================================================
--- gnunet/src/include/gnunet_transport_plugin.h 2014-11-03 13:36:49 UTC
(rev 34400)
+++ gnunet/src/include/gnunet_transport_plugin.h 2014-11-07 16:33:42 UTC
(rev 34401)
@@ -597,79 +597,6 @@
/**
- * Possible states of a session in a plugin.
- */
-enum GNUNET_TRANSPORT_SessionState
-{
- /**
- * Session is being torn down and about to disappear.
- */
- GNUNET_TRANSPORT_SS_DOWN,
-
- /**
- * Initial session handshake is in progress.
- */
- GNUNET_TRANSPORT_SS_HANDSHAKE,
-
- /**
- * Session is fully UP.
- */
- GNUNET_TRANSPORT_SS_UP
-
-};
-
-
-/**
- * Information about a plugin's session.
- */
-struct GNUNET_TRANSPORT_SessionInfo
-{
-
- /**
- * New state of the session.
- */
- enum GNUNET_TRANSPORT_SessionState state;
-
- /**
- * #GNUNET_YES if this is an inbound connection,
- * #GNUNET_NO if this is an outbound connection,
- * #GNUNET_SYSERR if connections of this plugin
- * are so fundamentally bidirectional
- * that they have no 'initiator'
- */
- int is_inbound;
-
- /**
- * Number of messages pending transmission for this session.
- */
- unsigned int num_msg_pending;
-
- /**
- * Number of bytes pending transmission for this session.
- */
- unsigned int num_bytes_pending;
-
- /**
- * Until when does this plugin refuse to receive to manage
- * staying within the inbound quota? ZERO if receive is
- * active.
- */
- struct GNUNET_TIME_Absolute receive_delay;
-
- /**
- * At what time will this session timeout (unless activity
- * happens)?
- */
- struct GNUNET_TIME_Absolute session_timeout;
-
- /**
- * Address used by the session. Can be NULL if none is available.
- */
- const struct GNUNET_HELLO_Address *address;
-};
-
-
-/**
* Function called by the plugin with information about the
* current sessions managed by the plugin (for monitoring).
*
Modified: gnunet/src/include/gnunet_transport_service.h
===================================================================
--- gnunet/src/include/gnunet_transport_service.h 2014-11-03 13:36:49 UTC
(rev 34400)
+++ gnunet/src/include/gnunet_transport_service.h 2014-11-07 16:33:42 UTC
(rev 34401)
@@ -885,7 +885,156 @@
GNUNET_TRANSPORT_blacklist_cancel (struct GNUNET_TRANSPORT_Blacklist *br);
+/**
+ * Handle for a plugin session state monitor.
+ */
+struct GNUNET_TRANSPORT_PluginMonitor;
+/**
+ * Abstract representation of a plugin's session.
+ * Corresponds to the `struct Session` within the TRANSPORT service.
+ */
+struct GNUNET_TRANSPORT_PluginSession;
+
+
+/**
+ * Possible states of a session in a plugin.
+ */
+enum GNUNET_TRANSPORT_SessionState
+{
+
+ /**
+ * The session was created (first call for each session object).
+ */
+ GNUNET_TRANSPORT_SS_INIT,
+
+ /**
+ * Initial session handshake is in progress.
+ */
+ GNUNET_TRANSPORT_SS_HANDSHAKE,
+
+ /**
+ * Session is fully UP.
+ */
+ GNUNET_TRANSPORT_SS_UP,
+
+ /**
+ * This is just an update about the session,
+ * the state did not change.
+ */
+ GNUNET_TRANSPORT_SS_UPDATE,
+
+ /**
+ * Session is being torn down and about to disappear.
+ * Last call for each session object.
+ */
+ GNUNET_TRANSPORT_SS_DONE
+
+};
+
+
+/**
+ * Information about a plugin's session.
+ */
+struct GNUNET_TRANSPORT_SessionInfo
+{
+
+ /**
+ * New state of the session.
+ */
+ enum GNUNET_TRANSPORT_SessionState state;
+
+ /**
+ * #GNUNET_YES if this is an inbound connection,
+ * #GNUNET_NO if this is an outbound connection,
+ * #GNUNET_SYSERR if connections of this plugin
+ * are so fundamentally bidirectional
+ * that they have no 'initiator'
+ */
+ int is_inbound;
+
+ /**
+ * Number of messages pending transmission for this session.
+ */
+ uint32_t num_msg_pending;
+
+ /**
+ * Number of bytes pending transmission for this session.
+ */
+ uint32_t num_bytes_pending;
+
+ /**
+ * Until when does this plugin refuse to receive to manage
+ * staying within the inbound quota? ZERO if receive is
+ * active.
+ */
+ struct GNUNET_TIME_Absolute receive_delay;
+
+ /**
+ * At what time will this session timeout (unless activity
+ * happens)?
+ */
+ struct GNUNET_TIME_Absolute session_timeout;
+
+ /**
+ * Address used by the session. Can be NULL if none is available.
+ */
+ const struct GNUNET_HELLO_Address *address;
+};
+
+
+/**
+ * Function called by the plugin with information about the
+ * current sessions managed by the plugin (for monitoring).
+ *
+ * @param cls closure
+ * @param session session handle this information is about,
+ * NULL to indicate that we are "in sync" (initial
+ * iteration complete)
+ * @param session_ctx storage location where the application
+ * can store data; will point to NULL on #GNUNET_TRANSPORT_SS_INIT,
+ * and must be reset to NULL on #GNUNET_TRANSPORT_SS_DONE
+ * @param info information about the state of the session,
+ * NULL if @a session is also NULL and we are
+ * merely signalling that the initial iteration is over;
+ * NULL with @a session being non-NULL if the monitor
+ * was being cancelled while sessions were active
+ */
+typedef void
+(*GNUNET_TRANSPORT_SessionMonitorCallback) (void *cls,
+ struct
GNUNET_TRANSPORT_PluginSession *session,
+ void **session_ctx,
+ const struct
GNUNET_TRANSPORT_SessionInfo *info);
+
+
+
+/**
+ * Install a plugin session state monitor callback. The callback
+ * will be notified whenever the session changes.
+ *
+ * @param cfg configuration to use
+ * @param cb callback to invoke on events
+ * @param cb_cls closure for @a cb
+ * @return NULL on error, otherwise handle for cancellation
+ */
+struct GNUNET_TRANSPORT_PluginMonitor *
+GNUNET_TRANSPORT_monitor_plugins (const struct GNUNET_CONFIGURATION_Handle
*cfg,
+ GNUNET_TRANSPORT_SessionMonitorCallback cb,
+ void *cb_cls);
+
+
+/**
+ * Cancel monitoring the plugin session state. The callback will be
+ * called once for each session that is up with the "info" argument
+ * being NULL (this is just to enable client-side cleanup).
+ *
+ * @param pm handle of the request that is to be cancelled
+ */
+void
+GNUNET_TRANSPORT_monitor_plugins_cancel (struct GNUNET_TRANSPORT_PluginMonitor
*pm);
+
+
+
#if 0 /* keep Emacsens' auto-indent happy */
{
#endif
Modified: gnunet/src/transport/Makefile.am
===================================================================
--- gnunet/src/transport/Makefile.am 2014-11-03 13:36:49 UTC (rev 34400)
+++ gnunet/src/transport/Makefile.am 2014-11-07 16:33:42 UTC (rev 34401)
@@ -95,7 +95,7 @@
if LINUX
install-exec-hook:
$(top_srcdir)/src/transport/install-wlan-helper.sh $(libexecdir)
$(SUDO_BINARY) || true
-if HAVE_LIBBLUETOOTH
+if HAVE_LIBBLUETOOTH
$(top_srcdir)/src/transport/install-bluetooth-helper.sh $(libexecdir)
$(SUDO_BINARY) || true
endif
else
@@ -164,6 +164,7 @@
transport_api_blacklist.c \
transport_api_address_to_string.c \
transport_api_monitor_peers.c \
+ transport_api_monitor_plugins.c \
transport_api_monitor_validation.c
libgnunettransport_la_LIBADD = \
$(top_builddir)/src/hello/libgnunethello.la \
Modified: gnunet/src/transport/gnunet-service-transport_clients.c
===================================================================
--- gnunet/src/transport/gnunet-service-transport_clients.c 2014-11-03
13:36:49 UTC (rev 34400)
+++ gnunet/src/transport/gnunet-service-transport_clients.c 2014-11-07
16:33:42 UTC (rev 34401)
@@ -117,6 +117,7 @@
int send_payload;
};
+
/**
* Context for address to string operations
*/
@@ -138,6 +139,7 @@
struct GNUNET_SERVER_TransmitContext* tc;
};
+
/**
* Client monitoring changes of active addresses of our neighbours.
*/
@@ -225,6 +227,7 @@
*/
static struct GNUNET_SERVER_NotificationContext *plugin_nc;
+
/**
* Find the internal handle associated with the given client handle
*
@@ -306,6 +309,7 @@
mc->client = client;
mc->peer = *peer;
GNUNET_CONTAINER_DLL_insert (peer_monitoring_clients_head,
peer_monitoring_clients_tail, mc);
+ GNUNET_SERVER_client_mark_monitor (client);
GNUNET_SERVER_notification_context_add (peer_nc, client);
if (0 != memcmp (peer, &all_zeros, sizeof (struct GNUNET_PeerIdentity)))
@@ -635,7 +639,7 @@
/**
- * Closure for 'handle_send_transmit_continuation'
+ * Closure for #handle_send_transmit_continuation()
*/
struct SendTransmitContinuationContext
{
@@ -1068,6 +1072,7 @@
return msg;
}
+
/**
* Compose #PeerIterateResponseMessage using the given peer and address.
*
@@ -1077,7 +1082,7 @@
*/
static struct ValidationIterateResponseMessage *
compose_validation_iterate_response_message (const struct GNUNET_PeerIdentity
*peer,
- const struct GNUNET_HELLO_Address
*address)
+ const struct GNUNET_HELLO_Address
*address)
{
struct ValidationIterateResponseMessage *msg;
size_t size;
@@ -1113,12 +1118,26 @@
return msg;
}
+
+/**
+ * Context for #send_validation_information() and
+ * #send_peer_information().
+ */
struct IterationContext
{
+ /**
+ * Context to use for the transmission.
+ */
struct GNUNET_SERVER_TransmitContext *tc;
+ /**
+ * Which peers do we care about?
+ */
struct GNUNET_PeerIdentity id;
+ /**
+ * #GNUNET_YES if @e id should be ignored because we want all peers.
+ */
int all;
};
@@ -1245,6 +1264,7 @@
return;
}
GNUNET_SERVER_disable_receive_done_warning (client);
+ GNUNET_SERVER_client_mark_monitor (client);
pc.tc = tc = GNUNET_SERVER_transmit_context_create (client);
/* Send initial list */
@@ -1318,6 +1338,7 @@
return;
}
GNUNET_SERVER_disable_receive_done_warning (client);
+ GNUNET_SERVER_client_mark_monitor (client);
pc.tc = tc = GNUNET_SERVER_transmit_context_create (client);
/* Send initial list */
@@ -1396,6 +1417,7 @@
msg->timeout = GNUNET_TIME_absolute_hton (info->session_timeout);
msg->delay = GNUNET_TIME_absolute_hton (info->receive_delay);
msg->peer = info->address->peer;
+ msg->session_id = (uint64_t) (intptr_t) session;
msg->plugin_name_len = htons (slen);
msg->plugin_address_len = htons (alen);
name = (char *) &msg[1];
@@ -1421,6 +1443,7 @@
struct GNUNET_SERVER_Client *client,
const struct GNUNET_MessageHeader *message)
{
+ GNUNET_SERVER_client_mark_monitor (client);
GNUNET_SERVER_disable_receive_done_warning (client);
if (0 == GNUNET_SERVER_notification_context_get_size (plugin_nc))
GST_plugins_monitor_subscribe (&plugin_session_info_cb, NULL);
Modified: gnunet/src/transport/plugin_transport_http_client.c
===================================================================
--- gnunet/src/transport/plugin_transport_http_client.c 2014-11-03 13:36:49 UTC
(rev 34400)
+++ gnunet/src/transport/plugin_transport_http_client.c 2014-11-07 16:33:42 UTC
(rev 34401)
@@ -519,7 +519,7 @@
GNUNET_assert (0 == s->bytes_in_queue);
notify_session_monitor (plugin,
s,
- GNUNET_TRANSPORT_SS_DOWN);
+ GNUNET_TRANSPORT_SS_DONE);
if (NULL != s->msg_tk)
{
GNUNET_SERVER_mst_destroy (s->msg_tk);
@@ -778,7 +778,7 @@
GNUNET_free (stat_txt);
notify_session_monitor (plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
if (H_TMP_DISCONNECTING == s->put.state)
{
/* PUT request is currently getting disconnected */
@@ -1078,7 +1078,7 @@
}
notify_session_monitor (plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
GNUNET_asprintf (&stat_txt,
"# bytes currently in %s_client buffers",
plugin->protocol);
@@ -1741,7 +1741,7 @@
the monitor, it may think we're about to die ... */
notify_session_monitor (s->plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
s->timeout_task = GNUNET_SCHEDULER_add_delayed (left,
&client_session_timeout,
s);
@@ -1860,7 +1860,12 @@
client_delete_session (s);
return NULL;
}
- notify_session_monitor (plugin, s, GNUNET_TRANSPORT_SS_UP); /* or handshake?
*/
+ notify_session_monitor (plugin,
+ s,
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (plugin,
+ s,
+ GNUNET_TRANSPORT_SS_UP); /* or handshake? */
return s;
}
@@ -2162,7 +2167,10 @@
notify_session_monitor (plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (plugin,
+ session,
+ GNUNET_TRANSPORT_SS_UP); /* FIXME: or handshake? */
return GNUNET_OK;
}
Modified: gnunet/src/transport/plugin_transport_http_server.c
===================================================================
--- gnunet/src/transport/plugin_transport_http_server.c 2014-11-03 13:36:49 UTC
(rev 34400)
+++ gnunet/src/transport/plugin_transport_http_server.c 2014-11-07 16:33:42 UTC
(rev 34401)
@@ -598,11 +598,13 @@
}
notify_session_monitor (plugin,
s,
- GNUNET_TRANSPORT_SS_DOWN);
+ GNUNET_TRANSPORT_SS_DONE);
if (GNUNET_YES == s->known_to_service)
+ {
plugin->env->session_end (plugin->env->cls,
s->address,
s);
+ }
if (NULL != s->msg_tk)
{
GNUNET_SERVER_mst_destroy (s->msg_tk);
@@ -1461,6 +1463,9 @@
GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
notify_session_monitor (plugin,
s,
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (plugin,
+ s,
GNUNET_TRANSPORT_SS_HANDSHAKE);
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Creating new session %p for peer `%s' connecting from `%s'\n",
@@ -1512,7 +1517,13 @@
(NULL != s->server_recv) )
{
s->known_to_service = GNUNET_YES;
- plugin->env->session_start (NULL, s->address ,s, NULL, 0);
+ notify_session_monitor (plugin,
+ s,
+ GNUNET_TRANSPORT_SS_UP);
+ plugin->env->session_start (NULL,
+ s->address,
+ s,
+ NULL, 0);
}
if ( (NULL == s->server_recv) ||
@@ -1592,7 +1603,7 @@
GNUNET_free (msg);
notify_session_monitor (s->plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
}
}
if (0 < bytes_read)
@@ -3298,7 +3309,7 @@
notify_session_monitor (plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_INIT);
return GNUNET_OK;
}
Modified: gnunet/src/transport/plugin_transport_tcp.c
===================================================================
--- gnunet/src/transport/plugin_transport_tcp.c 2014-11-03 13:36:49 UTC (rev
34400)
+++ gnunet/src/transport/plugin_transport_tcp.c 2014-11-07 16:33:42 UTC (rev
34401)
@@ -885,7 +885,7 @@
GNUNET_assert (0 == session->bytes_in_queue);
notify_session_monitor (session->plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_DONE);
if (session->receive_delay_task != GNUNET_SCHEDULER_NO_TASK)
{
@@ -942,7 +942,7 @@
the monitor, it may think we're about to die ... */
notify_session_monitor (s->plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
s->timeout_task = GNUNET_SCHEDULER_add_delayed (left,
&session_timeout,
s);
@@ -1030,6 +1030,9 @@
session->timeout_task = GNUNET_SCHEDULER_add_delayed
(GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT,
&session_timeout,
session);
+ notify_session_monitor (session->plugin,
+ session,
+ GNUNET_TRANSPORT_SS_INIT);
if (GNUNET_YES != is_nat)
{
GNUNET_STATISTICS_update (plugin->env->stats,
@@ -1144,7 +1147,7 @@
if (0 < ret)
notify_session_monitor (session->plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
return 0;
}
/* copy all pending messages that would fit */
@@ -1177,7 +1180,7 @@
}
notify_session_monitor (session->plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
/* schedule 'continuation' before callbacks so that callbacks that
* cancel everything don't cause us to use a session that no longer
* exists... */
@@ -1310,7 +1313,7 @@
pm);
notify_session_monitor (session->plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
session->msgs_in_queue++;
session->bytes_in_queue += pm->message_size;
process_pending_messages (session);
@@ -1410,12 +1413,12 @@
struct Session *session = cls;
session->nat_connection_timeout = GNUNET_SCHEDULER_NO_TASK;
- LOG(GNUNET_ERROR_TYPE_DEBUG,
- "NAT WAIT connection to `%4s' at `%s' could not be established, removing
session\n",
- GNUNET_i2s (&session->target),
- tcp_plugin_address_to_string (NULL,
- session->address->address,
- session->address->address_length));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "NAT WAIT connection to `%4s' at `%s' could not be established,
removing session\n",
+ GNUNET_i2s (&session->target),
+ tcp_plugin_address_to_string (NULL,
+ session->address->address,
+ session->address->address_length));
tcp_plugin_disconnect_session (session->plugin,
session);
}
@@ -1632,24 +1635,30 @@
&address->peer)))
{
LOG (GNUNET_ERROR_TYPE_DEBUG,
- "Found valid IPv4 NAT address (creating session)!\n");
- session = create_session (plugin, address, NULL, GNUNET_YES);
- session->ats_address_network_type = (enum GNUNET_ATS_Network_Type) ntohl (
- ats.value);
- GNUNET_break(
- session->ats_address_network_type != GNUNET_ATS_NET_UNSPECIFIED);
+ "Found valid IPv4 NAT address (creating session)!\n");
+ session = create_session (plugin,
+ address,
+ NULL,
+ GNUNET_YES);
+ session->ats_address_network_type = (enum GNUNET_ATS_Network_Type) ntohl
(ats.value);
+ GNUNET_break (session->ats_address_network_type !=
GNUNET_ATS_NET_UNSPECIFIED);
session->nat_connection_timeout = GNUNET_SCHEDULER_add_delayed
(NAT_TIMEOUT,
- &nat_connect_timeout, session);
- GNUNET_assert(session != NULL);
- GNUNET_assert(GNUNET_OK == GNUNET_CONTAINER_multipeermap_put
(plugin->nat_wait_conns,
- &session->target, session,
GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
+
&nat_connect_timeout,
+ session);
+ GNUNET_assert(GNUNET_OK ==
+ GNUNET_CONTAINER_multipeermap_put (plugin->nat_wait_conns,
+ &session->target,
+ session,
+
GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
- LOG(GNUNET_ERROR_TYPE_DEBUG,
- "Created NAT WAIT connection to `%4s' at `%s'\n",
- GNUNET_i2s (&session->target), GNUNET_a2s (sb, sbs));
-
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Created NAT WAIT connection to `%4s' at `%s'\n",
+ GNUNET_i2s (&session->target),
+ GNUNET_a2s (sb, sbs));
if (GNUNET_OK == GNUNET_NAT_run_client (plugin->nat, &a4))
+ {
return session;
+ }
else
{
LOG(GNUNET_ERROR_TYPE_DEBUG,
@@ -1714,24 +1723,28 @@
if (plugin->cur_connections == plugin->max_connections)
GNUNET_SERVER_suspend (plugin->server); /* Maximum number of connections
rechead */
- LOG(GNUNET_ERROR_TYPE_DEBUG,
- "Asked to transmit to `%4s', creating fresh session using address
`%s'.\n",
- GNUNET_i2s (&address->peer), GNUNET_a2s (sb, sbs));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Asked to transmit to `%4s', creating fresh session using address
`%s'.\n",
+ GNUNET_i2s (&address->peer), GNUNET_a2s (sb, sbs));
- session = create_session (plugin, address,
+ session = create_session (plugin,
+ address,
GNUNET_SERVER_connect_socket (plugin->server, sa),
GNUNET_NO);
- session->ats_address_network_type = (enum GNUNET_ATS_Network_Type) ntohl (
- ats.value);
- GNUNET_break(session->ats_address_network_type !=
GNUNET_ATS_NET_UNSPECIFIED);
+ session->ats_address_network_type = (enum GNUNET_ATS_Network_Type) ntohl
(ats.value);
+ GNUNET_break (session->ats_address_network_type !=
GNUNET_ATS_NET_UNSPECIFIED);
GNUNET_SERVER_client_set_user_context(session->client, session);
- GNUNET_CONTAINER_multipeermap_put (plugin->sessionmap, &session->target,
- session, GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
- LOG(GNUNET_ERROR_TYPE_DEBUG,
- "Creating new session for `%s' address `%s' session %p\n",
- GNUNET_i2s (&address->peer),
- tcp_plugin_address_to_string(NULL, address->address,
address->address_length),
- session);
+ GNUNET_CONTAINER_multipeermap_put (plugin->sessionmap,
+ &session->target,
+ session,
+
GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Creating new session for `%s' address `%s' session %p\n",
+ GNUNET_i2s (&address->peer),
+ tcp_plugin_address_to_string (NULL,
+ address->address,
+ address->address_length),
+ session);
/* Send TCP Welcome */
process_pending_messages (session);
@@ -2259,8 +2272,9 @@
{
if (GNUNET_OK == GNUNET_SERVER_client_get_address (client, &vaddr, &alen))
{
- LOG(GNUNET_ERROR_TYPE_DEBUG, "Found existing session %p for peer `%s'\n",
- session, GNUNET_a2s (vaddr, alen));
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Found existing session %p for peer `%s'\n",
+ session, GNUNET_a2s (vaddr, alen));
GNUNET_free(vaddr);
}
}
@@ -2305,21 +2319,27 @@
session = create_session (plugin, address, client, GNUNET_NO);
GNUNET_HELLO_address_free (address);
ats = plugin->env->get_address_type (plugin->env->cls, vaddr, alen);
- session->ats_address_network_type = (enum GNUNET_ATS_Network_Type) ntohl
(
- ats.value);
- LOG(GNUNET_ERROR_TYPE_DEBUG, "Creating new%s session %p for peer `%s'
client %p \n",
+ session->ats_address_network_type = (enum GNUNET_ATS_Network_Type) ntohl
(ats.value);
+ LOG(GNUNET_ERROR_TYPE_DEBUG,
+ "Creating new%s session %p for peer `%s' client %p \n",
GNUNET_HELLO_address_check_option (session->address,
- GNUNET_HELLO_ADDRESS_INFO_INBOUND) ? " inbound" : "", session,
+ GNUNET_HELLO_ADDRESS_INFO_INBOUND)
+ ? " inbound" : "",
+ session,
tcp_plugin_address_to_string(NULL, (void *)
session->address->address,
- session->address->address_length),
+ session->address->address_length),
client);
GNUNET_free(vaddr);
GNUNET_SERVER_client_set_user_context(session->client, session);
- GNUNET_CONTAINER_multipeermap_put (plugin->sessionmap, &session->target,
- session, GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
-
+ GNUNET_CONTAINER_multipeermap_put (plugin->sessionmap,
+ &session->target,
+ session,
+
GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
/* Notify transport and ATS about new session */
plugin->env->session_start (NULL, session->address, session, &ats, 1);
+ notify_session_monitor (plugin,
+ session,
+ GNUNET_TRANSPORT_SS_INIT);
}
else
{
@@ -2614,6 +2634,11 @@
notify_session_monitor (plugin,
session,
+ GNUNET_TRANSPORT_SS_INIT);
+ /* FIXME: cannot tell if this is up or not from current
+ session state... */
+ notify_session_monitor (plugin,
+ session,
GNUNET_TRANSPORT_SS_UP);
return GNUNET_OK;
}
Modified: gnunet/src/transport/plugin_transport_udp.c
===================================================================
--- gnunet/src/transport/plugin_transport_udp.c 2014-11-03 13:36:49 UTC (rev
34400)
+++ gnunet/src/transport/plugin_transport_udp.c 2014-11-07 16:33:42 UTC (rev
34401)
@@ -1270,7 +1270,7 @@
}
notify_session_monitor (s->plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
/* Destroy fragmentation context */
GNUNET_FRAGMENT_context_destroy (fc->frag,
&s->last_expected_msg_delay,
@@ -1385,7 +1385,7 @@
}
notify_session_monitor (s->plugin,
s,
- GNUNET_TRANSPORT_SS_DOWN);
+ GNUNET_TRANSPORT_SS_DONE);
plugin->env->session_end (plugin->env->cls,
s->address,
s);
@@ -1508,7 +1508,7 @@
the monitor, it may think we're about to die ... */
notify_session_monitor (s->plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
s->timeout_task = GNUNET_SCHEDULER_add_delayed (left,
&session_timeout,
s);
@@ -2154,7 +2154,7 @@
}
notify_session_monitor (s->plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
schedule_select (plugin);
return udpmlen;
}
@@ -2335,8 +2335,14 @@
{
s = udp_plugin_create_session (plugin, address);
plugin->env->session_start (NULL, address, s, NULL, 0);
+ notify_session_monitor (s->plugin,
+ s,
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (s->plugin,
+ s,
+ GNUNET_TRANSPORT_SS_UP);
}
- GNUNET_free(address);
+ GNUNET_free (address);
/* iterate over all embedded messages */
si.session = s;
@@ -2446,7 +2452,7 @@
enqueue (rc->plugin, udpw);
notify_session_monitor (s->plugin,
s,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
schedule_select (rc->plugin);
}
@@ -2845,7 +2851,7 @@
if (GNUNET_YES == removed)
notify_session_monitor (session->plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
return udpw;
}
@@ -2955,7 +2961,7 @@
dequeue (plugin, udpw);
notify_session_monitor (plugin,
udpw->session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
GNUNET_free (udpw);
return GNUNET_SYSERR;
}
@@ -2994,7 +3000,7 @@
dequeue (plugin, udpw);
notify_session_monitor (plugin,
udpw->session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
GNUNET_free(udpw);
return sent;
}
@@ -3311,6 +3317,9 @@
notify_session_monitor (plugin,
session,
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (plugin,
+ session,
GNUNET_TRANSPORT_SS_UP);
return GNUNET_OK;
}
Modified: gnunet/src/transport/plugin_transport_unix.c
===================================================================
--- gnunet/src/transport/plugin_transport_unix.c 2014-11-03 13:36:49 UTC
(rev 34400)
+++ gnunet/src/transport/plugin_transport_unix.c 2014-11-07 16:33:42 UTC
(rev 34401)
@@ -490,7 +490,7 @@
}
notify_session_monitor (plugin,
session,
- GNUNET_TRANSPORT_SS_DOWN);
+ GNUNET_TRANSPORT_SS_DONE);
GNUNET_HELLO_address_free (session->address);
GNUNET_break (0 == session->bytes_in_queue);
GNUNET_break (0 == session->msgs_in_queue);
@@ -520,7 +520,7 @@
the monitor, it may think we're about to die ... */
notify_session_monitor (session->plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
session->timeout_task = GNUNET_SCHEDULER_add_delayed (left,
&session_timeout,
session);
@@ -898,6 +898,9 @@
GNUNET_NO);
notify_session_monitor (plugin,
session,
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (plugin,
+ session,
GNUNET_TRANSPORT_SS_UP);
return session;
}
@@ -973,9 +976,6 @@
session->address,
session,
&plugin->ats_network, 1);
- notify_session_monitor (plugin,
- session,
- GNUNET_TRANSPORT_SS_UP);
}
else
{
@@ -1141,7 +1141,7 @@
if (GNUNET_YES == did_delete)
notify_session_monitor (plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
return; /* Nothing to send at the moment */
}
@@ -1163,7 +1163,7 @@
1, GNUNET_NO);
notify_session_monitor (plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
return;
}
GNUNET_CONTAINER_DLL_remove (plugin->msg_head,
@@ -1180,7 +1180,7 @@
plugin->bytes_in_queue, GNUNET_NO);
notify_session_monitor (plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
if (GNUNET_SYSERR == sent)
{
/* failed and no retry */
@@ -1358,7 +1358,7 @@
GNUNET_NO);
notify_session_monitor (plugin,
session,
- GNUNET_TRANSPORT_SS_UP);
+ GNUNET_TRANSPORT_SS_UPDATE);
if (GNUNET_SCHEDULER_NO_TASK == plugin->write_task)
plugin->write_task =
GNUNET_SCHEDULER_add_write_net (GNUNET_TIME_UNIT_FOREVER_REL,
@@ -1703,6 +1703,9 @@
notify_session_monitor (plugin,
session,
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (plugin,
+ session,
GNUNET_TRANSPORT_SS_UP);
return GNUNET_OK;
}
Modified: gnunet/src/transport/plugin_transport_wlan.c
===================================================================
--- gnunet/src/transport/plugin_transport_wlan.c 2014-11-03 13:36:49 UTC
(rev 34400)
+++ gnunet/src/transport/plugin_transport_wlan.c 2014-11-07 16:33:42 UTC
(rev 34401)
@@ -773,7 +773,7 @@
session);
notify_session_monitor (plugin,
session,
- GNUNET_TRANSPORT_SS_DOWN);
+ GNUNET_TRANSPORT_SS_DONE);
GNUNET_CONTAINER_DLL_remove (endpoint->sessions_head,
endpoint->sessions_tail,
session);
@@ -890,6 +890,9 @@
session);
notify_session_monitor (endpoint->plugin,
session,
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (endpoint->plugin,
+ session,
GNUNET_TRANSPORT_SS_UP);
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Created new session %p for peer `%s' with endpoint %s\n",
@@ -2046,9 +2049,14 @@
{
for (mac = plugin->mac_head; NULL != mac; mac = mac->next)
for (session = mac->sessions_head; NULL != session; session =
session->next)
+ {
notify_session_monitor (plugin,
session,
+ GNUNET_TRANSPORT_SS_INIT);
+ notify_session_monitor (plugin,
+ session,
GNUNET_TRANSPORT_SS_UP);
+ }
sic (sic_cls, NULL, NULL);
}
}
Modified: gnunet/src/transport/transport.h
===================================================================
--- gnunet/src/transport/transport.h 2014-11-03 13:36:49 UTC (rev 34400)
+++ gnunet/src/transport/transport.h 2014-11-07 16:33:42 UTC (rev 34401)
@@ -644,6 +644,11 @@
struct GNUNET_PeerIdentity peer;
/**
+ * Unique identifier for the session.
+ */
+ uint64_t session_id;
+
+ /**
* Length of the plugin name in bytes, including 0-termination.
*/
uint16_t plugin_name_len GNUNET_PACKED;
Modified: gnunet/src/transport/transport_api_monitor_peers.c
===================================================================
--- gnunet/src/transport/transport_api_monitor_peers.c 2014-11-03 13:36:49 UTC
(rev 34400)
+++ gnunet/src/transport/transport_api_monitor_peers.c 2014-11-07 16:33:42 UTC
(rev 34401)
@@ -167,7 +167,7 @@
/**
* Function called with responses from the service.
*
- * @param cls our `struct GNUNET_TRANSPORT_PeerAddressLookupContext *`
+ * @param cls our `struct GNUNET_TRANSPORT_PeerMonitoringContext *`
* @param msg NULL on timeout or error, otherwise presumably a
* message with the human-readable address
*/
@@ -203,7 +203,7 @@
/**
* Task run to re-establish the connection.
*
- * @param cls our `struct GNUNET_TRANSPORT_PeerAddressLookupContext *`
+ * @param cls our `struct GNUNET_TRANSPORT_PeerMonitoringContext *`
* @param tc scheduler context, unused
*/
static void
@@ -423,7 +423,7 @@
struct GNUNET_CLIENT_Connection *client;
client = GNUNET_CLIENT_connect ("transport", cfg);
- if (client == NULL)
+ if (NULL == client)
return NULL;
if (GNUNET_YES != one_shot)
timeout = GNUNET_TIME_UNIT_FOREVER_REL;
Added: gnunet/src/transport/transport_api_monitor_plugins.c
===================================================================
--- gnunet/src/transport/transport_api_monitor_plugins.c
(rev 0)
+++ gnunet/src/transport/transport_api_monitor_plugins.c 2014-11-07
16:33:42 UTC (rev 34401)
@@ -0,0 +1,434 @@
+/*
+ This file is part of GNUnet.
+ (C) 2014 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 transport/transport_api_monitor_plugins.c
+ * @brief montoring api for transport plugin session status
+ */
+#include "platform.h"
+#include "gnunet_util_lib.h"
+#include "gnunet_arm_service.h"
+#include "gnunet_hello_lib.h"
+#include "gnunet_protocols.h"
+#include "gnunet_transport_service.h"
+#include "transport.h"
+
+
+/**
+ * Handle for a plugin session state monitor.
+ */
+struct GNUNET_TRANSPORT_PluginMonitor
+{
+
+ /**
+ * Connection to the service.
+ */
+ struct GNUNET_CLIENT_Connection *client;
+
+ /**
+ * Our configuration.
+ */
+ const struct GNUNET_CONFIGURATION_Handle *cfg;
+
+ /**
+ * Callback to call.
+ */
+ GNUNET_TRANSPORT_SessionMonitorCallback cb;
+
+ /**
+ * Closure for @e cb
+ */
+ void *cb_cls;
+
+ /**
+ * Map of session_ids (reduced to 32-bits) to
+ * `struct GNUNET_TRANSPORT_PluginSession` objects.
+ */
+ struct GNUNET_CONTAINER_MultiHashMap32 *sessions;
+
+ /**
+ * Backoff for reconnect.
+ */
+ struct GNUNET_TIME_Relative backoff;
+
+ /**
+ * Task ID for reconnect.
+ */
+ GNUNET_SCHEDULER_TaskIdentifier reconnect_task;
+
+};
+
+
+/**
+ * Abstract representation of a plugin's session.
+ * Corresponds to the `struct Session` within the TRANSPORT service.
+ */
+struct GNUNET_TRANSPORT_PluginSession
+{
+ /**
+ * Unique session identifier.
+ */
+ uint64_t session_id;
+
+ /**
+ * Location for the client to store "data".
+ */
+ void *client_ctx;
+};
+
+
+/**
+ * Function called with responses from the service.
+ *
+ * @param cls our `struct GNUNET_TRANSPORT_PluginMonitor *`
+ * @param msg NULL on timeout or error, otherwise presumably a
+ * message with the human-readable address
+ */
+static void
+response_processor (void *cls,
+ const struct GNUNET_MessageHeader *msg);
+
+
+/**
+ * Send our subscription request to the service.
+ *
+ * @param pal_ctx our context
+ */
+static void
+send_plugin_mon_request (struct GNUNET_TRANSPORT_PluginMonitor *pm)
+{
+ struct GNUNET_MessageHeader msg;
+
+ msg.size = htons (sizeof (struct GNUNET_MessageHeader));
+ msg.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_PLUGIN_START);
+ GNUNET_assert (GNUNET_OK ==
+ GNUNET_CLIENT_transmit_and_get_response (pm->client,
+ &msg,
+
GNUNET_TIME_UNIT_FOREVER_REL,
+ GNUNET_YES,
+ &response_processor,
+ pm));
+}
+
+
+/**
+ * Task run to re-establish the connection.
+ *
+ * @param cls our `struct GNUNET_TRANSPORT_PluginMonitor *`
+ * @param tc scheduler context, unused
+ */
+static void
+do_plugin_connect (void *cls,
+ const struct GNUNET_SCHEDULER_TaskContext *tc)
+{
+ struct GNUNET_TRANSPORT_PluginMonitor *pm = cls;
+
+ pm->reconnect_task = GNUNET_SCHEDULER_NO_TASK;
+ pm->client = GNUNET_CLIENT_connect ("transport", pm->cfg);
+ GNUNET_assert (NULL != pm->client);
+ send_plugin_mon_request (pm);
+}
+
+
+/**
+ * Free the session entry and notify the callback about its demise.
+ *
+ * @param cls our `struct GNUNET_TRANSPORT_PluginMonitor`
+ * @param key key of the session in the map
+ * @param value the session to free
+ * @return #GNUNET_OK (continue to iterate)
+ */
+static int
+free_entry (void *cls,
+ uint32_t key,
+ void *value)
+{
+ struct GNUNET_TRANSPORT_PluginMonitor *pm = cls;
+ struct GNUNET_TRANSPORT_PluginSession *ps = value;
+
+ pm->cb (pm->cb_cls,
+ ps,
+ &ps->client_ctx,
+ NULL);
+ GNUNET_break (GNUNET_YES ==
+ GNUNET_CONTAINER_multihashmap32_remove (pm->sessions,
+ key,
+ ps));
+ GNUNET_break (NULL == ps->client_ctx);
+ GNUNET_free (ps);
+ return GNUNET_OK;
+}
+
+
+/**
+ * We got disconnected, remove all existing entries from
+ * the map and notify client.
+ *
+ * @param pm montitor that got disconnected
+ */
+static void
+clear_map (struct GNUNET_TRANSPORT_PluginMonitor *pm)
+{
+ GNUNET_CONTAINER_multihashmap32_iterate (pm->sessions,
+ &free_entry,
+ pm);
+}
+
+
+/**
+ * Cut the existing connection and reconnect.
+ *
+ * @param pm our context
+ */
+static void
+reconnect_plugin_ctx (struct GNUNET_TRANSPORT_PluginMonitor *pm)
+{
+ GNUNET_CLIENT_disconnect (pm->client);
+ pm->client = NULL;
+ clear_map (pm);
+ pm->backoff = GNUNET_TIME_STD_BACKOFF (pm->backoff);
+ pm->reconnect_task = GNUNET_SCHEDULER_add_delayed (pm->backoff,
+ &do_plugin_connect,
+ pm);
+}
+
+
+/**
+ * Convert 64-bit session ID to 32-bit index for hash map.
+ *
+ * @param id 64-bit session ID
+ * @return 32-bit hash map index
+ */
+static uint32_t
+wrap_id (uint64_t id)
+{
+ return ((uint32_t) id) ^ ((uint32_t) (id >> 32));
+}
+
+
+/**
+ * Context for #locate_by_id().
+ */
+struct SearchContext
+{
+
+ /**
+ * Result.
+ */
+ struct GNUNET_TRANSPORT_PluginSession *ps;
+
+ /**
+ * ID to locate.
+ */
+ uint64_t session_id;
+
+};
+
+
+/**
+ * Locate a session entry.
+ *
+ * @param cls our `struct SearchContext`
+ * @param key key of the session in the map
+ * @param value a session
+ * @return #GNUNET_OK (continue to iterate), or #GNUNET_SYSERR (match found)
+ */
+static int
+locate_by_id (void *cls,
+ uint32_t key,
+ void *value)
+{
+ struct SearchContext *sc = cls;
+ struct GNUNET_TRANSPORT_PluginSession *ps = value;
+
+ if (sc->session_id == ps->session_id)
+ {
+ sc->ps = ps;
+ return GNUNET_SYSERR;
+ }
+ return GNUNET_OK;
+}
+
+
+/**
+ * Function called with responses from the service.
+ *
+ * @param cls our `struct GNUNET_TRANSPORT_PluginMonitor *`
+ * @param msg NULL on timeout or error, otherwise presumably a
+ * message with the human-readable address
+ */
+static void
+response_processor (void *cls,
+ const struct GNUNET_MessageHeader *msg)
+{
+ struct GNUNET_TRANSPORT_PluginMonitor *pm = cls;
+ const struct TransportPluginMonitorMessage *tpmm;
+ struct GNUNET_TRANSPORT_PluginSession *ps;
+ const char *pname;
+ const void *paddr;
+ enum GNUNET_TRANSPORT_SessionState ss;
+ size_t pname_len;
+ size_t paddr_len;
+ struct GNUNET_TRANSPORT_SessionInfo info;
+ struct GNUNET_HELLO_Address addr;
+ struct SearchContext rv;
+
+ if (NULL == msg)
+ {
+ reconnect_plugin_ctx (pm);
+ return;
+ }
+ if ( (GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_PLUGIN_EVENT != ntohs
(msg->type)) ||
+ (sizeof (struct TransportPluginMonitorMessage) > ntohs (msg->size)) )
+ {
+ GNUNET_break (0);
+ reconnect_plugin_ctx (pm);
+ return;
+ }
+ tpmm = (const struct TransportPluginMonitorMessage *) msg;
+ pname = (const char *) &tpmm[1];
+ pname_len = ntohs (tpmm->plugin_name_len);
+ paddr_len = ntohs (tpmm->plugin_address_len);
+ if ( (pname_len +
+ paddr_len +
+ sizeof (struct TransportPluginMonitorMessage) != ntohs (msg->size)) ||
+ ( (0 != pname_len) &&
+ ('\0' != pname[pname_len - 1]) ) )
+ {
+ GNUNET_break (0);
+ reconnect_plugin_ctx (pm);
+ return;
+ }
+ paddr = &pname[pname_len];
+ ps = NULL;
+ ss = (enum GNUNET_TRANSPORT_SessionState) ntohs (tpmm->session_state);
+ if (GNUNET_TRANSPORT_SS_INIT == ss)
+ {
+ ps = GNUNET_new (struct GNUNET_TRANSPORT_PluginSession);
+ ps->session_id = tpmm->session_id;
+ (void) GNUNET_CONTAINER_multihashmap32_put (pm->sessions,
+ wrap_id (tpmm->session_id),
+ ps,
+
GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
+
+ }
+ else
+ {
+ rv.session_id = tpmm->session_id;
+ rv.ps = NULL;
+ (void) GNUNET_CONTAINER_multihashmap32_get_multiple (pm->sessions,
+ wrap_id
(tpmm->session_id),
+ &locate_by_id,
+ &rv);
+ ps = rv.ps;
+ if (NULL == ps)
+ {
+ GNUNET_break (0);
+ reconnect_plugin_ctx (pm);
+ return;
+ }
+ }
+ info.state = ss;
+ info.is_inbound = (int16_t) ntohs (tpmm->is_inbound);
+ info.num_msg_pending = ntohl (tpmm->msgs_pending);
+ info.num_bytes_pending = ntohl (tpmm->bytes_pending);
+ info.receive_delay = GNUNET_TIME_absolute_ntoh (tpmm->delay);
+ info.session_timeout = GNUNET_TIME_absolute_ntoh (tpmm->timeout);
+ info.address = &addr;
+ addr.peer = tpmm->peer;
+ addr.address = (0 == paddr_len) ? NULL : paddr;
+ addr.address_length = paddr_len;
+ addr.transport_name = (0 == pname_len) ? NULL : pname;
+ addr.local_info = GNUNET_HELLO_ADDRESS_INFO_NONE;
+ pm->cb (pm->cb_cls,
+ ps,
+ &ps->client_ctx,
+ &info);
+
+ if (GNUNET_TRANSPORT_SS_DONE == ss)
+ {
+ GNUNET_break (NULL == ps->client_ctx);
+ GNUNET_assert (GNUNET_YES ==
+ GNUNET_CONTAINER_multihashmap32_remove (pm->sessions,
+ wrap_id
(tpmm->session_id),
+ ps));
+ GNUNET_free (ps);
+ }
+}
+
+
+/**
+ * Install a plugin session state monitor callback. The callback
+ * will be notified whenever the session changes.
+ *
+ * @param cfg configuration to use
+ * @param cb callback to invoke on events
+ * @param cb_cls closure for @a cb
+ * @return NULL on error, otherwise handle for cancellation
+ */
+struct GNUNET_TRANSPORT_PluginMonitor *
+GNUNET_TRANSPORT_monitor_plugins (const struct GNUNET_CONFIGURATION_Handle
*cfg,
+ GNUNET_TRANSPORT_SessionMonitorCallback cb,
+ void *cb_cls)
+{
+ struct GNUNET_TRANSPORT_PluginMonitor *pm;
+ struct GNUNET_CLIENT_Connection *client;
+
+ client = GNUNET_CLIENT_connect ("transport", cfg);
+ if (NULL == client)
+ return NULL;
+ pm = GNUNET_new (struct GNUNET_TRANSPORT_PluginMonitor);
+ pm->cb = cb;
+ pm->cb_cls = cb_cls;
+ pm->cfg = cfg;
+ pm->client = client;
+ send_plugin_mon_request (pm);
+ return pm;
+}
+
+
+/**
+ * Cancel monitoring the plugin session state. The callback will
+ * be called once for each session that is up with the information
+ * #GNUNET_TRANSPORT_SS_FINI (even though the session may stay up;
+ * this is just to enable client-side cleanup).
+ *
+ * @param pm handle of the request that is to be cancelled
+ */
+void
+GNUNET_TRANSPORT_monitor_plugins_cancel (struct GNUNET_TRANSPORT_PluginMonitor
*pm)
+{
+ if (NULL != pm->client)
+ {
+ GNUNET_CLIENT_disconnect (pm->client);
+ pm->client = NULL;
+ }
+ if (GNUNET_SCHEDULER_NO_TASK != pm->reconnect_task)
+ {
+ GNUNET_SCHEDULER_cancel (pm->reconnect_task);
+ pm->reconnect_task = GNUNET_SCHEDULER_NO_TASK;
+ }
+ clear_map (pm);
+ GNUNET_CONTAINER_multihashmap32_destroy (pm->sessions);
+ GNUNET_free (pm);
+}
+
+
+/* end of transport_api_monitor_plugins.c */
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r34401 - in gnunet: m4 po src/include src/transport,
gnunet <=