gnunet-daemon-latency-logger.c File Reference

log latency values from neighbour connections into an SQLite database More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_ats_service.h"
#include <sqlite3.h>

Include dependency graph for gnunet-daemon-latency-logger.c:

Go to the source code of this file.

Data Structures
struct	Entry
	Entry type to be used in the map to store old latency values. More...

Macros
#define	LOG(type, ...)   GNUNET_log (type, __VA_ARGS__)
	Logging shorthand. More...
#define	DEBUG(...)   LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__)
	Debug logging shorthand. More...
#define	LOG_SQLITE(db, msg, level, cmd)
	Log an error message at log-level 'level' that indicates a failure of the command 'cmd' on file 'filename' with the message given by strerror(errno). More...

Functions
static int	free_iterator (void *cls, const struct GNUNET_PeerIdentity *key, void *value)
	Iterator over hash map entries. More...
static void	do_shutdown (void *cls)
	Shutdown. More...
static void	addr_info_cb (void *cls, const struct GNUNET_HELLO_Address *address, int address_active, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in, const struct GNUNET_ATS_Properties *prop)
	Signature of a function that is called with QoS information about an address. More...
static void	run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *c)
	Main function that will be run. More...
int	main (int argc, char *const *argv)
	Execution entry point. More...

Variables
static struct GNUNET_CONTAINER_MultiPeerMap *	map
	Handle to the map used to store old latency values for peers. More...
static struct sqlite3 *	db
	The SQLite database handle. More...
static struct GNUNET_ATS_PerformanceHandle *	ats
	Handle to the ATS performance subsystem. More...
static struct sqlite3_stmt *	stmt_insert
	Prepared statement for inserting values into the database table. More...

Detailed Description

log latency values from neighbour connections into an SQLite database

Author

Sree Harsha Totakura sreeh.nosp@m.arsh.nosp@m.a@tot.nosp@m.akur.nosp@m.a.in

Definition in file gnunet-daemon-latency-logger.c.

Macro Definition Documentation

LOG

#define LOG	(		type,
			...
	)		GNUNET_log (type, __VA_ARGS__)

Logging shorthand.

Definition at line 36 of file gnunet-daemon-latency-logger.c.

Referenced by run().

DEBUG

#define DEBUG

(

...

)

LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__)

Debug logging shorthand.

Definition at line 42 of file gnunet-daemon-latency-logger.c.

Referenced by run().

LOG_SQLITE

#define LOG_SQLITE	(		db,
			msg,
			level,
			cmd
	)

Value:

do {                                                                  \
    GNUNET_log_from (level, "sqlite", _ ( \
                       "`%s' failed at %s:%d with error: %s\n"), \
                     cmd, __FILE__, __LINE__, sqlite3_errmsg (db));  \
    if (msg != NULL)                                                    \
      GNUNET_asprintf (msg, _ ("`%s' failed at %s:%u with error: %s"), cmd, \
                       __FILE__, __LINE__, sqlite3_errmsg (db));     \
  } while (0)

Log an error message at log-level 'level' that indicates a failure of the command 'cmd' on file 'filename' with the message given by strerror(errno).

Definition at line 50 of file gnunet-daemon-latency-logger.c.

Referenced by addr_info_cb(), and run().

Function Documentation

do_shutdown()

static void do_shutdown ( void *  cls )

static

Shutdown.

Parameters

cls

NULL

Returns

Definition at line 132 of file gnunet-daemon-latency-logger.c.

References db, free_iterator(), GNUNET_assert, GNUNET_ATS_performance_done(), GNUNET_break, GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_SYSERR, and stmt_insert.

Referenced by run().

{
  GNUNET_ATS_performance_done (ats);
  ats = NULL;
  if (NULL != stmt_insert)
  {
    sqlite3_finalize (stmt_insert);
    stmt_insert = NULL;
  }
  GNUNET_break (SQLITE_OK == sqlite3_close (db));
  db = NULL;
  if (NULL != map)
  {
    GNUNET_assert (GNUNET_SYSERR !=
                   GNUNET_CONTAINER_multipeermap_iterate (map, free_iterator,
                                                          NULL));
    GNUNET_CONTAINER_multipeermap_destroy (map);
    map = NULL;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

addr_info_cb()

static void addr_info_cb ( void *  cls, const struct GNUNET_HELLO_Address *  address, int  address_active, struct GNUNET_BANDWIDTH_Value32NBO  bandwidth_out, struct GNUNET_BANDWIDTH_Value32NBO  bandwidth_in, const struct GNUNET_ATS_Properties *  prop  )

static

Signature of a function that is called with QoS information about an address.

Parameters

cls	closure
address	the address
address_active	GNUNET_YES if this address is actively used to maintain a connection to a peer; GNUNET_NO if the address is not actively used; GNUNET_SYSERR if this address is no longer available for ATS
bandwidth_out	assigned outbound bandwidth for the connection
bandwidth_in	assigned inbound bandwidth for the connection
prop	performance data for the address (as far as known)

Definition at line 168 of file gnunet-daemon-latency-logger.c.

References db, GNUNET_ATS_Properties::delay, GNUNET_assert, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_CONTAINER_multipeermap_contains(), GNUNET_CONTAINER_multipeermap_get(), GNUNET_CONTAINER_multipeermap_put(), GNUNET_ERROR_TYPE_ERROR, GNUNET_i2s(), GNUNET_new, GNUNET_SCHEDULER_shutdown(), GNUNET_YES, Entry::id, Entry::latency, LOG_SQLITE, GNUNET_HELLO_Address::peer, GNUNET_TIME_Relative::rel_value_us, and stmt_insert.

Referenced by GNUNET_ATS_performance_init(), and run().

{
  static const char *query_insert =
    "INSERT INTO ats_info("
    " id,"
    " val,"
    " timestamp"
    ") VALUES ("
    " ?1,"
    " ?2,"
    " datetime('now')"
    ");";
  struct Entry *entry;
  int latency; /* FIXME: type!? */

  if (NULL == address)
  {
    /* ATS service temporarily disconnected */
    return;
  }

  GNUNET_assert (NULL != db);
  if (GNUNET_YES != address_active)
    return;
  latency = (int) prop->delay.rel_value_us;
  entry = NULL;
  if (GNUNET_YES == GNUNET_CONTAINER_multipeermap_contains (map,
                                                            &address->peer))
  {
    entry = GNUNET_CONTAINER_multipeermap_get (map, &address->peer);
    GNUNET_assert (NULL != entry);
    if (latency == entry->latency)
      return;
  }
  if (NULL == stmt_insert)
  {
    if (SQLITE_OK != sqlite3_prepare_v2 (db, query_insert, -1, &stmt_insert,
                                         NULL))
    {
      LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_prepare_v2");
      goto err_shutdown;
    }
  }
  if ((SQLITE_OK != sqlite3_bind_text (stmt_insert, 1,
                                       GNUNET_i2s (&address->peer), -1,
                                       SQLITE_STATIC)) ||
      (SQLITE_OK != sqlite3_bind_int (stmt_insert, 2, latency)))
  {
    LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_bind_text");
    goto err_shutdown;
  }
  if (SQLITE_DONE != sqlite3_step (stmt_insert))
  {
    LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_step");
    goto err_shutdown;
  }
  if (SQLITE_OK != sqlite3_reset (stmt_insert))
  {
    LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite3_insert");
    goto err_shutdown;
  }
  if (NULL == entry)
  {
    entry = GNUNET_new (struct Entry);
    entry->id = address->peer;
    GNUNET_CONTAINER_multipeermap_put (map,
                                       &entry->id, entry,
                                       GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST);
  }
  entry->latency = latency;
  return;

err_shutdown:
  GNUNET_SCHEDULER_shutdown ();
}

Here is the call graph for this function:

Here is the caller graph for this function:

run()

static void run ( void *  cls, char *const *  args, const char *  cfgfile, const struct GNUNET_CONFIGURATION_Handle *  c  )

static

Main function that will be run.

Parameters

cls	closure
args	remaining command-line arguments
cfgfile	name of the configuration file used (for saving, can be NULL!)
c	configuration

Definition at line 259 of file gnunet-daemon-latency-logger.c.

References addr_info_cb(), db, DEBUG, do_shutdown(), GNUNET_ATS_performance_init(), GNUNET_break, GNUNET_CONFIGURATION_get_value_filename(), GNUNET_CONTAINER_multipeermap_create(), GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_OK, GNUNET_SCHEDULER_add_shutdown(), GNUNET_YES, LOG, and LOG_SQLITE.

Referenced by main().

{
  const char *query_create =
    "CREATE TABLE ats_info ("
    "id TEXT,"
    "val INTEGER,"
    "timestamp NUMERIC"
    ");";
  char *dbfile;

  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_filename (c, "LATENCY-LOGGER",
                                                            "DBFILE",
                                                            &dbfile))
  {
    GNUNET_break (0);
    return;
  }
  if (SQLITE_OK != sqlite3_open (dbfile, &db))
  {
    if (NULL != db)
    {
      LOG_SQLITE (db, NULL, GNUNET_ERROR_TYPE_ERROR, "sqlite_open_v2");
      GNUNET_break (SQLITE_OK == sqlite3_close (db));
    }
    else
      LOG (GNUNET_ERROR_TYPE_ERROR, "Cannot open sqlite file %s\n", dbfile);
    GNUNET_free (dbfile);
    return;
  }
  if (0 != sqlite3_exec (db, query_create, NULL, NULL, NULL))
    DEBUG ("SQLite Error: %d.  Perhaps the database `%s' already exits.\n",
           sqlite3_errcode (db), dbfile);
  DEBUG ("Opened database %s\n", dbfile);
  GNUNET_free (dbfile);
  dbfile = NULL;
  ats = GNUNET_ATS_performance_init (c, &addr_info_cb, NULL);
  map = GNUNET_CONTAINER_multipeermap_create (30, GNUNET_YES);
  GNUNET_SCHEDULER_add_shutdown (&do_shutdown, NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main	(	int	argc,
		char *const *	argv
	)

Execution entry point.

Definition at line 305 of file gnunet-daemon-latency-logger.c.

References _, GNUNET_free, GNUNET_GETOPT_OPTION_END, GNUNET_OK, GNUNET_PROGRAM_run(), GNUNET_STRINGS_get_utf8_args(), ret, and run().

{
  static const struct GNUNET_GETOPT_CommandLineOption options[] = {
    GNUNET_GETOPT_OPTION_END
  };
  int ret;

  if (GNUNET_OK != GNUNET_STRINGS_get_utf8_args (argc, argv, &argc, &argv))
    return 2;
  ret =
    (GNUNET_OK ==
     GNUNET_PROGRAM_run (argc, argv, "gnunet-daemon-latency-logger",
                         _ (
                           "Daemon to log latency values of connections to neighbours"),
                         options, &run, NULL)) ? 0 : 1;
  GNUNET_free ((void *) argv);
  return ret;
}

Here is the call graph for this function:

Variable Documentation

map

struct GNUNET_CONTAINER_MultiPeerMap* map

static

Handle to the map used to store old latency values for peers.

Definition at line 82 of file gnunet-daemon-latency-logger.c.

Referenced by add_to_meta_counter(), check_unique(), GNUNET_CONTAINER_multihashmap32_iterator_create(), GNUNET_CONTAINER_multihashmap_iterator_create(), GNUNET_CONTAINER_multipeermap_create(), GNUNET_CONTAINER_multipeermap_iterator_create(), GNUNET_CONTAINER_multishortmap_create(), GNUNET_CONTAINER_multishortmap_iterator_create(), GNUNET_CONTAINER_multiuuidmap_create(), GNUNET_CONTAINER_multiuuidmap_iterator_create(), GNUNET_TIME_absolute_get_monotonic(), handle_connection_create(), on_appsink_new_sample(), opc_free_iterator(), remove_all(), and run().

db

struct sqlite3* db

static

The SQLite database handle.

Definition at line 87 of file gnunet-daemon-latency-logger.c.

Referenced by addr_info_cb(), do_shutdown(), and run().

ats

struct GNUNET_ATS_PerformanceHandle* ats

static

Handle to the ATS performance subsystem.

Definition at line 92 of file gnunet-daemon-latency-logger.c.

stmt_insert

struct sqlite3_stmt* stmt_insert

static

Prepared statement for inserting values into the database table.

Definition at line 97 of file gnunet-daemon-latency-logger.c.

Referenced by addr_info_cb(), and do_shutdown().