1 /* 2 * rfc931() speaks a common subset of the RFC 931, AUTH, TAP, IDENT and RFC 3 * 1413 protocols. It queries an RFC 931 etc. compatible daemon on a remote 4 * host to look up the owner of a connection. The information should not be 5 * used for authentication purposes. This routine intercepts alarm signals. 6 * 7 * Diagnostics are reported through syslog(3). 8 * 9 * Author: Wietse Venema, Eindhoven University of Technology, The Netherlands. 10 * 11 * $FreeBSD: src/contrib/tcp_wrappers/rfc931.c,v 1.2.2.1 2000/07/18 16:41:11 dwmalone Exp $ 12 * $DragonFly: src/contrib/tcp_wrappers/rfc931.c,v 1.2 2003/06/17 04:24:06 dillon Exp $ 13 */ 14 15 #ifndef lint 16 static char sccsid[] = "@(#) rfc931.c 1.10 95/01/02 16:11:34"; 17 #endif 18 19 /* System libraries. */ 20 21 #include <stdio.h> 22 #include <syslog.h> 23 #include <sys/types.h> 24 #include <sys/socket.h> 25 #include <netinet/in.h> 26 #include <setjmp.h> 27 #include <signal.h> 28 #include <string.h> 29 30 #ifndef SEEK_SET 31 #define SEEK_SET 0 32 #endif 33 34 /* Local stuff. */ 35 36 #include "tcpd.h" 37 38 #define RFC931_PORT 113 /* Semi-well-known port */ 39 #define ANY_PORT 0 /* Any old port will do */ 40 41 int rfc931_timeout = RFC931_TIMEOUT;/* Global so it can be changed */ 42 43 static jmp_buf timebuf; 44 45 /* fsocket - open stdio stream on top of socket */ 46 47 static FILE *fsocket(domain, type, protocol) 48 int domain; 49 int type; 50 int protocol; 51 { 52 int s; 53 FILE *fp; 54 55 if ((s = socket(domain, type, protocol)) < 0) { 56 tcpd_warn("socket: %m"); 57 return (0); 58 } else { 59 if ((fp = fdopen(s, "r+")) == 0) { 60 tcpd_warn("fdopen: %m"); 61 close(s); 62 } 63 return (fp); 64 } 65 } 66 67 /* timeout - handle timeouts */ 68 69 static void timeout(sig) 70 int sig; 71 { 72 longjmp(timebuf, sig); 73 } 74 75 /* rfc931 - return remote user name, given socket structures */ 76 77 void rfc931(rmt_sin, our_sin, dest) 78 #ifdef INET6 79 struct sockaddr *rmt_sin; 80 struct sockaddr *our_sin; 81 #else 82 struct sockaddr_in *rmt_sin; 83 struct sockaddr_in *our_sin; 84 #endif 85 char *dest; 86 { 87 unsigned rmt_port; 88 unsigned our_port; 89 #ifdef INET6 90 struct sockaddr_storage rmt_query_sin; 91 struct sockaddr_storage our_query_sin; 92 int alen; 93 #else 94 struct sockaddr_in rmt_query_sin; 95 struct sockaddr_in our_query_sin; 96 #endif 97 char user[256]; /* XXX */ 98 char buffer[512]; /* XXX */ 99 char *cp; 100 char *result = unknown; 101 FILE *fp; 102 103 #ifdef INET6 104 /* address family must be the same */ 105 if (rmt_sin->sa_family != our_sin->sa_family) { 106 STRN_CPY(dest, result, STRING_LENGTH); 107 return; 108 } 109 switch (our_sin->sa_family) { 110 case AF_INET: 111 alen = sizeof(struct sockaddr_in); 112 break; 113 case AF_INET6: 114 alen = sizeof(struct sockaddr_in6); 115 break; 116 default: 117 STRN_CPY(dest, result, STRING_LENGTH); 118 return; 119 } 120 #endif 121 122 /* 123 * If we use a single, buffered, bidirectional stdio stream ("r+" or 124 * "w+" mode) we may read our own output. Such behaviour would make sense 125 * with resources that support random-access operations, but not with 126 * sockets. ANSI C suggests several functions which can be called when 127 * you want to change IO direction, fseek seems the most portable. 128 */ 129 130 #ifdef INET6 131 if ((fp = fsocket(our_sin->sa_family, SOCK_STREAM, 0)) != 0) { 132 #else 133 if ((fp = fsocket(AF_INET, SOCK_STREAM, 0)) != 0) { 134 #endif 135 /* 136 * Set up a timer so we won't get stuck while waiting for the server. 137 */ 138 139 if (setjmp(timebuf) == 0) { 140 signal(SIGALRM, timeout); 141 alarm(rfc931_timeout); 142 143 /* 144 * Bind the local and remote ends of the query socket to the same 145 * IP addresses as the connection under investigation. We go 146 * through all this trouble because the local or remote system 147 * might have more than one network address. The RFC931 etc. 148 * client sends only port numbers; the server takes the IP 149 * addresses from the query socket. 150 */ 151 152 #ifdef INET6 153 memcpy(&our_query_sin, our_sin, alen); 154 memcpy(&rmt_query_sin, rmt_sin, alen); 155 switch (our_sin->sa_family) { 156 case AF_INET: 157 ((struct sockaddr_in *)&our_query_sin)->sin_port = htons(ANY_PORT); 158 ((struct sockaddr_in *)&rmt_query_sin)->sin_port = htons(RFC931_PORT); 159 break; 160 case AF_INET6: 161 ((struct sockaddr_in6 *)&our_query_sin)->sin6_port = htons(ANY_PORT); 162 ((struct sockaddr_in6 *)&rmt_query_sin)->sin6_port = htons(RFC931_PORT); 163 break; 164 } 165 166 if (bind(fileno(fp), (struct sockaddr *) & our_query_sin, 167 alen) >= 0 && 168 connect(fileno(fp), (struct sockaddr *) & rmt_query_sin, 169 alen) >= 0) { 170 #else 171 our_query_sin = *our_sin; 172 our_query_sin.sin_port = htons(ANY_PORT); 173 rmt_query_sin = *rmt_sin; 174 rmt_query_sin.sin_port = htons(RFC931_PORT); 175 176 if (bind(fileno(fp), (struct sockaddr *) & our_query_sin, 177 sizeof(our_query_sin)) >= 0 && 178 connect(fileno(fp), (struct sockaddr *) & rmt_query_sin, 179 sizeof(rmt_query_sin)) >= 0) { 180 #endif 181 182 /* 183 * Send query to server. Neglect the risk that a 13-byte 184 * write would have to be fragmented by the local system and 185 * cause trouble with buggy System V stdio libraries. 186 */ 187 188 fprintf(fp, "%u,%u\r\n", 189 #ifdef INET6 190 ntohs(((struct sockaddr_in *)rmt_sin)->sin_port), 191 ntohs(((struct sockaddr_in *)our_sin)->sin_port)); 192 #else 193 ntohs(rmt_sin->sin_port), 194 ntohs(our_sin->sin_port)); 195 #endif 196 fflush(fp); 197 fseek(fp, 0, SEEK_SET); 198 199 /* 200 * Read response from server. Use fgets()/sscanf() so we can 201 * work around System V stdio libraries that incorrectly 202 * assume EOF when a read from a socket returns less than 203 * requested. 204 */ 205 206 if (fgets(buffer, sizeof(buffer), fp) != 0 207 && ferror(fp) == 0 && feof(fp) == 0 208 && sscanf(buffer, "%u , %u : USERID :%*[^:]:%255s", 209 &rmt_port, &our_port, user) == 3 210 #ifdef INET6 211 && ntohs(((struct sockaddr_in *)rmt_sin)->sin_port) == rmt_port 212 && ntohs(((struct sockaddr_in *)our_sin)->sin_port) == our_port) { 213 #else 214 && ntohs(rmt_sin->sin_port) == rmt_port 215 && ntohs(our_sin->sin_port) == our_port) { 216 #endif 217 218 /* 219 * Strip trailing carriage return. It is part of the 220 * protocol, not part of the data. 221 */ 222 223 if (cp = strchr(user, '\r')) 224 *cp = 0; 225 result = user; 226 } 227 } 228 alarm(0); 229 } 230 fclose(fp); 231 } 232 STRN_CPY(dest, result, STRING_LENGTH); 233 } 234