X-Git-Url: http://dolda2000.com/gitweb/?a=blobdiff_plain;f=daemon%2Fnet.c;h=410da9661cb7be27bbf18174674a6311c30c7da2;hb=92bd8f94ae7594bdc54577ee68f6576a0847e8bc;hp=f16441f0d67e0041f09828b2698fbc379309c419;hpb=d3372da97568d5e1f35fa19787c8ec8af93a0435;p=doldaconnect.git diff --git a/daemon/net.c b/daemon/net.c index f16441f..410da96 100644 --- a/daemon/net.c +++ b/daemon/net.c @@ -51,6 +51,7 @@ static struct configvar myvars[] = { /* 0 = Direct mode, 1 = Passive mode, 2 = SOCKS proxy */ {CONF_VAR_INT, "mode", {.num = 0}}, + {CONF_VAR_BOOL, "reuseaddr", {.num = 0}}, /* Only for direct mode */ {CONF_VAR_IPV4, "visibleipv4", {.ipv4 = {0}}}, {CONF_VAR_STRING, "publicif", {.str = L""}}, @@ -269,6 +270,23 @@ void putsock(struct socket *sk) } } +void sockpushdata(struct socket *sk, void *buf, size_t size) +{ + switch(sk->type) + { + case SOCK_STREAM: + sizebuf(&sk->inbuf.s.buf, &sk->inbuf.s.bufsize, sk->inbuf.s.datasize + size, 1, 1); + memmove(sk->inbuf.s.buf + size, sk->inbuf.s.buf, sk->inbuf.s.datasize); + memcpy(sk->inbuf.s.buf, buf, size); + sk->inbuf.s.datasize += size; + break; + case SOCK_DGRAM: + /* XXX */ + break; + } + return; +} + void *sockgetinbuf(struct socket *sk, size_t *size) { void *buf; @@ -521,6 +539,7 @@ size_t sockqueuesize(struct socket *sk) struct socket *netcslisten(int type, struct sockaddr *name, socklen_t namelen, void (*func)(struct socket *, struct socket *, void *), void *data) { struct socket *sk; + int intbuf; if(confgetint("net", "mode") == 1) { @@ -538,6 +557,11 @@ struct socket *netcslisten(int type, struct sockaddr *name, socklen_t namelen, v if((sk = mksock(name->sa_family, type)) == NULL) return(NULL); sk->state = SOCK_LST; + if(confgetint("net", "reuseaddr")) + { + intbuf = 1; + setsockopt(sk->fd, SOL_SOCKET, SO_REUSEADDR, &intbuf, sizeof(intbuf)); + } if(bind(sk->fd, name, namelen) < 0) { putsock(sk); @@ -567,6 +591,7 @@ struct socket *netcslisten(int type, struct sockaddr *name, socklen_t namelen, v struct socket *netcslistenlocal(int type, struct sockaddr *name, socklen_t namelen, void (*func)(struct socket *, struct socket *, void *), void *data) { struct socket *sk; + int intbuf; /* I don't know if this is actually correct (it probably isn't), * but since, at on least Linux systems, PF_* are specifically @@ -577,6 +602,11 @@ struct socket *netcslistenlocal(int type, struct sockaddr *name, socklen_t namel if((sk = mksock(name->sa_family, type)) == NULL) return(NULL); sk->state = SOCK_LST; + if(confgetint("net", "reuseaddr")) + { + intbuf = 1; + setsockopt(sk->fd, SOL_SOCKET, SO_REUSEADDR, &intbuf, sizeof(intbuf)); + } if(bind(sk->fd, name, namelen) < 0) { putsock(sk);