GNUnet MESSENGER service. More...

#include "platform.h"
#include "gnunet-service-messenger_ego_store.h"
#include "gnunet-service-messenger_handle.h"

Include dependency graph for gnunet-service-messenger_ego_store.c:

Functions
static void	callback_update_ego (void cls, struct GNUNET_IDENTITY_Ego ego, void *ctx, const char identifier)

void	init_ego_store (struct GNUNET_MESSENGER_EgoStore store, const struct GNUNET_CONFIGURATION_Handle config)
	Initializes an EGO-store as fully empty. More...

static int	iterate_destroy_egos (void cls, const struct GNUNET_HashCode key, void *value)

void	clear_ego_store (struct GNUNET_MESSENGER_EgoStore *store)
	Clears an EGO-store, wipes its content and deallocates its memory. More...

static int	iterate_create_ego (void cls, const struct GNUNET_HashCode key, void *value)

static void	callback_ego_create (void cls, const struct GNUNET_IDENTITY_PrivateKey key, enum GNUNET_ErrorCode ec)

void	create_store_ego (struct GNUNET_MESSENGER_EgoStore store, const char identifier)
	Creates a new EGO which will be registered to a store under a specific identifier. More...

void	bind_store_ego (struct GNUNET_MESSENGER_EgoStore store, const char identifier, void *handle)
	Binds an EGO which was registered to a store under a specific identifier to a given handle More...

void	unbind_store_ego (struct GNUNET_MESSENGER_EgoStore store, const char identifier, void *handle)
	Binds an EGO which was registered to a store under a specific identifier to a given handle More...

static void	callback_ego_lookup (void cls, struct GNUNET_IDENTITY_Ego ego)

void	lookup_store_ego (struct GNUNET_MESSENGER_EgoStore store, const char identifier, GNUNET_MESSENGER_EgoLookupCallback lookup, void *cls)
	Lookups an EGO which was registered to a store under a specific identifier. More...

struct GNUNET_MESSENGER_Ego *	update_store_ego (struct GNUNET_MESSENGER_EgoStore store, const char identifier, const struct GNUNET_IDENTITY_PrivateKey *key)
	Updates the registration of an EGO to a store under a specific identifier with a new key. More...

void	delete_store_ego (struct GNUNET_MESSENGER_EgoStore store, const char identifier)
	Deletes the registration of an EGO in a store under a specific identifier. More...

static void	callback_ego_rename (void *cls, enum GNUNET_ErrorCode ec)

void	rename_store_ego (struct GNUNET_MESSENGER_EgoStore store, const char old_identifier, const char *new_identifier)
	Updates the location of a registered EGO in a store to a different one under a specific new_identifier replacing its old one. More...

static void	callback_ego_delete (void *cls, enum GNUNET_ErrorCode ec)

void	renew_store_ego (struct GNUNET_MESSENGER_EgoStore store, const char identifier)
	Replaces the registered EGO in a store under a specific identifier with a newly created one. More...

Detailed Description

GNUnet MESSENGER service.

Author: Tobias Frisch

Definition in file gnunet-service-messenger_ego_store.c.

Function Documentation

◆ callback_update_ego()

static void callback_update_ego	(	void *	cls,
		struct GNUNET_IDENTITY_Ego *	ego,
		void **	ctx,
		const char *	identifier
	)

static

Definition at line 32 of file gnunet-service-messenger_ego_store.c.

 {
   if ((!ctx) || (!identifier))
     return;
  
   struct GNUNET_MESSENGER_EgoStore *store = cls;
  
   if (ego)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "New ego in use: '%s'\n", identifier);
     update_store_ego (store, identifier, GNUNET_IDENTITY_ego_get_private_key (ego));
   }
   else
   {
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Ego got deleted: '%s'\n", identifier);
     delete_store_ego (store, identifier);
   }
 }

References ctx, delete_store_ego(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_IDENTITY_ego_get_private_key(), GNUNET_log, and update_store_ego().

Referenced by init_ego_store().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ init_ego_store()

void init_ego_store	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const struct GNUNET_CONFIGURATION_Handle *	config
	)

Initializes an EGO-store as fully empty.

Parameters

[out]	store	EGO-store
[in]	config	Configuration handle

Definition at line 55 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert ((store) && (config));
  
   store->cfg = config;
   store->identity = GNUNET_IDENTITY_connect (config, &callback_update_ego, store);
   store->egos = GNUNET_CONTAINER_multihashmap_create (8, GNUNET_NO);
   store->handles = GNUNET_CONTAINER_multihashmap_create (8, GNUNET_NO);
  
   store->lu_start = NULL;
   store->lu_end = NULL;
  
   store->op_start = NULL;
   store->op_end = NULL;
 }

References callback_update_ego(), GNUNET_MESSENGER_EgoStore::cfg, config, GNUNET_MESSENGER_EgoStore::egos, GNUNET_assert, GNUNET_CONTAINER_multihashmap_create(), GNUNET_IDENTITY_connect(), GNUNET_NO, GNUNET_MESSENGER_EgoStore::handles, GNUNET_MESSENGER_EgoStore::identity, GNUNET_MESSENGER_EgoStore::lu_end, GNUNET_MESSENGER_EgoStore::lu_start, GNUNET_MESSENGER_EgoStore::op_end, and GNUNET_MESSENGER_EgoStore::op_start.

Referenced by create_service().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ iterate_destroy_egos()

static int iterate_destroy_egos	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Definition at line 73 of file gnunet-service-messenger_ego_store.c.

 {
   struct GNUNET_MESSENGER_Ego *ego = value;
   GNUNET_free(ego);
   return GNUNET_YES;
 }

References GNUNET_free, GNUNET_YES, and value.

Referenced by clear_ego_store().

Here is the caller graph for this function:

◆ clear_ego_store()

void clear_ego_store ( struct GNUNET_MESSENGER_EgoStore * store )

Clears an EGO-store, wipes its content and deallocates its memory.

Parameters

[in,out] store EGO-store

Definition at line 83 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert (store);
  
   struct GNUNET_MESSENGER_EgoOperation *op;
  
   while (store->op_start)
   {
     op = store->op_start;
  
     GNUNET_IDENTITY_cancel (op->operation);
     GNUNET_CONTAINER_DLL_remove (store->op_start, store->op_end, op);
  
     if (op->identifier)
       GNUNET_free (op->identifier);
  
     GNUNET_free (op);
   }
  
   struct GNUNET_MESSENGER_EgoLookup *lu;
  
   while (store->lu_start)
   {
     lu = store->lu_start;
  
     GNUNET_IDENTITY_ego_lookup_cancel(lu->lookup);
     GNUNET_CONTAINER_DLL_remove (store->lu_start, store->lu_end, lu);
  
     if (lu->identifier)
       GNUNET_free(lu->identifier);
  
     GNUNET_free (lu);
   }
  
   GNUNET_CONTAINER_multihashmap_iterate (store->egos, iterate_destroy_egos, NULL);
   GNUNET_CONTAINER_multihashmap_destroy (store->egos);
  
   GNUNET_CONTAINER_multihashmap_destroy (store->handles);
  
   if (store->identity)
   {
     GNUNET_IDENTITY_disconnect (store->identity);
  
     store->identity = NULL;
   }
 }

Referenced by destroy_service().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ iterate_create_ego()

static int iterate_create_ego	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Definition at line 131 of file gnunet-service-messenger_ego_store.c.

 {
   struct GNUNET_MESSENGER_SrvHandle *handle = value;
   set_srv_handle_ego (handle, (struct GNUNET_MESSENGER_Ego*) cls);
   return GNUNET_YES;
 }

References GNUNET_YES, handle, set_srv_handle_ego(), and value.

Referenced by callback_ego_create().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ callback_ego_create()

static void callback_ego_create	(	void *	cls,
		const struct GNUNET_IDENTITY_PrivateKey *	key,
		enum GNUNET_ErrorCode	ec
	)

static

FIXME: This is dangerous, please handle errors

Definition at line 141 of file gnunet-service-messenger_ego_store.c.

 {
   struct GNUNET_MESSENGER_EgoOperation *element = cls;
   struct GNUNET_MESSENGER_EgoStore *store = element->store;
  
   GNUNET_assert (element->identifier);
  
   if (GNUNET_EC_NONE != ec)
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "%s\n",
                 GNUNET_ErrorCode_get_hint (ec));
  
   if (key)
   {
     struct GNUNET_MESSENGER_Ego *msg_ego = update_store_ego (store, element->identifier, key);
  
     struct GNUNET_HashCode hash;
     GNUNET_CRYPTO_hash (element->identifier, strlen (element->identifier), &hash);
  
     GNUNET_CONTAINER_multihashmap_get_multiple (store->handles, &hash, iterate_create_ego, msg_ego);
   }
   else
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Creating ego failed!\n");
  
   GNUNET_CONTAINER_DLL_remove (store->op_start, store->op_end, element);
   GNUNET_free (element->identifier);
   GNUNET_free (element);
 }

References GNUNET_MESSENGER_EgoOperation::cls, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multihashmap_get_multiple(), GNUNET_CRYPTO_hash(), GNUNET_EC_NONE, GNUNET_ERROR_TYPE_WARNING, GNUNET_ErrorCode_get_hint(), GNUNET_free, GNUNET_log, GNUNET_MESSENGER_EgoStore::handles, GNUNET_MESSENGER_EgoOperation::identifier, iterate_create_ego(), key, GNUNET_MESSENGER_EgoStore::op_end, GNUNET_MESSENGER_EgoStore::op_start, GNUNET_MESSENGER_EgoOperation::store, and update_store_ego().

Referenced by create_store_ego().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ create_store_ego()

void create_store_ego	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const char *	identifier
	)

Creates a new EGO which will be registered to a store under a specific identifier.

Parameters

[in,out]	store	EGO-store
[in]	identifier	Identifier string

Definition at line 175 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert ((store) && (identifier));
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store create ego: %s\n", identifier);
  
   struct GNUNET_MESSENGER_EgoOperation *element = GNUNET_new (struct GNUNET_MESSENGER_EgoOperation);
  
   element->store = store;
   element->cls = NULL;
  
   element->identifier = GNUNET_strdup (identifier);
  
   element->operation = GNUNET_IDENTITY_create (
       store->identity,
       identifier,
       NULL,
       GNUNET_IDENTITY_TYPE_ECDSA,
       callback_ego_create,
       element
   );
  
   GNUNET_CONTAINER_DLL_insert (store->op_start, store->op_end, element);
 }

References callback_ego_create(), GNUNET_MESSENGER_EgoOperation::cls, GNUNET_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_IDENTITY_create(), GNUNET_IDENTITY_TYPE_ECDSA, GNUNET_log, GNUNET_new, GNUNET_strdup, GNUNET_MESSENGER_EgoOperation::identifier, GNUNET_MESSENGER_EgoStore::identity, GNUNET_MESSENGER_EgoStore::op_end, GNUNET_MESSENGER_EgoStore::op_start, GNUNET_MESSENGER_EgoOperation::operation, and GNUNET_MESSENGER_EgoOperation::store.

Referenced by callback_ego_delete(), and callback_update_handle().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ bind_store_ego()

void bind_store_ego	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const char *	identifier,
		void *	handle
	)

Binds an EGO which was registered to a store under a specific identifier to a given handle

Parameters

[in,out]	store	EGO-store
[in]	identifier	Identifier string
[in,out]	handle	Handle

Definition at line 202 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert ((store) && (identifier) && (handle));
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store bind ego: %s\n", identifier);
  
   struct GNUNET_HashCode hash;
   GNUNET_CRYPTO_hash (identifier, strlen (identifier), &hash);
  
   if (GNUNET_YES == GNUNET_CONTAINER_multihashmap_contains_value(store->handles, &hash, handle))
     return;
  
   if (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put(store->handles, &hash, handle,
                                                      GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE))
     GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "Putting handle binding to ego store failed!\n");
 }

References GNUNET_assert, GNUNET_CONTAINER_multihashmap_contains_value(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_CRYPTO_hash(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_OK, GNUNET_YES, handle, GNUNET_MESSENGER_EgoStore::handles, GNUNET_MESSENGER_EgoOperation::identifier, and GNUNET_MESSENGER_EgoOperation::store.

Referenced by callback_update_handle().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ unbind_store_ego()

void unbind_store_ego	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const char *	identifier,
		void *	handle
	)

Binds an EGO which was registered to a store under a specific identifier to a given handle

Parameters

[in,out]	store	EGO-store
[in]	identifier	Identifier string
[in,out]	handle	Handle

Definition at line 222 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert ((store) && (identifier) && (handle));
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store unbind ego: %s\n", identifier);
  
   struct GNUNET_HashCode hash;
   GNUNET_CRYPTO_hash (identifier, strlen (identifier), &hash);
  
   if (GNUNET_YES != GNUNET_CONTAINER_multihashmap_contains_value(store->handles, &hash, handle))
     return;
  
   if (GNUNET_YES != GNUNET_CONTAINER_multihashmap_remove(store->handles, &hash, handle))
     GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "Removing handle binding from ego store failed!\n");
 }

References GNUNET_assert, GNUNET_CONTAINER_multihashmap_contains_value(), GNUNET_CONTAINER_multihashmap_remove(), GNUNET_CRYPTO_hash(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_YES, handle, and GNUNET_MESSENGER_EgoStore::handles.

Referenced by destroy_srv_handle().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ callback_ego_lookup()

static void callback_ego_lookup	(	void *	cls,
		struct GNUNET_IDENTITY_Ego *	ego
	)

static

Definition at line 241 of file gnunet-service-messenger_ego_store.c.

 {
   struct GNUNET_MESSENGER_EgoLookup *element = cls;
   struct GNUNET_MESSENGER_EgoStore *store = element->store;
  
   GNUNET_assert (element->identifier);
  
   struct GNUNET_MESSENGER_Ego *msg_ego = NULL;
  
   if (ego)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "New ego looked up: '%s'\n", element->identifier);
     msg_ego = update_store_ego (
         store,
         element->identifier,
         GNUNET_IDENTITY_ego_get_private_key(ego)
     );
   }
   else
   {
     struct GNUNET_HashCode hash;
     GNUNET_CRYPTO_hash (element->identifier, strlen (element->identifier), &hash);
  
     if (GNUNET_CONTAINER_multihashmap_get (store->egos, &hash))
     {
       GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Looked up ego got deleted: '%s'\n", element->identifier);
       delete_store_ego(store, element->identifier);
     }
   }
  
   if (element->cb)
     element->cb(element->cls, element->identifier, msg_ego);
  
   GNUNET_CONTAINER_DLL_remove (store->lu_start, store->lu_end, element);
   GNUNET_free (element->identifier);
   GNUNET_free (element);
 }

References GNUNET_MESSENGER_EgoLookup::cb, GNUNET_MESSENGER_EgoLookup::cls, delete_store_ego(), GNUNET_MESSENGER_EgoStore::egos, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CRYPTO_hash(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_IDENTITY_ego_get_private_key(), GNUNET_log, GNUNET_MESSENGER_EgoLookup::identifier, GNUNET_MESSENGER_EgoStore::lu_end, GNUNET_MESSENGER_EgoStore::lu_start, GNUNET_MESSENGER_EgoLookup::store, and update_store_ego().

Referenced by lookup_store_ego().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ lookup_store_ego()

void lookup_store_ego	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const char *	identifier,
		GNUNET_MESSENGER_EgoLookupCallback	lookup,
		void *	cls
	)

Lookups an EGO which was registered to a store under a specific identifier.

Parameters

[in,out]	store	EGO-store
[in]	identifier	Identifier string
[in]	lookup	Lookup callback (non-NULL)
[in]	cls	Closure

Definition at line 281 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert (store);
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store lookup ego: %s\n", identifier);
  
   if (!identifier)
   {
     lookup(cls, identifier, NULL);
     return;
   }
  
   struct GNUNET_MESSENGER_EgoLookup *element = GNUNET_new (struct GNUNET_MESSENGER_EgoLookup);
  
   element->store = store;
  
   element->cb = lookup;
   element->cls = cls;
  
   element->identifier = GNUNET_strdup (identifier);
  
   element->lookup = GNUNET_IDENTITY_ego_lookup(store->cfg, identifier, callback_ego_lookup, element);
  
   GNUNET_CONTAINER_DLL_insert (store->lu_start, store->lu_end, element);
 }

References callback_ego_lookup(), GNUNET_MESSENGER_EgoLookup::cb, GNUNET_MESSENGER_EgoStore::cfg, GNUNET_MESSENGER_EgoLookup::cls, GNUNET_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_IDENTITY_ego_lookup(), GNUNET_log, GNUNET_new, GNUNET_strdup, GNUNET_MESSENGER_EgoLookup::identifier, GNUNET_MESSENGER_EgoLookup::lookup, GNUNET_MESSENGER_EgoStore::lu_end, GNUNET_MESSENGER_EgoStore::lu_start, and GNUNET_MESSENGER_EgoLookup::store.

Referenced by set_srv_handle_name(), setup_srv_handle_name(), and update_srv_handle().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ update_store_ego()

struct GNUNET_MESSENGER_Ego* update_store_ego	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const char *	identifier,
		const struct GNUNET_IDENTITY_PrivateKey *	key
	)

Updates the registration of an EGO to a store under a specific identifier with a new key.

Parameters

[in,out]	store	EGO-store
[in]	identifier	Identifier string
[in]	key	Private EGO key

Returns: Updated EGO

Definition at line 311 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert ((store) && (identifier) && (key));
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store update ego: %s\n", identifier);
  
   struct GNUNET_HashCode hash;
   GNUNET_CRYPTO_hash (identifier, strlen (identifier), &hash);
  
   struct GNUNET_MESSENGER_Ego *ego = GNUNET_CONTAINER_multihashmap_get (store->egos, &hash);
  
   if (!ego)
   {
     ego = GNUNET_new(struct GNUNET_MESSENGER_Ego);
     GNUNET_CONTAINER_multihashmap_put (store->egos, &hash, ego, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST);
   }
  
   GNUNET_memcpy(&(ego->priv), key, sizeof(*key));
  
   if (GNUNET_OK != GNUNET_IDENTITY_key_get_public (key, &(ego->pub)))
     GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Updating invalid ego key failed!\n");
  
   return ego;
 }

References GNUNET_MESSENGER_EgoStore::egos, GNUNET_assert, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_CRYPTO_hash(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_IDENTITY_key_get_public(), GNUNET_log, GNUNET_memcpy, GNUNET_new, GNUNET_OK, key, GNUNET_MESSENGER_Ego::priv, and GNUNET_MESSENGER_Ego::pub.

Referenced by callback_ego_create(), callback_ego_lookup(), and callback_update_ego().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ delete_store_ego()

void delete_store_ego	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const char *	identifier
	)

Deletes the registration of an EGO in a store under a specific identifier.

Parameters

[in,out]	store	EGO-store
[in]	identifier	Identifier string

Definition at line 339 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert ((store) && (identifier));
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store delete ego: %s\n", identifier);
  
   struct GNUNET_HashCode hash;
   GNUNET_CRYPTO_hash (identifier, strlen (identifier), &hash);
  
   struct GNUNET_MESSENGER_Ego *ego = GNUNET_CONTAINER_multihashmap_get (store->egos, &hash);
  
   if (ego)
   {
     GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Ego is not stored!\n");
     return;
   }
  
   if (GNUNET_YES != GNUNET_CONTAINER_multihashmap_remove (store->egos, &hash, ego))
   {
     GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "Removing ego from store failed!\n");
     return;
   }
  
   GNUNET_free(ego);
 }

References GNUNET_MESSENGER_EgoStore::egos, GNUNET_assert, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_multihashmap_remove(), GNUNET_CRYPTO_hash(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, and GNUNET_YES.

Referenced by callback_ego_lookup(), and callback_update_ego().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ callback_ego_rename()

static void callback_ego_rename	(	void *	cls,
		enum GNUNET_ErrorCode	ec
	)

static

FIXME: Dangerous, handle error

Definition at line 367 of file gnunet-service-messenger_ego_store.c.

 {
   struct GNUNET_MESSENGER_EgoOperation *element = cls;
   struct GNUNET_MESSENGER_EgoStore *store = element->store;
  
   GNUNET_assert (element->identifier);
  
   if (GNUNET_EC_NONE != ec)
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "%s\n",
                 GNUNET_ErrorCode_get_hint (ec));
  
   struct GNUNET_HashCode hash;
   GNUNET_CRYPTO_hash (element->identifier, strlen (element->identifier), &hash);
  
   struct GNUNET_MESSENGER_Ego *ego = GNUNET_CONTAINER_multihashmap_get (store->egos, &hash);
  
   if (!ego)
     GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Ego is not stored!\n");
  
   char *identifier = (char*) element->cls;
  
   if (GNUNET_YES == GNUNET_CONTAINER_multihashmap_remove (store->egos, &hash, ego))
   {
     GNUNET_CRYPTO_hash (identifier, strlen (identifier), &hash);
  
     GNUNET_CONTAINER_multihashmap_put (store->egos, &hash, ego,
                                        GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST);
   }
   else
     GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Renaming ego failed!\n");
  
   GNUNET_free (identifier);
  
   GNUNET_CONTAINER_DLL_remove (store->op_start, store->op_end, element);
   GNUNET_free (element->identifier);
   GNUNET_free (element);
 }

References GNUNET_MESSENGER_EgoOperation::cls, GNUNET_MESSENGER_EgoStore::egos, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_multihashmap_remove(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_CRYPTO_hash(), GNUNET_EC_NONE, GNUNET_ERROR_TYPE_WARNING, GNUNET_ErrorCode_get_hint(), GNUNET_free, GNUNET_log, GNUNET_YES, GNUNET_MESSENGER_EgoOperation::identifier, GNUNET_MESSENGER_EgoStore::op_end, GNUNET_MESSENGER_EgoStore::op_start, and GNUNET_MESSENGER_EgoOperation::store.

Referenced by rename_store_ego().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ rename_store_ego()

void rename_store_ego	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const char *	old_identifier,
		const char *	new_identifier
	)

Updates the location of a registered EGO in a store to a different one under a specific new_identifier replacing its old one.

Parameters

[in,out]	store	EGO-store
[in]	old_identifier	Old identifier string
[in]	new_identifier	New identifier string

Definition at line 410 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert ((store) && (old_identifier) && (new_identifier));
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store rename ego: %s -> %s\n", old_identifier, new_identifier);
  
   struct GNUNET_MESSENGER_EgoOperation *element = GNUNET_new (struct GNUNET_MESSENGER_EgoOperation);
  
   element->store = store;
   element->cls = GNUNET_strdup (new_identifier);
  
   element->identifier = GNUNET_strdup (old_identifier);
  
   element->operation = GNUNET_IDENTITY_rename (
       store->identity,
       old_identifier,
       new_identifier,
       callback_ego_rename,
       element
   );
  
   GNUNET_CONTAINER_DLL_insert (store->op_start, store->op_end, element);
 }

References callback_ego_rename(), GNUNET_MESSENGER_EgoOperation::cls, GNUNET_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_IDENTITY_rename(), GNUNET_log, GNUNET_new, GNUNET_strdup, GNUNET_MESSENGER_EgoOperation::identifier, GNUNET_MESSENGER_EgoStore::identity, GNUNET_MESSENGER_EgoStore::op_end, GNUNET_MESSENGER_EgoStore::op_start, GNUNET_MESSENGER_EgoOperation::operation, and GNUNET_MESSENGER_EgoOperation::store.

Referenced by callback_set_handle_name().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ callback_ego_delete()

static void callback_ego_delete	(	void *	cls,
		enum GNUNET_ErrorCode	ec
	)

static

FIXME: Dangerous, handle error

Definition at line 437 of file gnunet-service-messenger_ego_store.c.

 {
   struct GNUNET_MESSENGER_EgoOperation *element = cls;
   struct GNUNET_MESSENGER_EgoStore *store = element->store;
  
   GNUNET_assert (element->identifier);
  
   if (GNUNET_EC_NONE != ec)
     GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "%s\n",
                 GNUNET_ErrorCode_get_hint (ec));
  
   create_store_ego (store, element->identifier);
  
   GNUNET_CONTAINER_DLL_remove (store->op_start, store->op_end, element);
   GNUNET_free (element->identifier);
   GNUNET_free (element);
 }

References GNUNET_MESSENGER_EgoOperation::cls, create_store_ego(), GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_EC_NONE, GNUNET_ERROR_TYPE_WARNING, GNUNET_ErrorCode_get_hint(), GNUNET_free, GNUNET_log, GNUNET_MESSENGER_EgoOperation::identifier, GNUNET_MESSENGER_EgoStore::op_end, GNUNET_MESSENGER_EgoStore::op_start, and GNUNET_MESSENGER_EgoOperation::store.

Referenced by renew_store_ego().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ renew_store_ego()

void renew_store_ego	(	struct GNUNET_MESSENGER_EgoStore *	store,
		const char *	identifier
	)

Replaces the registered EGO in a store under a specific identifier with a newly created one.

Parameters

[in,out]	store	EGO-store
[in]	identifier	Identifier string

Definition at line 460 of file gnunet-service-messenger_ego_store.c.

 {
   GNUNET_assert ((store) && (identifier));
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store renew ego: %s\n", identifier);
  
   struct GNUNET_MESSENGER_EgoOperation *element = GNUNET_new (struct GNUNET_MESSENGER_EgoOperation);
  
   element->store = store;
   element->cls = NULL;
  
   element->identifier = GNUNET_strdup (identifier);
  
   element->operation = GNUNET_IDENTITY_delete(
       store->identity,
       identifier,
       callback_ego_delete,
       element
   );
  
   GNUNET_CONTAINER_DLL_insert (store->op_start, store->op_end, element);
 }

References callback_ego_delete(), GNUNET_MESSENGER_EgoOperation::cls, GNUNET_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_IDENTITY_delete(), GNUNET_log, GNUNET_new, GNUNET_strdup, GNUNET_MESSENGER_EgoOperation::identifier, GNUNET_MESSENGER_EgoStore::identity, GNUNET_MESSENGER_EgoStore::op_end, GNUNET_MESSENGER_EgoStore::op_start, GNUNET_MESSENGER_EgoOperation::operation, and GNUNET_MESSENGER_EgoOperation::store.

Referenced by callback_update_handle().

Here is the call graph for this function:

Here is the caller graph for this function:

Functions

Detailed Description

Function Documentation

◆ callback_update_ego()

◆ init_ego_store()

◆ iterate_destroy_egos()

◆ clear_ego_store()

◆ iterate_create_ego()

◆ callback_ego_create()

◆ create_store_ego()

◆ bind_store_ego()

◆ unbind_store_ego()

◆ callback_ego_lookup()

◆ lookup_store_ego()

◆ update_store_ego()

◆ delete_store_ego()

◆ callback_ego_rename()

◆ rename_store_ego()

◆ callback_ego_delete()

◆ renew_store_ego()