1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/* Copyright 2011 NORDUnet A/S. All rights reserved.
See the file COPYING for licensing information. */
#if defined HAVE_CONFIG_H
#include <config.h>
#endif
#include <assert.h>
#include <event2/event.h>
#include <radsec/radsec.h>
#include <radsec/radsec-impl.h>
#include "debug.h"
#include "event.h"
#include "compat.h"
#include "udp.h"
/* Send one packet, the first in queue. */
static void
_send (struct rs_connection *conn, int fd)
{
ssize_t r = 0;
struct rs_packet *pkt = conn->out_queue;
assert (pkt->rpkt);
assert (pkt->rpkt->data);
/* Send. */
r = compat_send (fd, pkt->rpkt->data, pkt->rpkt->data_len, 0);
if (r == -1)
{
int sockerr = evutil_socket_geterror (pkt->conn->fd);
if (sockerr != EAGAIN)
rs_err_conn_push_fl (pkt->conn, RSE_SOCKERR, __FILE__, __LINE__,
"%d: send: %d (%s)", fd, sockerr,
evutil_socket_error_to_string (sockerr));
return; /* Don't unlink packet. */
}
/* Unlink the packet. */
conn->out_queue = pkt->next;
/* If there are more packets in queue, add the write event again. */
if (pkt->conn->out_queue)
{
r = event_add (pkt->conn->wev, NULL);
if (r < 0)
{
rs_err_conn_push_fl (pkt->conn, RSE_EVENT, __FILE__, __LINE__,
"event_add: %s", evutil_gai_strerror (r));
return;
}
}
}
/* Callback for conn->wev and conn->rev. FIXME: Rename. */
static void
_evcb (evutil_socket_t fd, short what, void *user_data)
{
//rs_debug (("%s: fd=%d what=0x%x\n", __func__, fd, what));
if (what & EV_TIMEOUT)
{
struct rs_connection *conn = (struct rs_connection *) user_data;
assert (conn);
conn->is_connecting = 0;
rs_debug (("%s: UDP timeout NYI", __func__));
}
else if (what & EV_READ)
{
struct rs_connection *conn = (struct rs_connection *) user_data;
assert (conn);
/* read a single UDP packet and stick it in a new struct
rs_packet */
/* TODO: Verify that reception of an unsolicited response packet
results in connection being closed. */
rs_debug (("%s: UDP read NYI", __func__));
/* TODO: delete retransmit timer */
}
else if (what & EV_WRITE)
{
struct rs_packet *pkt = (struct rs_packet *) user_data;
assert (pkt);
if (!pkt->conn->is_connected)
event_on_connect (pkt->conn, pkt);
if (pkt->conn->out_queue)
_send (pkt->conn, fd);
}
}
int
udp_init (struct rs_connection *conn, struct rs_packet *pkt)
{
assert (!conn->bev);
conn->rev = event_new (conn->evb, conn->fd, EV_READ|EV_PERSIST, _evcb, conn);
conn->wev = event_new (conn->evb, conn->fd, EV_WRITE, _evcb, pkt);
if (!conn->rev || !conn->wev)
{
if (conn->rev)
event_free (conn->rev);
/* ENOMEM _or_ EINVAL but EINVAL only if we use EV_SIGNAL, at
least for now (libevent-2.0.5). */
return rs_err_conn_push_fl (conn, RSE_NOMEM, __FILE__, __LINE__, NULL);
}
return RSE_OK;
}
|
