gnunet-service-messenger_operation_store.c File Reference

GNUnet MESSENGER service. More...

#include "platform.h"
#include "gnunet-service-messenger_operation_store.h"
#include "gnunet-service-messenger_operation.h"
#include "gnunet-service-messenger_room.h"

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

Go to the source code of this file.

Functions
void	init_operation_store (struct GNUNET_MESSENGER_OperationStore *store, struct GNUNET_MESSENGER_SrvRoom *room)
	Initializes an operation store as fully empty with a given room. More...
static int	iterate_destroy_operations (void *cls, const struct GNUNET_HashCode *key, void *value)
void	clear_operation_store (struct GNUNET_MESSENGER_OperationStore *store)
	Clears an operation store, stops all operations and deallocates its memory. More...
static int	callback_scan_for_operations (void *cls, const char *filename)
void	load_operation_store (struct GNUNET_MESSENGER_OperationStore *store, const char *directory)
	Loads operations from a directory into an operation store. More...
static int	iterate_save_operations (void *cls, const struct GNUNET_HashCode *key, void *value)
void	save_operation_store (const struct GNUNET_MESSENGER_OperationStore *store, const char *directory)
	Saves operations from an operation store into a directory. More...
enum GNUNET_MESSENGER_OperationType	get_store_operation_type (const struct GNUNET_MESSENGER_OperationStore *store, const struct GNUNET_HashCode *hash)
	Returns the type of the active operation under a given hash in a specific operation store. More...
int	use_store_operation (struct GNUNET_MESSENGER_OperationStore *store, const struct GNUNET_HashCode *hash, enum GNUNET_MESSENGER_OperationType type, struct GNUNET_TIME_Relative delay)
	Tries to use an operation under a given hash in a specific operation store. More...
void	cancel_store_operation (struct GNUNET_MESSENGER_OperationStore *store, const struct GNUNET_HashCode *hash)
	Stops any active operation under a given hash in a specific operation store. More...
void	callback_room_deletion (struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_HashCode *hash)
void	callback_room_merge (struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_HashCode *hash)
void	callback_store_operation (struct GNUNET_MESSENGER_OperationStore *store, enum GNUNET_MESSENGER_OperationType type, const struct GNUNET_HashCode *hash)

Detailed Description

GNUnet MESSENGER service.

Author

Tobias Frisch

Definition in file gnunet-service-messenger_operation_store.c.

Function Documentation

init_operation_store()

void init_operation_store	(	struct GNUNET_MESSENGER_OperationStore *	store,
		struct GNUNET_MESSENGER_SrvRoom *	room
	)

Initializes an operation store as fully empty with a given room.

Parameters

[out]	store	Operation store
[in,out]	room	Room

Definition at line 33 of file gnunet-service-messenger_operation_store.c.

{
  GNUNET_assert((store) && (room));
 
  store->room = room;
  store->operations = GNUNET_CONTAINER_multihashmap_create(8, GNUNET_NO);
}

References GNUNET_assert, GNUNET_CONTAINER_multihashmap_create(), GNUNET_NO, GNUNET_MESSENGER_OperationStore::operations, and GNUNET_MESSENGER_OperationStore::room.

Referenced by create_srv_room().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_destroy_operations()

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

static

Definition at line 43 of file gnunet-service-messenger_operation_store.c.

{
  struct GNUNET_MESSENGER_Operation *op = value;
 
  destroy_operation(op);
 
  return GNUNET_YES;
}

References destroy_operation(), GNUNET_YES, op, and value.

Referenced by clear_operation_store().

Here is the call graph for this function:

Here is the caller graph for this function:

clear_operation_store()

void clear_operation_store

(

struct GNUNET_MESSENGER_OperationStore *

store

)

Clears an operation store, stops all operations and deallocates its memory.

Parameters

[in,out]

store

Operation store

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

{
  GNUNET_assert(store);
 
  GNUNET_CONTAINER_multihashmap_iterate (store->operations, iterate_destroy_operations, NULL);
  GNUNET_CONTAINER_multihashmap_destroy(store->operations);
}

References GNUNET_assert, GNUNET_CONTAINER_multihashmap_destroy(), GNUNET_CONTAINER_multihashmap_iterate(), iterate_destroy_operations(), GNUNET_MESSENGER_OperationStore::operations, and GNUNET_MESSENGER_Operation::store.

Referenced by destroy_srv_room().

Here is the call graph for this function:

Here is the caller graph for this function:

callback_scan_for_operations()

static int callback_scan_for_operations ( void *  cls, const char *  filename  )

static

Definition at line 64 of file gnunet-service-messenger_operation_store.c.

{
  struct GNUNET_MESSENGER_OperationStore *store = cls;
 
  if (GNUNET_YES != GNUNET_DISK_file_test (filename))
    return GNUNET_OK;
 
  if ((strlen(filename) <= 4) || (0 != strcmp(filename + strlen(filename) - 4, ".cfg")))
    return GNUNET_OK;
 
  struct GNUNET_MESSENGER_Operation *op = load_operation(store, filename);
 
  if ((op) && (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put(
      store->operations,
      &(op->hash), op,
      GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST)))
  {
    destroy_operation(op);
  }
 
  return GNUNET_OK;
}

References destroy_operation(), filename, GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_DISK_file_test(), GNUNET_OK, GNUNET_YES, load_operation(), op, GNUNET_MESSENGER_OperationStore::operations, and GNUNET_MESSENGER_Operation::store.

Referenced by load_operation_store().

Here is the call graph for this function:

Here is the caller graph for this function:

load_operation_store()

void load_operation_store	(	struct GNUNET_MESSENGER_OperationStore *	store,
		const char *	directory
	)

Loads operations from a directory into an operation store.

Parameters

[out]	store	Operation store
[in]	directory	Path to a directory

Definition at line 89 of file gnunet-service-messenger_operation_store.c.

{
  GNUNET_assert ((store) && (directory));
 
  char* load_dir;
  GNUNET_asprintf (&load_dir, "%s%s%c", directory, "operations", DIR_SEPARATOR);
 
  if (GNUNET_OK == GNUNET_DISK_directory_test (load_dir, GNUNET_YES))
    GNUNET_DISK_directory_scan (load_dir, callback_scan_for_operations, store);
 
  GNUNET_free(load_dir);
}

References callback_scan_for_operations(), DIR_SEPARATOR, GNUNET_asprintf(), GNUNET_assert, GNUNET_DISK_directory_scan(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_OK, GNUNET_YES, and GNUNET_MESSENGER_Operation::store.

Referenced by load_srv_room().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_save_operations()

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

static

Definition at line 104 of file gnunet-service-messenger_operation_store.c.

{
  const char *save_dir = cls;
 
  struct GNUNET_MESSENGER_Operation *op = value;
 
  if (!op)
    return GNUNET_YES;
 
  char *op_dir;
  GNUNET_asprintf (&op_dir, "%s%s.cfg", save_dir, GNUNET_h2s(key));
  save_operation(op, op_dir);
 
  GNUNET_free(op_dir);
  return GNUNET_YES;
}

References GNUNET_asprintf(), GNUNET_free, GNUNET_h2s(), GNUNET_YES, key, op, save_operation(), and value.

Referenced by get_store_operation_type().

Here is the call graph for this function:

Here is the caller graph for this function:

save_operation_store()

void save_operation_store	(	const struct GNUNET_MESSENGER_OperationStore *	store,
		const char *	directory
	)

Saves operations from an operation store into a directory.

Parameters

[in]	store	Operation store
[in]	directory	Path to a directory

Definition at line 124 of file gnunet-service-messenger_operation_store.c.

{
  GNUNET_assert ((store) && (directory));
 
  char* save_dir;
  GNUNET_asprintf (&save_dir, "%s%s%c", directory, "operations", DIR_SEPARATOR);
 
  if ((GNUNET_YES == GNUNET_DISK_directory_test (save_dir, GNUNET_NO)) ||
      (GNUNET_OK == GNUNET_DISK_directory_create (save_dir)))
    GNUNET_CONTAINER_multihashmap_iterate (store->operations, iterate_save_operations, save_dir);
 
  GNUNET_free(save_dir);
}

Referenced by save_srv_room().

Here is the caller graph for this function:

get_store_operation_type()

enum GNUNET_MESSENGER_OperationType get_store_operation_type	(	const struct GNUNET_MESSENGER_OperationStore *	store,
		const struct GNUNET_HashCode *	hash
	)

Returns the type of the active operation under a given hash in a specific operation store.

If there is no active operation under the given hash, GNUNET_MESSENGER_OP_UNKNOWN gets returned instead.

Parameters

[in]	store	Operation store
[in]	hash	Hash of message

Returns

Type of operation or GNUNET_MESSENGER_OP_UNKNOWN

Definition at line 124 of file gnunet-service-messenger_operation_store.c.

{
  GNUNET_assert((store) && (hash));
 
  struct GNUNET_MESSENGER_Operation *op = GNUNET_CONTAINER_multihashmap_get(store->operations, hash);
 
  if (!op)
    return GNUNET_MESSENGER_OP_UNKNOWN;
 
  return op->type;
}

References DIR_SEPARATOR, GNUNET_asprintf(), GNUNET_assert, GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_DISK_directory_create(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_NO, GNUNET_OK, GNUNET_YES, iterate_save_operations(), GNUNET_MESSENGER_OperationStore::operations, and GNUNET_MESSENGER_Operation::store.

Referenced by idle_request_room_messages(), update_room_message(), and update_tunnel_last_message().

Here is the call graph for this function:

Here is the caller graph for this function:

use_store_operation()

int use_store_operation	(	struct GNUNET_MESSENGER_OperationStore *	store,
		const struct GNUNET_HashCode *	hash,
		enum GNUNET_MESSENGER_OperationType	type,
		struct GNUNET_TIME_Relative	delay
	)

Tries to use an operation under a given hash in a specific operation store.

The operation will use the selected type if successful. The operation will be delayed by a given delay.

If the selected type is GNUNET_MESSENGER_OP_DELETE any active operation under the given hash will be stopped and replaced.

If the new operation could be started successfully the method returns GNUNET_OK, otherwise GNUNET_SYSERR.

Parameters

[in,out]	store	Operation store
[in]	hash	Hash of message
[in]	type	Operation type
[in]	delay	Delay

Returns

GNUNET_OK on success, otherwise GNUNET_SYSERR

Definition at line 154 of file gnunet-service-messenger_operation_store.c.

{
  GNUNET_assert((store) && (hash));
 
  struct GNUNET_MESSENGER_Operation *op = GNUNET_CONTAINER_multihashmap_get(store->operations, hash);
 
  if (op)
    goto use_op;
 
  op = create_operation(hash);
 
  if (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put(store->operations, hash, op, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))
  {
    destroy_operation(op);
 
    return GNUNET_SYSERR;
  }
 
use_op:
  if ((op->type != GNUNET_MESSENGER_OP_UNKNOWN) &&
      (type == GNUNET_MESSENGER_OP_DELETE))
    stop_operation (op);
 
  return start_operation(op, type, store, delay);
}

References create_operation(), delay, destroy_operation(), GNUNET_assert, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_MESSENGER_OP_DELETE, GNUNET_MESSENGER_OP_UNKNOWN, GNUNET_OK, GNUNET_SYSERR, GNUNET_MESSENGER_Operation::hash, op, GNUNET_MESSENGER_OperationStore::operations, start_operation(), stop_operation(), GNUNET_MESSENGER_Operation::store, and type.

Referenced by callback_found_message(), delete_srv_room_message(), idle_request_room_messages(), and send_message_request().

Here is the call graph for this function:

Here is the caller graph for this function:

cancel_store_operation()

void cancel_store_operation	(	struct GNUNET_MESSENGER_OperationStore *	store,
		const struct GNUNET_HashCode *	hash
	)

Stops any active operation under a given hash in a specific operation store.

Beware that calling this method will also implicitly free the memory of any active operation under the given hash!

Parameters

[in,out]	store	Operation store
[in]	hash	Hash of message

Definition at line 184 of file gnunet-service-messenger_operation_store.c.

{
  GNUNET_assert((store) && (hash));
 
  struct GNUNET_MESSENGER_Operation *op = GNUNET_CONTAINER_multihashmap_get(store->operations, hash);
 
  if (!op)
    return;
 
  stop_operation(op);
 
  if (GNUNET_YES != GNUNET_CONTAINER_multihashmap_remove(store->operations, hash, op))
    GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Canceled operation could not be removed: %s\n",
               GNUNET_h2s(hash));
 
  destroy_operation(op);
}

References destroy_operation(), GNUNET_assert, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_multihashmap_remove(), GNUNET_ERROR_TYPE_WARNING, GNUNET_h2s(), GNUNET_log, GNUNET_YES, GNUNET_MESSENGER_Operation::hash, op, GNUNET_MESSENGER_OperationStore::operations, stop_operation(), and GNUNET_MESSENGER_Operation::store.

Referenced by callback_store_operation(), and update_room_message().

Here is the call graph for this function:

Here is the caller graph for this function:

callback_room_deletion()

void callback_room_deletion	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		const struct GNUNET_HashCode *	hash
	)

Definition at line 648 of file gnunet-service-messenger_room.c.

{
  if (GNUNET_OK != delete_store_message (get_srv_room_message_store(room), hash))
  {
    GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Deletion of message failed! (%s)\n", GNUNET_h2s(hash));
    return;
  }
}

References delete_store_message(), get_srv_room_message_store(), GNUNET_ERROR_TYPE_WARNING, GNUNET_h2s(), GNUNET_log, and GNUNET_OK.

Referenced by callback_store_operation().

Here is the call graph for this function:

Here is the caller graph for this function:

callback_room_merge()

void callback_room_merge	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		const struct GNUNET_HashCode *	hash
	)

Definition at line 659 of file gnunet-service-messenger_room.c.

{
  if (!room->host)
    return;
 
  send_srv_room_message (room, room->host, create_message_merge (hash));
}

References create_message_merge(), GNUNET_MESSENGER_SrvRoom::host, and send_srv_room_message().

Referenced by callback_store_operation().

Here is the call graph for this function:

Here is the caller graph for this function:

callback_store_operation()

void callback_store_operation	(	struct GNUNET_MESSENGER_OperationStore *	store,
		enum GNUNET_MESSENGER_OperationType	type,
		const struct GNUNET_HashCode *	hash
	)

Definition at line 212 of file gnunet-service-messenger_operation_store.c.

{
  GNUNET_assert((store) && (hash));
 
  struct GNUNET_HashCode op_hash;
  GNUNET_memcpy(&op_hash, hash, sizeof(op_hash));
  cancel_store_operation (store, &op_hash);
 
  struct GNUNET_MESSENGER_SrvRoom *room = store->room;
 
  switch (type)
  {
  case GNUNET_MESSENGER_OP_REQUEST:
    break;
  case GNUNET_MESSENGER_OP_DELETE:
    callback_room_deletion (room, &op_hash);
    break;
  case GNUNET_MESSENGER_OP_MERGE:
    callback_room_merge (room, &op_hash);
    break;
  default:
    break;
  }
}

References callback_room_deletion(), callback_room_merge(), cancel_store_operation(), GNUNET_assert, GNUNET_memcpy, GNUNET_MESSENGER_OP_DELETE, GNUNET_MESSENGER_OP_MERGE, GNUNET_MESSENGER_OP_REQUEST, GNUNET_MESSENGER_Operation::hash, GNUNET_MESSENGER_OperationStore::room, GNUNET_MESSENGER_Operation::store, and type.

Referenced by callback_operation().

Here is the call graph for this function:

Here is the caller graph for this function: