2 This file is part of GNUnet.
3 (C) 2010 Christian Grothoff
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., 59 Temple Place - Suite 330,
18 Boston, MA 02111-1307, USA.
22 * @file vpn/gnunet-helper-vpn-api.c
23 * @brief exposes the API (the convenience-functions) of dealing with the
25 * @author Philipp Toelke
29 #include <gnunet_common.h>
30 #include <gnunet_server_lib.h>
31 #include <gnunet_os_lib.h>
33 #include "gnunet-helper-vpn-api.h"
36 stop_helper (struct GNUNET_VPN_HELPER_Handle *handle)
38 if (NULL == handle->helper_proc)
40 GNUNET_OS_process_kill (handle->helper_proc, SIGKILL);
41 GNUNET_OS_process_wait (handle->helper_proc);
42 GNUNET_OS_process_close (handle->helper_proc);
43 handle->helper_proc = NULL;
45 GNUNET_DISK_pipe_close (handle->helper_in);
46 GNUNET_DISK_pipe_close (handle->helper_out);
48 GNUNET_SERVER_mst_destroy (handle->mst);
51 extern GNUNET_SCHEDULER_TaskIdentifier shs_task;
54 * Read from the helper-process
57 helper_read (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tsdkctx)
59 struct GNUNET_VPN_HELPER_Handle *handle = cls;
61 /* no message can be bigger then 64k */
64 if (tsdkctx->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)
67 int t = GNUNET_DISK_file_read (handle->fh_from_helper, &buf, 65535);
69 /* On read-error, restart the helper */
72 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
73 "Read error for header from vpn-helper: %m\n");
76 /* Restart the helper */
78 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
79 handle->restart_task, handle);
84 GNUNET_SERVER_mst_receive (handle->mst, handle->client, buf, t, 0, 0))
86 GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "SYSERR from mst\n");
89 /* Restart the helper */
91 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
92 handle->restart_task, handle);
97 GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
98 handle->fh_from_helper, &helper_read, handle);
102 cleanup_helper (struct GNUNET_VPN_HELPER_Handle *handle)
104 stop_helper (handle);
105 GNUNET_free (handle);
108 struct GNUNET_VPN_HELPER_Handle *
109 start_helper (const char *ifname, const char *ipv6addr, const char *ipv6prefix,
110 const char *ipv4addr, const char *ipv4mask,
111 const char *process_name, GNUNET_SCHEDULER_Task restart_task,
112 GNUNET_SERVER_MessageTokenizerCallback cb, void *cb_cls)
114 struct GNUNET_VPN_HELPER_Handle *handle =
115 GNUNET_malloc (sizeof (struct GNUNET_VPN_HELPER_Handle));
117 handle->helper_in = GNUNET_DISK_pipe (GNUNET_YES, GNUNET_YES, GNUNET_NO);
118 handle->helper_out = GNUNET_DISK_pipe (GNUNET_YES, GNUNET_NO, GNUNET_YES);
120 handle->restart_task = restart_task;
122 if (handle->helper_in == NULL || handle->helper_out == NULL)
124 GNUNET_free (handle);
128 handle->helper_proc =
129 GNUNET_OS_start_process (handle->helper_in, handle->helper_out,
130 "gnunet-helper-vpn", process_name, ifname,
131 ipv6addr, ipv6prefix, ipv4addr, ipv4mask, NULL);
133 handle->fh_from_helper =
134 GNUNET_DISK_pipe_handle (handle->helper_out, GNUNET_DISK_PIPE_END_READ);
135 handle->fh_to_helper =
136 GNUNET_DISK_pipe_handle (handle->helper_in, GNUNET_DISK_PIPE_END_WRITE);
138 GNUNET_DISK_pipe_close_end (handle->helper_out, GNUNET_DISK_PIPE_END_WRITE);
139 GNUNET_DISK_pipe_close_end (handle->helper_in, GNUNET_DISK_PIPE_END_READ);
141 handle->mst = GNUNET_SERVER_mst_create (cb, cb_cls);
143 GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
144 handle->fh_from_helper, &helper_read, handle);