aboutsummaryrefslogtreecommitdiff
path: root/src/util/test_client.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/util/test_client.c')
-rw-r--r--src/util/test_client.c196
1 files changed, 0 insertions, 196 deletions
diff --git a/src/util/test_client.c b/src/util/test_client.c
deleted file mode 100644
index ef5765fff..000000000
--- a/src/util/test_client.c
+++ /dev/null
@@ -1,196 +0,0 @@
1/*
2 This file is part of GNUnet.
3 Copyright (C) 2009, 2016 GNUnet e.V.
4
5 GNUnet is free software: you can redistribute it and/or modify it
6 under the terms of the GNU Affero General Public License as published
7 by the Free Software Foundation, either version 3 of the License,
8 or (at your option) any later version.
9
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 Affero General Public License for more details.
14
15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>.
17
18 SPDX-License-Identifier: AGPL3.0-or-later
19 */
20/**
21 * @file util/test_client.c
22 * @brief tests for client.c
23 * @author Christian Grothoff
24 */
25#include "platform.h"
26#include "gnunet_util_lib.h"
27
28static int global_ret;
29
30static struct GNUNET_MQ_Handle *client_mq;
31
32#define MY_TYPE 130
33
34
35/**
36 * Callback that just bounces the message back to the sender.
37 */
38static void
39handle_echo (void *cls,
40 const struct GNUNET_MessageHeader *message)
41{
42 struct GNUNET_SERVICE_Client *c = cls;
43 struct GNUNET_MQ_Handle *mq = GNUNET_SERVICE_client_get_mq (c);
44 struct GNUNET_MQ_Envelope *env;
45
46 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
47 "Receiving message from client, bouncing back\n");
48 env = GNUNET_MQ_msg_copy (message);
49 GNUNET_MQ_send (mq,
50 env);
51 GNUNET_SERVICE_client_continue (c);
52}
53
54
55static void
56handle_bounce (void *cls,
57 const struct GNUNET_MessageHeader *got)
58{
59 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
60 "Receiving bounce, checking content\n");
61 GNUNET_assert (NULL != got);
62 global_ret = 2;
63 GNUNET_MQ_destroy (client_mq);
64 client_mq = NULL;
65}
66
67
68/**
69 * Generic error handler, called with the appropriate error code and
70 * the same closure specified at the creation of the message queue.
71 * Not every message queue implementation supports an error handler.
72 *
73 * @param cls closure with the `struct GNUNET_STATISTICS_Handle *`
74 * @param error error code
75 */
76static void
77mq_error_handler (void *cls,
78 enum GNUNET_MQ_Error error)
79{
80 GNUNET_assert (0); /* should never happen */
81}
82
83
84static void
85task (void *cls,
86 const struct GNUNET_CONFIGURATION_Handle *cfg,
87 struct GNUNET_SERVICE_Handle *sh)
88{
89 struct GNUNET_MQ_MessageHandler chandlers[] = {
90 GNUNET_MQ_hd_fixed_size (bounce,
91 MY_TYPE,
92 struct GNUNET_MessageHeader,
93 cls),
94 GNUNET_MQ_handler_end ()
95 };
96 struct GNUNET_MQ_Envelope *env;
97 struct GNUNET_MessageHeader *msg;
98
99 /* test that ill-configured client fails instantly */
100 GNUNET_assert (NULL ==
101 GNUNET_CLIENT_connect (cfg,
102 "invalid-service",
103 NULL,
104 &mq_error_handler,
105 NULL));
106 client_mq = GNUNET_CLIENT_connect (cfg,
107 "test_client",
108 chandlers,
109 &mq_error_handler,
110 NULL);
111 GNUNET_assert (NULL != client_mq);
112 env = GNUNET_MQ_msg (msg,
113 MY_TYPE);
114 GNUNET_MQ_send (client_mq,
115 env);
116}
117
118
119/**
120 * Function called when the client connects to the service.
121 *
122 * @param cls the name of the service
123 * @param c connecting client
124 * @param mq message queue to talk to the client
125 * @return @a c
126 */
127static void *
128connect_cb (void *cls,
129 struct GNUNET_SERVICE_Client *c,
130 struct GNUNET_MQ_Handle *mq)
131{
132 return c;
133}
134
135
136/**
137 * Function called when the client disconnects.
138 *
139 * @param cls our service name
140 * @param c disconnecting client
141 * @param internal_cls must match @a c
142 */
143static void
144disconnect_cb (void *cls,
145 struct GNUNET_SERVICE_Client *c,
146 void *internal_cls)
147{
148 if (2 == global_ret)
149 {
150 GNUNET_SCHEDULER_shutdown ();
151 global_ret = 0;
152 }
153}
154
155
156int
157main (int argc,
158 char *argv[])
159{
160 struct GNUNET_MQ_MessageHandler shandlers[] = {
161 GNUNET_MQ_hd_fixed_size (echo,
162 MY_TYPE,
163 struct GNUNET_MessageHeader,
164 NULL),
165 GNUNET_MQ_handler_end ()
166 };
167 char *test_argv[] = {
168 (char *) "test_client",
169 "-c",
170 "test_client_data.conf",
171 NULL
172 };
173
174 GNUNET_log_setup ("test_client",
175 "WARNING",
176 NULL);
177 if (0 != strstr (argv[0],
178 "unix"))
179 test_argv[2] = "test_client_unix.conf";
180 global_ret = 1;
181 if (0 !=
182 GNUNET_SERVICE_run_ (3,
183 test_argv,
184 "test_client",
185 GNUNET_SERVICE_OPTION_NONE,
186 &task,
187 &connect_cb,
188 &disconnect_cb,
189 NULL,
190 shandlers))
191 global_ret = 3;
192 return global_ret;
193}
194
195
196/* end of test_client.c */
generated by cgit v1.2.3 (git 2.39.1) at 2024-04-24 06:58:19 +0000