gnunet-service-messenger_service.h File Reference

GNUnet MESSENGER service. More...

#include "platform.h"
#include "gnunet_configuration_lib.h"
#include "gnunet_crypto_lib.h"
#include "gnunet_container_lib.h"
#include "gnunet_disk_lib.h"
#include "gnunet_identity_service.h"
#include "messenger_api_ego.h"
#include "gnunet-service-messenger_list_handles.h"
#include "gnunet-service-messenger_contact.h"
#include "gnunet-service-messenger_room.h"

Include dependency graph for gnunet-service-messenger_service.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_Service

Functions
struct GNUNET_MESSENGER_Service *	create_service (const struct GNUNET_CONFIGURATION_Handle *config, struct GNUNET_SERVICE_Handle *service_handle)
	Creates and allocates a new service using a given config and a GNUnet service handle. More...
void	destroy_service (struct GNUNET_MESSENGER_Service *service)
	Destroys a service and frees its memory fully. More...
struct GNUNET_MESSENGER_Ego *	lookup_service_ego (struct GNUNET_MESSENGER_Service *service, const char *identifier)
	Lookups an EGO which was registered to a service under a specific identifier. More...
void	update_service_ego (struct GNUNET_MESSENGER_Service *service, const char *identifier, const struct GNUNET_IDENTITY_PrivateKey *key)
	Updates the registration of an EGO to a service under a specific identifier with a new key. More...
struct GNUNET_MESSENGER_SrvHandle *	add_service_handle (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MQ_Handle *mq)
	Creates and adds a new handle to a service using a given message queue. More...
void	remove_service_handle (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MESSENGER_SrvHandle *handle)
	Removes a handle from a service and destroys it. More...
int	get_service_peer_identity (const struct GNUNET_MESSENGER_Service *service, struct GNUNET_PeerIdentity *peer)
	Tries to write the peer identity of the peer running a service on to the peer parameter. More...
struct GNUNET_MESSENGER_SrvContact *	get_service_contact_by_pubkey (struct GNUNET_MESSENGER_Service *service, const struct GNUNET_IDENTITY_PublicKey *pubkey)
	Returns a contact of a service identified by a given public key. More...
void	swap_service_contact_by_pubkey (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MESSENGER_SrvContact *contact, const struct GNUNET_IDENTITY_PublicKey *pubkey)
	Changes the public key for a contact known to a service to a specific public key and updates local map entries to access the contact by its updated key. More...
struct GNUNET_ShortHashCode *	generate_service_new_member_id (struct GNUNET_MESSENGER_Service *service, const struct GNUNET_HashCode *key)
	Tries to generate and allocate a new unique member id for a given room of a service identified by its key. More...
struct GNUNET_MESSENGER_SrvRoom *	get_service_room (struct GNUNET_MESSENGER_Service *service, const struct GNUNET_HashCode *key)
	Returns the room identified by a given key for a service. More...
int	open_service_room (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MESSENGER_SrvHandle *handle, const struct GNUNET_HashCode *key)
	Tries to open a room using a given key for a service by a specific handle. More...
int	entry_service_room (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MESSENGER_SrvHandle *handle, const struct GNUNET_PeerIdentity *door, const struct GNUNET_HashCode *key)
	Tries to enter a room using a given key for a service by a specific handle. More...
int	close_service_room (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MESSENGER_SrvHandle *handle, const struct GNUNET_HashCode *key)
	Tries to close a room using a given key for a service by a specific handle. More...
void	load_service_room_and_messages (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MESSENGER_SrvRoom *room)
	Loads the local configuration for a given room of a service which contains the last messages hash and the ruleset for general access of new members. More...
void	save_service_room_and_messages (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MESSENGER_SrvRoom *room)
	Saves the configuration for a given room of a service which contains the last messages hash and the ruleset for general access of new members locally. More...
void	handle_service_message (struct GNUNET_MESSENGER_Service *service, struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Sends a received or sent message with a given hash to each handle of a service which is currently member of a specific room for handling it in the client API. More...

Detailed Description

GNUnet MESSENGER service.

Author

Tobias Frisch

Definition in file gnunet-service-messenger_service.h.

Function Documentation

create_service()

struct GNUNET_MESSENGER_Service* create_service	(	const struct GNUNET_CONFIGURATION_Handle *	config,
		struct GNUNET_SERVICE_Handle *	service_handle
	)

Creates and allocates a new service using a given config and a GNUnet service handle.

Parameters

config	Configuration
service_handle	GNUnet service handle

Returns

New service

Definition at line 61 of file gnunet-service-messenger_service.c.

References GNUNET_MESSENGER_Service::cadet, callback_shutdown_service(), callback_update_ego(), config, GNUNET_MESSENGER_Service::config, GNUNET_MESSENGER_Service::contacts, GNUNET_MESSENGER_Service::dir, GNUNET_MESSENGER_Service::egos, GNUNET_CADET_connect(), GNUNET_CONFIGURATION_get_value_filename(), GNUNET_CONTAINER_multihashmap_create(), GNUNET_DISK_directory_create(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_IDENTITY_connect(), GNUNET_MESSENGER_SERVICE_NAME, GNUNET_new, GNUNET_NO, GNUNET_OK, GNUNET_SCHEDULER_add_shutdown(), GNUNET_YES, GNUNET_MESSENGER_Service::handles, GNUNET_MESSENGER_Service::identity, init_list_handles(), GNUNET_MESSENGER_Service::rooms, GNUNET_MESSENGER_Service::service, service, and GNUNET_MESSENGER_Service::shutdown.

Referenced by run().

{
  struct GNUNET_MESSENGER_Service *service = GNUNET_new(struct GNUNET_MESSENGER_Service);

  service->config = config;
  service->service = service_handle;

  service->shutdown = GNUNET_SCHEDULER_add_shutdown (&callback_shutdown_service, service);

  service->dir = NULL;

  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_filename (service->config,
  GNUNET_MESSENGER_SERVICE_NAME,
                                                            "MESSENGER_DIR", &(service->dir)))
  {
    if (service->dir)
      GNUNET_free(service->dir);

    service->dir = NULL;
  }
  else
  {
    if ((GNUNET_YES != GNUNET_DISK_directory_test (service->dir, GNUNET_YES)) && (GNUNET_OK
        != GNUNET_DISK_directory_create (service->dir)))
    {
      GNUNET_free(service->dir);

      service->dir = NULL;
    }
  }

  service->cadet = GNUNET_CADET_connect (service->config);
  service->identity = GNUNET_IDENTITY_connect (service->config, &callback_update_ego, service);

  service->egos = GNUNET_CONTAINER_multihashmap_create (8, GNUNET_NO);

  init_list_handles (&(service->handles));

  service->contacts = GNUNET_CONTAINER_multihashmap_create (8, GNUNET_NO);
  service->rooms = GNUNET_CONTAINER_multihashmap_create (8, GNUNET_NO);

  return service;
}

Here is the call graph for this function:

Here is the caller graph for this function:

destroy_service()

void destroy_service

(

struct GNUNET_MESSENGER_Service *

service

)

Destroys a service and frees its memory fully.

Parameters

service

Service

Definition at line 130 of file gnunet-service-messenger_service.c.

References GNUNET_MESSENGER_Service::cadet, clear_list_handles(), GNUNET_MESSENGER_Service::contacts, GNUNET_MESSENGER_Service::dir, GNUNET_MESSENGER_Service::egos, GNUNET_CADET_disconnect(), GNUNET_CONTAINER_multihashmap_destroy(), GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_free, GNUNET_IDENTITY_disconnect(), GNUNET_SCHEDULER_cancel(), GNUNET_SERVICE_shutdown(), GNUNET_MESSENGER_Service::handles, GNUNET_MESSENGER_Service::identity, iterate_destroy_contacts(), iterate_destroy_egos(), iterate_destroy_rooms(), GNUNET_MESSENGER_Service::rooms, GNUNET_MESSENGER_Service::service, and GNUNET_MESSENGER_Service::shutdown.

Referenced by callback_shutdown_service().

{
  if (service->shutdown)
  {
    GNUNET_SCHEDULER_cancel (service->shutdown);

    service->shutdown = NULL;
  }

  GNUNET_CONTAINER_multihashmap_iterate (service->egos, iterate_destroy_egos, NULL);

  clear_list_handles (&(service->handles));

  GNUNET_CONTAINER_multihashmap_iterate (service->rooms, iterate_destroy_rooms, NULL);
  GNUNET_CONTAINER_multihashmap_iterate (service->contacts, iterate_destroy_contacts, NULL);

  GNUNET_CONTAINER_multihashmap_destroy (service->egos);
  GNUNET_CONTAINER_multihashmap_destroy (service->rooms);
  GNUNET_CONTAINER_multihashmap_destroy (service->contacts);

  if (service->cadet)
  {
    GNUNET_CADET_disconnect (service->cadet);

    service->cadet = NULL;
  }

  if (service->identity)
  {
    GNUNET_IDENTITY_disconnect (service->identity);

    service->identity = NULL;
  }

  if (service->dir)
  {
    GNUNET_free(service->dir);

    service->dir = NULL;
  }

  GNUNET_SERVICE_shutdown (service->service);

  GNUNET_free(service);
}

Here is the call graph for this function:

Here is the caller graph for this function:

lookup_service_ego()

struct GNUNET_MESSENGER_Ego* lookup_service_ego	(	struct GNUNET_MESSENGER_Service *	service,
		const char *	identifier
	)

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

Parameters

service	Service
identifier	Identifier string

Returns

EGO or NULL

Definition at line 177 of file gnunet-service-messenger_service.c.

References GNUNET_MESSENGER_Service::egos, GNUNET_assert, GNUNET_CONTAINER_multihashmap_get(), and GNUNET_CRYPTO_hash().

Referenced by callback_ego_create(), set_handle_name(), setup_handle_name(), and update_handle().

{
  GNUNET_assert(identifier);

  struct GNUNET_HashCode hash;

  GNUNET_CRYPTO_hash(identifier, strlen(identifier), &hash);
  return GNUNET_CONTAINER_multihashmap_get(service->egos, &hash);
}

Here is the call graph for this function:

Here is the caller graph for this function:

update_service_ego()

void update_service_ego	(	struct GNUNET_MESSENGER_Service *	service,
		const char *	identifier,
		const struct GNUNET_IDENTITY_PrivateKey *	key
	)

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

Parameters

service	Service
identifier	Identifier string
key	Private EGO key

Definition at line 188 of file gnunet-service-messenger_service.c.

References GNUNET_MESSENGER_Service::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, GNUNET_MESSENGER_Ego::priv, and GNUNET_MESSENGER_Ego::pub.

Referenced by callback_ego_create(), and callback_update_ego().

{
  GNUNET_assert((identifier) && (key));

  struct GNUNET_HashCode hash;

  GNUNET_CRYPTO_hash(identifier, strlen(identifier), &hash);

  struct GNUNET_MESSENGER_Ego* ego = GNUNET_CONTAINER_multihashmap_get(service->egos, &hash);

  if (!ego)
  {
    ego = GNUNET_new(struct GNUNET_MESSENGER_Ego);
    GNUNET_CONTAINER_multihashmap_put(service->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");
}

Here is the call graph for this function:

Here is the caller graph for this function:

add_service_handle()

struct GNUNET_MESSENGER_SrvHandle* add_service_handle	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MQ_Handle *	mq
	)

Creates and adds a new handle to a service using a given message queue.

Parameters

service	Service
mq	Message queue

Returns

New handle

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

References add_list_handle(), create_handle(), handle, and GNUNET_MESSENGER_Service::handles.

Referenced by callback_client_connect().

{
  struct GNUNET_MESSENGER_SrvHandle *handle = create_handle (service, mq);

  if (handle)
  {
    add_list_handle (&(service->handles), handle);
  }

  return handle;
}

Here is the call graph for this function:

Here is the caller graph for this function:

remove_service_handle()

void remove_service_handle	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MESSENGER_SrvHandle *	handle
	)

Removes a handle from a service and destroys it.

Parameters

service	Service
handle	Handle

Definition at line 225 of file gnunet-service-messenger_service.c.

References destroy_handle(), GNUNET_YES, GNUNET_MESSENGER_Service::handles, and remove_list_handle().

Referenced by callback_client_disconnect().

{
  if (!handle)
    return;

  if (GNUNET_YES == remove_list_handle (&(service->handles), handle))
    destroy_handle (handle);
}

Here is the call graph for this function:

Here is the caller graph for this function:

get_service_peer_identity()

int get_service_peer_identity	(	const struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_PeerIdentity *	peer
	)

Tries to write the peer identity of the peer running a service on to the peer parameter.

The functions returns GNUNET_OK on success, otherwise GNUNET_SYSERR.

Parameters

	service	Service
[out]	peer	Peer identity

Returns

GNUNET_OK on success, otherwise GNUNET_SYSERR

Definition at line 235 of file gnunet-service-messenger_service.c.

References GNUNET_MESSENGER_Service::config, and GNUNET_CRYPTO_get_peer_identity().

Referenced by create_message_peer(), and rebuild_room_basement_structure().

{
  return GNUNET_CRYPTO_get_peer_identity (service->config, peer);
}

Here is the call graph for this function:

Here is the caller graph for this function:

get_service_contact_by_pubkey()

struct GNUNET_MESSENGER_SrvContact* get_service_contact_by_pubkey	(	struct GNUNET_MESSENGER_Service *	service,
		const struct GNUNET_IDENTITY_PublicKey *	pubkey
	)

Returns a contact of a service identified by a given public key.

If no matching contact exists, it will tried to create one with the specific public key. If the function still fails to do so, NULL gets returned.

Parameters

service	Service
pubkey	Public key of EGO

Returns

Contact

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

References GNUNET_MESSENGER_Service::contacts, create_contact(), destroy_contact(), GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_CRYPTO_hash(), and GNUNET_OK.

Referenced by add_room_contact(), and callback_verify_room_message().

{
  struct GNUNET_HashCode hash;

  GNUNET_CRYPTO_hash (pubkey, sizeof(*pubkey), &hash);

  struct GNUNET_MESSENGER_SrvContact *contact = GNUNET_CONTAINER_multihashmap_get (service->contacts, &hash);

  if (contact)
    return contact;

  contact = create_contact (pubkey);

  if (GNUNET_OK == GNUNET_CONTAINER_multihashmap_put (service->contacts, &hash, contact,
                                                      GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))
    return contact;

  destroy_contact (contact);
  return NULL;
}

Here is the call graph for this function:

Here is the caller graph for this function:

swap_service_contact_by_pubkey()

void swap_service_contact_by_pubkey	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MESSENGER_SrvContact *	contact,
		const struct GNUNET_IDENTITY_PublicKey *	pubkey
	)

Changes the public key for a contact known to a service to a specific public key and updates local map entries to access the contact by its updated key.

Parameters

service	Service
contact	Contact
pubkey	Public key of EGO

Definition at line 263 of file gnunet-service-messenger_service.c.

References GNUNET_MESSENGER_Service::contacts, get_contact_id_from_key(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_multihashmap_remove(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_memcpy, GNUNET_YES, and GNUNET_MESSENGER_SrvContact::public_key.

Referenced by handle_message_key().

{
  const struct GNUNET_HashCode *hash = get_contact_id_from_key (contact);

  if (GNUNET_YES == GNUNET_CONTAINER_multihashmap_remove (service->contacts, hash, contact))
  {
    GNUNET_memcpy(&(contact->public_key), pubkey, sizeof(*pubkey));

    hash = get_contact_id_from_key (contact);

    GNUNET_CONTAINER_multihashmap_put (service->contacts, hash, contact,
                                       GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

generate_service_new_member_id()

struct GNUNET_ShortHashCode* generate_service_new_member_id	(	struct GNUNET_MESSENGER_Service *	service,
		const struct GNUNET_HashCode *	key
	)

Tries to generate and allocate a new unique member id for a given room of a service identified by its key.

If the generation fails caused by too many tries of duplicates, it returns NULL.

Parameters

service	Service
key	Key of room

Returns

Newly generated member id or NULL

Definition at line 280 of file gnunet-service-messenger_service.c.

References generate_free_member_id(), generate_room_member_id(), get_service_room(), and GNUNET_new.

Referenced by create_handle_member_id().

{
  struct GNUNET_MESSENGER_SrvRoom *room = get_service_room (service, key);

  if (room)
  {
    return generate_room_member_id (room);
  }
  else
  {
    struct GNUNET_ShortHashCode *random_id = GNUNET_new(struct GNUNET_ShortHashCode);
    generate_free_member_id (random_id, NULL);
    return random_id;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

get_service_room()

struct GNUNET_MESSENGER_SrvRoom* get_service_room	(	struct GNUNET_MESSENGER_Service *	service,
		const struct GNUNET_HashCode *	key
	)

Returns the room identified by a given key for a service.

If the service doesn't know any room using the given key, NULL gets returned.

Parameters

service	Service
key	Key of room

Returns

Room or NULL

Definition at line 297 of file gnunet-service-messenger_service.c.

References GNUNET_CONTAINER_multihashmap_get(), and GNUNET_MESSENGER_Service::rooms.

Referenced by close_service_room(), entry_service_room(), generate_service_new_member_id(), handle_get_message(), open_service_room(), and send_handle_message().

{
  return GNUNET_CONTAINER_multihashmap_get (service->rooms, key);
}

Here is the call graph for this function:

Here is the caller graph for this function:

open_service_room()

int open_service_room	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MESSENGER_SrvHandle *	handle,
		const struct GNUNET_HashCode *	key
	)

Tries to open a room using a given key for a service by a specific handle.

The room will be created if necessary. If the function is successful, it returns GNUNET_YES, otherwise GNUNET_NO.

Parameters

service	Service
handle	Handle
key	Key of room

Returns

GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 303 of file gnunet-service-messenger_service.c.

References create_room(), destroy_room(), get_service_room(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_NO, GNUNET_OK, GNUNET_YES, open_room(), and GNUNET_MESSENGER_Service::rooms.

Referenced by open_handle_room().

{
  struct GNUNET_MESSENGER_SrvRoom *room = get_service_room (service, key);

  if (room)
    return open_room (room, handle);

  room = create_room (handle, key);

  if ((GNUNET_YES == open_room (room, handle)) && (GNUNET_OK
      == GNUNET_CONTAINER_multihashmap_put (service->rooms, key, room, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST)))
    return GNUNET_YES;

  destroy_room (room);
  return GNUNET_NO;
}

Here is the call graph for this function:

Here is the caller graph for this function:

entry_service_room()

int entry_service_room	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MESSENGER_SrvHandle *	handle,
		const struct GNUNET_PeerIdentity *	door,
		const struct GNUNET_HashCode *	key
	)

Tries to enter a room using a given key for a service by a specific handle.

The room will be created if necessary. If the function is successful, it returns GNUNET_YES, otherwise GNUNET_NO.

The room will be entered through the peer identitied by the peer identity provided as door parameter and a new connection will be made.

Parameters

service	Service
handle	Handle
door	Peer identity
key	Key of room

Returns

GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 322 of file gnunet-service-messenger_service.c.

References create_room(), destroy_room(), entry_room_at(), get_service_room(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_NO, GNUNET_OK, GNUNET_YES, and GNUNET_MESSENGER_Service::rooms.

Referenced by entry_handle_room().

{
  struct GNUNET_MESSENGER_SrvRoom *room = get_service_room (service, key);

  if (room)
  {
    if (GNUNET_YES == entry_room_at (room, handle, door))
      return GNUNET_YES;
    else
      return GNUNET_NO;
  }

  room = create_room (handle, key);

  if ((GNUNET_YES == entry_room_at (room, handle, door)) && (GNUNET_OK
      == GNUNET_CONTAINER_multihashmap_put (service->rooms, key, room, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST)))
  {
    return GNUNET_YES;
  }
  else
  {
    destroy_room (room);
    return GNUNET_NO;
  }

}

Here is the call graph for this function:

Here is the caller graph for this function:

close_service_room()

int close_service_room	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MESSENGER_SrvHandle *	handle,
		const struct GNUNET_HashCode *	key
	)

Tries to close a room using a given key for a service by a specific handle.

The room will be created if necessary. If the function is successful, it returns GNUNET_YES, otherwise GNUNET_NO.

If the specific handle is currently the host of the room for this service, a new handle which is a member will take its place. Otherwise the room will be destroyed for this service.

Parameters

service	Service
handle	Handle
key	Key of room

Returns

GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 351 of file gnunet-service-messenger_service.c.

References create_message_leave(), destroy_message(), destroy_room(), find_list_handle_by_member(), get_handle_member_id(), get_service_room(), GNUNET_assert, GNUNET_CONTAINER_multihashmap_remove(), GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_Service::handles, GNUNET_MESSENGER_SrvRoom::host, key, GNUNET_MESSENGER_SrvHandle::member_ids, GNUNET_MESSENGER_Service::rooms, and send_room_message().

Referenced by close_handle_room().

{
  struct GNUNET_MESSENGER_SrvRoom *room = get_service_room (service, key);

  if (!room)
    return GNUNET_NO;

  struct GNUNET_MESSENGER_Message *message = create_message_leave ();

  if (message)
  {
    struct GNUNET_HashCode hash;

    send_room_message (room, handle, message, &hash);
    destroy_message (message);
  }

  const struct GNUNET_ShortHashCode *id = get_handle_member_id (handle, key);

  GNUNET_assert(id);

  if (GNUNET_YES != GNUNET_CONTAINER_multihashmap_remove (handle->member_ids, key, id))
    return GNUNET_NO;

  struct GNUNET_MESSENGER_SrvHandle *member_handle = (struct GNUNET_MESSENGER_SrvHandle*) find_list_handle_by_member (
      &(service->handles), key);

  if (!member_handle)
  {
    if (GNUNET_OK == GNUNET_CONTAINER_multihashmap_remove (service->rooms, key, room))
    {
      destroy_room (room);
      return GNUNET_YES;
    }
    else
      return GNUNET_NO;
  }

  if (room->host == handle)
    room->host = member_handle;

  return GNUNET_YES;
}

Here is the call graph for this function:

Here is the caller graph for this function:

load_service_room_and_messages()

void load_service_room_and_messages	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MESSENGER_SrvRoom *	room
	)

Loads the local configuration for a given room of a service which contains the last messages hash and the ruleset for general access of new members.

Parameters

service	Service
room	Room

Definition at line 403 of file gnunet-service-messenger_service.c.

References cfg, config_file, get_room_data_subdir(), get_room_message(), GNUNET_asprintf(), GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_destroy(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_parse(), GNUNET_CRYPTO_hash_from_string, GNUNET_DISK_directory_test(), GNUNET_DISK_file_test(), GNUNET_free, GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_SrvRoom::host, load_message_store(), GNUNET_MESSENGER_SrvRoom::store, GNUNET_MESSENGER_SrvRoom::strict_access, and update_room_last_messages().

Referenced by create_room().

{
  char *room_dir;
  get_room_data_subdir (service, room, &room_dir);

  if (GNUNET_YES == GNUNET_DISK_directory_test (room_dir, GNUNET_YES))
  {
    load_message_store (&room->store, room_dir);

    char *config_file;
    GNUNET_asprintf (&config_file, "%s%s", room_dir, "room.cfg");

    struct GNUNET_CONFIGURATION_Handle *cfg = GNUNET_CONFIGURATION_create ();

    if ((GNUNET_YES == GNUNET_DISK_file_test (config_file)) && (GNUNET_OK
        == GNUNET_CONFIGURATION_parse (cfg, config_file)))
    {
      unsigned long long access;

      if (GNUNET_OK == GNUNET_CONFIGURATION_get_value_number (cfg, "room", "access-rule", &access))
        room->strict_access = (int) (access);

      char *message_string;

      if ((GNUNET_OK == GNUNET_CONFIGURATION_get_value_string (cfg, "room", "last-message", &message_string)) && (message_string))
      {
        struct GNUNET_HashCode hash;

        GNUNET_CRYPTO_hash_from_string(message_string, &hash);

        const struct GNUNET_MESSENGER_Message *message = get_room_message (room, room->host, &hash, GNUNET_NO);

        if (message)
          update_room_last_messages (room, message, &hash);

        GNUNET_free(message_string);
      }
    }

    GNUNET_CONFIGURATION_destroy (cfg);

    GNUNET_free(config_file);
  }

  GNUNET_free(room_dir);
}

Here is the call graph for this function:

Here is the caller graph for this function:

save_service_room_and_messages()

void save_service_room_and_messages	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MESSENGER_SrvRoom *	room
	)

Saves the configuration for a given room of a service which contains the last messages hash and the ruleset for general access of new members locally.

Parameters

service	Service
room	Room

Definition at line 451 of file gnunet-service-messenger_service.c.

References cfg, config_file, get_room_data_subdir(), GNUNET_asprintf(), GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_destroy(), GNUNET_CONFIGURATION_set_value_number(), GNUNET_CONFIGURATION_set_value_string(), GNUNET_CONFIGURATION_write(), GNUNET_CONTAINER_multihashmap_contains(), GNUNET_DISK_directory_create(), GNUNET_DISK_directory_test(), GNUNET_free, GNUNET_h2s_full(), GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_ListMessage::hash, GNUNET_MESSENGER_ListMessages::head, GNUNET_MESSENGER_SrvRoom::key, GNUNET_MESSENGER_SrvRoom::last_messages, GNUNET_MESSENGER_Service::rooms, save_message_store(), GNUNET_MESSENGER_SrvRoom::store, and GNUNET_MESSENGER_SrvRoom::strict_access.

Referenced by destroy_room().

{
  if (GNUNET_YES != GNUNET_CONTAINER_multihashmap_contains (service->rooms, &(room->key)))
  {
    return;
  }

  char *room_dir;
  get_room_data_subdir (service, room, &room_dir);

  if ((GNUNET_YES == GNUNET_DISK_directory_test (room_dir, GNUNET_NO)) || (GNUNET_OK
      == GNUNET_DISK_directory_create (room_dir)))
  {
    save_message_store (&room->store, room_dir);

    char *config_file;
    GNUNET_asprintf (&config_file, "%s%s", room_dir, "room.cfg");

    struct GNUNET_CONFIGURATION_Handle *cfg = GNUNET_CONFIGURATION_create ();

    GNUNET_CONFIGURATION_set_value_number (cfg, "room", "access-rule", room->strict_access);

    if (room->last_messages.head)
      GNUNET_CONFIGURATION_set_value_string (cfg, "room", "last-message",
                                             GNUNET_h2s_full (&(room->last_messages.head->hash)));

    GNUNET_CONFIGURATION_write (cfg, config_file);
    GNUNET_CONFIGURATION_destroy (cfg);

    GNUNET_free(config_file);
  }

  GNUNET_free(room_dir);
}

Here is the call graph for this function:

Here is the caller graph for this function:

handle_service_message()

void handle_service_message	(	struct GNUNET_MESSENGER_Service *	service,
		struct GNUNET_MESSENGER_SrvRoom *	room,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Sends a received or sent message with a given hash to each handle of a service which is currently member of a specific room for handling it in the client API.

Parameters

service	Service
room	Room
message	Message
hash	Hash of message

Definition at line 487 of file gnunet-service-messenger_service.c.

References encode_message(), env, get_handle_member_id(), get_message_size(), GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_RECV_MESSAGE, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), handle, GNUNET_MESSENGER_ListHandle::handle, GNUNET_MESSENGER_Service::handles, GNUNET_MESSENGER_RecvMessage::hash, GNUNET_MESSENGER_ListHandles::head, GNUNET_MESSENGER_RecvMessage::key, GNUNET_MESSENGER_SrvRoom::key, GNUNET_MESSENGER_SrvHandle::mq, msg, and GNUNET_MESSENGER_ListHandle::next.

Referenced by handle_room_messages().

{
  struct GNUNET_MESSENGER_ListHandle *element = service->handles.head;

  const uint16_t length = get_message_size (message);

  while (element)
  {
    struct GNUNET_MESSENGER_SrvHandle *handle = (struct GNUNET_MESSENGER_SrvHandle*) element->handle;

    if ((handle->mq) && (get_handle_member_id (handle, &(room->key))))
    {
      struct GNUNET_MESSENGER_RecvMessage *msg;
      struct GNUNET_MQ_Envelope *env;

      env = GNUNET_MQ_msg_extra(msg, length, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_RECV_MESSAGE);

      GNUNET_memcpy(&(msg->key), &(room->key), sizeof(room->key));
      GNUNET_memcpy(&(msg->hash), hash, sizeof(*hash));

      char *buffer = ((char*) msg) + sizeof(*msg);
      encode_message (message, length, buffer);

      GNUNET_MQ_send (handle->mq, env);
    }

    element = element->next;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: