aboutsummaryrefslogtreecommitdiff
path: root/src/cadet/cadet_api_list_tunnels.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/cadet/cadet_api_list_tunnels.c')
-rw-r--r--src/cadet/cadet_api_list_tunnels.c239
1 files changed, 0 insertions, 239 deletions
diff --git a/src/cadet/cadet_api_list_tunnels.c b/src/cadet/cadet_api_list_tunnels.c
deleted file mode 100644
index e9ae069bb..000000000
--- a/src/cadet/cadet_api_list_tunnels.c
+++ /dev/null
@@ -1,239 +0,0 @@
1/*
2 This file is part of GNUnet.
3 Copyright (C) 2011, 2017, 2019 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 cadet/cadet_api_list_tunnels.c
22 * @brief cadet api: client implementation of cadet service
23 * @author Bartlomiej Polot
24 * @author Christian Grothoff
25 */
26#include "platform.h"
27#include "gnunet_util_lib.h"
28#include "gnunet_constants.h"
29#include "gnunet_cadet_service.h"
30#include "cadet.h"
31#include "cadet_protocol.h"
32
33
34/**
35 * Operation handle.
36 */
37struct GNUNET_CADET_ListTunnels
38{
39 /**
40 * Monitor callback
41 */
42 GNUNET_CADET_TunnelsCB tunnels_cb;
43
44 /**
45 * Info callback closure for @c tunnels_cb.
46 */
47 void *tunnels_cb_cls;
48
49 /**
50 * Message queue to talk to CADET service.
51 */
52 struct GNUNET_MQ_Handle *mq;
53
54 /**
55 * Configuration we use.
56 */
57 const struct GNUNET_CONFIGURATION_Handle *cfg;
58
59 /**
60 * Task to reconnect.
61 */
62 struct GNUNET_SCHEDULER_Task *reconnect_task;
63
64 /**
65 * Backoff for reconnect attempts.
66 */
67 struct GNUNET_TIME_Relative backoff;
68};
69
70
71/**
72 * Process a local reply about info on all tunnels, pass info to the user.
73 *
74 * @param cls a `struct GNUNET_CADET_ListTunnels *`
75 * @param info Message itself.
76 */
77static void
78handle_get_tunnels (void *cls,
79 const struct GNUNET_CADET_LocalInfoTunnel *info)
80{
81 struct GNUNET_CADET_ListTunnels *lt = cls;
82 struct GNUNET_CADET_TunnelDetails td;
83
84 td.peer = info->destination;
85 td.channels = ntohl (info->channels);
86 td.connections = ntohl (info->connections);
87 td.estate = ntohs (info->estate);
88 td.cstate = ntohs (info->cstate);
89 lt->tunnels_cb (lt->tunnels_cb_cls,
90 &td);
91}
92
93
94/**
95 * Process a local reply about info on all tunnels, pass info to the user.
96 *
97 * @param cls a `struct GNUNET_CADET_ListTunnels *`
98 * @param message Message itself.
99 */
100static void
101handle_get_tunnels_end (void *cls,
102 const struct GNUNET_MessageHeader *msg)
103{
104 struct GNUNET_CADET_ListTunnels *lt = cls;
105
106 (void) msg;
107
108 lt->tunnels_cb (lt->tunnels_cb_cls,
109 NULL);
110 GNUNET_CADET_list_tunnels_cancel (lt);
111}
112
113
114/**
115 * Reconnect to the service and try again.
116 *
117 * @param cls a `struct GNUNET_CADET_ListTunnels` operation
118 */
119static void
120reconnect (void *cls);
121
122
123/**
124 * Function called on connection trouble. Reconnects.
125 *
126 * @param cls a `struct GNUNET_CADET_ListTunnels`
127 * @param error error code from MQ
128 */
129static void
130error_handler (void *cls,
131 enum GNUNET_MQ_Error error)
132{
133 struct GNUNET_CADET_ListTunnels *lt = cls;
134
135 GNUNET_MQ_destroy (lt->mq);
136 lt->mq = NULL;
137 lt->backoff = GNUNET_TIME_randomized_backoff (lt->backoff,
138 GNUNET_TIME_UNIT_MINUTES);
139 lt->reconnect_task = GNUNET_SCHEDULER_add_delayed (lt->backoff,
140 &reconnect,
141 lt);
142}
143
144
145/**
146 * Reconnect to the service and try again.
147 *
148 * @param cls a `struct GNUNET_CADET_ListTunnels` operation
149 */
150static void
151reconnect (void *cls)
152{
153 struct GNUNET_CADET_ListTunnels *lt = cls;
154 struct GNUNET_MQ_MessageHandler handlers[] = {
155 GNUNET_MQ_hd_fixed_size (get_tunnels,
156 GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_TUNNELS,
157 struct GNUNET_CADET_LocalInfoTunnel,
158 lt),
159 GNUNET_MQ_hd_fixed_size (get_tunnels_end,
160 GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_TUNNELS_END,
161 struct GNUNET_MessageHeader,
162 lt),
163 GNUNET_MQ_handler_end ()
164 };
165 struct GNUNET_MessageHeader *msg;
166 struct GNUNET_MQ_Envelope *env;
167
168 lt->reconnect_task = NULL;
169 lt->mq = GNUNET_CLIENT_connect (lt->cfg,
170 "cadet",
171 handlers,
172 &error_handler,
173 lt);
174 if (NULL == lt->mq)
175 return;
176 env = GNUNET_MQ_msg (msg,
177 GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_TUNNELS);
178 GNUNET_MQ_send (lt->mq,
179 env);
180}
181
182
183/**
184 * Request information about tunnels of the running cadet peer.
185 * The callback will be called for every tunnel of the service.
186 * Only one info request (of any kind) can be active at once.
187 *
188 * @param cfg configuration to use
189 * @param callback Function to call with the requested data.
190 * @param callback_cls Closure for @c callback.
191 * @return NULL on error
192 */
193struct GNUNET_CADET_ListTunnels *
194GNUNET_CADET_list_tunnels (const struct GNUNET_CONFIGURATION_Handle *cfg,
195 GNUNET_CADET_TunnelsCB callback,
196 void *callback_cls)
197{
198 struct GNUNET_CADET_ListTunnels *lt;
199
200 if (NULL == callback)
201 {
202 GNUNET_break (0);
203 return NULL;
204 }
205 lt = GNUNET_new (struct GNUNET_CADET_ListTunnels);
206 lt->tunnels_cb = callback;
207 lt->tunnels_cb_cls = callback_cls;
208 lt->cfg = cfg;
209 reconnect (lt);
210 if (NULL == lt->mq)
211 {
212 GNUNET_free (lt);
213 return NULL;
214 }
215 return lt;
216}
217
218
219/**
220 * Cancel a monitor request. The monitor callback will not be called.
221 *
222 * @param lt operation handle
223 * @return Closure given to GNUNET_CADET_list_tunnels().
224 */
225void *
226GNUNET_CADET_list_tunnels_cancel (struct GNUNET_CADET_ListTunnels *lt)
227{
228 void *ret = lt->tunnels_cb_cls;
229
230 if (NULL != lt->mq)
231 GNUNET_MQ_destroy (lt->mq);
232 if (NULL != lt->reconnect_task)
233 GNUNET_SCHEDULER_cancel (lt->reconnect_task);
234 GNUNET_free (lt);
235 return ret;
236}
237
238
239/* end of cadet_api_list_tunnels.c */
generated by cgit v1.2.3 (git 2.39.1) at 2024-04-23 15:09:02 +0000