main.c revision 37018
16059Samurai/* 26059Samurai * User Process PPP 36059Samurai * 46059Samurai * Written by Toshiharu OHNO (tony-o@iij.ad.jp) 56059Samurai * 66059Samurai * Copyright (C) 1993, Internet Initiative Japan, Inc. All rights reserverd. 76059Samurai * 86059Samurai * Redistribution and use in source and binary forms are permitted 96059Samurai * provided that the above copyright notice and this paragraph are 106059Samurai * duplicated in all such forms and that any documentation, 116059Samurai * advertising materials, and other materials related to such 126059Samurai * distribution and use acknowledge that the software was developed 136059Samurai * by the Internet Initiative Japan, Inc. The name of the 146059Samurai * IIJ may not be used to endorse or promote products derived 156059Samurai * from this software without specific prior written permission. 166059Samurai * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR 176059Samurai * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED 186059Samurai * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE. 196059Samurai * 2037018Sbrian * $Id: main.c,v 1.133 1998/06/15 19:06:50 brian Exp $ 218857Srgrimes * 226059Samurai * TODO: 236059Samurai */ 2436285Sbrian 2536452Sbrian#include <sys/types.h> 2630715Sbrian#include <sys/socket.h> 2730715Sbrian#include <netinet/in.h> 2830715Sbrian#include <netinet/in_systm.h> 2930715Sbrian#include <netinet/ip.h> 3036285Sbrian#include <sys/un.h> 3136285Sbrian#include <net/if_tun.h> 3230715Sbrian 3330715Sbrian#include <errno.h> 346059Samurai#include <fcntl.h> 3511336Samurai#include <paths.h> 3630715Sbrian#include <signal.h> 3730715Sbrian#include <stdio.h> 3830715Sbrian#include <string.h> 396059Samurai#include <sys/time.h> 406059Samurai#include <termios.h> 4118786Sjkh#include <unistd.h> 4230715Sbrian 4330715Sbrian#include "mbuf.h" 4430715Sbrian#include "log.h" 4530715Sbrian#include "defs.h" 4631061Sbrian#include "id.h" 4730715Sbrian#include "timer.h" 4830715Sbrian#include "fsm.h" 4936285Sbrian#include "lqr.h" 506059Samurai#include "hdlc.h" 5131514Sbrian#include "lcp.h" 5213389Sphk#include "ccp.h" 5336285Sbrian#include "iplist.h" 5436285Sbrian#include "throughput.h" 5536285Sbrian#include "slcompress.h" 566059Samurai#include "ipcp.h" 5736285Sbrian#include "filter.h" 5836285Sbrian#include "descriptor.h" 5936285Sbrian#include "link.h" 6036285Sbrian#include "mp.h" 6136285Sbrian#include "bundle.h" 6226142Sbrian#include "loadalias.h" 636735Samurai#include "auth.h" 6413389Sphk#include "systems.h" 6513389Sphk#include "ip.h" 6623840Sbrian#include "sig.h" 6730715Sbrian#include "main.h" 6831195Sbrian#include "tun.h" 6936285Sbrian#include "server.h" 7036285Sbrian#include "prompt.h" 7136285Sbrian#include "chat.h" 7236285Sbrian#include "chap.h" 7336285Sbrian#include "datalink.h" 746059Samurai 756735Samurai#ifndef O_NONBLOCK 766735Samurai#ifdef O_NDELAY 776735Samurai#define O_NONBLOCK O_NDELAY 786735Samurai#endif 796735Samurai#endif 806735Samurai 8136431Sbrianstatic void DoLoop(struct bundle *); 8230715Sbrianstatic void TerminalStop(int); 8331343Sbrianstatic const char *ex_desc(int); 8430715Sbrian 8536285Sbrianstatic struct bundle *SignalBundle; 8636285Sbrianstatic struct prompt *SignalPrompt; 876059Samurai 8810528Samuraivoid 8936285SbrianCleanup(int excode) 906059Samurai{ 9136285Sbrian SignalBundle->CleaningUp = 1; 9236285Sbrian if (bundle_Phase(SignalBundle) != PHASE_DEAD) 9337007Sbrian bundle_Close(SignalBundle, NULL, CLOSE_STAYDOWN); 946059Samurai} 956059Samurai 966059Samuraivoid 9736285SbrianAbortProgram(int excode) 986059Samurai{ 9936285Sbrian server_Close(SignalBundle); 10036285Sbrian log_Printf(LogPHASE, "PPP Terminated (%s).\n", ex_desc(excode)); 10137007Sbrian bundle_Close(SignalBundle, NULL, CLOSE_STAYDOWN); 10236285Sbrian bundle_Destroy(SignalBundle); 10336285Sbrian log_Close(); 1046059Samurai exit(excode); 1056059Samurai} 1066059Samurai 1076059Samuraistatic void 10828679SbrianCloseConnection(int signo) 1096059Samurai{ 11026858Sbrian /* NOTE, these are manual, we've done a setsid() */ 11136285Sbrian sig_signal(SIGINT, SIG_IGN); 11236285Sbrian log_Printf(LogPHASE, "Caught signal %d, abort connection(s)\n", signo); 11337018Sbrian bundle_Down(SignalBundle, CLOSE_STAYDOWN); 11436285Sbrian sig_signal(SIGINT, CloseConnection); 1156059Samurai} 1166059Samurai 1176059Samuraistatic void 11828679SbrianCloseSession(int signo) 1196059Samurai{ 12036285Sbrian log_Printf(LogPHASE, "Signal %d, terminate.\n", signo); 12128679Sbrian Cleanup(EX_TERM); 1226059Samurai} 1236059Samurai 12436285Sbrianstatic pid_t BGPid = 0; 12536285Sbrian 12610528Samuraistatic void 12736285SbrianKillChild(int signo) 12810528Samurai{ 12936285Sbrian log_Printf(LogPHASE, "Parent: Signal %d\n", signo); 13036285Sbrian kill(BGPid, SIGINT); 13110528Samurai} 13210528Samurai 13310528Samuraistatic void 13436285SbrianTerminalCont(int signo) 13510528Samurai{ 13636285Sbrian signal(SIGCONT, SIG_DFL); 13736285Sbrian prompt_Continue(SignalPrompt); 13810528Samurai} 13910528Samurai 14026940Sbrianstatic void 14136285SbrianTerminalStop(int signo) 14226940Sbrian{ 14336285Sbrian prompt_Suspend(SignalPrompt); 14436285Sbrian signal(SIGCONT, TerminalCont); 14536285Sbrian raise(SIGSTOP); 14626940Sbrian} 14726940Sbrian 14831081Sbrianstatic void 14931081SbrianBringDownServer(int signo) 15031081Sbrian{ 15136285Sbrian /* Drops all child prompts too ! */ 15236285Sbrian server_Close(SignalBundle); 15331081Sbrian} 15431081Sbrian 15531343Sbrianstatic const char * 15625908Sbrianex_desc(int ex) 15725908Sbrian{ 15837010Sbrian static char num[12]; /* Used immediately if returned */ 15931343Sbrian static const char *desc[] = { 16031343Sbrian "normal", "start", "sock", "modem", "dial", "dead", "done", 16131343Sbrian "reboot", "errdead", "hangup", "term", "nodial", "nologin" 16231343Sbrian }; 16310528Samurai 16431962Sbrian if (ex >= 0 && ex < sizeof desc / sizeof *desc) 16525908Sbrian return desc[ex]; 16625908Sbrian snprintf(num, sizeof num, "%d", ex); 16725908Sbrian return num; 16825908Sbrian} 16925908Sbrian 17030715Sbrianstatic void 17131343SbrianUsage(void) 1726059Samurai{ 17320120Snate fprintf(stderr, 17431343Sbrian "Usage: ppp [-auto | -background | -direct | -dedicated | -ddial ]" 17531343Sbrian#ifndef NOALIAS 17631343Sbrian " [ -alias ]" 17731343Sbrian#endif 17831343Sbrian " [system]\n"); 1796059Samurai exit(EX_START); 1806059Samurai} 1816059Samurai 18231197Sbrianstatic char * 18336285SbrianProcessArgs(int argc, char **argv, int *mode) 1846059Samurai{ 18536465Sbrian int optc, labelrequired, newmode; 1866059Samurai char *cp; 1876059Samurai 18836285Sbrian optc = labelrequired = 0; 18936465Sbrian *mode = PHYS_INTERACTIVE; 1906059Samurai while (argc > 0 && **argv == '-') { 1916059Samurai cp = *argv + 1; 19236465Sbrian newmode = Nam2mode(cp); 19336465Sbrian switch (newmode) { 19436465Sbrian case PHYS_NONE: 19536465Sbrian if (strcmp(cp, "alias") == 0) { 19631343Sbrian#ifndef NOALIAS 19736465Sbrian if (alias_Load() != 0) 19836285Sbrian#endif 19936465Sbrian log_Printf(LogWARN, "Cannot load alias library\n"); 20036465Sbrian optc--; /* this option isn't exclusive */ 20136465Sbrian } else 20236465Sbrian Usage(); 20336465Sbrian break; 20436465Sbrian 20536465Sbrian case PHYS_ALL: 20636465Sbrian Usage(); 20736465Sbrian break; 20836465Sbrian 20936465Sbrian case PHYS_AUTO: 21036465Sbrian case PHYS_BACKGROUND: 21136465Sbrian case PHYS_DDIAL: 21236465Sbrian labelrequired = 1; 21336465Sbrian /* fall through */ 21436465Sbrian 21536465Sbrian default: 21636465Sbrian *mode = newmode; 21736465Sbrian } 2186059Samurai optc++; 21928679Sbrian argv++; 22028679Sbrian argc--; 2216059Samurai } 22236465Sbrian 2236059Samurai if (argc > 1) { 22436285Sbrian fprintf(stderr, "You may specify only one system label.\n"); 2256059Samurai exit(EX_START); 2266059Samurai } 2276059Samurai 2286059Samurai if (optc > 1) { 22936285Sbrian fprintf(stderr, "You may specify only one mode.\n"); 2306059Samurai exit(EX_START); 2316059Samurai } 23231197Sbrian 23336285Sbrian if (labelrequired && argc != 1) { 23436285Sbrian fprintf(stderr, "Destination system must be specified in" 23536285Sbrian " auto, background or ddial mode.\n"); 23636285Sbrian exit(EX_START); 23736285Sbrian } 23836285Sbrian 23931197Sbrian return argc == 1 ? *argv : NULL; /* Don't SetLabel yet ! */ 2406059Samurai} 2416059Samurai 24226940Sbrianint 24328679Sbrianmain(int argc, char **argv) 2446059Samurai{ 24531197Sbrian char *name, *label; 24636285Sbrian int nfds, mode; 24736285Sbrian struct bundle *bundle; 24836285Sbrian struct prompt *prompt; 24926516Sbrian 25031823Sbrian nfds = getdtablesize(); 25131823Sbrian if (nfds >= FD_SETSIZE) 25231823Sbrian /* 25331823Sbrian * If we've got loads of file descriptors, make sure they're all 25431823Sbrian * closed. If they aren't, we may end up with a seg fault when our 25531823Sbrian * `fd_set's get too big when select()ing ! 25631823Sbrian */ 25731823Sbrian while (--nfds > 2) 25831823Sbrian close(nfds); 25931823Sbrian 26030715Sbrian name = strrchr(argv[0], '/'); 26136285Sbrian log_Open(name ? name + 1 : argv[0]); 26226516Sbrian 26336467Sbrian label = ProcessArgs(argc - 1, argv + 1, &mode); 26431121Sbrian 26536285Sbrian#ifdef __FreeBSD__ 26636285Sbrian /* 26736285Sbrian * A FreeBSD hack to dodge a bug in the tty driver that drops output 26836285Sbrian * occasionally.... I must find the real reason some time. To display 26936285Sbrian * the dodgy behaviour, comment out this bit, make yourself a large 27036285Sbrian * routing table and then run ppp in interactive mode. The `show route' 27136285Sbrian * command will drop chunks of data !!! 27236285Sbrian */ 27336465Sbrian if (mode == PHYS_INTERACTIVE) { 27436285Sbrian close(STDIN_FILENO); 27536285Sbrian if (open(_PATH_TTY, O_RDONLY) != STDIN_FILENO) { 27636285Sbrian fprintf(stderr, "Cannot open %s for input !\n", _PATH_TTY); 27736285Sbrian return 2; 27836285Sbrian } 27936285Sbrian } 28036285Sbrian#endif 28136285Sbrian 28236285Sbrian /* Allow output for the moment (except in direct mode) */ 28336285Sbrian if (mode == PHYS_DIRECT) 28436285Sbrian prompt = NULL; 28536285Sbrian else { 28636285Sbrian SignalPrompt = prompt = prompt_Create(NULL, NULL, PROMPT_STD); 28736465Sbrian prompt_Printf(prompt, "Working in %s mode\n", mode2Nam(mode)); 28836285Sbrian } 28936285Sbrian 29031121Sbrian ID0init(); 29131158Sbrian if (ID0realuid() != 0) { 29231158Sbrian char conf[200], *ptr; 29331158Sbrian 29431158Sbrian snprintf(conf, sizeof conf, "%s/%s", _PATH_PPP, CONFFILE); 29531158Sbrian do { 29631158Sbrian if (!access(conf, W_OK)) { 29736285Sbrian log_Printf(LogALERT, "ppp: Access violation: Please protect %s\n", conf); 29831158Sbrian return -1; 29931158Sbrian } 30031158Sbrian ptr = conf + strlen(conf)-2; 30131158Sbrian while (ptr > conf && *ptr != '/') 30231158Sbrian *ptr-- = '\0'; 30331158Sbrian } while (ptr >= conf); 30431158Sbrian } 30531158Sbrian 30636285Sbrian if (!system_IsValid(label, prompt, mode)) { 30731121Sbrian fprintf(stderr, "You may not use ppp in this mode with this label\n"); 30836285Sbrian if (mode == PHYS_DIRECT) { 30931157Sbrian const char *l; 31031197Sbrian l = label ? label : "default"; 31136285Sbrian log_Printf(LogWARN, "Label %s rejected -direct connection\n", l); 31231157Sbrian } 31336285Sbrian log_Close(); 31431121Sbrian return 1; 31529083Sbrian } 31631121Sbrian 31736467Sbrian if ((bundle = bundle_Create(TUN_PREFIX, mode, (const char **)argv)) == NULL) { 31836285Sbrian log_Printf(LogWARN, "bundle_Create: %s\n", strerror(errno)); 31926940Sbrian return EX_START; 3206059Samurai } 32136314Sbrian if (prompt) { 32236314Sbrian prompt->bundle = bundle; /* couldn't do it earlier */ 32336314Sbrian prompt_Printf(prompt, "Using interface: %s\n", bundle->ifp.Name); 32436314Sbrian } 32536285Sbrian SignalBundle = bundle; 32631121Sbrian 32737008Sbrian if (system_Select(bundle, "default", CONFFILE, prompt, NULL) < 0) 32836285Sbrian prompt_Printf(prompt, "Warning: No default entry found in config file.\n"); 32936285Sbrian 33036285Sbrian sig_signal(SIGHUP, CloseSession); 33136285Sbrian sig_signal(SIGTERM, CloseSession); 33236285Sbrian sig_signal(SIGINT, CloseConnection); 33336285Sbrian sig_signal(SIGQUIT, CloseSession); 33436285Sbrian sig_signal(SIGALRM, SIG_IGN); 33524753Sache signal(SIGPIPE, SIG_IGN); 3366059Samurai 33736465Sbrian if (mode == PHYS_INTERACTIVE) 33836285Sbrian sig_signal(SIGTSTP, TerminalStop); 33936285Sbrian 34036285Sbrian sig_signal(SIGUSR2, BringDownServer); 34136285Sbrian 34231197Sbrian if (label) { 34331197Sbrian /* 34436285Sbrian * Set label both before and after system_Select ! 34536285Sbrian * This way, "set enddisc label" works during system_Select, and we 34636285Sbrian * also end up with the correct label if we have embedded load 34736285Sbrian * commands. 34831197Sbrian */ 34936285Sbrian bundle_SetLabel(bundle, label); 35037008Sbrian if (system_Select(bundle, label, CONFFILE, prompt, NULL) < 0) { 35136285Sbrian prompt_Printf(prompt, "Destination system (%s) not found.\n", label); 35236285Sbrian AbortProgram(EX_START); 3536059Samurai } 35436285Sbrian bundle_SetLabel(bundle, label); 35536465Sbrian if (mode == PHYS_AUTO && 35636285Sbrian bundle->ncp.ipcp.cfg.peer_range.ipaddr.s_addr == INADDR_ANY) { 35736285Sbrian prompt_Printf(prompt, "You must \"set ifaddr\" with a peer address " 35836285Sbrian "in label %s for auto mode.\n", label); 35936285Sbrian AbortProgram(EX_START); 36036285Sbrian } 3616059Samurai } 36226940Sbrian 36336465Sbrian if (mode != PHYS_INTERACTIVE) { 36436285Sbrian if (mode != PHYS_DIRECT) { 36536285Sbrian int bgpipe[2]; 36636285Sbrian pid_t bgpid; 36736285Sbrian 36836465Sbrian if (mode == PHYS_BACKGROUND && pipe(bgpipe)) { 36936285Sbrian log_Printf(LogERROR, "pipe: %s\n", strerror(errno)); 37036285Sbrian AbortProgram(EX_SOCK); 37120813Sjkh } 3726059Samurai 37328679Sbrian bgpid = fork(); 37420813Sjkh if (bgpid == -1) { 37536285Sbrian log_Printf(LogERROR, "fork: %s\n", strerror(errno)); 37636285Sbrian AbortProgram(EX_SOCK); 37720813Sjkh } 37836285Sbrian 37920813Sjkh if (bgpid) { 38020813Sjkh char c = EX_NORMAL; 38111336Samurai 38236465Sbrian if (mode == PHYS_BACKGROUND) { 38336285Sbrian close(bgpipe[1]); 38420813Sjkh BGPid = bgpid; 38536285Sbrian /* If we get a signal, kill the child */ 38636285Sbrian signal(SIGHUP, KillChild); 38736285Sbrian signal(SIGTERM, KillChild); 38836285Sbrian signal(SIGINT, KillChild); 38936285Sbrian signal(SIGQUIT, KillChild); 39036285Sbrian 39136285Sbrian /* Wait for our child to close its pipe before we exit */ 39236285Sbrian if (read(bgpipe[0], &c, 1) != 1) { 39336285Sbrian prompt_Printf(prompt, "Child exit, no status.\n"); 39436285Sbrian log_Printf(LogPHASE, "Parent: Child exit, no status.\n"); 39525908Sbrian } else if (c == EX_NORMAL) { 39636285Sbrian prompt_Printf(prompt, "PPP enabled.\n"); 39736285Sbrian log_Printf(LogPHASE, "Parent: PPP enabled.\n"); 39825908Sbrian } else { 39936285Sbrian prompt_Printf(prompt, "Child failed (%s).\n", ex_desc((int) c)); 40036285Sbrian log_Printf(LogPHASE, "Parent: Child failed (%s).\n", 40128679Sbrian ex_desc((int) c)); 40228679Sbrian } 40336285Sbrian close(bgpipe[0]); 40420813Sjkh } 40528679Sbrian return c; 40636465Sbrian } else if (mode == PHYS_BACKGROUND) { 40736285Sbrian close(bgpipe[0]); 40836285Sbrian bundle->notify.fd = bgpipe[1]; 40936285Sbrian } 41020813Sjkh 41136709Sbrian bundle_LockTun(bundle); /* we have a new pid */ 41236709Sbrian 41336285Sbrian /* -auto, -dedicated, -ddial & -background */ 41436285Sbrian prompt_Destroy(prompt, 0); 41536285Sbrian close(STDOUT_FILENO); 41636285Sbrian close(STDERR_FILENO); 41736285Sbrian close(STDIN_FILENO); 41826686Sbrian setsid(); 41936285Sbrian } else { 42036285Sbrian /* -direct: STDIN_FILENO gets used by modem_Open */ 42136285Sbrian prompt_TtyInit(NULL); 42236285Sbrian close(STDOUT_FILENO); 42336285Sbrian close(STDERR_FILENO); 42426686Sbrian } 4256059Samurai } else { 42636285Sbrian /* Interactive mode */ 42732129Sbrian close(STDERR_FILENO); 42836285Sbrian prompt_TtyInit(prompt); 42936285Sbrian prompt_TtyCommandMode(prompt); 43036285Sbrian prompt_Required(prompt); 4316059Samurai } 43229696Sbrian 43336285Sbrian log_Printf(LogPHASE, "PPP Started (%s mode).\n", mode2Nam(mode)); 43436431Sbrian DoLoop(bundle); 43536285Sbrian AbortProgram(EX_NORMAL); 4366059Samurai 43736285Sbrian return EX_NORMAL; 4386059Samurai} 4396059Samurai 4406059Samuraistatic void 44136431SbrianDoLoop(struct bundle *bundle) 4426059Samurai{ 4436059Samurai fd_set rfds, wfds, efds; 44436285Sbrian int i, nfds; 4456059Samurai 44636285Sbrian do { 44723598Sache nfds = 0; 44828679Sbrian FD_ZERO(&rfds); 44928679Sbrian FD_ZERO(&wfds); 45028679Sbrian FD_ZERO(&efds); 4517001Samurai 45236314Sbrian /* All our datalinks, the tun device and the MP socket */ 45336285Sbrian descriptor_UpdateSet(&bundle->desc, &rfds, &wfds, &efds, &nfds); 45425067Sbrian 45536314Sbrian /* All our prompts and the diagnostic socket */ 45636314Sbrian descriptor_UpdateSet(&server.desc, &rfds, NULL, NULL, &nfds); 45736314Sbrian 45836285Sbrian if (bundle_IsDead(bundle)) 45936285Sbrian /* Don't select - we'll be here forever */ 46036285Sbrian break; 46126551Sbrian 46236285Sbrian i = select(nfds, &rfds, &wfds, &efds, NULL); 46326696Sbrian 46436345Sbrian if (i < 0 && errno != EINTR) { 46536285Sbrian log_Printf(LogERROR, "DoLoop: select(): %s\n", strerror(errno)); 46636285Sbrian if (log_IsKept(LogTIMER)) { 46736285Sbrian struct timeval t; 46836285Sbrian 46936285Sbrian for (i = 0; i <= nfds; i++) { 47036285Sbrian if (FD_ISSET(i, &rfds)) { 47136285Sbrian log_Printf(LogTIMER, "Read set contains %d\n", i); 47236285Sbrian FD_CLR(i, &rfds); 47336285Sbrian t.tv_sec = t.tv_usec = 0; 47436285Sbrian if (select(nfds, &rfds, &wfds, &efds, &t) != -1) { 47536285Sbrian log_Printf(LogTIMER, "The culprit !\n"); 47636285Sbrian break; 47736285Sbrian } 47836285Sbrian } 47936285Sbrian if (FD_ISSET(i, &wfds)) { 48036285Sbrian log_Printf(LogTIMER, "Write set contains %d\n", i); 48136285Sbrian FD_CLR(i, &wfds); 48236285Sbrian t.tv_sec = t.tv_usec = 0; 48336285Sbrian if (select(nfds, &rfds, &wfds, &efds, &t) != -1) { 48436285Sbrian log_Printf(LogTIMER, "The culprit !\n"); 48536285Sbrian break; 48636285Sbrian } 48736285Sbrian } 48836285Sbrian if (FD_ISSET(i, &efds)) { 48936285Sbrian log_Printf(LogTIMER, "Error set contains %d\n", i); 49036285Sbrian FD_CLR(i, &efds); 49136285Sbrian t.tv_sec = t.tv_usec = 0; 49236285Sbrian if (select(nfds, &rfds, &wfds, &efds, &t) != -1) { 49336285Sbrian log_Printf(LogTIMER, "The culprit !\n"); 49436285Sbrian break; 49536285Sbrian } 49636285Sbrian } 49736285Sbrian } 49828679Sbrian } 49928679Sbrian break; 5008857Srgrimes } 5016059Samurai 50236345Sbrian sig_Handle(); 50336345Sbrian 50436345Sbrian if (i <= 0) 50536345Sbrian continue; 50636345Sbrian 50736285Sbrian for (i = 0; i <= nfds; i++) 50836285Sbrian if (FD_ISSET(i, &efds)) { 50936285Sbrian log_Printf(LogALERT, "Exception detected on descriptor %d\n", i); 51036285Sbrian break; 5116059Samurai } 51228679Sbrian 51336285Sbrian if (i <= nfds) 51436285Sbrian break; 51528536Sbrian 51636285Sbrian if (descriptor_IsSet(&server.desc, &rfds)) 51736285Sbrian descriptor_Read(&server.desc, bundle, &rfds); 51832039Sbrian 51936285Sbrian if (descriptor_IsSet(&bundle->desc, &wfds)) 52036285Sbrian descriptor_Write(&bundle->desc, bundle, &wfds); 52136285Sbrian 52236285Sbrian if (descriptor_IsSet(&bundle->desc, &rfds)) 52336285Sbrian descriptor_Read(&bundle->desc, bundle, &rfds); 52436345Sbrian 52536285Sbrian } while (bundle_CleanDatalinks(bundle), !bundle_IsDead(bundle)); 52636285Sbrian 52736285Sbrian log_Printf(LogDEBUG, "DoLoop done.\n"); 5286059Samurai} 529