blob: 540387f1a985a4ad3b4fd5656174ac54b2c986c4 [file] [log] [blame]
Bernhard Reutner-Fischer2c998512006-04-12 18:09:26 +00001/* vi: set sw=4 ts=4: */
Bernhard Reutner-Fischerdac7ff12006-04-12 17:55:51 +00002/*
Eric Andersen08a72202002-09-30 20:52:10 +00003 * Simple telnet server
4 * Bjorn Wesen, Axis Communications AB (bjornw@axis.com)
5 *
Rob Landley1ec5b292006-05-29 07:42:02 +00006 * Licensed under GPLv2 or later, see file LICENSE in this tarball for details.
Eric Andersen08a72202002-09-30 20:52:10 +00007 *
8 * ---------------------------------------------------------------------------
9 * (C) Copyright 2000, Axis Communications AB, LUND, SWEDEN
10 ****************************************************************************
11 *
12 * The telnetd manpage says it all:
13 *
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +020014 * Telnetd operates by allocating a pseudo-terminal device (see pty(4)) for
15 * a client, then creating a login process which has the slave side of the
16 * pseudo-terminal as stdin, stdout, and stderr. Telnetd manipulates the
17 * master side of the pseudo-terminal, implementing the telnet protocol and
18 * passing characters between the remote client and the login process.
Eric Andersen08a72202002-09-30 20:52:10 +000019 *
20 * Vladimir Oleynik <dzo@simtreas.ru> 2001
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +020021 * Set process group corrections, initial busybox port
Eric Andersen08a72202002-09-30 20:52:10 +000022 */
23
Denis Vlasenko75f8d082006-11-22 15:54:52 +000024#define DEBUG 0
Eric Andersen08a72202002-09-30 20:52:10 +000025
Denis Vlasenkob6adbf12007-05-26 19:00:18 +000026#include "libbb.h"
Bernhard Reutner-Fischerf4701962008-01-27 12:50:12 +000027#include <syslog.h>
Rob Landley099ed502006-08-28 09:41:49 +000028
Denis Vlasenko75f8d082006-11-22 15:54:52 +000029#if DEBUG
Eric Andersen08a72202002-09-30 20:52:10 +000030#define TELCMDS
31#define TELOPTS
32#endif
33#include <arpa/telnet.h>
Eric Andersen08a72202002-09-30 20:52:10 +000034
Eric Andersen08a72202002-09-30 20:52:10 +000035struct tsession {
36 struct tsession *next;
Denis Vlasenkod814c982009-02-02 23:43:57 +000037 pid_t shell_pid;
Denys Vlasenko1d77db82009-06-10 13:38:08 +020038 int sockfd_read;
39 int sockfd_write;
40 int ptyfd;
Denis Vlasenko59d7c432007-10-15 15:19:36 +000041
Eric Andersen08a72202002-09-30 20:52:10 +000042 /* two circular buffers */
Denis Vlasenko59d7c432007-10-15 15:19:36 +000043 /*char *buf1, *buf2;*/
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +020044/*#define TS_BUF1(ts) ts->buf1*/
45/*#define TS_BUF2(ts) TS_BUF2(ts)*/
46#define TS_BUF1(ts) ((unsigned char*)(ts + 1))
47#define TS_BUF2(ts) (((unsigned char*)(ts + 1)) + BUFSIZE)
Eric Andersen08a72202002-09-30 20:52:10 +000048 int rdidx1, wridx1, size1;
49 int rdidx2, wridx2, size2;
50};
51
Denis Vlasenko88308fe2007-06-25 10:35:11 +000052/* Two buffers are directly after tsession in malloced memory.
53 * Make whole thing fit in 4k */
Denis Vlasenko59d7c432007-10-15 15:19:36 +000054enum { BUFSIZE = (4 * 1024 - sizeof(struct tsession)) / 2 };
Denis Vlasenko88308fe2007-06-25 10:35:11 +000055
Eric Andersen08a72202002-09-30 20:52:10 +000056
Denis Vlasenko59d7c432007-10-15 15:19:36 +000057/* Globals */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +020058struct globals {
59 struct tsession *sessions;
60 const char *loginpath;
61 const char *issuefile;
62 int maxfd;
63};
64#define G (*(struct globals*)&bb_common_bufsiz1)
65#define INIT_G() do { \
66 G.loginpath = "/bin/login"; \
67 G.issuefile = "/etc/issue.net"; \
68} while (0)
Eric Andersen08a72202002-09-30 20:52:10 +000069
70
71/*
Denis Vlasenko59d7c432007-10-15 15:19:36 +000072 Remove all IAC's from buf1 (received IACs are ignored and must be removed
73 so as to not be interpreted by the terminal). Make an uninterrupted
74 string of characters fit for the terminal. Do this by packing
75 all characters meant for the terminal sequentially towards the end of buf.
Eric Andersen08a72202002-09-30 20:52:10 +000076
77 Return a pointer to the beginning of the characters meant for the terminal.
78 and make *num_totty the number of characters that should be sent to
79 the terminal.
80
81 Note - If an IAC (3 byte quantity) starts before (bf + len) but extends
Denis Vlasenko59d7c432007-10-15 15:19:36 +000082 past (bf + len) then that IAC will be left unprocessed and *processed
83 will be less than len.
Eric Andersen08a72202002-09-30 20:52:10 +000084
Denis Vlasenko10916c52007-10-15 17:28:00 +000085 CR-LF ->'s CR mapping is also done here, for convenience.
86
87 NB: may fail to remove iacs which wrap around buffer!
Denis Vlasenko75f8d082006-11-22 15:54:52 +000088 */
Denis Vlasenko10916c52007-10-15 17:28:00 +000089static unsigned char *
Denis Vlasenko75f8d082006-11-22 15:54:52 +000090remove_iacs(struct tsession *ts, int *pnum_totty)
91{
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +020092 unsigned char *ptr0 = TS_BUF1(ts) + ts->wridx1;
Eric Andersen08a72202002-09-30 20:52:10 +000093 unsigned char *ptr = ptr0;
94 unsigned char *totty = ptr;
95 unsigned char *end = ptr + MIN(BUFSIZE - ts->wridx1, ts->size1);
Eric Andersen08a72202002-09-30 20:52:10 +000096 int num_totty;
97
98 while (ptr < end) {
99 if (*ptr != IAC) {
Denis Vlasenko10916c52007-10-15 17:28:00 +0000100 char c = *ptr;
101
102 *totty++ = c;
103 ptr++;
Denis Vlasenkob0150d22008-11-07 01:58:21 +0000104 /* We map \r\n ==> \r for pragmatic reasons.
Eric Andersen3752d332003-12-19 11:30:13 +0000105 * Many client implementations send \r\n when
106 * the user hits the CarriageReturn key.
107 */
Denis Vlasenko10916c52007-10-15 17:28:00 +0000108 if (c == '\r' && ptr < end && (*ptr == '\n' || *ptr == '\0'))
Eric Andersen3752d332003-12-19 11:30:13 +0000109 ptr++;
Denis Vlasenkob0150d22008-11-07 01:58:21 +0000110 continue;
Eric Andersen08a72202002-09-30 20:52:10 +0000111 }
Denis Vlasenkob0150d22008-11-07 01:58:21 +0000112
113 if ((ptr+1) >= end)
114 break;
115 if (ptr[1] == NOP) { /* Ignore? (putty keepalive, etc.) */
116 ptr += 2;
117 continue;
118 }
119 if (ptr[1] == IAC) { /* Literal IAC? (emacs M-DEL) */
120 *totty++ = ptr[1];
121 ptr += 2;
122 continue;
123 }
124
125 /*
126 * TELOPT_NAWS support!
127 */
128 if ((ptr+2) >= end) {
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200129 /* Only the beginning of the IAC is in the
Denis Vlasenkob0150d22008-11-07 01:58:21 +0000130 buffer we were asked to process, we can't
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200131 process this char */
Denis Vlasenkob0150d22008-11-07 01:58:21 +0000132 break;
133 }
134 /*
135 * IAC -> SB -> TELOPT_NAWS -> 4-byte -> IAC -> SE
136 */
137 if (ptr[1] == SB && ptr[2] == TELOPT_NAWS) {
138 struct winsize ws;
139 if ((ptr+8) >= end)
140 break; /* incomplete, can't process */
141 ws.ws_col = (ptr[3] << 8) | ptr[4];
142 ws.ws_row = (ptr[5] << 8) | ptr[6];
143 ioctl(ts->ptyfd, TIOCSWINSZ, (char *)&ws);
144 ptr += 9;
145 continue;
146 }
147 /* skip 3-byte IAC non-SB cmd */
148#if DEBUG
149 fprintf(stderr, "Ignoring IAC %s,%s\n",
150 TELCMD(ptr[1]), TELOPT(ptr[2]));
151#endif
152 ptr += 3;
Eric Andersen08a72202002-09-30 20:52:10 +0000153 }
154
Denis Vlasenko0de37e12007-10-17 11:08:53 +0000155 num_totty = totty - ptr0;
Eric Andersen08a72202002-09-30 20:52:10 +0000156 *pnum_totty = num_totty;
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200157 /* The difference between ptr and totty is number of iacs
158 we removed from the stream. Adjust buf1 accordingly */
Denis Vlasenko10916c52007-10-15 17:28:00 +0000159 if ((ptr - totty) == 0) /* 99.999% of cases */
160 return ptr0;
161 ts->wridx1 += ptr - totty;
162 ts->size1 -= ptr - totty;
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200163 /* Move chars meant for the terminal towards the end of the buffer */
Eric Andersen08a72202002-09-30 20:52:10 +0000164 return memmove(ptr - num_totty, ptr0, num_totty);
165}
166
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000167/*
Denis Vlasenko81c6a912008-11-12 21:14:50 +0000168 * Converting single IAC into double on output
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000169 */
170static size_t iac_safe_write(int fd, const char *buf, size_t count)
171{
Denis Vlasenko81c6a912008-11-12 21:14:50 +0000172 const char *IACptr;
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000173 size_t wr, rc, total;
174
175 total = 0;
176 while (1) {
177 if (count == 0)
178 return total;
Denis Vlasenko81c6a912008-11-12 21:14:50 +0000179 if (*buf == (char)IAC) {
180 static const char IACIAC[] ALIGN1 = { IAC, IAC };
181 rc = safe_write(fd, IACIAC, 2);
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000182 if (rc != 2)
183 break;
184 buf++;
185 total++;
186 count--;
187 continue;
188 }
Denis Vlasenko81c6a912008-11-12 21:14:50 +0000189 /* count != 0, *buf != IAC */
190 IACptr = memchr(buf, IAC, count);
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000191 wr = count;
Denis Vlasenko81c6a912008-11-12 21:14:50 +0000192 if (IACptr)
193 wr = IACptr - buf;
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000194 rc = safe_write(fd, buf, wr);
195 if (rc != wr)
196 break;
197 buf += rc;
198 total += rc;
199 count -= rc;
200 }
201 /* here: rc - result of last short write */
202 if ((ssize_t)rc < 0) { /* error? */
203 if (total == 0)
204 return rc;
205 rc = 0;
206 }
207 return total + rc;
208}
Eric Andersen08a72202002-09-30 20:52:10 +0000209
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200210/* Must match getopt32 string */
211enum {
212 OPT_WATCHCHILD = (1 << 2), /* -K */
213 OPT_INETD = (1 << 3) * ENABLE_FEATURE_TELNETD_STANDALONE, /* -i */
214 OPT_PORT = (1 << 4) * ENABLE_FEATURE_TELNETD_STANDALONE, /* -p */
215 OPT_FOREGROUND = (1 << 6) * ENABLE_FEATURE_TELNETD_STANDALONE, /* -F */
216};
217
Eric Andersen08a72202002-09-30 20:52:10 +0000218static struct tsession *
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000219make_new_session(
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200220 IF_FEATURE_TELNETD_STANDALONE(int sock)
Denis Vlasenko5e34ff22009-04-21 11:09:40 +0000221 IF_NOT_FEATURE_TELNETD_STANDALONE(void)
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000222) {
Denis Vlasenko88308fe2007-06-25 10:35:11 +0000223 const char *login_argv[2];
Eric Andersen08a72202002-09-30 20:52:10 +0000224 struct termios termbuf;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000225 int fd, pid;
Denis Vlasenko85c24712008-03-17 09:04:04 +0000226 char tty_name[GETPTY_BUFSIZE];
Rob Landley1ec5b292006-05-29 07:42:02 +0000227 struct tsession *ts = xzalloc(sizeof(struct tsession) + BUFSIZE * 2);
Eric Andersen08a72202002-09-30 20:52:10 +0000228
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000229 /*ts->buf1 = (char *)(ts + 1);*/
230 /*ts->buf2 = ts->buf1 + BUFSIZE;*/
Eric Andersen08a72202002-09-30 20:52:10 +0000231
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200232 /* Got a new connection, set up a tty */
Bernhard Reutner-Fischerae4342c2008-05-19 08:18:50 +0000233 fd = xgetpty(tty_name);
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200234 if (fd > G.maxfd)
235 G.maxfd = fd;
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000236 ts->ptyfd = fd;
237 ndelay_on(fd);
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200238 close_on_exec_on(fd);
239
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000240#if ENABLE_FEATURE_TELNETD_STANDALONE
Denis Vlasenko6d044352008-11-09 00:44:40 +0000241 /* SO_KEEPALIVE by popular demand */
242 setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, &const_int_1, sizeof(const_int_1));
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200243 ts->sockfd_read = sock;
Denis Vlasenkof472b232007-10-16 21:35:17 +0000244 ndelay_on(sock);
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200245 if (sock == 0) { /* We are called with fd 0 - we are in inetd mode */
Denis Vlasenko9e237672007-10-17 11:18:49 +0000246 sock++; /* so use fd 1 for output */
247 ndelay_on(sock);
248 }
Denis Vlasenkof472b232007-10-16 21:35:17 +0000249 ts->sockfd_write = sock;
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200250 if (sock > G.maxfd)
251 G.maxfd = sock;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000252#else
Denis Vlasenko6d044352008-11-09 00:44:40 +0000253 /* SO_KEEPALIVE by popular demand */
254 setsockopt(0, SOL_SOCKET, SO_KEEPALIVE, &const_int_1, sizeof(const_int_1));
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000255 /* ts->sockfd_read = 0; - done by xzalloc */
Denis Vlasenkof472b232007-10-16 21:35:17 +0000256 ts->sockfd_write = 1;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000257 ndelay_on(0);
258 ndelay_on(1);
259#endif
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200260
Eric Andersen08a72202002-09-30 20:52:10 +0000261 /* Make the telnet client understand we will echo characters so it
262 * should not do it locally. We don't tell the client to run linemode,
263 * because we want to handle line editing and tab completion and other
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000264 * stuff that requires char-by-char support. */
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000265 {
266 static const char iacs_to_send[] ALIGN1 = {
267 IAC, DO, TELOPT_ECHO,
268 IAC, DO, TELOPT_NAWS,
Denis Vlasenkod814c982009-02-02 23:43:57 +0000269 /* This requires telnetd.ctrlSQ.patch (incomplete) */
270 /* IAC, DO, TELOPT_LFLOW, */
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000271 IAC, WILL, TELOPT_ECHO,
272 IAC, WILL, TELOPT_SGA
273 };
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000274 /* This confuses iac_safe_write(), it will try to duplicate
275 * each IAC... */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200276 //memcpy(TS_BUF2(ts), iacs_to_send, sizeof(iacs_to_send));
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000277 //ts->rdidx2 = sizeof(iacs_to_send);
278 //ts->size2 = sizeof(iacs_to_send);
Denis Vlasenko81c6a912008-11-12 21:14:50 +0000279 /* So just stuff it into TCP stream! (no error check...) */
280#if ENABLE_FEATURE_TELNETD_STANDALONE
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000281 safe_write(sock, iacs_to_send, sizeof(iacs_to_send));
Denis Vlasenko81c6a912008-11-12 21:14:50 +0000282#else
283 safe_write(1, iacs_to_send, sizeof(iacs_to_send));
284#endif
285 /*ts->rdidx2 = 0; - xzalloc did it */
Denis Vlasenko9f2f8082008-11-11 02:56:39 +0000286 /*ts->size2 = 0;*/
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000287 }
Eric Andersen08a72202002-09-30 20:52:10 +0000288
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000289 fflush(NULL); /* flush all streams */
290 pid = vfork(); /* NOMMU-friendly */
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000291 if (pid < 0) {
292 free(ts);
293 close(fd);
Denis Vlasenko23c81282007-10-16 22:01:23 +0000294 /* sock will be closed by caller */
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000295 bb_perror_msg("vfork");
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000296 return NULL;
Eric Andersen08a72202002-09-30 20:52:10 +0000297 }
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000298 if (pid > 0) {
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000299 /* Parent */
Denis Vlasenko2450c452007-10-15 22:09:15 +0000300 ts->shell_pid = pid;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000301 return ts;
Eric Andersen08a72202002-09-30 20:52:10 +0000302 }
Denis Vlasenkof7996f32007-01-11 17:20:00 +0000303
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000304 /* Child */
305 /* Careful - we are after vfork! */
Eric Andersen08a72202002-09-30 20:52:10 +0000306
Denis Vlasenkod814c982009-02-02 23:43:57 +0000307 /* Restore default signal handling ASAP */
Denis Vlasenko25591c32008-02-16 22:58:56 +0000308 bb_signals((1 << SIGCHLD) + (1 << SIGPIPE), SIG_DFL);
Denis Vlasenko018b1552007-11-06 01:38:46 +0000309
Denis Vlasenkod814c982009-02-02 23:43:57 +0000310 /* Make new session and process group */
311 setsid();
312
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200313 /* Open the child's side of the tty */
Denis Vlasenko9af7c9d2007-01-19 21:19:35 +0000314 /* NB: setsid() disconnects from any previous ctty's. Therefore
315 * we must open child's side of the tty AFTER setsid! */
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200316 close(0);
Denis Vlasenko1101d1c2008-07-21 09:22:28 +0000317 xopen(tty_name, O_RDWR); /* becomes our ctty */
318 xdup2(0, 1);
319 xdup2(0, 2);
Denis Vlasenko88308fe2007-06-25 10:35:11 +0000320 tcsetpgrp(0, getpid()); /* switch this tty's process group to us */
Eric Andersen08a72202002-09-30 20:52:10 +0000321
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200322 /* The pseudo-terminal allocated to the client is configured to operate
323 * in cooked mode, and with XTABS CRMOD enabled (see tty(4)) */
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000324 tcgetattr(0, &termbuf);
325 termbuf.c_lflag |= ECHO; /* if we use readline we dont want this */
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000326 termbuf.c_oflag |= ONLCR | XTABS;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000327 termbuf.c_iflag |= ICRNL;
328 termbuf.c_iflag &= ~IXOFF;
329 /*termbuf.c_lflag &= ~ICANON;*/
Denis Vlasenko202ac502008-11-05 13:20:58 +0000330 tcsetattr_stdin_TCSANOW(&termbuf);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000331
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000332 /* Uses FILE-based I/O to stdout, but does fflush(stdout),
333 * so should be safe with vfork.
334 * I fear, though, that some users will have ridiculously big
Denis Vlasenko018b1552007-11-06 01:38:46 +0000335 * issue files, and they may block writing to fd 1,
336 * (parent is supposed to read it, but parent waits
337 * for vforked child to exec!) */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200338 print_login_issue(G.issuefile, tty_name);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000339
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000340 /* Exec shell / login / whatever */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200341 login_argv[0] = G.loginpath;
Denis Vlasenko88308fe2007-06-25 10:35:11 +0000342 login_argv[1] = NULL;
Denis Vlasenko018b1552007-11-06 01:38:46 +0000343 /* exec busybox applet (if PREFER_APPLETS=y), if that fails,
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200344 * exec external program.
345 * NB: sock is either 0 or has CLOEXEC set on it.
346 * fd has CLOEXEC set on it too. These two fds will be closed here.
347 */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200348 BB_EXECVP(G.loginpath, (char **)login_argv);
Denis Vlasenko018b1552007-11-06 01:38:46 +0000349 /* _exit is safer with vfork, and we shouldn't send message
Denis Vlasenko2450c452007-10-15 22:09:15 +0000350 * to remote clients anyway */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200351 _exit(EXIT_FAILURE); /*bb_perror_msg_and_die("execv %s", G.loginpath);*/
Eric Andersen08a72202002-09-30 20:52:10 +0000352}
353
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000354#if ENABLE_FEATURE_TELNETD_STANDALONE
355
Eric Andersen08a72202002-09-30 20:52:10 +0000356static void
357free_session(struct tsession *ts)
358{
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200359 struct tsession *t = G.sessions;
Eric Andersen08a72202002-09-30 20:52:10 +0000360
Denis Vlasenkoe87b8682007-10-17 14:33:31 +0000361 if (option_mask32 & OPT_INETD)
Bernhard Reutner-Fischer636a1f82008-05-19 09:29:47 +0000362 exit(EXIT_SUCCESS);
Denis Vlasenkoe87b8682007-10-17 14:33:31 +0000363
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000364 /* Unlink this telnet session from the session list */
Mike Frysinger731f81c2006-05-10 15:23:12 +0000365 if (t == ts)
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200366 G.sessions = ts->next;
Eric Andersen08a72202002-09-30 20:52:10 +0000367 else {
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000368 while (t->next != ts)
Eric Andersen08a72202002-09-30 20:52:10 +0000369 t = t->next;
370 t->next = ts->next;
371 }
372
Denis Vlasenkof472b232007-10-16 21:35:17 +0000373#if 0
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000374 /* It was said that "normal" telnetd just closes ptyfd,
375 * doesn't send SIGKILL. When we close ptyfd,
376 * kernel sends SIGHUP to processes having slave side opened. */
Denis Vlasenkof472b232007-10-16 21:35:17 +0000377 kill(ts->shell_pid, SIGKILL);
Denis Vlasenkod814c982009-02-02 23:43:57 +0000378 waitpid(ts->shell_pid, NULL, 0);
Denis Vlasenkof472b232007-10-16 21:35:17 +0000379#endif
Eric Andersen08a72202002-09-30 20:52:10 +0000380 close(ts->ptyfd);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000381 close(ts->sockfd_read);
Denis Vlasenkof472b232007-10-16 21:35:17 +0000382 /* We do not need to close(ts->sockfd_write), it's the same
383 * as sockfd_read unless we are in inetd mode. But in inetd mode
Denis Vlasenkoe87b8682007-10-17 14:33:31 +0000384 * we do not reach this */
Eric Andersen08a72202002-09-30 20:52:10 +0000385 free(ts);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000386
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000387 /* Scan all sessions and find new maxfd */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200388 G.maxfd = 0;
389 ts = G.sessions;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000390 while (ts) {
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200391 if (G.maxfd < ts->ptyfd)
392 G.maxfd = ts->ptyfd;
393 if (G.maxfd < ts->sockfd_read)
394 G.maxfd = ts->sockfd_read;
Denis Vlasenkof472b232007-10-16 21:35:17 +0000395#if 0
396 /* Again, sockfd_write == sockfd_read here */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200397 if (G.maxfd < ts->sockfd_write)
398 G.maxfd = ts->sockfd_write;
Denis Vlasenkof472b232007-10-16 21:35:17 +0000399#endif
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000400 ts = ts->next;
401 }
Eric Andersen08a72202002-09-30 20:52:10 +0000402}
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000403
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000404#else /* !FEATURE_TELNETD_STANDALONE */
405
Bernhard Reutner-Fischer636a1f82008-05-19 09:29:47 +0000406/* Used in main() only, thus "return 0" actually is exit(EXIT_SUCCESS). */
Denis Vlasenkoe87b8682007-10-17 14:33:31 +0000407#define free_session(ts) return 0
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000408
409#endif
410
Denis Vlasenkoa60f84e2008-07-05 09:18:54 +0000411static void handle_sigchld(int sig UNUSED_PARAM)
Denis Vlasenko2450c452007-10-15 22:09:15 +0000412{
413 pid_t pid;
414 struct tsession *ts;
415
Denis Vlasenko018b1552007-11-06 01:38:46 +0000416 /* Looping: more than one child may have exited */
417 while (1) {
Denis Vlasenkofb0eba72008-01-02 19:55:04 +0000418 pid = wait_any_nohang(NULL);
Denis Vlasenko018b1552007-11-06 01:38:46 +0000419 if (pid <= 0)
420 break;
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200421 ts = G.sessions;
Denis Vlasenko2450c452007-10-15 22:09:15 +0000422 while (ts) {
423 if (ts->shell_pid == pid) {
424 ts->shell_pid = -1;
Denis Vlasenko018b1552007-11-06 01:38:46 +0000425 break;
Denis Vlasenko2450c452007-10-15 22:09:15 +0000426 }
427 ts = ts->next;
428 }
429 }
430}
431
Denis Vlasenko9b49a5e2007-10-11 10:05:36 +0000432int telnetd_main(int argc, char **argv) MAIN_EXTERNALLY_VISIBLE;
Denis Vlasenkoa60f84e2008-07-05 09:18:54 +0000433int telnetd_main(int argc UNUSED_PARAM, char **argv)
Eric Andersen08a72202002-09-30 20:52:10 +0000434{
Eric Andersen08a72202002-09-30 20:52:10 +0000435 fd_set rdfdset, wrfdset;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000436 unsigned opt;
Denis Vlasenko10916c52007-10-15 17:28:00 +0000437 int count;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000438 struct tsession *ts;
439#if ENABLE_FEATURE_TELNETD_STANDALONE
440#define IS_INETD (opt & OPT_INETD)
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000441 int master_fd = master_fd; /* be happy, gcc */
Denis Vlasenko13858992006-10-08 12:49:22 +0000442 unsigned portnbr = 23;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000443 char *opt_bindaddr = NULL;
444 char *opt_portnbr;
445#else
446 enum {
447 IS_INETD = 1,
448 master_fd = -1,
449 portnbr = 23,
450 };
Glenn L McGrathc2b91862003-09-12 11:27:15 +0000451#endif
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200452 INIT_G();
453
Denis Vlasenko2450c452007-10-15 22:09:15 +0000454 /* Even if !STANDALONE, we accept (and ignore) -i, thus people
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000455 * don't need to guess whether it's ok to pass -i to us */
Denis Vlasenko5e34ff22009-04-21 11:09:40 +0000456 opt = getopt32(argv, "f:l:Ki" IF_FEATURE_TELNETD_STANDALONE("p:b:F"),
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200457 &G.issuefile, &G.loginpath
Denis Vlasenko5e34ff22009-04-21 11:09:40 +0000458 IF_FEATURE_TELNETD_STANDALONE(, &opt_portnbr, &opt_bindaddr));
Denis Vlasenko2450c452007-10-15 22:09:15 +0000459 if (!IS_INETD /*&& !re_execed*/) {
460 /* inform that we start in standalone mode?
461 * May be useful when people forget to give -i */
462 /*bb_error_msg("listening for connections");*/
463 if (!(opt & OPT_FOREGROUND)) {
464 /* DAEMON_CHDIR_ROOT was giving inconsistent
Denis Vlasenko008eda22007-10-16 10:47:27 +0000465 * behavior with/without -F, -i */
Denis Vlasenko018b1552007-11-06 01:38:46 +0000466 bb_daemonize_or_rexec(0 /*was DAEMON_CHDIR_ROOT*/, argv);
Denis Vlasenko2450c452007-10-15 22:09:15 +0000467 }
468 }
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000469 /* Redirect log to syslog early, if needed */
470 if (IS_INETD || !(opt & OPT_FOREGROUND)) {
Denis Vlasenko5e4fda02009-03-08 23:46:48 +0000471 openlog(applet_name, LOG_PID, LOG_DAEMON);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000472 logmode = LOGMODE_SYSLOG;
473 }
Denis Vlasenko5e34ff22009-04-21 11:09:40 +0000474 IF_FEATURE_TELNETD_STANDALONE(
Denis Vlasenko2450c452007-10-15 22:09:15 +0000475 if (opt & OPT_PORT)
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000476 portnbr = xatou16(opt_portnbr);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000477 );
Eric Andersen08a72202002-09-30 20:52:10 +0000478
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200479 /* Used to check access(G.loginpath, X_OK) here. Pointless.
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000480 * exec will do this for us for free later. */
Glenn L McGrath9e5d6c02003-01-21 20:55:56 +0000481
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000482#if ENABLE_FEATURE_TELNETD_STANDALONE
483 if (IS_INETD) {
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200484 G.sessions = make_new_session(0);
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200485 if (!G.sessions) /* pty opening or vfork problem, exit */
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000486 return 1; /* make_new_session prints error message */
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000487 } else {
Denis Vlasenko9de420c2007-01-10 09:28:01 +0000488 master_fd = create_and_bind_stream_or_die(opt_bindaddr, portnbr);
Denis Vlasenkoc8717cd2006-11-22 16:10:39 +0000489 xlisten(master_fd, 1);
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200490 close_on_exec_on(master_fd);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000491 }
Rob Landley00e76cb2005-05-10 23:53:33 +0000492#else
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200493 G.sessions = make_new_session();
494 if (!G.sessions) /* pty opening or vfork problem, exit */
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000495 return 1; /* make_new_session prints error message */
Rob Landley00e76cb2005-05-10 23:53:33 +0000496#endif
Eric Andersen08a72202002-09-30 20:52:10 +0000497
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000498 /* We don't want to die if just one session is broken */
499 signal(SIGPIPE, SIG_IGN);
Eric Andersen08a72202002-09-30 20:52:10 +0000500
Denis Vlasenko2450c452007-10-15 22:09:15 +0000501 if (opt & OPT_WATCHCHILD)
502 signal(SIGCHLD, handle_sigchld);
Denis Vlasenko018b1552007-11-06 01:38:46 +0000503 else /* prevent dead children from becoming zombies */
504 signal(SIGCHLD, SIG_IGN);
Denis Vlasenko2450c452007-10-15 22:09:15 +0000505
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000506/*
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200507 This is how the buffers are used. The arrows indicate data flow.
508
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000509 +-------+ wridx1++ +------+ rdidx1++ +----------+
510 | | <-------------- | buf1 | <-------------- | |
511 | | size1-- +------+ size1++ | |
512 | pty | | socket |
513 | | rdidx2++ +------+ wridx2++ | |
514 | | --------------> | buf2 | --------------> | |
515 +-------+ size2++ +------+ size2-- +----------+
516
517 size1: "how many bytes are buffered for pty between rdidx1 and wridx1?"
518 size2: "how many bytes are buffered for socket between rdidx2 and wridx2?"
519
520 Each session has got two buffers. Buffers are circular. If sizeN == 0,
521 buffer is empty. If sizeN == BUFSIZE, buffer is full. In both these cases
522 rdidxN == wridxN.
523*/
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000524 again:
525 FD_ZERO(&rdfdset);
526 FD_ZERO(&wrfdset);
Eric Andersen08a72202002-09-30 20:52:10 +0000527
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000528 /* Select on the master socket, all telnet sockets and their
529 * ptys if there is room in their session buffers.
530 * NB: scalability problem: we recalculate entire bitmap
531 * before each select. Can be a problem with 500+ connections. */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200532 ts = G.sessions;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000533 while (ts) {
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200534 struct tsession *next = ts->next; /* in case we free ts */
Denis Vlasenko2450c452007-10-15 22:09:15 +0000535 if (ts->shell_pid == -1) {
Denis Vlasenko018b1552007-11-06 01:38:46 +0000536 /* Child died and we detected that */
Denis Vlasenko2450c452007-10-15 22:09:15 +0000537 free_session(ts);
538 } else {
539 if (ts->size1 > 0) /* can write to pty */
540 FD_SET(ts->ptyfd, &wrfdset);
541 if (ts->size1 < BUFSIZE) /* can read from socket */
542 FD_SET(ts->sockfd_read, &rdfdset);
543 if (ts->size2 > 0) /* can write to socket */
544 FD_SET(ts->sockfd_write, &wrfdset);
545 if (ts->size2 < BUFSIZE) /* can read from pty */
546 FD_SET(ts->ptyfd, &rdfdset);
547 }
548 ts = next;
549 }
550 if (!IS_INETD) {
551 FD_SET(master_fd, &rdfdset);
552 /* This is needed because free_session() does not
Denis Vlasenko018b1552007-11-06 01:38:46 +0000553 * take master_fd into account when it finds new
Denis Vlasenko2450c452007-10-15 22:09:15 +0000554 * maxfd among remaining fd's */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200555 if (master_fd > G.maxfd)
556 G.maxfd = master_fd;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000557 }
558
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200559 count = select(G.maxfd + 1, &rdfdset, &wrfdset, NULL, NULL);
Denis Vlasenko10916c52007-10-15 17:28:00 +0000560 if (count < 0)
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000561 goto again; /* EINTR or ENOMEM */
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000562
563#if ENABLE_FEATURE_TELNETD_STANDALONE
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200564 /* Check for and accept new sessions */
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000565 if (!IS_INETD && FD_ISSET(master_fd, &rdfdset)) {
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000566 int fd;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000567 struct tsession *new_ts;
568
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000569 fd = accept(master_fd, NULL, NULL);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000570 if (fd < 0)
571 goto again;
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200572 close_on_exec_on(fd);
573
574 /* Create a new session and link it into active list */
575 new_ts = make_new_session(fd);
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000576 if (new_ts) {
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200577 new_ts->next = G.sessions;
578 G.sessions = new_ts;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000579 } else {
580 close(fd);
Eric Andersen08a72202002-09-30 20:52:10 +0000581 }
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000582 }
583#endif
Eric Andersen08a72202002-09-30 20:52:10 +0000584
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200585 /* Then check for data tunneling */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200586 ts = G.sessions;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000587 while (ts) { /* For all sessions... */
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200588 struct tsession *next = ts->next; /* in case we free ts */
Eric Andersen08a72202002-09-30 20:52:10 +0000589
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000590 if (/*ts->size1 &&*/ FD_ISSET(ts->ptyfd, &wrfdset)) {
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000591 int num_totty;
Denis Vlasenko10916c52007-10-15 17:28:00 +0000592 unsigned char *ptr;
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200593 /* Write to pty from buffer 1 */
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000594 ptr = remove_iacs(ts, &num_totty);
Denis Vlasenko10916c52007-10-15 17:28:00 +0000595 count = safe_write(ts->ptyfd, ptr, num_totty);
596 if (count < 0) {
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000597 if (errno == EAGAIN)
598 goto skip1;
Denis Vlasenkof472b232007-10-16 21:35:17 +0000599 goto kill_session;
Eric Andersen08a72202002-09-30 20:52:10 +0000600 }
Denis Vlasenko10916c52007-10-15 17:28:00 +0000601 ts->size1 -= count;
602 ts->wridx1 += count;
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000603 if (ts->wridx1 >= BUFSIZE) /* actually == BUFSIZE */
Eric Andersen08a72202002-09-30 20:52:10 +0000604 ts->wridx1 = 0;
Eric Andersen08a72202002-09-30 20:52:10 +0000605 }
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000606 skip1:
607 if (/*ts->size2 &&*/ FD_ISSET(ts->sockfd_write, &wrfdset)) {
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200608 /* Write to socket from buffer 2 */
Denis Vlasenko10916c52007-10-15 17:28:00 +0000609 count = MIN(BUFSIZE - ts->wridx2, ts->size2);
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200610 count = iac_safe_write(ts->sockfd_write, (void*)(TS_BUF2(ts) + ts->wridx2), count);
Denis Vlasenko10916c52007-10-15 17:28:00 +0000611 if (count < 0) {
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000612 if (errno == EAGAIN)
613 goto skip2;
Denis Vlasenkof472b232007-10-16 21:35:17 +0000614 goto kill_session;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000615 }
Denis Vlasenko10916c52007-10-15 17:28:00 +0000616 ts->size2 -= count;
617 ts->wridx2 += count;
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000618 if (ts->wridx2 >= BUFSIZE) /* actually == BUFSIZE */
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000619 ts->wridx2 = 0;
620 }
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000621 skip2:
Denis Vlasenko10916c52007-10-15 17:28:00 +0000622 /* Should not be needed, but... remove_iacs is actually buggy
623 * (it cannot process iacs which wrap around buffer's end)!
624 * Since properly fixing it requires writing bigger code,
Denis Vlasenkof472b232007-10-16 21:35:17 +0000625 * we rely instead on this code making it virtually impossible
Denis Vlasenko10916c52007-10-15 17:28:00 +0000626 * to have wrapped iac (people don't type at 2k/second).
627 * It also allows for bigger reads in common case. */
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000628 if (ts->size1 == 0) {
629 ts->rdidx1 = 0;
630 ts->wridx1 = 0;
631 }
632 if (ts->size2 == 0) {
633 ts->rdidx2 = 0;
634 ts->wridx2 = 0;
635 }
Denis Vlasenko10916c52007-10-15 17:28:00 +0000636
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000637 if (/*ts->size1 < BUFSIZE &&*/ FD_ISSET(ts->sockfd_read, &rdfdset)) {
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200638 /* Read from socket to buffer 1 */
Denis Vlasenko10916c52007-10-15 17:28:00 +0000639 count = MIN(BUFSIZE - ts->rdidx1, BUFSIZE - ts->size1);
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200640 count = safe_read(ts->sockfd_read, TS_BUF1(ts) + ts->rdidx1, count);
Denis Vlasenko10916c52007-10-15 17:28:00 +0000641 if (count <= 0) {
642 if (count < 0 && errno == EAGAIN)
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000643 goto skip3;
Denis Vlasenkof472b232007-10-16 21:35:17 +0000644 goto kill_session;
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000645 }
646 /* Ignore trailing NUL if it is there */
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200647 if (!TS_BUF1(ts)[ts->rdidx1 + count - 1]) {
Denis Vlasenkof472b232007-10-16 21:35:17 +0000648 --count;
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000649 }
Denis Vlasenko10916c52007-10-15 17:28:00 +0000650 ts->size1 += count;
651 ts->rdidx1 += count;
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000652 if (ts->rdidx1 >= BUFSIZE) /* actually == BUFSIZE */
653 ts->rdidx1 = 0;
654 }
655 skip3:
656 if (/*ts->size2 < BUFSIZE &&*/ FD_ISSET(ts->ptyfd, &rdfdset)) {
Denys Vlasenko1d77db82009-06-10 13:38:08 +0200657 /* Read from pty to buffer 2 */
Denis Vlasenko10916c52007-10-15 17:28:00 +0000658 count = MIN(BUFSIZE - ts->rdidx2, BUFSIZE - ts->size2);
Denys Vlasenkoa4bcbd02009-06-09 23:01:24 +0200659 count = safe_read(ts->ptyfd, TS_BUF2(ts) + ts->rdidx2, count);
Denis Vlasenko10916c52007-10-15 17:28:00 +0000660 if (count <= 0) {
661 if (count < 0 && errno == EAGAIN)
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000662 goto skip4;
Denis Vlasenkof472b232007-10-16 21:35:17 +0000663 goto kill_session;
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000664 }
Denis Vlasenko10916c52007-10-15 17:28:00 +0000665 ts->size2 += count;
666 ts->rdidx2 += count;
Denis Vlasenko59d7c432007-10-15 15:19:36 +0000667 if (ts->rdidx2 >= BUFSIZE) /* actually == BUFSIZE */
668 ts->rdidx2 = 0;
669 }
670 skip4:
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000671 ts = next;
Denis Vlasenkof472b232007-10-16 21:35:17 +0000672 continue;
673 kill_session:
674 free_session(ts);
675 ts = next;
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000676 }
Denis Vlasenkof472b232007-10-16 21:35:17 +0000677
Denis Vlasenko75f8d082006-11-22 15:54:52 +0000678 goto again;
Eric Andersen08a72202002-09-30 20:52:10 +0000679}