ref: b7af62b250e5dff30320a181ca9d53ab5a7c276d
dir: /os/init/mpcinit.b/
implement Init; # # init program for Motorola 800 series (serial console only) # include "sys.m"; sys: Sys; include "draw.m"; draw: Draw; include "keyring.m"; kr: Keyring; include "security.m"; auth: Auth; Init: module { init: fn(); }; Shell: module { init: fn(ctxt: ref Draw->Context, argv: list of string); }; Bootpreadlen: con 128; # option switches UseLocalFS: con 1<<0; EtherBoot: con 1<<1; Prompting: con 1<<3; lfs(): int { if(!ftlinit("#F/flash/flash", 1024*1024, 1024*1024)) return -1; if(mountkfs("#X/ftldata", "main", "flash") < 0) return -1; if(sys->bind("#Kmain", "/n/local", sys->MREPL) < 0){ sys->print("can't bind #Kmain to /n/local: %r\n"); return -1; } if(sys->bind("/n/local", "/", Sys->MCREATE|Sys->MREPL) < 0){ sys->print("can't bind /n/local after /: %r\n"); return -1; } return 0; } donebind := 0; # # set up network mount # netfs(mountpt: string): int { sys->print("bootp ..."); fd: ref Sys->FD; if(!donebind){ fd = sys->open("/net/ipifc/clone", sys->OWRITE); if(fd == nil) { sys->print("init: open /net/ipifc/clone: %r\n"); return -1; } if(sys->fprint(fd, "bind ether %s", "/net/ether0") < 0) { sys->print("could not bind ether0 interface: %r\n"); return -1; } donebind = 1; }else{ fd = sys->open("/net/ipifc/0/ctl", Sys->OWRITE); if(fd == nil){ sys->print("init: can't reopen /net/ipifc/0/ctl: %r\n"); return -1; } } if(sys->fprint(fd, "bootp") < 0){ sys->print("init: bootp failed: %r\n"); return -1; } server := bootp(); if(server == nil) return -1; net := "tcp"; # how to specify il? svcname := net + "!" + server + "!6666"; sys->print("dial %s...", svcname); (ok, c) := sys->dial(svcname, nil); if(ok < 0){ sys->print("can't dial %s: %r\n", svcname); return -1; } sys->print("\nConnected ...\n"); if(kr != nil){ err: string; sys->print("Authenticate ..."); ai := kr->readauthinfo("/nvfs/default"); if(ai == nil){ sys->print("readauthinfo /nvfs/default failed: %r\n"); sys->print("trying mount as `nobody'\n"); } (c.dfd, err) = auth->client("none", ai, c.dfd); if(c.dfd == nil){ sys->print("authentication failed: %s\n", err); return -1; } } sys->print("mount %s...", mountpt); c.cfd = nil; n := sys->mount(c.dfd, nil, mountpt, sys->MREPL, ""); if(n > 0) return 0; if(n < 0) sys->print("%r"); return -1; } init() { sys = load Sys Sys->PATH; kr = load Keyring Keyring->PATH; auth = load Auth Auth->PATH; if(auth != nil) auth->init(); sys->print("**\n** Inferno\n** Vita Nuova\n**\n"); optsw := options(); sys->print("Switch options: 0x%ux\n", optsw); # # Setup what we need to call a server and # Authenticate # sys->bind("#l", "/net", sys->MREPL); sys->bind("#I", "/net", sys->MAFTER); sys->bind("#c", "/dev", sys->MAFTER); fsready := 0; mountpt := "/"; usertc := 0; if((optsw & Prompting) == 0){ if(optsw & UseLocalFS){ sys->print("Option: use local file system\n"); if(lfs() == 0){ fsready = 1; mountpt = "/n/remote"; } } if(optsw & EtherBoot){ sys->print("Attempting remote mount\n"); if(netfs(mountpt) == 0) fsready = 1; } } if(fsready == 0){ sys->print("\n\n"); stdin := sys->fildes(0); buf := array[128] of byte; sources := "fs" :: "net" :: nil; loop: for(;;) { sys->print("root from ("); cm := ""; for(l := sources; l != nil; l = tl l){ sys->print("%s%s", cm, hd l); cm = ","; } sys->print(")[%s] ", hd sources); n := sys->read(stdin, buf, len buf); if(n <= 0) continue; if(buf[n-1] == byte '\n') n--; (nil, choice) := sys->tokenize(string buf[0:n], "\t "); if(choice == nil) choice = sources; opt := hd choice; case opt { * => sys->print("\ninvalid boot option: '%s'\n", opt); break; "fs" or "" => if(lfs() == 0){ usertc = 1; break loop; } "net" => if(netfs("/") == 0) break loop; } } } # # default namespace # sys->unmount(nil, "/dev"); sys->bind("#c", "/dev", sys->MBEFORE); # console sys->bind("#l", "/net", sys->MBEFORE); # ethernet sys->bind("#I", "/net", sys->MBEFORE); # TCP/IP sys->bind("#p", "/prog", sys->MREPL); # prog device sys->bind("#d", "/fd", Sys->MREPL); setsysname(); sys->print("clock...\n"); setclock(usertc, mountpt); sys->print("Console...\n"); shell := load Shell "/dis/sh.dis"; if(shell == nil) { sys->print("init: load /dis/sh.dis: %r"); exit; } dc: ref Draw->Context; shell->init(dc, nil); } setclock(usertc: int, timedir: string) { now := 0; if(usertc){ fd := sys->open("#r/rtc", Sys->OREAD); if(fd != nil){ b := array[64] of byte; n := sys->read(fd, b, len b-1); if(n > 0){ b[n] = byte 0; now = int string b; if(now <= 16r20000000) now = 0; # rtc itself is not initialised } } } if(now == 0){ (ok, dir) := sys->stat(timedir); if (ok < 0) { sys->print("init: stat %s: %r", timedir); return; } now = dir.atime; } fd := sys->open("/dev/time", sys->OWRITE); if (fd == nil) { sys->print("init: can't open /dev/time: %r"); return; } # Time is kept as microsecs, atime is in secs b := array of byte sys->sprint("%ud000000", now); if (sys->write(fd, b, len b) != len b) sys->print("init: can't write /dev/time: %r"); } # # Set system name from nvram # setsysname() { fd := sys->open("/nvfs/ID", sys->OREAD); if(fd == nil) return; fds := sys->open("/dev/sysname", sys->OWRITE); if(fds == nil) return; buf := array[128] of byte; nr := sys->read(fd, buf, len buf); if(nr <= 0) return; sys->write(fds, buf, nr); } # # fetch options from switch DS2 # options(): int { fd := sys->open("#r/switch", Sys->OREAD); if(fd == nil){ sys->print("can't open #r/switch: %r\n"); return 0; } b := array[20] of byte; n := sys->read(fd, b, len b); s := string b[0:n]; return int s; } bootp(): string { fd := sys->open("/net/bootp", sys->OREAD); if(fd == nil) { sys->print("init: can't open /net/bootp: %r"); return nil; } buf := array[Bootpreadlen] of byte; nr := sys->read(fd, buf, len buf); fd = nil; if(nr <= 0) { sys->print("init: read /net/bootp: %r"); return nil; } (ntok, ls) := sys->tokenize(string buf, " \t\n"); while(ls != nil) { if(hd ls == "fsip"){ ls = tl ls; break; } ls = tl ls; } if(ls == nil) { sys->print("init: server address not in bootp read"); return nil; } srv := hd ls; sys->print("%s\n", srv); return srv; } # # set up flash translation layer # ftldone := 0; ftlinit(flashmem: string, offset: int, length: int): int { if(ftldone) return 1; sys->print("Set flash translation of %s at offset %d (%d bytes)\n", flashmem, offset, length); fd := sys->open("#X/ftlctl", Sys->OWRITE); if(fd == nil){ sys->print("can't open #X/ftlctl: %r\n"); return 0; } if(sys->fprint(fd, "init %s %ud %ud", flashmem, offset, length) <= 0){ sys->print("can't init flash translation: %r"); return 0; } ftldone = 1; return 1; } # # Mount kfs filesystem # mountkfs(devname: string, fsname: string, options: string): int { fd := sys->open("#Kcons/kfsctl", sys->OWRITE); if(fd == nil) { sys->print("could not open #Kcons/kfsctl: %r\n"); return -1; } if(sys->fprint(fd, "filsys %s %s %s", fsname, devname, options) <= 0){ sys->print("could not write #Kcons/kfsctl: %r\n"); return -1; } if(options == "ro") sys->fprint(fd, "cons flashwrite"); return 0; }