*/
struct GNUNET_TRANSPORT_TryConnectHandle *next;
+ /**
+ *
+ */
struct GNUNET_PeerIdentity pid;
+ /**
+ *
+ */
struct GNUNET_TRANSPORT_Handle *th;
+ /**
+ *
+ */
struct GNUNET_TRANSPORT_TransmitHandle *tth;
+ /**
+ *
+ */
GNUNET_TRANSPORT_TryConnectCallback cb;
- int connect;
-
/**
* Closure for @e cb.
*/
void *cb_cls;
+
+ /**
+ *
+ */
+ int connect;
+
};
*/
struct GNUNET_TRANSPORT_OfferHelloHandle *next;
+ /**
+ *
+ */
struct GNUNET_TRANSPORT_Handle *th;
+ /**
+ *
+ */
struct GNUNET_TRANSPORT_TransmitHandle *tth;
+ /**
+ *
+ */
GNUNET_SCHEDULER_Task cont;
/**
*/
void *cls;
+ /**
+ *
+ */
struct GNUNET_MessageHeader *msg;
};
};
-
/**
* Schedule the task to send one message, either from the control
* list or the peer message queues to the service.
* @param msg message received, NULL on timeout or fatal error
*/
static void
-demultiplexer (void *cls, const struct GNUNET_MessageHeader *msg)
+demultiplexer (void *cls,
+ const struct GNUNET_MessageHeader *msg)
{
struct GNUNET_TRANSPORT_Handle *h = cls;
const struct DisconnectInfoMessage *dim;
}
-
/**
* Send REQUEST_CONNECT message to the service.
*
return sizeof (struct TransportRequestConnectMessage);
}
+
/**
* Ask the transport service to establish a connection to
* the given peer.
GNUNET_TRANSPORT_TryConnectCallback cb,
void *cb_cls)
{
- struct GNUNET_TRANSPORT_TryConnectHandle *tch = NULL;
+ struct GNUNET_TRANSPORT_TryConnectHandle *tch;
if (NULL == handle->client)
- return NULL;
+ return NULL;
tch = GNUNET_new (struct GNUNET_TRANSPORT_TryConnectHandle);
tch->th = handle;
tch->pid = *(target);
tch->tth = schedule_control_transmit (handle,
sizeof (struct TransportRequestConnectMessage),
&send_try_connect, tch);
- GNUNET_CONTAINER_DLL_insert(handle->tc_head, handle->tc_tail, tch);
+ GNUNET_CONTAINER_DLL_insert (handle->tc_head,
+ handle->tc_tail,
+ tch);
return tch;
}
GNUNET_free (tch);
}
+
/**
* Ask the transport service to shutdown a connection to
* the given peer.
* @param target who we should try to connect to
* @param cb callback to be called when request was transmitted to transport
* service
- * @param cb_cls closure for the callback
+ * @param cb_cls closure for the callback @a cb
* @return a `struct GNUNET_TRANSPORT_TryConnectHandle` handle or
* NULL on failure (cb will not be called)
*/
struct GNUNET_TRANSPORT_TryConnectHandle *
GNUNET_TRANSPORT_try_disconnect (struct GNUNET_TRANSPORT_Handle *handle,
- const struct GNUNET_PeerIdentity *target,
- GNUNET_TRANSPORT_TryConnectCallback cb,
- void *cb_cls)
+ const struct GNUNET_PeerIdentity *target,
+ GNUNET_TRANSPORT_TryConnectCallback cb,
+ void *cb_cls)
{
- struct GNUNET_TRANSPORT_TryConnectHandle *tch = NULL;
+ struct GNUNET_TRANSPORT_TryConnectHandle *tch;
if (NULL == handle->client)
- return NULL;
+ return NULL;
tch = GNUNET_new (struct GNUNET_TRANSPORT_TryConnectHandle);
tch->th = handle;
tch->pid = *(target);
tch->tth = schedule_control_transmit (handle,
sizeof (struct TransportRequestConnectMessage),
&send_try_connect, tch);
- GNUNET_CONTAINER_DLL_insert(handle->tc_head, handle->tc_tail, tch);
+ GNUNET_CONTAINER_DLL_insert (handle->tc_head,
+ handle->tc_tail,
+ tch);
return tch;
}
GNUNET_TRANSPORT_try_disconnect_cancel (struct GNUNET_TRANSPORT_TryConnectHandle *tch)
{
struct GNUNET_TRANSPORT_Handle *th;
- GNUNET_assert (GNUNET_NO == tch->connect);
+ GNUNET_assert (GNUNET_NO == tch->connect);
th = tch->th;
cancel_control_transmit (th, tch->tth);
GNUNET_CONTAINER_DLL_remove (th->tc_head, th->tc_tail, tch);
}
-
-
/**
* Send HELLO message to the service.
*