sys/src/cmd/ip/tftpd.c

   1 /*
   2  * tftpd - tftp service, see /lib/rfc/rfc783 (now rfc1350 + 234[789])
   3  */
   4 #include <u.h>
   5 #include <libc.h>
   6 #include <auth.h>
   7 #include <bio.h>
   8 #include <ip.h>
   9 #include <ndb.h>
  10
  11 enum
  12 {
  13         Maxpath=        128,
  14
  15         Debug=          0,
  16
  17         Opsize=         sizeof(short),
  18         Blksize=        sizeof(short),
  19         Hdrsize=        Opsize + Blksize,
  20
  21         Ackerr=         -1,
  22         Ackok=          0,
  23         Ackrexmit=      1,
  24
  25         /* op codes */
  26         Tftp_READ       = 1,
  27         Tftp_WRITE      = 2,
  28         Tftp_DATA       = 3,
  29         Tftp_ACK        = 4,
  30         Tftp_ERROR      = 5,
  31         Tftp_OACK       = 6,            /* option acknowledge */
  32
  33         Errnotdef       = 0,            /* see textual error instead */
  34         Errnotfound     = 1,
  35         Errnoaccess     = 2,
  36         Errdiskfull     = 3,
  37         Errbadop        = 4,
  38         Errbadtid       = 5,
  39         Errexists       = 6,
  40         Errnouser       = 7,
  41         Errbadopt       = 8,            /* really bad option value */
  42
  43         Defsegsize      = 512,
  44         Maxsegsize      = 65464,        /* from rfc2348 */
  45
  46         /*
  47          * bandt (viaduct) tunnels use smaller mtu than ether's
  48          * (1400 bytes for tcp mss of 1300 bytes).
  49          */
  50         Bandtmtu        = 1400,
  51         /*
  52          * maximum size of block's data content, excludes hdrs,
  53          * notably IP/UDP and TFTP, using worst-case (IPv6) sizes.
  54          */
  55         Bandtblksz      = Bandtmtu - 40 - 8,
  56         Bcavium         = 1432,         /* cavium's u-boot demands this size */
  57 };
  58
  59 typedef struct Opt Opt;
  60 struct Opt {
  61         char    *name;
  62         int     *valp;          /* set to client's value if within bounds */
  63         int     min;
  64         int     max;
  65 };
  66
  67 int     dbg;
  68 int     restricted;
  69 int     pid;
  70
  71 /* options */
  72 int     blksize = Defsegsize;           /* excluding 4-byte header */
  73 int     timeout = 5;                    /* seconds */
  74 int     tsize;
  75 static Opt option[] = {
  76         "timeout",      &timeout,       1,      255,
  77         /* see "hack" below */
  78         "blksize",      &blksize,       8,      Maxsegsize,
  79         "tsize",        &tsize,         0,      ~0UL >> 1,
  80 };
  81
  82 void    sendfile(int, char*, char*, int);
  83 void    recvfile(int, char*, char*);
  84 void    nak(int, int, char*);
  85 void    ack(int, ushort);
  86 void    clrcon(void);
  87 void    setuser(void);
  88 char*   sunkernel(char*);
  89 void    remoteaddr(char*, char*, int);
  90 void    doserve(int);
  91
  92 char    bigbuf[32768];
  93 char    raddr[64];
  94
  95 char    *dir = "/lib/tftpd";
  96 char    *dirsl;
  97 int     dirsllen;
  98 char    flog[] = "ipboot";
  99 char    net[Maxpath];
 100
 101 static char *opnames[] = {
 102 [Tftp_READ]     "read",
 103 [Tftp_WRITE]    "write",
 104 [Tftp_DATA]     "data",
 105 [Tftp_ACK]      "ack",
 106 [Tftp_ERROR]    "error",
 107 [Tftp_OACK]     "oack",
 108 };
 109
 110 void
 111 usage(void)
 112 {
 113         fprint(2, "usage: %s [-dr] [-h homedir] [-s svc] [-x netmtpt]\n",
 114                 argv0);
 115         exits("usage");
 116 }
 117
 118 void
 119 main(int argc, char **argv)
 120 {
 121         char buf[64];
 122         char adir[64], ldir[64];
 123         int cfd, lcfd, dfd;
 124         char *svc = "69";
 125
 126         setnetmtpt(net, sizeof net, nil);
 127         ARGBEGIN{
 128         case 'd':
 129                 dbg++;
 130                 break;
 131         case 'h':
 132                 dir = EARGF(usage());
 133                 break;
 134         case 'r':
 135                 restricted = 1;
 136                 break;
 137         case 's':
 138                 svc = EARGF(usage());
 139                 break;
 140         case 'x':
 141                 setnetmtpt(net, sizeof net, EARGF(usage()));
 142                 break;
 143         default:
 144                 usage();
 145         }ARGEND
 146
 147         snprint(buf, sizeof buf, "%s/", dir);
 148         dirsl = strdup(buf);
 149         dirsllen = strlen(dirsl);
 150
 151         fmtinstall('E', eipfmt);
 152         fmtinstall('I', eipfmt);
 153
 154         /*
 155          * setuser calls newns, and typical /lib/namespace files contain
 156          * "cd /usr/$user", so call setuser before chdir.
 157          */
 158         setuser();
 159         if(chdir(dir) < 0)
 160                 sysfatal("can't get to directory %s: %r", dir);
 161
 162         if(!dbg)
 163                 switch(rfork(RFNOTEG|RFPROC|RFFDG)) {
 164                 case -1:
 165                         sysfatal("fork: %r");
 166                 case 0:
 167                         break;
 168                 default:
 169                         exits(0);
 170                 }
 171
 172         snprint(buf, sizeof buf, "%s/udp!*!%s", net, svc);
 173         cfd = announce(buf, adir);
 174         if (cfd < 0)
 175                 sysfatal("announcing on %s: %r", buf);
 176         syslog(dbg, flog, "tftpd started on %s dir %s", buf, adir);
 177 //      setuser();
 178         for(;;) {
 179                 lcfd = listen(adir, ldir);
 180                 if(lcfd < 0)
 181                         sysfatal("listening on %s: %r", adir);
 182
 183                 switch(fork()) {
 184                 case -1:
 185                         sysfatal("fork: %r");
 186                 case 0:
 187                         dfd = accept(lcfd, ldir);
 188                         if(dfd < 0)
 189                                 exits(0);
 190                         remoteaddr(ldir, raddr, sizeof(raddr));
 191                         pid = getpid();
 192                         syslog(0, flog, "tftp %d connection from %s dir %s",
 193                                 pid, raddr, ldir);
 194                         doserve(dfd);
 195                         exits("done");
 196                         break;
 197                 default:
 198                         close(lcfd);
 199                         continue;
 200                 }
 201         }
 202 }
 203
 204 static Opt *
 205 handleopt(int fd, char *name, char *val)
 206 {
 207         int n;
 208         Opt *op;
 209
 210         for (op = option; op < option + nelem(option); op++)
 211                 if(cistrcmp(name, op->name) == 0) {
 212                         n = strtol(val, nil, 10);
 213                         if (n < op->min || n > op->max) {
 214                                 nak(fd, Errbadopt, "option value out of range");
 215                                 syslog(dbg, flog, "tftp bad option value from "
 216                                         "client: %s %s", name, val);
 217                                 sysfatal("bad option value from client: %s %s",
 218                                         name, val);
 219                         }
 220                         *op->valp = n;
 221                         /* incoming 0 for tsize is uninteresting */
 222                         if(cistrcmp("tsize", op->name) != 0)
 223                                 syslog(dbg, flog, "tftpd %d setting %s to client's %d",
 224                                         pid, name, n);
 225                         return op;
 226                 }
 227         return nil;
 228 }
 229
 230 static vlong
 231 filesize(char *file)
 232 {
 233         vlong size;
 234         Dir *dp;
 235
 236         dp = dirstat(file);
 237         if (dp == nil)
 238                 return -1;
 239         size = dp->length;
 240         free(dp);
 241         return size;
 242 }
 243
 244 /* copy word into bp iff it fits before ep, returns bytes to advance bp. */
 245 static int
 246 emits(char *word, char *bp, char *ep)
 247 {
 248         int len;
 249
 250         len = strlen(word) + 1;
 251         if (bp + len >= ep)
 252                 return -1;
 253         strcpy(bp, word);
 254         return len;
 255 }
 256
 257 /* format number into bp iff it fits before ep. */
 258 static int
 259 emitn(vlong n, char *bp, char *ep)
 260 {
 261         char numb[32];
 262
 263         snprint(numb, sizeof numb, "%lld", n);
 264         return emits(numb, bp, ep);
 265 }
 266
 267 /*
 268  * send an OACK packet to respond to options.  bail early with -1 on error.
 269  * p is the packet containing the options.
 270  *
 271  * hack: bandt (viaducts) uses smaller mtu than ether's
 272  * (1400 bytes for tcp mss of 1300 bytes),
 273  * so offer at most bandt's mtu minus headers,
 274  * to avoid failure of pxe booting via viaduct.
 275  * there's an exception for the cavium's u-boot.
 276  */
 277 static int
 278 options(int fd, char *buf, int bufsz, char *file, ushort oper, char *p, int dlen)
 279 {
 280         int nmlen, vallen, olen, nopts;
 281         vlong size;
 282         char *val, *bp, *ep;
 283         Opt *op;
 284
 285         buf[0] = 0;
 286         buf[1] = Tftp_OACK;
 287         bp = buf + Opsize;
 288         ep = buf + bufsz;
 289         nopts = 0;
 290         for (; dlen > 0 && *p != '\0'; p = val + vallen, bp += olen) {
 291                 nmlen = strlen(p) + 1;          /* include NUL */
 292                 if (nmlen > dlen)
 293                         break;
 294                 dlen -= nmlen;
 295                 val = p + nmlen;
 296                 if (dlen <= 0 || *val == '\0')
 297                         break;
 298
 299                 vallen = strlen(val) + 1;
 300                 if (vallen > dlen)
 301                         break;
 302                 dlen -= vallen;
 303
 304                 nopts++;
 305                 olen = 0;
 306                 op = handleopt(fd, p, val);
 307                 if (op == nil)
 308                         continue;
 309
 310                 /* append OACK response to buf */
 311                 nmlen = emits(p, bp, ep);       /* option name */
 312                 if (nmlen < 0)
 313                         return -1;
 314                 bp += nmlen;
 315
 316                 if (oper == Tftp_READ && cistrcmp(p, "tsize") == 0) {
 317                         size = filesize(file);
 318                         if (size == -1) {
 319                                 nak(fd, Errnotfound, "no such file");
 320                                 syslog(dbg, flog, "tftpd tsize for "
 321                                         "non-existent file %s", file);
 322                                 // *op->valp = 0;
 323                                 // olen = emits("0", bp, ep);
 324                                 return -1;
 325                         }
 326                         *op->valp = size;
 327                         olen = emitn(size, bp, ep);
 328                         syslog(dbg, flog, "tftpd %d %s tsize is %,lld",
 329                                 pid, file, size);
 330                 } else if (oper == Tftp_READ && cistrcmp(p, "blksize") == 0 &&
 331                     blksize > Bandtblksz && blksize != Bcavium) {
 332                         *op->valp = blksize = Bandtblksz;
 333                         olen = emitn(blksize, bp, ep);
 334                         syslog(dbg, flog, "tftpd %d overriding blksize to %d",
 335                                 pid, blksize);
 336                 } else
 337                         olen = emits(val, bp, ep);  /* use requested value */
 338         }
 339         if (nopts == 0)
 340                 return 0;               /* no options actually seen */
 341
 342         if (write(fd, buf, bp - buf) < bp - buf) {
 343                 syslog(dbg, flog, "tftpd network write error on oack to %s: %r",
 344                         raddr);
 345                 sysfatal("tftpd: network write error: %r");
 346         }
 347         if(Debug)
 348                 syslog(dbg, flog, "tftpd oack: options to %s", raddr);
 349         return nopts;
 350 }
 351
 352 static void
 353 optlog(char *bytes, char *p, int dlen)
 354 {
 355         char *bp;
 356
 357         bp = bytes;
 358         sprint(bp, "tftpd %d option bytes: ", dlen);
 359         bp += strlen(bp);
 360         for (; dlen > 0; dlen--, p++)
 361                 *bp++ = *p? *p: ' ';
 362         *bp = '\0';
 363         syslog(dbg, flog, "%s", bytes);
 364 }
 365
 366 /*
 367  * replace one occurrence of %[ICE] with ip, cfgpxe name, or ether mac, resp.
 368  * we can't easily use $ because u-boot has stranger quoting rules than sh.
 369  */
 370 char *
 371 mapname(char *file)
 372 {
 373         int nf;
 374         char *p, *newnm, *cur, *arpf, *ln, *remip, *bang;
 375         char *fields[4];
 376         Biobuf *arp;
 377
 378         p = strchr(file, '%');
 379         if (p == nil || p[1] == '\0')
 380                 return strdup(file);
 381
 382         remip = strdup(raddr);
 383         newnm = mallocz(strlen(file) + Maxpath, 1);
 384         if (remip == nil || newnm == nil)
 385                 sysfatal("out of memory");
 386
 387         bang = strchr(remip, '!');
 388         if (bang)
 389                 *bang = '\0';                   /* remove !port */
 390
 391         memmove(newnm, file, p - file);         /* copy up to % */
 392         cur = newnm + strlen(newnm);
 393         switch(p[1]) {
 394         case 'I':
 395                 strcpy(cur, remip);             /* remote's IP */
 396                 break;
 397         case 'C':
 398                 strcpy(cur, "/cfg/pxe/");
 399                 cur += strlen(cur);
 400                 /* fall through */
 401         case 'E':
 402                 /* look up remote's IP in /net/arp to get mac. */
 403                 arpf = smprint("%s/arp", net);
 404                 arp = Bopen(arpf, OREAD);
 405                 free(arpf);
 406                 if (arp == nil)
 407                         break;
 408                 /* read lines looking for remip in 3rd field of 4 */
 409                 while ((ln = Brdline(arp, '\n')) != nil) {
 410                         ln[Blinelen(arp)-1] = 0;
 411                         nf = tokenize(ln, fields, nelem(fields));
 412                         if (nf >= 4 && strcmp(fields[2], remip) == 0) {
 413                                 strcpy(cur, fields[3]);
 414                                 break;
 415                         }
 416                 }
 417                 Bterm(arp);
 418                 break;
 419         }
 420         strcat(newnm, p + 2);                   /* tail following %x */
 421         free(remip);
 422         return newnm;
 423 }
 424
 425 void
 426 doserve(int fd)
 427 {
 428         int dlen, opts;
 429         char *mode, *p, *file;
 430         short op;
 431
 432         dlen = read(fd, bigbuf, sizeof(bigbuf)-1);
 433         if(dlen < 0)
 434                 sysfatal("listen read: %r");
 435
 436         bigbuf[dlen] = '\0';
 437         op = (bigbuf[0]<<8) | bigbuf[1];
 438         dlen -= Opsize;
 439         mode = file = bigbuf + Opsize;
 440         while(*mode != '\0' && dlen--)
 441                 mode++;
 442         mode++;
 443         p = mode;
 444         while(*p && dlen--)
 445                 p++;
 446
 447         file = mapname(file);   /* we don't free the result; minor leak */
 448
 449         if(dlen == 0) {
 450                 nak(fd, 0, "bad tftpmode");
 451                 close(fd);
 452                 syslog(dbg, flog, "tftpd %d bad mode %s for file %s from %s",
 453                         pid, mode, file, raddr);
 454                 return;
 455         }
 456
 457         if(op != Tftp_READ && op != Tftp_WRITE) {
 458                 nak(fd, Errbadop, "Illegal TFTP operation");
 459                 close(fd);
 460                 syslog(dbg, flog, "tftpd %d bad request %d (%s) %s", pid, op,
 461                         (op < nelem(opnames)? opnames[op]: "gok"), raddr);
 462                 return;
 463         }
 464
 465         if(restricted){
 466                 if(file[0] == '#' || strncmp(file, "../", 3) == 0 ||
 467                   strstr(file, "/../") != nil ||
 468                   (file[0] == '/' && strncmp(file, dirsl, dirsllen) != 0)){
 469                         nak(fd, Errnoaccess, "Permission denied");
 470                         close(fd);
 471                         syslog(dbg, flog, "tftpd %d bad request %d from %s file %s",
 472                                 pid, op, raddr, file);
 473                         return;
 474                 }
 475         }
 476
 477         /*
 478          * options are supposed to be negotiated, but the cavium board's
 479          * u-boot really wants us to use a block size of 1432 bytes and won't
 480          * take `no' for an answer.
 481          */
 482         p++;                            /* skip NUL after mode */
 483         dlen--;
 484         opts = 0;
 485         if(dlen > 0) {                  /* might have options */
 486                 char bytes[32*1024];
 487
 488                 if(Debug)
 489                         optlog(bytes, p, dlen);
 490                 opts = options(fd, bytes, sizeof bytes, file, op, p, dlen);
 491                 if (opts < 0)
 492                         return;
 493         }
 494         if(op == Tftp_READ)
 495                 sendfile(fd, file, mode, opts);
 496         else
 497                 recvfile(fd, file, mode);
 498 }
 499
 500 void
 501 catcher(void *junk, char *msg)
 502 {
 503         USED(junk);
 504
 505         if(strncmp(msg, "exit", 4) == 0)
 506                 noted(NDFLT);
 507         noted(NCONT);
 508 }
 509
 510 static int
 511 awaitack(int fd, int block)
 512 {
 513         int ackblock, al, rxl;
 514         ushort op;
 515         uchar ack[1024];
 516
 517         for(rxl = 0; rxl < 10; rxl++) {
 518                 memset(ack, 0, Hdrsize);
 519                 alarm(1000);
 520                 al = read(fd, ack, sizeof(ack));
 521                 alarm(0);
 522                 if(al < 0) {
 523                         if (Debug)
 524                                 syslog(dbg, flog, "tftpd %d timed out "
 525                                         "waiting for ack from %s", pid, raddr);
 526                         return Ackrexmit;
 527                 }
 528                 op = ack[0]<<8|ack[1];
 529                 if(op == Tftp_ERROR) {
 530                         if (Debug)
 531                                 syslog(dbg, flog, "tftpd %d got error "
 532                                         "waiting for ack from %s", pid, raddr);
 533                         return Ackerr;
 534                 } else if(op != Tftp_ACK) {
 535                         syslog(dbg, flog, "tftpd %d rcvd %s op from %s", pid,
 536                                 (op < nelem(opnames)? opnames[op]: "gok"),
 537                                 raddr);
 538                         return Ackerr;
 539                 }
 540                 ackblock = ack[2]<<8|ack[3];
 541                 if (Debug)
 542                         syslog(dbg, flog, "tftpd %d read ack of %d bytes "
 543                                 "for block %d", pid, al, ackblock);
 544                 if(ackblock == block)
 545                         return Ackok;           /* for block just sent */
 546                 else if(ackblock == block + 1)  /* intel pxe eof bug */
 547                         return Ackok;
 548                 else if(ackblock == 0xffff)
 549                         return Ackrexmit;
 550                 else
 551                         /* ack is for some other block; ignore it, try again */
 552                         syslog(dbg, flog, "tftpd %d expected ack for block %d, "
 553                                 "got %d", pid, block, ackblock);
 554         }
 555         return Ackrexmit;
 556 }
 557
 558 void
 559 sendfile(int fd, char *name, char *mode, int opts)
 560 {
 561         int file, block, ret, rexmit, n, txtry;
 562         uchar buf[Maxsegsize+Hdrsize];
 563         char errbuf[ERRMAX];
 564
 565         file = -1;
 566         syslog(dbg, flog, "tftpd %d send file '%s' %s to %s",
 567                 pid, name, mode, raddr);
 568         name = sunkernel(name);
 569         if(name == 0){
 570                 nak(fd, 0, "not in our database");
 571                 goto error;
 572         }
 573
 574         notify(catcher);
 575
 576         file = open(name, OREAD);
 577         if(file < 0) {
 578                 errstr(errbuf, sizeof errbuf);
 579                 nak(fd, 0, errbuf);
 580                 goto error;
 581         }
 582         block = 0;
 583         rexmit = Ackok;
 584         n = 0;
 585         /*
 586          * if we sent an oack previously, wait for the client's ack or error.
 587          * if we get no ack for our oack, it could be that we returned
 588          * a tsize that the client can't handle, or it could be intel
 589          * pxe just read-with-tsize to get size, couldn't be bothered to
 590          * ack our oack and has just gone ahead and issued another read.
 591          */
 592         if(opts && awaitack(fd, 0) != Ackok)
 593                 goto error;
 594
 595         for(txtry = 0; txtry < timeout;) {
 596                 if(rexmit == Ackok) {
 597                         block++;
 598                         buf[0] = 0;
 599                         buf[1] = Tftp_DATA;
 600                         buf[2] = block>>8;
 601                         buf[3] = block;
 602                         n = read(file, buf+Hdrsize, blksize);
 603                         if(n < 0) {
 604                                 errstr(errbuf, sizeof errbuf);
 605                                 nak(fd, 0, errbuf);
 606                                 goto error;
 607                         }
 608                         txtry = 0;
 609                 }
 610                 else {
 611                         syslog(dbg, flog, "tftpd %d rexmit %d %s:%d to %s",
 612                                 pid, Hdrsize+n, name, block, raddr);
 613                         txtry++;
 614                 }
 615
 616                 ret = write(fd, buf, Hdrsize+n);
 617                 if(ret < Hdrsize+n) {
 618                         syslog(dbg, flog,
 619                                 "tftpd network write error on %s to %s: %r",
 620                                 name, raddr);
 621                         sysfatal("tftpd: network write error: %r");
 622                 }
 623                 if (Debug)
 624                         syslog(dbg, flog, "tftpd %d sent block %d", pid, block);
 625
 626                 rexmit = awaitack(fd, block);
 627                 if (rexmit == Ackerr)
 628                         break;
 629                 if(ret != blksize+Hdrsize && rexmit == Ackok)
 630                         break;
 631         }
 632         syslog(dbg, flog, "tftpd %d done sending file '%s' %s to %s",
 633                 pid, name, mode, raddr);
 634 error:
 635         close(fd);
 636         close(file);
 637 }
 638
 639 void
 640 recvfile(int fd, char *name, char *mode)
 641 {
 642         ushort op, block, inblock;
 643         uchar buf[Maxsegsize+8];
 644         char errbuf[ERRMAX];
 645         int n, ret, file;
 646
 647         syslog(dbg, flog, "receive file '%s' %s from %s", name, mode, raddr);
 648
 649         file = create(name, OWRITE, 0666);
 650         if(file < 0) {
 651                 errstr(errbuf, sizeof errbuf);
 652                 nak(fd, 0, errbuf);
 653                 syslog(dbg, flog, "can't create %s: %s", name, errbuf);
 654                 return;
 655         }
 656
 657         block = 0;
 658         ack(fd, block);
 659         block++;
 660
 661         for (;;) {
 662                 alarm(15000);
 663                 n = read(fd, buf, blksize+8);
 664                 alarm(0);
 665                 if(n < 0) {
 666                         syslog(dbg, flog, "tftpd: network error reading %s: %r",
 667                                 name);
 668                         goto error;
 669                 }
 670                 /*
 671                  * NB: not `<='; just a header is legal and happens when
 672                  * file being read is a multiple of segment-size bytes long.
 673                  */
 674                 if(n < Hdrsize) {
 675                         syslog(dbg, flog,
 676                                 "tftpd: short read from network, reading %s",
 677                                 name);
 678                         goto error;
 679                 }
 680                 op = buf[0]<<8|buf[1];
 681                 if(op == Tftp_ERROR) {
 682                         syslog(dbg, flog, "tftpd: tftp error reading %s", name);
 683                         goto error;
 684                 }
 685
 686                 n -= Hdrsize;
 687                 inblock = buf[2]<<8|buf[3];
 688                 if(op == Tftp_DATA) {
 689                         if(inblock == block) {
 690                                 ret = write(file, buf+Hdrsize, n);
 691                                 if(ret != n) {
 692                                         errstr(errbuf, sizeof errbuf);
 693                                         nak(fd, 0, errbuf);
 694                                         syslog(dbg, flog,
 695                                             "tftpd: error writing %s: %s",
 696                                                 name, errbuf);
 697                                         goto error;
 698                                 }
 699                                 ack(fd, block);
 700                                 block++;
 701                         } else
 702                                 ack(fd, 0xffff);        /* tell him to resend */
 703                 }
 704         }
 705 error:
 706         close(file);
 707 }
 708
 709 void
 710 ack(int fd, ushort block)
 711 {
 712         uchar ack[4];
 713         int n;
 714
 715         ack[0] = 0;
 716         ack[1] = Tftp_ACK;
 717         ack[2] = block>>8;
 718         ack[3] = block;
 719
 720         n = write(fd, ack, 4);
 721         if(n < 4)
 722                 sysfatal("network write: %r");
 723 }
 724
 725 void
 726 nak(int fd, int code, char *msg)
 727 {
 728         char buf[128];
 729         int n;
 730
 731         n = 5 + strlen(msg);
 732         if(n > sizeof(buf))
 733                 n = sizeof(buf);
 734         buf[0] = 0;
 735         buf[1] = Tftp_ERROR;
 736         buf[2] = 0;
 737         buf[3] = code;
 738         memmove(buf+4, msg, n - 5);
 739         buf[n-1] = 0;
 740         if(write(fd, buf, n) != n)
 741                 sysfatal("write nak: %r");
 742 }
 743
 744 void
 745 setuser(void)
 746 {
 747         int fd;
 748
 749         fd = open("#c/user", OWRITE);
 750         if(fd < 0 || write(fd, "none", strlen("none")) < 0)
 751                 sysfatal("can't become none: %r");
 752         close(fd);
 753         if(newns("none", nil) < 0)
 754                 sysfatal("can't build namespace: %r");
 755 }
 756
 757 char*
 758 lookup(char *sattr, char *sval, char *tattr, char *tval, int len)
 759 {
 760         static Ndb *db;
 761         char *attrs[1];
 762         Ndbtuple *t;
 763
 764         if(db == nil)
 765                 db = ndbopen(0);
 766         if(db == nil)
 767                 return nil;
 768
 769         if(sattr == nil)
 770                 sattr = ipattr(sval);
 771
 772         attrs[0] = tattr;
 773         t = ndbipinfo(db, sattr, sval, attrs, 1);
 774         if(t == nil)
 775                 return nil;
 776         strncpy(tval, t->val, len);
 777         tval[len-1] = 0;
 778         ndbfree(t);
 779         return tval;
 780 }
 781
 782 /*
 783  *  for sun kernel boots, replace the requested file name with
 784  *  a one from our database.  If the database doesn't specify a file,
 785  *  don't answer.
 786  */
 787 char*
 788 sunkernel(char *name)
 789 {
 790         ulong addr;
 791         uchar v4[IPv4addrlen];
 792         uchar v6[IPaddrlen];
 793         char buf[256];
 794         char ipbuf[128];
 795         char *suffix;
 796
 797         addr = strtoul(name, &suffix, 16);
 798         if(suffix-name != 8 || (strcmp(suffix, "") != 0 && strcmp(suffix, ".SUN") != 0))
 799                 return name;
 800
 801         v4[0] = addr>>24;
 802         v4[1] = addr>>16;
 803         v4[2] = addr>>8;
 804         v4[3] = addr;
 805         v4tov6(v6, v4);
 806         sprint(ipbuf, "%I", v6);
 807         return lookup("ip", ipbuf, "bootf", buf, sizeof buf);
 808 }
 809
 810 void
 811 remoteaddr(char *dir, char *raddr, int len)
 812 {
 813         char buf[64];
 814         int fd, n;
 815
 816         snprint(buf, sizeof(buf), "%s/remote", dir);
 817         fd = open(buf, OREAD);
 818         if(fd < 0){
 819                 snprint(raddr, sizeof(raddr), "unknown");
 820                 return;
 821         }
 822         n = read(fd, raddr, len-1);
 823         close(fd);
 824         if(n <= 0){
 825                 snprint(raddr, sizeof(raddr), "unknown");
 826                 return;
 827         }
 828         if(n > 0)
 829                 n--;
 830         raddr[n] = 0;
 831 }