Fix reading broken BER in gcrypt/rsa.c
[tinc] / src / vde_device.c
1 /*
2     device.c -- VDE plug
3     Copyright (C) 2013 Guus Sliepen <guus@tinc-vpn.org>
4
5     This program is free software; you can redistribute it and/or modify
6     it under the terms of the GNU General Public License as published by
7     the Free Software Foundation; either version 2 of the License, or
8     (at your option) any later version.
9
10     This program is distributed in the hope that it will be useful,
11     but WITHOUT ANY WARRANTY; without even the implied warranty of
12     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13     GNU General Public License for more details.
14
15     You should have received a copy of the GNU General Public License along
16     with this program; if not, write to the Free Software Foundation, Inc.,
17     51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
18 */
19
20 #include "system.h"
21
22 #include <libvdeplug.h>
23
24 #include "conf.h"
25 #include "device.h"
26 #include "names.h"
27 #include "net.h"
28 #include "logger.h"
29 #include "route.h"
30 #include "xalloc.h"
31
32 static struct vdeconn *conn = NULL;
33 static int port = 0;
34 static char *group = NULL;
35 static const char *device_info = "VDE socket";
36
37 static bool setup_device(void) {
38         if(!get_config_string(lookup_config(&config_tree, "Device"), &device)) {
39                 xasprintf(&device, RUNSTATEDIR "/vde.ctl");
40         }
41
42         get_config_string(lookup_config(&config_tree, "Interface"), &iface);
43
44         get_config_int(lookup_config(&config_tree, "VDEPort"), &port);
45
46         get_config_string(lookup_config(&config_tree, "VDEGroup"), &group);
47
48         struct vde_open_args args = {
49                 .port = port,
50                 .group = group,
51                 .mode = 0700,
52         };
53
54         conn = vde_open(device, identname, &args);
55
56         if(!conn) {
57                 logger(DEBUG_ALWAYS, LOG_ERR, "Could not open VDE socket %s", device);
58                 return false;
59         }
60
61         device_fd = vde_datafd(conn);
62
63 #ifdef FD_CLOEXEC
64         fcntl(device_fd, F_SETFD, FD_CLOEXEC);
65 #endif
66
67         logger(DEBUG_ALWAYS, LOG_INFO, "%s is a %s", device, device_info);
68
69         if(routing_mode == RMODE_ROUTER) {
70                 overwrite_mac = true;
71         }
72
73         return true;
74 }
75
76 static void close_device(void) {
77         if(conn) {
78                 vde_close(conn);
79                 conn = NULL;
80         }
81
82         free(device);
83         device = NULL;
84
85         free(iface);
86         iface = NULL;
87
88         device_info = NULL;
89 }
90
91 static bool read_packet(vpn_packet_t *packet) {
92         ssize_t lenin = vde_recv(conn, DATA(packet), MTU, 0);
93
94         if(lenin <= 0) {
95                 logger(DEBUG_ALWAYS, LOG_ERR, "Error while reading from %s %s: %s", device_info, device, strerror(errno));
96                 event_exit();
97                 return false;
98         }
99
100         if(lenin == 1) {
101                 logger(DEBUG_TRAFFIC, LOG_DEBUG,
102                        "Dropped a packet received from %s - the sender was not allowed to send that packet.", device_info);
103                 return false;
104         }
105
106         if(lenin < 14) {
107                 logger(DEBUG_TRAFFIC, LOG_DEBUG,
108                        "Received an invalid packet from %s - packet shorter than an ethernet header).", device_info);
109                 return false;
110         }
111
112         packet->len = lenin;
113
114         logger(DEBUG_TRAFFIC, LOG_DEBUG, "Read packet of %d bytes from %s", packet->len, device_info);
115
116         return true;
117 }
118
119 static bool write_packet(vpn_packet_t *packet) {
120         if(vde_send(conn, DATA(packet), packet->len, 0) < 0) {
121                 if(errno != EINTR && errno != EAGAIN) {
122                         logger(DEBUG_ALWAYS, LOG_ERR, "Can't write to %s %s: %s", device_info, device, strerror(errno));
123                         event_exit();
124                 }
125
126                 return false;
127         }
128
129         return true;
130 }
131
132 const devops_t vde_devops = {
133         .setup = setup_device,
134         .close = close_device,
135         .read = read_packet,
136         .write = write_packet,
137 };