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);
52 * Read from the helper-process
55 helper_read (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tsdkctx)
57 struct GNUNET_VPN_HELPER_Handle *handle = cls;
58 /* no message can be bigger then 64k */
61 if (tsdkctx->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)
64 int t = GNUNET_DISK_file_read (handle->fh_from_helper, &buf, 65535);
66 /* On read-error, restart the helper */
69 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
70 "Read error for header from vpn-helper: %m\n");
73 /* Restart the helper */
74 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
75 handle->restart_task, handle);
80 GNUNET_SERVER_mst_receive (handle->mst, handle->client, buf, t, 0, 0))
82 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
86 /* Restart the helper */
87 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
88 handle->restart_task, handle);
93 GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
94 handle->fh_from_helper, &helper_read,
99 cleanup_helper (struct GNUNET_VPN_HELPER_Handle *handle)
101 stop_helper (handle);
102 GNUNET_free (handle);
105 struct GNUNET_VPN_HELPER_Handle *
106 start_helper (const char *ifname,
107 const char *ipv6addr,
108 const char *ipv6prefix,
109 const char *ipv4addr,
110 const char *ipv4mask, const char *process_name,
111 GNUNET_SCHEDULER_Task restart_task,
112 GNUNET_SERVER_MessageTokenizerCallback cb, void *cb_cls,
115 struct GNUNET_VPN_HELPER_Handle *handle =
116 GNUNET_malloc (sizeof (struct GNUNET_VPN_HELPER_Handle));
118 handle->helper_in = GNUNET_DISK_pipe (GNUNET_YES, GNUNET_YES, GNUNET_NO);
119 handle->helper_out = GNUNET_DISK_pipe (GNUNET_YES, GNUNET_NO, GNUNET_YES);
121 handle->restart_task = restart_task;
123 if (handle->helper_in == NULL || handle->helper_out == NULL)
125 GNUNET_free (handle);
129 handle->helper_proc =
130 GNUNET_OS_start_process (handle->helper_in, handle->helper_out,
131 "gnunet-helper-vpn", process_name, ifname,
132 ipv6addr, ipv6prefix, ipv4addr, ipv4mask, NULL);
134 handle->fh_from_helper =
135 GNUNET_DISK_pipe_handle (handle->helper_out, GNUNET_DISK_PIPE_END_READ);
136 handle->fh_to_helper =
137 GNUNET_DISK_pipe_handle (handle->helper_in, GNUNET_DISK_PIPE_END_WRITE);
139 GNUNET_DISK_pipe_close_end (handle->helper_out, GNUNET_DISK_PIPE_END_WRITE);
140 GNUNET_DISK_pipe_close_end (handle->helper_in, GNUNET_DISK_PIPE_END_READ);
142 handle->mst = GNUNET_SERVER_mst_create (cb, cb_cls);
144 GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
145 handle->fh_from_helper, &helper_read,