*/
static GNUNET_TRANSPORT_NotifyDisconnect disconnect_notify_cb;
-
/**
* Lookup a neighbour entry in the neighbours hash map.
*
void
GST_neighbours_stop ()
{
+ GNUNET_assert (neighbours != NULL);
+
GNUNET_CONTAINER_multihashmap_iterate (neighbours, &disconnect_all_neighbours,
NULL);
GNUNET_CONTAINER_multihashmap_destroy (neighbours);
struct NeighbourMapEntry *n;
struct GNUNET_MessageHeader connect_msg;
+ GNUNET_assert (neighbours != NULL);
+
n = lookup_neighbour (peer);
if (NULL == n)
{
{
struct NeighbourMapEntry *n;
+ GNUNET_assert (neighbours != NULL);
+
GNUNET_assert (0 !=
memcmp (target, &GST_my_identity,
sizeof (struct GNUNET_PeerIdentity)));
{
struct NeighbourMapEntry *n;
+ GNUNET_assert (neighbours != NULL);
+
n = lookup_neighbour (target);
if ((NULL == n) || (n->is_connected != GNUNET_YES))
return GNUNET_NO; /* not connected */
{
struct NeighbourMapEntry *n;
+ GNUNET_assert (neighbours != NULL);
+
n = lookup_neighbour (peer);
if (NULL == n)
return;
struct NeighbourMapEntry *n;
struct MessageQueue *mq;
+ GNUNET_assert (neighbours != NULL);
+
n = lookup_neighbour (target);
if ((n == NULL) || (GNUNET_YES != n->is_connected))
{
struct NeighbourMapEntry *n;
struct GNUNET_TIME_Relative ret;
+ GNUNET_assert (neighbours != NULL);
+
n = lookup_neighbour (sender);
if (n == NULL)
{
{
struct NeighbourMapEntry *n;
+ GNUNET_assert (neighbours != NULL);
+
n = lookup_neighbour (neighbour);
if (NULL == n)
{
{
struct NeighbourMapEntry *n;
+ GNUNET_assert (neighbours != NULL);
+
n = lookup_neighbour (neighbour);
if (n == NULL)
{
{
struct IteratorContext ic;
+ GNUNET_assert (neighbours != NULL);
+
ic.cb = cb;
ic.cb_cls = cb_cls;
GNUNET_CONTAINER_multihashmap_iterate (neighbours, &neighbours_iterate, &ic);
struct GNUNET_TRANSPORT_PluginFunctions *papi;
struct GNUNET_MessageHeader disconnect_msg;
+ GNUNET_assert (neighbours != NULL);
+
n = lookup_neighbour (target);
if (NULL == n)
return; /* not active */