main.c revision 37019
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 * 2037019Sbrian * $Id: main.c,v 1.134 1998/06/16 19:40:27 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)) { 29737019Sbrian log_Printf(LogALERT, "ppp: Access violation: Please protect %s\n", 29837019Sbrian conf); 29931158Sbrian return -1; 30031158Sbrian } 30131158Sbrian ptr = conf + strlen(conf)-2; 30231158Sbrian while (ptr > conf && *ptr != '/') 30331158Sbrian *ptr-- = '\0'; 30431158Sbrian } while (ptr >= conf); 30531158Sbrian } 30631158Sbrian 30736285Sbrian if (!system_IsValid(label, prompt, mode)) { 30831121Sbrian fprintf(stderr, "You may not use ppp in this mode with this label\n"); 30936285Sbrian if (mode == PHYS_DIRECT) { 31031157Sbrian const char *l; 31131197Sbrian l = label ? label : "default"; 31236285Sbrian log_Printf(LogWARN, "Label %s rejected -direct connection\n", l); 31331157Sbrian } 31436285Sbrian log_Close(); 31531121Sbrian return 1; 31629083Sbrian } 31731121Sbrian 31836467Sbrian if ((bundle = bundle_Create(TUN_PREFIX, mode, (const char **)argv)) == NULL) { 31936285Sbrian log_Printf(LogWARN, "bundle_Create: %s\n", strerror(errno)); 32026940Sbrian return EX_START; 3216059Samurai } 32236314Sbrian if (prompt) { 32336314Sbrian prompt->bundle = bundle; /* couldn't do it earlier */ 32436314Sbrian prompt_Printf(prompt, "Using interface: %s\n", bundle->ifp.Name); 32536314Sbrian } 32636285Sbrian SignalBundle = bundle; 32731121Sbrian 32837008Sbrian if (system_Select(bundle, "default", CONFFILE, prompt, NULL) < 0) 32936285Sbrian prompt_Printf(prompt, "Warning: No default entry found in config file.\n"); 33036285Sbrian 33136285Sbrian sig_signal(SIGHUP, CloseSession); 33236285Sbrian sig_signal(SIGTERM, CloseSession); 33336285Sbrian sig_signal(SIGINT, CloseConnection); 33436285Sbrian sig_signal(SIGQUIT, CloseSession); 33536285Sbrian sig_signal(SIGALRM, SIG_IGN); 33624753Sache signal(SIGPIPE, SIG_IGN); 3376059Samurai 33836465Sbrian if (mode == PHYS_INTERACTIVE) 33936285Sbrian sig_signal(SIGTSTP, TerminalStop); 34036285Sbrian 34136285Sbrian sig_signal(SIGUSR2, BringDownServer); 34236285Sbrian 34331197Sbrian if (label) { 34431197Sbrian /* 34536285Sbrian * Set label both before and after system_Select ! 34636285Sbrian * This way, "set enddisc label" works during system_Select, and we 34736285Sbrian * also end up with the correct label if we have embedded load 34836285Sbrian * commands. 34931197Sbrian */ 35036285Sbrian bundle_SetLabel(bundle, label); 35137008Sbrian if (system_Select(bundle, label, CONFFILE, prompt, NULL) < 0) { 35236285Sbrian prompt_Printf(prompt, "Destination system (%s) not found.\n", label); 35336285Sbrian AbortProgram(EX_START); 3546059Samurai } 35536285Sbrian bundle_SetLabel(bundle, label); 35636465Sbrian if (mode == PHYS_AUTO && 35736285Sbrian bundle->ncp.ipcp.cfg.peer_range.ipaddr.s_addr == INADDR_ANY) { 35836285Sbrian prompt_Printf(prompt, "You must \"set ifaddr\" with a peer address " 35936285Sbrian "in label %s for auto mode.\n", label); 36036285Sbrian AbortProgram(EX_START); 36136285Sbrian } 3626059Samurai } 36326940Sbrian 36436465Sbrian if (mode != PHYS_INTERACTIVE) { 36536285Sbrian if (mode != PHYS_DIRECT) { 36636285Sbrian int bgpipe[2]; 36736285Sbrian pid_t bgpid; 36836285Sbrian 36936465Sbrian if (mode == PHYS_BACKGROUND && pipe(bgpipe)) { 37036285Sbrian log_Printf(LogERROR, "pipe: %s\n", strerror(errno)); 37136285Sbrian AbortProgram(EX_SOCK); 37220813Sjkh } 3736059Samurai 37428679Sbrian bgpid = fork(); 37520813Sjkh if (bgpid == -1) { 37636285Sbrian log_Printf(LogERROR, "fork: %s\n", strerror(errno)); 37736285Sbrian AbortProgram(EX_SOCK); 37820813Sjkh } 37936285Sbrian 38020813Sjkh if (bgpid) { 38120813Sjkh char c = EX_NORMAL; 38211336Samurai 38336465Sbrian if (mode == PHYS_BACKGROUND) { 38436285Sbrian close(bgpipe[1]); 38520813Sjkh BGPid = bgpid; 38636285Sbrian /* If we get a signal, kill the child */ 38736285Sbrian signal(SIGHUP, KillChild); 38836285Sbrian signal(SIGTERM, KillChild); 38936285Sbrian signal(SIGINT, KillChild); 39036285Sbrian signal(SIGQUIT, KillChild); 39136285Sbrian 39236285Sbrian /* Wait for our child to close its pipe before we exit */ 39336285Sbrian if (read(bgpipe[0], &c, 1) != 1) { 39436285Sbrian prompt_Printf(prompt, "Child exit, no status.\n"); 39536285Sbrian log_Printf(LogPHASE, "Parent: Child exit, no status.\n"); 39625908Sbrian } else if (c == EX_NORMAL) { 39736285Sbrian prompt_Printf(prompt, "PPP enabled.\n"); 39836285Sbrian log_Printf(LogPHASE, "Parent: PPP enabled.\n"); 39925908Sbrian } else { 40036285Sbrian prompt_Printf(prompt, "Child failed (%s).\n", ex_desc((int) c)); 40136285Sbrian log_Printf(LogPHASE, "Parent: Child failed (%s).\n", 40228679Sbrian ex_desc((int) c)); 40328679Sbrian } 40436285Sbrian close(bgpipe[0]); 40520813Sjkh } 40628679Sbrian return c; 40736465Sbrian } else if (mode == PHYS_BACKGROUND) { 40836285Sbrian close(bgpipe[0]); 40936285Sbrian bundle->notify.fd = bgpipe[1]; 41036285Sbrian } 41120813Sjkh 41236709Sbrian bundle_LockTun(bundle); /* we have a new pid */ 41336709Sbrian 41436285Sbrian /* -auto, -dedicated, -ddial & -background */ 41536285Sbrian prompt_Destroy(prompt, 0); 41636285Sbrian close(STDOUT_FILENO); 41736285Sbrian close(STDERR_FILENO); 41836285Sbrian close(STDIN_FILENO); 41926686Sbrian setsid(); 42036285Sbrian } else { 42136285Sbrian /* -direct: STDIN_FILENO gets used by modem_Open */ 42236285Sbrian prompt_TtyInit(NULL); 42336285Sbrian close(STDOUT_FILENO); 42436285Sbrian close(STDERR_FILENO); 42526686Sbrian } 4266059Samurai } else { 42736285Sbrian /* Interactive mode */ 42832129Sbrian close(STDERR_FILENO); 42936285Sbrian prompt_TtyInit(prompt); 43036285Sbrian prompt_TtyCommandMode(prompt); 43136285Sbrian prompt_Required(prompt); 4326059Samurai } 43329696Sbrian 43436285Sbrian log_Printf(LogPHASE, "PPP Started (%s mode).\n", mode2Nam(mode)); 43536431Sbrian DoLoop(bundle); 43636285Sbrian AbortProgram(EX_NORMAL); 4376059Samurai 43836285Sbrian return EX_NORMAL; 4396059Samurai} 4406059Samurai 4416059Samuraistatic void 44236431SbrianDoLoop(struct bundle *bundle) 4436059Samurai{ 4446059Samurai fd_set rfds, wfds, efds; 44536285Sbrian int i, nfds; 4466059Samurai 44736285Sbrian do { 44823598Sache nfds = 0; 44928679Sbrian FD_ZERO(&rfds); 45028679Sbrian FD_ZERO(&wfds); 45128679Sbrian FD_ZERO(&efds); 4527001Samurai 45336314Sbrian /* All our datalinks, the tun device and the MP socket */ 45436285Sbrian descriptor_UpdateSet(&bundle->desc, &rfds, &wfds, &efds, &nfds); 45525067Sbrian 45636314Sbrian /* All our prompts and the diagnostic socket */ 45736314Sbrian descriptor_UpdateSet(&server.desc, &rfds, NULL, NULL, &nfds); 45836314Sbrian 45936285Sbrian if (bundle_IsDead(bundle)) 46036285Sbrian /* Don't select - we'll be here forever */ 46136285Sbrian break; 46226551Sbrian 46336285Sbrian i = select(nfds, &rfds, &wfds, &efds, NULL); 46426696Sbrian 46536345Sbrian if (i < 0 && errno != EINTR) { 46636285Sbrian log_Printf(LogERROR, "DoLoop: select(): %s\n", strerror(errno)); 46736285Sbrian if (log_IsKept(LogTIMER)) { 46836285Sbrian struct timeval t; 46936285Sbrian 47036285Sbrian for (i = 0; i <= nfds; i++) { 47136285Sbrian if (FD_ISSET(i, &rfds)) { 47236285Sbrian log_Printf(LogTIMER, "Read set contains %d\n", i); 47336285Sbrian FD_CLR(i, &rfds); 47436285Sbrian t.tv_sec = t.tv_usec = 0; 47536285Sbrian if (select(nfds, &rfds, &wfds, &efds, &t) != -1) { 47636285Sbrian log_Printf(LogTIMER, "The culprit !\n"); 47736285Sbrian break; 47836285Sbrian } 47936285Sbrian } 48036285Sbrian if (FD_ISSET(i, &wfds)) { 48136285Sbrian log_Printf(LogTIMER, "Write set contains %d\n", i); 48236285Sbrian FD_CLR(i, &wfds); 48336285Sbrian t.tv_sec = t.tv_usec = 0; 48436285Sbrian if (select(nfds, &rfds, &wfds, &efds, &t) != -1) { 48536285Sbrian log_Printf(LogTIMER, "The culprit !\n"); 48636285Sbrian break; 48736285Sbrian } 48836285Sbrian } 48936285Sbrian if (FD_ISSET(i, &efds)) { 49036285Sbrian log_Printf(LogTIMER, "Error set contains %d\n", i); 49136285Sbrian FD_CLR(i, &efds); 49236285Sbrian t.tv_sec = t.tv_usec = 0; 49336285Sbrian if (select(nfds, &rfds, &wfds, &efds, &t) != -1) { 49436285Sbrian log_Printf(LogTIMER, "The culprit !\n"); 49536285Sbrian break; 49636285Sbrian } 49736285Sbrian } 49836285Sbrian } 49928679Sbrian } 50028679Sbrian break; 5018857Srgrimes } 5026059Samurai 50336345Sbrian sig_Handle(); 50436345Sbrian 50536345Sbrian if (i <= 0) 50636345Sbrian continue; 50736345Sbrian 50836285Sbrian for (i = 0; i <= nfds; i++) 50936285Sbrian if (FD_ISSET(i, &efds)) { 51037019Sbrian log_Printf(LogERROR, "Exception detected on descriptor %d\n", i); 51136285Sbrian break; 5126059Samurai } 51328679Sbrian 51436285Sbrian if (i <= nfds) 51536285Sbrian break; 51628536Sbrian 51736285Sbrian if (descriptor_IsSet(&server.desc, &rfds)) 51836285Sbrian descriptor_Read(&server.desc, bundle, &rfds); 51932039Sbrian 52036285Sbrian if (descriptor_IsSet(&bundle->desc, &wfds)) 52136285Sbrian descriptor_Write(&bundle->desc, bundle, &wfds); 52236285Sbrian 52336285Sbrian if (descriptor_IsSet(&bundle->desc, &rfds)) 52436285Sbrian descriptor_Read(&bundle->desc, bundle, &rfds); 52536345Sbrian 52636285Sbrian } while (bundle_CleanDatalinks(bundle), !bundle_IsDead(bundle)); 52736285Sbrian 52836285Sbrian log_Printf(LogDEBUG, "DoLoop done.\n"); 5296059Samurai} 530