[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r35670 - gnunet/src/datacache
From: |
gnunet |
Subject: |
[GNUnet-SVN] r35670 - gnunet/src/datacache |
Date: |
Wed, 29 Apr 2015 10:17:17 +0200 |
Author: grothoff
Date: 2015-04-29 10:17:17 +0200 (Wed, 29 Apr 2015)
New Revision: 35670
Modified:
gnunet/src/datacache/plugin_datacache_postgres.c
Log:
implementing postgres version of get_random
Modified: gnunet/src/datacache/plugin_datacache_postgres.c
===================================================================
--- gnunet/src/datacache/plugin_datacache_postgres.c 2015-04-29 08:06:54 UTC
(rev 35669)
+++ gnunet/src/datacache/plugin_datacache_postgres.c 2015-04-29 08:17:17 UTC
(rev 35670)
@@ -1,6 +1,6 @@
/*
This file is part of GNUnet
- Copyright (C) 2006, 2009, 2010, 2012 Christian Grothoff (and other
contributing authors)
+ Copyright (C) 2006, 2009, 2010, 2012, 2015 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
@@ -158,6 +158,11 @@
"ORDER BY discard_time ASC LIMIT 1", 0)) ||
(GNUNET_OK !=
GNUNET_POSTGRES_prepare (plugin->dbh,
+ "get_random",
+ "SELECT discard_time,type,value,path,key FROM
gn090dc "
+ "ORDER BY key ASC LIMIT 1 OFFSET $1", 1)) ||
+ (GNUNET_OK !=
+ GNUNET_POSTGRES_prepare (plugin->dbh,
"delrow",
"DELETE FROM gn090dc WHERE oid=$1", 1)) ||
(GNUNET_OK !=
@@ -405,6 +410,103 @@
/**
+ * Obtain a random key-value pair from the datacache.
+ *
+ * @param cls closure (our `struct Plugin`)
+ * @param iter maybe NULL (to just count)
+ * @param iter_cls closure for @a iter
+ * @return the number of results found, zero (datacache empty) or one
+ */
+static unsigned int
+postgres_plugin_get_random (void *cls,
+ GNUNET_DATACACHE_Iterator iter,
+ void *iter_cls)
+{
+ struct Plugin *plugin = cls;
+ unsigned int off;
+ uint32_t off_be;
+ struct GNUNET_TIME_Absolute expiration_time;
+ uint32_t size;
+ unsigned int path_len;
+ const struct GNUNET_PeerIdentity *path;
+ const struct GNUNET_HashCode *key;
+ unsigned int type;
+ PGresult *res;
+ const char *paramValues[] = {
+ (const char *) &off_be,
+ };
+ int paramLengths[] = {
+ sizeof (off_be),
+ };
+ const int paramFormats[] = { 1 };
+
+ if (0 == plugin->num_items)
+ return 0;
+ if (NULL == iter)
+ return 1;
+ off = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_NONCE,
+ plugin->num_items);
+ off_be = htonl (off);
+ res =
+ PQexecPrepared (plugin->dbh, "get_random",
+ 1, paramValues, paramLengths, paramFormats,
+ 1);
+ if (GNUNET_OK !=
+ GNUNET_POSTGRES_check_result (plugin->dbh,
+ res,
+ PGRES_TUPLES_OK,
+ "PQexecPrepared",
+ "get_random"))
+ {
+ GNUNET_break (0);
+ return 0;
+ }
+ if (0 == PQntuples (res))
+ {
+ GNUNET_break (0);
+ return 0;
+ }
+ if ( (5 != PQnfields (res)) ||
+ (sizeof (uint64_t) != PQfsize (res, 0)) ||
+ (sizeof (uint32_t) != PQfsize (res, 1)) ||
+ (sizeof (struct GNUNET_HashCode) != PQfsize (res, 4)) )
+ {
+ GNUNET_break (0);
+ PQclear (res);
+ return 0;
+ }
+ expiration_time.abs_value_us =
+ GNUNET_ntohll (*(uint64_t *) PQgetvalue (res, 0, 0));
+ type = ntohl (*(uint32_t *) PQgetvalue (res, 0, 1));
+ size = PQgetlength (res, 0, 2);
+ path_len = PQgetlength (res, 0, 3);
+ if (0 != (path_len % sizeof (struct GNUNET_PeerIdentity)))
+ {
+ GNUNET_break (0);
+ path_len = 0;
+ }
+ path_len %= sizeof (struct GNUNET_PeerIdentity);
+ path = (const struct GNUNET_PeerIdentity *) PQgetvalue (res, 0, 3);
+ key = (const struct GNUNET_HashCode *) PQgetvalue (res, 0, 4);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Found random value with key %s of size %u bytes and type %u in
database\n",
+ GNUNET_h2s (key),
+ (unsigned int) size,
+ (unsigned int) type);
+ (void) iter (iter_cls,
+ key,
+ size,
+ PQgetvalue (res, 0, 2),
+ (enum GNUNET_BLOCK_Type) type,
+ expiration_time,
+ path_len,
+ path);
+ PQclear (res);
+ return 1;
+}
+
+
+/**
* Entry point for the plugin.
*
* @param cls closure (the `struct GNUNET_DATACACHE_PluginEnvironmnet`)
@@ -431,6 +533,7 @@
api->get = &postgres_plugin_get;
api->put = &postgres_plugin_put;
api->del = &postgres_plugin_del;
+ api->get_random = &postgres_plugin_get_random;
LOG (GNUNET_ERROR_TYPE_INFO,
"Postgres datacache running\n");
return api;
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r35670 - gnunet/src/datacache,
gnunet <=