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...

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.

{
  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;
}

References cfg, ch, GNUNET_CONTAINER_multipeermap_create(), GNUNET_new, GNUNET_YES, and reconnect().

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

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.

{
  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);
}

References ch, free_sug_handle(), GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_free, GNUNET_MQ_destroy(), GNUNET_SCHEDULER_cancel(), and GNUNET_CADET_Channel::mq.

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

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.

{
  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;
}

References bw, GNUNET_TRANSPORT_ApplicationSuggestHandle::bw, ch, 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_CADET_Channel::mq, peer, pk, GNUNET_TRANSPORT_ApplicationSuggestHandle::pk, and transmit_suggestion().

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.

{
  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);
}

References 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, LOG, m, GNUNET_CADET_Channel::mq, and 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.

{
  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);
}

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

Here is the caller graph for this function: