1 files changed, 143 insertions, 0 deletions
diff --git a/usr.sbin/iscsid/util.c b/usr.sbin/iscsid/util.c
new file mode 100644
index 00000000000..8e1242efbd4
--- /dev/null
+++ b/usr.sbin/iscsid/util.c
@@ -0,0 +1,143 @@
+/*	$OpenBSD: util.c,v 1.1 2010/09/24 09:43:19 claudio Exp $ */
+
+/*
+ * Copyright (c) 2009 Claudio Jeker <claudio@openbsd.org>
+ *
+ * Permission to use, copy, modify, and distribute this software for any
+ * purpose with or without fee is hereby granted, provided that the above
+ * copyright notice and this permission notice appear in all copies.
+ * 
+ * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+ * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+ * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+ * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+ * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+ * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+ * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+ */
+#include <sys/types.h>
+#include <sys/queue.h>
+#include <sys/socket.h>
+#include <sys/uio.h>
+
+#include <scsi/iscsi.h>
+
+#include <errno.h>
+#include <event.h>
+#include <fcntl.h>
+#include <netdb.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <strings.h>
+#include <unistd.h>
+
+#include "iscsid.h"
+#include "log.h"
+
+struct pdu *
+pdu_new(void)
+{
+	struct pdu *p;
+
+	if (!(p = calloc(1, sizeof(*p))))
+		return NULL;
+	return p;
+}
+
+void *
+pdu_alloc(size_t len)
+{
+	return malloc(PDU_LEN(len));
+}
+
+void *
+pdu_dup(void *data, size_t len)
+{
+	void *p;
+
+	if ((p = malloc(PDU_LEN(len))))
+		bcopy(data, p, len);
+	return p;
+}
+
+int
+pdu_addbuf(struct pdu *p, void *buf, size_t len, unsigned int elm)
+{
+	if (len & 0x3) {
+		bzero((char *)buf + len, 4 - (len & 0x3));
+		len += 4 - (len & 0x3);
+	}
+
+	if (elm < PDU_MAXIOV)
+		if (!p->iov[elm].iov_base) {
+			p->iov[elm].iov_base = buf;
+			p->iov[elm].iov_len = len;
+			return 0;
+		}
+
+	/* no space left */
+	return -1;
+}
+
+void *
+pdu_getbuf(struct pdu *p, size_t *len, unsigned int elm)
+{
+	if (len)
+		*len = 0;
+	if (elm < PDU_MAXIOV)
+		if (p->iov[elm].iov_base) {
+			if (len)
+				*len = p->iov[elm].iov_len;
+			return p->iov[elm].iov_base;
+		}
+
+	return NULL;
+}
+
+void
+pdu_free(struct pdu *p)
+{
+	unsigned int j;
+
+	for (j = 0; j < PDU_MAXIOV; j++)
+		free(p->iov[j].iov_base);
+	free(p);
+}
+
+int
+socket_setblockmode(int fd, int nonblocking)
+{
+	int     flags;
+
+	if ((flags = fcntl(fd, F_GETFL, 0)) == -1)
+		return -1;
+
+	if (nonblocking)
+		flags |= O_NONBLOCK;
+	else
+		flags &= ~O_NONBLOCK;     
+
+	if ((flags = fcntl(fd, F_SETFL, flags)) == -1)
+		return -1;
+	return 0;
+}
+
+const char *
+log_sockaddr(void *arg)
+{
+	struct sockaddr *sa = arg;
+	char port[6];
+	char host[NI_MAXHOST];
+	static char buf[NI_MAXHOST + 8];
+
+	if (getnameinfo(sa, sa->sa_len, host, sizeof(host), port, sizeof(port),
+	    NI_NUMERICHOST))
+		return "unknown";
+	if (port[0] == '0')
+		strlcpy(buf, host, sizeof(buf));
+	else if (sa->sa_family == AF_INET)
+		snprintf(buf, sizeof(buf), "%s:%s", host, port);
+	else
+		snprintf(buf, sizeof(buf), "[%s]:%s", host, port);
+	return buf;
+}