Initial checkin

Imported from subversion report, converted to git. Updated all paths in
scripts and makefiles, reflecting the new directory hierarchy.

1 files changed, 193 insertions, 0 deletions

diff --git a/rfc1035/rfc1035tcp.c b/rfc1035/rfc1035tcp.c
new file mode 100644
index 0000000..69725da
--- /dev/null
+++ b/rfc1035/rfc1035tcp.c
@@ -0,0 +1,193 @@
+/*
+** Copyright 1998 - 2011 Double Precision, Inc.
+** See COPYING for distribution information.
+*/
+
+#include	"config.h"
+#include	"rfc1035.h"
+#include	<stdio.h>
+#include	<string.h>
+#include	"soxwrap/soxwrap.h"
+#include	<sys/types.h>
+#include	<arpa/inet.h>
+#if	HAVE_UNISTD_H
+#include	<unistd.h>
+#endif
+#include	<stdlib.h>
+#include	<errno.h>
+#include	<fcntl.h>
+#if TIME_WITH_SYS_TIME
+#include	<sys/time.h>
+#include	<time.h>
+#else
+#if HAVE_SYS_TIME_H
+#include	<sys/time.h>
+#else
+#include	<time.h>
+#endif
+#endif
+
+
+int rfc1035_open_tcp(struct rfc1035_res *res, const RFC1035_ADDR *addr)
+{
+RFC1035_NETADDR addrbuf;
+int	af;
+const struct sockaddr *addrptr;
+int	addrptrlen;
+
+int	fd=rfc1035_mksocket(SOCK_STREAM, 0, &af);
+
+	if (fd < 0)	return (-1);
+
+	if (rfc1035_mkaddress(af, &addrbuf,
+		addr, htons(53),
+		&addrptr, &addrptrlen))
+	{
+		close(fd);
+		return (-1);
+	}
+
+	if (fcntl(fd, F_SETFL, fcntl(fd, F_GETFL, 0) | O_NDELAY) < 0)
+	{
+		sox_close(fd);
+		return (-1);
+	}
+
+	if (sox_connect(fd, addrptr, addrptrlen) == 0)
+		return (fd);
+
+	if (errno == EINPROGRESS || errno == EAGAIN)
+	{
+	unsigned	w=res->rfc1035_timeout_initial;
+
+		if (!w)	w=RFC1035_DEFAULT_INITIAL_TIMEOUT;
+		if (rfc1035_wait_query(fd, w) == 0 &&
+			(sox_connect(fd, addrptr, addrptrlen) == 0
+				|| errno == EISCONN))
+		{
+			return (fd);
+		}
+	}
+	sox_close(fd);
+	return (-1);
+}
+
+int rfc1035_send_tcp(int fd, const char *query, unsigned query_len)
+{
+int	n=query_len+2;
+char	*buf=malloc(n);
+char	*p;
+int	pl;
+
+	if (!buf)	return (-1);
+
+	buf[0]=query_len >> 8;
+	buf[1]=query_len;
+
+	memcpy(buf+2, query, query_len);
+
+	p=buf;
+	pl=n;
+	while (pl)
+	{
+	int	i=sox_write(fd, p, pl);
+
+		if (i < 0 && errno == EINTR)	continue;
+		if (i <= 0)	break;
+		p += i;
+		pl -= i;
+	}
+	free(buf);
+
+	if (pl)	return (-1);
+	return (0);
+}
+
+static int doread(int fd, char *buf, int bufsize)
+{
+int	len;
+
+	do
+	{
+		len=sox_read(fd, buf, bufsize);
+	} while (len < 0 && errno == EINTR);
+	return (len);
+}
+
+char *rfc1035_recv_tcp(struct rfc1035_res *res, int fd, int *buflen, unsigned w)
+{
+int	len;
+unsigned response_len;
+char lenbuf[2];
+char	*mallocedbuf=0;
+time_t	current_time, finish_time;
+
+	time(&current_time);
+	finish_time=current_time+w;
+
+	if (rfc1035_wait_reply(fd, w))
+		return (0);
+
+	len=doread(fd, lenbuf, 2);
+	if (len <= 0)
+	{
+		errno=EIO;
+		return (0);
+	}
+	if (len == 1)
+	{
+		time(&current_time);
+		if (current_time >= finish_time)	return (0);
+		if (rfc1035_wait_reply(fd, finish_time - current_time))
+			return (0);
+
+		len=doread(fd, lenbuf+1, 1);
+		if (len <= 0)
+		{
+			errno=EIO;
+			return (0);
+		}
+		++len;
+	}
+
+	response_len= ((unsigned)(unsigned char)lenbuf[0] << 8)
+			| (unsigned char)lenbuf[1];
+
+	if ((mallocedbuf=malloc(response_len)) == 0)
+		return (0);
+
+	*buflen=0;
+
+	while ((unsigned)*buflen < response_len)
+	{
+		time(&current_time);
+		if (current_time >= finish_time ||
+			rfc1035_wait_reply(fd, finish_time - current_time))
+		{
+			len=0;
+			errno=ETIMEDOUT;
+		}
+		else
+			len=doread(fd, mallocedbuf + *buflen,
+						response_len - *buflen);
+		if (len <= 0)
+		{
+			free(mallocedbuf);
+			return (0);
+		}
+		*buflen += len;
+	}
+	return (mallocedbuf);
+}
+
+char *rfc1035_query_tcp(struct rfc1035_res *res,
+	int fd, const char *query, unsigned query_len,
+	int *buflen, unsigned s)
+{
+char	*p;
+
+	if ( rfc1035_send_tcp(fd, query, query_len) < 0 ||
+		(p=rfc1035_recv_tcp(res, fd, buflen, s)) == 0)
+		return (0);
+	return (p);
+}