}
}
+
+
+void do_shutdown (void *cls,
+ const struct GNUNET_SCHEDULER_TaskContext * tc)
+{
+ struct GNUNET_TESTING_Daemon *d = cls;
+ GNUNET_TESTING_daemon_stop (d, TIMEOUT, &end_cb, NULL, GNUNET_YES,
+ GNUNET_NO);
+}
+
+
static void
my_cb (void *cls,
const struct GNUNET_PeerIdentity *id,
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Daemon `%s' started, will now stop it.\n", GNUNET_i2s (id));
#endif
- GNUNET_TESTING_daemon_stop (d, TIMEOUT, &end_cb, NULL, GNUNET_YES,
- GNUNET_NO);
+ GNUNET_SCHEDULER_add_now(&do_shutdown, d);
}
#define TOPOLOGY_HACK GNUNET_YES
-#define AVOID_CONN_MALLOC GNUNET_NO
/**
* Lowest port used for GNUnet testing. Should be high enough to not
* Connection context for peer group.
*/
struct ConnectTopologyContext ct_ctx;
-
-#if AVOID_CONN_MALLOC
- struct PeerConnection working_peer_connections[200000];
-
- unsigned int current_peer_connection;
-#endif
};
struct UpdateContext
added = 0;
if (add_first)
{
-#if AVOID_CONN_MALLOC
- new_first = &pg->working_peer_connections[pg->current_peer_connection];
- pg->current_peer_connection++;
-#else
new_first = GNUNET_malloc (sizeof (struct PeerConnection));
-#endif
new_first->index = second;
GNUNET_CONTAINER_DLL_insert(*first_list, *first_tail, new_first);
pg->peers[first].num_connections++;
if (add_second)
{
-#if AVOID_CONN_MALLOC
- new_second = &pg->working_peer_connections[pg->current_peer_connection];
- pg->current_peer_connection++;
-#else
new_second = GNUNET_malloc (sizeof (struct PeerConnection));
-#endif
new_second->index = first;
GNUNET_CONTAINER_DLL_insert(*second_list, *second_tail, new_second);
pg->peers[second].num_connections++;