ref: 6bb619c8db2867ddd9cd19c0aec05065f5ee0cae
dir: /os/init/reminit.b/
implement Init; # # init program for standalone remote pc kernel - for benchmarking # include "sys.m"; sys: Sys; FD, Connection, sprint, Dir: import sys; print, fprint, open, bind, mount, dial, sleep, read, chdir: import sys; include "draw.m"; draw: Draw; Context: import draw; include "keyring.m"; kr: Keyring; include "security.m"; auth: Auth; Init: module { init: fn(); }; Shell: module { init: fn(ctxt: ref Context, argv: list of string); }; remotefs(server: string): int { ok, n: int; c: Connection; (ok, c) = dial("tcp!" + server + "!6666", nil); if(ok < 0) return -1; sys->print("Connected ...\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 ...\n"); c.cfd = nil; n = mount(c.dfd, "/n/remote", sys->MREPL, ""); if(n > 0) return 0; return -1; } Bootpreadlen: con 128; bootp(): string { # # BUG: if bootp fails, can't then use "add ether" correctly # fd := open("/net/ipifc", sys->OWRITE); if(fd == nil) { print("init: open /net/ipifc: %r"); return nil; } fprint(fd, "bootp /net/ether0"); fd = open("/net/bootp", sys->OREAD); if(fd == nil) { print("init: open /net/bootp: %r\n"); return nil; } buf := array[Bootpreadlen] of byte; nr := read(fd, buf, len buf); fd = nil; if(nr > 0) { (ntok, ls) := sys->tokenize(string buf, " \t\n"); while(ls != nil) { if(hd ls == "fsip") { ls = tl ls; break; } ls = tl ls; } srv : string; if(ls == nil || ((srv = hd ls) == "0.0.0.0")) { print("init: server address not in bootp read\n"); return nil; } return srv; } return nil; } init() { sys = load Sys Sys->PATH; stdin := sys->fildes(0); kr = load Keyring Keyring->PATH; auth = load Auth Auth->PATH; if(auth != nil) auth->init(); sys->print("**\n** Inferno\n** Vita Nuova\n**\n"); sys->print("Setup boot net services ...\n"); # # Setup what we need to call a server and # Authenticate # sys->print("Bind ethernet ...\n"); bind("#l", "/net", sys->MREPL); sys->print("Bind IP ...\n"); bind("#I", "/net", sys->MAFTER); sys->print("Bind console ...\n"); bind("#c", "/dev", sys->MAFTER); setsysname(); if (1) { print("bootp ...\n"); srv := bootp(); if (srv != nil) if (remotefs(srv) < 0) print("No remote filesystem\n"); else { print("Remote filesystem mounted\n"); bind("/n/remote/dis", "/dis", sys->MBEFORE); bind("/n/remote/dis/lib", "/dis/lib", sys->MBEFORE); } } else { print("Standalone mode\n"); fd := open("/net/ipifc", sys->OWRITE); if(fd == nil) { print("init: open /net/ipifc: %r"); exit; } fprint(fd, "add ether /net/ether0 %s %s", "200.1.1.60", "255.255.255.0"); fd = nil; } # # default namespace # sys->unmount(nil, "/dev"); bind("#c", "/dev", sys->MBEFORE); # console bind("#l", "/net", sys->MBEFORE); # ethernet bind("#I", "/net", sys->MBEFORE); # TCP/IP bind("#p", "/prog", sys->MREPL); # prog device sys->bind("#d", "/fd", Sys->MREPL); bind("#T", "/dev", sys->MBEFORE); # kprof device bind("#x", "/dev", sys->MBEFORE); # bench device print("clock...\n"); setclock(); print("Server...\n"); dc: ref Context; cs := load Shell "/dis/ndb/cs.dis"; if(cs == nil) print("Server not loaded\n"); else cs->init(dc, "cs" :: nil); server := load Shell "/dis/lib/srv.dis"; if(server == nil) print("Server not loaded\n"); else { # server->init(dc, "srv" :: nil); } print("Console...\n"); sys->chdir("/n/remote/usr/john/appl/bench"); shell := load Shell "/dis/sh.dis"; if(shell == nil) { print("init: load /dis/sh.dis: %r"); exit; } shell->init(dc, nil); } setclock() { (ok, dir) := sys->stat("/"); if (ok < 0) { print("init: stat /: %r"); return; } fd := sys->open("/dev/time", sys->OWRITE); if (fd == nil) { print("init: open /dev/time: %r"); return; } # Time is kept as microsecs, atime is in secs b := array of byte sprint("%d000000", dir.atime); if (sys->write(fd, b, len b) != len b) print("init: write /dev/time: %r"); } # # Set system name from nvram # setsysname() { fd := open("/nvfs/ID", sys->OREAD); if(fd == nil) return; fds := 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); } readline(fd: ref Sys->FD): string { l := array [128] of byte; nb := sys->read(fd, l, len l); if(nb <= 1) return ""; return string l[0:nb-1]; }