X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fmulticast%2Ftest_multicast_multipeer.c;h=0f973517df757876c895896587aae68679713224;hb=f82b3a27df765f4a31548ae4efe66dc3dbc42cef;hp=aee3a44d5aa84065834fa2fb736bd81b7e5179ca;hpb=b0042448a40e90426ea8013b1abba8b2ecb69c2b;p=oweals%2Fgnunet.git diff --git a/src/multicast/test_multicast_multipeer.c b/src/multicast/test_multicast_multipeer.c index aee3a44d5..0f973517d 100644 --- a/src/multicast/test_multicast_multipeer.c +++ b/src/multicast/test_multicast_multipeer.c @@ -35,7 +35,7 @@ #define NUM_PEERS 2 -static struct GNUNET_TESTBED_Operation *op0; +static struct GNUNET_TESTBED_Operation *op0; static struct GNUNET_TESTBED_Operation *op1; static struct GNUNET_TESTBED_Operation *pi_op0; static struct GNUNET_TESTBED_Operation *pi_op1; @@ -114,15 +114,15 @@ timeout_task (void *cls) } -static void +static void member_join_request (void *cls, const struct GNUNET_CRYPTO_EcdsaPublicKey *member_pub_key, const struct GNUNET_MessageHeader *join_msg, struct GNUNET_MULTICAST_JoinHandle *jh) { - GNUNET_log (GNUNET_ERROR_TYPE_INFO, + GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Member sent a join request.\n"); - + } int notify (void *cls, @@ -143,7 +143,7 @@ int notify (void *cls, } -static void +static void member_join_decision (void *cls, int is_admitted, const struct GNUNET_PeerIdentity *peer, @@ -165,32 +165,32 @@ member_join_decision (void *cls, } } -static void +static void member_replay_frag () { - GNUNET_log (GNUNET_ERROR_TYPE_INFO, + GNUNET_log (GNUNET_ERROR_TYPE_INFO, "member replay frag...\n"); } -static void -member_replay_msg () +static void +member_replay_msg () { - GNUNET_log (GNUNET_ERROR_TYPE_INFO, + GNUNET_log (GNUNET_ERROR_TYPE_INFO, "member replay msg...\n"); } -static void -member_message () +static void +member_message () { - GNUNET_log (GNUNET_ERROR_TYPE_INFO, + GNUNET_log (GNUNET_ERROR_TYPE_INFO, "member message...\n"); } -static void +static void origin_join_request (void *cls, const struct GNUNET_CRYPTO_EcdsaPublicKey *member_pub_key, const struct GNUNET_MessageHeader *join_msg, - struct GNUNET_MULTICAST_JoinHandle *jh) + struct GNUNET_MULTICAST_JoinHandle *jh) { struct GNUNET_MessageHeader *join_resp; @@ -217,7 +217,7 @@ origin_join_request (void *cls, result = GNUNET_OK; } -static void +static void origin_replay_frag (void *cls, const struct GNUNET_CRYPTO_EcdsaPublicKey *member_pub_key, uint64_t fragment_id, @@ -227,7 +227,7 @@ origin_replay_frag (void *cls, GNUNET_log (GNUNET_ERROR_TYPE_INFO, "origin replay fraq msg\n"); } -static void +static void origin_replay_msg (void *cls, const struct GNUNET_CRYPTO_EcdsaPublicKey *member_pub_key, uint64_t message_id, @@ -235,7 +235,7 @@ origin_replay_msg (void *cls, uint64_t flags, struct GNUNET_MULTICAST_ReplayHandle *rh) { - + GNUNET_log (GNUNET_ERROR_TYPE_INFO, "origin replay msg\n"); } @@ -267,11 +267,11 @@ service_connect1 (void *cls, void *ca_result, const char *emsg) { - member = ca_result; + member = ca_result; if (NULL != member) GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Connected to multicast service of member\n"); - else + else result = GNUNET_SYSERR; } @@ -291,7 +291,7 @@ multicast_ca1 (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg) { struct GNUNET_MessageHeader *join_msg; - + // Get members keys member_key = GNUNET_CRYPTO_ecdsa_key_create (); GNUNET_CRYPTO_ecdsa_key_get_public (member_key, &member_pub_key); @@ -302,10 +302,10 @@ multicast_ca1 (void *cls, join_msg->size = htons (sizeof (join_msg) + data_size); join_msg->type = htons (123); GNUNET_memcpy (&join_msg[1], data, data_size); - + GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Members tries to join multicast group\n"); - + return GNUNET_MULTICAST_member_join (cfg, &group_pub_key, member_key, @@ -328,13 +328,13 @@ peer_information_cb (void *cls, const struct GNUNET_TESTBED_PeerInformation *pinfo, const char *emsg) { - int i = (int) cls; + int i = (int) (long) cls; if (NULL == pinfo) { result = GNUNET_SYSERR; GNUNET_SCHEDULER_shutdown (); } - + peer_id[i] = pinfo->result.id; GNUNET_log (GNUNET_ERROR_TYPE_INFO, @@ -403,13 +403,13 @@ service_connect0 (void *cls, * Function run when service multicast has started and is providing us * with a configuration file. */ -static void * +static void * multicast_ca0 (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg) { group_key = GNUNET_CRYPTO_eddsa_key_create (); GNUNET_CRYPTO_eddsa_key_get_public (group_key, &group_pub_key); - + return GNUNET_MULTICAST_origin_start (cfg, group_key, 0, @@ -460,7 +460,7 @@ testbed_master (void *cls, topology (FIXME) */ GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Connected to testbed_master()\n"); - + peers = p; GNUNET_log (GNUNET_ERROR_TYPE_INFO, @@ -478,7 +478,7 @@ testbed_master (void *cls, NULL); /* closure for the above two callbacks */ GNUNET_SCHEDULER_add_shutdown (&shutdown_task, NULL); /* Schedule a new task on shutdown */ - + /* Schedule the shutdown task with a delay of a few Seconds */ timeout_tid = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 40), &timeout_task, NULL);