* Observed latency, set once we got a reply.
*/
struct GNUNET_TIME_Relative latency;
-
+
/**
* Category of the request.
*/
enum RequestCategory cat;
-
+
};
if (NULL == (req = todo_head))
{
struct GNUNET_TIME_Absolute at;
-
+
if (NULL == (req = act_head))
{
GNUNET_SCHEDULER_shutdown ();
rp[rc] = 0;
}
for (req = succ_head;NULL != req; req = req->next)
- {
+ {
GNUNET_assert (rp[req->cat] < replies[req->cat]);
ra[req->cat][rp[req->cat]++] = req;
}
failures[rc]);
GNUNET_free (ra[rc]);
}
-
- if (NULL != gns)
- {
- GNUNET_GNS_disconnect (gns);
- gns = NULL;
- }
if (NULL != t)
{
GNUNET_SCHEDULER_cancel (t);
req);
free_request (req);
}
+ if (NULL != gns)
+ {
+ GNUNET_GNS_disconnect (gns);
+ gns = NULL;
+ }
}