From: wessels <>
Date: Sat, 4 May 1996 05:22:22 +0000 (+0000)
Subject: adding
X-Git-Tag: SQUID_3_0_PRE1~6095
X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=f1443bd9f290fb7c7bd4328d78b98bde1c3c4219;p=thirdparty%2Fsquid.git

adding
---

diff --git a/src/ident.cc b/src/ident.cc
new file mode 100644
index 0000000000..5435dd01dc
--- /dev/null
+++ b/src/ident.cc
@@ -0,0 +1,115 @@
+/* $Id: ident.cc,v 1.1 1996/05/03 23:22:22 wessels Exp $ */
+
+/*
+ * DEBUG: Section 30           ident/RFC931
+ */
+
+#include "squid.h"
+
+#define IDENT_PORT 113
+
+static void identRequestComplete _PARAMS((int, char *, int, int, icpStateData *));
+static void identReadReply _PARAMS((int, icpStateData *));
+static void identClose _PARAMS((int, icpStateData *));
+
+static void identClose(fd, icpState)
+     int fd;
+     icpStateData *icpState;
+{
+    debug(30, 1, "identClose: FD %d\n", fd);
+    icpState->ident_fd = -1;
+}
+
+/* start a TCP connection to the peer host on port 113 */
+void identStart(sock, icpState)
+     icpStateData *icpState;
+{
+    char *host;
+    u_short port;
+    static char reqbuf[BUFSIZ];
+    int status;
+
+    host = inet_ntoa(icpState->peer.sin_addr);
+    port = ntohs(icpState->peer.sin_port);
+
+    debug(30, 1, "identStart: peer is %s:%d\n", host, port);
+
+    if (sock < 0) {
+	if ((sock = comm_open(COMM_NONBLOCKING, 0, 0, "ident")) == COMM_ERROR) {
+	    debug(30, 4, "identStart: Failed because we're out of sockets.\n");
+	    return;
+	}
+    }
+    icpState->ident_fd = sock;
+    comm_set_select_handler(sock,
+	COMM_SELECT_CLOSE,
+	(PF) identClose,
+	(void *) icpState);
+    if ((status = comm_connect(sock, host, IDENT_PORT)) < 0) {
+	if (status != EINPROGRESS) {
+	    comm_close(sock);
+	    return;		/* die silently */
+	}
+	debug(30, 1, "identStart: FD %d: %s\n", sock, xstrerror());
+	comm_set_select_handler(sock,
+	    COMM_SELECT_WRITE,
+	    (PF) identStart,
+	    (void *) icpState);
+	return;
+    }
+    debug(30, 1, "identStart: FD %d: Connected, preparing request...\n", sock);
+    sprintf(reqbuf, "%d, %d\r\n",
+	ntohs(icpState->peer.sin_port),
+	ntohs(icpState->me.sin_port));
+    /* XXX icpWrite() returns a data structure which we need to free if there is
+     * a timeout */
+    (void) icpWrite(sock,
+	reqbuf,
+	strlen(reqbuf),
+	5,			/* timeout */
+	identRequestComplete,
+	(void *) icpState);
+    comm_set_select_handler(sock,
+	COMM_SELECT_READ,
+	(PF) identReadReply,
+	(void *) icpState);
+}
+
+static void identRequestComplete(fd, buf, size, errflag, state)
+     int fd;
+     char *buf;
+     int size;
+     int errflag;
+     icpStateData *state;
+{
+    debug(30, 1, "identRequestComplete: FD %d: wrote %d bytes\n", fd, size);
+}
+
+static void identReadReply(fd, icpState)
+     int fd;
+     icpStateData *icpState;
+{
+    static char buf[BUFSIZ];
+    char *t = NULL;
+    int len = -1;
+
+    buf[0] = '\0';
+    len = read(fd, buf, BUFSIZ);
+    if (len < 0) {
+	debug(30, 1, "identReadReply: FD %d: %s\n", fd, xstrerror());
+    } else if (len == 0) {
+	debug(30, 1, "identReadReply: FD %d: Read 0 bytes\n", fd);
+    }
+    if ((t = strchr(buf, '\r')))
+	*t = '\0';
+    if ((t = strchr(buf, '\n')))
+	*t = '\0';
+    debug(30, 1, "identReadReply: FD %d: Read '%s'\n", fd, buf);
+    if (strstr(buf, "USERID")) {
+	if ((t = strrchr(buf, ':'))) {
+	    while (isspace(*++t));
+	    strncpy(icpState->ident, t, ICP_IDENT_SZ);
+	}
+    }
+    comm_close(fd);
+}