GNUnet MESSENGER service. More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_identity_service.h"
#include "gnunet_time_lib.h"
#include "gnunet-service-messenger_member.h"
#include "messenger_api_contact.h"

Include dependency graph for gnunet-service-messenger_member_session.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	GNUNET_MESSENGER_MemberSession

Functions
struct GNUNET_MESSENGER_MemberSession *	create_member_session (struct GNUNET_MESSENGER_Member member, const struct GNUNET_IDENTITY_PublicKey pubkey)
	Creates and allocates a new member session of a member with a given public key. More...

struct GNUNET_MESSENGER_MemberSession *	switch_member_session (struct GNUNET_MESSENGER_MemberSession session, const struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode *hash)
	Creates and allocates a new member session closing and replacing a given other session of the same member. More...

void	destroy_member_session (struct GNUNET_MESSENGER_MemberSession *session)
	Destroys a member session and frees its memory fully. More...

int	reset_member_session (struct GNUNET_MESSENGER_MemberSession session, const struct GNUNET_HashCode hash)
	Resets a given member session which re-opens a member session for new usage. More...

void	close_member_session (struct GNUNET_MESSENGER_MemberSession *session)
	Closes a given member session which opens the request for completion of the given member session. More...

int	is_member_session_closed (const struct GNUNET_MESSENGER_MemberSession *session)
	Returns if the given member session has been closed. More...

int	is_member_session_completed (const struct GNUNET_MESSENGER_MemberSession *session)
	Returns if the given member session has been completed. More...

struct GNUNET_TIME_Absolute	get_member_session_start (const struct GNUNET_MESSENGER_MemberSession *session)
	Returns the timestamp of the member session's start. More...

const struct GNUNET_HashCode *	get_member_session_key (const struct GNUNET_MESSENGER_MemberSession *session)
	Returns the key of the room a given member session belongs to. More...

const struct GNUNET_ShortHashCode *	get_member_session_id (const struct GNUNET_MESSENGER_MemberSession *session)
	Returns the member id of a given member session. More...

const struct GNUNET_IDENTITY_PublicKey *	get_member_session_public_key (const struct GNUNET_MESSENGER_MemberSession *session)
	Returns the public key from an EGO of a given member session. More...

const struct GNUNET_HashCode *	get_member_session_context (const struct GNUNET_MESSENGER_MemberSession *session)
	Returns the member context of a given member session. More...

struct GNUNET_MESSENGER_Contact *	get_member_session_contact (struct GNUNET_MESSENGER_MemberSession *session)
	Returns the contact which is connected to a given member session. More...

int	verify_member_session_as_sender (const struct GNUNET_MESSENGER_MemberSession session, const struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode *hash)
	Verifies a given member session as sender of a selected message and its hash. More...

int	check_member_session_history (const struct GNUNET_MESSENGER_MemberSession session, const struct GNUNET_HashCode hash, int ownership)
	Checks the history of a session for a specific message which is identified by its hash and if the ownership flag is set, if the message is owned by the sessions contact. More...

void	update_member_session_history (struct GNUNET_MESSENGER_MemberSession session, const struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode *hash)
	Adds a given message to the history of a session using the messages hash. More...

void	clear_member_session_history (struct GNUNET_MESSENGER_MemberSession session, const struct GNUNET_HashCode hash)
	Removes a message from the history of a session using the messages hash. More...

void	load_member_session (struct GNUNET_MESSENGER_Member member, const char directory)
	Loads data from a directory into a new allocated and created member session of a member if the required information can be read from the content of the given directory. More...

void	load_member_session_next (struct GNUNET_MESSENGER_MemberSession session, const char directory)
	Loads the connection from one session to another through the next attribute. More...

void	save_member_session (struct GNUNET_MESSENGER_MemberSession session, const char directory)
	Saves data from a member session into a directory which can be load to restore the member session completely. More...

Detailed Description

GNUnet MESSENGER service.

Author: Tobias Frisch

Definition in file gnunet-service-messenger_member_session.h.

Function Documentation

◆ create_member_session()

struct GNUNET_MESSENGER_MemberSession* create_member_session	(	struct GNUNET_MESSENGER_Member *	member,
		const struct GNUNET_IDENTITY_PublicKey *	pubkey
	)

Creates and allocates a new member session of a member with a given public key.

If the creation fails, NULL gets returned.

Parameters

[in,out]	member	Member
[in]	pubkey	Public key of EGO

Returns: New member session

Definition at line 35 of file gnunet-service-messenger_member_session.c.

 {
   if ((!member) || (!pubkey) || (!(member->store)))
     return NULL;
  
   struct GNUNET_MESSENGER_MemberSession *session = GNUNET_new(struct GNUNET_MESSENGER_MemberSession);
   session->member = member;
  
   GNUNET_memcpy(&(session->public_key), pubkey, sizeof(session->public_key));
  
   get_context_from_member (
       get_member_session_key (session),
       get_member_session_id (session),
       &(session->context)
   );
  
   struct GNUNET_MESSENGER_ContactStore *store = get_member_contact_store(session->member->store);
  
   session->contact = get_store_contact(
       store,
       get_member_session_context (session),
       get_member_session_public_key (session)
   );
  
   if (!(session->contact))
   {
     GNUNET_free(session);
     return NULL;
   }
  
   increase_contact_rc (session->contact);
  
   session->history = GNUNET_CONTAINER_multihashmap_create(8, GNUNET_NO);
  
   init_list_messages(&(session->messages));
  
   session->prev = NULL;
   session->next = NULL;
  
   session->start = GNUNET_TIME_absolute_get();
  
   session->closed = GNUNET_NO;
   session->completed = GNUNET_NO;
  
   return session;
 }

Referenced by load_member_session(), and try_member_session().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ switch_member_session()

struct GNUNET_MESSENGER_MemberSession* switch_member_session	(	struct GNUNET_MESSENGER_MemberSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Creates and allocates a new member session closing and replacing a given other session of the same member.

The new session could have significant changes to the members public key or its member id depending on the used message to switch session. The new session will be linked to the old one.

Parameters

[in,out]	session	Old member session
[in]	message	Message
[in]	hash	Hash of message

Returns: New member session

Definition at line 181 of file gnunet-service-messenger_member_session.c.

 {
   if ((!session) || (!message) || (!hash))
     return NULL;
  
   GNUNET_assert((GNUNET_MESSENGER_KIND_ID == message->header.kind) ||
                 (GNUNET_MESSENGER_KIND_KEY == message->header.kind));
  
   struct GNUNET_MESSENGER_MemberSession *next = GNUNET_new(struct GNUNET_MESSENGER_MemberSession);
  
   if (GNUNET_MESSENGER_KIND_ID == message->header.kind)
     next->member = add_store_member(session->member->store, &(message->body.id.id));
   else
     next->member = session->member;
  
   if (GNUNET_MESSENGER_KIND_KEY == message->header.kind)
     GNUNET_memcpy(&(next->public_key), &(message->body.key.key), sizeof(next->public_key));
   else
     GNUNET_memcpy(&(next->public_key), get_member_session_public_key(session), sizeof(next->public_key));
  
   get_context_from_member (
       get_member_session_key (next),
       get_member_session_id (next),
       &(next->context)
   );
  
   update_store_contact(
       get_member_contact_store(next->member->store),
       get_member_session_contact(session),
       get_member_session_context(session),
       get_member_session_context(next),
       get_member_session_public_key(next)
   );
  
   next->contact = get_member_session_contact(session);
  
   if (!(next->contact))
   {
     GNUNET_free(next);
     return NULL;
   }
  
   increase_contact_rc (next->contact);
  
   next->history = GNUNET_CONTAINER_multihashmap_create(
       GNUNET_CONTAINER_multihashmap_size(session->history), GNUNET_NO
   );
  
   GNUNET_CONTAINER_multihashmap_iterate(session->history, iterate_copy_history, next);
  
   init_list_messages(&(next->messages));
   copy_list_messages(&(next->messages), &(session->messages));
  
   session->next = next;
   next->prev = session;
   next->next = NULL;
  
   next->start = GNUNET_TIME_absolute_get();
  
   session->closed = GNUNET_YES;
   next->closed = GNUNET_NO;
   next->completed = GNUNET_NO;
  
   check_member_session_completion (session);
  
   return next;
 }

Referenced by handle_session_switch().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ destroy_member_session()

void destroy_member_session ( struct GNUNET_MESSENGER_MemberSession * session )

Destroys a member session and frees its memory fully.

Parameters

[in,out] session Member session

Definition at line 252 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert (session);
  
   GNUNET_CONTAINER_multihashmap_destroy (session->history);
  
   clear_list_messages (&(session->messages));
  
   struct GNUNET_MESSENGER_Contact *contact = get_member_session_contact (session);
  
   if ((contact) && (GNUNET_YES == decrease_contact_rc (contact)))
     remove_store_contact (
         get_member_contact_store(session->member->store),
         contact,
         get_member_session_context(session)
     );
  
   GNUNET_free(session);
 }

References clear_list_messages(), decrease_contact_rc(), get_member_contact_store(), get_member_session_contact(), get_member_session_context(), GNUNET_assert, GNUNET_CONTAINER_multihashmap_destroy(), GNUNET_free, GNUNET_YES, GNUNET_MESSENGER_MemberSession::history, GNUNET_MESSENGER_MemberSession::member, GNUNET_MESSENGER_MemberSession::messages, remove_store_contact(), and GNUNET_MESSENGER_Member::store.

Referenced by iterate_destroy_session(), and remove_room_member_session().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ reset_member_session()

int reset_member_session	(	struct GNUNET_MESSENGER_MemberSession *	session,
		const struct GNUNET_HashCode *	hash
	)

Resets a given member session which re-opens a member session for new usage.

Every connection to other sessions will be be dropped. The member sessions messages will be cleared but old history from uncompleted sessions however can be reused!

Parameters

[in,out]	session	Member session
[in]	hash	Hash of initial message (JOIN message!)

Returns: GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 273 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert ((session) && (hash));
  
   struct GNUNET_MESSENGER_ContactStore *store = get_member_contact_store(session->member->store);
   struct GNUNET_MESSENGER_Contact *contact = get_store_contact(
       store,
       get_member_session_context (session),
       get_member_session_public_key (session)
   );
  
   if (!contact)
     return GNUNET_SYSERR;
  
   if (contact == session->contact)
     goto clear_messages;
  
   session->contact = contact;
   increase_contact_rc (session->contact);
  
 clear_messages:
   clear_list_messages(&(session->messages));
   add_to_list_messages(&(session->messages), hash);
  
   session->next = NULL;
   session->closed = GNUNET_NO;
   session->completed = GNUNET_NO;
  
   return GNUNET_OK;
 }

References add_to_list_messages(), clear_list_messages(), GNUNET_MESSENGER_MemberSession::closed, GNUNET_MESSENGER_MemberSession::completed, GNUNET_MESSENGER_MemberSession::contact, get_member_contact_store(), get_member_session_context(), get_member_session_public_key(), get_store_contact(), GNUNET_assert, GNUNET_NO, GNUNET_OK, GNUNET_SYSERR, increase_contact_rc(), GNUNET_MESSENGER_MemberSession::member, GNUNET_MESSENGER_MemberSession::messages, GNUNET_MESSENGER_MemberSession::next, and GNUNET_MESSENGER_Member::store.

Referenced by handle_message_join().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ close_member_session()

void close_member_session ( struct GNUNET_MESSENGER_MemberSession * session )

Closes a given member session which opens the request for completion of the given member session.

Closing a session may complete a session and can't be used without a reset! (

See also: reset_member_session() )

Parameters

[in,out] session Member session

Definition at line 306 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert (session);
  
   session->closed = GNUNET_YES;
   check_member_session_completion (session);
 }

References check_member_session_completion(), GNUNET_MESSENGER_MemberSession::closed, GNUNET_assert, and GNUNET_YES.

Referenced by handle_message_leave().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_member_session_closed()

int is_member_session_closed ( const struct GNUNET_MESSENGER_MemberSession * session )

Returns if the given member session has been closed.

Parameters

[in] session Member session

Returns: GNUNET_YES or GNUNET_NO

Definition at line 315 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert(session);
  
   return session->closed;
 }

References GNUNET_MESSENGER_MemberSession::closed, and GNUNET_assert.

Referenced by check_srv_room_peer_status().

Here is the caller graph for this function:

◆ is_member_session_completed()

int is_member_session_completed ( const struct GNUNET_MESSENGER_MemberSession * session )

Returns if the given member session has been completed.

A completed member session can't verify any message as its own and it won't add any message to its history.

Parameters

[in] session Member session

Returns: GNUNET_YES or GNUNET_NO

Definition at line 323 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert(session);
  
   return session->completed;
 }

Referenced by check_member_session_completion(), iterate_forward_members(), iterate_notify_about_members(), iterate_update_member_sessions(), update_member_session_history(), and verify_member_session_as_sender().

Here is the caller graph for this function:

◆ get_member_session_start()

struct GNUNET_TIME_Absolute get_member_session_start ( const struct GNUNET_MESSENGER_MemberSession * session )

Returns the timestamp of the member session's start.

Parameters

[in] session Member session

Returns: Absolute timestamp

Definition at line 323 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert(session);
  
   if (session->prev)
     return get_member_session_start(session->prev);
  
   return session->start;
 }

References GNUNET_MESSENGER_MemberSession::completed, and GNUNET_assert.

Referenced by solve_srv_room_member_collisions().

Here is the caller graph for this function:

◆ get_member_session_key()

const struct GNUNET_HashCode* get_member_session_key ( const struct GNUNET_MESSENGER_MemberSession * session )

Returns the key of the room a given member session belongs to.

Parameters

[in] session Member session

Returns: Key of room

Definition at line 342 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert((session) && (session->member));
  
   return get_member_store_key(session->member->store);
 }

References get_member_store_key(), GNUNET_assert, GNUNET_MESSENGER_MemberSession::member, and GNUNET_MESSENGER_Member::store.

Referenced by create_member_session(), and switch_member_session().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_member_session_id()

const struct GNUNET_ShortHashCode* get_member_session_id ( const struct GNUNET_MESSENGER_MemberSession * session )

Returns the member id of a given member session.

Parameters

[in] session Member session

Returns: Member id

Definition at line 350 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert(session);
  
   return get_member_id(session->member);
 }

References get_member_id(), GNUNET_assert, and GNUNET_MESSENGER_MemberSession::member.

Referenced by check_member_session_completion(), create_member_session(), delete_srv_room_message(), remove_room_member_session(), switch_member_session(), update_member_session_history(), and verify_member_session_as_sender().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_member_session_public_key()

const struct GNUNET_IDENTITY_PublicKey* get_member_session_public_key ( const struct GNUNET_MESSENGER_MemberSession * session )

Returns the public key from an EGO of a given member session.

Parameters

[in] session Member session

Returns: Public key of EGO

Definition at line 358 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert(session);
  
   return &(session->public_key);
 }

References GNUNET_assert, and GNUNET_MESSENGER_MemberSession::public_key.

Referenced by add_member_session(), create_member_session(), handle_message_id(), iterate_member_sessions_it(), remove_member_session(), remove_room_member_session(), reset_member_session(), switch_member_session(), and verify_member_session_as_sender().

Here is the caller graph for this function:

◆ get_member_session_context()

const struct GNUNET_HashCode* get_member_session_context ( const struct GNUNET_MESSENGER_MemberSession * session )

Returns the member context of a given member session.

Parameters

[in] session Member session

Returns: Member context as hash

Definition at line 366 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert(session);
  
   return &(session->context);
 }

References GNUNET_MESSENGER_MemberSession::context, and GNUNET_assert.

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

Here is the caller graph for this function:

◆ get_member_session_contact()

struct GNUNET_MESSENGER_Contact* get_member_session_contact ( struct GNUNET_MESSENGER_MemberSession * session )

Returns the contact which is connected to a given member session.

Parameters

[in] session Member session

Returns: Contact

Definition at line 374 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert (session);
  
   return session->contact;
 }

References GNUNET_MESSENGER_MemberSession::contact, and GNUNET_assert.

Referenced by destroy_member_session(), handle_message_name(), and switch_member_session().

Here is the caller graph for this function:

◆ verify_member_session_as_sender()

int verify_member_session_as_sender	(	const struct GNUNET_MESSENGER_MemberSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Verifies a given member session as sender of a selected message and its hash.

The function returns GNUNET_OK if the message session is verified as sender, otherwise GNUNET_SYSERR.

See also: is_member_session_completed() for verification.

Parameters

[in]	session	Member session
[in]	message	Message
[in]	hash	Hash of message

Returns: GNUNET_OK on success, otherwise GNUNET_SYSERR

Definition at line 381 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert((session) && (message) && (hash));
  
   if (GNUNET_YES == is_member_session_completed(session))
     return GNUNET_SYSERR;
  
   if (0 != GNUNET_memcmp(get_member_session_id(session), &(message->header.sender_id)))
     return GNUNET_SYSERR;
  
   return verify_message(message, hash, get_member_session_public_key(session));
 }

References get_member_session_id(), get_member_session_public_key(), GNUNET_assert, GNUNET_memcmp, GNUNET_SYSERR, GNUNET_YES, GNUNET_MESSENGER_Message::header, is_member_session_completed(), GNUNET_MESSENGER_MessageHeader::sender_id, and verify_message().

Referenced by iterate_search_session(), and update_member_session_history().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ check_member_session_history()

int check_member_session_history	(	const struct GNUNET_MESSENGER_MemberSession *	session,
		const struct GNUNET_HashCode *	hash,
		int	ownership
	)

Checks the history of a session for a specific message which is identified by its hash and if the ownership flag is set, if the message is owned by the sessions contact.

Parameters

[in]	session	Member session
[in]	hash	Hash of message
[in]	ownership	Ownership flag

Returns: GNUNET_YES if found, otherwise GNUNET_NO

Definition at line 397 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert((session) && (hash));
  
   if (GNUNET_YES == ownership)
     return (NULL != GNUNET_CONTAINER_multihashmap_get(session->history, hash)? GNUNET_YES : GNUNET_NO);
   else
     return GNUNET_CONTAINER_multihashmap_contains(session->history, hash);
 }

References GNUNET_assert, GNUNET_CONTAINER_multihashmap_contains(), GNUNET_CONTAINER_multihashmap_get(), GNUNET_NO, GNUNET_YES, and GNUNET_MESSENGER_MemberSession::history.

Referenced by check_member_session_completion(), delete_srv_room_message(), notify_about_members(), recv_message_request(), and request_room_message_step().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ update_member_session_history()

void update_member_session_history	(	struct GNUNET_MESSENGER_MemberSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Adds a given message to the history of a session using the messages hash.

The ownership will be set automatically.

See also: is_member_session_completed() for updating a history.

Parameters

[in,out]	session	Member session
[in]	message	Message
[in]	hash	Hash of message

Definition at line 420 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert((session) && (message) && (hash));
  
   if (GNUNET_YES == is_member_session_completed(session))
     return;
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Updating sessions history (%s) += (%s)\n",
              GNUNET_sh2s(get_member_session_id(session)), GNUNET_h2s(hash));
  
   if (GNUNET_OK == verify_member_session_as_sender (session, message, hash))
   {
     if (GNUNET_YES == is_message_session_bound (message))
       add_to_list_messages(&(session->messages), hash);
  
     update_member_chain_history (session, hash, GNUNET_YES);
   }
   else
     update_member_chain_history (session, hash, GNUNET_NO);
  
   if (GNUNET_YES == session->closed)
     check_member_session_completion(session);
 }

References add_to_list_messages(), check_member_session_completion(), GNUNET_MESSENGER_MemberSession::closed, get_member_session_id(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_sh2s(), GNUNET_YES, is_member_session_completed(), is_message_session_bound(), GNUNET_MESSENGER_MemberSession::messages, update_member_chain_history(), and verify_member_session_as_sender().

Referenced by iterate_update_member_sessions().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ clear_member_session_history()

void clear_member_session_history	(	struct GNUNET_MESSENGER_MemberSession *	session,
		const struct GNUNET_HashCode *	hash
	)

Removes a message from the history of a session using the messages hash.

Parameters

[in,out]	session	Member session
[in]	hash	Hash of message

Definition at line 457 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert((session) && (hash));
  
   clear_member_chain_history (session, hash);
 }

References clear_member_chain_history(), and GNUNET_assert.

Referenced by clear_member_chain_history().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ load_member_session()

void load_member_session	(	struct GNUNET_MESSENGER_Member *	member,
		const char *	directory
	)

Loads data from a directory into a new allocated and created member session of a member if the required information can be read from the content of the given directory.

Parameters

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

Definition at line 515 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert ((member) && (directory));
  
   char *config_file;
   GNUNET_asprintf (&config_file, "%s%s", directory, "session.cfg");
  
   struct GNUNET_MESSENGER_MemberSession *session = NULL;
  
   if (GNUNET_YES != GNUNET_DISK_file_test (config_file))
     goto free_config;
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Load session configuration of member: %s\n", config_file);
  
   struct GNUNET_CONFIGURATION_Handle *cfg = GNUNET_CONFIGURATION_create ();
  
   if (GNUNET_OK == GNUNET_CONFIGURATION_parse (cfg, config_file))
   {
     char *key_data;
  
     if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_string(cfg, "session", "key", &key_data))
       goto destroy_config;
  
     struct GNUNET_IDENTITY_PublicKey key;
  
     enum GNUNET_GenericReturnValue key_return = GNUNET_IDENTITY_public_key_from_string(key_data, &key);
  
     GNUNET_free(key_data);
  
     if (GNUNET_OK != key_return)
       goto destroy_config;
  
     session = create_member_session(member, &key);
  
     unsigned long long numeric_value;
  
     if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number(cfg, "session", "start", &numeric_value))
       session->start.abs_value_us = numeric_value;
  
     if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number(cfg, "session", "closed", &numeric_value))
       session->closed = (GNUNET_YES == numeric_value? GNUNET_YES : GNUNET_NO);
  
     if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number(cfg, "session", "completed", &numeric_value))
       session->completed = (GNUNET_YES == numeric_value? GNUNET_YES : GNUNET_NO);
   }
  
 destroy_config:
   GNUNET_CONFIGURATION_destroy (cfg);
  
 free_config:
   GNUNET_free(config_file);
  
   if (!session)
     return;
  
   char *history_file;
   GNUNET_asprintf (&history_file, "%s%s", directory, "history.map");
  
   load_member_session_history (session, history_file);
   GNUNET_free(history_file);
  
   char *messages_file;
   GNUNET_asprintf (&messages_file, "%s%s", directory, "messages.list");
  
   load_list_messages(&(session->messages), messages_file);
   GNUNET_free(messages_file);
  
   add_member_session(member, session);
 }

References GNUNET_TIME_Absolute::abs_value_us, add_member_session(), cfg, GNUNET_MESSENGER_MemberSession::closed, GNUNET_MESSENGER_MemberSession::completed, config_file, create_member_session(), GNUNET_asprintf(), GNUNET_assert, GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_destroy(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_parse(), GNUNET_DISK_file_test(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_IDENTITY_public_key_from_string(), GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_YES, key, load_list_messages(), load_member_session_history(), GNUNET_MESSENGER_MemberSession::messages, and GNUNET_MESSENGER_MemberSession::start.

Referenced by callback_scan_for_sessions().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ load_member_session_next()

void load_member_session_next	(	struct GNUNET_MESSENGER_MemberSession *	session,
		const char *	directory
	)

Loads the connection from one session to another through the next attribute.

Necessary information will be loaded from a configuration file inside of a given directory.

Parameters

[in,out]	session	Member session
[in]	directory	Path to a directory

Definition at line 606 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert ((session) && (directory));
  
   char *config_file;
   GNUNET_asprintf (&config_file, "%s%s", directory, "session.cfg");
  
   if (GNUNET_YES != GNUNET_DISK_file_test (config_file))
     goto free_config;
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Load next session configuration of member: %s\n", config_file);
  
   struct GNUNET_CONFIGURATION_Handle *cfg = GNUNET_CONFIGURATION_create ();
  
   if (GNUNET_OK == GNUNET_CONFIGURATION_parse (cfg, config_file))
   {
     char *key_data;
  
     if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_string(cfg, "session", "next_key", &key_data))
       goto destroy_config;
  
     struct GNUNET_IDENTITY_PublicKey next_key;
  
     enum GNUNET_GenericReturnValue key_return = GNUNET_IDENTITY_public_key_from_string(key_data, &next_key);
  
     GNUNET_free(key_data);
  
     if (GNUNET_OK != key_return)
       goto destroy_config;
  
     struct GNUNET_ShortHashCode next_id;
  
     if (GNUNET_OK != GNUNET_CONFIGURATION_get_data (cfg, "session", "next_id", &next_id, sizeof(next_id)))
       goto destroy_config;
  
     struct GNUNET_MESSENGER_Member *member = get_store_member(session->member->store, &next_id);
  
     session->next = get_cycle_safe_next_session(
         session, member? get_member_session (member, &next_key) : NULL
     );
  
     if (session->next)
       session->next->prev = session;
   }
  
 destroy_config:
   GNUNET_CONFIGURATION_destroy (cfg);
  
 free_config:
   GNUNET_free(config_file);
 }

References cfg, config_file, get_cycle_safe_next_session(), get_member_session(), get_store_member(), GNUNET_asprintf(), GNUNET_assert, GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_destroy(), GNUNET_CONFIGURATION_get_data(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_parse(), GNUNET_DISK_file_test(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_IDENTITY_public_key_from_string(), GNUNET_log, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_MemberSession::member, GNUNET_MESSENGER_MemberSession::next, next_id, GNUNET_MESSENGER_MemberSession::prev, and GNUNET_MESSENGER_Member::store.

Referenced by iterate_load_next_session().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ save_member_session()

void save_member_session	(	struct GNUNET_MESSENGER_MemberSession *	session,
		const char *	directory
	)

Saves data from a member session into a directory which can be load to restore the member session completely.

Parameters

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

Definition at line 701 of file gnunet-service-messenger_member_session.c.

 {
   GNUNET_assert ((session) && (directory));
  
   char *config_file;
   GNUNET_asprintf (&config_file, "%s%s", directory, "session.cfg");
  
   GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Save session configuration of member: %s\n", config_file);
  
   struct GNUNET_CONFIGURATION_Handle *cfg = GNUNET_CONFIGURATION_create ();
  
   char *key_data = GNUNET_IDENTITY_public_key_to_string(get_member_session_public_key(session));
  
   if (key_data)
   {
     GNUNET_CONFIGURATION_set_value_string (cfg, "session", "key", key_data);
  
     GNUNET_free(key_data);
   }
  
   if (session->next)
   {
     const struct GNUNET_ShortHashCode *next_id = get_member_session_id(session->next);
  
     char *next_id_data = GNUNET_STRINGS_data_to_string_alloc (next_id, sizeof(*next_id));
  
     if (next_id_data)
     {
       GNUNET_CONFIGURATION_set_value_string (cfg, "session", "next_id", next_id_data);
  
       GNUNET_free(next_id_data);
     }
  
     key_data = GNUNET_IDENTITY_public_key_to_string(get_member_session_public_key(session->next));
  
     if (key_data)
     {
       GNUNET_CONFIGURATION_set_value_string (cfg, "session", "next_key", key_data);
  
       GNUNET_free(key_data);
     }
   }
  
   GNUNET_CONFIGURATION_set_value_number(cfg, "session", "start", session->start.abs_value_us);
  
   GNUNET_CONFIGURATION_set_value_number (cfg, "session", "closed", session->closed);
   GNUNET_CONFIGURATION_set_value_number (cfg, "session", "completed", session->completed);
  
   GNUNET_CONFIGURATION_write (cfg, config_file);
   GNUNET_CONFIGURATION_destroy (cfg);
  
   GNUNET_free(config_file);
  
   char *history_file;
   GNUNET_asprintf (&history_file, "%s%s", directory, "history.map");
  
   save_member_session_history (session, history_file);
   GNUNET_free(history_file);
  
   char *messages_file;
   GNUNET_asprintf (&messages_file, "%s%s", directory, "messages.list");
  
   save_list_messages(&(session->messages), messages_file);
   GNUNET_free(messages_file);
 }

Referenced by iterate_save_session().

Here is the caller graph for this function:

Data Structures

Functions

Detailed Description

Function Documentation

◆ create_member_session()

◆ switch_member_session()

◆ destroy_member_session()

◆ reset_member_session()

◆ close_member_session()

◆ is_member_session_closed()

◆ is_member_session_completed()

◆ get_member_session_start()

◆ get_member_session_key()

◆ get_member_session_id()

◆ get_member_session_public_key()

◆ get_member_session_context()

◆ get_member_session_contact()

◆ verify_member_session_as_sender()

◆ check_member_session_history()

◆ update_member_session_history()

◆ clear_member_session_history()

◆ load_member_session()

◆ load_member_session_next()

◆ save_member_session()