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 130 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 164 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 255 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 301 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 80 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(), mlp_free_peers(), on_appsink_new_sample(), opc_free_iterator(), remove_all(), and run().

db

struct sqlite3* db

static

The SQLite database handle.

Definition at line 85 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 90 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 95 of file gnunet-daemon-latency-logger.c.

Referenced by addr_info_cb(), and do_shutdown().