projects
/
radsecproxy.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
radsecproxy-1.6.5.
[radsecproxy.git]
/
udp.c
diff --git
a/udp.c
b/udp.c
index
4740fd0
..
380db18
100644
(file)
--- a/
udp.c
+++ b/
udp.c
@@
-24,9
+24,9
@@
#include <arpa/inet.h>
#include <regex.h>
#include <pthread.h>
#include <arpa/inet.h>
#include <regex.h>
#include <pthread.h>
-#include "list.h"
-#include "hostport.h"
+#include <assert.h>
#include "radsecproxy.h"
#include "radsecproxy.h"
+#include "hostport.h"
#ifdef RADPROT_UDP
#include "debug.h"
#ifdef RADPROT_UDP
#include "debug.h"
@@
-86,7
+86,9
@@
static char **getlistenerargs() {
void udpsetsrcres() {
if (!srcres)
void udpsetsrcres() {
if (!srcres)
- srcres = resolvepassiveaddrinfo(protoopts ? protoopts->sourcearg : NULL, NULL, protodefs.socktype);
+ srcres =
+ resolvepassiveaddrinfo(protoopts ? protoopts->sourcearg : NULL,
+ AF_UNSPEC, NULL, protodefs.socktype);
}
void removeudpclientfromreplyq(struct client *c) {
}
void removeudpclientfromreplyq(struct client *c) {
@@
-318,6
+320,7
@@
void addclientudp(struct client *client) {
}
void addserverextraudp(struct clsrvconf *conf) {
}
void addserverextraudp(struct clsrvconf *conf) {
+ assert(list_first(conf->hostports) != NULL);
switch (((struct hostportres *)list_first(conf->hostports)->data)->addrinfo->ai_family) {
case AF_INET:
if (client4_sock < 0) {
switch (((struct hostportres *)list_first(conf->hostports)->data)->addrinfo->ai_family) {
case AF_INET:
if (client4_sock < 0) {
@@
-349,15
+352,15
@@
void initextraudp() {
}
if (client4_sock >= 0)
}
if (client4_sock >= 0)
- if (pthread_create(&cl4th,
NULL
, udpclientrd, (void *)&client4_sock))
+ if (pthread_create(&cl4th,
&pthread_attr
, udpclientrd, (void *)&client4_sock))
debugx(1, DBG_ERR, "pthread_create failed");
if (client6_sock >= 0)
debugx(1, DBG_ERR, "pthread_create failed");
if (client6_sock >= 0)
- if (pthread_create(&cl6th,
NULL
, udpclientrd, (void *)&client6_sock))
+ if (pthread_create(&cl6th,
&pthread_attr
, udpclientrd, (void *)&client6_sock))
debugx(1, DBG_ERR, "pthread_create failed");
if (find_clconf_type(handle, NULL)) {
server_replyq = newqueue();
debugx(1, DBG_ERR, "pthread_create failed");
if (find_clconf_type(handle, NULL)) {
server_replyq = newqueue();
- if (pthread_create(&srvth,
NULL
, udpserverwr, (void *)server_replyq))
+ if (pthread_create(&srvth,
&pthread_attr
, udpserverwr, (void *)server_replyq))
debugx(1, DBG_ERR, "pthread_create failed");
}
}
debugx(1, DBG_ERR, "pthread_create failed");
}
}