aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--iemnet_receiver.c3
-rw-r--r--udpserver.c3
2 files changed, 4 insertions, 2 deletions
diff --git a/iemnet_receiver.c b/iemnet_receiver.c
index 0b8b661..ff1f123 100644
--- a/iemnet_receiver.c
+++ b/iemnet_receiver.c
@@ -120,6 +120,7 @@ static void*iemnet__receiver_readthread(void*arg) {
while(1) {
t_iemnet_chunk*c=NULL;
+ fd_set rs;
pthread_mutex_lock(&receiver->keeprec_mtx);
if(!receiver->keepreceiving) {
@@ -129,7 +130,7 @@ static void*iemnet__receiver_readthread(void*arg) {
pthread_mutex_unlock(&receiver->keeprec_mtx);
fromlen = sizeof(from);
- fd_set rs=readset;
+ rs=readset;
timout.tv_sec=0;
timout.tv_usec=1000;
diff --git a/udpserver.c b/udpserver.c
index ea5b064..1f17150 100644
--- a/udpserver.c
+++ b/udpserver.c
@@ -561,8 +561,9 @@ static void udpserver_receive_callback(void *y, t_iemnet_chunk*c) {
if(c) {
int conns = x->x_nconnections;
+ t_udpserver_sender*sdr=NULL;
DEBUG("add new sender from %d", c->port);
- t_udpserver_sender*sdr=udpserver_sender_add(x, c->addr, c->port);
+ sdr=udpserver_sender_add(x, c->addr, c->port);
DEBUG("added new sender from %d", c->port);
if(sdr) {
udpserver_info_connection(x, sdr);