aboutsummaryrefslogtreecommitdiff
path: root/src/curl/curl_reschedule.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/curl/curl_reschedule.c')
-rw-r--r--src/curl/curl_reschedule.c201
1 files changed, 0 insertions, 201 deletions
diff --git a/src/curl/curl_reschedule.c b/src/curl/curl_reschedule.c
deleted file mode 100644
index a1fe55aa5..000000000
--- a/src/curl/curl_reschedule.c
+++ /dev/null
@@ -1,201 +0,0 @@
1/*
2 This file is part of GNUnet
3 Copyright (C) 2015, 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 curl/curl_reschedule.c
22 * @brief API for event loop integration with GNUnet SCHEDULER.
23 * @author Christian Grothoff
24 */
25#include "platform.h"
26#include <jansson.h>
27#include "gnunet_curl_lib.h"
28#include "gnunet_util_lib.h"
29
30extern void *
31GNUNET_CURL_download_get_result_ (struct GNUNET_CURL_DownloadBuffer *db,
32 CURL *eh,
33 long *response_code);
34
35/**
36 * Closure for #GNUNET_CURL_gnunet_scheduler_reschedule().
37 */
38struct GNUNET_CURL_RescheduleContext
39{
40 /**
41 * Just the task.
42 */
43 struct GNUNET_SCHEDULER_Task *task;
44
45 /**
46 * Context we manage.
47 */
48 struct GNUNET_CURL_Context *ctx;
49
50 /**
51 * Parser of the raw response.
52 */
53 GNUNET_CURL_RawParser parser;
54
55 /**
56 * Deallocate the response object.
57 */
58 GNUNET_CURL_ResponseCleaner cleaner;
59};
60
61
62/**
63 * Initialize reschedule context; with custom response parser
64 *
65 * @param ctx context to manage
66 * @return closure for #GNUNET_CURL_gnunet_scheduler_reschedule().
67 */
68struct GNUNET_CURL_RescheduleContext *
69GNUNET_CURL_gnunet_rc_create_with_parser (struct GNUNET_CURL_Context *ctx,
70 GNUNET_CURL_RawParser rp,
71 GNUNET_CURL_ResponseCleaner rc)
72{
73 struct GNUNET_CURL_RescheduleContext *rctx;
74
75 rctx = GNUNET_new (struct GNUNET_CURL_RescheduleContext);
76 rctx->ctx = ctx;
77 rctx->parser = rp;
78 rctx->cleaner = rc;
79
80 return rctx;
81}
82
83
84/**
85 * Just a wrapper to avoid casting of function pointers.
86 *
87 * @param response the (JSON) response to clean.
88 */
89static void
90clean_result (void *response)
91{
92 json_decref (response);
93}
94
95
96/**
97 * Initialize reschedule context.
98 *
99 * @param ctx context to manage
100 * @return closure for #GNUNET_CURL_gnunet_scheduler_reschedule().
101 */
102struct GNUNET_CURL_RescheduleContext *
103GNUNET_CURL_gnunet_rc_create (struct GNUNET_CURL_Context *ctx)
104{
105 struct GNUNET_CURL_RescheduleContext *rc;
106
107 rc = GNUNET_new (struct GNUNET_CURL_RescheduleContext);
108 rc->ctx = ctx;
109 rc->parser = &GNUNET_CURL_download_get_result_;
110 rc->cleaner = &clean_result;
111 return rc;
112}
113
114
115/**
116 * Destroy reschedule context.
117 *
118 * @param rc context to destroy
119 */
120void
121GNUNET_CURL_gnunet_rc_destroy (struct GNUNET_CURL_RescheduleContext *rc)
122{
123 if (NULL != rc->task)
124 GNUNET_SCHEDULER_cancel (rc->task);
125 GNUNET_free (rc);
126}
127
128
129/**
130 * Task that runs the context's event loop with the GNUnet scheduler.
131 *
132 * @param cls a `struct GNUNET_CURL_RescheduleContext *`
133 */
134static void
135context_task (void *cls)
136{
137 struct GNUNET_CURL_RescheduleContext *rc = cls;
138 long timeout;
139 int max_fd;
140 fd_set read_fd_set;
141 fd_set write_fd_set;
142 fd_set except_fd_set;
143 struct GNUNET_NETWORK_FDSet *rs;
144 struct GNUNET_NETWORK_FDSet *ws;
145 struct GNUNET_TIME_Relative delay;
146
147 rc->task = NULL;
148 GNUNET_CURL_perform2 (rc->ctx, rc->parser, rc->cleaner);
149 max_fd = -1;
150 timeout = -1;
151 FD_ZERO (&read_fd_set);
152 FD_ZERO (&write_fd_set);
153 FD_ZERO (&except_fd_set);
154 GNUNET_CURL_get_select_info (rc->ctx,
155 &read_fd_set,
156 &write_fd_set,
157 &except_fd_set,
158 &max_fd,
159 &timeout);
160 if (timeout >= 0)
161 delay =
162 GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS, timeout);
163 else
164 delay = GNUNET_TIME_UNIT_FOREVER_REL;
165 rs = GNUNET_NETWORK_fdset_create ();
166 GNUNET_NETWORK_fdset_copy_native (rs, &read_fd_set, max_fd + 1);
167 ws = GNUNET_NETWORK_fdset_create ();
168 GNUNET_NETWORK_fdset_copy_native (ws, &write_fd_set, max_fd + 1);
169 if (NULL == rc->task)
170 rc->task = GNUNET_SCHEDULER_add_select (GNUNET_SCHEDULER_PRIORITY_DEFAULT,
171 delay,
172 rs,
173 ws,
174 &context_task,
175 rc);
176 GNUNET_NETWORK_fdset_destroy (rs);
177 GNUNET_NETWORK_fdset_destroy (ws);
178}
179
180
181/**
182 * Implementation of the #GNUNET_CURL_RescheduleCallback for GNUnet's
183 * scheduler. Will run the CURL context using GNUnet's scheduler.
184 * Note that you MUST immediately destroy the reschedule context after
185 * calling #GNUNET_CURL_fini().
186 *
187 * @param cls must point to a `struct GNUNET_CURL_RescheduleContext *`
188 * (pointer to a pointer!)
189 */
190void
191GNUNET_CURL_gnunet_scheduler_reschedule (void *cls)
192{
193 struct GNUNET_CURL_RescheduleContext *rc = *(void **) cls;
194
195 if (NULL != rc->task)
196 GNUNET_SCHEDULER_cancel (rc->task);
197 rc->task = GNUNET_SCHEDULER_add_now (&context_task, rc);
198}
199
200
201/* end of curl_reschedule.c */
generated by cgit v1.2.3 (git 2.39.1) at 2024-04-20 02:24:57 +0000