j3d1/tinc
1
0
Fork 0
Code Issues 1 Pull requests Releases Wiki Activity

Copy packets before putting them in the queue.

Browse source
This commit is contained in:
Guus Sliepen 2001-02-25 16:04:00 +00:00
parent 38adc479a4
commit 9de5787574
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/net.c
View file

@ -17,7 +17,7 @@
along with this program; if not, write to the Free Software along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
$Id: net.c,v 1.35.4.94 2001/01/13 16:36:21 guus Exp $ $Id: net.c,v 1.35.4.95 2001/02/25 16:04:00 guus Exp $
*/ */
#include "config.h" #include "config.h"
@ -202,6 +202,7 @@ int send_packet(ip_t to, vpn_packet_t *packet)
{ {
connection_t *cl; connection_t *cl;
subnet_t *subnet; subnet_t *subnet;
vpn_packet_t *copy;
cp cp
if((subnet = lookup_subnet_ipv4(&to)) == NULL) if((subnet = lookup_subnet_ipv4(&to)) == NULL)
{ {
@ -242,7 +243,13 @@ cp
syslog(LOG_INFO, _("No valid key known yet for %s (%s), queueing packet"), syslog(LOG_INFO, _("No valid key known yet for %s (%s), queueing packet"),
cl->name, cl->hostname); cl->name, cl->hostname);
list_insert_tail(cl->queue, packet); /* Since packet is on the stack of handle_tap_input(),
we have to make a copy of it first. */
copy = xmalloc(sizeof(vpn_packet_t));
memcpy(copy, packet, sizeof(vpn_packet_t));
list_insert_tail(cl->queue, copy);
if(!cl->status.waitingforkey) if(!cl->status.waitingforkey)
send_req_key(myself, cl); /* Keys should be sent to the host running the tincd */ send_req_key(myself, cl); /* Keys should be sent to the host running the tincd */
@ -260,7 +267,7 @@ cp
void flush_queue(connection_t *cl) void flush_queue(connection_t *cl)
{ {
list_node_t *node, *next; list_node_t *node, *next;
cp
if(debug_lvl >= DEBUG_TRAFFIC) if(debug_lvl >= DEBUG_TRAFFIC)
syslog(LOG_INFO, _("Flushing queue for %s (%s)"), cl->name, cl->hostname); syslog(LOG_INFO, _("Flushing queue for %s (%s)"), cl->name, cl->hostname);
@ -270,6 +277,7 @@ void flush_queue(connection_t *cl)
xsend(cl, (vpn_packet_t *)node->data); xsend(cl, (vpn_packet_t *)node->data);
list_delete_node(cl->queue, node); list_delete_node(cl->queue, node);
} }
cp
} }
/* /*