}
+/**
+ * Abort test: schedule disconnect and shutdown immediately
+ *
+ * @param line Line in the code the abort is requested from (__LINE__).
+ */
void
abort_test (long line)
{
{
GNUNET_SCHEDULER_cancel (disconnect_task);
}
- disconnect_task = GNUNET_SCHEDULER_add_delayed (SHORT_TIME,
- &disconnect_mesh_peers,
- (void *) line);
+ disconnect_task = GNUNET_SCHEDULER_add_delayed (SHORT_TIME,
+ &disconnect_mesh_peers,
+ (void *) line);
}
/**
if (size < size_payload || NULL == buf)
{
GNUNET_break (0);
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"size %u, buf %p, data_sent %u, data_received %u\n",
size,
buf,
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"peer %s disconnected\n",
GNUNET_i2s (peer));
+ if (P2P_SIGNAL == test)
+ {
+ ok ++;
+ if (GNUNET_SCHEDULER_NO_TASK != disconnect_task)
+ {
+ GNUNET_SCHEDULER_cancel (disconnect_task);
+ }
+ disconnect_task = GNUNET_SCHEDULER_add_now (&disconnect_mesh_peers,
+ (void *) __LINE__);
+ }
return;
}