plugin_datastore_mysql.c File Reference

mysql-based datastore backend More...

#include "platform.h"
#include "gnunet_datastore_plugin.h"
#include "gnunet_util_lib.h"
#include "gnunet_mysql_lib.h"
#include "gnunet_my_lib.h"

Include dependency graph for plugin_datastore_mysql.c:

Go to the source code of this file.

Data Structures
struct	Plugin
	Handle for a plugin. More...
struct	ReplCtx
	Context for repl_proc() function. More...
struct	ExpiCtx
	Context for expi_proc() function. More...

Macros
#define	MAX_DATUM_SIZE   65536
#define	INSERT_ENTRY   "INSERT INTO gn090 (repl,type,prio,anonLevel,expire,rvalue,hash,vhash,value) VALUES (?,?,?,?,?,?,?,?,?)"
	Prepared statements. More...
#define	DELETE_ENTRY_BY_UID   "DELETE FROM gn090 WHERE uid=?"
#define	DELETE_ENTRY_BY_HASH_VALUE
#define	RESULT_COLUMNS   "repl, type, prio, anonLevel, expire, hash, value, uid"
#define	SELECT_ENTRY
#define	SELECT_ENTRY_BY_HASH
#define	SELECT_ENTRY_BY_HASH_AND_TYPE
#define	UPDATE_ENTRY
#define	DEC_REPL   "UPDATE gn090 SET repl=GREATEST (1, repl) - 1 WHERE uid=?"
#define	SELECT_SIZE   "SELECT SUM(LENGTH(value)+256) FROM gn090"
#define	SELECT_IT_NON_ANONYMOUS
#define	SELECT_IT_EXPIRATION
#define	SELECT_IT_PRIORITY
#define	SELECT_IT_REPLICATION
#define	SELECT_MAX_REPL   "SELECT MAX(repl) FROM gn090"
#define	GET_ALL_KEYS   "SELECT hash from gn090"
#define	MAX_PARAM   16
#define	MRUNS(a)   (GNUNET_OK != GNUNET_MYSQL_statement_run (plugin->mc, a))
#define	PINIT(a, b)

Functions
static int	do_delete_entry (struct Plugin *plugin, unsigned long long uid)
	Delete an entry from the gn090 table. More...
static void	mysql_plugin_estimate_size (void *cls, unsigned long long *estimate)
	Get an estimate of how much space the database is currently using. More...
static void	mysql_plugin_put (void *cls, const struct GNUNET_HashCode *key, bool absent, uint32_t size, const void *data, enum GNUNET_BLOCK_Type type, uint32_t priority, uint32_t anonymity, uint32_t replication, struct GNUNET_TIME_Absolute expiration, PluginPutCont cont, void *cont_cls)
	Store an item in the datastore. More...
static void	execute_select (struct Plugin *plugin, struct GNUNET_MYSQL_StatementHandle *stmt, PluginDatumProcessor proc, void *proc_cls, struct GNUNET_MY_QueryParam *params_select)
	Run the given select statement and call 'proc' on the resulting values (which must be in particular positions). More...
static void	mysql_plugin_get_key (void *cls, uint64_t next_uid, bool random, const struct GNUNET_HashCode *key, enum GNUNET_BLOCK_Type type, PluginDatumProcessor proc, void *proc_cls)
	Get one of the results for a particular key in the datastore. More...
static void	mysql_plugin_get_zero_anonymity (void *cls, uint64_t next_uid, enum GNUNET_BLOCK_Type type, PluginDatumProcessor proc, void *proc_cls)
	Get a zero-anonymity datum from the datastore. More...
static int	repl_proc (void *cls, const struct GNUNET_HashCode *key, uint32_t size, const void *data, enum GNUNET_BLOCK_Type type, uint32_t priority, uint32_t anonymity, uint32_t replication, struct GNUNET_TIME_Absolute expiration, uint64_t uid)
	Wrapper for the processor for mysql_plugin_get_replication(). More...
static void	mysql_plugin_get_replication (void *cls, PluginDatumProcessor proc, void *proc_cls)
	Get a random item for replication. More...
static void	mysql_plugin_get_keys (void *cls, PluginKeyProcessor proc, void *proc_cls)
	Get all of the keys in the datastore. More...
static int	expi_proc (void *cls, const struct GNUNET_HashCode *key, uint32_t size, const void *data, enum GNUNET_BLOCK_Type type, uint32_t priority, uint32_t anonymity, uint32_t replication, struct GNUNET_TIME_Absolute expiration, uint64_t uid)
	Wrapper for the processor for mysql_plugin_get_expiration(). More...
static void	mysql_plugin_get_expiration (void *cls, PluginDatumProcessor proc, void *proc_cls)
	Get a random item for expiration. More...
static void	mysql_plugin_drop (void *cls)
	Drop database. More...
static void	mysql_plugin_remove_key (void *cls, const struct GNUNET_HashCode *key, uint32_t size, const void *data, PluginRemoveCont cont, void *cont_cls)
	Remove a particular key in the datastore. More...
void *	libgnunet_plugin_datastore_mysql_init (void *cls)
	Entry point for the plugin. More...
void *	libgnunet_plugin_datastore_mysql_done (void *cls)
	Exit point from the plugin. More...

Detailed Description

mysql-based datastore backend

Author

Igor Wronsky

Christian Grothoff

Christophe Genevey

NOTE: This db module does NOT work with mysql prior to 4.1 since it uses prepared statements. MySQL 5.0.46 promises to fix a bug in MyISAM that is causing us grief. At the time of this writing, that version is yet to be released. In anticipation, the code will use MyISAM with 5.0.46 (and higher). If you run such a version, please run "make check" to verify that the MySQL bug was actually fixed in your version (and if not, change the code below to use MyISAM for gn071).

HIGHLIGHTS

Pros

• On up-to-date hardware where mysql can be used comfortably, this module will have better performance than the other db choices (according to our tests).
• Its often possible to recover the mysql database from internal inconsistencies. The other db choices do not support repair! Cons
• Memory usage (Comment: "I have 1G and it never caused me trouble")
• Manual setup

MANUAL SETUP INSTRUCTIONS

1) in gnunet.conf, set

    [datastore]
    DATABASE = "mysql"

2) Then access mysql as root,

  $ mysql -u root -p

and do the following. [You should replace $USER with the username that will be running the gnunetd process].

   CREATE DATABASE gnunet;
   GRANT select,insert,update,delete,create,alter,drop,create temporary tables
      ON gnunet.* TO $USER@localhost;
   SET PASSWORD FOR $USER@localhost=PASSWORD('$the_password_you_like');
   FLUSH PRIVILEGES;

3) In the $HOME directory of $USER, create a ".my.cnf" file with the following lines

   [client]
   user=$USER
   password=$the_password_you_like

That's it. Note that .my.cnf file is a security risk unless its on a safe partition etc. The $HOME/.my.cnf can of course be a symbolic link. Even greater security risk can be achieved by setting no password for $USER. Luckily $USER has only privileges to mess up GNUnet's tables, nothing else (unless you give them more, of course).

4) Still, perhaps you should briefly try if the DB connection works. First, login as $USER. Then use,

  $ mysql -u $USER -p $the_password_you_like
  mysql> use gnunet;

If you get the message "Database changed" it probably works.

[If you get "ERROR 2002: Can't connect to local MySQL server through socket '/tmp/mysql.sock' (2)" it may be resolvable by "ln -s /var/run/mysqld/mysqld.sock /tmp/mysql.sock" so there may be some additional trouble depending on your mysql setup.]

REPAIRING TABLES

• Its probably healthy to check your tables for inconsistencies every now and then.
• If you get odd SEGVs on gnunetd startup, it might be that the mysql databases have been corrupted.
• The tables can be verified/fixed in two ways; 1) by running mysqlcheck -A, or 2) by executing (inside of mysql using the GNUnet database):

    mysql> REPAIR TABLE gn090;
  

PROBLEMS?

If you have problems related to the mysql module, your best friend is probably the mysql manual. The first thing to check is that mysql is basically operational, that you can connect to it, create tables, issue queries etc.

Definition in file plugin_datastore_mysql.c.

Macro Definition Documentation

MAX_DATUM_SIZE

#define MAX_DATUM_SIZE   65536

Definition at line 126 of file plugin_datastore_mysql.c.

Referenced by execute_select(), and mysql_plugin_put().

INSERT_ENTRY

#define INSERT_ENTRY   "INSERT INTO gn090 (repl,type,prio,anonLevel,expire,rvalue,hash,vhash,value) VALUES (?,?,?,?,?,?,?,?,?)"

Prepared statements.

Definition at line 147 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

DELETE_ENTRY_BY_UID

#define DELETE_ENTRY_BY_UID   "DELETE FROM gn090 WHERE uid=?"

Definition at line 151 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

DELETE_ENTRY_BY_HASH_VALUE

#define DELETE_ENTRY_BY_HASH_VALUE

Value:

"DELETE FROM gn090 " \
  "WHERE hash = ? AND " \
  "value = ? " \
  "LIMIT 1"

Definition at line 154 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

RESULT_COLUMNS

#define RESULT_COLUMNS   "repl, type, prio, anonLevel, expire, hash, value, uid"

Definition at line 160 of file plugin_datastore_mysql.c.

SELECT_ENTRY

#define SELECT_ENTRY

Value:

"SELECT " RESULT_COLUMNS " FROM gn090 " \
  "WHERE uid >= ? AND " \
  "(rvalue >= ? OR 0 = ?) " \
  "ORDER BY uid LIMIT 1"

Definition at line 162 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

SELECT_ENTRY_BY_HASH

#define SELECT_ENTRY_BY_HASH

Value:

"SELECT " RESULT_COLUMNS " FROM gn090 " \
  "FORCE INDEX (idx_hash_type_uid) " \
  "WHERE hash=? AND " \
  "uid >= ? AND " \
  "(rvalue >= ? OR 0 = ?) " \
  "ORDER BY uid LIMIT 1"

Definition at line 168 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

SELECT_ENTRY_BY_HASH_AND_TYPE

#define SELECT_ENTRY_BY_HASH_AND_TYPE

Value:

"SELECT " RESULT_COLUMNS " FROM gn090 " \
  "FORCE INDEX (idx_hash_type_uid) " \
  "WHERE hash = ? AND " \
  "type = ? AND " \
  "uid >= ? AND " \
  "(rvalue >= ? OR 0 = ?) " \
  "ORDER BY uid LIMIT 1"

Definition at line 176 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

UPDATE_ENTRY

#define UPDATE_ENTRY

Value:

"UPDATE gn090 SET " \
  "prio = prio + ?, " \
  "repl = repl + ?, " \
  "expire = GREATEST(expire, ?) " \
  "WHERE hash = ? AND vhash = ?"

Definition at line 185 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

DEC_REPL

#define DEC_REPL   "UPDATE gn090 SET repl=GREATEST (1, repl) - 1 WHERE uid=?"

Definition at line 192 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

SELECT_SIZE

#define SELECT_SIZE   "SELECT SUM(LENGTH(value)+256) FROM gn090"

Definition at line 195 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

SELECT_IT_NON_ANONYMOUS

#define SELECT_IT_NON_ANONYMOUS

Value:

"SELECT " RESULT_COLUMNS " FROM gn090 " \
  "FORCE INDEX (idx_anonLevel_type_rvalue) " \
  "WHERE anonLevel=0 AND " \
  "type=? AND " \
  "uid >= ? " \
  "ORDER BY uid LIMIT 1"

Definition at line 198 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

SELECT_IT_EXPIRATION

#define SELECT_IT_EXPIRATION

Value:

"SELECT " RESULT_COLUMNS " FROM gn090 " \
  "FORCE INDEX (idx_expire) " \
  "WHERE expire < ? " \
  "ORDER BY expire ASC LIMIT 1"

Definition at line 206 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

SELECT_IT_PRIORITY

#define SELECT_IT_PRIORITY

Value:

"SELECT " RESULT_COLUMNS " FROM gn090 " \
  "FORCE INDEX (idx_prio) " \
  "ORDER BY prio ASC LIMIT 1"

Definition at line 212 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

SELECT_IT_REPLICATION

#define SELECT_IT_REPLICATION

Value:

"SELECT " RESULT_COLUMNS " FROM gn090 " \
  "FORCE INDEX (idx_repl_rvalue) " \
  "WHERE repl=? AND " \
  " (rvalue>=? OR" \
  "  NOT EXISTS (SELECT 1 FROM gn090 FORCE INDEX (idx_repl_rvalue) WHERE repl=? AND rvalue>=?)) " \
  "ORDER BY rvalue ASC " \
  "LIMIT 1"

Definition at line 217 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

SELECT_MAX_REPL

#define SELECT_MAX_REPL   "SELECT MAX(repl) FROM gn090"

Definition at line 226 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init().

GET_ALL_KEYS

#define GET_ALL_KEYS   "SELECT hash from gn090"

Definition at line 229 of file plugin_datastore_mysql.c.

Referenced by libgnunet_plugin_datastore_mysql_init(), and mysql_plugin_get_keys().

MAX_PARAM

#define MAX_PARAM   16

Definition at line 233 of file plugin_datastore_mysql.c.

MRUNS

#define MRUNS

(

a

)

(GNUNET_OK != GNUNET_MYSQL_statement_run (plugin->mc, a))

Referenced by libgnunet_plugin_datastore_mysql_init().

PINIT

#define PINIT	(		a,
			b
	)

Value:

(NULL == (a = GNUNET_MYSQL_statement_prepare (plugin->mc, \
                                                                  b)))

Referenced by libgnunet_plugin_datastore_mysql_init().

Function Documentation

do_delete_entry()

static int do_delete_entry ( struct Plugin *  plugin, unsigned long long  uid  )

static

Delete an entry from the gn090 table.

Parameters

plugin	plugin context
uid	unique ID of the entry to delete

Returns

GNUNET_OK on success, GNUNET_NO if no such value exists, GNUNET_SYSERR on error

Definition at line 243 of file plugin_datastore_mysql.c.

References Plugin::delete_entry_by_uid, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_MY_exec_prepared(), GNUNET_MY_query_param_end, GNUNET_MY_query_param_uint64(), GNUNET_OK, Plugin::mc, and ret.

Referenced by execute_select().

{
  int ret;
  uint64_t uid64 = (uint64_t) uid;
  struct GNUNET_MY_QueryParam params_delete[] = {
    GNUNET_MY_query_param_uint64 (&uid64),
    GNUNET_MY_query_param_end
  };

  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Deleting value %llu from gn090 table\n",
              uid);
  ret = GNUNET_MY_exec_prepared (plugin->mc,
                                 plugin->delete_entry_by_uid,
                                 params_delete);
  if (ret >= 0)
  {
    return GNUNET_OK;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
              "Deleting value %llu from gn090 table failed\n",
              (unsigned long long) uid);
  return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_estimate_size()

static void mysql_plugin_estimate_size ( void *  cls, unsigned long long *  estimate  )

static

Get an estimate of how much space the database is currently using.

Parameters

cls	our struct Plugin *

Returns

number of bytes used on disk

Definition at line 278 of file plugin_datastore_mysql.c.

References Plugin::get_size, GNUNET_assert, GNUNET_break, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_MY_exec_prepared(), GNUNET_MY_extract_result(), GNUNET_MY_query_param_end, GNUNET_MY_result_spec_end, GNUNET_MY_result_spec_uint64(), GNUNET_NO, GNUNET_OK, Plugin::mc, plugin, and ret.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;
  uint64_t total;
  int ret;
  struct GNUNET_MY_QueryParam params_get[] = {
    GNUNET_MY_query_param_end
  };
  struct GNUNET_MY_ResultSpec results_get[] = {
    GNUNET_MY_result_spec_uint64 (&total),
    GNUNET_MY_result_spec_end
  };

  ret = GNUNET_MY_exec_prepared (plugin->mc,
                                 plugin->get_size,
                                 params_get);
  *estimate = 0;
  total = UINT64_MAX;
  if ((GNUNET_OK == ret) &&
      (GNUNET_OK ==
       GNUNET_MY_extract_result (plugin->get_size,
                                 results_get)))
  {
    *estimate = (unsigned long long) total;
    GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                "Size estimate for MySQL payload is %lld\n",
                (long long) total);
    GNUNET_assert (UINT64_MAX != total);
    GNUNET_break (GNUNET_NO ==
                  GNUNET_MY_extract_result (plugin->get_size,
                                            NULL));
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_put()

static void mysql_plugin_put ( void *  cls, const struct GNUNET_HashCode *  key, bool  absent, uint32_t  size, const void *  data, enum GNUNET_BLOCK_Type  type, uint32_t  priority, uint32_t  anonymity, uint32_t  replication, struct GNUNET_TIME_Absolute  expiration, PluginPutCont  cont, void *  cont_cls  )

static

Store an item in the datastore.

Parameters

cls	closure
key	key for the item
absent	true if the key was not found in the bloom filter
size	number of bytes in data
data	content stored
type	type of the content
priority	priority of the content
anonymity	anonymity-level for the content
replication	replication-level for the content
expiration	expiration time for the content
cont	continuation called with success or failure status
cont_cls	closure for cont

Definition at line 331 of file plugin_datastore_mysql.c.

References _, GNUNET_TIME_Absolute::abs_value_us, GNUNET_DATACACHE_PluginEnvironment::cls, Plugin::env, GNUNET_break, GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u64(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_MY_exec_prepared(), GNUNET_MY_extract_result(), GNUNET_MY_query_param_auto_from_type, GNUNET_MY_query_param_end, GNUNET_MY_query_param_fixed_size(), GNUNET_MY_query_param_uint32(), GNUNET_MY_query_param_uint64(), GNUNET_MYSQL_statement_get_stmt(), GNUNET_NO, GNUNET_OK, GNUNET_SYSERR, Plugin::insert_entry, MAX_DATUM_SIZE, Plugin::mc, plugin, and Plugin::update_entry.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;
  uint64_t lexpiration = expiration.abs_value_us;
  struct GNUNET_HashCode vhash;

  GNUNET_CRYPTO_hash (data,
                      size,
                      &vhash);
  if (! absent)
  {
    struct GNUNET_MY_QueryParam params_update[] = {
      GNUNET_MY_query_param_uint32 (&priority),
      GNUNET_MY_query_param_uint32 (&replication),
      GNUNET_MY_query_param_uint64 (&lexpiration),
      GNUNET_MY_query_param_auto_from_type (key),
      GNUNET_MY_query_param_auto_from_type (&vhash),
      GNUNET_MY_query_param_end
    };

    if (GNUNET_OK !=
        GNUNET_MY_exec_prepared (plugin->mc,
                                 plugin->update_entry,
                                 params_update))
    {
      cont (cont_cls,
            key,
            size,
            GNUNET_SYSERR,
            _ ("MySQL statement run failure"));
      return;
    }

    MYSQL_STMT *stmt = GNUNET_MYSQL_statement_get_stmt (plugin->update_entry);
    my_ulonglong rows = mysql_stmt_affected_rows (stmt);

    GNUNET_break (GNUNET_NO ==
                  GNUNET_MY_extract_result (plugin->update_entry,
                                            NULL));
    if (0 != rows)
    {
      cont (cont_cls,
            key,
            size,
            GNUNET_NO,
            NULL);
      return;
    }
  }

  uint64_t lrvalue = GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_WEAK,
                                               UINT64_MAX);
  struct GNUNET_MY_QueryParam params_insert[] = {
    GNUNET_MY_query_param_uint32 (&replication),
    GNUNET_MY_query_param_uint32 (&type),
    GNUNET_MY_query_param_uint32 (&priority),
    GNUNET_MY_query_param_uint32 (&anonymity),
    GNUNET_MY_query_param_uint64 (&lexpiration),
    GNUNET_MY_query_param_uint64 (&lrvalue),
    GNUNET_MY_query_param_auto_from_type (key),
    GNUNET_MY_query_param_auto_from_type (&vhash),
    GNUNET_MY_query_param_fixed_size (data, size),
    GNUNET_MY_query_param_end
  };

  if (size > MAX_DATUM_SIZE)
  {
    GNUNET_break (0);
    cont (cont_cls, key, size, GNUNET_SYSERR, _ ("Data too large"));
    return;
  }

  if (GNUNET_OK !=
      GNUNET_MY_exec_prepared (plugin->mc,
                               plugin->insert_entry,
                               params_insert))
  {
    cont (cont_cls,
          key,
          size,
          GNUNET_SYSERR,
          _ ("MySQL statement run failure"));
    return;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Inserted value `%s' with size %u into gn090 table\n",
              GNUNET_h2s (key),
              (unsigned int) size);
  if (size > 0)
    plugin->env->duc (plugin->env->cls,
                      size);
  GNUNET_break (GNUNET_NO ==
                GNUNET_MY_extract_result (plugin->insert_entry,
                                          NULL));
  cont (cont_cls,
        key,
        size,
        GNUNET_OK,
        NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

execute_select()

static void execute_select ( struct Plugin *  plugin, struct GNUNET_MYSQL_StatementHandle *  stmt, PluginDatumProcessor  proc, void *  proc_cls, struct GNUNET_MY_QueryParam *  params_select  )

static

Run the given select statement and call 'proc' on the resulting values (which must be in particular positions).

Parameters

plugin	the plugin handle
stmt	select statement to run
proc	function to call on result
proc_cls	closure for proc
params_select	arguments to initialize stmt

Definition at line 455 of file plugin_datastore_mysql.c.

References anonymity, GNUNET_DATACACHE_PluginEnvironment::cls, do_delete_entry(), Plugin::env, GNUNET_assert, GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_MY_cleanup_result(), GNUNET_MY_exec_prepared(), GNUNET_MY_extract_result(), GNUNET_MY_result_spec_absolute_time(), GNUNET_MY_result_spec_auto_from_type, GNUNET_MY_result_spec_end, GNUNET_MY_result_spec_uint32(), GNUNET_MY_result_spec_uint64(), GNUNET_MY_result_spec_variable_size(), GNUNET_NO, GNUNET_OK, GNUNET_STRINGS_absolute_time_to_string(), GNUNET_TIME_UNIT_ZERO_ABS, MAX_DATUM_SIZE, Plugin::mc, replication, ret, type, and value.

Referenced by expi_proc(), mysql_plugin_get_expiration(), mysql_plugin_get_key(), mysql_plugin_get_replication(), and mysql_plugin_get_zero_anonymity().

{
  int ret;
  uint32_t replication;
  uint32_t type;
  uint32_t priority;
  uint32_t anonymity;
  uint64_t uid;
  size_t value_size;
  void *value;
  struct GNUNET_HashCode key;
  struct GNUNET_TIME_Absolute expiration;
  struct GNUNET_MY_ResultSpec results_select[] = {
    GNUNET_MY_result_spec_uint32 (&replication),
    GNUNET_MY_result_spec_uint32 (&type),
    GNUNET_MY_result_spec_uint32 (&priority),
    GNUNET_MY_result_spec_uint32 (&anonymity),
    GNUNET_MY_result_spec_absolute_time (&expiration),
    GNUNET_MY_result_spec_auto_from_type (&key),
    GNUNET_MY_result_spec_variable_size (&value, &value_size),
    GNUNET_MY_result_spec_uint64 (&uid),
    GNUNET_MY_result_spec_end
  };

  ret = GNUNET_MY_exec_prepared (plugin->mc,
                                 stmt,
                                 params_select);
  if (GNUNET_OK != ret)
  {
    proc (proc_cls,
          NULL, 0, NULL, 0, 0, 0, 0, GNUNET_TIME_UNIT_ZERO_ABS, 0);
    return;
  }

  ret = GNUNET_MY_extract_result (stmt,
                                  results_select);
  if (GNUNET_OK != ret)
  {
    proc (proc_cls,
          NULL, 0, NULL, 0, 0, 0, 0, GNUNET_TIME_UNIT_ZERO_ABS, 0);
    return;
  }

  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Found %u-byte value under key `%s' with prio %u, anon %u, expire %s selecting from gn090 table\n",
              (unsigned int) value_size,
              GNUNET_h2s (&key),
              (unsigned int) priority,
              (unsigned int) anonymity,
              GNUNET_STRINGS_absolute_time_to_string (expiration));
  GNUNET_assert (value_size < MAX_DATUM_SIZE);
  GNUNET_break (GNUNET_NO ==
                GNUNET_MY_extract_result (stmt,
                                          NULL));
  ret = proc (proc_cls,
              &key,
              value_size,
              value,
              type,
              priority,
              anonymity,
              replication,
              expiration,
              uid);
  GNUNET_MY_cleanup_result (results_select);
  if (GNUNET_NO == ret)
  {
    do_delete_entry (plugin, uid);
    if (0 != value_size)
      plugin->env->duc (plugin->env->cls,
                        -value_size);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_get_key()

static void mysql_plugin_get_key ( void *  cls, uint64_t  next_uid, bool  random, const struct GNUNET_HashCode *  key, enum GNUNET_BLOCK_Type  type, PluginDatumProcessor  proc, void *  proc_cls  )

static

Get one of the results for a particular key in the datastore.

Parameters

cls	closure
next_uid	return the result with lowest uid >= next_uid
random	if true, return a random result instead of using next_uid
key	key to match, never NULL
type	entries of which type are relevant? Use 0 for any type.
proc	function to call on the matching value, with NULL for if no value matches
proc_cls	closure for proc

Definition at line 548 of file plugin_datastore_mysql.c.

References execute_select(), GNUNET_BLOCK_TYPE_ANY, GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u64(), GNUNET_MY_query_param_auto_from_type, GNUNET_MY_query_param_end, GNUNET_MY_query_param_uint32(), GNUNET_MY_query_param_uint64(), plugin, Plugin::select_entry, Plugin::select_entry_by_hash, and Plugin::select_entry_by_hash_and_type.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;
  uint64_t rvalue;

  if (random)
  {
    rvalue = GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_WEAK,
                                       UINT64_MAX);
    next_uid = 0;
  }
  else
    rvalue = 0;

  if (NULL == key)
  {
    struct GNUNET_MY_QueryParam params_select[] = {
      GNUNET_MY_query_param_uint64 (&next_uid),
      GNUNET_MY_query_param_uint64 (&rvalue),
      GNUNET_MY_query_param_uint64 (&rvalue),
      GNUNET_MY_query_param_end
    };

    execute_select (plugin,
                    plugin->select_entry,
                    proc,
                    proc_cls,
                    params_select);
  }
  else if (type != GNUNET_BLOCK_TYPE_ANY)
  {
    struct GNUNET_MY_QueryParam params_select[] = {
      GNUNET_MY_query_param_auto_from_type (key),
      GNUNET_MY_query_param_uint32 (&type),
      GNUNET_MY_query_param_uint64 (&next_uid),
      GNUNET_MY_query_param_uint64 (&rvalue),
      GNUNET_MY_query_param_uint64 (&rvalue),
      GNUNET_MY_query_param_end
    };

    execute_select (plugin,
                    plugin->select_entry_by_hash_and_type,
                    proc,
                    proc_cls,
                    params_select);
  }
  else
  {
    struct GNUNET_MY_QueryParam params_select[] = {
      GNUNET_MY_query_param_auto_from_type (key),
      GNUNET_MY_query_param_uint64 (&next_uid),
      GNUNET_MY_query_param_uint64 (&rvalue),
      GNUNET_MY_query_param_uint64 (&rvalue),
      GNUNET_MY_query_param_end
    };

    execute_select (plugin,
                    plugin->select_entry_by_hash,
                    proc,
                    proc_cls,
                    params_select);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_get_zero_anonymity()

static void mysql_plugin_get_zero_anonymity ( void *  cls, uint64_t  next_uid, enum GNUNET_BLOCK_Type  type, PluginDatumProcessor  proc, void *  proc_cls  )

static

Get a zero-anonymity datum from the datastore.

Parameters

cls	our struct Plugin *
next_uid	return the result with lowest uid >= next_uid
type	entries of which type should be considered? Must not be zero (ANY).
proc	function to call on a matching value; will be called with NULL if no value matches
proc_cls	closure for proc

Definition at line 631 of file plugin_datastore_mysql.c.

References execute_select(), GNUNET_MY_query_param_end, GNUNET_MY_query_param_uint32(), GNUNET_MY_query_param_uint64(), plugin, and Plugin::zero_iter.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;
  uint32_t typei = (uint32_t) type;

  struct GNUNET_MY_QueryParam params_zero_iter[] = {
    GNUNET_MY_query_param_uint32 (&typei),
    GNUNET_MY_query_param_uint64 (&next_uid),
    GNUNET_MY_query_param_end
  };

  execute_select (plugin,
                  plugin->zero_iter,
                  proc,
                  proc_cls,
                  params_zero_iter);
}

Here is the call graph for this function:

Here is the caller graph for this function:

repl_proc()

static int repl_proc ( void *  cls, const struct GNUNET_HashCode *  key, uint32_t  size, const void *  data, enum GNUNET_BLOCK_Type  type, uint32_t  priority, uint32_t  anonymity, uint32_t  replication, struct GNUNET_TIME_Absolute  expiration, uint64_t  uid  )

static

Wrapper for the processor for mysql_plugin_get_replication().

Decrements the replication counter and calls the original iterator.

Parameters

cls	closure
key	key for the content
size	number of bytes in data
data	content stored
type	type of the content
priority	priority of the content
anonymity	anonymity-level for the content
replication	replication-level for the content
expiration	expiration time for the content
uid	unique identifier for the datum; maybe 0 if no unique identifier is available

Returns

GNUNET_SYSERR to abort the iteration, GNUNET_OK to continue (continue on call to "next", of course), GNUNET_NO to delete the item and continue (if supported)

Definition at line 697 of file plugin_datastore_mysql.c.

References Plugin::dec_repl, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_MY_exec_prepared(), GNUNET_MY_query_param_end, GNUNET_MY_query_param_uint64(), GNUNET_SYSERR, Plugin::mc, plugin, ReplCtx::plugin, ReplCtx::proc, ReplCtx::proc_cls, and ret.

Referenced by mysql_plugin_get_replication().

{
  struct ReplCtx *rc = cls;
  struct Plugin *plugin = rc->plugin;
  int ret;
  int iret;

  ret = rc->proc (rc->proc_cls,
                  key,
                  size,
                  data,
                  type,
                  priority,
                  anonymity,
                  replication,
                  expiration,
                  uid);
  if (NULL != key)
  {
    struct GNUNET_MY_QueryParam params_proc[] = {
      GNUNET_MY_query_param_uint64 (&uid),
      GNUNET_MY_query_param_end
    };

    iret = GNUNET_MY_exec_prepared (plugin->mc,
                                    plugin->dec_repl,
                                    params_proc);
    if (GNUNET_SYSERR == iret)
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  "Failed to reduce replication counter\n");
      return GNUNET_SYSERR;
    }
  }
  return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_get_replication()

static void mysql_plugin_get_replication ( void *  cls, PluginDatumProcessor  proc, void *  proc_cls  )

static

Get a random item for replication.

Returns a single, not expired, random item from those with the highest replication counters. The item's replication counter is decremented by one IF it was positive before. Call proc with all values ZERO or NULL if the datastore is empty.

Parameters

cls	closure
proc	function to call the value (once only).
proc_cls	closure for proc

Definition at line 756 of file plugin_datastore_mysql.c.

References execute_select(), GNUNET_break, GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u64(), GNUNET_MY_exec_prepared(), GNUNET_MY_extract_result(), GNUNET_MY_query_param_end, GNUNET_MY_query_param_uint32(), GNUNET_MY_query_param_uint64(), GNUNET_MY_result_spec_end, GNUNET_MY_result_spec_uint32(), GNUNET_NO, GNUNET_OK, GNUNET_TIME_UNIT_ZERO_ABS, Plugin::max_repl, Plugin::mc, plugin, ReplCtx::plugin, ReplCtx::proc, ReplCtx::proc_cls, repl_proc(), and Plugin::select_replication.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;
  uint64_t rvalue;
  uint32_t repl;
  struct ReplCtx rc;
  struct GNUNET_MY_QueryParam params_get[] = {
    GNUNET_MY_query_param_end
  };
  struct GNUNET_MY_ResultSpec results_get[] = {
    GNUNET_MY_result_spec_uint32 (&repl),
    GNUNET_MY_result_spec_end
  };
  struct GNUNET_MY_QueryParam params_select[] = {
    GNUNET_MY_query_param_uint32 (&repl),
    GNUNET_MY_query_param_uint64 (&rvalue),
    GNUNET_MY_query_param_uint32 (&repl),
    GNUNET_MY_query_param_uint64 (&rvalue),
    GNUNET_MY_query_param_end
  };

  rc.plugin = plugin;
  rc.proc = proc;
  rc.proc_cls = proc_cls;

  if (1 !=
      GNUNET_MY_exec_prepared (plugin->mc,
                               plugin->max_repl,
                               params_get))
  {
    proc (proc_cls, NULL, 0, NULL, 0, 0, 0, 0, GNUNET_TIME_UNIT_ZERO_ABS, 0);
    return;
  }

  if (GNUNET_OK !=
      GNUNET_MY_extract_result (plugin->max_repl,
                                results_get))
  {
    proc (proc_cls, NULL, 0, NULL, 0, 0, 0, 0, GNUNET_TIME_UNIT_ZERO_ABS, 0);
    return;
  }
  GNUNET_break (GNUNET_NO ==
                GNUNET_MY_extract_result (plugin->max_repl,
                                          NULL));
  rvalue = GNUNET_CRYPTO_random_u64 (GNUNET_CRYPTO_QUALITY_WEAK,
                                     UINT64_MAX);

  execute_select (plugin,
                  plugin->select_replication,
                  &repl_proc,
                  &rc,
                  params_select);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_get_keys()

static void mysql_plugin_get_keys ( void *  cls, PluginKeyProcessor  proc, void *  proc_cls  )

static

Get all of the keys in the datastore.

Parameters

cls	closure
proc	function to call on each key
proc_cls	closure for proc

Definition at line 821 of file plugin_datastore_mysql.c.

References _, GET_ALL_KEYS, Plugin::get_all_keys, GNUNET_assert, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_memcmp, GNUNET_MY_exec_prepared(), GNUNET_MY_extract_result(), GNUNET_MY_query_param_end, GNUNET_MY_result_spec_auto_from_type, GNUNET_MY_result_spec_end, GNUNET_MYSQL_statement_get_stmt(), GNUNET_MYSQL_statements_invalidate(), GNUNET_OK, GNUNET_SYSERR, GNUNET_YES, Plugin::key, Plugin::mc, plugin, and ret.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;
  int ret;
  MYSQL_STMT *statement;
  unsigned int cnt;
  struct GNUNET_HashCode key;
  struct GNUNET_HashCode last;
  struct GNUNET_MY_QueryParam params_select[] = {
    GNUNET_MY_query_param_end
  };
  struct GNUNET_MY_ResultSpec results_select[] = {
    GNUNET_MY_result_spec_auto_from_type (&key),
    GNUNET_MY_result_spec_end
  };

  GNUNET_assert (NULL != proc);
  statement = GNUNET_MYSQL_statement_get_stmt (plugin->get_all_keys);
  if (GNUNET_OK !=
      GNUNET_MY_exec_prepared (plugin->mc,
                               plugin->get_all_keys,
                               params_select))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                _ ("`%s' for `%s' failed at %s:%d with error: %s\n"),
                "mysql_stmt_execute",
                GET_ALL_KEYS,
                __FILE__,
                __LINE__,
                mysql_stmt_error (statement));
    GNUNET_MYSQL_statements_invalidate (plugin->mc);
    proc (proc_cls, NULL, 0);
    return;
  }
  memset (&last, 0, sizeof(last));   /* make static analysis happy */
  ret = GNUNET_YES;
  cnt = 0;
  while (ret == GNUNET_YES)
  {
    ret = GNUNET_MY_extract_result (plugin->get_all_keys,
                                    results_select);
    if (0 != GNUNET_memcmp (&last,
                            &key))
    {
      if (0 != cnt)
        proc (proc_cls,
              &last,
              cnt);
      cnt = 1;
      last = key;
    }
    else
    {
      cnt++;
    }
  }
  if (0 != cnt)
    proc (proc_cls,
          &last,
          cnt);
  /* finally, let app know we are done */
  proc (proc_cls,
        NULL,
        0);
  if (GNUNET_SYSERR == ret)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                _ ("`%s' failed at %s:%d with error: %s\n"),
                "mysql_stmt_fetch",
                __FILE__,
                __LINE__,
                mysql_stmt_error (statement));
    GNUNET_MYSQL_statements_invalidate (plugin->mc);
    return;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

expi_proc()

static int expi_proc ( void *  cls, const struct GNUNET_HashCode *  key, uint32_t  size, const void *  data, enum GNUNET_BLOCK_Type  type, uint32_t  priority, uint32_t  anonymity, uint32_t  replication, struct GNUNET_TIME_Absolute  expiration, uint64_t  uid  )

static

Wrapper for the processor for mysql_plugin_get_expiration().

If no expired value was found, we do a second query for low-priority content.

Parameters

cls	closure
key	key for the content
size	number of bytes in data
data	content stored
type	type of the content
priority	priority of the content
anonymity	anonymity-level for the content
replication	replication-level for the content
expiration	expiration time for the content
uid	unique identifier for the datum; maybe 0 if no unique identifier is available

Returns

GNUNET_SYSERR to abort the iteration, GNUNET_OK to continue (continue on call to "next", of course), GNUNET_NO to delete the item and continue (if supported)

Definition at line 944 of file plugin_datastore_mysql.c.

References execute_select(), GNUNET_MY_query_param_end, GNUNET_SYSERR, plugin, ExpiCtx::plugin, ExpiCtx::proc, ExpiCtx::proc_cls, and Plugin::select_priority.

Referenced by mysql_plugin_get_expiration().

{
  struct ExpiCtx *rc = cls;
  struct Plugin *plugin = rc->plugin;
  struct GNUNET_MY_QueryParam params_select[] = {
    GNUNET_MY_query_param_end
  };

  if (NULL == key)
  {
    execute_select (plugin,
                    plugin->select_priority,
                    rc->proc,
                    rc->proc_cls,
                    params_select);
    return GNUNET_SYSERR;
  }
  return rc->proc (rc->proc_cls,
                   key,
                   size,
                   data,
                   type,
                   priority,
                   anonymity,
                   replication,
                   expiration,
                   uid);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_get_expiration()

static void mysql_plugin_get_expiration ( void *  cls, PluginDatumProcessor  proc, void *  proc_cls  )

static

Get a random item for expiration.

Call proc with all values ZERO or NULL if the datastore is empty.

Parameters

cls	closure
proc	function to call the value (once only).
proc_cls	closure for proc

Definition at line 992 of file plugin_datastore_mysql.c.

References execute_select(), expi_proc(), GNUNET_MY_query_param_absolute_time(), GNUNET_MY_query_param_end, GNUNET_TIME_absolute_get(), plugin, ExpiCtx::plugin, ExpiCtx::proc, ExpiCtx::proc_cls, and Plugin::select_expiration.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;
  struct GNUNET_TIME_Absolute now;
  struct GNUNET_MY_QueryParam params_select[] = {
    GNUNET_MY_query_param_absolute_time (&now),
    GNUNET_MY_query_param_end
  };
  struct ExpiCtx rc;

  rc.plugin = plugin;
  rc.proc = proc;
  rc.proc_cls = proc_cls;
  now = GNUNET_TIME_absolute_get ();
  execute_select (plugin,
                  plugin->select_expiration,
                  expi_proc,
                  &rc,
                  params_select);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_drop()

static void mysql_plugin_drop ( void *  cls )

static

Drop database.

Parameters

cls	the struct Plugin *

Definition at line 1022 of file plugin_datastore_mysql.c.

References GNUNET_DATACACHE_PluginEnvironment::cls, Plugin::env, GNUNET_MYSQL_statement_run(), GNUNET_OK, Plugin::mc, and plugin.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;

  if (GNUNET_OK !=
      GNUNET_MYSQL_statement_run (plugin->mc,
                                  "DROP TABLE gn090"))
    return;                     /* error */
  plugin->env->duc (plugin->env->cls, 0);
}

Here is the call graph for this function:

Here is the caller graph for this function:

mysql_plugin_remove_key()

static void mysql_plugin_remove_key ( void *  cls, const struct GNUNET_HashCode *  key, uint32_t  size, const void *  data, PluginRemoveCont  cont, void *  cont_cls  )

static

Remove a particular key in the datastore.

Parameters

cls	closure
key	key for the content
size	number of bytes in data
data	content stored
cont	continuation called with success or failure status
cont_cls	continuation closure for cont

Definition at line 1045 of file plugin_datastore_mysql.c.

References _, GNUNET_DATACACHE_PluginEnvironment::cls, Plugin::delete_entry_by_hash_value, Plugin::env, GNUNET_ERROR_TYPE_WARNING, GNUNET_h2s(), GNUNET_log, GNUNET_MY_exec_prepared(), GNUNET_MY_query_param_auto_from_type, GNUNET_MY_query_param_end, GNUNET_MY_query_param_fixed_size(), GNUNET_MYSQL_statement_get_stmt(), GNUNET_NO, GNUNET_OK, GNUNET_SYSERR, Plugin::mc, and plugin.

Referenced by libgnunet_plugin_datastore_mysql_init().

{
  struct Plugin *plugin = cls;
  struct GNUNET_MY_QueryParam params_delete[] = {
    GNUNET_MY_query_param_auto_from_type (key),
    GNUNET_MY_query_param_fixed_size (data, size),
    GNUNET_MY_query_param_end
  };

  if (GNUNET_OK !=
      GNUNET_MY_exec_prepared (plugin->mc,
                               plugin->delete_entry_by_hash_value,
                               params_delete))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                "Removing key `%s' from gn090 table failed\n",
                GNUNET_h2s (key));
    cont (cont_cls,
          key,
          size,
          GNUNET_SYSERR,
          _ ("MySQL statement run failure"));
    return;
  }

  MYSQL_STMT *stmt = GNUNET_MYSQL_statement_get_stmt (
    plugin->delete_entry_by_hash_value);
  my_ulonglong rows = mysql_stmt_affected_rows (stmt);

  if (0 == rows)
  {
    cont (cont_cls,
          key,
          size,
          GNUNET_NO,
          NULL);
    return;
  }
  plugin->env->duc (plugin->env->cls,
                    -size);
  cont (cont_cls,
        key,
        size,
        GNUNET_OK,
        NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

libgnunet_plugin_datastore_mysql_init()

void* libgnunet_plugin_datastore_mysql_init

(

void *

cls

)

Entry point for the plugin.

Parameters

cls	the struct GNUNET_DATASTORE_PluginEnvironment *

Returns

our struct Plugin *

Definition at line 1105 of file plugin_datastore_mysql.c.

References _, Plugin::api, GNUNET_DATASTORE_PluginEnvironment::cfg, GNUNET_DATASTORE_PluginEnvironment::cls, GNUNET_DATASTORE_PluginFunctions::cls, DEC_REPL, Plugin::dec_repl, DELETE_ENTRY_BY_HASH_VALUE, Plugin::delete_entry_by_hash_value, DELETE_ENTRY_BY_UID, Plugin::delete_entry_by_uid, GNUNET_DATASTORE_PluginFunctions::drop, Plugin::env, GNUNET_DATASTORE_PluginFunctions::estimate_size, GET_ALL_KEYS, Plugin::get_all_keys, GNUNET_DATASTORE_PluginFunctions::get_expiration, GNUNET_DATASTORE_PluginFunctions::get_key, GNUNET_DATASTORE_PluginFunctions::get_keys, GNUNET_DATASTORE_PluginFunctions::get_replication, Plugin::get_size, GNUNET_DATASTORE_PluginFunctions::get_zero_anonymity, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_log_from, GNUNET_MYSQL_context_create(), GNUNET_MYSQL_context_destroy(), GNUNET_new, INSERT_ENTRY, Plugin::insert_entry, Plugin::max_repl, Plugin::mc, MRUNS, mysql_plugin_drop(), mysql_plugin_estimate_size(), mysql_plugin_get_expiration(), mysql_plugin_get_key(), mysql_plugin_get_keys(), mysql_plugin_get_replication(), mysql_plugin_get_zero_anonymity(), mysql_plugin_put(), mysql_plugin_remove_key(), PINIT, plugin, GNUNET_DATASTORE_PluginFunctions::put, GNUNET_DATASTORE_PluginFunctions::remove_key, SELECT_ENTRY, Plugin::select_entry, SELECT_ENTRY_BY_HASH, Plugin::select_entry_by_hash, SELECT_ENTRY_BY_HASH_AND_TYPE, Plugin::select_entry_by_hash_and_type, Plugin::select_expiration, SELECT_IT_EXPIRATION, SELECT_IT_NON_ANONYMOUS, SELECT_IT_PRIORITY, SELECT_IT_REPLICATION, SELECT_MAX_REPL, Plugin::select_priority, Plugin::select_replication, SELECT_SIZE, UPDATE_ENTRY, Plugin::update_entry, and Plugin::zero_iter.

{
  struct GNUNET_DATASTORE_PluginEnvironment *env = cls;
  struct GNUNET_DATASTORE_PluginFunctions *api;
  struct Plugin *plugin;

  plugin = GNUNET_new (struct Plugin);
  plugin->env = env;
  plugin->mc = GNUNET_MYSQL_context_create (env->cfg,
                                            "datastore-mysql");
  if (NULL == plugin->mc)
  {
    GNUNET_free (plugin);
    return NULL;
  }
#define MRUNS(a) (GNUNET_OK != GNUNET_MYSQL_statement_run (plugin->mc, a))
#define PINIT(a, b) (NULL == (a = GNUNET_MYSQL_statement_prepare (plugin->mc, \
                                                                  b)))
  if (MRUNS
        ("CREATE TABLE IF NOT EXISTS gn090 ("
        " repl INT(11) UNSIGNED NOT NULL DEFAULT 0,"
        " type INT(11) UNSIGNED NOT NULL DEFAULT 0,"
        " prio INT(11) UNSIGNED NOT NULL DEFAULT 0,"
        " anonLevel INT(11) UNSIGNED NOT NULL DEFAULT 0,"
        " expire BIGINT UNSIGNED NOT NULL DEFAULT 0,"
        " rvalue BIGINT UNSIGNED NOT NULL,"
        " hash BINARY(64) NOT NULL DEFAULT '',"
        " vhash BINARY(64) NOT NULL DEFAULT '',"
        " value BLOB NOT NULL DEFAULT '',"
        " uid BIGINT NOT NULL AUTO_INCREMENT,"
        " PRIMARY KEY (uid),"
        " INDEX idx_hash_type_uid (hash(64),type,rvalue),"
        " INDEX idx_prio (prio),"
        " INDEX idx_repl_rvalue (repl,rvalue),"
        " INDEX idx_expire (expire),"
        " INDEX idx_anonLevel_type_rvalue (anonLevel,type,rvalue)"
        ") ENGINE=InnoDB") || MRUNS ("SET AUTOCOMMIT = 1") ||
      PINIT (plugin->insert_entry, INSERT_ENTRY) ||
      PINIT (plugin->delete_entry_by_uid, DELETE_ENTRY_BY_UID) ||
      PINIT (plugin->delete_entry_by_hash_value, DELETE_ENTRY_BY_HASH_VALUE) ||
      PINIT (plugin->select_entry, SELECT_ENTRY) ||
      PINIT (plugin->select_entry_by_hash, SELECT_ENTRY_BY_HASH) ||
      PINIT (plugin->select_entry_by_hash_and_type,
             SELECT_ENTRY_BY_HASH_AND_TYPE) ||
      PINIT (plugin->get_size, SELECT_SIZE) ||
      PINIT (plugin->update_entry, UPDATE_ENTRY) ||
      PINIT (plugin->dec_repl, DEC_REPL) ||
      PINIT (plugin->zero_iter, SELECT_IT_NON_ANONYMOUS) ||
      PINIT (plugin->select_expiration, SELECT_IT_EXPIRATION) ||
      PINIT (plugin->select_priority, SELECT_IT_PRIORITY) ||
      PINIT (plugin->max_repl, SELECT_MAX_REPL) ||
      PINIT (plugin->get_all_keys, GET_ALL_KEYS) ||
      PINIT (plugin->select_replication, SELECT_IT_REPLICATION) ||
      false)
  {
    GNUNET_MYSQL_context_destroy (plugin->mc);
    GNUNET_free (plugin);
    return NULL;
  }
#undef PINIT
#undef MRUNS

  api = GNUNET_new (struct GNUNET_DATASTORE_PluginFunctions);
  api->cls = plugin;
  api->estimate_size = &mysql_plugin_estimate_size;
  api->put = &mysql_plugin_put;
  api->get_key = &mysql_plugin_get_key;
  api->get_replication = &mysql_plugin_get_replication;
  api->get_expiration = &mysql_plugin_get_expiration;
  api->get_zero_anonymity = &mysql_plugin_get_zero_anonymity;
  api->get_keys = &mysql_plugin_get_keys;
  api->drop = &mysql_plugin_drop;
  api->remove_key = &mysql_plugin_remove_key;
  GNUNET_log_from (GNUNET_ERROR_TYPE_INFO, "mysql",
                   _ ("Mysql database running\n"));
  return api;
}

Here is the call graph for this function:

libgnunet_plugin_datastore_mysql_done()

void* libgnunet_plugin_datastore_mysql_done

(

void *

cls

)

Exit point from the plugin.

Parameters

cls	our struct Plugin *

Returns

always NULL

Definition at line 1191 of file plugin_datastore_mysql.c.

References Plugin::api, GNUNET_DATASTORE_PluginFunctions::cls, GNUNET_free, GNUNET_MYSQL_context_destroy(), Plugin::mc, and plugin.

{
  struct GNUNET_DATASTORE_PluginFunctions *api = cls;
  struct Plugin *plugin = api->cls;

  GNUNET_MYSQL_context_destroy (plugin->mc);
  GNUNET_free (plugin);
  GNUNET_free (api);
  return NULL;
}

Here is the call graph for this function: