GNUnet  0.11.x
Functions
messenger_api_util.c File Reference

messenger api: client implementation of GNUnet MESSENGER service More...

#include "messenger_api_util.h"
Include dependency graph for messenger_api_util.c:

Go to the source code of this file.

Functions

static void callback_close_channel (void *cls)
 
void delayed_disconnect_channel (struct GNUNET_CADET_Channel *channel)
 Starts an urgent task to close a CADET channel asynchronously. More...
 
int generate_free_member_id (struct GNUNET_ShortHashCode *id, const struct GNUNET_CONTAINER_MultiShortmap *members)
 Tries to generate an unused member id and store it into the id parameter. More...
 
const struct GNUNET_IDENTITY_PublicKeyget_anonymous_public_key ()
 Returns the public identity key of GNUNET_IDENTITY_ego_get_anonymous() without recalculating it every time. More...
 
void convert_messenger_key_to_port (const struct GNUNET_HashCode *key, struct GNUNET_HashCode *port)
 Converts a Messenger service key of a room to the specific port which gets used for the CADET channels. More...
 

Detailed Description

messenger api: client implementation of GNUnet MESSENGER service

Author
Tobias Frisch

Definition in file messenger_api_util.c.

Function Documentation

◆ callback_close_channel()

static void callback_close_channel ( void *  cls)
static

Definition at line 29 of file messenger_api_util.c.

References GNUNET_CADET_channel_destroy().

Referenced by delayed_disconnect_channel().

30 {
31  struct GNUNET_CADET_Channel *channel = cls;
32 
33  if (channel)
35 }
Opaque handle to a channel.
Definition: cadet.h:116
void GNUNET_CADET_channel_destroy(struct GNUNET_CADET_Channel *channel)
Destroy an existing channel.
Definition: cadet_api.c:837
Here is the call graph for this function:
Here is the caller graph for this function:

◆ delayed_disconnect_channel()

void delayed_disconnect_channel ( struct GNUNET_CADET_Channel channel)

Starts an urgent task to close a CADET channel asynchronously.

Parameters

Definition at line 38 of file messenger_api_util.c.

References callback_close_channel(), GNUNET_assert, GNUNET_SCHEDULER_add_delayed_with_priority(), GNUNET_SCHEDULER_PRIORITY_URGENT, and GNUNET_TIME_relative_get_zero_().

Referenced by bind_tunnel(), callback_room_connect(), and disconnect_tunnel().

39 {
40  GNUNET_assert(channel);
41 
44  callback_close_channel, channel);
45 }
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_delayed_with_priority(struct GNUNET_TIME_Relative delay, enum GNUNET_SCHEDULER_Priority priority, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay.
Definition: scheduler.c:1199
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
struct GNUNET_TIME_Relative GNUNET_TIME_relative_get_zero_(void)
Return relative time of 0ms.
Definition: time.c:100
static void callback_close_channel(void *cls)
Run with priority for urgent tasks.
Here is the call graph for this function:
Here is the caller graph for this function:

◆ generate_free_member_id()

int generate_free_member_id ( struct GNUNET_ShortHashCode id,
const struct GNUNET_CONTAINER_MultiShortmap members 
)

Tries to generate an unused member id and store it into the id parameter.

A map containing all currently used member ids is used to check against.

Parameters
[out]idNew member id
[in]membersMap of member ids
Returns
GNUNET_YES on success, GNUNET_NO on failure

Definition at line 48 of file messenger_api_util.c.

References GNUNET_assert, GNUNET_CONTAINER_multishortmap_contains(), GNUNET_CONTAINER_multishortmap_size(), GNUNET_CRYPTO_QUALITY_STRONG, GNUNET_CRYPTO_random_block(), GNUNET_NO, and GNUNET_YES.

Referenced by create_handle_member_id(), create_member(), and solve_room_member_collisions().

49 {
50  GNUNET_assert(id);
51 
52  size_t counter = 1 + (members ? GNUNET_CONTAINER_multishortmap_size (members) : 0);
53 
54  do
55  {
57 
58  if ((members) && (GNUNET_YES == GNUNET_CONTAINER_multishortmap_contains (members, id)))
59  counter--;
60  else
61  break;
62  }
63  while (counter > 0);
64 
65  if (counter)
66  return GNUNET_YES;
67 
68  return GNUNET_NO;
69 }
unsigned int GNUNET_CONTAINER_multishortmap_size(const struct GNUNET_CONTAINER_MultiShortmap *map)
Get the number of key-value pairs in the map.
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
A 256-bit hashcode.
void GNUNET_CRYPTO_random_block(enum GNUNET_CRYPTO_Quality mode, void *buffer, size_t length)
Fill block with a random values.
int GNUNET_CONTAINER_multishortmap_contains(const struct GNUNET_CONTAINER_MultiShortmap *map, const struct GNUNET_ShortHashCode *key)
Check if the map contains any value under the given key (including values that are NULL)...
High-quality operations are desired.
Here is the call graph for this function:
Here is the caller graph for this function:

◆ get_anonymous_public_key()

const struct GNUNET_IDENTITY_PublicKey* get_anonymous_public_key ( )

Returns the public identity key of GNUNET_IDENTITY_ego_get_anonymous() without recalculating it every time.

Returns
anonymous public key

Definition at line 72 of file messenger_api_util.c.

References GNUNET_IDENTITY_ego_get_anonymous(), and GNUNET_IDENTITY_ego_get_public_key().

Referenced by get_handle_key(), get_non_anonymous_key(), and select_store_contact_map().

73 {
74  static struct GNUNET_IDENTITY_PublicKey public_key;
75  static struct GNUNET_IDENTITY_Ego* ego = NULL;
76 
77  if (!ego)
78  {
80  GNUNET_IDENTITY_ego_get_public_key(ego, &public_key);
81  }
82 
83  return &public_key;
84 }
void GNUNET_IDENTITY_ego_get_public_key(struct GNUNET_IDENTITY_Ego *ego, struct GNUNET_IDENTITY_PublicKey *pk)
Get the identifier (public key) of an ego.
Definition: identity_api.c:652
Handle for an ego.
Definition: identity.h:36
struct GNUNET_IDENTITY_Ego * GNUNET_IDENTITY_ego_get_anonymous()
Obtain the ego representing 'anonymous' users.
Definition: identity_api.c:156
An identity key as per LSD0001.
Here is the call graph for this function:
Here is the caller graph for this function:

◆ convert_messenger_key_to_port()

void convert_messenger_key_to_port ( const struct GNUNET_HashCode key,
struct GNUNET_HashCode port 
)

Converts a Messenger service key of a room to the specific port which gets used for the CADET channels.

The port includes upper bits of the GNUNET_MESSENGER_VERSION to reduce the chance of incompatible connections.

Parameters
[in]keyMessenger service room key
[out]portCADET service port

Definition at line 87 of file messenger_api_util.c.

References GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_hash_sum(), GNUNET_htole32, and GNUNET_MESSENGER_VERSION.

Referenced by connect_tunnel(), and open_room().

88 {
89  static uint32_t version_value = 0;
90  static struct GNUNET_HashCode version;
91 
92  if (!version_value) {
93  version_value = (uint32_t) (GNUNET_MESSENGER_VERSION);
94  version_value = ((version_value >> 16) & 0xFFFF);
95  version_value = GNUNET_htole32(version_value);
96  GNUNET_CRYPTO_hash(&version_value, sizeof(version_value), &version);
97  }
98 
99  GNUNET_CRYPTO_hash_sum(key, &version, port);
100 }
#define GNUNET_MESSENGER_VERSION
Version number of GNUnet Messenger API.
void GNUNET_CRYPTO_hash_sum(const struct GNUNET_HashCode *a, const struct GNUNET_HashCode *delta, struct GNUNET_HashCode *result)
compute result = a + delta
Definition: crypto_hash.c:122
void GNUNET_CRYPTO_hash(const void *block, size_t size, struct GNUNET_HashCode *ret)
Compute hash of a given block.
Definition: crypto_hash.c:41
#define GNUNET_htole32(x)
A 512-bit hashcode.
Here is the call graph for this function:
Here is the caller graph for this function: