testing_messenger_cmd_join_room.c File Reference

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_testing_core_lib.h"
#include "gnunet_testing_transport_lib.h"
#include "gnunet_messenger_service.h"
#include "messenger-testing-cmds.h"

Include dependency graph for testing_messenger_cmd_join_room.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_MESSENGER_JoinRoomState

Functions
static void	join_room_run (void *cls, struct GNUNET_TESTING_Interpreter *is)
static void	join_room_cleanup (void *cls)
struct GNUNET_TESTING_Command	GNUNET_MESSENGER_cmd_join_room (const char *label, const char *service_label, const char *room_key)

Function Documentation

join_room_run()

static void join_room_run ( void *  cls, struct GNUNET_TESTING_Interpreter *  is  )

static

Definition at line 42 of file testing_messenger_cmd_join_room.c.

{
  struct GNUNET_MESSENGER_JoinRoomState *jrs = cls;
  struct GNUNET_HashCode key;
 
  if (jrs->room_key)
    GNUNET_CRYPTO_hash (jrs->room_key, strlen (jrs->room_key), &key);
  else
    memset (&key, 0, sizeof(key));
 
  const struct GNUNET_TESTING_Command *service_cmd;
  service_cmd = GNUNET_TESTING_interpreter_lookup_command (is,
                                                           jrs->service_label);
 
  struct GNUNET_MESSENGER_StartServiceState *sss;
  GNUNET_MESSENGER_get_trait_state (service_cmd, &sss);
 
  unsigned int peer_index;
  unsigned int stage_index;
  struct GNUNET_MESSENGER_RoomState *rs;
 
  rs = GNUNET_CONTAINER_multihashmap_get (sss->rooms, &key);
  if (rs)
    goto skip_room_state;
 
  rs = GNUNET_MESSENGER_create_room_state (sss->topology);
  if ((! rs) && (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put (sss->rooms,
                                                                 &key,
                                                                 rs,
                                                                 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST)))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Testing library failed to create a room state with key '%s'\n",
                jrs->room_key);
    GNUNET_TESTING_interpreter_fail (is);
    return;
  }
 
skip_room_state:
  peer_index = sss->peer_index;
  stage_index = sss->stage_index;
 
  const unsigned int index = stage_index * sss->topology->peer_amount
                             + peer_index;
  const struct GNUNET_MESSENGER_TestStage *stage =
    &(sss->topology->peer_stages[index]);
 
  unsigned int door_index = stage->door_id;
 
  if (door_index == 0)
    door_index = (peer_index + GNUNET_CRYPTO_random_u32 (
                    GNUNET_CRYPTO_QUALITY_WEAK,
                    sss->topology->peer_amount - 1
                    ) + 1) % sss->topology->peer_amount;
  else
    door_index = (door_index - 1) % sss->topology->peer_amount;
 
  struct GNUNET_PeerIdentity *door;
  door = GNUNET_TESTING_get_peer (door_index, sss->tl_system);
  if (! door)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Testing library failed to get peer identity of index '%u'\n",
                door_index);
    GNUNET_TESTING_interpreter_fail (is);
    return;
  }
 
  struct GNUNET_MESSENGER_Room *room;
  switch (stage->join)
  {
  case GNUNET_MESSENGER_STAGE_JOIN_OPEN_ROOM:
    room = GNUNET_MESSENGER_open_room (sss->msg, &key);
 
    if (! room)
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "Testing library failed to open room with key '%s'\n",
                  jrs->room_key);
      GNUNET_free (door);
      GNUNET_TESTING_interpreter_fail (is);
      return;
    }
 
    break;
  case GNUNET_MESSENGER_STAGE_JOIN_ENTER_ROOM:
    room = GNUNET_MESSENGER_enter_room (sss->msg, door, &key);
 
    if (! room)
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "Testing library failed to enter room with key '%s'\n",
                  jrs->room_key);
      GNUNET_free (door);
      GNUNET_TESTING_interpreter_fail (is);
      return;
    }
 
    break;
  default:
    room = NULL;
    break;
  }
 
  jrs->room = room;
TODO: sss->stage_index++;
 
  GNUNET_free (door);
}

References GNUNET_MESSENGER_TestStage::door_id, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u32(), GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, GNUNET_MESSENGER_create_room_state(), GNUNET_MESSENGER_enter_room(), GNUNET_MESSENGER_get_trait_state(), GNUNET_MESSENGER_open_room(), GNUNET_MESSENGER_STAGE_JOIN_ENTER_ROOM, GNUNET_MESSENGER_STAGE_JOIN_OPEN_ROOM, GNUNET_OK, GNUNET_TESTING_get_peer(), GNUNET_TESTING_interpreter_fail(), GNUNET_TESTING_interpreter_lookup_command(), is, GNUNET_MESSENGER_TestStage::join, key, GNUNET_MESSENGER_StartServiceState::msg, GNUNET_MESSENGER_TestStageTopology::peer_amount, GNUNET_MESSENGER_StartServiceState::peer_index, GNUNET_MESSENGER_TestStageTopology::peer_stages, GNUNET_MESSENGER_JoinRoomState::room, GNUNET_MESSENGER_JoinRoomState::room_key, GNUNET_MESSENGER_StartServiceState::rooms, GNUNET_MESSENGER_JoinRoomState::service_label, GNUNET_MESSENGER_StartServiceState::stage_index, GNUNET_MESSENGER_StartServiceState::tl_system, and GNUNET_MESSENGER_StartServiceState::topology.

Referenced by GNUNET_MESSENGER_cmd_join_room().

Here is the call graph for this function:

Here is the caller graph for this function:

join_room_cleanup()

static void join_room_cleanup ( void *  cls )

static

Definition at line 155 of file testing_messenger_cmd_join_room.c.

{
  struct GNUNET_MESSENGER_JoinRoomState *jrs = cls;
 
  GNUNET_free (jrs->room_key);
  GNUNET_free (jrs->service_label);
  GNUNET_free (jrs);
}

References GNUNET_free, GNUNET_MESSENGER_JoinRoomState::room_key, and GNUNET_MESSENGER_JoinRoomState::service_label.

Referenced by GNUNET_MESSENGER_cmd_join_room().

Here is the caller graph for this function:

GNUNET_MESSENGER_cmd_join_room()

struct GNUNET_TESTING_Command GNUNET_MESSENGER_cmd_join_room	(	const char *	label,
		const char *	service_label,
		const char *	room_key
	)

Definition at line 166 of file testing_messenger_cmd_join_room.c.

{
  struct GNUNET_MESSENGER_JoinRoomState *jrs;
 
  jrs = GNUNET_new (struct GNUNET_MESSENGER_JoinRoomState);
  jrs->service_label = GNUNET_strdup (service_label);
  jrs->room_key = GNUNET_strdup (room_key);
 
  return GNUNET_TESTING_command_new (jrs,
                                     label,
                                     &join_room_run,
                                     &join_room_cleanup,
                                     NULL);
}

References GNUNET_new, GNUNET_strdup, GNUNET_TESTING_command_new, join_room_cleanup(), join_room_run(), room_key, GNUNET_MESSENGER_JoinRoomState::room_key, and GNUNET_MESSENGER_JoinRoomState::service_label.

Here is the call graph for this function: