[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r34028 - gnunet/src/psyc
From: |
gnunet |
Subject: |
[GNUnet-SVN] r34028 - gnunet/src/psyc |
Date: |
Thu, 24 Jul 2014 11:30:18 +0200 |
Author: tg
Date: 2014-07-24 11:30:18 +0200 (Thu, 24 Jul 2014)
New Revision: 34028
Modified:
gnunet/src/psyc/test_psyc.c
Log:
psyc: fix timing-related test failure
Modified: gnunet/src/psyc/test_psyc.c
===================================================================
--- gnunet/src/psyc/test_psyc.c 2014-07-24 08:17:41 UTC (rev 34027)
+++ gnunet/src/psyc/test_psyc.c 2014-07-24 09:30:18 UTC (rev 34028)
@@ -41,23 +41,23 @@
/**
* Return value from 'main'.
*/
-static int res;
+int res;
-static const struct GNUNET_CONFIGURATION_Handle *cfg;
+const struct GNUNET_CONFIGURATION_Handle *cfg;
/**
* Handle for task for timeout termination.
*/
-static GNUNET_SCHEDULER_TaskIdentifier end_badly_task;
+GNUNET_SCHEDULER_TaskIdentifier end_badly_task;
-static struct GNUNET_PSYC_Master *mst;
-static struct GNUNET_PSYC_Slave *slv;
+struct GNUNET_PSYC_Master *mst;
+struct GNUNET_PSYC_Slave *slv;
-static struct GNUNET_CRYPTO_EddsaPrivateKey *channel_key;
-static struct GNUNET_CRYPTO_EcdsaPrivateKey *slave_key;
+struct GNUNET_CRYPTO_EddsaPrivateKey *channel_key;
+struct GNUNET_CRYPTO_EcdsaPrivateKey *slave_key;
-static struct GNUNET_CRYPTO_EddsaPublicKey channel_pub_key;
-static struct GNUNET_CRYPTO_EcdsaPublicKey slave_pub_key;
+struct GNUNET_CRYPTO_EddsaPublicKey channel_pub_key;
+struct GNUNET_CRYPTO_EcdsaPublicKey slave_pub_key;
struct TransmitClosure
{
@@ -76,7 +76,7 @@
struct TransmitClosure *tmit;
-static uint8_t join_req_count;
+uint8_t join_req_count;
enum
{
@@ -86,7 +86,7 @@
} test;
-static void
+void
master_transmit ();
@@ -115,7 +115,7 @@
/**
* Clean up all resources used.
*/
-static void
+void
cleanup ()
{
if (NULL != slv)
@@ -134,7 +134,7 @@
* @param cls NULL
* @param tc scheduler context
*/
-static void
+void
end_badly (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
{
res = 1;
@@ -149,7 +149,7 @@
* @param cls NULL
* @param tc scheduler context
*/
-static void
+void
end_normally (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
{
res = 0;
@@ -161,7 +161,7 @@
/**
* Finish the test case (successfully).
*/
-static void
+void
end ()
{
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Ending tests.\n");
@@ -176,7 +176,7 @@
}
-static void
+void
master_message_cb (void *cls, uint64_t message_id, uint32_t flags,
const struct GNUNET_PSYC_MessageHeader *msg)
{
@@ -188,7 +188,7 @@
}
-static void
+void
master_message_part_cb (void *cls, uint64_t message_id,
uint64_t data_offset, uint32_t flags,
const struct GNUNET_MessageHeader *msg)
@@ -233,7 +233,7 @@
}
-static void
+void
slave_message_cb (void *cls, uint64_t message_id, uint32_t flags,
const struct GNUNET_PSYC_MessageHeader *msg)
{
@@ -245,7 +245,7 @@
}
-static void
+void
slave_message_part_cb (void *cls, uint64_t message_id,
uint64_t data_offset, uint32_t flags,
const struct GNUNET_MessageHeader *msg)
@@ -278,7 +278,7 @@
}
-static void
+void
transmit_resume (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
{
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Transmission resumed.\n");
@@ -290,7 +290,7 @@
}
-static int
+int
tmit_notify_data (void *cls, uint16_t *data_size, void *data)
{
struct TransmitClosure *tmit = cls;
@@ -332,7 +332,7 @@
}
-static int
+int
tmit_notify_mod (void *cls, uint16_t *data_size, void *data, uint8_t *oper,
uint32_t *full_value_size)
{
@@ -408,11 +408,11 @@
}
-static void
+void
slave_join ();
-static void
+void
join_decision_cb (void *cls,
const struct GNUNET_PSYC_JoinDecisionMessage *dcsn,
int is_admitted,
@@ -449,7 +449,7 @@
}
-static void
+void
join_request_cb (void *cls,
const struct GNUNET_PSYC_JoinRequestMessage *req,
const struct GNUNET_CRYPTO_EcdsaPublicKey *slave_key,
@@ -468,7 +468,7 @@
}
-static void
+void
slave_connect_cb (void *cls, uint64_t max_message_id)
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
@@ -476,12 +476,12 @@
}
-static void
+void
slave_join ()
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Joining slave.\n");
- struct GNUNET_PeerIdentity origin; // FIXME: this peer
+ struct GNUNET_PeerIdentity origin = {}; // FIXME: this peer
struct GNUNET_ENV_Environment *env = GNUNET_ENV_environment_create ();
GNUNET_ENV_environment_add (env, GNUNET_ENV_OP_ASSIGN,
"_foo", "bar baz", 7);
@@ -498,7 +498,7 @@
}
-static void
+void
master_transmit ()
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Master sending message to all.\n");
@@ -550,7 +550,7 @@
}
-static void
+void
master_start_cb (void *cls, uint64_t max_message_id)
{
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
@@ -559,6 +559,23 @@
}
+void
+master_start ()
+{
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Starting master.\n");
+ mst = GNUNET_PSYC_master_start (cfg, channel_key,
GNUNET_PSYC_CHANNEL_PRIVATE,
+ &master_start_cb, &join_request_cb,
+ &master_message_cb, &master_message_part_cb,
+ NULL);
+}
+
+void
+schedule_master_start (void *cls, const struct GNUNET_SCHEDULER_TaskContext
*tc)
+{
+ master_start ();
+}
+
+
/**
* Main function of the test, run from scheduler.
*
@@ -566,7 +583,7 @@
* @param cfg configuration we use (also to connect to PSYC service)
* @param peer handle to access more of the peer (not used)
*/
-static void
+void
#if DEBUG_TEST_PSYC
run (void *cls, char *const *args, const char *cfgfile,
const struct GNUNET_CONFIGURATION_Handle *c)
@@ -585,11 +602,14 @@
GNUNET_CRYPTO_eddsa_key_get_public (channel_key, &channel_pub_key);
GNUNET_CRYPTO_ecdsa_key_get_public (slave_key, &slave_pub_key);
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Starting master.\n");
- mst = GNUNET_PSYC_master_start (cfg, channel_key,
GNUNET_PSYC_CHANNEL_PRIVATE,
- &master_start_cb, &join_request_cb,
- &master_message_cb, &master_message_part_cb,
- NULL);
+#if DEBUG_TEST_PSYC
+ master_start ();
+#else
+ /* Allow some time for the services to initialize. */
+ GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
+ &schedule_master_start, NULL);
+#endif
+ return;
}
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r34028 - gnunet/src/psyc,
gnunet <=