2 * SPDX-License-Identifier: BSD-2-Clause-FreeBSD
4 * Copyright (c) 1998 Brian Somers <brian@Awfulhak.org>
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
10 * 1. Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 #include <sys/param.h>
32 #include <sys/socket.h>
33 #include <netinet/in.h>
35 #include <net/if_tun.h> /* For TUNS* ioctls */
36 #include <net/route.h>
37 #include <netinet/in_systm.h>
38 #include <netinet/ip.h>
69 #include "throughput.h"
70 #include "slcompress.h"
75 #include "descriptor.h"
104 #define SCATTER_SEGMENTS 7 /* version, datalink, name, physical,
105 throughput, throughput, device */
107 #define SEND_MAXFD 3 /* Max file descriptors passed through
108 the local domain socket */
110 static int bundle_RemainingIdleTime(struct bundle *);
112 static const char * const PhaseNames[] = {
113 "Dead", "Establish", "Authenticate", "Network", "Terminate"
117 bundle_PhaseName(struct bundle *bundle)
119 return bundle->phase <= PHASE_TERMINATE ?
120 PhaseNames[bundle->phase] : "unknown";
124 bundle_NewPhase(struct bundle *bundle, u_int new)
126 if (new == bundle->phase)
129 if (new <= PHASE_TERMINATE)
130 log_Printf(LogPHASE, "bundle: %s\n", PhaseNames[new]);
136 MPPE_MasterKeyValid = 0;
138 log_DisplayPrompts();
141 case PHASE_ESTABLISH:
145 case PHASE_AUTHENTICATE:
147 log_DisplayPrompts();
151 if (ncp_fsmStart(&bundle->ncp, bundle)) {
153 log_DisplayPrompts();
155 log_Printf(LogPHASE, "bundle: All NCPs are disabled\n");
156 bundle_Close(bundle, NULL, CLOSE_STAYDOWN);
160 case PHASE_TERMINATE:
162 mp_Down(&bundle->ncp.mp);
163 log_DisplayPrompts();
169 bundle_LayerStart(void *v __unused, struct fsm *fp __unused)
171 /* The given FSM is about to start up ! */
176 bundle_Notify(struct bundle *bundle, char c)
178 if (bundle->notify.fd != -1) {
181 ret = write(bundle->notify.fd, &c, 1);
182 if (c != EX_REDIAL && c != EX_RECONNECT) {
184 log_Printf(LogCHAT, "Parent notified of %s\n",
185 c == EX_NORMAL ? "success" : "failure");
187 log_Printf(LogERROR, "Failed to notify parent of success\n");
188 close(bundle->notify.fd);
189 bundle->notify.fd = -1;
191 log_Printf(LogCHAT, "Parent notified of %s\n", ex_desc(c));
193 log_Printf(LogERROR, "Failed to notify parent of %s\n", ex_desc(c));
198 bundle_ClearQueues(void *v)
200 struct bundle *bundle = (struct bundle *)v;
203 log_Printf(LogPHASE, "Clearing choked output queue\n");
204 timer_Stop(&bundle->choked.timer);
209 * We've had a full queue for PACKET_DEL_SECS seconds without being
210 * able to get rid of any of the packets. We've probably given up
211 * on the redials at this point, and the queued data has almost
212 * definitely been timed out by the layer above. As this is preventing
213 * us from reading the TUN_NAME device (we don't want to buffer stuff
214 * indefinitely), we may as well nuke this data and start with a clean
217 * Unfortunately, this has the side effect of shafting any compression
218 * dictionaries in use (causing the relevant RESET_REQ/RESET_ACK).
221 ncp_DeleteQueues(&bundle->ncp);
222 for (dl = bundle->links; dl; dl = dl->next)
223 physical_DeleteQueue(dl->physical);
227 bundle_LinkAdded(struct bundle *bundle, struct datalink *dl)
229 bundle->phys_type.all |= dl->physical->type;
230 if (dl->state == DATALINK_OPEN)
231 bundle->phys_type.open |= dl->physical->type;
234 if ((bundle->phys_type.open & (PHYS_DEDICATED|PHYS_DDIAL))
235 != bundle->phys_type.open && bundle->session.timer.state == TIMER_STOPPED)
236 if (bundle->radius.sessiontime)
237 bundle_StartSessionTimer(bundle, 0);
240 if ((bundle->phys_type.open & (PHYS_DEDICATED|PHYS_DDIAL))
241 != bundle->phys_type.open && bundle->idle.timer.state == TIMER_STOPPED)
242 /* We may need to start our idle timer */
243 bundle_StartIdleTimer(bundle, 0);
247 bundle_LinksRemoved(struct bundle *bundle)
251 bundle->phys_type.all = bundle->phys_type.open = 0;
252 for (dl = bundle->links; dl; dl = dl->next)
253 bundle_LinkAdded(bundle, dl);
255 bundle_CalculateBandwidth(bundle);
256 mp_CheckAutoloadTimer(&bundle->ncp.mp);
258 if ((bundle->phys_type.open & (PHYS_DEDICATED|PHYS_DDIAL))
259 == bundle->phys_type.open) {
261 if (bundle->radius.sessiontime)
262 bundle_StopSessionTimer(bundle);
264 bundle_StopIdleTimer(bundle);
269 bundle_LayerUp(void *v, struct fsm *fp)
272 * The given fsm is now up
273 * If it's an LCP, adjust our phys_mode.open value and check the
275 * If it's the first NCP, calculate our bandwidth
276 * If it's the first NCP, set our ``upat'' time
277 * If it's the first NCP, start the idle timer.
278 * If it's an NCP, tell our -background parent to go away.
279 * If it's the first NCP, start the autoload timer
281 struct bundle *bundle = (struct bundle *)v;
283 if (fp->proto == PROTO_LCP) {
284 struct physical *p = link2physical(fp->link);
286 bundle_LinkAdded(bundle, p->dl);
287 mp_CheckAutoloadTimer(&bundle->ncp.mp);
288 } else if (isncp(fp->proto)) {
289 if (ncp_LayersOpen(&fp->bundle->ncp) == 1) {
290 bundle_CalculateBandwidth(fp->bundle);
293 if (bundle->radius.sessiontime)
294 bundle_StartSessionTimer(bundle, 0);
296 bundle_StartIdleTimer(bundle, 0);
297 mp_CheckAutoloadTimer(&fp->bundle->ncp.mp);
299 bundle_Notify(bundle, EX_NORMAL);
300 } else if (fp->proto == PROTO_CCP)
301 bundle_CalculateBandwidth(fp->bundle); /* Against ccp_MTUOverhead */
305 bundle_LayerDown(void *v, struct fsm *fp)
308 * The given FSM has been told to come down.
309 * If it's our last NCP, stop the idle timer.
310 * If it's our last NCP, clear our ``upat'' value.
311 * If it's our last NCP, stop the autoload timer
312 * If it's an LCP, adjust our phys_type.open value and any timers.
313 * If it's an LCP and we're in multilink mode, adjust our tun
314 * If it's the last LCP, down all NCPs
315 * speed and make sure our minimum sequence number is adjusted.
318 struct bundle *bundle = (struct bundle *)v;
320 if (isncp(fp->proto)) {
321 if (ncp_LayersOpen(&fp->bundle->ncp) == 0) {
323 if (bundle->radius.sessiontime)
324 bundle_StopSessionTimer(bundle);
326 bundle_StopIdleTimer(bundle);
328 mp_StopAutoloadTimer(&bundle->ncp.mp);
330 } else if (fp->proto == PROTO_LCP) {
332 struct datalink *lost;
335 bundle_LinksRemoved(bundle); /* adjust timers & phys_type values */
339 for (dl = bundle->links; dl; dl = dl->next) {
340 if (fp == &dl->physical->link.lcp.fsm)
342 else if (dl->state != DATALINK_CLOSED && dl->state != DATALINK_HANGUP)
346 if (bundle->ncp.mp.active) {
347 bundle_CalculateBandwidth(bundle);
350 mp_LinkLost(&bundle->ncp.mp, lost);
352 log_Printf(LogALERT, "Oops, lost an unrecognised datalink (%s) !\n",
356 if (!others_active) {
357 /* Down the NCPs. We don't expect to get fsm_Close()d ourself ! */
358 ncp2initial(&bundle->ncp);
359 mp_Down(&bundle->ncp.mp);
365 bundle_LayerFinish(void *v, struct fsm *fp)
367 /* The given fsm is now down (fp cannot be NULL)
369 * If it's the last NCP, fsm_Close all LCPs
370 * If it's the last NCP, bring any MP layer down
373 struct bundle *bundle = (struct bundle *)v;
376 if (isncp(fp->proto) && !ncp_LayersUnfinished(&bundle->ncp)) {
377 if (bundle_Phase(bundle) != PHASE_DEAD)
378 bundle_NewPhase(bundle, PHASE_TERMINATE);
379 for (dl = bundle->links; dl; dl = dl->next)
380 if (dl->state == DATALINK_OPEN)
381 datalink_Close(dl, CLOSE_STAYDOWN);
383 mp_Down(&bundle->ncp.mp);
388 bundle_Close(struct bundle *bundle, const char *name, int how)
391 * Please close the given datalink.
392 * If name == NULL or name is the last datalink, fsm_Close all NCPs
394 * If it isn't the last datalink, just Close that datalink.
397 struct datalink *dl, *this_dl;
403 for (dl = bundle->links; dl; dl = dl->next) {
404 if (name && !strcasecmp(name, dl->name))
406 if (name == NULL || this_dl == dl) {
409 datalink_DontHangup(dl);
412 datalink_StayDown(dl);
415 } else if (dl->state != DATALINK_CLOSED && dl->state != DATALINK_HANGUP)
419 if (name && this_dl == NULL) {
420 log_Printf(LogWARN, "%s: Invalid datalink name\n", name);
424 if (!others_active) {
426 if (bundle->radius.sessiontime)
427 bundle_StopSessionTimer(bundle);
429 bundle_StopIdleTimer(bundle);
430 if (ncp_LayersUnfinished(&bundle->ncp))
431 ncp_Close(&bundle->ncp);
433 ncp2initial(&bundle->ncp);
434 mp_Down(&bundle->ncp.mp);
435 for (dl = bundle->links; dl; dl = dl->next)
436 datalink_Close(dl, how);
438 } else if (this_dl && this_dl->state != DATALINK_CLOSED &&
439 this_dl->state != DATALINK_HANGUP)
440 datalink_Close(this_dl, how);
444 bundle_Down(struct bundle *bundle, int how)
448 for (dl = bundle->links; dl; dl = dl->next)
449 datalink_Down(dl, how);
453 bundle_UpdateSet(struct fdescriptor *d, fd_set *r, fd_set *w, fd_set *e, int *n)
455 struct bundle *bundle = descriptor2bundle(d);
463 /* If there are aren't many packets queued, look for some more. */
464 for (nlinks = 0, dl = bundle->links; dl; dl = dl->next)
468 queued = r ? ncp_FillPhysicalQueues(&bundle->ncp, bundle) :
469 ncp_QueueLen(&bundle->ncp);
471 if (r && (bundle->phase == PHASE_NETWORK ||
472 bundle->phys_type.all & PHYS_AUTO)) {
473 /* enough surplus so that we can tell if we're getting swamped */
474 ifqueue = nlinks > bundle->cfg.ifqueue ? nlinks : bundle->cfg.ifqueue;
475 if (queued < ifqueue) {
476 /* Not enough - select() for more */
477 if (bundle->choked.timer.state == TIMER_RUNNING)
478 timer_Stop(&bundle->choked.timer); /* Not needed any more */
479 FD_SET(bundle->dev.fd, r);
480 if (*n < bundle->dev.fd + 1)
481 *n = bundle->dev.fd + 1;
482 log_Printf(LogTIMER, "%s: fdset(r) %d\n", TUN_NAME, bundle->dev.fd);
484 } else if (bundle->choked.timer.state == TIMER_STOPPED) {
485 bundle->choked.timer.func = bundle_ClearQueues;
486 bundle->choked.timer.name = "output choke";
487 bundle->choked.timer.load = bundle->cfg.choked.timeout * SECTICKS;
488 bundle->choked.timer.arg = bundle;
489 timer_Start(&bundle->choked.timer);
495 result += descriptor_UpdateSet(&bundle->radius.desc, r, w, e, n);
498 /* Which links need a select() ? */
499 for (dl = bundle->links; dl; dl = dl->next)
500 result += descriptor_UpdateSet(&dl->desc, r, w, e, n);
503 * This *MUST* be called after the datalink UpdateSet()s as it
504 * might be ``holding'' one of the datalinks (death-row) and
505 * wants to be able to de-select() it from the descriptor set.
507 result += descriptor_UpdateSet(&bundle->ncp.mp.server.desc, r, w, e, n);
513 bundle_IsSet(struct fdescriptor *d, const fd_set *fdset)
515 struct bundle *bundle = descriptor2bundle(d);
518 for (dl = bundle->links; dl; dl = dl->next)
519 if (descriptor_IsSet(&dl->desc, fdset))
523 if (descriptor_IsSet(&bundle->radius.desc, fdset))
527 if (descriptor_IsSet(&bundle->ncp.mp.server.desc, fdset))
530 return FD_ISSET(bundle->dev.fd, fdset);
534 bundle_DescriptorRead(struct fdescriptor *d __unused, struct bundle *bundle,
541 if (descriptor_IsSet(&bundle->ncp.mp.server.desc, fdset))
542 descriptor_Read(&bundle->ncp.mp.server.desc, bundle, fdset);
544 for (dl = bundle->links; dl; dl = dl->next)
545 if (descriptor_IsSet(&dl->desc, fdset))
546 descriptor_Read(&dl->desc, bundle, fdset);
549 if (descriptor_IsSet(&bundle->radius.desc, fdset))
550 descriptor_Read(&bundle->radius.desc, bundle, fdset);
553 if (FD_ISSET(bundle->dev.fd, fdset)) {
559 if (bundle->dev.header) {
560 data = (u_char *)&tun;
564 sz = sizeof tun.data;
567 /* something to read from tun */
569 n = read(bundle->dev.fd, data, sz);
571 log_Printf(LogWARN, "%s: read: %s\n", bundle->dev.Name, strerror(errno));
575 if (bundle->dev.header) {
576 n -= sz - sizeof tun.data;
578 log_Printf(LogERROR, "%s: read: Got only %d bytes of data !\n",
579 bundle->dev.Name, n);
582 af = ntohl(tun.header.family);
584 if (af != AF_INET && af != AF_INET6)
588 /* XXX: Should be maintaining drop/family counts ! */
593 if (af == AF_INET && ((struct ip *)tun.data)->ip_dst.s_addr ==
594 bundle->ncp.ipcp.my_ip.s_addr) {
595 /* we've been asked to send something addressed *to* us :( */
596 if (Enabled(bundle, OPT_LOOPBACK)) {
597 pri = PacketCheck(bundle, af, tun.data, n, &bundle->filter.in,
600 n += sz - sizeof tun.data;
601 write(bundle->dev.fd, data, n);
602 log_Printf(LogDEBUG, "Looped back packet addressed to myself\n");
606 log_Printf(LogDEBUG, "Oops - forwarding packet addressed to myself\n");
610 * Process on-demand dialup. Output packets are queued within the tunnel
611 * device until the appropriate NCP is opened.
614 if (bundle_Phase(bundle) == PHASE_DEAD) {
616 * Note, we must be in AUTO mode :-/ otherwise our interface should
617 * *not* be UP and we can't receive data
619 pri = PacketCheck(bundle, af, tun.data, n, &bundle->filter.dial,
622 bundle_Open(bundle, NULL, PHYS_AUTO, 0);
625 * Drop the packet. If we were to queue it, we'd just end up with
626 * a pile of timed-out data in our output queue by the time we get
627 * around to actually dialing. We'd also prematurely reach the
628 * threshold at which we stop select()ing to read() the tun
629 * device - breaking auto-dial.
635 pri = PacketCheck(bundle, af, tun.data, n, &bundle->filter.out,
638 /* Prepend the number of seconds timeout given in the filter */
639 tun.header.timeout = secs;
640 ncp_Enqueue(&bundle->ncp, af, pri, (char *)&tun, n + sizeof tun.header);
646 bundle_DescriptorWrite(struct fdescriptor *d __unused, struct bundle *bundle,
652 /* This is not actually necessary as struct mpserver doesn't Write() */
653 if (descriptor_IsSet(&bundle->ncp.mp.server.desc, fdset))
654 if (descriptor_Write(&bundle->ncp.mp.server.desc, bundle, fdset) == 1)
657 for (dl = bundle->links; dl; dl = dl->next)
658 if (descriptor_IsSet(&dl->desc, fdset))
659 switch (descriptor_Write(&dl->desc, bundle, fdset)) {
661 datalink_ComeDown(dl, CLOSE_NORMAL);
671 bundle_LockTun(struct bundle *bundle)
674 char pidfile[PATH_MAX];
676 snprintf(pidfile, sizeof pidfile, "%stun%d.pid", _PATH_VARRUN, bundle->unit);
677 lockfile = ID0fopen(pidfile, "w");
678 if (lockfile != NULL) {
679 fprintf(lockfile, "%d\n", (int)getpid());
682 #ifndef RELEASE_CRUNCH
684 log_Printf(LogERROR, "Warning: Can't create %s: %s\n",
685 pidfile, strerror(errno));
690 bundle_UnlockTun(struct bundle *bundle)
692 char pidfile[PATH_MAX];
694 snprintf(pidfile, sizeof pidfile, "%stun%d.pid", _PATH_VARRUN, bundle->unit);
699 bundle_Create(const char *prefix, int type, int unit)
701 static struct bundle bundle; /* there can be only one */
702 int enoentcount, err, minunit, maxunit;
704 #if defined(__FreeBSD__) && !defined(NOKLDLOAD)
707 #if defined(TUNSIFMODE) || defined(TUNSLMODE) || defined(TUNSIFHEAD)
711 if (bundle.iface != NULL) { /* Already allocated ! */
712 log_Printf(LogALERT, "bundle_Create: There's only one BUNDLE !\n");
725 #if defined(__FreeBSD__) && !defined(NOKLDLOAD)
728 for (bundle.unit = minunit; bundle.unit != maxunit; bundle.unit++) {
729 snprintf(bundle.dev.Name, sizeof bundle.dev.Name, "%s%d",
730 prefix, bundle.unit);
731 bundle.dev.fd = ID0open(bundle.dev.Name, O_RDWR);
732 if (bundle.dev.fd >= 0)
734 else if (errno == ENXIO || errno == ENOENT) {
735 #if defined(__FreeBSD__) && !defined(NOKLDLOAD)
736 if (bundle.unit == minunit && !kldtried++) {
738 * Attempt to load the tunnel interface KLD if it isn't loaded
741 if (loadmodules(LOAD_VERBOSLY, "if_tun", NULL))
746 if (errno != ENOENT || ++enoentcount > 2) {
754 if (bundle.dev.fd < 0) {
756 log_Printf(LogWARN, "No available tunnel devices found (%s)\n",
759 log_Printf(LogWARN, "%s%d: %s\n", prefix, unit, strerror(err));
763 log_SetTun(bundle.unit, NULL);
765 ifname = strrchr(bundle.dev.Name, '/');
767 ifname = bundle.dev.Name;
771 bundle.iface = iface_Create(ifname);
772 if (bundle.iface == NULL) {
773 close(bundle.dev.fd);
778 /* Make sure we're POINTOPOINT & IFF_MULTICAST */
779 iff = IFF_POINTOPOINT | IFF_MULTICAST;
780 if (ID0ioctl(bundle.dev.fd, TUNSIFMODE, &iff) < 0)
781 log_Printf(LogERROR, "bundle_Create: ioctl(TUNSIFMODE): %s\n",
786 /* Make sure we're not prepending sockaddrs */
788 if (ID0ioctl(bundle.dev.fd, TUNSLMODE, &iff) < 0)
789 log_Printf(LogERROR, "bundle_Create: ioctl(TUNSLMODE): %s\n",
794 /* We want the address family please ! */
796 if (ID0ioctl(bundle.dev.fd, TUNSIFHEAD, &iff) < 0) {
797 log_Printf(LogERROR, "bundle_Create: ioctl(TUNSIFHEAD): %s\n",
799 bundle.dev.header = 0;
801 bundle.dev.header = 1;
804 /* Always present for OpenBSD */
805 bundle.dev.header = 1;
808 * If TUNSIFHEAD isn't available and we're not OpenBSD, assume
809 * everything's AF_INET (hopefully the tun device won't pass us
812 bundle.dev.header = 0;
816 log_Printf(LogPHASE, "Using interface: %s\n", ifname);
818 bundle.bandwidth = 0;
819 bundle.routing_seq = 0;
820 bundle.phase = PHASE_DEAD;
821 bundle.CleaningUp = 0;
822 bundle.NatEnabled = 0;
824 bundle.fsm.LayerStart = bundle_LayerStart;
825 bundle.fsm.LayerUp = bundle_LayerUp;
826 bundle.fsm.LayerDown = bundle_LayerDown;
827 bundle.fsm.LayerFinish = bundle_LayerFinish;
828 bundle.fsm.object = &bundle;
830 bundle.cfg.idle.timeout = NCP_IDLE_TIMEOUT;
831 bundle.cfg.idle.min_timeout = 0;
832 *bundle.cfg.auth.name = '\0';
833 *bundle.cfg.auth.key = '\0';
834 bundle.cfg.optmask = (1ull << OPT_IDCHECK) | (1ull << OPT_LOOPBACK) |
835 (1ull << OPT_SROUTES) | (1ull << OPT_TCPMSSFIXUP) |
836 (1ull << OPT_THROUGHPUT) | (1ull << OPT_UTMP) |
837 (1ull << OPT_NAS_IP_ADDRESS) |
838 (1ull << OPT_NAS_IDENTIFIER);
840 opt_enable(&bundle, OPT_IPCP);
841 if (probe.ipv6_available)
842 opt_enable(&bundle, OPT_IPV6CP);
844 *bundle.cfg.label = '\0';
845 bundle.cfg.ifqueue = DEF_IFQUEUE;
846 bundle.cfg.choked.timeout = CHOKED_TIMEOUT;
847 bundle.phys_type.all = type;
848 bundle.phys_type.open = 0;
851 bundle.links = datalink_Create("deflink", &bundle, type);
852 if (bundle.links == NULL) {
853 log_Printf(LogALERT, "Cannot create data link: %s\n", strerror(errno));
854 iface_Free(bundle.iface);
856 close(bundle.dev.fd);
860 bundle.desc.type = BUNDLE_DESCRIPTOR;
861 bundle.desc.UpdateSet = bundle_UpdateSet;
862 bundle.desc.IsSet = bundle_IsSet;
863 bundle.desc.Read = bundle_DescriptorRead;
864 bundle.desc.Write = bundle_DescriptorWrite;
866 ncp_Init(&bundle.ncp, &bundle);
868 memset(&bundle.filter, '\0', sizeof bundle.filter);
869 bundle.filter.in.fragok = bundle.filter.in.logok = 1;
870 bundle.filter.in.name = "IN";
871 bundle.filter.out.fragok = bundle.filter.out.logok = 1;
872 bundle.filter.out.name = "OUT";
873 bundle.filter.dial.name = "DIAL";
874 bundle.filter.dial.logok = 1;
875 bundle.filter.alive.name = "ALIVE";
876 bundle.filter.alive.logok = 1;
879 for (i = 0; i < MAXFILTERS; i++) {
880 bundle.filter.in.rule[i].f_action = A_NONE;
881 bundle.filter.out.rule[i].f_action = A_NONE;
882 bundle.filter.dial.rule[i].f_action = A_NONE;
883 bundle.filter.alive.rule[i].f_action = A_NONE;
886 memset(&bundle.idle.timer, '\0', sizeof bundle.idle.timer);
887 bundle.idle.done = 0;
888 bundle.notify.fd = -1;
889 memset(&bundle.choked.timer, '\0', sizeof bundle.choked.timer);
891 radius_Init(&bundle.radius);
894 /* Clean out any leftover crud */
895 iface_Clear(bundle.iface, &bundle.ncp, 0, IFACE_CLEAR_ALL);
897 bundle_LockTun(&bundle);
903 bundle_DownInterface(struct bundle *bundle)
905 route_IfDelete(bundle, 1);
906 iface_ClearFlags(bundle->iface->name, IFF_UP);
910 bundle_Destroy(struct bundle *bundle)
915 * Clean up the interface. We don't really need to do the timer_Stop()s,
916 * mp_Down(), iface_Clear() and bundle_DownInterface() unless we're getting
917 * out under exceptional conditions such as a descriptor exception.
919 timer_Stop(&bundle->idle.timer);
920 timer_Stop(&bundle->choked.timer);
921 mp_Down(&bundle->ncp.mp);
922 iface_Clear(bundle->iface, &bundle->ncp, 0, IFACE_CLEAR_ALL);
923 bundle_DownInterface(bundle);
926 /* Tell the radius server the bad news */
927 radius_Destroy(&bundle->radius);
930 /* Again, these are all DATALINK_CLOSED unless we're abending */
933 dl = datalink_Destroy(dl);
935 ncp_Destroy(&bundle->ncp);
937 close(bundle->dev.fd);
938 bundle_UnlockTun(bundle);
940 /* In case we never made PHASE_NETWORK */
941 bundle_Notify(bundle, EX_ERRDEAD);
943 iface_Destroy(bundle->iface);
944 bundle->iface = NULL;
948 bundle_LinkClosed(struct bundle *bundle, struct datalink *dl)
951 * Our datalink has closed.
952 * CleanDatalinks() (called from DoLoop()) will remove closed
953 * BACKGROUND, FOREGROUND and DIRECT links.
954 * If it's the last data link, enter phase DEAD.
956 * NOTE: dl may not be in our list (bundle_SendDatalink()) !
959 struct datalink *odl;
962 log_SetTtyCommandMode(dl);
965 for (odl = bundle->links; odl; odl = odl->next)
966 if (odl != dl && odl->state != DATALINK_CLOSED)
970 if (dl->physical->type != PHYS_AUTO) /* Not in -auto mode */
971 bundle_DownInterface(bundle);
972 ncp2initial(&bundle->ncp);
973 mp_Down(&bundle->ncp.mp);
974 bundle_NewPhase(bundle, PHASE_DEAD);
976 if (bundle->radius.sessiontime)
977 bundle_StopSessionTimer(bundle);
979 bundle_StopIdleTimer(bundle);
984 bundle_Open(struct bundle *bundle, const char *name, int mask, int force)
987 * Please open the given datalink, or all if name == NULL
991 for (dl = bundle->links; dl; dl = dl->next)
992 if (name == NULL || !strcasecmp(dl->name, name)) {
993 if ((mask & dl->physical->type) &&
994 (dl->state == DATALINK_CLOSED ||
995 (force && dl->state == DATALINK_OPENING &&
996 dl->dial.timer.state == TIMER_RUNNING) ||
997 dl->state == DATALINK_READY)) {
998 timer_Stop(&dl->dial.timer); /* We're finished with this */
999 datalink_Up(dl, 1, 1);
1000 if (mask & PHYS_AUTO)
1001 break; /* Only one AUTO link at a time */
1009 bundle2datalink(struct bundle *bundle, const char *name)
1011 struct datalink *dl;
1014 for (dl = bundle->links; dl; dl = dl->next)
1015 if (!strcasecmp(dl->name, name))
1017 } else if (bundle->links && !bundle->links->next)
1018 return bundle->links;
1024 bundle_ShowLinks(struct cmdargs const *arg)
1026 struct datalink *dl;
1027 struct pppThroughput *t;
1028 unsigned long long octets;
1031 for (dl = arg->bundle->links; dl; dl = dl->next) {
1032 octets = MAX(dl->physical->link.stats.total.in.OctetsPerSecond,
1033 dl->physical->link.stats.total.out.OctetsPerSecond);
1035 prompt_Printf(arg->prompt, "Name: %s [%s, %s]",
1036 dl->name, mode2Nam(dl->physical->type), datalink_State(dl));
1037 if (dl->physical->link.stats.total.rolling && dl->state == DATALINK_OPEN)
1038 prompt_Printf(arg->prompt, " bandwidth %d, %llu bps (%llu bytes/sec)",
1039 dl->mp.bandwidth ? dl->mp.bandwidth :
1040 physical_GetSpeed(dl->physical),
1041 octets * 8, octets);
1042 prompt_Printf(arg->prompt, "\n");
1045 t = &arg->bundle->ncp.mp.link.stats.total;
1046 octets = MAX(t->in.OctetsPerSecond, t->out.OctetsPerSecond);
1047 secs = t->downtime ? 0 : throughput_uptime(t);
1048 if (secs > t->SamplePeriod)
1049 secs = t->SamplePeriod;
1051 prompt_Printf(arg->prompt, "Currently averaging %llu bps (%llu bytes/sec)"
1052 " over the last %d secs\n", octets * 8, octets, secs);
1058 optval(struct bundle *bundle, int opt)
1060 return Enabled(bundle, opt) ? "enabled" : "disabled";
1064 bundle_ShowStatus(struct cmdargs const *arg)
1068 prompt_Printf(arg->prompt, "Phase %s\n", bundle_PhaseName(arg->bundle));
1069 prompt_Printf(arg->prompt, " Device: %s\n", arg->bundle->dev.Name);
1070 prompt_Printf(arg->prompt, " Interface: %s @ %lubps",
1071 arg->bundle->iface->name, arg->bundle->bandwidth);
1073 if (arg->bundle->upat) {
1074 int secs = bundle_Uptime(arg->bundle);
1076 prompt_Printf(arg->prompt, ", up time %d:%02d:%02d", secs / 3600,
1077 (secs / 60) % 60, secs % 60);
1079 prompt_Printf(arg->prompt, "\n Queued: %lu of %u\n",
1080 (unsigned long)ncp_QueueLen(&arg->bundle->ncp),
1081 arg->bundle->cfg.ifqueue);
1083 prompt_Printf(arg->prompt, "\nDefaults:\n");
1084 prompt_Printf(arg->prompt, " Label: %s\n",
1085 arg->bundle->cfg.label);
1086 prompt_Printf(arg->prompt, " Auth name: %s\n",
1087 arg->bundle->cfg.auth.name);
1088 prompt_Printf(arg->prompt, " Diagnostic socket: ");
1089 if (*server.cfg.sockname != '\0') {
1090 prompt_Printf(arg->prompt, "%s", server.cfg.sockname);
1091 if (server.cfg.mask != (mode_t)-1)
1092 prompt_Printf(arg->prompt, ", mask 0%03o", (int)server.cfg.mask);
1093 prompt_Printf(arg->prompt, "%s\n", server.fd == -1 ? " (not open)" : "");
1094 } else if (server.cfg.port != 0)
1095 prompt_Printf(arg->prompt, "TCP port %d%s\n", server.cfg.port,
1096 server.fd == -1 ? " (not open)" : "");
1098 prompt_Printf(arg->prompt, "none\n");
1100 prompt_Printf(arg->prompt, " Choked Timer: %us\n",
1101 arg->bundle->cfg.choked.timeout);
1104 radius_Show(&arg->bundle->radius, arg->prompt);
1107 prompt_Printf(arg->prompt, " Idle Timer: ");
1108 if (arg->bundle->cfg.idle.timeout) {
1109 prompt_Printf(arg->prompt, "%us", arg->bundle->cfg.idle.timeout);
1110 if (arg->bundle->cfg.idle.min_timeout)
1111 prompt_Printf(arg->prompt, ", min %us",
1112 arg->bundle->cfg.idle.min_timeout);
1113 remaining = bundle_RemainingIdleTime(arg->bundle);
1114 if (remaining != -1)
1115 prompt_Printf(arg->prompt, " (%ds remaining)", remaining);
1116 prompt_Printf(arg->prompt, "\n");
1118 prompt_Printf(arg->prompt, "disabled\n");
1120 prompt_Printf(arg->prompt, " Filter Decap: %-20.20s",
1121 optval(arg->bundle, OPT_FILTERDECAP));
1122 prompt_Printf(arg->prompt, " ID check: %s\n",
1123 optval(arg->bundle, OPT_IDCHECK));
1124 prompt_Printf(arg->prompt, " Iface-Alias: %-20.20s",
1125 optval(arg->bundle, OPT_IFACEALIAS));
1127 prompt_Printf(arg->prompt, " IPCP: %s\n",
1128 optval(arg->bundle, OPT_IPCP));
1129 prompt_Printf(arg->prompt, " IPV6CP: %-20.20s",
1130 optval(arg->bundle, OPT_IPV6CP));
1132 prompt_Printf(arg->prompt, " Keep-Session: %s\n",
1133 optval(arg->bundle, OPT_KEEPSESSION));
1134 prompt_Printf(arg->prompt, " Loopback: %-20.20s",
1135 optval(arg->bundle, OPT_LOOPBACK));
1136 prompt_Printf(arg->prompt, " PasswdAuth: %s\n",
1137 optval(arg->bundle, OPT_PASSWDAUTH));
1138 prompt_Printf(arg->prompt, " Proxy: %-20.20s",
1139 optval(arg->bundle, OPT_PROXY));
1140 prompt_Printf(arg->prompt, " Proxyall: %s\n",
1141 optval(arg->bundle, OPT_PROXYALL));
1142 prompt_Printf(arg->prompt, " Sticky Routes: %-20.20s",
1143 optval(arg->bundle, OPT_SROUTES));
1144 prompt_Printf(arg->prompt, " TCPMSS Fixup: %s\n",
1145 optval(arg->bundle, OPT_TCPMSSFIXUP));
1146 prompt_Printf(arg->prompt, " Throughput: %-20.20s",
1147 optval(arg->bundle, OPT_THROUGHPUT));
1148 prompt_Printf(arg->prompt, " Utmp Logging: %s\n",
1149 optval(arg->bundle, OPT_UTMP));
1150 prompt_Printf(arg->prompt, " NAS-IP-Address: %-20.20s",
1151 optval(arg->bundle, OPT_NAS_IP_ADDRESS));
1152 prompt_Printf(arg->prompt, " NAS-Identifier: %s\n",
1153 optval(arg->bundle, OPT_NAS_IDENTIFIER));
1159 bundle_IdleTimeout(void *v)
1161 struct bundle *bundle = (struct bundle *)v;
1163 log_Printf(LogPHASE, "Idle timer expired\n");
1164 bundle_StopIdleTimer(bundle);
1165 bundle_Close(bundle, NULL, CLOSE_STAYDOWN);
1169 * Start Idle timer. If timeout is reached, we call bundle_Close() to
1170 * close LCP and link.
1173 bundle_StartIdleTimer(struct bundle *bundle, unsigned secs)
1175 timer_Stop(&bundle->idle.timer);
1176 if ((bundle->phys_type.open & (PHYS_DEDICATED|PHYS_DDIAL)) !=
1177 bundle->phys_type.open && bundle->cfg.idle.timeout) {
1178 time_t now = time(NULL);
1181 secs = bundle->cfg.idle.timeout;
1183 /* We want at least `secs' */
1184 if (bundle->cfg.idle.min_timeout > secs && bundle->upat) {
1185 unsigned up = now - bundle->upat;
1187 if (bundle->cfg.idle.min_timeout > up &&
1188 bundle->cfg.idle.min_timeout - up > (long long)secs)
1189 /* Only increase from the current `remaining' value */
1190 secs = bundle->cfg.idle.min_timeout - up;
1192 bundle->idle.timer.func = bundle_IdleTimeout;
1193 bundle->idle.timer.name = "idle";
1194 bundle->idle.timer.load = secs * SECTICKS;
1195 bundle->idle.timer.arg = bundle;
1196 timer_Start(&bundle->idle.timer);
1197 bundle->idle.done = now + secs;
1202 bundle_SetIdleTimer(struct bundle *bundle, unsigned timeout,
1203 unsigned min_timeout)
1205 bundle->cfg.idle.timeout = timeout;
1206 bundle->cfg.idle.min_timeout = min_timeout;
1207 if (ncp_LayersOpen(&bundle->ncp))
1208 bundle_StartIdleTimer(bundle, 0);
1212 bundle_StopIdleTimer(struct bundle *bundle)
1214 timer_Stop(&bundle->idle.timer);
1215 bundle->idle.done = 0;
1219 bundle_RemainingIdleTime(struct bundle *bundle)
1221 if (bundle->idle.done)
1222 return bundle->idle.done - time(NULL);
1229 bundle_SessionTimeout(void *v)
1231 struct bundle *bundle = (struct bundle *)v;
1233 log_Printf(LogPHASE, "Session-Timeout timer expired\n");
1234 bundle_StopSessionTimer(bundle);
1235 bundle_Close(bundle, NULL, CLOSE_STAYDOWN);
1239 bundle_StartSessionTimer(struct bundle *bundle, unsigned secs)
1241 timer_Stop(&bundle->session.timer);
1242 if ((bundle->phys_type.open & (PHYS_DEDICATED|PHYS_DDIAL)) !=
1243 bundle->phys_type.open && bundle->radius.sessiontime) {
1244 time_t now = time(NULL);
1247 secs = bundle->radius.sessiontime;
1249 bundle->session.timer.func = bundle_SessionTimeout;
1250 bundle->session.timer.name = "session";
1251 bundle->session.timer.load = secs * SECTICKS;
1252 bundle->session.timer.arg = bundle;
1253 timer_Start(&bundle->session.timer);
1254 bundle->session.done = now + secs;
1259 bundle_StopSessionTimer(struct bundle *bundle)
1261 timer_Stop(&bundle->session.timer);
1262 bundle->session.done = 0;
1268 bundle_IsDead(struct bundle *bundle)
1270 return !bundle->links || (bundle->phase == PHASE_DEAD && bundle->CleaningUp);
1273 static struct datalink *
1274 bundle_DatalinkLinkout(struct bundle *bundle, struct datalink *dl)
1276 struct datalink **dlp;
1278 for (dlp = &bundle->links; *dlp; dlp = &(*dlp)->next)
1282 bundle_LinksRemoved(bundle);
1290 bundle_DatalinkLinkin(struct bundle *bundle, struct datalink *dl)
1292 struct datalink **dlp = &bundle->links;
1295 dlp = &(*dlp)->next;
1300 bundle_LinkAdded(bundle, dl);
1301 mp_CheckAutoloadTimer(&bundle->ncp.mp);
1305 bundle_CleanDatalinks(struct bundle *bundle)
1307 struct datalink **dlp = &bundle->links;
1311 if ((*dlp)->state == DATALINK_CLOSED &&
1312 (*dlp)->physical->type &
1313 (PHYS_DIRECT|PHYS_BACKGROUND|PHYS_FOREGROUND)) {
1314 *dlp = datalink_Destroy(*dlp);
1317 dlp = &(*dlp)->next;
1320 bundle_LinksRemoved(bundle);
1324 bundle_DatalinkClone(struct bundle *bundle, struct datalink *dl,
1327 if (bundle2datalink(bundle, name)) {
1328 log_Printf(LogWARN, "Clone: %s: name already exists\n", name);
1332 bundle_DatalinkLinkin(bundle, datalink_Clone(dl, name));
1337 bundle_DatalinkRemove(struct bundle *bundle, struct datalink *dl)
1339 dl = bundle_DatalinkLinkout(bundle, dl);
1341 datalink_Destroy(dl);
1345 bundle_SetLabel(struct bundle *bundle, const char *label)
1348 strncpy(bundle->cfg.label, label, sizeof bundle->cfg.label - 1);
1350 *bundle->cfg.label = '\0';
1354 bundle_GetLabel(struct bundle *bundle)
1356 return *bundle->cfg.label ? bundle->cfg.label : NULL;
1362 struct iovec iov[SCATTER_SEGMENTS];
1363 int niov, expect, f;
1365 iov[0].iov_len = strlen(Version) + 1;
1366 iov[0].iov_base = NULL;
1368 if (datalink2iov(NULL, iov, &niov, SCATTER_SEGMENTS, NULL, NULL) == -1) {
1369 log_Printf(LogERROR, "Cannot determine space required for link\n");
1373 for (f = expect = 0; f < niov; f++)
1374 expect += iov[f].iov_len;
1380 bundle_ReceiveDatalink(struct bundle *bundle, int s)
1382 char cmsgbuf[sizeof(struct cmsghdr) + sizeof(int) * SEND_MAXFD];
1383 int niov, expect, f, *fd, nfd, onfd;
1385 struct iovec iov[SCATTER_SEGMENTS];
1386 struct cmsghdr *cmsg;
1388 struct datalink *dl;
1391 log_Printf(LogPHASE, "Receiving datalink\n");
1394 * Create our scatter/gather array - passing NULL gets the space
1395 * allocation requirement rather than actually flattening the
1398 iov[0].iov_len = strlen(Version) + 1;
1399 iov[0].iov_base = NULL;
1401 if (datalink2iov(NULL, iov, &niov, SCATTER_SEGMENTS, NULL, NULL) == -1) {
1402 log_Printf(LogERROR, "Cannot determine space required for link\n");
1406 /* Allocate the scatter/gather array for recvmsg() */
1407 for (f = expect = 0; f < niov; f++) {
1408 if ((iov[f].iov_base = malloc(iov[f].iov_len)) == NULL) {
1409 log_Printf(LogERROR, "Cannot allocate space to receive link\n");
1413 expect += iov[f].iov_len;
1416 /* Set up our message */
1417 cmsg = (struct cmsghdr *)cmsgbuf;
1418 cmsg->cmsg_len = sizeof cmsgbuf;
1419 cmsg->cmsg_level = SOL_SOCKET;
1420 cmsg->cmsg_type = 0;
1422 memset(&msg, '\0', sizeof msg);
1423 msg.msg_name = NULL;
1424 msg.msg_namelen = 0;
1426 msg.msg_iovlen = 1; /* Only send the version at the first pass */
1427 msg.msg_control = cmsgbuf;
1428 msg.msg_controllen = sizeof cmsgbuf;
1430 log_Printf(LogDEBUG, "Expecting %u scatter/gather bytes\n",
1431 (unsigned)iov[0].iov_len);
1433 if ((got = recvmsg(s, &msg, MSG_WAITALL)) != (ssize_t)iov[0].iov_len) {
1435 log_Printf(LogERROR, "Failed recvmsg: %s\n", strerror(errno));
1437 log_Printf(LogERROR, "Failed recvmsg: Got %zd, not %u\n",
1438 got, (unsigned)iov[0].iov_len);
1440 free(iov[niov].iov_base);
1444 if (cmsg->cmsg_level != SOL_SOCKET || cmsg->cmsg_type != SCM_RIGHTS) {
1445 log_Printf(LogERROR, "Recvmsg: no descriptors received !\n");
1447 free(iov[niov].iov_base);
1451 fd = (int *)CMSG_DATA(cmsg);
1452 nfd = ((caddr_t)cmsg + cmsg->cmsg_len - (caddr_t)fd) / sizeof(int);
1455 log_Printf(LogERROR, "Recvmsg: %d descriptor%s received (too few) !\n",
1456 nfd, nfd == 1 ? "" : "s");
1460 free(iov[niov].iov_base);
1465 * We've successfully received two or more open file descriptors
1466 * through our socket, plus a version string. Make sure it's the
1467 * correct version, and drop the connection if it's not.
1469 if (strncmp(Version, iov[0].iov_base, iov[0].iov_len)) {
1470 log_Printf(LogWARN, "Cannot receive datalink, incorrect version"
1471 " (\"%.*s\", not \"%s\")\n", (int)iov[0].iov_len,
1472 (char *)iov[0].iov_base, Version);
1476 free(iov[niov].iov_base);
1481 * Everything looks good. Send the other side our process id so that
1482 * they can transfer lock ownership, and wait for them to send the
1486 if ((got = write(fd[1], &pid, sizeof pid)) != sizeof pid) {
1488 log_Printf(LogERROR, "Failed write: %s\n", strerror(errno));
1490 log_Printf(LogERROR, "Failed write: Got %zd, not %d\n", got,
1495 free(iov[niov].iov_base);
1499 if ((got = readv(fd[1], iov + 1, niov - 1)) != expect) {
1501 log_Printf(LogERROR, "Failed write: %s\n", strerror(errno));
1503 log_Printf(LogERROR, "Failed write: Got %zd, not %d\n", got, expect);
1507 free(iov[niov].iov_base);
1512 onfd = nfd; /* We've got this many in our array */
1513 nfd -= 2; /* Don't include p->fd and our reply descriptor */
1514 niov = 1; /* Skip the version id */
1515 dl = iov2datalink(bundle, iov, &niov, sizeof iov / sizeof *iov, fd[0],
1520 log_Printf(LogERROR, "bundle_ReceiveDatalink: Failed to handle %d "
1521 "auxiliary file descriptors (%d remain)\n", onfd, nfd);
1522 datalink_Destroy(dl);
1527 bundle_DatalinkLinkin(bundle, dl);
1528 datalink_AuthOk(dl);
1529 bundle_CalculateBandwidth(dl->bundle);
1538 free(iov[0].iov_base);
1542 bundle_SendDatalink(struct datalink *dl, int s, struct sockaddr_un *sun)
1544 char cmsgbuf[CMSG_SPACE(sizeof(int) * SEND_MAXFD)];
1545 const char *constlock;
1547 struct cmsghdr *cmsg;
1549 struct iovec iov[SCATTER_SEGMENTS];
1550 int niov, f, expect, newsid, fd[SEND_MAXFD], nfd, reply[2];
1554 log_Printf(LogPHASE, "Transmitting datalink %s\n", dl->name);
1556 /* Record the base device name for a lock transfer later */
1557 constlock = physical_LockedDevice(dl->physical);
1559 lock = alloca(strlen(constlock) + 1);
1560 strcpy(lock, constlock);
1564 bundle_LinkClosed(dl->bundle, dl);
1565 bundle_DatalinkLinkout(dl->bundle, dl);
1567 /* Build our scatter/gather array */
1568 iov[0].iov_len = strlen(Version) + 1;
1569 iov[0].iov_base = strdup(Version);
1573 fd[0] = datalink2iov(dl, iov, &niov, SCATTER_SEGMENTS, fd + 2, &nfd);
1575 if (fd[0] != -1 && socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, reply) != -1) {
1577 * fd[1] is used to get the peer process id back, then to confirm that
1578 * we've transferred any device locks to that process id.
1582 nfd += 2; /* Include fd[0] and fd[1] */
1583 memset(&msg, '\0', sizeof msg);
1585 msg.msg_name = NULL;
1586 msg.msg_namelen = 0;
1588 * Only send the version to start... We used to send the whole lot, but
1589 * this caused problems with our RECVBUF size as a single link is about
1590 * 22k ! This way, we should bump into no limits.
1594 msg.msg_control = cmsgbuf;
1595 msg.msg_controllen = CMSG_SPACE(sizeof(int) * nfd);
1598 cmsg = (struct cmsghdr *)cmsgbuf;
1599 cmsg->cmsg_len = msg.msg_controllen;
1600 cmsg->cmsg_level = SOL_SOCKET;
1601 cmsg->cmsg_type = SCM_RIGHTS;
1603 for (f = 0; f < nfd; f++)
1604 *((int *)CMSG_DATA(cmsg) + f) = fd[f];
1606 for (f = 1, expect = 0; f < niov; f++)
1607 expect += iov[f].iov_len;
1609 if (setsockopt(reply[0], SOL_SOCKET, SO_SNDBUF, &expect, sizeof(int)) == -1)
1610 log_Printf(LogERROR, "setsockopt(SO_RCVBUF, %d): %s\n", expect,
1612 if (setsockopt(reply[1], SOL_SOCKET, SO_RCVBUF, &expect, sizeof(int)) == -1)
1613 log_Printf(LogERROR, "setsockopt(SO_RCVBUF, %d): %s\n", expect,
1616 log_Printf(LogDEBUG, "Sending %d descriptor%s and %u bytes in scatter"
1617 "/gather array\n", nfd, nfd == 1 ? "" : "s",
1618 (unsigned)iov[0].iov_len);
1620 if ((got = sendmsg(s, &msg, 0)) == -1)
1621 log_Printf(LogERROR, "Failed sendmsg: %s: %s\n",
1622 sun->sun_path, strerror(errno));
1623 else if (got != (ssize_t)iov[0].iov_len)
1624 log_Printf(LogERROR, "%s: Failed initial sendmsg: Only sent %zd of %u\n",
1625 sun->sun_path, got, (unsigned)iov[0].iov_len);
1627 /* We must get the ACK before closing the descriptor ! */
1630 if ((got = read(reply[0], &newpid, sizeof newpid)) == sizeof newpid) {
1631 log_Printf(LogDEBUG, "Received confirmation from pid %ld\n",
1633 if (lock && (res = ID0uu_lock_txfr(lock, newpid)) != UU_LOCK_OK)
1634 log_Printf(LogERROR, "uu_lock_txfr: %s\n", uu_lockerr(res));
1636 log_Printf(LogDEBUG, "Transmitting link (%d bytes)\n", expect);
1637 if ((got = writev(reply[0], iov + 1, niov - 1)) != expect) {
1639 log_Printf(LogERROR, "%s: Failed writev: %s\n",
1640 sun->sun_path, strerror(errno));
1642 log_Printf(LogERROR, "%s: Failed writev: Wrote %zd of %d\n",
1643 sun->sun_path, got, expect);
1645 } else if (got == -1)
1646 log_Printf(LogERROR, "%s: Failed socketpair read: %s\n",
1647 sun->sun_path, strerror(errno));
1649 log_Printf(LogERROR, "%s: Failed socketpair read: Got %zd of %d\n",
1650 sun->sun_path, got, (int)(sizeof newpid));
1656 newsid = Enabled(dl->bundle, OPT_KEEPSESSION) ||
1657 tcgetpgrp(fd[0]) == getpgrp();
1661 bundle_setsid(dl->bundle, got != -1);
1666 free(iov[niov].iov_base);
1670 bundle_RenameDatalink(struct bundle *bundle, struct datalink *ndl,
1673 struct datalink *dl;
1675 if (!strcasecmp(ndl->name, name))
1678 for (dl = bundle->links; dl; dl = dl->next)
1679 if (!strcasecmp(dl->name, name))
1682 datalink_Rename(ndl, name);
1687 bundle_SetMode(struct bundle *bundle, struct datalink *dl, int mode)
1691 omode = dl->physical->type;
1695 if (mode == PHYS_AUTO && !(bundle->phys_type.all & PHYS_AUTO))
1696 /* First auto link */
1697 if (bundle->ncp.ipcp.peer_ip.s_addr == INADDR_ANY) {
1698 log_Printf(LogWARN, "You must `set ifaddr' or `open' before"
1699 " changing mode to %s\n", mode2Nam(mode));
1703 if (!datalink_SetMode(dl, mode))
1706 if (mode == PHYS_AUTO && !(bundle->phys_type.all & PHYS_AUTO) &&
1707 bundle->phase != PHASE_NETWORK)
1708 /* First auto link, we need an interface */
1709 ipcp_InterfaceUp(&bundle->ncp.ipcp);
1711 /* Regenerate phys_type and adjust idle timer */
1712 bundle_LinksRemoved(bundle);
1718 bundle_setsid(struct bundle *bundle, int holdsession)
1721 * Lose the current session. This means getting rid of our pid
1722 * too so that the tty device will really go away, and any getty
1723 * etc will be allowed to restart.
1728 struct datalink *dl;
1730 if (!holdsession && bundle_IsDead(bundle)) {
1732 * No need to lose our session after all... we're going away anyway
1734 * We should really stop the timer and pause if holdsession is set and
1735 * the bundle's dead, but that leaves other resources lying about :-(
1741 if (pipe(fds) == -1) {
1742 log_Printf(LogERROR, "pipe: %s\n", strerror(errno));
1745 switch ((pid = fork())) {
1747 log_Printf(LogERROR, "fork: %s\n", strerror(errno));
1753 read(fds[0], &done, 1); /* uu_locks are mine ! */
1755 if (pipe(fds) == -1) {
1756 log_Printf(LogERROR, "pipe(2): %s\n", strerror(errno));
1759 switch ((pid = fork())) {
1761 log_Printf(LogERROR, "fork(2): %s\n", strerror(errno));
1767 bundle_LockTun(bundle); /* update pid */
1768 read(fds[0], &done, 1); /* uu_locks are mine ! */
1771 bundle_ChangedPID(bundle);
1772 log_Printf(LogDEBUG, "%ld -> %ld: %s session control\n",
1773 (long)orig, (long)getpid(),
1774 holdsession ? "Passed" : "Dropped");
1775 timer_InitService(0); /* Start the Timer Service */
1779 /* Give away all our physical locks (to the final process) */
1780 for (dl = bundle->links; dl; dl = dl->next)
1781 if (dl->state != DATALINK_CLOSED)
1782 physical_ChangedPid(dl->physical, pid);
1783 write(fds[1], "!", 1); /* done */
1791 /* Give away all our physical locks (to the intermediate process) */
1792 for (dl = bundle->links; dl; dl = dl->next)
1793 if (dl->state != DATALINK_CLOSED)
1794 physical_ChangedPid(dl->physical, pid);
1795 write(fds[1], "!", 1); /* done */
1800 timer_TermService();
1801 signal(SIGPIPE, SIG_DFL);
1802 signal(SIGALRM, SIG_DFL);
1803 signal(SIGHUP, SIG_DFL);
1804 signal(SIGTERM, SIG_DFL);
1805 signal(SIGINT, SIG_DFL);
1806 signal(SIGQUIT, SIG_DFL);
1807 for (fd = getdtablesize(); fd >= 0; fd--)
1810 * Reap the intermediate process. As we're not exiting but the
1811 * intermediate is, we don't want it to become defunct.
1813 waitpid(pid, &status, 0);
1814 /* Tweak our process arguments.... */
1815 SetTitle("session owner");
1817 setuid(ID0realuid());
1820 * Hang around for a HUP. This should happen as soon as the
1821 * ppp that we passed our ctty descriptor to closes it.
1822 * NOTE: If this process dies, the passed descriptor becomes
1823 * invalid and will give a select() error by setting one
1824 * of the error fds, aborting the other ppp. We don't
1825 * want that to happen !
1835 bundle_HighestState(struct bundle *bundle)
1837 struct datalink *dl;
1838 unsigned result = DATALINK_CLOSED;
1840 for (dl = bundle->links; dl; dl = dl->next)
1841 if (result < dl->state)
1848 bundle_Exception(struct bundle *bundle, int fd)
1850 struct datalink *dl;
1852 for (dl = bundle->links; dl; dl = dl->next)
1853 if (dl->physical->fd == fd) {
1854 datalink_Down(dl, CLOSE_NORMAL);
1862 bundle_AdjustFilters(struct bundle *bundle, struct ncpaddr *local,
1863 struct ncpaddr *remote)
1865 filter_AdjustAddr(&bundle->filter.in, local, remote, NULL);
1866 filter_AdjustAddr(&bundle->filter.out, local, remote, NULL);
1867 filter_AdjustAddr(&bundle->filter.dial, local, remote, NULL);
1868 filter_AdjustAddr(&bundle->filter.alive, local, remote, NULL);
1872 bundle_AdjustDNS(struct bundle *bundle)
1874 struct in_addr *dns = bundle->ncp.ipcp.ns.dns;
1876 filter_AdjustAddr(&bundle->filter.in, NULL, NULL, dns);
1877 filter_AdjustAddr(&bundle->filter.out, NULL, NULL, dns);
1878 filter_AdjustAddr(&bundle->filter.dial, NULL, NULL, dns);
1879 filter_AdjustAddr(&bundle->filter.alive, NULL, NULL, dns);
1883 bundle_CalculateBandwidth(struct bundle *bundle)
1885 struct datalink *dl;
1886 int sp, overhead, maxoverhead;
1888 bundle->bandwidth = 0;
1889 bundle->iface->mtu = 0;
1892 for (dl = bundle->links; dl; dl = dl->next) {
1893 overhead = ccp_MTUOverhead(&dl->physical->link.ccp);
1894 if (maxoverhead < overhead)
1895 maxoverhead = overhead;
1896 if (dl->state == DATALINK_OPEN) {
1897 if ((sp = dl->mp.bandwidth) == 0 &&
1898 (sp = physical_GetSpeed(dl->physical)) == 0)
1899 log_Printf(LogDEBUG, "%s: %s: Cannot determine bandwidth\n",
1900 dl->name, dl->physical->name.full);
1902 bundle->bandwidth += sp;
1903 if (!bundle->ncp.mp.active) {
1904 bundle->iface->mtu = dl->physical->link.lcp.his_mru;
1910 if (bundle->bandwidth == 0)
1911 bundle->bandwidth = 115200; /* Shrug */
1913 if (bundle->ncp.mp.active) {
1914 bundle->iface->mtu = bundle->ncp.mp.peer_mrru;
1915 overhead = ccp_MTUOverhead(&bundle->ncp.mp.link.ccp);
1916 if (maxoverhead < overhead)
1917 maxoverhead = overhead;
1918 } else if (!bundle->iface->mtu)
1919 bundle->iface->mtu = DEF_MRU;
1922 if (bundle->radius.valid && bundle->radius.mtu &&
1923 bundle->radius.mtu < bundle->iface->mtu) {
1924 log_Printf(LogLCP, "Reducing MTU to radius value %lu\n",
1925 bundle->radius.mtu);
1926 bundle->iface->mtu = bundle->radius.mtu;
1931 log_Printf(LogLCP, "Reducing MTU from %lu to %lu (CCP requirement)\n",
1932 bundle->iface->mtu, bundle->iface->mtu - maxoverhead);
1933 bundle->iface->mtu -= maxoverhead;
1936 tun_configure(bundle);
1938 route_UpdateMTU(bundle);
1942 bundle_AutoAdjust(struct bundle *bundle, int percent, int what)
1944 struct datalink *dl, *choice, *otherlinkup;
1946 choice = otherlinkup = NULL;
1947 for (dl = bundle->links; dl; dl = dl->next)
1948 if (dl->physical->type == PHYS_AUTO) {
1949 if (dl->state == DATALINK_OPEN) {
1950 if (what == AUTO_DOWN) {
1952 otherlinkup = choice;
1955 } else if (dl->state == DATALINK_CLOSED) {
1956 if (what == AUTO_UP) {
1961 /* An auto link in an intermediate state - forget it for the moment */
1965 } else if (dl->state == DATALINK_OPEN && what == AUTO_DOWN)
1969 if (what == AUTO_UP) {
1970 log_Printf(LogPHASE, "%d%% saturation -> Opening link ``%s''\n",
1971 percent, choice->name);
1972 datalink_Up(choice, 1, 1);
1973 mp_CheckAutoloadTimer(&bundle->ncp.mp);
1974 } else if (otherlinkup) { /* Only bring the second-last link down */
1975 log_Printf(LogPHASE, "%d%% saturation -> Closing link ``%s''\n",
1976 percent, choice->name);
1977 datalink_Close(choice, CLOSE_STAYDOWN);
1978 mp_CheckAutoloadTimer(&bundle->ncp.mp);
1984 bundle_WantAutoloadTimer(struct bundle *bundle)
1986 struct datalink *dl;
1987 int autolink, opened;
1989 if (bundle->phase == PHASE_NETWORK) {
1990 for (autolink = opened = 0, dl = bundle->links; dl; dl = dl->next)
1991 if (dl->physical->type == PHYS_AUTO) {
1992 if (++autolink == 2 || (autolink == 1 && opened))
1993 /* Two auto links or one auto and one open in NETWORK phase */
1995 } else if (dl->state == DATALINK_OPEN) {
1998 /* One auto and one open link in NETWORK phase */
2007 bundle_ChangedPID(struct bundle *bundle)
2010 ioctl(bundle->dev.fd, TUNSIFPID, 0);
2015 bundle_Uptime(struct bundle *bundle)
2018 return time(NULL) - bundle->upat;