mirror of
https://git.FreeBSD.org/src.git
synced 2025-01-04 12:52:15 +00:00
Implement server-side transaction TCP. (Has no effect on non-TTCP clients.)
This commit is contained in:
parent
802c953a44
commit
dd07a8677b
Notes:
svn2git
2020-12-20 02:59:44 +00:00
svn path=/head/; revision=12908
@ -38,12 +38,17 @@ static char copyright[] =
|
||||
#endif /* not lint */
|
||||
|
||||
#ifndef lint
|
||||
/*
|
||||
static char sccsid[] = "@(#)fingerd.c 8.1 (Berkeley) 6/4/93";
|
||||
*/
|
||||
static const char rcsid[] =
|
||||
"$Id$";
|
||||
#endif /* not lint */
|
||||
|
||||
#include <sys/types.h>
|
||||
#include <sys/socket.h>
|
||||
#include <netinet/in.h>
|
||||
#include <netinet/tcp.h>
|
||||
#include <arpa/inet.h>
|
||||
#include <errno.h>
|
||||
|
||||
@ -55,7 +60,7 @@ static char sccsid[] = "@(#)fingerd.c 8.1 (Berkeley) 6/4/93";
|
||||
#include <strings.h>
|
||||
#include "pathnames.h"
|
||||
|
||||
void err __P((const char *, ...));
|
||||
void logerr __P((const char *, ...));
|
||||
|
||||
int
|
||||
main(argc, argv)
|
||||
@ -88,13 +93,13 @@ main(argc, argv)
|
||||
break;
|
||||
case '?':
|
||||
default:
|
||||
err("illegal option -- %c", ch);
|
||||
logerr("illegal option -- %c", ch);
|
||||
}
|
||||
|
||||
if (logging) {
|
||||
sval = sizeof(sin);
|
||||
if (getpeername(0, (struct sockaddr *)&sin, &sval) < 0)
|
||||
err("getpeername: %s", strerror(errno));
|
||||
logerr("getpeername: %s", strerror(errno));
|
||||
if (hp = gethostbyaddr((char *)&sin.sin_addr.s_addr,
|
||||
sizeof(sin.sin_addr.s_addr), AF_INET))
|
||||
lp = hp->h_name;
|
||||
@ -103,6 +108,17 @@ main(argc, argv)
|
||||
syslog(LOG_NOTICE, "query from %s", lp);
|
||||
}
|
||||
|
||||
/*
|
||||
* Enable server-side Transaction TCP.
|
||||
*/
|
||||
{
|
||||
int one = 1;
|
||||
if (setsockopt(STDOUT_FILENO, IPPROTO_TCP, TCP_NOPUSH, &one,
|
||||
sizeof one) < 0) {
|
||||
logerr("setsockopt(TCP_NOPUSH) failed: %m");
|
||||
}
|
||||
}
|
||||
|
||||
if (!fgets(line, sizeof(line), stdin))
|
||||
exit(1);
|
||||
|
||||
@ -137,7 +153,7 @@ main(argc, argv)
|
||||
else
|
||||
*comp = prog;
|
||||
if (pipe(p) < 0)
|
||||
err("pipe: %s", strerror(errno));
|
||||
logerr("pipe: %s", strerror(errno));
|
||||
|
||||
switch(vfork()) {
|
||||
case 0:
|
||||
@ -147,14 +163,14 @@ main(argc, argv)
|
||||
(void)close(p[1]);
|
||||
}
|
||||
execv(prog, comp);
|
||||
err("execv: %s: %s", prog, strerror(errno));
|
||||
logerr("execv: %s: %s", prog, strerror(errno));
|
||||
_exit(1);
|
||||
case -1:
|
||||
err("fork: %s", strerror(errno));
|
||||
logerr("fork: %s", strerror(errno));
|
||||
}
|
||||
(void)close(p[1]);
|
||||
if (!(fp = fdopen(p[0], "r")))
|
||||
err("fdopen: %s", strerror(errno));
|
||||
logerr("fdopen: %s", strerror(errno));
|
||||
while ((ch = getc(fp)) != EOF) {
|
||||
if (ch == '\n')
|
||||
putchar('\r');
|
||||
@ -171,9 +187,9 @@ main(argc, argv)
|
||||
|
||||
void
|
||||
#if __STDC__
|
||||
err(const char *fmt, ...)
|
||||
logerr(const char *fmt, ...)
|
||||
#else
|
||||
err(fmt, va_alist)
|
||||
logerr(fmt, va_alist)
|
||||
char *fmt;
|
||||
va_dcl
|
||||
#endif
|
||||
|
Loading…
Reference in New Issue
Block a user