X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Fdatastore%2Fplugin_datastore_template.c;h=fdd4fb157bf48021f41e81a23894890d486e353b;hb=2105059516320800eaa8fff1196b58f29a50ba7c;hp=566155fb50521c2d511116da63fcb3f50263dd68;hpb=5746309cb4be2073d550ad7a6885e918631dbc38;p=oweals%2Fgnunet.git diff --git a/src/datastore/plugin_datastore_template.c b/src/datastore/plugin_datastore_template.c index 566155fb5..fdd4fb157 100644 --- a/src/datastore/plugin_datastore_template.c +++ b/src/datastore/plugin_datastore_template.c @@ -1,6 +1,6 @@ /* This file is part of GNUnet - (C) 2009, 2011 Christian Grothoff (and other contributing authors) + Copyright (C) 2009, 2011 GNUnet e.V. GNUnet is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published @@ -14,8 +14,8 @@ 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. + Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + Boston, MA 02110-1301, USA. */ /** @@ -47,11 +47,13 @@ struct Plugin * @param cls our "struct Plugin*" * @return number of bytes used on disk */ -static unsigned long long -template_plugin_estimate_size (void *cls) +static void +template_plugin_estimate_size (void *cls, unsigned long long *estimate) { + if (NULL == estimate) + return; GNUNET_break (0); - return 0; + *estimate = 0; } @@ -67,19 +69,19 @@ template_plugin_estimate_size (void *cls) * @param anonymity anonymity-level for the content * @param replication replication-level for the content * @param expiration expiration time for the content - * @param msg set to error message - * @return GNUNET_OK on success + * @param cont continuation called with success or failure status + * @param cont_cls continuation closure */ -static int -template_plugin_put (void *cls, const GNUNET_HashCode * key, uint32_t size, +static void +template_plugin_put (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, char **msg) + struct GNUNET_TIME_Absolute expiration, PluginPutCont cont, + void *cont_cls) { GNUNET_break (0); - *msg = GNUNET_strdup ("not implemented"); - return GNUNET_SYSERR; + cont (cont_cls, key, size, GNUNET_SYSERR, "not implemented"); } @@ -87,7 +89,7 @@ template_plugin_put (void *cls, const GNUNET_HashCode * key, uint32_t size, * Get one of the results for a particular key in the datastore. * * @param cls closure - * @param offset offset of the result (modulo num-results); + * @param offset offset of the result (modulo num-results); * specific ordering does not matter for the offset * @param key maybe NULL (to match all entries) * @param vhash hash of the value, maybe NULL (to @@ -103,8 +105,8 @@ template_plugin_put (void *cls, const GNUNET_HashCode * key, uint32_t size, */ static void template_plugin_get_key (void *cls, uint64_t offset, - const GNUNET_HashCode * key, - const GNUNET_HashCode * vhash, + const struct GNUNET_HashCode * key, + const struct GNUNET_HashCode * vhash, enum GNUNET_BLOCK_Type type, PluginDatumProcessor proc, void *proc_cls) { @@ -168,16 +170,16 @@ template_plugin_get_expiration (void *cls, PluginDatumProcessor proc, * @param expire new expiration time should be the * MAX of any existing expiration time and * this value - * @param msg set to error message - * @return GNUNET_OK on success + * @param cont continuation called with success or failure status + * @param cons_cls continuation closure */ -static int +static void template_plugin_update (void *cls, uint64_t uid, int delta, - struct GNUNET_TIME_Absolute expire, char **msg) + struct GNUNET_TIME_Absolute expire, + PluginUpdateCont cont, void *cont_cls) { GNUNET_break (0); - *msg = GNUNET_strdup ("not implemented"); - return GNUNET_SYSERR; + cont (cont_cls, GNUNET_SYSERR, "not implemented"); } @@ -185,7 +187,7 @@ template_plugin_update (void *cls, uint64_t uid, int delta, * Call the given processor on an item with zero anonymity. * * @param cls our "struct Plugin*" - * @param offset offset of the result (modulo num-results); + * @param offset offset of the result (modulo num-results); * specific ordering does not matter for the offset * @param type entries of which type should be considered? * Use 0 for any type. @@ -212,6 +214,22 @@ template_plugin_drop (void *cls) } +/** + * Get all of the keys in the datastore. + * + * @param cls closure + * @param proc function to call on each key + * @param proc_cls closure for proc + */ +static void +template_get_keys (void *cls, + PluginKeyProcessor proc, + void *proc_cls) +{ + proc (proc_cls, NULL, 0); +} + + /** * Entry point for the plugin. * @@ -225,9 +243,9 @@ libgnunet_plugin_datastore_template_init (void *cls) struct GNUNET_DATASTORE_PluginFunctions *api; struct Plugin *plugin; - plugin = GNUNET_malloc (sizeof (struct Plugin)); + plugin = GNUNET_new (struct Plugin); plugin->env = env; - api = GNUNET_malloc (sizeof (struct GNUNET_DATASTORE_PluginFunctions)); + api = GNUNET_new (struct GNUNET_DATASTORE_PluginFunctions); api->cls = plugin; api->estimate_size = &template_plugin_estimate_size; api->put = &template_plugin_put; @@ -237,6 +255,7 @@ libgnunet_plugin_datastore_template_init (void *cls) api->get_expiration = &template_plugin_get_expiration; api->get_zero_anonymity = &template_plugin_get_zero_anonymity; api->drop = &template_plugin_drop; + api->get_keys = &template_get_keys; GNUNET_log_from (GNUNET_ERROR_TYPE_INFO, "template", _("Template database running\n")); return api;