1fb11a9c2SBrian Somers /*- 2fb11a9c2SBrian Somers * Copyright (c) 2000 Brian Somers <brian@Awfulhak.org> 3fb11a9c2SBrian Somers * All rights reserved. 4fb11a9c2SBrian Somers * 5fb11a9c2SBrian Somers * Redistribution and use in source and binary forms, with or without 6fb11a9c2SBrian Somers * modification, are permitted provided that the following conditions 7fb11a9c2SBrian Somers * are met: 8fb11a9c2SBrian Somers * 1. Redistributions of source code must retain the above copyright 9fb11a9c2SBrian Somers * notice, this list of conditions and the following disclaimer. 10fb11a9c2SBrian Somers * 2. Redistributions in binary form must reproduce the above copyright 11fb11a9c2SBrian Somers * notice, this list of conditions and the following disclaimer in the 12fb11a9c2SBrian Somers * documentation and/or other materials provided with the distribution. 13fb11a9c2SBrian Somers * 14fb11a9c2SBrian Somers * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 15fb11a9c2SBrian Somers * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 16fb11a9c2SBrian Somers * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 17fb11a9c2SBrian Somers * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 18fb11a9c2SBrian Somers * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 19fb11a9c2SBrian Somers * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 20fb11a9c2SBrian Somers * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 21fb11a9c2SBrian Somers * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 22fb11a9c2SBrian Somers * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 23fb11a9c2SBrian Somers * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 24fb11a9c2SBrian Somers * SUCH DAMAGE. 25fb11a9c2SBrian Somers * 26fb11a9c2SBrian Somers * $FreeBSD$ 27fb11a9c2SBrian Somers */ 28fb11a9c2SBrian Somers 29fb11a9c2SBrian Somers #include <sys/param.h> 30fb11a9c2SBrian Somers #include <sys/socket.h> 31fb11a9c2SBrian Somers #include <sys/un.h> 32fb11a9c2SBrian Somers #include <netinet/in.h> 33fb11a9c2SBrian Somers #include <arpa/inet.h> 34fb11a9c2SBrian Somers #include <netdb.h> 35fb11a9c2SBrian Somers #include <netgraph.h> 36fb11a9c2SBrian Somers #include <net/ethernet.h> 37fb11a9c2SBrian Somers #include <netinet/in_systm.h> 38fb11a9c2SBrian Somers #include <netinet/ip.h> 39fb11a9c2SBrian Somers #include <netgraph/ng_ether.h> 40fb11a9c2SBrian Somers #include <netgraph/ng_message.h> 41fb11a9c2SBrian Somers #include <netgraph/ng_socket.h> 42fb11a9c2SBrian Somers 43fb11a9c2SBrian Somers #include <errno.h> 44fb11a9c2SBrian Somers #include <stdio.h> 45fb11a9c2SBrian Somers #include <stdlib.h> 46fb11a9c2SBrian Somers #include <string.h> 47fb11a9c2SBrian Somers #include <sysexits.h> 48fb11a9c2SBrian Somers #include <sys/fcntl.h> 49fb11a9c2SBrian Somers #include <sys/uio.h> 50fb11a9c2SBrian Somers #include <termios.h> 51fb11a9c2SBrian Somers #include <sys/time.h> 52fb11a9c2SBrian Somers #include <unistd.h> 53fb11a9c2SBrian Somers 54fb11a9c2SBrian Somers #include "layer.h" 55fb11a9c2SBrian Somers #include "defs.h" 56fb11a9c2SBrian Somers #include "mbuf.h" 57fb11a9c2SBrian Somers #include "log.h" 58fb11a9c2SBrian Somers #include "timer.h" 59fb11a9c2SBrian Somers #include "lqr.h" 60fb11a9c2SBrian Somers #include "hdlc.h" 61fb11a9c2SBrian Somers #include "throughput.h" 62fb11a9c2SBrian Somers #include "fsm.h" 63fb11a9c2SBrian Somers #include "lcp.h" 64fb11a9c2SBrian Somers #include "ccp.h" 65fb11a9c2SBrian Somers #include "link.h" 66fb11a9c2SBrian Somers #include "async.h" 67fb11a9c2SBrian Somers #include "descriptor.h" 68fb11a9c2SBrian Somers #include "physical.h" 69fb11a9c2SBrian Somers #include "main.h" 70fb11a9c2SBrian Somers #include "mp.h" 71fb11a9c2SBrian Somers #include "chat.h" 72fb11a9c2SBrian Somers #include "auth.h" 73fb11a9c2SBrian Somers #include "chap.h" 74fb11a9c2SBrian Somers #include "cbcp.h" 75fb11a9c2SBrian Somers #include "datalink.h" 76fb11a9c2SBrian Somers #include "slcompress.h" 77fb11a9c2SBrian Somers #include "iplist.h" 78fb11a9c2SBrian Somers #include "ncpaddr.h" 79fb11a9c2SBrian Somers #include "ipcp.h" 80fb11a9c2SBrian Somers #include "ipv6cp.h" 81fb11a9c2SBrian Somers #include "ncp.h" 82fb11a9c2SBrian Somers #include "filter.h" 83fb11a9c2SBrian Somers #ifndef NORADIUS 84fb11a9c2SBrian Somers #include "radius.h" 85fb11a9c2SBrian Somers #endif 86fb11a9c2SBrian Somers #include "bundle.h" 87fb11a9c2SBrian Somers #include "id.h" 88fb11a9c2SBrian Somers #include "netgraph.h" 89fb11a9c2SBrian Somers 90fb11a9c2SBrian Somers 91fb11a9c2SBrian Somers struct ngdevice { 92fb11a9c2SBrian Somers struct device dev; /* What struct physical knows about */ 93fb11a9c2SBrian Somers int cs; /* Control socket */ 9489624a34SHartmut Brandt char hook[NG_HOOKSIZ]; /* Our socket node hook */ 95fb11a9c2SBrian Somers }; 96fb11a9c2SBrian Somers 97fb11a9c2SBrian Somers #define device2ng(d) ((d)->type == NG_DEVICE ? (struct ngdevice *)d : NULL) 98fb11a9c2SBrian Somers #define NG_MSGBUFSZ 4096 99fb11a9c2SBrian Somers #define NETGRAPH_PREFIX "netgraph:" 100fb11a9c2SBrian Somers 101057f1760SBrian Somers unsigned 102fb11a9c2SBrian Somers ng_DeviceSize(void) 103fb11a9c2SBrian Somers { 104fb11a9c2SBrian Somers return sizeof(struct ngdevice); 105fb11a9c2SBrian Somers } 106fb11a9c2SBrian Somers 107fb11a9c2SBrian Somers static int 108057f1760SBrian Somers ng_MessageOut(struct ngdevice *dev, const char *data) 109fb11a9c2SBrian Somers { 11089624a34SHartmut Brandt char path[NG_PATHSIZ]; 111fb11a9c2SBrian Somers char *fmt; 112057f1760SBrian Somers size_t len; 113057f1760SBrian Somers int pos, dpos; 114fb11a9c2SBrian Somers 115fb11a9c2SBrian Somers /* 116fb11a9c2SBrian Somers * We expect a node path, one or more spaces, a command, one or more 117fb11a9c2SBrian Somers * spaces and an ascii netgraph structure. 118fb11a9c2SBrian Somers */ 119fb11a9c2SBrian Somers data += strspn(data, " \t"); 120fb11a9c2SBrian Somers len = strcspn(data, " \t"); 121fb11a9c2SBrian Somers if (len >= sizeof path) { 122fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: %.*s: Node path too long\n", 123fb11a9c2SBrian Somers dev->dev.name, len, data); 124fb11a9c2SBrian Somers return 0; 125fb11a9c2SBrian Somers } 126fb11a9c2SBrian Somers memcpy(path, data, len); 127fb11a9c2SBrian Somers path[len] = '\0'; 128fb11a9c2SBrian Somers data += len; 129fb11a9c2SBrian Somers 130fb11a9c2SBrian Somers data += strspn(data, " \t"); 131fb11a9c2SBrian Somers len = strcspn(data, " \t"); 132fb11a9c2SBrian Somers for (pos = len; pos >= 0; pos--) 133fb11a9c2SBrian Somers if (data[pos] == '%') 134fb11a9c2SBrian Somers len++; 135fb11a9c2SBrian Somers if ((fmt = alloca(len + 4)) == NULL) { 136fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: alloca(%d) failure... %s\n", 137fb11a9c2SBrian Somers dev->dev.name, len + 4, strerror(errno)); 138fb11a9c2SBrian Somers return 0; 139fb11a9c2SBrian Somers } 140fb11a9c2SBrian Somers 141fb11a9c2SBrian Somers /* 142fb11a9c2SBrian Somers * This is probably a waste of time, but we really don't want to end 143fb11a9c2SBrian Somers * up stuffing unexpected % escapes into the kernel.... 144fb11a9c2SBrian Somers */ 145057f1760SBrian Somers for (pos = dpos = 0; pos < (int)len;) { 146fb11a9c2SBrian Somers if (data[dpos] == '%') 147fb11a9c2SBrian Somers fmt[pos++] = '%'; 148fb11a9c2SBrian Somers fmt[pos++] = data[dpos++]; 149fb11a9c2SBrian Somers } 150fb11a9c2SBrian Somers strcpy(fmt + pos, " %s"); 151fb11a9c2SBrian Somers data += dpos; 152fb11a9c2SBrian Somers 153fb11a9c2SBrian Somers data += strspn(data, " \t"); 154fb11a9c2SBrian Somers if (NgSendAsciiMsg(dev->cs, path, fmt, data) < 0) { 155fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: NgSendAsciiMsg (to %s): \"%s\", \"%s\": %s\n", 156fb11a9c2SBrian Somers dev->dev.name, path, fmt, data, strerror(errno)); 157fb11a9c2SBrian Somers return 0; 158fb11a9c2SBrian Somers } 159fb11a9c2SBrian Somers 160fb11a9c2SBrian Somers return 1; 161fb11a9c2SBrian Somers } 162fb11a9c2SBrian Somers 163fb11a9c2SBrian Somers /* 164fb11a9c2SBrian Somers * Get a netgraph message 165fb11a9c2SBrian Somers */ 166fb11a9c2SBrian Somers static ssize_t 167fb11a9c2SBrian Somers ng_MessageIn(struct physical *p, char *buf, size_t sz) 168fb11a9c2SBrian Somers { 169fb11a9c2SBrian Somers char msgbuf[sizeof(struct ng_mesg) * 2 + NG_MSGBUFSZ]; 170fb11a9c2SBrian Somers struct ngdevice *dev = device2ng(p->handler); 171fb11a9c2SBrian Somers struct ng_mesg *rep = (struct ng_mesg *)msgbuf; 17289624a34SHartmut Brandt char path[NG_PATHSIZ]; 173057f1760SBrian Somers size_t len; 174fb11a9c2SBrian Somers 175fb11a9c2SBrian Somers #ifdef BROKEN_SELECT 176fb11a9c2SBrian Somers struct timeval t; 177fb11a9c2SBrian Somers fd_set *r; 178fb11a9c2SBrian Somers int ret; 179fb11a9c2SBrian Somers 180fb11a9c2SBrian Somers if (dev->cs < 0) 181fb11a9c2SBrian Somers return 0; 182fb11a9c2SBrian Somers 183fb11a9c2SBrian Somers if ((r = mkfdset()) == NULL) { 184fb11a9c2SBrian Somers log_Printf(LogERROR, "DoLoop: Cannot create fd_set\n"); 185fb11a9c2SBrian Somers return -1; 186fb11a9c2SBrian Somers } 187fb11a9c2SBrian Somers zerofdset(r); 188fb11a9c2SBrian Somers FD_SET(dev->cs, r); 189fb11a9c2SBrian Somers t.tv_sec = t.tv_usec = 0; 190fb11a9c2SBrian Somers ret = select(dev->cs + 1, r, NULL, NULL, &t); 191fb11a9c2SBrian Somers free(r); 192fb11a9c2SBrian Somers 193fb11a9c2SBrian Somers if (ret <= 0) 194fb11a9c2SBrian Somers return 0; 195fb11a9c2SBrian Somers #endif 196fb11a9c2SBrian Somers 197fb11a9c2SBrian Somers if (NgRecvAsciiMsg(dev->cs, rep, sizeof msgbuf, path)) { 198fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: NgRecvAsciiMsg: %s\n", 199fb11a9c2SBrian Somers dev->dev.name, strerror(errno)); 200fb11a9c2SBrian Somers return -1; 201fb11a9c2SBrian Somers } 202fb11a9c2SBrian Somers 203fb11a9c2SBrian Somers /* XXX: Should we check rep->header.version ? */ 204fb11a9c2SBrian Somers 205fb11a9c2SBrian Somers if (sz == 0) 206fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Unexpected message: %s\n", dev->dev.name, 207fb11a9c2SBrian Somers rep->header.cmdstr); 208fb11a9c2SBrian Somers else { 209fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: Received message: %s\n", dev->dev.name, 210fb11a9c2SBrian Somers rep->header.cmdstr); 211fb11a9c2SBrian Somers len = strlen(rep->header.cmdstr); 212fb11a9c2SBrian Somers if (sz > len) 213fb11a9c2SBrian Somers sz = len; 214fb11a9c2SBrian Somers memcpy(buf, rep->header.cmdstr, sz); 215fb11a9c2SBrian Somers } 216fb11a9c2SBrian Somers 217fb11a9c2SBrian Somers return sz; 218fb11a9c2SBrian Somers } 219fb11a9c2SBrian Somers 220fb11a9c2SBrian Somers static ssize_t 221fb11a9c2SBrian Somers ng_Write(struct physical *p, const void *v, size_t n) 222fb11a9c2SBrian Somers { 223fb11a9c2SBrian Somers struct ngdevice *dev = device2ng(p->handler); 224fb11a9c2SBrian Somers 225fb11a9c2SBrian Somers switch (p->dl->state) { 226fb11a9c2SBrian Somers case DATALINK_DIAL: 227fb11a9c2SBrian Somers case DATALINK_LOGIN: 228057f1760SBrian Somers return ng_MessageOut(dev, v) ? (ssize_t)n : -1; 229fb11a9c2SBrian Somers } 230057f1760SBrian Somers return NgSendData(p->fd, dev->hook, v, n) == -1 ? -1 : (ssize_t)n; 231fb11a9c2SBrian Somers } 232fb11a9c2SBrian Somers 233fb11a9c2SBrian Somers static ssize_t 234fb11a9c2SBrian Somers ng_Read(struct physical *p, void *v, size_t n) 235fb11a9c2SBrian Somers { 23689624a34SHartmut Brandt char hook[NG_HOOKSIZ]; 237fb11a9c2SBrian Somers 238fb11a9c2SBrian Somers switch (p->dl->state) { 239fb11a9c2SBrian Somers case DATALINK_DIAL: 240fb11a9c2SBrian Somers case DATALINK_LOGIN: 241fb11a9c2SBrian Somers return ng_MessageIn(p, v, n); 242fb11a9c2SBrian Somers } 243fb11a9c2SBrian Somers 244fb11a9c2SBrian Somers return NgRecvData(p->fd, v, n, hook); 245fb11a9c2SBrian Somers } 246fb11a9c2SBrian Somers 247fb11a9c2SBrian Somers static int 248fb11a9c2SBrian Somers ng_RemoveFromSet(struct physical *p, fd_set *r, fd_set *w, fd_set *e) 249fb11a9c2SBrian Somers { 250fb11a9c2SBrian Somers struct ngdevice *dev = device2ng(p->handler); 251fb11a9c2SBrian Somers int result; 252fb11a9c2SBrian Somers 253fb11a9c2SBrian Somers if (r && dev->cs >= 0 && FD_ISSET(dev->cs, r)) { 254fb11a9c2SBrian Somers FD_CLR(dev->cs, r); 255fb11a9c2SBrian Somers log_Printf(LogTIMER, "%s: fdunset(ctrl) %d\n", p->link.name, dev->cs); 256fb11a9c2SBrian Somers result = 1; 257fb11a9c2SBrian Somers } else 258fb11a9c2SBrian Somers result = 0; 259fb11a9c2SBrian Somers 260fb11a9c2SBrian Somers /* Careful... physical_RemoveFromSet() called us ! */ 261fb11a9c2SBrian Somers 262fb11a9c2SBrian Somers p->handler->removefromset = NULL; 263fb11a9c2SBrian Somers result += physical_RemoveFromSet(p, r, w, e); 264fb11a9c2SBrian Somers p->handler->removefromset = ng_RemoveFromSet; 265fb11a9c2SBrian Somers 266fb11a9c2SBrian Somers return result; 267fb11a9c2SBrian Somers } 268fb11a9c2SBrian Somers 269fb11a9c2SBrian Somers static void 270fb11a9c2SBrian Somers ng_Free(struct physical *p) 271fb11a9c2SBrian Somers { 272fb11a9c2SBrian Somers struct ngdevice *dev = device2ng(p->handler); 273fb11a9c2SBrian Somers 274fb11a9c2SBrian Somers physical_SetDescriptor(p); 275fb11a9c2SBrian Somers if (dev->cs != -1) 276fb11a9c2SBrian Somers close(dev->cs); 277fb11a9c2SBrian Somers free(dev); 278fb11a9c2SBrian Somers } 279fb11a9c2SBrian Somers 280fb11a9c2SBrian Somers static void 281fb11a9c2SBrian Somers ng_device2iov(struct device *d, struct iovec *iov, int *niov, 282057f1760SBrian Somers int maxiov __unused, int *auxfd, int *nauxfd) 283fb11a9c2SBrian Somers { 284c5e246d4SBrian Somers struct ngdevice *dev; 285fb11a9c2SBrian Somers int sz = physical_MaxDeviceSize(); 286fb11a9c2SBrian Somers 287c5e246d4SBrian Somers iov[*niov].iov_base = d = realloc(d, sz); 288c5e246d4SBrian Somers if (d == NULL) { 289fb11a9c2SBrian Somers log_Printf(LogALERT, "Failed to allocate memory: %d\n", sz); 290fb11a9c2SBrian Somers AbortProgram(EX_OSERR); 291fb11a9c2SBrian Somers } 292fb11a9c2SBrian Somers iov[*niov].iov_len = sz; 293fb11a9c2SBrian Somers (*niov)++; 294fb11a9c2SBrian Somers 295c5e246d4SBrian Somers dev = device2ng(d); 296fb11a9c2SBrian Somers *auxfd = dev->cs; 297fb11a9c2SBrian Somers (*nauxfd)++; 298fb11a9c2SBrian Somers } 299fb11a9c2SBrian Somers 300fb11a9c2SBrian Somers static const struct device basengdevice = { 301fb11a9c2SBrian Somers NG_DEVICE, 302fb11a9c2SBrian Somers "netgraph", 303fb11a9c2SBrian Somers 0, 304fb11a9c2SBrian Somers { CD_REQUIRED, DEF_NGCDDELAY }, 305fb11a9c2SBrian Somers NULL, 306fb11a9c2SBrian Somers ng_RemoveFromSet, 307fb11a9c2SBrian Somers NULL, 308fb11a9c2SBrian Somers NULL, 309fb11a9c2SBrian Somers NULL, 310fb11a9c2SBrian Somers NULL, 311fb11a9c2SBrian Somers NULL, 312fb11a9c2SBrian Somers ng_Free, 313fb11a9c2SBrian Somers ng_Read, 314fb11a9c2SBrian Somers ng_Write, 315fb11a9c2SBrian Somers ng_device2iov, 316fb11a9c2SBrian Somers NULL, 317de59e178SBrian Somers NULL, 318fb11a9c2SBrian Somers NULL 319fb11a9c2SBrian Somers }; 320fb11a9c2SBrian Somers 321fb11a9c2SBrian Somers struct device * 322fb11a9c2SBrian Somers ng_iov2device(int type, struct physical *p, struct iovec *iov, int *niov, 323057f1760SBrian Somers int maxiov __unused, int *auxfd, int *nauxfd) 324fb11a9c2SBrian Somers { 325fb11a9c2SBrian Somers if (type == NG_DEVICE) { 326fb11a9c2SBrian Somers struct ngdevice *dev = (struct ngdevice *)iov[(*niov)++].iov_base; 327fb11a9c2SBrian Somers 328fb11a9c2SBrian Somers dev = realloc(dev, sizeof *dev); /* Reduce to the correct size */ 329fb11a9c2SBrian Somers if (dev == NULL) { 330fb11a9c2SBrian Somers log_Printf(LogALERT, "Failed to allocate memory: %d\n", 331fb11a9c2SBrian Somers (int)(sizeof *dev)); 332fb11a9c2SBrian Somers AbortProgram(EX_OSERR); 333fb11a9c2SBrian Somers } 334fb11a9c2SBrian Somers 335fb11a9c2SBrian Somers if (*nauxfd) { 336fb11a9c2SBrian Somers dev->cs = *auxfd; 337fb11a9c2SBrian Somers (*nauxfd)--; 338fb11a9c2SBrian Somers } else 339fb11a9c2SBrian Somers dev->cs = -1; 340fb11a9c2SBrian Somers 341fb11a9c2SBrian Somers /* Refresh function pointers etc */ 342fb11a9c2SBrian Somers memcpy(&dev->dev, &basengdevice, sizeof dev->dev); 343fb11a9c2SBrian Somers 344fb11a9c2SBrian Somers /* XXX: Are netgraph always synchronous ? */ 345fb11a9c2SBrian Somers physical_SetupStack(p, dev->dev.name, PHYSICAL_FORCE_SYNCNOACF); 346fb11a9c2SBrian Somers return &dev->dev; 347fb11a9c2SBrian Somers } 348fb11a9c2SBrian Somers 349fb11a9c2SBrian Somers return NULL; 350fb11a9c2SBrian Somers } 351fb11a9c2SBrian Somers 352fb11a9c2SBrian Somers static int 353fb11a9c2SBrian Somers ng_UpdateSet(struct fdescriptor *d, fd_set *r, fd_set *w, fd_set *e, int *n) 354fb11a9c2SBrian Somers { 355fb11a9c2SBrian Somers struct physical *p = descriptor2physical(d); 356fb11a9c2SBrian Somers struct ngdevice *dev = device2ng(p->handler); 357fb11a9c2SBrian Somers int result; 358fb11a9c2SBrian Somers 359fb11a9c2SBrian Somers switch (p->dl->state) { 360fb11a9c2SBrian Somers case DATALINK_DIAL: 361fb11a9c2SBrian Somers case DATALINK_LOGIN: 362fb11a9c2SBrian Somers if (r) { 363fb11a9c2SBrian Somers FD_SET(dev->cs, r); 364fb11a9c2SBrian Somers log_Printf(LogTIMER, "%s(ctrl): fdset(r) %d\n", p->link.name, dev->cs); 365fb11a9c2SBrian Somers result = 1; 366fb11a9c2SBrian Somers } else 367fb11a9c2SBrian Somers result = 0; 368fb11a9c2SBrian Somers break; 369fb11a9c2SBrian Somers 370fb11a9c2SBrian Somers default: 371fb11a9c2SBrian Somers result = physical_doUpdateSet(d, r, w, e, n, 0); 372fb11a9c2SBrian Somers break; 373fb11a9c2SBrian Somers } 374fb11a9c2SBrian Somers 375fb11a9c2SBrian Somers return result; 376fb11a9c2SBrian Somers } 377fb11a9c2SBrian Somers 378fb11a9c2SBrian Somers static int 379fb11a9c2SBrian Somers ng_IsSet(struct fdescriptor *d, const fd_set *fdset) 380fb11a9c2SBrian Somers { 381fb11a9c2SBrian Somers struct physical *p = descriptor2physical(d); 382fb11a9c2SBrian Somers struct ngdevice *dev = device2ng(p->handler); 383fb11a9c2SBrian Somers int result; 384fb11a9c2SBrian Somers 385fb11a9c2SBrian Somers result = dev->cs >= 0 && FD_ISSET(dev->cs, fdset); 386fb11a9c2SBrian Somers result += physical_IsSet(d, fdset); 387fb11a9c2SBrian Somers 388fb11a9c2SBrian Somers return result; 389fb11a9c2SBrian Somers } 390fb11a9c2SBrian Somers 391fb11a9c2SBrian Somers static void 392fb11a9c2SBrian Somers ng_DescriptorRead(struct fdescriptor *d, struct bundle *bundle, 393fb11a9c2SBrian Somers const fd_set *fdset) 394fb11a9c2SBrian Somers { 395fb11a9c2SBrian Somers struct physical *p = descriptor2physical(d); 396fb11a9c2SBrian Somers struct ngdevice *dev = device2ng(p->handler); 397fb11a9c2SBrian Somers 398fb11a9c2SBrian Somers if (dev->cs >= 0 && FD_ISSET(dev->cs, fdset)) 399fb11a9c2SBrian Somers ng_MessageIn(p, NULL, 0); 400fb11a9c2SBrian Somers 401fb11a9c2SBrian Somers if (physical_IsSet(d, fdset)) 402fb11a9c2SBrian Somers physical_DescriptorRead(d, bundle, fdset); 403fb11a9c2SBrian Somers } 404fb11a9c2SBrian Somers 405fb11a9c2SBrian Somers static struct device * 406fb11a9c2SBrian Somers ng_Abandon(struct ngdevice *dev, struct physical *p) 407fb11a9c2SBrian Somers { 408fb11a9c2SBrian Somers /* Abandon our node construction */ 409fb11a9c2SBrian Somers close(dev->cs); 410fb11a9c2SBrian Somers close(p->fd); 411fb11a9c2SBrian Somers p->fd = -2; /* Nobody else need try.. */ 412fb11a9c2SBrian Somers free(dev); 413fb11a9c2SBrian Somers 414fb11a9c2SBrian Somers return NULL; 415fb11a9c2SBrian Somers } 416fb11a9c2SBrian Somers 417fb11a9c2SBrian Somers 418fb11a9c2SBrian Somers /* 419fb11a9c2SBrian Somers * Populate the ``word'' (of size ``sz'') named ``what'' from ``from'' 420fb11a9c2SBrian Somers * ending with any character from ``sep''. Point ``endp'' at the next 421fb11a9c2SBrian Somers * word. 422fb11a9c2SBrian Somers */ 423fb11a9c2SBrian Somers 424fb11a9c2SBrian Somers #define GETSEGMENT(what, from, sep, endp) \ 425fb11a9c2SBrian Somers getsegment(#what, (what), sizeof(what), from, sep, endp) 426fb11a9c2SBrian Somers 427fb11a9c2SBrian Somers static int 428fb11a9c2SBrian Somers getsegment(const char *what, char *word, size_t sz, const char *from, 429fb11a9c2SBrian Somers const char *sep, const char **endp) 430fb11a9c2SBrian Somers { 431057f1760SBrian Somers size_t len; 432fb11a9c2SBrian Somers 433fb11a9c2SBrian Somers if ((len = strcspn(from, sep)) == 0) { 434fb11a9c2SBrian Somers log_Printf(LogWARN, "%s name should not be empty !\n", what); 435fb11a9c2SBrian Somers return 0; 436fb11a9c2SBrian Somers } 437fb11a9c2SBrian Somers 438fb11a9c2SBrian Somers if (len >= sz) { 439fb11a9c2SBrian Somers log_Printf(LogWARN, "%s name too long, max %d !\n", what, sz - 1); 440fb11a9c2SBrian Somers return 0; 441fb11a9c2SBrian Somers } 442fb11a9c2SBrian Somers 443fb11a9c2SBrian Somers strncpy(word, from, len); 444fb11a9c2SBrian Somers word[len] = '\0'; 445fb11a9c2SBrian Somers 446fb11a9c2SBrian Somers *endp = from + len; 447fb11a9c2SBrian Somers *endp += strspn(*endp, sep); 448fb11a9c2SBrian Somers 449fb11a9c2SBrian Somers return 1; 450fb11a9c2SBrian Somers } 451fb11a9c2SBrian Somers 452fb11a9c2SBrian Somers struct device * 453fb11a9c2SBrian Somers ng_Create(struct physical *p) 454fb11a9c2SBrian Somers { 455fb11a9c2SBrian Somers struct sockaddr_ng ngsock; 456fb11a9c2SBrian Somers u_char rbuf[2048]; 457fb11a9c2SBrian Somers struct sockaddr *sock = (struct sockaddr *)&ngsock; 458fb11a9c2SBrian Somers const struct hooklist *hlist; 459fb11a9c2SBrian Somers const struct nodeinfo *ninfo; 460fb11a9c2SBrian Somers const struct linkinfo *nlink; 461fb11a9c2SBrian Somers struct ngdevice *dev; 462fb11a9c2SBrian Somers struct ng_mesg *resp; 463fb11a9c2SBrian Somers struct ngm_mkpeer mkp; 464fb11a9c2SBrian Somers struct ngm_connect ngc; 465fb11a9c2SBrian Somers const char *devp, *endp; 46689624a34SHartmut Brandt char lasthook[NG_HOOKSIZ]; 46789624a34SHartmut Brandt char hook[NG_HOOKSIZ]; 46889624a34SHartmut Brandt char nodetype[NG_TYPESIZ + NG_NODESIZ]; 46989624a34SHartmut Brandt char modname[NG_TYPESIZ + 3]; 47089624a34SHartmut Brandt char path[NG_PATHSIZ]; 471fb11a9c2SBrian Somers char *nodename; 472057f1760SBrian Somers int len, sz, done; 473057f1760SBrian Somers unsigned f; 474fb11a9c2SBrian Somers 475fb11a9c2SBrian Somers dev = NULL; 476fb11a9c2SBrian Somers if (p->fd < 0 && !strncasecmp(p->name.full, NETGRAPH_PREFIX, 477fb11a9c2SBrian Somers sizeof NETGRAPH_PREFIX - 1)) { 478fb11a9c2SBrian Somers p->fd--; /* We own the device - change fd */ 479fb11a9c2SBrian Somers 480fb11a9c2SBrian Somers if ((dev = malloc(sizeof *dev)) == NULL) 481fb11a9c2SBrian Somers return NULL; 482fb11a9c2SBrian Somers 483fb11a9c2SBrian Somers loadmodules(LOAD_VERBOSLY, "netgraph", "ng_socket", NULL); 484fb11a9c2SBrian Somers 485fb11a9c2SBrian Somers /* Create a socket node */ 486fb11a9c2SBrian Somers if (ID0NgMkSockNode(NULL, &dev->cs, &p->fd) == -1) { 487fb11a9c2SBrian Somers log_Printf(LogWARN, "Cannot create netgraph socket node: %s\n", 488fb11a9c2SBrian Somers strerror(errno)); 489fb11a9c2SBrian Somers free(dev); 490fb11a9c2SBrian Somers p->fd = -2; 491fb11a9c2SBrian Somers return NULL; 492fb11a9c2SBrian Somers } 493fb11a9c2SBrian Somers 494fb11a9c2SBrian Somers devp = p->name.full + sizeof NETGRAPH_PREFIX - 1; 495fb11a9c2SBrian Somers *lasthook = *path = '\0'; 496fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: Opening netgraph device \"%s\"\n", 497fb11a9c2SBrian Somers p->link.name, devp); 498fb11a9c2SBrian Somers done = 0; 499fb11a9c2SBrian Somers 500fb11a9c2SBrian Somers while (*devp != '\0' && !done) { 501fb11a9c2SBrian Somers if (*devp != '[') { 502fb11a9c2SBrian Somers if (*lasthook == '\0') { 503fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Netgraph devices must start with" 504fb11a9c2SBrian Somers " [nodetype:nodename]\n", p->link.name); 505fb11a9c2SBrian Somers return ng_Abandon(dev, p); 506fb11a9c2SBrian Somers } 507fb11a9c2SBrian Somers 508fb11a9c2SBrian Somers /* Get the hook name of the new node */ 509fb11a9c2SBrian Somers if (!GETSEGMENT(hook, devp, ".[", &endp)) 510fb11a9c2SBrian Somers return ng_Abandon(dev, p); 511fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: Got hook \"%s\"\n", p->link.name, hook); 512fb11a9c2SBrian Somers devp = endp; 513fb11a9c2SBrian Somers if (*devp == '\0') { 514fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Netgraph device must not end with a second" 515fb11a9c2SBrian Somers " hook\n", p->link.name); 516fb11a9c2SBrian Somers return ng_Abandon(dev, p); 517fb11a9c2SBrian Somers } 518fb11a9c2SBrian Somers if (devp[-1] != '[') { 519fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Expected a [nodetype:nodename] at device" 520fb11a9c2SBrian Somers " pos %d\n", p->link.name, devp - p->link.name - 1); 521fb11a9c2SBrian Somers return ng_Abandon(dev, p); 522fb11a9c2SBrian Somers } 523fb11a9c2SBrian Somers } else { 524fb11a9c2SBrian Somers /* Use lasthook as the hook name */ 525fb11a9c2SBrian Somers strcpy(hook, lasthook); 526fb11a9c2SBrian Somers devp++; 527fb11a9c2SBrian Somers } 528fb11a9c2SBrian Somers 529fb11a9c2SBrian Somers /* We've got ``lasthook'' and ``hook'', get the node type */ 530fb11a9c2SBrian Somers if (!GETSEGMENT(nodetype, devp, "]", &endp)) 531fb11a9c2SBrian Somers return ng_Abandon(dev, p); 532fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: Got node \"%s\"\n", p->link.name, nodetype); 533fb11a9c2SBrian Somers 534fb11a9c2SBrian Somers if ((nodename = strchr(nodetype, ':')) != NULL) { 535fb11a9c2SBrian Somers *nodename++ = '\0'; 536fb11a9c2SBrian Somers if (*nodename == '\0' && *nodetype == '\0') { 537fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Empty [nodetype:nodename] at device" 538fb11a9c2SBrian Somers " pos %d\n", p->link.name, devp - p->link.name - 1); 539fb11a9c2SBrian Somers return ng_Abandon(dev, p); 540fb11a9c2SBrian Somers } 541fb11a9c2SBrian Somers } 542fb11a9c2SBrian Somers 543fb11a9c2SBrian Somers /* Ignore optional colons after nodes */ 544fb11a9c2SBrian Somers devp = *endp == ':' ? endp + 1 : endp; 545fb11a9c2SBrian Somers if (*devp == '.') 546fb11a9c2SBrian Somers devp++; 547fb11a9c2SBrian Somers 548fb11a9c2SBrian Somers if (*lasthook == '\0') { 549fb11a9c2SBrian Somers /* This is the first node in the chain */ 550fb11a9c2SBrian Somers if (nodename == NULL || *nodename == '\0') { 551fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: %s: No initial device nodename\n", 552fb11a9c2SBrian Somers p->link.name, devp); 553fb11a9c2SBrian Somers return ng_Abandon(dev, p); 554fb11a9c2SBrian Somers } 555fb11a9c2SBrian Somers 556fb11a9c2SBrian Somers if (*nodetype != '\0') { 557fb11a9c2SBrian Somers /* Attempt to load the module */ 558fb11a9c2SBrian Somers snprintf(modname, sizeof modname, "ng_%s", nodetype); 559fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: Attempting to load %s.ko\n", 560fb11a9c2SBrian Somers p->link.name, modname); 561fb11a9c2SBrian Somers loadmodules(LOAD_QUIETLY, modname, NULL); 562fb11a9c2SBrian Somers } 563fb11a9c2SBrian Somers 564fb11a9c2SBrian Somers snprintf(path, sizeof path, "%s:", nodename); 565fb11a9c2SBrian Somers /* XXX: If we have a node type, ensure it's correct */ 566fb11a9c2SBrian Somers } else { 567fb11a9c2SBrian Somers /* 568fb11a9c2SBrian Somers * Ask for a list of hooks attached to the previous node. If we 569fb11a9c2SBrian Somers * find the one we're interested in, and if it's connected to a 570fb11a9c2SBrian Somers * node of the right type using the correct hook, use that. 571fb11a9c2SBrian Somers * If we find the hook connected to something else, fail. 572fb11a9c2SBrian Somers * If we find no match, mkpeer the new node. 573fb11a9c2SBrian Somers */ 574fb11a9c2SBrian Somers if (*nodetype == '\0') { 575fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Nodetype missing at device offset %d\n", 576fb11a9c2SBrian Somers p->link.name, 577fb11a9c2SBrian Somers devp - p->name.full + sizeof NETGRAPH_PREFIX - 1); 578fb11a9c2SBrian Somers return ng_Abandon(dev, p); 579fb11a9c2SBrian Somers } 580fb11a9c2SBrian Somers 581fb11a9c2SBrian Somers /* Get a list of node hooks */ 582fb11a9c2SBrian Somers if (NgSendMsg(dev->cs, path, NGM_GENERIC_COOKIE, NGM_LISTHOOKS, 583fb11a9c2SBrian Somers NULL, 0) < 0) { 584fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: %s Cannot send a LISTHOOOKS message: %s\n", 585fb11a9c2SBrian Somers p->link.name, path, strerror(errno)); 586fb11a9c2SBrian Somers return ng_Abandon(dev, p); 587fb11a9c2SBrian Somers } 588fb11a9c2SBrian Somers 589fb11a9c2SBrian Somers /* Get our list back */ 590fb11a9c2SBrian Somers resp = (struct ng_mesg *)rbuf; 591fb11a9c2SBrian Somers if (NgRecvMsg(dev->cs, resp, sizeof rbuf, NULL) <= 0) { 592fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Cannot get netgraph response: %s\n", 593fb11a9c2SBrian Somers p->link.name, strerror(errno)); 594fb11a9c2SBrian Somers return ng_Abandon(dev, p); 595fb11a9c2SBrian Somers } 596fb11a9c2SBrian Somers 597fb11a9c2SBrian Somers hlist = (const struct hooklist *)resp->data; 598fb11a9c2SBrian Somers ninfo = &hlist->nodeinfo; 599fb11a9c2SBrian Somers 600fb11a9c2SBrian Somers log_Printf(LogDEBUG, "List of netgraph node ``%s'' (id %x) hooks:\n", 601fb11a9c2SBrian Somers path, ninfo->id); 602fb11a9c2SBrian Somers 603fb11a9c2SBrian Somers /* look for a hook already attached. */ 604fb11a9c2SBrian Somers for (f = 0; f < ninfo->hooks; f++) { 605fb11a9c2SBrian Somers nlink = &hlist->link[f]; 606fb11a9c2SBrian Somers 607fb11a9c2SBrian Somers log_Printf(LogDEBUG, " Found %s -> %s (type %s)\n", nlink->ourhook, 608fb11a9c2SBrian Somers nlink->peerhook, nlink->nodeinfo.type); 609fb11a9c2SBrian Somers 610fb11a9c2SBrian Somers if (!strcmp(nlink->ourhook, lasthook)) { 611fb11a9c2SBrian Somers if (strcmp(nlink->peerhook, hook) || 612fb11a9c2SBrian Somers strcmp(nlink->nodeinfo.type, nodetype)) { 613fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: hook %s:%s is already in use\n", 614fb11a9c2SBrian Somers p->link.name, nlink->ourhook, path); 615fb11a9c2SBrian Somers return ng_Abandon(dev, p); 616fb11a9c2SBrian Somers } 617fb11a9c2SBrian Somers /* The node is already hooked up nicely.... reuse it */ 618fb11a9c2SBrian Somers break; 619fb11a9c2SBrian Somers } 620fb11a9c2SBrian Somers } 621fb11a9c2SBrian Somers 622fb11a9c2SBrian Somers if (f == ninfo->hooks) { 623fb11a9c2SBrian Somers /* Attempt to load the module */ 624fb11a9c2SBrian Somers snprintf(modname, sizeof modname, "ng_%s", nodetype); 625fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: Attempting to load %s.ko\n", 626fb11a9c2SBrian Somers p->link.name, modname); 627fb11a9c2SBrian Somers loadmodules(LOAD_QUIETLY, modname, NULL); 628fb11a9c2SBrian Somers 629fb11a9c2SBrian Somers /* Create (mkpeer) the new node */ 630fb11a9c2SBrian Somers 631fb11a9c2SBrian Somers snprintf(mkp.type, sizeof mkp.type, "%s", nodetype); 632fb11a9c2SBrian Somers snprintf(mkp.ourhook, sizeof mkp.ourhook, "%s", lasthook); 633fb11a9c2SBrian Somers snprintf(mkp.peerhook, sizeof mkp.peerhook, "%s", hook); 634fb11a9c2SBrian Somers 635fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: Doing MKPEER %s%s -> %s (type %s)\n", 636fb11a9c2SBrian Somers p->link.name, path, mkp.ourhook, mkp.peerhook, nodetype); 637fb11a9c2SBrian Somers 638fb11a9c2SBrian Somers if (NgSendMsg(dev->cs, path, NGM_GENERIC_COOKIE, 639fb11a9c2SBrian Somers NGM_MKPEER, &mkp, sizeof mkp) < 0) { 640fb11a9c2SBrian Somers log_Printf(LogWARN, "%s Cannot create %s netgraph node: %s\n", 641fb11a9c2SBrian Somers path, nodetype, strerror(errno)); 642fb11a9c2SBrian Somers return ng_Abandon(dev, p); 643fb11a9c2SBrian Somers } 644fb11a9c2SBrian Somers } 645fb11a9c2SBrian Somers len = strlen(path); 646fb11a9c2SBrian Somers snprintf(path + len, sizeof path - len, "%s%s", 647fb11a9c2SBrian Somers path[len - 1] == ':' ? "" : ".", lasthook); 648fb11a9c2SBrian Somers } 649fb11a9c2SBrian Somers 650fb11a9c2SBrian Somers /* Get a list of node hooks */ 651fb11a9c2SBrian Somers if (NgSendMsg(dev->cs, path, NGM_GENERIC_COOKIE, NGM_LISTHOOKS, 652fb11a9c2SBrian Somers NULL, 0) < 0) { 653fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: %s Cannot send a LISTHOOOKS message: %s\n", 654fb11a9c2SBrian Somers p->link.name, path, strerror(errno)); 655fb11a9c2SBrian Somers return ng_Abandon(dev, p); 656fb11a9c2SBrian Somers } 657fb11a9c2SBrian Somers 658fb11a9c2SBrian Somers /* Get our list back */ 659fb11a9c2SBrian Somers resp = (struct ng_mesg *)rbuf; 660fb11a9c2SBrian Somers if (NgRecvMsg(dev->cs, resp, sizeof rbuf, NULL) <= 0) { 661fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Cannot get netgraph response: %s\n", 662fb11a9c2SBrian Somers p->link.name, strerror(errno)); 663fb11a9c2SBrian Somers return ng_Abandon(dev, p); 664fb11a9c2SBrian Somers } 665fb11a9c2SBrian Somers 666fb11a9c2SBrian Somers hlist = (const struct hooklist *)resp->data; 667fb11a9c2SBrian Somers ninfo = &hlist->nodeinfo; 668fb11a9c2SBrian Somers 669fb11a9c2SBrian Somers if (*lasthook != '\0' && nodename != NULL && *nodename != '\0' && 670fb11a9c2SBrian Somers strcmp(ninfo->name, nodename) && 671fb11a9c2SBrian Somers NgNameNode(dev->cs, path, "%s", nodename) < 0) { 672fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: %s: Cannot name netgraph node: %s\n", 673fb11a9c2SBrian Somers p->link.name, path, strerror(errno)); 674fb11a9c2SBrian Somers return ng_Abandon(dev, p); 675fb11a9c2SBrian Somers } 676fb11a9c2SBrian Somers 677fb11a9c2SBrian Somers if (!GETSEGMENT(lasthook, devp, " \t.[", &endp)) 678fb11a9c2SBrian Somers return ng_Abandon(dev, p); 679fb11a9c2SBrian Somers log_Printf(LogDEBUG, "%s: Got hook \"%s\"\n", p->link.name, lasthook); 680fb11a9c2SBrian Somers 681fb11a9c2SBrian Somers len = strlen(lasthook); 682fb11a9c2SBrian Somers done = strchr(" \t", devp[len]) ? 1 : 0; 683fb11a9c2SBrian Somers devp = endp; 684fb11a9c2SBrian Somers 685fb11a9c2SBrian Somers if (*devp != '\0') { 686fb11a9c2SBrian Somers if (devp[-1] == '[') 687fb11a9c2SBrian Somers devp--; 688fb11a9c2SBrian Somers } /* else should moan about devp[-1] being '[' ? */ 689fb11a9c2SBrian Somers } 690fb11a9c2SBrian Somers 691fb11a9c2SBrian Somers snprintf(dev->hook, sizeof dev->hook, "%s", lasthook); 692fb11a9c2SBrian Somers 693fb11a9c2SBrian Somers /* Connect the node to our socket node */ 694fb11a9c2SBrian Somers snprintf(ngc.path, sizeof ngc.path, "%s", path); 695fb11a9c2SBrian Somers snprintf(ngc.ourhook, sizeof ngc.ourhook, "%s", dev->hook); 696fb11a9c2SBrian Somers memcpy(ngc.peerhook, ngc.ourhook, sizeof ngc.peerhook); 697fb11a9c2SBrian Somers 698fb11a9c2SBrian Somers log_Printf(LogDEBUG, "Connecting netgraph socket .:%s -> %s.%s\n", 699fb11a9c2SBrian Somers ngc.ourhook, ngc.path, ngc.peerhook); 700fb11a9c2SBrian Somers if (NgSendMsg(dev->cs, ".:", NGM_GENERIC_COOKIE, 701fb11a9c2SBrian Somers NGM_CONNECT, &ngc, sizeof ngc) < 0) { 702fb11a9c2SBrian Somers log_Printf(LogWARN, "Cannot connect %s and socket netgraph " 703fb11a9c2SBrian Somers "nodes: %s\n", path, strerror(errno)); 704fb11a9c2SBrian Somers return ng_Abandon(dev, p); 705fb11a9c2SBrian Somers } 706fb11a9c2SBrian Somers 707fb11a9c2SBrian Somers /* Hook things up so that we monitor dev->cs */ 708fb11a9c2SBrian Somers p->desc.UpdateSet = ng_UpdateSet; 709fb11a9c2SBrian Somers p->desc.IsSet = ng_IsSet; 710fb11a9c2SBrian Somers p->desc.Read = ng_DescriptorRead; 711fb11a9c2SBrian Somers 712fb11a9c2SBrian Somers memcpy(&dev->dev, &basengdevice, sizeof dev->dev); 713fb11a9c2SBrian Somers 714fb11a9c2SBrian Somers } else { 715fb11a9c2SBrian Somers /* See if we're a netgraph socket */ 716fb11a9c2SBrian Somers 717fb11a9c2SBrian Somers sz = sizeof ngsock; 718fb11a9c2SBrian Somers if (getsockname(p->fd, sock, &sz) != -1 && sock->sa_family == AF_NETGRAPH) { 719fb11a9c2SBrian Somers /* 720fb11a9c2SBrian Somers * It's a netgraph node... We can't determine hook names etc, so we 721fb11a9c2SBrian Somers * stay pretty impartial.... 722fb11a9c2SBrian Somers */ 723fb11a9c2SBrian Somers log_Printf(LogPHASE, "%s: Link is a netgraph node\n", p->link.name); 724fb11a9c2SBrian Somers 725fb11a9c2SBrian Somers if ((dev = malloc(sizeof *dev)) == NULL) { 726fb11a9c2SBrian Somers log_Printf(LogWARN, "%s: Cannot allocate an ether device: %s\n", 727fb11a9c2SBrian Somers p->link.name, strerror(errno)); 728fb11a9c2SBrian Somers return NULL; 729fb11a9c2SBrian Somers } 730fb11a9c2SBrian Somers 731fb11a9c2SBrian Somers memcpy(&dev->dev, &basengdevice, sizeof dev->dev); 732fb11a9c2SBrian Somers dev->cs = -1; 733fb11a9c2SBrian Somers *dev->hook = '\0'; 734fb11a9c2SBrian Somers } 735fb11a9c2SBrian Somers } 736fb11a9c2SBrian Somers 737fb11a9c2SBrian Somers if (dev) { 738fb11a9c2SBrian Somers physical_SetupStack(p, dev->dev.name, PHYSICAL_FORCE_SYNCNOACF); 739fb11a9c2SBrian Somers return &dev->dev; 740fb11a9c2SBrian Somers } 741fb11a9c2SBrian Somers 742fb11a9c2SBrian Somers return NULL; 743fb11a9c2SBrian Somers } 744