messenger_api_cmd_start_service.c File Reference

cmd to start a messenger service. More...

#include "gnunet_util_lib.h"
#include "gnunet_testing_ng_lib.h"
#include "gnunet_testing_netjail_lib.h"
#include "gnunet_transport_testing_ng_lib.h"
#include "gnunet_messenger_service.h"
#include "messenger-testing-cmds.h"

Include dependency graph for messenger_api_cmd_start_service.c:

Go to the source code of this file.

Functions
static void	on_message_cb (void *cls, struct GNUNET_MESSENGER_Room *room, const struct GNUNET_MESSENGER_Contact *sender, const struct GNUNET_MESSENGER_Contact *recipient, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash, enum GNUNET_MESSENGER_MessageFlags flags)
static void	start_service_run (void *cls, struct GNUNET_TESTING_Interpreter *is)
static void	start_service_cleanup (void *cls)
static enum GNUNET_GenericReturnValue	start_service_traits (void *cls, const void **ret, const char *trait, unsigned int index)
struct GNUNET_TESTING_Command	GNUNET_MESSENGER_cmd_start_service (const char *label, const char *peer_label, const char *system_label, struct GNUNET_MESSENGER_TestStageTopology *topology, unsigned int peer_index)

Detailed Description

cmd to start a messenger service.

Author

Tobias Frisch

Definition in file messenger_api_cmd_start_service.c.

Function Documentation

on_message_cb()

static void on_message_cb ( void *  cls, struct GNUNET_MESSENGER_Room *  room, const struct GNUNET_MESSENGER_Contact *  sender, const struct GNUNET_MESSENGER_Contact *  recipient, const struct GNUNET_MESSENGER_Message *  message, const struct GNUNET_HashCode *  hash, enum GNUNET_MESSENGER_MessageFlags  flags  )

static

Definition at line 35 of file messenger_api_cmd_start_service.c.

{
  struct GNUNET_MESSENGER_StartServiceState *sss = cls;
 
  const struct GNUNET_HashCode *key = GNUNET_MESSENGER_room_get_key (room);
  struct GNUNET_MESSENGER_RoomState *rs;
 
  rs = GNUNET_CONTAINER_multihashmap_get (sss->rooms, key);
  if (! rs)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Testing library failed to find room state\n");
    GNUNET_TESTING_interpreter_fail (sss->is);
    return;
  }
 
  if (GNUNET_MESSENGER_KIND_PEER != message->header.kind)
    return;
 
  if (GNUNET_OK != GNUNET_CONTAINER_multipeermap_put (rs->doors,
                                                      &(message->body.peer.peer),
                                                      NULL,
                                                      GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Testing library failed to register peer identity as found door\n");
    GNUNET_TESTING_interpreter_fail (sss->is);
    return;
  }
}

References GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_RoomState::doors, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE, GNUNET_CONTAINER_multipeermap_put(), GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MESSENGER_KIND_PEER, GNUNET_MESSENGER_room_get_key(), GNUNET_OK, GNUNET_TESTING_interpreter_fail(), GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_StartServiceState::is, key, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessagePeer::peer, GNUNET_MESSENGER_MessageBody::peer, and GNUNET_MESSENGER_StartServiceState::rooms.

Referenced by start_service_run().

Here is the call graph for this function:

Here is the caller graph for this function:

start_service_run()

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

static

Definition at line 74 of file messenger_api_cmd_start_service.c.

{
  struct GNUNET_MESSENGER_StartServiceState *sss = cls;
 
  sss->is = is;
 
  const struct GNUNET_TESTING_Command *peer_cmd;
  peer_cmd = GNUNET_TESTING_interpreter_lookup_command (is,
                                                        sss->peer_label);
 
  const struct GNUNET_TESTING_StartPeerState *sps;
  GNUNET_TRANSPORT_TESTING_get_trait_state (peer_cmd, &sps);
 
  const struct GNUNET_TESTING_Command *system_cmd;
  system_cmd = GNUNET_TESTING_interpreter_lookup_command (is,
                                                          sss->system_label);
 
  const struct GNUNET_TESTING_System *tl_system;
  GNUNET_TESTING_get_trait_test_system (system_cmd,
                                        &tl_system);
 
  sss->tl_system = tl_system;
 
  sss->msg = GNUNET_MESSENGER_connect (sps->cfg, NULL, NULL, on_message_cb,
                                       sss);
  if (! sss->msg)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Testing library failed to connect to messenger service\n");
    GNUNET_TESTING_interpreter_fail (is);
    return;
  }
 
  sss->rooms = GNUNET_CONTAINER_multihashmap_create (
    sss->topology->stage_amount, GNUNET_NO);
}

References GNUNET_TESTING_StartPeerState::cfg, GNUNET_CONTAINER_multihashmap_create(), GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MESSENGER_connect(), GNUNET_NO, GNUNET_TESTING_get_trait_test_system(), GNUNET_TESTING_interpreter_fail(), GNUNET_TESTING_interpreter_lookup_command(), GNUNET_TRANSPORT_TESTING_get_trait_state(), GNUNET_MESSENGER_StartServiceState::is, is, GNUNET_MESSENGER_StartServiceState::msg, on_message_cb(), GNUNET_MESSENGER_StartServiceState::peer_label, GNUNET_MESSENGER_StartServiceState::rooms, GNUNET_MESSENGER_TestStageTopology::stage_amount, GNUNET_MESSENGER_StartServiceState::system_label, GNUNET_MESSENGER_StartServiceState::tl_system, and GNUNET_MESSENGER_StartServiceState::topology.

Referenced by GNUNET_MESSENGER_cmd_start_service().

Here is the call graph for this function:

Here is the caller graph for this function:

start_service_cleanup()

static void start_service_cleanup ( void *  cls )

static

Definition at line 114 of file messenger_api_cmd_start_service.c.

{
  struct GNUNET_MESSENGER_StartServiceState *sss = cls;
 
  GNUNET_free (sss->system_label);
  GNUNET_free (sss->peer_label);
  GNUNET_free (sss);
}

References GNUNET_free, GNUNET_MESSENGER_StartServiceState::peer_label, and GNUNET_MESSENGER_StartServiceState::system_label.

Referenced by GNUNET_MESSENGER_cmd_start_service().

Here is the caller graph for this function:

start_service_traits()

static enum GNUNET_GenericReturnValue start_service_traits ( void *  cls, const void **  ret, const char *  trait, unsigned int  index  )

static

Definition at line 125 of file messenger_api_cmd_start_service.c.

{
  struct GNUNET_MESSENGER_StartServiceState *sss = cls;
 
  struct GNUNET_TESTING_Trait traits[] = {
    GNUNET_MESSENGER_make_trait_state ((void *) sss),
    GNUNET_TESTING_trait_end ()
  };
 
  return GNUNET_TESTING_get_trait (traits,
                                   ret,
                                   trait,
                                   index);
}

References GNUNET_MESSENGER_make_trait_state(), GNUNET_TESTING_get_trait(), GNUNET_TESTING_trait_end(), GNUNET_TESTING_Trait::index, and ret.

Referenced by GNUNET_MESSENGER_cmd_start_service().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_MESSENGER_cmd_start_service()

struct GNUNET_TESTING_Command GNUNET_MESSENGER_cmd_start_service	(	const char *	label,
		const char *	peer_label,
		const char *	system_label,
		struct GNUNET_MESSENGER_TestStageTopology *	topology,
		unsigned int	peer_index
	)

Definition at line 145 of file messenger_api_cmd_start_service.c.

{
  struct GNUNET_MESSENGER_StartServiceState *sss;
 
  sss = GNUNET_new (struct GNUNET_MESSENGER_StartServiceState);
  sss->peer_label = GNUNET_strdup (peer_label);
  sss->system_label = GNUNET_strdup (system_label);
  sss->topology = topology;
 
  sss->is = NULL;
  sss->tl_system = NULL;
  sss->msg = NULL;
  sss->rooms = NULL;
  sss->peer_index = peer_index;
  sss->stage_index = 0;
 
  return GNUNET_TESTING_command_new (sss,
                                     label,
                                     &start_service_run,
                                     &start_service_cleanup,
                                     &start_service_traits,
                                     NULL);
}

References GNUNET_new, GNUNET_strdup, GNUNET_TESTING_command_new(), GNUNET_MESSENGER_StartServiceState::is, GNUNET_MESSENGER_StartServiceState::msg, GNUNET_MESSENGER_StartServiceState::peer_index, GNUNET_MESSENGER_StartServiceState::peer_label, GNUNET_MESSENGER_StartServiceState::rooms, GNUNET_MESSENGER_StartServiceState::stage_index, start_service_cleanup(), start_service_run(), start_service_traits(), GNUNET_MESSENGER_StartServiceState::system_label, GNUNET_MESSENGER_StartServiceState::tl_system, and GNUNET_MESSENGER_StartServiceState::topology.

Here is the call graph for this function: