}
if (GNUNET_YES != active)
- return;
+ return;
for (i = 0; i < ats_count; i++)
{
if (GNUNET_ATS_QUALITY_NET_DELAY != ntohl (ats[i].type))
}
+/**
+ * Function called after the creation of a connected peer record is complete.
+ *
+ * @param cls closure (unused)
+ * @param cp handle to the newly created connected peer record
+ */
+static void
+connected_peer_cb (void *cls, struct GSF_ConnectedPeer *cp)
+{
+ if (NULL == cp)
+ return;
+ GSF_iterate_pending_requests_ (&consider_peer_for_forwarding, cp);
+}
+
+
/**
* Method called whenever a given peer connects.
*
static void
peer_connect_handler (void *cls, const struct GNUNET_PeerIdentity *peer)
{
- struct GSF_ConnectedPeer *cp;
-
if (0 == memcmp (&my_id, peer, sizeof (struct GNUNET_PeerIdentity)))
return;
- cp = GSF_peer_connect_handler_ (peer);
- if (NULL == cp)
- return;
- GSF_iterate_pending_requests_ (&consider_peer_for_forwarding, cp);
+ GSF_peer_connect_handler_ (peer, &connected_peer_cb, NULL);
}