service

Bandwidth allocation. More...

Functions
struct GNUNET_TRANSPORT_ApplicationHandle *	GNUNET_TRANSPORT_application_init (const struct GNUNET_CONFIGURATION_Handle *cfg)
	Initialize the TRANSPORT application client handle. More...
void	GNUNET_TRANSPORT_application_done (struct GNUNET_TRANSPORT_ApplicationHandle *ch)
	Shutdown TRANSPORT application client. More...
struct GNUNET_TRANSPORT_ApplicationSuggestHandle *	GNUNET_TRANSPORT_application_suggest (struct GNUNET_TRANSPORT_ApplicationHandle *ch, const struct GNUNET_PeerIdentity *peer, enum GNUNET_MQ_PriorityPreferences pk, struct GNUNET_BANDWIDTH_Value32NBO bw)
	An application would like TRANSPORT to connect to a peer. More...
void	GNUNET_TRANSPORT_application_suggest_cancel (struct GNUNET_TRANSPORT_ApplicationSuggestHandle *sh)
	We no longer care about being connected to a peer. More...
void	GNUNET_TRANSPORT_application_validate (struct GNUNET_TRANSPORT_ApplicationHandle *ch, const struct GNUNET_PeerIdentity *peer, enum GNUNET_NetworkType nt, const char *addr)
	An application (or a communicator) has received a HELLO (or other address data of another peer) and wants TRANSPORT to validate that the address is correct. More...
int	GNUNET_TRANSPORT_get_trait_application_handle (const struct GNUNET_TESTING_Command *cmd, struct GNUNET_TRANSPORT_ApplicationHandle **ah)

Detailed Description

Bandwidth allocation.

Function Documentation

GNUNET_TRANSPORT_application_init()

struct GNUNET_TRANSPORT_ApplicationHandle* GNUNET_TRANSPORT_application_init

(

const struct GNUNET_CONFIGURATION_Handle *

cfg

)

Initialize the TRANSPORT application client handle.

Parameters

cfg	configuration to use

Returns

ats application handle, NULL on error

Initialize the TRANSPORT application client handle.

Parameters

cfg	configuration to use

Returns

transport application handle, NULL on error

Definition at line 219 of file transport_api2_application.c.

References cfg, GNUNET_TRANSPORT_ApplicationHandle::cfg, GNUNET_TRANSPORT_ApplicationSuggestHandle::ch, GNUNET_CONTAINER_multipeermap_create(), GNUNET_new, GNUNET_YES, reconnect(), and GNUNET_TRANSPORT_ApplicationHandle::sug_requests.

Referenced by GNUNET_TRANSPORT_TESTING_start_peer(), run(), start_peer_run(), and tng_connect_run().

{
  struct GNUNET_TRANSPORT_ApplicationHandle *ch;

  ch = GNUNET_new (struct GNUNET_TRANSPORT_ApplicationHandle);
  ch->cfg = cfg;
  ch->sug_requests = GNUNET_CONTAINER_multipeermap_create (32, GNUNET_YES);
  reconnect (ch);
  return ch;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TRANSPORT_application_done()

void GNUNET_TRANSPORT_application_done

(

struct GNUNET_TRANSPORT_ApplicationHandle *

ch

)

Shutdown TRANSPORT application client.

Parameters

ch	handle to destroy

Shutdown TRANSPORT application client.

Parameters

ch	handle to release

Definition at line 257 of file transport_api2_application.c.

References free_sug_handle(), GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_free, GNUNET_MQ_destroy(), GNUNET_SCHEDULER_cancel(), GNUNET_TRANSPORT_ApplicationHandle::mq, GNUNET_TRANSPORT_ApplicationHandle::sug_requests, and GNUNET_TRANSPORT_ApplicationHandle::task.

Referenced by do_shutdown(), GNUNET_TRANSPORT_TESTING_stop_peer(), and start_peer_cleanup().

{
  if (NULL != ch->mq)
  {
    GNUNET_MQ_destroy (ch->mq);
    ch->mq = NULL;
  }
  if (NULL != ch->task)
  {
    GNUNET_SCHEDULER_cancel (ch->task);
    ch->task = NULL;
  }
  GNUNET_CONTAINER_multipeermap_iterate (ch->sug_requests,
                                         &free_sug_handle,
                                         NULL);
  GNUNET_CONTAINER_multipeermap_destroy (ch->sug_requests);
  GNUNET_free (ch);
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TRANSPORT_application_suggest()

struct GNUNET_TRANSPORT_ApplicationSuggestHandle* GNUNET_TRANSPORT_application_suggest	(	struct GNUNET_TRANSPORT_ApplicationHandle *	ch,
		const struct GNUNET_PeerIdentity *	peer,
		enum GNUNET_MQ_PriorityPreferences	pk,
		struct GNUNET_BANDWIDTH_Value32NBO	bw
	)

An application would like TRANSPORT to connect to a peer.

Parameters

ch	handle
peer	identity of the peer we need an address for
pk	what kind of application will the application require (can be GNUNET_MQ_PRIO_BACKGROUND, we will still try to connect)
bw	desired bandwidth, can be zero (we will still try to connect)

Returns

suggest handle, NULL if a request is already pending

Definition at line 289 of file transport_api2_application.c.

References GNUNET_TRANSPORT_ApplicationSuggestHandle::bw, GNUNET_TRANSPORT_ApplicationSuggestHandle::ch, GNUNET_assert, GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_CONTAINER_multipeermap_put(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_new, GNUNET_OK, GNUNET_TRANSPORT_ApplicationSuggestHandle::id, LOG, GNUNET_TRANSPORT_ApplicationHandle::mq, peer, GNUNET_TRANSPORT_ApplicationSuggestHandle::pk, GNUNET_TRANSPORT_ApplicationHandle::sug_requests, and transmit_suggestion().

{
  struct GNUNET_TRANSPORT_ApplicationSuggestHandle *s;

  s = GNUNET_new (struct GNUNET_TRANSPORT_ApplicationSuggestHandle);
  s->ch = ch;
  s->id = *peer;
  s->pk = pk;
  s->bw = bw;
  (void) GNUNET_CONTAINER_multipeermap_put (
    ch->sug_requests,
    &s->id,
    s,
    GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Requesting TRANSPORT to suggest address for `%s'\n",
       GNUNET_i2s (peer));
  if (NULL == ch->mq)
    return s;
  GNUNET_assert (GNUNET_OK == transmit_suggestion (ch, &s->id, s));
  return s;
}

Here is the call graph for this function:

GNUNET_TRANSPORT_application_suggest_cancel()

void GNUNET_TRANSPORT_application_suggest_cancel

(

struct GNUNET_TRANSPORT_ApplicationSuggestHandle *

sh

)

We no longer care about being connected to a peer.

Parameters

sh	handle to stop

Definition at line 323 of file transport_api2_application.c.

References GNUNET_TRANSPORT_ApplicationSuggestHandle::bw, GNUNET_TRANSPORT_ApplicationSuggestHandle::ch, GNUNET_assert, GNUNET_CONTAINER_multipeermap_remove(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_i2s(), GNUNET_MESSAGE_TYPE_TRANSPORT_SUGGEST_CANCEL, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_OK, GNUNET_TRANSPORT_ApplicationSuggestHandle::id, LOG, m, GNUNET_TRANSPORT_ApplicationHandle::mq, GNUNET_TRANSPORT_ApplicationSuggestHandle::pk, and GNUNET_TRANSPORT_ApplicationHandle::sug_requests.

{
  struct GNUNET_TRANSPORT_ApplicationHandle *ch = sh->ch;
  struct GNUNET_MQ_Envelope *ev;
  struct ExpressPreferenceMessage *m;

  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Telling TRANSPORT we no longer care for an address for `%s'\n",
       GNUNET_i2s (&sh->id));
  GNUNET_assert (
    GNUNET_OK ==
    GNUNET_CONTAINER_multipeermap_remove (ch->sug_requests, &sh->id, sh));
  if (NULL == ch->mq)
  {
    GNUNET_free (sh);
    return;
  }
  ev = GNUNET_MQ_msg (m, GNUNET_MESSAGE_TYPE_TRANSPORT_SUGGEST_CANCEL);
  m->pk = htonl ((uint32_t) sh->pk);
  m->bw = sh->bw;
  m->peer = sh->id;
  GNUNET_MQ_send (ch->mq, ev);
  GNUNET_free (sh);
}

Here is the call graph for this function:

GNUNET_TRANSPORT_application_validate()

void GNUNET_TRANSPORT_application_validate	(	struct GNUNET_TRANSPORT_ApplicationHandle *	ch,
		const struct GNUNET_PeerIdentity *	peer,
		enum GNUNET_NetworkType	nt,
		const char *	addr
	)

An application (or a communicator) has received a HELLO (or other address data of another peer) and wants TRANSPORT to validate that the address is correct.

The result is NOT returned, in fact TRANSPORT may do nothing (i.e. if it has too many active validations or recently tried this one already). If the addr validates, TRANSPORT will persist the address with PEERSTORE.

Parameters

ch	handle
peer	identity of the peer we have an address for
nt	network type of addr (as claimed by the other peer); used by TRANSPORT to avoid trying addr's that really cannot work due to network type mismatches
addr	address to validate

Definition at line 366 of file transport_api2_application.c.

References GNUNET_ERROR_TYPE_WARNING, GNUNET_i2s(), GNUNET_log, GNUNET_MESSAGE_TYPE_TRANSPORT_REQUEST_HELLO_VALIDATION, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), m, GNUNET_TRANSPORT_ApplicationHandle::mq, and peer.

Referenced by connect_peers_run(), offer_hello(), and sock_read().

{
  struct GNUNET_MQ_Envelope *ev;
  struct RequestHelloValidationMessage *m;
  size_t alen;

  if (NULL == ch->mq)
  {
    GNUNET_log (
      GNUNET_ERROR_TYPE_WARNING,
      "Address validation for %s:%s skipped as transport is not connected\n",
      GNUNET_i2s (peer),
      addr);
    return;
  }
  alen = strlen (addr) + 1;
  ev =
    GNUNET_MQ_msg_extra (m,
                         alen,
                         GNUNET_MESSAGE_TYPE_TRANSPORT_REQUEST_HELLO_VALIDATION);
  m->peer = *peer;
  m->nt = htonl ((uint32_t) nt);
  memcpy (&m[1], addr, alen);
  GNUNET_MQ_send (ch->mq, ev);
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TRANSPORT_get_trait_application_handle()

int GNUNET_TRANSPORT_get_trait_application_handle	(	const struct GNUNET_TESTING_Command *	cmd,
		struct GNUNET_TRANSPORT_ApplicationHandle **	ah
	)

Definition at line 524 of file transport_api_cmd_start_peer.c.

References GNUNET_TESTING_Command::cls, and GNUNET_TESTING_Command::traits.

Referenced by connect_peers_run().

{
  return cmd->traits (cmd->cls,
                      (const void **) ah,
                      "application_handle",
                      (unsigned int) 0);
}

Here is the caller graph for this function: