11ae349f5Scvs2svn /* 21ae349f5Scvs2svn * User Process PPP 31ae349f5Scvs2svn * 41ae349f5Scvs2svn * Written by Toshiharu OHNO (tony-o@iij.ad.jp) 51ae349f5Scvs2svn * 61ae349f5Scvs2svn * Copyright (C) 1993, Internet Initiative Japan, Inc. All rights reserverd. 71ae349f5Scvs2svn * 81ae349f5Scvs2svn * Redistribution and use in source and binary forms are permitted 91ae349f5Scvs2svn * provided that the above copyright notice and this paragraph are 101ae349f5Scvs2svn * duplicated in all such forms and that any documentation, 111ae349f5Scvs2svn * advertising materials, and other materials related to such 121ae349f5Scvs2svn * distribution and use acknowledge that the software was developed 131ae349f5Scvs2svn * by the Internet Initiative Japan, Inc. The name of the 141ae349f5Scvs2svn * IIJ may not be used to endorse or promote products derived 151ae349f5Scvs2svn * from this software without specific prior written permission. 161ae349f5Scvs2svn * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR 171ae349f5Scvs2svn * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED 181ae349f5Scvs2svn * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE. 191ae349f5Scvs2svn * 2029e275ceSBrian Somers * $Id: main.c,v 1.121.2.1 1998/01/29 00:49:26 brian Exp $ 211ae349f5Scvs2svn * 221ae349f5Scvs2svn * TODO: 231ae349f5Scvs2svn * o Add commands for traffic summary, version display, etc. 241ae349f5Scvs2svn * o Add signal handler for misc controls. 251ae349f5Scvs2svn */ 261ae349f5Scvs2svn #include <sys/param.h> 271ae349f5Scvs2svn #include <sys/time.h> 281ae349f5Scvs2svn #include <sys/select.h> 291ae349f5Scvs2svn #include <sys/socket.h> 301ae349f5Scvs2svn #include <net/if.h> 311ae349f5Scvs2svn #include <net/if_tun.h> 321ae349f5Scvs2svn #include <netinet/in.h> 331ae349f5Scvs2svn #include <netinet/in_systm.h> 341ae349f5Scvs2svn #include <netinet/ip.h> 351ae349f5Scvs2svn #include <arpa/inet.h> 361ae349f5Scvs2svn 371ae349f5Scvs2svn #include <errno.h> 381ae349f5Scvs2svn #include <fcntl.h> 391ae349f5Scvs2svn #include <paths.h> 401ae349f5Scvs2svn #include <signal.h> 411ae349f5Scvs2svn #include <stdio.h> 421ae349f5Scvs2svn #include <stdlib.h> 431ae349f5Scvs2svn #include <string.h> 441ae349f5Scvs2svn #include <sys/time.h> 451ae349f5Scvs2svn #include <sys/wait.h> 461ae349f5Scvs2svn #include <termios.h> 471ae349f5Scvs2svn #include <unistd.h> 481ae349f5Scvs2svn 491ae349f5Scvs2svn #include "command.h" 501ae349f5Scvs2svn #include "mbuf.h" 511ae349f5Scvs2svn #include "log.h" 521ae349f5Scvs2svn #include "defs.h" 531ae349f5Scvs2svn #include "id.h" 541ae349f5Scvs2svn #include "timer.h" 551ae349f5Scvs2svn #include "fsm.h" 561ae349f5Scvs2svn #include "modem.h" 571ae349f5Scvs2svn #include "os.h" 581ae349f5Scvs2svn #include "hdlc.h" 591ae349f5Scvs2svn #include "lcp.h" 601ae349f5Scvs2svn #include "ccp.h" 6129e275ceSBrian Somers #include "iplist.h" 6229e275ceSBrian Somers #include "throughput.h" 631ae349f5Scvs2svn #include "ipcp.h" 641ae349f5Scvs2svn #include "loadalias.h" 651ae349f5Scvs2svn #include "vars.h" 661ae349f5Scvs2svn #include "auth.h" 671ae349f5Scvs2svn #include "filter.h" 681ae349f5Scvs2svn #include "systems.h" 691ae349f5Scvs2svn #include "ip.h" 701ae349f5Scvs2svn #include "sig.h" 711ae349f5Scvs2svn #include "server.h" 721ae349f5Scvs2svn #include "main.h" 731ae349f5Scvs2svn #include "vjcomp.h" 741ae349f5Scvs2svn #include "async.h" 751ae349f5Scvs2svn #include "pathnames.h" 761ae349f5Scvs2svn #include "tun.h" 771ae349f5Scvs2svn #include "route.h" 7863b73463SBrian Somers #include "physical.h" 791ae349f5Scvs2svn 801ae349f5Scvs2svn #ifndef O_NONBLOCK 811ae349f5Scvs2svn #ifdef O_NDELAY 821ae349f5Scvs2svn #define O_NONBLOCK O_NDELAY 831ae349f5Scvs2svn #endif 841ae349f5Scvs2svn #endif 851ae349f5Scvs2svn 861ae349f5Scvs2svn int TermMode = 0; 871ae349f5Scvs2svn int tunno = 0; 881ae349f5Scvs2svn 891ae349f5Scvs2svn static struct termios oldtio; /* Original tty mode */ 901ae349f5Scvs2svn static struct termios comtio; /* Command level tty mode */ 911ae349f5Scvs2svn static pid_t BGPid = 0; 921ae349f5Scvs2svn static char pid_filename[MAXPATHLEN]; 931ae349f5Scvs2svn static int dial_up; 941ae349f5Scvs2svn 951ae349f5Scvs2svn static void DoLoop(void); 961ae349f5Scvs2svn static void TerminalStop(int); 971ae349f5Scvs2svn static const char *ex_desc(int); 981ae349f5Scvs2svn 991ae349f5Scvs2svn static void 1001ae349f5Scvs2svn TtyInit(int DontWantInt) 1011ae349f5Scvs2svn { 1021ae349f5Scvs2svn struct termios newtio; 1031ae349f5Scvs2svn int stat; 1041ae349f5Scvs2svn 1051ae349f5Scvs2svn stat = fcntl(netfd, F_GETFL, 0); 1061ae349f5Scvs2svn if (stat > 0) { 1071ae349f5Scvs2svn stat |= O_NONBLOCK; 1081ae349f5Scvs2svn (void) fcntl(netfd, F_SETFL, stat); 1091ae349f5Scvs2svn } 1101ae349f5Scvs2svn newtio = oldtio; 1111ae349f5Scvs2svn newtio.c_lflag &= ~(ECHO | ISIG | ICANON); 1121ae349f5Scvs2svn newtio.c_iflag = 0; 1131ae349f5Scvs2svn newtio.c_oflag &= ~OPOST; 1141ae349f5Scvs2svn newtio.c_cc[VEOF] = _POSIX_VDISABLE; 1151ae349f5Scvs2svn if (DontWantInt) 1161ae349f5Scvs2svn newtio.c_cc[VINTR] = _POSIX_VDISABLE; 1171ae349f5Scvs2svn newtio.c_cc[VMIN] = 1; 1181ae349f5Scvs2svn newtio.c_cc[VTIME] = 0; 1191ae349f5Scvs2svn newtio.c_cflag |= CS8; 1201ae349f5Scvs2svn tcsetattr(netfd, TCSANOW, &newtio); 1211ae349f5Scvs2svn comtio = newtio; 1221ae349f5Scvs2svn } 1231ae349f5Scvs2svn 1241ae349f5Scvs2svn /* 1251ae349f5Scvs2svn * Set tty into command mode. We allow canonical input and echo processing. 1261ae349f5Scvs2svn */ 1271ae349f5Scvs2svn void 1281ae349f5Scvs2svn TtyCommandMode(int prompt) 1291ae349f5Scvs2svn { 1301ae349f5Scvs2svn struct termios newtio; 1311ae349f5Scvs2svn int stat; 1321ae349f5Scvs2svn 1331ae349f5Scvs2svn if (!(mode & MODE_INTER)) 1341ae349f5Scvs2svn return; 1351ae349f5Scvs2svn tcgetattr(netfd, &newtio); 1361ae349f5Scvs2svn newtio.c_lflag |= (ECHO | ISIG | ICANON); 1371ae349f5Scvs2svn newtio.c_iflag = oldtio.c_iflag; 1381ae349f5Scvs2svn newtio.c_oflag |= OPOST; 1391ae349f5Scvs2svn tcsetattr(netfd, TCSADRAIN, &newtio); 1401ae349f5Scvs2svn stat = fcntl(netfd, F_GETFL, 0); 1411ae349f5Scvs2svn if (stat > 0) { 1421ae349f5Scvs2svn stat |= O_NONBLOCK; 1431ae349f5Scvs2svn (void) fcntl(netfd, F_SETFL, stat); 1441ae349f5Scvs2svn } 1451ae349f5Scvs2svn TermMode = 0; 1461ae349f5Scvs2svn if (prompt) 1471ae349f5Scvs2svn Prompt(); 1481ae349f5Scvs2svn } 1491ae349f5Scvs2svn 1501ae349f5Scvs2svn /* 1511ae349f5Scvs2svn * Set tty into terminal mode which is used while we invoke term command. 1521ae349f5Scvs2svn */ 1531ae349f5Scvs2svn void 1541ae349f5Scvs2svn TtyTermMode() 1551ae349f5Scvs2svn { 1561ae349f5Scvs2svn int stat; 1571ae349f5Scvs2svn 1581ae349f5Scvs2svn tcsetattr(netfd, TCSADRAIN, &comtio); 1591ae349f5Scvs2svn stat = fcntl(netfd, F_GETFL, 0); 1601ae349f5Scvs2svn if (stat > 0) { 1611ae349f5Scvs2svn stat &= ~O_NONBLOCK; 1621ae349f5Scvs2svn (void) fcntl(netfd, F_SETFL, stat); 1631ae349f5Scvs2svn } 1641ae349f5Scvs2svn TermMode = 1; 1651ae349f5Scvs2svn } 1661ae349f5Scvs2svn 1671ae349f5Scvs2svn void 1681ae349f5Scvs2svn TtyOldMode() 1691ae349f5Scvs2svn { 1701ae349f5Scvs2svn int stat; 1711ae349f5Scvs2svn 1721ae349f5Scvs2svn stat = fcntl(netfd, F_GETFL, 0); 1731ae349f5Scvs2svn if (stat > 0) { 1741ae349f5Scvs2svn stat &= ~O_NONBLOCK; 1751ae349f5Scvs2svn (void) fcntl(netfd, F_SETFL, stat); 1761ae349f5Scvs2svn } 1771ae349f5Scvs2svn tcsetattr(netfd, TCSADRAIN, &oldtio); 1781ae349f5Scvs2svn } 1791ae349f5Scvs2svn 1801ae349f5Scvs2svn void 1811ae349f5Scvs2svn Cleanup(int excode) 1821ae349f5Scvs2svn { 1831ae349f5Scvs2svn DropClient(1); 1841ae349f5Scvs2svn ServerClose(); 1851ae349f5Scvs2svn OsInterfaceDown(1); 18663b73463SBrian Somers HangupModem(pppVars.physical, 1); /* XXX must be expanded to 18763b73463SBrian Somers take all modems */ 1881ae349f5Scvs2svn nointr_sleep(1); 1891ae349f5Scvs2svn DeleteIfRoutes(1); 1901ae349f5Scvs2svn ID0unlink(pid_filename); 1911ae349f5Scvs2svn if (mode & MODE_BACKGROUND && BGFiledes[1] != -1) { 1921ae349f5Scvs2svn char c = EX_ERRDEAD; 1931ae349f5Scvs2svn 1941ae349f5Scvs2svn if (write(BGFiledes[1], &c, 1) == 1) 1951ae349f5Scvs2svn LogPrintf(LogPHASE, "Parent notified of failure.\n"); 1961ae349f5Scvs2svn else 1971ae349f5Scvs2svn LogPrintf(LogPHASE, "Failed to notify parent of failure.\n"); 1981ae349f5Scvs2svn close(BGFiledes[1]); 1991ae349f5Scvs2svn } 2001ae349f5Scvs2svn LogPrintf(LogPHASE, "PPP Terminated (%s).\n", ex_desc(excode)); 2011ae349f5Scvs2svn TtyOldMode(); 2021ae349f5Scvs2svn LogClose(); 2031ae349f5Scvs2svn 2041ae349f5Scvs2svn exit(excode); 2051ae349f5Scvs2svn } 2061ae349f5Scvs2svn 2071ae349f5Scvs2svn static void 2081ae349f5Scvs2svn CloseConnection(int signo) 2091ae349f5Scvs2svn { 2101ae349f5Scvs2svn /* NOTE, these are manual, we've done a setsid() */ 2111ae349f5Scvs2svn pending_signal(SIGINT, SIG_IGN); 2121ae349f5Scvs2svn LogPrintf(LogPHASE, "Caught signal %d, abort connection\n", signo); 2131ae349f5Scvs2svn reconnectState = RECON_FALSE; 2141ae349f5Scvs2svn reconnectCount = 0; 2151ae349f5Scvs2svn DownConnection(); 2161ae349f5Scvs2svn dial_up = 0; 2171ae349f5Scvs2svn pending_signal(SIGINT, CloseConnection); 2181ae349f5Scvs2svn } 2191ae349f5Scvs2svn 2201ae349f5Scvs2svn static void 2211ae349f5Scvs2svn CloseSession(int signo) 2221ae349f5Scvs2svn { 2231ae349f5Scvs2svn if (BGPid) { 2241ae349f5Scvs2svn kill(BGPid, SIGINT); 2251ae349f5Scvs2svn exit(EX_TERM); 2261ae349f5Scvs2svn } 2271ae349f5Scvs2svn LogPrintf(LogPHASE, "Signal %d, terminate.\n", signo); 2281ae349f5Scvs2svn reconnect(RECON_FALSE); 22963b73463SBrian Somers LcpClose(&LcpFsm); 2301ae349f5Scvs2svn Cleanup(EX_TERM); 2311ae349f5Scvs2svn } 2321ae349f5Scvs2svn 2331ae349f5Scvs2svn static void 2341ae349f5Scvs2svn TerminalCont(int signo) 2351ae349f5Scvs2svn { 2361ae349f5Scvs2svn pending_signal(SIGCONT, SIG_DFL); 2371ae349f5Scvs2svn pending_signal(SIGTSTP, TerminalStop); 2381ae349f5Scvs2svn TtyCommandMode(getpgrp() == tcgetpgrp(netfd)); 2391ae349f5Scvs2svn } 2401ae349f5Scvs2svn 2411ae349f5Scvs2svn static void 2421ae349f5Scvs2svn TerminalStop(int signo) 2431ae349f5Scvs2svn { 2441ae349f5Scvs2svn pending_signal(SIGCONT, TerminalCont); 2451ae349f5Scvs2svn TtyOldMode(); 2461ae349f5Scvs2svn pending_signal(SIGTSTP, SIG_DFL); 2471ae349f5Scvs2svn kill(getpid(), signo); 2481ae349f5Scvs2svn } 2491ae349f5Scvs2svn 2501ae349f5Scvs2svn static void 2511ae349f5Scvs2svn SetUpServer(int signo) 2521ae349f5Scvs2svn { 2531ae349f5Scvs2svn int res; 2541ae349f5Scvs2svn 2551ae349f5Scvs2svn VarHaveLocalAuthKey = 0; 2561ae349f5Scvs2svn LocalAuthInit(); 2571ae349f5Scvs2svn if ((res = ServerTcpOpen(SERVER_PORT + tunno)) != 0) 2581ae349f5Scvs2svn LogPrintf(LogERROR, "SIGUSR1: Failed %d to open port %d\n", 2591ae349f5Scvs2svn res, SERVER_PORT + tunno); 2601ae349f5Scvs2svn } 2611ae349f5Scvs2svn 2621ae349f5Scvs2svn static void 2631ae349f5Scvs2svn BringDownServer(int signo) 2641ae349f5Scvs2svn { 2651ae349f5Scvs2svn VarHaveLocalAuthKey = 0; 2661ae349f5Scvs2svn LocalAuthInit(); 2671ae349f5Scvs2svn ServerClose(); 2681ae349f5Scvs2svn } 2691ae349f5Scvs2svn 2701ae349f5Scvs2svn static const char * 2711ae349f5Scvs2svn ex_desc(int ex) 2721ae349f5Scvs2svn { 2731ae349f5Scvs2svn static char num[12]; 2741ae349f5Scvs2svn static const char *desc[] = { 2751ae349f5Scvs2svn "normal", "start", "sock", "modem", "dial", "dead", "done", 2761ae349f5Scvs2svn "reboot", "errdead", "hangup", "term", "nodial", "nologin" 2771ae349f5Scvs2svn }; 2781ae349f5Scvs2svn 2791ae349f5Scvs2svn if (ex >= 0 && ex < sizeof desc / sizeof *desc) 2801ae349f5Scvs2svn return desc[ex]; 2811ae349f5Scvs2svn snprintf(num, sizeof num, "%d", ex); 2821ae349f5Scvs2svn return num; 2831ae349f5Scvs2svn } 2841ae349f5Scvs2svn 2851ae349f5Scvs2svn static void 2861ae349f5Scvs2svn Usage(void) 2871ae349f5Scvs2svn { 2881ae349f5Scvs2svn fprintf(stderr, 2891ae349f5Scvs2svn "Usage: ppp [-auto | -background | -direct | -dedicated | -ddial ]" 2901ae349f5Scvs2svn #ifndef NOALIAS 2911ae349f5Scvs2svn " [ -alias ]" 2921ae349f5Scvs2svn #endif 2931ae349f5Scvs2svn " [system]\n"); 2941ae349f5Scvs2svn exit(EX_START); 2951ae349f5Scvs2svn } 2961ae349f5Scvs2svn 2971ae349f5Scvs2svn static char * 2981ae349f5Scvs2svn ProcessArgs(int argc, char **argv) 2991ae349f5Scvs2svn { 3001ae349f5Scvs2svn int optc; 3011ae349f5Scvs2svn char *cp; 3021ae349f5Scvs2svn 3031ae349f5Scvs2svn optc = 0; 3041ae349f5Scvs2svn mode = MODE_INTER; 3051ae349f5Scvs2svn while (argc > 0 && **argv == '-') { 3061ae349f5Scvs2svn cp = *argv + 1; 3071ae349f5Scvs2svn if (strcmp(cp, "auto") == 0) { 3081ae349f5Scvs2svn mode |= MODE_AUTO; 3091ae349f5Scvs2svn mode &= ~MODE_INTER; 3101ae349f5Scvs2svn } else if (strcmp(cp, "background") == 0) { 3111ae349f5Scvs2svn mode |= MODE_BACKGROUND; 3121ae349f5Scvs2svn mode &= ~MODE_INTER; 3131ae349f5Scvs2svn } else if (strcmp(cp, "direct") == 0) { 3141ae349f5Scvs2svn mode |= MODE_DIRECT; 3151ae349f5Scvs2svn mode &= ~MODE_INTER; 3161ae349f5Scvs2svn } else if (strcmp(cp, "dedicated") == 0) { 3171ae349f5Scvs2svn mode |= MODE_DEDICATED; 3181ae349f5Scvs2svn mode &= ~MODE_INTER; 3191ae349f5Scvs2svn } else if (strcmp(cp, "ddial") == 0) { 3201ae349f5Scvs2svn mode |= MODE_DDIAL; 3211ae349f5Scvs2svn mode &= ~MODE_INTER; 3221ae349f5Scvs2svn #ifndef NOALIAS 3231ae349f5Scvs2svn } else if (strcmp(cp, "alias") == 0) { 3241ae349f5Scvs2svn if (loadAliasHandlers(&VarAliasHandlers) == 0) 3251ae349f5Scvs2svn mode |= MODE_ALIAS; 3261ae349f5Scvs2svn else 3271ae349f5Scvs2svn LogPrintf(LogWARN, "Cannot load alias library\n"); 3281ae349f5Scvs2svn optc--; /* this option isn't exclusive */ 3291ae349f5Scvs2svn #endif 3301ae349f5Scvs2svn } else 3311ae349f5Scvs2svn Usage(); 3321ae349f5Scvs2svn optc++; 3331ae349f5Scvs2svn argv++; 3341ae349f5Scvs2svn argc--; 3351ae349f5Scvs2svn } 3361ae349f5Scvs2svn if (argc > 1) { 3371ae349f5Scvs2svn fprintf(stderr, "specify only one system label.\n"); 3381ae349f5Scvs2svn exit(EX_START); 3391ae349f5Scvs2svn } 3401ae349f5Scvs2svn 3411ae349f5Scvs2svn if (optc > 1) { 3421ae349f5Scvs2svn fprintf(stderr, "specify only one mode.\n"); 3431ae349f5Scvs2svn exit(EX_START); 3441ae349f5Scvs2svn } 3451ae349f5Scvs2svn 3461ae349f5Scvs2svn return argc == 1 ? *argv : NULL; /* Don't SetLabel yet ! */ 3471ae349f5Scvs2svn } 3481ae349f5Scvs2svn 3491ae349f5Scvs2svn int 3501ae349f5Scvs2svn main(int argc, char **argv) 3511ae349f5Scvs2svn { 3521ae349f5Scvs2svn FILE *lockfile; 3531ae349f5Scvs2svn char *name, *label; 3541ae349f5Scvs2svn int nfds; 3551ae349f5Scvs2svn 3561ae349f5Scvs2svn nfds = getdtablesize(); 3571ae349f5Scvs2svn if (nfds >= FD_SETSIZE) 3581ae349f5Scvs2svn /* 3591ae349f5Scvs2svn * If we've got loads of file descriptors, make sure they're all 3601ae349f5Scvs2svn * closed. If they aren't, we may end up with a seg fault when our 3611ae349f5Scvs2svn * `fd_set's get too big when select()ing ! 3621ae349f5Scvs2svn */ 3631ae349f5Scvs2svn while (--nfds > 2) 3641ae349f5Scvs2svn close(nfds); 3651ae349f5Scvs2svn 3661ae349f5Scvs2svn VarTerm = 0; 3671ae349f5Scvs2svn name = strrchr(argv[0], '/'); 3681ae349f5Scvs2svn LogOpen(name ? name + 1 : argv[0]); 3691ae349f5Scvs2svn 3701ae349f5Scvs2svn tcgetattr(STDIN_FILENO, &oldtio); /* Save original tty mode */ 3711ae349f5Scvs2svn 3721ae349f5Scvs2svn argc--; 3731ae349f5Scvs2svn argv++; 3741ae349f5Scvs2svn label = ProcessArgs(argc, argv); 3751ae349f5Scvs2svn if (!(mode & MODE_DIRECT)) 3761ae349f5Scvs2svn VarTerm = stdout; 3771ae349f5Scvs2svn 3781ae349f5Scvs2svn ID0init(); 3791ae349f5Scvs2svn if (ID0realuid() != 0) { 3801ae349f5Scvs2svn char conf[200], *ptr; 3811ae349f5Scvs2svn 3821ae349f5Scvs2svn snprintf(conf, sizeof conf, "%s/%s", _PATH_PPP, CONFFILE); 3831ae349f5Scvs2svn do { 3841ae349f5Scvs2svn if (!access(conf, W_OK)) { 3851ae349f5Scvs2svn LogPrintf(LogALERT, "ppp: Access violation: Please protect %s\n", conf); 3861ae349f5Scvs2svn return -1; 3871ae349f5Scvs2svn } 3881ae349f5Scvs2svn ptr = conf + strlen(conf)-2; 3891ae349f5Scvs2svn while (ptr > conf && *ptr != '/') 3901ae349f5Scvs2svn *ptr-- = '\0'; 3911ae349f5Scvs2svn } while (ptr >= conf); 3921ae349f5Scvs2svn } 3931ae349f5Scvs2svn 3941ae349f5Scvs2svn if (!ValidSystem(label)) { 3951ae349f5Scvs2svn fprintf(stderr, "You may not use ppp in this mode with this label\n"); 3961ae349f5Scvs2svn if (mode & MODE_DIRECT) { 3971ae349f5Scvs2svn const char *l; 3981ae349f5Scvs2svn l = label ? label : "default"; 3991ae349f5Scvs2svn LogPrintf(LogWARN, "Label %s rejected -direct connection\n", l); 4001ae349f5Scvs2svn } 4011ae349f5Scvs2svn LogClose(); 4021ae349f5Scvs2svn return 1; 4031ae349f5Scvs2svn } 4041ae349f5Scvs2svn 4051ae349f5Scvs2svn if (!GetShortHost()) 4061ae349f5Scvs2svn return 1; 4071ae349f5Scvs2svn IsInteractive(1); 4081ae349f5Scvs2svn IpcpDefAddress(); 4091ae349f5Scvs2svn 4101ae349f5Scvs2svn if (mode & MODE_INTER) 4111ae349f5Scvs2svn VarLocalAuth = LOCAL_AUTH; 4121ae349f5Scvs2svn 4131ae349f5Scvs2svn if (SelectSystem("default", CONFFILE) < 0 && VarTerm) 4141ae349f5Scvs2svn fprintf(VarTerm, "Warning: No default entry is given in config file.\n"); 4151ae349f5Scvs2svn 4161ae349f5Scvs2svn if (OpenTunnel(&tunno) < 0) { 4171ae349f5Scvs2svn LogPrintf(LogWARN, "OpenTunnel: %s\n", strerror(errno)); 4181ae349f5Scvs2svn return EX_START; 4191ae349f5Scvs2svn } 4201ae349f5Scvs2svn CleanInterface(IfDevName); 4211ae349f5Scvs2svn if ((mode & MODE_OUTGOING_DAEMON) && !(mode & MODE_DEDICATED)) 4221ae349f5Scvs2svn if (label == NULL) { 4231ae349f5Scvs2svn if (VarTerm) 4241ae349f5Scvs2svn fprintf(VarTerm, "Destination system must be specified in" 4251ae349f5Scvs2svn " auto, background or ddial mode.\n"); 4261ae349f5Scvs2svn return EX_START; 4271ae349f5Scvs2svn } 4281ae349f5Scvs2svn 4291ae349f5Scvs2svn pending_signal(SIGHUP, CloseSession); 4301ae349f5Scvs2svn pending_signal(SIGTERM, CloseSession); 4311ae349f5Scvs2svn pending_signal(SIGINT, CloseConnection); 4321ae349f5Scvs2svn pending_signal(SIGQUIT, CloseSession); 4331ae349f5Scvs2svn #ifdef SIGPIPE 4341ae349f5Scvs2svn signal(SIGPIPE, SIG_IGN); 4351ae349f5Scvs2svn #endif 4361ae349f5Scvs2svn #ifdef SIGALRM 4371ae349f5Scvs2svn pending_signal(SIGALRM, SIG_IGN); 4381ae349f5Scvs2svn #endif 4391ae349f5Scvs2svn if (mode & MODE_INTER) { 4401ae349f5Scvs2svn #ifdef SIGTSTP 4411ae349f5Scvs2svn pending_signal(SIGTSTP, TerminalStop); 4421ae349f5Scvs2svn #endif 4431ae349f5Scvs2svn #ifdef SIGTTIN 4441ae349f5Scvs2svn pending_signal(SIGTTIN, TerminalStop); 4451ae349f5Scvs2svn #endif 4461ae349f5Scvs2svn #ifdef SIGTTOU 4471ae349f5Scvs2svn pending_signal(SIGTTOU, SIG_IGN); 4481ae349f5Scvs2svn #endif 4491ae349f5Scvs2svn } 4501ae349f5Scvs2svn if (!(mode & MODE_INTER)) { 4511ae349f5Scvs2svn #ifdef SIGUSR1 4521ae349f5Scvs2svn pending_signal(SIGUSR1, SetUpServer); 4531ae349f5Scvs2svn #endif 4541ae349f5Scvs2svn #ifdef SIGUSR2 4551ae349f5Scvs2svn pending_signal(SIGUSR2, BringDownServer); 4561ae349f5Scvs2svn #endif 4571ae349f5Scvs2svn } 4581ae349f5Scvs2svn 4591ae349f5Scvs2svn if (label) { 4601ae349f5Scvs2svn if (SelectSystem(label, CONFFILE) < 0) { 4611ae349f5Scvs2svn LogPrintf(LogWARN, "Destination system %s not found in conf file.\n", 4621ae349f5Scvs2svn GetLabel()); 4631ae349f5Scvs2svn Cleanup(EX_START); 4641ae349f5Scvs2svn } 4651ae349f5Scvs2svn /* 4661ae349f5Scvs2svn * We don't SetLabel() 'till now in case SelectSystem() has an 4671ae349f5Scvs2svn * embeded load "otherlabel" command. 4681ae349f5Scvs2svn */ 4691ae349f5Scvs2svn SetLabel(label); 4701ae349f5Scvs2svn if (mode & MODE_OUTGOING_DAEMON && 47129e275ceSBrian Somers IpcpInfo.DefHisAddress.ipaddr.s_addr == INADDR_ANY) { 4721ae349f5Scvs2svn LogPrintf(LogWARN, "You must \"set ifaddr\" in label %s for" 4731ae349f5Scvs2svn " auto, background or ddial mode.\n", label); 4741ae349f5Scvs2svn Cleanup(EX_START); 4751ae349f5Scvs2svn } 4761ae349f5Scvs2svn } 4771ae349f5Scvs2svn 4781ae349f5Scvs2svn if (mode & MODE_DAEMON) { 4791ae349f5Scvs2svn if (mode & MODE_BACKGROUND) { 4801ae349f5Scvs2svn if (pipe(BGFiledes)) { 4811ae349f5Scvs2svn LogPrintf(LogERROR, "pipe: %s\n", strerror(errno)); 4821ae349f5Scvs2svn Cleanup(EX_SOCK); 4831ae349f5Scvs2svn } 4841ae349f5Scvs2svn } 4851ae349f5Scvs2svn 4861ae349f5Scvs2svn if (!(mode & MODE_DIRECT)) { 4871ae349f5Scvs2svn pid_t bgpid; 4881ae349f5Scvs2svn 4891ae349f5Scvs2svn bgpid = fork(); 4901ae349f5Scvs2svn if (bgpid == -1) { 4911ae349f5Scvs2svn LogPrintf(LogERROR, "fork: %s\n", strerror(errno)); 4921ae349f5Scvs2svn Cleanup(EX_SOCK); 4931ae349f5Scvs2svn } 4941ae349f5Scvs2svn if (bgpid) { 4951ae349f5Scvs2svn char c = EX_NORMAL; 4961ae349f5Scvs2svn 4971ae349f5Scvs2svn if (mode & MODE_BACKGROUND) { 4981ae349f5Scvs2svn /* Wait for our child to close its pipe before we exit. */ 4991ae349f5Scvs2svn BGPid = bgpid; 5001ae349f5Scvs2svn close(BGFiledes[1]); 5011ae349f5Scvs2svn if (read(BGFiledes[0], &c, 1) != 1) { 5021ae349f5Scvs2svn fprintf(VarTerm, "Child exit, no status.\n"); 5031ae349f5Scvs2svn LogPrintf(LogPHASE, "Parent: Child exit, no status.\n"); 5041ae349f5Scvs2svn } else if (c == EX_NORMAL) { 5051ae349f5Scvs2svn fprintf(VarTerm, "PPP enabled.\n"); 5061ae349f5Scvs2svn LogPrintf(LogPHASE, "Parent: PPP enabled.\n"); 5071ae349f5Scvs2svn } else { 5081ae349f5Scvs2svn fprintf(VarTerm, "Child failed (%s).\n", ex_desc((int) c)); 5091ae349f5Scvs2svn LogPrintf(LogPHASE, "Parent: Child failed (%s).\n", 5101ae349f5Scvs2svn ex_desc((int) c)); 5111ae349f5Scvs2svn } 5121ae349f5Scvs2svn close(BGFiledes[0]); 5131ae349f5Scvs2svn } 5141ae349f5Scvs2svn return c; 5151ae349f5Scvs2svn } else if (mode & MODE_BACKGROUND) 5161ae349f5Scvs2svn close(BGFiledes[0]); 5171ae349f5Scvs2svn } 5181ae349f5Scvs2svn 5191ae349f5Scvs2svn VarTerm = 0; /* We know it's currently stdout */ 5201ae349f5Scvs2svn close(STDOUT_FILENO); 5211ae349f5Scvs2svn close(STDERR_FILENO); 5221ae349f5Scvs2svn 5231ae349f5Scvs2svn if (mode & MODE_DIRECT) 5241ae349f5Scvs2svn /* STDIN_FILENO gets used by OpenModem in DIRECT mode */ 5251ae349f5Scvs2svn TtyInit(1); 5261ae349f5Scvs2svn else if (mode & MODE_DAEMON) { 5271ae349f5Scvs2svn setsid(); 5281ae349f5Scvs2svn close(STDIN_FILENO); 5291ae349f5Scvs2svn } 5301ae349f5Scvs2svn } else { 5311ae349f5Scvs2svn close(STDIN_FILENO); 5321ae349f5Scvs2svn if ((netfd = open(_PATH_TTY, O_RDONLY)) < 0) { 5331ae349f5Scvs2svn fprintf(stderr, "Cannot open %s for intput !\n", _PATH_TTY); 5341ae349f5Scvs2svn return 2; 5351ae349f5Scvs2svn } 5361ae349f5Scvs2svn close(STDERR_FILENO); 5371ae349f5Scvs2svn TtyInit(0); 5381ae349f5Scvs2svn TtyCommandMode(1); 5391ae349f5Scvs2svn } 5401ae349f5Scvs2svn 5411ae349f5Scvs2svn snprintf(pid_filename, sizeof pid_filename, "%stun%d.pid", 5421ae349f5Scvs2svn _PATH_VARRUN, tunno); 5431ae349f5Scvs2svn lockfile = ID0fopen(pid_filename, "w"); 5441ae349f5Scvs2svn if (lockfile != NULL) { 5451ae349f5Scvs2svn fprintf(lockfile, "%d\n", (int) getpid()); 5461ae349f5Scvs2svn fclose(lockfile); 5471ae349f5Scvs2svn } 5481ae349f5Scvs2svn #ifndef RELEASE_CRUNCH 5491ae349f5Scvs2svn else 5501ae349f5Scvs2svn LogPrintf(LogALERT, "Warning: Can't create %s: %s\n", 5511ae349f5Scvs2svn pid_filename, strerror(errno)); 5521ae349f5Scvs2svn #endif 5531ae349f5Scvs2svn 5541ae349f5Scvs2svn LogPrintf(LogPHASE, "PPP Started.\n"); 5551ae349f5Scvs2svn 5561ae349f5Scvs2svn 5571ae349f5Scvs2svn do 5581ae349f5Scvs2svn DoLoop(); 5591ae349f5Scvs2svn while (mode & MODE_DEDICATED); 5601ae349f5Scvs2svn 5611ae349f5Scvs2svn Cleanup(EX_DONE); 5621ae349f5Scvs2svn return 0; 5631ae349f5Scvs2svn } 5641ae349f5Scvs2svn 5651ae349f5Scvs2svn /* 5661ae349f5Scvs2svn * Turn into packet mode, where we speak PPP. 5671ae349f5Scvs2svn */ 5681ae349f5Scvs2svn void 5691ae349f5Scvs2svn PacketMode(int delay) 5701ae349f5Scvs2svn { 57163b73463SBrian Somers if (RawModem(pppVars.physical) < 0) { 5721ae349f5Scvs2svn LogPrintf(LogWARN, "PacketMode: Not connected.\n"); 5731ae349f5Scvs2svn return; 5741ae349f5Scvs2svn } 5751ae349f5Scvs2svn AsyncInit(); 5761ae349f5Scvs2svn VjInit(15); 57763b73463SBrian Somers LcpInit(pppVars.physical); 57863b73463SBrian Somers IpcpInit(pppVars.physical); 57963b73463SBrian Somers CcpInit(pppVars.physical); 5801ae349f5Scvs2svn LcpUp(); 5811ae349f5Scvs2svn 5821ae349f5Scvs2svn LcpOpen(delay); 5831ae349f5Scvs2svn if (mode & MODE_INTER) 5841ae349f5Scvs2svn TtyCommandMode(1); 5851ae349f5Scvs2svn if (VarTerm) { 5861ae349f5Scvs2svn fprintf(VarTerm, "Packet mode.\n"); 5871ae349f5Scvs2svn aft_cmd = 1; 5881ae349f5Scvs2svn } 5891ae349f5Scvs2svn } 5901ae349f5Scvs2svn 5911ae349f5Scvs2svn static void 5921ae349f5Scvs2svn ShowHelp(void) 5931ae349f5Scvs2svn { 5941ae349f5Scvs2svn fprintf(stderr, "The following commands are available:\r\n"); 5951ae349f5Scvs2svn fprintf(stderr, " ~p\tEnter Packet mode\r\n"); 5961ae349f5Scvs2svn fprintf(stderr, " ~-\tDecrease log level\r\n"); 5971ae349f5Scvs2svn fprintf(stderr, " ~+\tIncrease log level\r\n"); 5981ae349f5Scvs2svn fprintf(stderr, " ~t\tShow timers (only in \"log debug\" mode)\r\n"); 5991ae349f5Scvs2svn fprintf(stderr, " ~m\tShow memory map (only in \"log debug\" mode)\r\n"); 6001ae349f5Scvs2svn fprintf(stderr, " ~.\tTerminate program\r\n"); 6011ae349f5Scvs2svn fprintf(stderr, " ~?\tThis help\r\n"); 6021ae349f5Scvs2svn } 6031ae349f5Scvs2svn 6041ae349f5Scvs2svn static void 6051ae349f5Scvs2svn ReadTty(void) 6061ae349f5Scvs2svn { 6071ae349f5Scvs2svn int n; 6081ae349f5Scvs2svn char ch; 6091ae349f5Scvs2svn static int ttystate; 6101ae349f5Scvs2svn char linebuff[LINE_LEN]; 6111ae349f5Scvs2svn 6121ae349f5Scvs2svn LogPrintf(LogDEBUG, "termode = %d, netfd = %d, mode = %d\n", 6131ae349f5Scvs2svn TermMode, netfd, mode); 6141ae349f5Scvs2svn if (!TermMode) { 6151ae349f5Scvs2svn n = read(netfd, linebuff, sizeof linebuff - 1); 6161ae349f5Scvs2svn if (n > 0) { 6171ae349f5Scvs2svn aft_cmd = 1; 6181ae349f5Scvs2svn if (linebuff[n-1] == '\n') 6191ae349f5Scvs2svn linebuff[--n] = '\0'; 6201ae349f5Scvs2svn else 6211ae349f5Scvs2svn linebuff[n] = '\0'; 6221ae349f5Scvs2svn if (n) 6231ae349f5Scvs2svn DecodeCommand(linebuff, n, IsInteractive(0) ? NULL : "Client"); 6241ae349f5Scvs2svn Prompt(); 6251ae349f5Scvs2svn } else if (n <= 0) { 6261ae349f5Scvs2svn LogPrintf(LogPHASE, "Client connection closed.\n"); 6271ae349f5Scvs2svn DropClient(0); 6281ae349f5Scvs2svn } 6291ae349f5Scvs2svn return; 6301ae349f5Scvs2svn } 6311ae349f5Scvs2svn 6321ae349f5Scvs2svn /* 6331ae349f5Scvs2svn * We are in terminal mode, decode special sequences 6341ae349f5Scvs2svn */ 6351ae349f5Scvs2svn n = read(netfd, &ch, 1); 6361ae349f5Scvs2svn LogPrintf(LogDEBUG, "Got %d bytes (reading from the terminal)\n", n); 6371ae349f5Scvs2svn 6381ae349f5Scvs2svn if (n > 0) { 6391ae349f5Scvs2svn switch (ttystate) { 6401ae349f5Scvs2svn case 0: 6411ae349f5Scvs2svn if (ch == '~') 6421ae349f5Scvs2svn ttystate++; 6431ae349f5Scvs2svn else 64463b73463SBrian Somers /* XXX missing return value check */ 64563b73463SBrian Somers Physical_Write(pppVars.physical, &ch, n); 6461ae349f5Scvs2svn break; 6471ae349f5Scvs2svn case 1: 6481ae349f5Scvs2svn switch (ch) { 6491ae349f5Scvs2svn case '?': 6501ae349f5Scvs2svn ShowHelp(); 6511ae349f5Scvs2svn break; 6521ae349f5Scvs2svn case 'p': 6531ae349f5Scvs2svn 6541ae349f5Scvs2svn /* 6551ae349f5Scvs2svn * XXX: Should check carrier. 6561ae349f5Scvs2svn */ 6571ae349f5Scvs2svn if (LcpFsm.state <= ST_CLOSED) 6581ae349f5Scvs2svn PacketMode(0); 6591ae349f5Scvs2svn break; 6601ae349f5Scvs2svn case '.': 6611ae349f5Scvs2svn TermMode = 1; 6621ae349f5Scvs2svn aft_cmd = 1; 6631ae349f5Scvs2svn TtyCommandMode(1); 6641ae349f5Scvs2svn break; 6651ae349f5Scvs2svn case 't': 6661ae349f5Scvs2svn if (LogIsKept(LogDEBUG)) { 6671ae349f5Scvs2svn ShowTimers(); 6681ae349f5Scvs2svn break; 6691ae349f5Scvs2svn } 6701ae349f5Scvs2svn case 'm': 6711ae349f5Scvs2svn if (LogIsKept(LogDEBUG)) { 6721ae349f5Scvs2svn ShowMemMap(NULL); 6731ae349f5Scvs2svn break; 6741ae349f5Scvs2svn } 6751ae349f5Scvs2svn default: 67663b73463SBrian Somers if (Physical_Write(pppVars.physical, &ch, n) < 0) 6771ae349f5Scvs2svn LogPrintf(LogERROR, "error writing to modem.\n"); 6781ae349f5Scvs2svn break; 6791ae349f5Scvs2svn } 6801ae349f5Scvs2svn ttystate = 0; 6811ae349f5Scvs2svn break; 6821ae349f5Scvs2svn } 6831ae349f5Scvs2svn } 6841ae349f5Scvs2svn } 6851ae349f5Scvs2svn 6861ae349f5Scvs2svn 6871ae349f5Scvs2svn /* 6881ae349f5Scvs2svn * Here, we'll try to detect HDLC frame 6891ae349f5Scvs2svn */ 6901ae349f5Scvs2svn 6911ae349f5Scvs2svn static const char *FrameHeaders[] = { 6921ae349f5Scvs2svn "\176\377\003\300\041", 6931ae349f5Scvs2svn "\176\377\175\043\300\041", 6941ae349f5Scvs2svn "\176\177\175\043\100\041", 6951ae349f5Scvs2svn "\176\175\337\175\043\300\041", 6961ae349f5Scvs2svn "\176\175\137\175\043\100\041", 6971ae349f5Scvs2svn NULL, 6981ae349f5Scvs2svn }; 6991ae349f5Scvs2svn 7001ae349f5Scvs2svn static const u_char * 70163b73463SBrian Somers HdlcDetect(struct physical *physical, u_char * cp, int n) 7021ae349f5Scvs2svn { 7031ae349f5Scvs2svn const char *ptr, *fp, **hp; 7041ae349f5Scvs2svn 7051ae349f5Scvs2svn cp[n] = '\0'; /* be sure to null terminated */ 7061ae349f5Scvs2svn ptr = NULL; 7071ae349f5Scvs2svn for (hp = FrameHeaders; *hp; hp++) { 7081ae349f5Scvs2svn fp = *hp; 70963b73463SBrian Somers if (Physical_IsSync(physical)) 7101ae349f5Scvs2svn fp++; 7111ae349f5Scvs2svn ptr = strstr((char *) cp, fp); 7121ae349f5Scvs2svn if (ptr) 7131ae349f5Scvs2svn break; 7141ae349f5Scvs2svn } 7151ae349f5Scvs2svn return ((const u_char *) ptr); 7161ae349f5Scvs2svn } 7171ae349f5Scvs2svn 7181ae349f5Scvs2svn static struct pppTimer RedialTimer; 7191ae349f5Scvs2svn 7201ae349f5Scvs2svn static void 7211ae349f5Scvs2svn RedialTimeout(void *v) 7221ae349f5Scvs2svn { 7231ae349f5Scvs2svn StopTimer(&RedialTimer); 7241ae349f5Scvs2svn LogPrintf(LogPHASE, "Redialing timer expired.\n"); 7251ae349f5Scvs2svn } 7261ae349f5Scvs2svn 7271ae349f5Scvs2svn static void 7281ae349f5Scvs2svn StartRedialTimer(int Timeout) 7291ae349f5Scvs2svn { 7301ae349f5Scvs2svn StopTimer(&RedialTimer); 7311ae349f5Scvs2svn 7321ae349f5Scvs2svn if (Timeout) { 7331ae349f5Scvs2svn RedialTimer.state = TIMER_STOPPED; 7341ae349f5Scvs2svn 7351ae349f5Scvs2svn if (Timeout > 0) 7361ae349f5Scvs2svn RedialTimer.load = Timeout * SECTICKS; 7371ae349f5Scvs2svn else 7381ae349f5Scvs2svn RedialTimer.load = (random() % REDIAL_PERIOD) * SECTICKS; 7391ae349f5Scvs2svn 7401ae349f5Scvs2svn LogPrintf(LogPHASE, "Enter pause (%d) for redialing.\n", 7411ae349f5Scvs2svn RedialTimer.load / SECTICKS); 7421ae349f5Scvs2svn 7431ae349f5Scvs2svn RedialTimer.func = RedialTimeout; 7441ae349f5Scvs2svn StartTimer(&RedialTimer); 7451ae349f5Scvs2svn } 7461ae349f5Scvs2svn } 7471ae349f5Scvs2svn 7481ae349f5Scvs2svn #define IN_SIZE sizeof(struct sockaddr_in) 7491ae349f5Scvs2svn #define UN_SIZE sizeof(struct sockaddr_in) 7501ae349f5Scvs2svn #define ADDRSZ (IN_SIZE > UN_SIZE ? IN_SIZE : UN_SIZE) 7511ae349f5Scvs2svn 7521ae349f5Scvs2svn static void 7531ae349f5Scvs2svn DoLoop(void) 7541ae349f5Scvs2svn { 7551ae349f5Scvs2svn fd_set rfds, wfds, efds; 7561ae349f5Scvs2svn int pri, i, n, wfd, nfds; 7571ae349f5Scvs2svn char hisaddr[ADDRSZ]; 7581ae349f5Scvs2svn struct sockaddr *sa = (struct sockaddr *)hisaddr; 7591ae349f5Scvs2svn struct sockaddr_in *sin = (struct sockaddr_in *)hisaddr; 7601ae349f5Scvs2svn struct timeval timeout, *tp; 7611ae349f5Scvs2svn int ssize = ADDRSZ; 7621ae349f5Scvs2svn const u_char *cp; 7631ae349f5Scvs2svn int tries; 7641ae349f5Scvs2svn int qlen; 7651ae349f5Scvs2svn int res; 7661ae349f5Scvs2svn struct tun_data tun; 7671ae349f5Scvs2svn #define rbuff tun.data 7681ae349f5Scvs2svn 7691ae349f5Scvs2svn if (mode & MODE_DIRECT) { 7701ae349f5Scvs2svn LogPrintf(LogDEBUG, "Opening modem\n"); 77163b73463SBrian Somers if (OpenModem(pppVars.physical) < 0) 7721ae349f5Scvs2svn return; 7731ae349f5Scvs2svn LogPrintf(LogPHASE, "Packet mode enabled\n"); 7741ae349f5Scvs2svn PacketMode(VarOpenMode); 7751ae349f5Scvs2svn } else if (mode & MODE_DEDICATED) { 77663b73463SBrian Somers if (!Physical_IsActive(pppVars.physical)) 77763b73463SBrian Somers while (OpenModem(pppVars.physical) < 0) 7781ae349f5Scvs2svn nointr_sleep(VarReconnectTimer); 7791ae349f5Scvs2svn } 7801ae349f5Scvs2svn fflush(VarTerm); 7811ae349f5Scvs2svn 7821ae349f5Scvs2svn timeout.tv_sec = 0; 7831ae349f5Scvs2svn timeout.tv_usec = 0; 7841ae349f5Scvs2svn reconnectState = RECON_UNKNOWN; 7851ae349f5Scvs2svn 7861ae349f5Scvs2svn if (mode & MODE_BACKGROUND) 7871ae349f5Scvs2svn dial_up = 1; /* Bring the line up */ 7881ae349f5Scvs2svn else 7891ae349f5Scvs2svn dial_up = 0; /* XXXX */ 7901ae349f5Scvs2svn tries = 0; 7911ae349f5Scvs2svn for (;;) { 7921ae349f5Scvs2svn nfds = 0; 7931ae349f5Scvs2svn FD_ZERO(&rfds); 7941ae349f5Scvs2svn FD_ZERO(&wfds); 7951ae349f5Scvs2svn FD_ZERO(&efds); 7961ae349f5Scvs2svn 7971ae349f5Scvs2svn /* 7981ae349f5Scvs2svn * If the link is down and we're in DDIAL mode, bring it back up. 7991ae349f5Scvs2svn */ 8001ae349f5Scvs2svn if (mode & MODE_DDIAL && LcpFsm.state <= ST_CLOSED) 8011ae349f5Scvs2svn dial_up = 1; 8021ae349f5Scvs2svn 8031ae349f5Scvs2svn /* 8041ae349f5Scvs2svn * If we lost carrier and want to re-establish the connection due to the 8051ae349f5Scvs2svn * "set reconnect" value, we'd better bring the line back up. 8061ae349f5Scvs2svn */ 8071ae349f5Scvs2svn if (LcpFsm.state <= ST_CLOSED) { 8081ae349f5Scvs2svn if (!dial_up && reconnectState == RECON_TRUE) { 8091ae349f5Scvs2svn if (++reconnectCount <= VarReconnectTries) { 8101ae349f5Scvs2svn LogPrintf(LogPHASE, "Connection lost, re-establish (%d/%d)\n", 8111ae349f5Scvs2svn reconnectCount, VarReconnectTries); 8121ae349f5Scvs2svn StartRedialTimer(VarReconnectTimer); 8131ae349f5Scvs2svn dial_up = 1; 8141ae349f5Scvs2svn } else { 8151ae349f5Scvs2svn if (VarReconnectTries) 8161ae349f5Scvs2svn LogPrintf(LogPHASE, "Connection lost, maximum (%d) times\n", 8171ae349f5Scvs2svn VarReconnectTries); 8181ae349f5Scvs2svn reconnectCount = 0; 8191ae349f5Scvs2svn if (mode & MODE_BACKGROUND) 8201ae349f5Scvs2svn Cleanup(EX_DEAD); 8211ae349f5Scvs2svn } 8221ae349f5Scvs2svn reconnectState = RECON_ENVOKED; 8231ae349f5Scvs2svn } else if (mode & MODE_DEDICATED) 8241ae349f5Scvs2svn PacketMode(VarOpenMode); 8251ae349f5Scvs2svn } 8261ae349f5Scvs2svn 8271ae349f5Scvs2svn /* 8281ae349f5Scvs2svn * If Ip packet for output is enqueued and require dial up, Just do it! 8291ae349f5Scvs2svn */ 8301ae349f5Scvs2svn if (dial_up && RedialTimer.state != TIMER_RUNNING) { 83163b73463SBrian Somers LogPrintf(LogDEBUG, "going to dial: modem = %d\n", 83263b73463SBrian Somers Physical_GetFD(pppVars.physical)); 83363b73463SBrian Somers if (OpenModem(pppVars.physical) < 0) { 8341ae349f5Scvs2svn tries++; 8351ae349f5Scvs2svn if (!(mode & MODE_DDIAL) && VarDialTries) 8361ae349f5Scvs2svn LogPrintf(LogCHAT, "Failed to open modem (attempt %u of %d)\n", 8371ae349f5Scvs2svn tries, VarDialTries); 8381ae349f5Scvs2svn else 8391ae349f5Scvs2svn LogPrintf(LogCHAT, "Failed to open modem (attempt %u)\n", tries); 8401ae349f5Scvs2svn 8411ae349f5Scvs2svn if (!(mode & MODE_DDIAL) && VarDialTries && tries >= VarDialTries) { 8421ae349f5Scvs2svn if (mode & MODE_BACKGROUND) 8431ae349f5Scvs2svn Cleanup(EX_DIAL); /* Can't get the modem */ 8441ae349f5Scvs2svn dial_up = 0; 8451ae349f5Scvs2svn reconnectState = RECON_UNKNOWN; 8461ae349f5Scvs2svn reconnectCount = 0; 8471ae349f5Scvs2svn tries = 0; 8481ae349f5Scvs2svn } else 8491ae349f5Scvs2svn StartRedialTimer(VarRedialTimeout); 8501ae349f5Scvs2svn } else { 8511ae349f5Scvs2svn tries++; /* Tries are per number, not per list of 8521ae349f5Scvs2svn * numbers. */ 8531ae349f5Scvs2svn if (!(mode & MODE_DDIAL) && VarDialTries) 8541ae349f5Scvs2svn LogPrintf(LogCHAT, "Dial attempt %u of %d\n", tries, VarDialTries); 8551ae349f5Scvs2svn else 8561ae349f5Scvs2svn LogPrintf(LogCHAT, "Dial attempt %u\n", tries); 8571ae349f5Scvs2svn 85863b73463SBrian Somers if ((res = DialModem(pppVars.physical)) == EX_DONE) { 85963b73463SBrian Somers ModemTimeout(pppVars.physical); 8601ae349f5Scvs2svn PacketMode(VarOpenMode); 8611ae349f5Scvs2svn dial_up = 0; 8621ae349f5Scvs2svn reconnectState = RECON_UNKNOWN; 8631ae349f5Scvs2svn tries = 0; 8641ae349f5Scvs2svn } else { 8651ae349f5Scvs2svn if (mode & MODE_BACKGROUND) { 8661ae349f5Scvs2svn if (VarNextPhone == NULL || res == EX_SIG) 8671ae349f5Scvs2svn Cleanup(EX_DIAL); /* Tried all numbers - no luck */ 8681ae349f5Scvs2svn else 8691ae349f5Scvs2svn /* Try all numbers in background mode */ 8701ae349f5Scvs2svn StartRedialTimer(VarRedialNextTimeout); 8711ae349f5Scvs2svn } else if (!(mode & MODE_DDIAL) && 8721ae349f5Scvs2svn ((VarDialTries && tries >= VarDialTries) || 8731ae349f5Scvs2svn res == EX_SIG)) { 8741ae349f5Scvs2svn /* I give up ! Can't get through :( */ 8751ae349f5Scvs2svn StartRedialTimer(VarRedialTimeout); 8761ae349f5Scvs2svn dial_up = 0; 8771ae349f5Scvs2svn reconnectState = RECON_UNKNOWN; 8781ae349f5Scvs2svn reconnectCount = 0; 8791ae349f5Scvs2svn tries = 0; 8801ae349f5Scvs2svn } else if (VarNextPhone == NULL) 8811ae349f5Scvs2svn /* Dial failed. Keep quite during redial wait period. */ 8821ae349f5Scvs2svn StartRedialTimer(VarRedialTimeout); 8831ae349f5Scvs2svn else 8841ae349f5Scvs2svn StartRedialTimer(VarRedialNextTimeout); 8851ae349f5Scvs2svn } 8861ae349f5Scvs2svn } 8871ae349f5Scvs2svn } 88863b73463SBrian Somers qlen = ModemQlen(pppVars.physical); 8891ae349f5Scvs2svn 8901ae349f5Scvs2svn if (qlen == 0) { 89163b73463SBrian Somers IpStartOutput(pppVars.physical); 89263b73463SBrian Somers qlen = ModemQlen(pppVars.physical); 8931ae349f5Scvs2svn } 89463b73463SBrian Somers if (Physical_IsActive(pppVars.physical)) { 89563b73463SBrian Somers /* XXX-ML this should probably be abstracted */ 89663b73463SBrian Somers if (Physical_GetFD(pppVars.physical) + 1 > nfds) 89763b73463SBrian Somers nfds = Physical_GetFD(pppVars.physical) + 1; 89863b73463SBrian Somers Physical_FD_SET(pppVars.physical, &rfds); 89963b73463SBrian Somers Physical_FD_SET(pppVars.physical, &efds); 9001ae349f5Scvs2svn if (qlen > 0) { 90163b73463SBrian Somers Physical_FD_SET(pppVars.physical, &wfds); 9021ae349f5Scvs2svn } 9031ae349f5Scvs2svn } 9041ae349f5Scvs2svn if (server >= 0) { 9051ae349f5Scvs2svn if (server + 1 > nfds) 9061ae349f5Scvs2svn nfds = server + 1; 9071ae349f5Scvs2svn FD_SET(server, &rfds); 9081ae349f5Scvs2svn } 9091ae349f5Scvs2svn 9101ae349f5Scvs2svn #ifndef SIGALRM 9111ae349f5Scvs2svn /* 9121ae349f5Scvs2svn * *** IMPORTANT *** 9131ae349f5Scvs2svn * CPU is serviced every TICKUNIT micro seconds. This value must be chosen 9141ae349f5Scvs2svn * with great care. If this values is too big, it results in loss of 9151ae349f5Scvs2svn * characters from the modem and poor response. If this value is too 9161ae349f5Scvs2svn * small, ppp eats too much CPU time. 9171ae349f5Scvs2svn */ 9181ae349f5Scvs2svn usleep(TICKUNIT); 9191ae349f5Scvs2svn TimerService(); 9201ae349f5Scvs2svn #else 9211ae349f5Scvs2svn handle_signals(); 9221ae349f5Scvs2svn #endif 9231ae349f5Scvs2svn 9241ae349f5Scvs2svn /* If there are aren't many packets queued, look for some more. */ 9251ae349f5Scvs2svn if (qlen < 20 && tun_in >= 0) { 9261ae349f5Scvs2svn if (tun_in + 1 > nfds) 9271ae349f5Scvs2svn nfds = tun_in + 1; 9281ae349f5Scvs2svn FD_SET(tun_in, &rfds); 9291ae349f5Scvs2svn } 9301ae349f5Scvs2svn if (netfd >= 0) { 9311ae349f5Scvs2svn if (netfd + 1 > nfds) 9321ae349f5Scvs2svn nfds = netfd + 1; 9331ae349f5Scvs2svn FD_SET(netfd, &rfds); 9341ae349f5Scvs2svn FD_SET(netfd, &efds); 9351ae349f5Scvs2svn } 9361ae349f5Scvs2svn #ifndef SIGALRM 9371ae349f5Scvs2svn 9381ae349f5Scvs2svn /* 9391ae349f5Scvs2svn * Normally, select() will not block because modem is writable. In AUTO 9401ae349f5Scvs2svn * mode, select will block until we find packet from tun 9411ae349f5Scvs2svn */ 9421ae349f5Scvs2svn tp = (RedialTimer.state == TIMER_RUNNING) ? &timeout : NULL; 9431ae349f5Scvs2svn i = select(nfds, &rfds, &wfds, &efds, tp); 9441ae349f5Scvs2svn #else 9451ae349f5Scvs2svn 9461ae349f5Scvs2svn /* 9471ae349f5Scvs2svn * When SIGALRM timer is running, a select function will be return -1 and 9481ae349f5Scvs2svn * EINTR after a Time Service signal hundler is done. If the redial 9491ae349f5Scvs2svn * timer is not running and we are trying to dial, poll with a 0 value 9501ae349f5Scvs2svn * timer. 9511ae349f5Scvs2svn */ 9521ae349f5Scvs2svn tp = (dial_up && RedialTimer.state != TIMER_RUNNING) ? &timeout : NULL; 9531ae349f5Scvs2svn i = select(nfds, &rfds, &wfds, &efds, tp); 9541ae349f5Scvs2svn #endif 9551ae349f5Scvs2svn 9561ae349f5Scvs2svn if (i == 0) { 9571ae349f5Scvs2svn continue; 9581ae349f5Scvs2svn } 9591ae349f5Scvs2svn if (i < 0) { 9601ae349f5Scvs2svn if (errno == EINTR) { 9611ae349f5Scvs2svn handle_signals(); 9621ae349f5Scvs2svn continue; 9631ae349f5Scvs2svn } 9641ae349f5Scvs2svn LogPrintf(LogERROR, "DoLoop: select(): %s\n", strerror(errno)); 9651ae349f5Scvs2svn break; 9661ae349f5Scvs2svn } 96763b73463SBrian Somers if ((netfd >= 0 && FD_ISSET(netfd, &efds)) || 96863b73463SBrian Somers (Physical_FD_ISSET(pppVars.physical, &efds))) { 9691ae349f5Scvs2svn LogPrintf(LogALERT, "Exception detected.\n"); 9701ae349f5Scvs2svn break; 9711ae349f5Scvs2svn } 9721ae349f5Scvs2svn if (server >= 0 && FD_ISSET(server, &rfds)) { 9731ae349f5Scvs2svn wfd = accept(server, sa, &ssize); 9741ae349f5Scvs2svn if (wfd < 0) { 9751ae349f5Scvs2svn LogPrintf(LogERROR, "DoLoop: accept(): %s\n", strerror(errno)); 9761ae349f5Scvs2svn continue; 9771ae349f5Scvs2svn } 9781ae349f5Scvs2svn switch (sa->sa_family) { 9791ae349f5Scvs2svn case AF_LOCAL: 9801ae349f5Scvs2svn LogPrintf(LogPHASE, "Connected to local client.\n"); 9811ae349f5Scvs2svn break; 9821ae349f5Scvs2svn case AF_INET: 9831ae349f5Scvs2svn if (ntohs(sin->sin_port) < 1024) { 9841ae349f5Scvs2svn LogPrintf(LogALERT, "Rejected client connection from %s:%u" 9851ae349f5Scvs2svn "(invalid port number) !\n", 9861ae349f5Scvs2svn inet_ntoa(sin->sin_addr), ntohs(sin->sin_port)); 9871ae349f5Scvs2svn close(wfd); 9881ae349f5Scvs2svn continue; 9891ae349f5Scvs2svn } 9901ae349f5Scvs2svn LogPrintf(LogPHASE, "Connected to client from %s:%u\n", 9911ae349f5Scvs2svn inet_ntoa(sin->sin_addr), sin->sin_port); 9921ae349f5Scvs2svn break; 9931ae349f5Scvs2svn default: 9941ae349f5Scvs2svn write(wfd, "Unrecognised access !\n", 22); 9951ae349f5Scvs2svn close(wfd); 9961ae349f5Scvs2svn continue; 9971ae349f5Scvs2svn } 9981ae349f5Scvs2svn if (netfd >= 0) { 9991ae349f5Scvs2svn write(wfd, "Connection already in use.\n", 27); 10001ae349f5Scvs2svn close(wfd); 10011ae349f5Scvs2svn continue; 10021ae349f5Scvs2svn } 10031ae349f5Scvs2svn netfd = wfd; 10041ae349f5Scvs2svn VarTerm = fdopen(netfd, "a+"); 10051ae349f5Scvs2svn LocalAuthInit(); 10061ae349f5Scvs2svn IsInteractive(1); 10071ae349f5Scvs2svn Prompt(); 10081ae349f5Scvs2svn } 10091ae349f5Scvs2svn if (netfd >= 0 && FD_ISSET(netfd, &rfds)) 10101ae349f5Scvs2svn /* something to read from tty */ 10111ae349f5Scvs2svn ReadTty(); 101263b73463SBrian Somers if (Physical_FD_ISSET(pppVars.physical, &wfds)) { 10131ae349f5Scvs2svn /* ready to write into modem */ 101463b73463SBrian Somers ModemStartOutput(pppVars.physical); 101563b73463SBrian Somers if (!Physical_IsActive(pppVars.physical)) 10161ae349f5Scvs2svn dial_up = 1; 10171ae349f5Scvs2svn } 101863b73463SBrian Somers if (Physical_FD_ISSET(pppVars.physical, &rfds)) { 10191ae349f5Scvs2svn /* something to read from modem */ 10201ae349f5Scvs2svn if (LcpFsm.state <= ST_CLOSED) 10211ae349f5Scvs2svn nointr_usleep(10000); 102263b73463SBrian Somers n = Physical_Read(pppVars.physical, rbuff, sizeof rbuff); 10231ae349f5Scvs2svn if ((mode & MODE_DIRECT) && n <= 0) { 10241ae349f5Scvs2svn DownConnection(); 10251ae349f5Scvs2svn } else 10261ae349f5Scvs2svn LogDumpBuff(LogASYNC, "ReadFromModem", rbuff, n); 10271ae349f5Scvs2svn 10281ae349f5Scvs2svn if (LcpFsm.state <= ST_CLOSED) { 10291ae349f5Scvs2svn /* 10301ae349f5Scvs2svn * In dedicated mode, we just discard input until LCP is started. 10311ae349f5Scvs2svn */ 10321ae349f5Scvs2svn if (!(mode & MODE_DEDICATED)) { 103363b73463SBrian Somers cp = HdlcDetect(pppVars.physical, rbuff, n); 10341ae349f5Scvs2svn if (cp) { 10351ae349f5Scvs2svn /* 10361ae349f5Scvs2svn * LCP packet is detected. Turn ourselves into packet mode. 10371ae349f5Scvs2svn */ 10381ae349f5Scvs2svn if (cp != rbuff) { 103963b73463SBrian Somers /* XXX missing return value checks */ 104063b73463SBrian Somers Physical_Write(pppVars.physical, rbuff, cp - rbuff); 104163b73463SBrian Somers Physical_Write(pppVars.physical, "\r\n", 2); 10421ae349f5Scvs2svn } 10431ae349f5Scvs2svn PacketMode(0); 10441ae349f5Scvs2svn } else 10451ae349f5Scvs2svn write(fileno(VarTerm), rbuff, n); 10461ae349f5Scvs2svn } 10471ae349f5Scvs2svn } else { 10481ae349f5Scvs2svn if (n > 0) 104963b73463SBrian Somers AsyncInput(rbuff, n, pppVars.physical); 10501ae349f5Scvs2svn } 10511ae349f5Scvs2svn } 10521ae349f5Scvs2svn if (tun_in >= 0 && FD_ISSET(tun_in, &rfds)) { /* something to read 10531ae349f5Scvs2svn * from tun */ 10541ae349f5Scvs2svn n = read(tun_in, &tun, sizeof tun); 10551ae349f5Scvs2svn if (n < 0) { 10561ae349f5Scvs2svn LogPrintf(LogERROR, "read from tun: %s\n", strerror(errno)); 10571ae349f5Scvs2svn continue; 10581ae349f5Scvs2svn } 10591ae349f5Scvs2svn n -= sizeof tun - sizeof tun.data; 10601ae349f5Scvs2svn if (n <= 0) { 10611ae349f5Scvs2svn LogPrintf(LogERROR, "read from tun: Only %d bytes read\n", n); 10621ae349f5Scvs2svn continue; 10631ae349f5Scvs2svn } 10641ae349f5Scvs2svn if (!tun_check_header(tun, AF_INET)) 10651ae349f5Scvs2svn continue; 10661ae349f5Scvs2svn if (((struct ip *) rbuff)->ip_dst.s_addr == IpcpInfo.want_ipaddr.s_addr) { 10671ae349f5Scvs2svn /* we've been asked to send something addressed *to* us :( */ 10681ae349f5Scvs2svn if (VarLoopback) { 10691ae349f5Scvs2svn pri = PacketCheck(rbuff, n, FL_IN); 10701ae349f5Scvs2svn if (pri >= 0) { 10711ae349f5Scvs2svn struct mbuf *bp; 10721ae349f5Scvs2svn 10731ae349f5Scvs2svn #ifndef NOALIAS 10741ae349f5Scvs2svn if (mode & MODE_ALIAS) { 10751ae349f5Scvs2svn VarPacketAliasIn(rbuff, sizeof rbuff); 10761ae349f5Scvs2svn n = ntohs(((struct ip *) rbuff)->ip_len); 10771ae349f5Scvs2svn } 10781ae349f5Scvs2svn #endif 10791ae349f5Scvs2svn bp = mballoc(n, MB_IPIN); 10801ae349f5Scvs2svn memcpy(MBUF_CTOP(bp), rbuff, n); 10811ae349f5Scvs2svn IpInput(bp); 10821ae349f5Scvs2svn LogPrintf(LogDEBUG, "Looped back packet addressed to myself\n"); 10831ae349f5Scvs2svn } 10841ae349f5Scvs2svn continue; 10851ae349f5Scvs2svn } else 10861ae349f5Scvs2svn LogPrintf(LogDEBUG, "Oops - forwarding packet addressed to myself\n"); 10871ae349f5Scvs2svn } 10881ae349f5Scvs2svn 10891ae349f5Scvs2svn /* 10901ae349f5Scvs2svn * Process on-demand dialup. Output packets are queued within tunnel 10911ae349f5Scvs2svn * device until IPCP is opened. 10921ae349f5Scvs2svn */ 10931ae349f5Scvs2svn if (LcpFsm.state <= ST_CLOSED && (mode & MODE_AUTO) && 10941ae349f5Scvs2svn (pri = PacketCheck(rbuff, n, FL_DIAL)) >= 0) 10951ae349f5Scvs2svn dial_up = 1; 10961ae349f5Scvs2svn 10971ae349f5Scvs2svn pri = PacketCheck(rbuff, n, FL_OUT); 10981ae349f5Scvs2svn if (pri >= 0) { 10991ae349f5Scvs2svn #ifndef NOALIAS 11001ae349f5Scvs2svn if (mode & MODE_ALIAS) { 11011ae349f5Scvs2svn VarPacketAliasOut(rbuff, sizeof rbuff); 11021ae349f5Scvs2svn n = ntohs(((struct ip *) rbuff)->ip_len); 11031ae349f5Scvs2svn } 11041ae349f5Scvs2svn #endif 11051ae349f5Scvs2svn IpEnqueue(pri, rbuff, n); 11061ae349f5Scvs2svn } 11071ae349f5Scvs2svn } 11081ae349f5Scvs2svn } 11091ae349f5Scvs2svn LogPrintf(LogDEBUG, "Job (DoLoop) done.\n"); 11101ae349f5Scvs2svn } 1111