gnunet-service-messenger_member_store.c File Reference

GNUnet MESSENGER service. More...

#include "platform.h"
#include "gnunet-service-messenger_member_store.h"
#include "gnunet-service-messenger_member.h"
#include "gnunet-service-messenger_service.h"
#include "gnunet-service-messenger_room.h"

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

Go to the source code of this file.

Data Structures
struct	GNUNET_MESSENGER_ClosureIterateMembers

Functions
void	init_member_store (struct GNUNET_MESSENGER_MemberStore *store, struct GNUNET_MESSENGER_SrvRoom *room)
	Initializes a member store as fully empty connected to a room. More...
static int	iterate_destroy_members (void *cls, const struct GNUNET_ShortHashCode *key, void *value)
void	clear_member_store (struct GNUNET_MESSENGER_MemberStore *store)
	Clears a member store, wipes its content and deallocates its memory. More...
struct GNUNET_MESSENGER_ContactStore *	get_member_contact_store (struct GNUNET_MESSENGER_MemberStore *store)
	Returns the used contact store of a given member store. More...
const struct GNUNET_HashCode *	get_member_store_key (const struct GNUNET_MESSENGER_MemberStore *store)
	Returns the shared secret you need to access a room of the store. More...
static int	callback_scan_for_members (void *cls, const char *filename)
static int	iterate_load_next_member_sessions (void *cls, const struct GNUNET_ShortHashCode *id, void *value)
static int	iterate_sync_member_contacts (void *cls, const struct GNUNET_ShortHashCode *id, void *value)
void	load_member_store (struct GNUNET_MESSENGER_MemberStore *store, const char *directory)
	Loads members from a directory into a member store. More...
static int	iterate_save_members (void *cls, const struct GNUNET_ShortHashCode *id, void *value)
void	save_member_store (struct GNUNET_MESSENGER_MemberStore *store, const char *directory)
	Saves members from a member store into a directory. More...
struct GNUNET_MESSENGER_Member *	get_store_member (const struct GNUNET_MESSENGER_MemberStore *store, const struct GNUNET_ShortHashCode *id)
	Returns the member in a store identified by a given id. More...
struct GNUNET_MESSENGER_Member *	get_store_member_of (struct GNUNET_MESSENGER_MemberStore *store, const struct GNUNET_MESSENGER_Message *message)
	Returns the member of a store using a sender id of a given message. More...
struct GNUNET_MESSENGER_Member *	add_store_member (struct GNUNET_MESSENGER_MemberStore *store, const struct GNUNET_ShortHashCode *id)
	Adds a member to a store under a specific id and returns it on success. More...
static int	iterate_store_members_it (void *cls, const struct GNUNET_ShortHashCode *key, void *value)
int	iterate_store_members (struct GNUNET_MESSENGER_MemberStore *store, GNUNET_MESSENGER_MemberIteratorCallback it, void *cls)
	Iterate through all member sessions currently connected to the members of the given member store and call the provided iterator callback with a selected closure. More...

Detailed Description

GNUnet MESSENGER service.

Author

Tobias Frisch

Definition in file gnunet-service-messenger_member_store.c.

Function Documentation

init_member_store()

void init_member_store	(	struct GNUNET_MESSENGER_MemberStore *	store,
		struct GNUNET_MESSENGER_SrvRoom *	room
	)

Initializes a member store as fully empty connected to a room.

Parameters

[out]	store	Member store
	room	Room

Definition at line 34 of file gnunet-service-messenger_member_store.c.

{
  GNUNET_assert ((store) && (room));
 
  store->room = room;
  store->members = GNUNET_CONTAINER_multishortmap_create(8, GNUNET_NO);
}

References GNUNET_assert, GNUNET_CONTAINER_multishortmap_create(), GNUNET_NO, GNUNET_MESSENGER_MemberStore::members, and GNUNET_MESSENGER_MemberStore::room.

Referenced by create_srv_room().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_destroy_members()

static int iterate_destroy_members ( void *  cls, const struct GNUNET_ShortHashCode *  key, void *  value  )

static

Definition at line 44 of file gnunet-service-messenger_member_store.c.

{
  struct GNUNET_MESSENGER_Member *member = value;
  destroy_member(member);
  return GNUNET_YES;
}

References destroy_member(), GNUNET_YES, and value.

Referenced by clear_member_store().

Here is the call graph for this function:

Here is the caller graph for this function:

clear_member_store()

void clear_member_store

(

struct GNUNET_MESSENGER_MemberStore *

store

)

Clears a member store, wipes its content and deallocates its memory.

Parameters

[in,out]

store

Member store

Definition at line 54 of file gnunet-service-messenger_member_store.c.

{
  GNUNET_assert ((store) && (store->members));
 
  GNUNET_CONTAINER_multishortmap_iterate (store->members, iterate_destroy_members, NULL);
  GNUNET_CONTAINER_multishortmap_destroy (store->members);
}

References GNUNET_assert, GNUNET_CONTAINER_multishortmap_destroy(), GNUNET_CONTAINER_multishortmap_iterate(), iterate_destroy_members(), GNUNET_MESSENGER_MemberStore::members, and GNUNET_MESSENGER_Member::store.

Referenced by destroy_srv_room().

Here is the call graph for this function:

Here is the caller graph for this function:

get_member_contact_store()

struct GNUNET_MESSENGER_ContactStore* get_member_contact_store

(

struct GNUNET_MESSENGER_MemberStore *

store

)

Returns the used contact store of a given member store.

Parameters

[in,out]

store

Member store

Returns

Contact store

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

{
  GNUNET_assert ((store) && (store->room));
 
  struct GNUNET_MESSENGER_SrvRoom *room = store->room;
 
  return get_service_contact_store(room->service);
}

References get_service_contact_store(), GNUNET_assert, GNUNET_MESSENGER_MemberStore::room, and GNUNET_MESSENGER_SrvRoom::service.

Referenced by check_member_session_completion(), create_member_session(), destroy_member_session(), reset_member_session(), and switch_member_session().

Here is the call graph for this function:

Here is the caller graph for this function:

get_member_store_key()

const struct GNUNET_HashCode* get_member_store_key

(

const struct GNUNET_MESSENGER_MemberStore *

store

)

Returns the shared secret you need to access a room of the store.

Parameters

[in]

store

Member store

Returns

Shared secret

Definition at line 74 of file gnunet-service-messenger_member_store.c.

{
  GNUNET_assert (store);
 
  return get_srv_room_key((const struct GNUNET_MESSENGER_SrvRoom*) store->room);
}

References get_srv_room_key(), GNUNET_assert, and GNUNET_MESSENGER_MemberStore::room.

Referenced by get_member_session_key().

Here is the call graph for this function:

Here is the caller graph for this function:

callback_scan_for_members()

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

static

Definition at line 82 of file gnunet-service-messenger_member_store.c.

{
  struct GNUNET_MESSENGER_MemberStore *store = cls;
 
  if (GNUNET_YES == GNUNET_DISK_directory_test (filename, GNUNET_YES))
  {
    char *directory;
 
    GNUNET_asprintf (&directory, "%s%c", filename, DIR_SEPARATOR);
 
    load_member(store, directory);
 
    GNUNET_free(directory);
  }
 
  return GNUNET_OK;
}

References DIR_SEPARATOR, filename, GNUNET_asprintf(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_OK, GNUNET_YES, and load_member().

Referenced by load_member_store().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_load_next_member_sessions()

static int iterate_load_next_member_sessions ( void *  cls, const struct GNUNET_ShortHashCode *  id, void *  value  )

static

Definition at line 102 of file gnunet-service-messenger_member_store.c.

{
  const char *sync_dir = cls;
 
  struct GNUNET_MESSENGER_Member *member = value;
 
  if (!member)
    return GNUNET_YES;
 
  char *member_dir;
  GNUNET_asprintf (&member_dir, "%s%s%c", sync_dir, GNUNET_sh2s(id), DIR_SEPARATOR);
 
  if (GNUNET_YES == GNUNET_DISK_directory_test (member_dir, GNUNET_YES))
    load_member_next_sessions (member, member_dir);
 
  GNUNET_free(member_dir);
  return GNUNET_YES;
}

References DIR_SEPARATOR, GNUNET_asprintf(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_sh2s(), GNUNET_YES, load_member_next_sessions(), and value.

Referenced by load_member_store().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_sync_member_contacts()

static int iterate_sync_member_contacts ( void *  cls, const struct GNUNET_ShortHashCode *  id, void *  value  )

static

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

{
  struct GNUNET_MESSENGER_Member *member = value;
 
  if (!member)
    return GNUNET_YES;
 
  sync_member_contacts (member);
  return GNUNET_YES;
}

References GNUNET_YES, sync_member_contacts(), and value.

Referenced by load_member_store().

Here is the call graph for this function:

Here is the caller graph for this function:

load_member_store()

void load_member_store	(	struct GNUNET_MESSENGER_MemberStore *	store,
		const char *	directory
	)

Loads members from a directory into a member store.

Parameters

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

Definition at line 138 of file gnunet-service-messenger_member_store.c.

{
  GNUNET_assert ((store) && (directory));
 
  char *scan_dir;
  GNUNET_asprintf (&scan_dir, "%s%s%c", directory, "members", DIR_SEPARATOR);
 
  if (GNUNET_OK == GNUNET_DISK_directory_test (scan_dir, GNUNET_YES))
    GNUNET_DISK_directory_scan (scan_dir, callback_scan_for_members, store);
 
  GNUNET_CONTAINER_multishortmap_iterate(store->members, iterate_load_next_member_sessions, scan_dir);
  GNUNET_CONTAINER_multishortmap_iterate(store->members, iterate_sync_member_contacts, NULL);
 
  GNUNET_free(scan_dir);
}

References callback_scan_for_members(), DIR_SEPARATOR, GNUNET_asprintf(), GNUNET_assert, GNUNET_CONTAINER_multishortmap_iterate(), GNUNET_DISK_directory_scan(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_OK, GNUNET_YES, iterate_load_next_member_sessions(), iterate_sync_member_contacts(), GNUNET_MESSENGER_MemberStore::members, find_typedefs::scan_dir(), and GNUNET_MESSENGER_Member::store.

Referenced by load_srv_room().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_save_members()

static int iterate_save_members ( void *  cls, const struct GNUNET_ShortHashCode *  id, void *  value  )

static

Definition at line 156 of file gnunet-service-messenger_member_store.c.

{
  const char *save_dir = cls;
 
  struct GNUNET_MESSENGER_Member *member = value;
 
  if (!member)
    return GNUNET_YES;
 
  char *member_dir;
  GNUNET_asprintf (&member_dir, "%s%s%c", save_dir, GNUNET_sh2s(id), DIR_SEPARATOR);
 
  if ((GNUNET_YES == GNUNET_DISK_directory_test (member_dir, GNUNET_NO)) ||
      (GNUNET_OK == GNUNET_DISK_directory_create (member_dir)))
    save_member(member, member_dir);
 
  GNUNET_free(member_dir);
  return GNUNET_YES;
}

References DIR_SEPARATOR, GNUNET_asprintf(), GNUNET_DISK_directory_create(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_NO, GNUNET_OK, GNUNET_sh2s(), GNUNET_YES, save_member(), and value.

Referenced by save_member_store().

Here is the call graph for this function:

Here is the caller graph for this function:

save_member_store()

void save_member_store	(	struct GNUNET_MESSENGER_MemberStore *	store,
		const char *	directory
	)

Saves members from a member store into a directory.

Parameters

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

Definition at line 179 of file gnunet-service-messenger_member_store.c.

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

References DIR_SEPARATOR, GNUNET_asprintf(), GNUNET_assert, GNUNET_CONTAINER_multishortmap_iterate(), GNUNET_DISK_directory_create(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_NO, GNUNET_OK, GNUNET_YES, iterate_save_members(), GNUNET_MESSENGER_MemberStore::members, and GNUNET_MESSENGER_Member::store.

Referenced by save_srv_room().

Here is the call graph for this function:

Here is the caller graph for this function:

get_store_member()

struct GNUNET_MESSENGER_Member* get_store_member	(	const struct GNUNET_MESSENGER_MemberStore *	store,
		const struct GNUNET_ShortHashCode *	id
	)

Returns the member in a store identified by a given id.

If the store does not contain a member with the given id, NULL gets returned.

Parameters

[in]	store	Member store
[in]	id	Member id

Returns

Member or NULL

Definition at line 195 of file gnunet-service-messenger_member_store.c.

{
  GNUNET_assert ((store) && (store->members) && (id));
 
  return GNUNET_CONTAINER_multishortmap_get (store->members, id);
}

References GNUNET_assert, GNUNET_CONTAINER_multishortmap_get(), GNUNET_MESSENGER_MemberStore::members, and GNUNET_MESSENGER_Member::store.

Referenced by add_store_member(), get_handle_member_session(), get_store_member_of(), handle_get_message(), load_member_session_next(), and solve_srv_room_member_collisions().

Here is the call graph for this function:

Here is the caller graph for this function:

get_store_member_of()

struct GNUNET_MESSENGER_Member* get_store_member_of	(	struct GNUNET_MESSENGER_MemberStore *	store,
		const struct GNUNET_MESSENGER_Message *	message
	)

Returns the member of a store using a sender id of a given message.

If the member does not provide a matching session, NULL gets returned.

Parameters

[in,out]	store	Member store
[in]	message	Message

Returns

Member or NULL

Definition at line 204 of file gnunet-service-messenger_member_store.c.

{
  if ((GNUNET_MESSENGER_KIND_INFO == message->header.kind) ||
      (GNUNET_MESSENGER_KIND_JOIN == message->header.kind))
    return add_store_member(store, &(message->header.sender_id));
  else
    return get_store_member(store, &(message->header.sender_id));
}

References add_store_member(), get_store_member(), GNUNET_MESSENGER_KIND_INFO, GNUNET_MESSENGER_KIND_JOIN, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessageHeader::sender_id, and GNUNET_MESSENGER_Member::store.

Referenced by callback_found_message(), callback_room_handle_message(), check_srv_room_peer_status(), handle_room_messages(), and recv_message_request().

Here is the call graph for this function:

Here is the caller graph for this function:

add_store_member()

struct GNUNET_MESSENGER_Member* add_store_member	(	struct GNUNET_MESSENGER_MemberStore *	store,
		const struct GNUNET_ShortHashCode *	id
	)

Adds a member to a store under a specific id and returns it on success.

Parameters

[in,out]	store	Member store
[in]	id	Member id

Returns

Member or NULL

Definition at line 215 of file gnunet-service-messenger_member_store.c.

{
  GNUNET_assert ((store) && (store->members));
 
  struct GNUNET_MESSENGER_Member *member = id? get_store_member(store, id) : NULL;
 
  if (member)
    return member;
 
  member = create_member(store, id);
 
  if (!member)
    return NULL;
 
  if (GNUNET_OK != GNUNET_CONTAINER_multishortmap_put (store->members, get_member_id(member), member,
                                                       GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))
  {
    destroy_member(member);
    return NULL;
  }
 
  return member;
}

References create_member(), destroy_member(), get_member_id(), get_store_member(), GNUNET_assert, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_CONTAINER_multishortmap_put(), GNUNET_OK, GNUNET_MESSENGER_MemberStore::members, and GNUNET_MESSENGER_Member::store.

Referenced by get_store_member_of(), join_room_locally(), load_member(), open_srv_room(), and switch_member_session().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_store_members_it()

static int iterate_store_members_it ( void *  cls, const struct GNUNET_ShortHashCode *  key, void *  value  )

static

Definition at line 246 of file gnunet-service-messenger_member_store.c.

{
  struct GNUNET_MESSENGER_ClosureIterateMembers *iterate = cls;
  struct GNUNET_MESSENGER_Member *member = value;
 
  return iterate_member_sessions(member, iterate->it, iterate->cls);
}

References GNUNET_MESSENGER_ClosureIterateMembers::cls, GNUNET_MESSENGER_ClosureIterateMembers::it, iterate_member_sessions(), and value.

Referenced by iterate_store_members().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_store_members()

int iterate_store_members	(	struct GNUNET_MESSENGER_MemberStore *	store,
		GNUNET_MESSENGER_MemberIteratorCallback	it,
		void *	cls
	)

Iterate through all member sessions currently connected to the members of the given member store and call the provided iterator callback with a selected closure.

The function will return the amount of members it iterated through.

Parameters

[in,out]	store	Member store
[in]	it	Iterator callback
[in,out]	cls	Closure

Returns

Amount of members iterated through

Definition at line 257 of file gnunet-service-messenger_member_store.c.

{
  GNUNET_assert ((store) && (store->members) && (it));
 
  struct GNUNET_MESSENGER_ClosureIterateMembers iterate;
 
  iterate.it = it;
  iterate.cls = cls;
 
  return GNUNET_CONTAINER_multishortmap_iterate(store->members, iterate_store_members_it, &iterate);
}

References GNUNET_MESSENGER_ClosureIterateMembers::cls, GNUNET_assert, GNUNET_CONTAINER_multishortmap_iterate(), GNUNET_MESSENGER_ClosureIterateMembers::it, iterate_store_members_it(), GNUNET_MESSENGER_MemberStore::members, and GNUNET_MESSENGER_Member::store.

Referenced by callback_room_handle_message(), join_room_locally(), and recv_message_info().

Here is the call graph for this function:

Here is the caller graph for this function: