gnunet-service-messenger_ego_store.c File Reference

GNUnet MESSENGER service. More...

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

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

Go to the source code of this file.

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 void	callback_ego_create (void *cls, const struct GNUNET_IDENTITY_PrivateKey *key, const char *emsg)
void	create_store_ego (struct GNUNET_MESSENGER_EgoStore *store, const char *identifier, void *handle)
	Creates a new EGO which will be registered to a store under a specific identifier. 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...
static void	callback_ego_rename (void *cls, const char *emsg)
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...

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 31 of file gnunet-service-messenger_ego_store.c.

{
  if ((!ego) || (!identifier))
    return;
 
  struct GNUNET_MESSENGER_EgoStore *store = cls;
 
  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));
}

References 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 47 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->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::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 65 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 75 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);
 
  if (store->identity)
  {
    GNUNET_IDENTITY_disconnect (store->identity);
 
    store->identity = NULL;
  }
}

References GNUNET_MESSENGER_EgoStore::egos, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multihashmap_destroy(), GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_free, GNUNET_IDENTITY_cancel(), GNUNET_IDENTITY_disconnect(), GNUNET_IDENTITY_ego_lookup_cancel(), GNUNET_MESSENGER_EgoLookup::identifier, GNUNET_MESSENGER_EgoStore::identity, iterate_destroy_egos(), GNUNET_MESSENGER_EgoLookup::lookup, GNUNET_MESSENGER_EgoStore::lu_end, GNUNET_MESSENGER_EgoStore::lu_start, op, GNUNET_MESSENGER_EgoStore::op_end, GNUNET_MESSENGER_EgoStore::op_start, GNUNET_MESSENGER_EgoLookup::store, and GNUNET_MESSENGER_EgoOperation::store.

Referenced by destroy_service().

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, const char *  emsg  )

static

Definition at line 121 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 (emsg)
    GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "%s\n", emsg);
 
  if (key)
  {
    struct GNUNET_MESSENGER_SrvHandle *handle = element->handle;
 
    struct GNUNET_MESSENGER_Ego *msg_ego = update_store_ego (store, element->identifier, key);
 
    set_handle_ego (handle, 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_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, handle, GNUNET_MESSENGER_EgoOperation::handle, GNUNET_MESSENGER_EgoOperation::identifier, key, GNUNET_MESSENGER_EgoStore::op_end, GNUNET_MESSENGER_EgoStore::op_start, set_handle_ego(), 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,
		void *	handle
	)

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

A given handle will be informed about the creation and changes its EGO accordingly.

Parameters

	[in/out]	store EGO-store
[in]	identifier	Identifier string
	[in/out]	handle Handle or NULL

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

{
  GNUNET_assert ((store) && (identifier));
 
  struct GNUNET_MESSENGER_EgoOperation *element = GNUNET_new (struct GNUNET_MESSENGER_EgoOperation);
 
  element->store = store;
  element->handle = handle;
 
  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_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_IDENTITY_create(), GNUNET_IDENTITY_TYPE_ECDSA, GNUNET_new, GNUNET_strdup, handle, GNUNET_MESSENGER_EgoOperation::handle, 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:

callback_ego_lookup()

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

static

Definition at line 170 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;
 
  if (ego)
    msg_ego = update_store_ego (
        store, element->identifier, GNUNET_IDENTITY_ego_get_private_key(ego)
    );
  else
    msg_ego = NULL;
 
  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, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_IDENTITY_ego_get_private_key(), 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 196 of file gnunet-service-messenger_ego_store.c.

{
  GNUNET_assert (store);
 
  if (!identifier)
  {
    lookup(cls, identifier, NULL);
    return;
  }
 
  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)
    lookup(cls, identifier, ego);
  else
  {
    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_MESSENGER_EgoStore::egos, GNUNET_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CRYPTO_hash(), GNUNET_IDENTITY_ego_lookup(), 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_handle_name(), setup_handle_name(), and update_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 234 of file gnunet-service-messenger_ego_store.c.

{
  GNUNET_assert ((store) && (identifier) && (key));
 
  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_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:

callback_ego_rename()

static void callback_ego_rename ( void *  cls, const char *  emsg  )

static

Definition at line 260 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 (emsg)
    GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "%s\n", emsg);
 
  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 (GNUNET_YES == GNUNET_CONTAINER_multihashmap_remove (store->egos, &hash, ego))
  {
    GNUNET_CRYPTO_hash ((char*) element->handle, strlen ((char*) element->handle), &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 (element->handle);
 
  GNUNET_CONTAINER_DLL_remove (store->op_start, store->op_end, element);
  GNUNET_free (element->identifier);
  GNUNET_free (element);
}

References 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_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_YES, GNUNET_MESSENGER_EgoOperation::handle, 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 294 of file gnunet-service-messenger_ego_store.c.

{
  GNUNET_assert ((store) && (old_identifier) && (new_identifier));
 
  struct GNUNET_MESSENGER_EgoOperation *element = GNUNET_new (struct GNUNET_MESSENGER_EgoOperation);
 
  element->store = store;
  element->handle = 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_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_IDENTITY_rename(), GNUNET_new, GNUNET_strdup, GNUNET_MESSENGER_EgoOperation::handle, 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: