2 This file is part of GNUnet.
3 Copyright (C) 2013 GNUnet e.V.
5 GNUnet is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published
7 by the Free Software Foundation; either version 3, or (at your
8 option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with GNUnet; see the file COPYING. If not, write to the
17 Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
18 Boston, MA 02110-1301, USA.
22 #include "gnunet_util_lib.h"
23 #include "gnunet_testing_lib.h"
24 #include "gnunet_core_service.h"
30 * Has the test been successful?
34 unsigned int num_received;
36 struct GNUNET_CORE_Handle *core;
38 struct GNUNET_MQ_Handle *mq;
40 struct GNUNET_PeerIdentity myself;
45 const struct GNUNET_PeerIdentity *my_identity)
47 if (NULL == my_identity)
52 myself = *my_identity;
53 mq = GNUNET_CORE_mq_create (core, my_identity);
58 connect_cb (void *cls, const struct GNUNET_PeerIdentity *peer)
60 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Connected to peer %s.\n",
62 if (0 == memcmp (peer, &myself, sizeof (struct GNUNET_PeerIdentity)))
65 struct GNUNET_MQ_Envelope *ev;
66 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Queueing messages.\n");
67 for (i = 0; i < NUM_MSG; i++)
69 ev = GNUNET_MQ_msg_header (GNUNET_MESSAGE_TYPE_TEST);
70 GNUNET_MQ_send (mq, ev);
77 handle_test (void *cls,
78 const struct GNUNET_PeerIdentity *other,
79 const struct GNUNET_MessageHeader *message)
81 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Got test message %d\n", num_received);
83 if (NUM_MSG == num_received)
86 GNUNET_SCHEDULER_shutdown ();
89 if (num_received > NUM_MSG)
99 shutdown_task (void *cls,
100 const struct GNUNET_SCHEDULER_TaskContext *tc)
102 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Shutting down\n");
103 GNUNET_MQ_destroy (mq);
104 GNUNET_CORE_disconnect (core);
109 * Initialize framework and start test
111 * @param cls Closure (unused).
112 * @param cfg Configuration handle.
113 * @param peer Testing peer handle.
117 const struct GNUNET_CONFIGURATION_Handle *cfg,
118 struct GNUNET_TESTING_Peer *peer)
120 static const struct GNUNET_CORE_MessageHandler handlers[] = {
121 {&handle_test, GNUNET_MESSAGE_TYPE_TEST, 0},
124 core = GNUNET_CORE_connect (cfg,
125 NULL, &init_cb, &connect_cb, NULL,
126 NULL, GNUNET_NO, NULL,
127 GNUNET_NO, handlers);
133 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_FOREVER_REL, &shutdown_task, NULL);
137 main (int argc, char *argv1[])
139 if (0 != GNUNET_TESTING_peer_run ("test-core-api-mq",
140 "test_core_api_peer1.conf",
143 return (result == GNUNET_OK) ? 0 : 1;