ref: a1b177116747ff22cceea2121bf40da526ba60c3
dir: /appl/alphabet/fs/proto.b/
implement Proto, Fsmodule;
include "sys.m";
sys: Sys;
include "readdir.m";
readdir: Readdir;
include "bufio.m";
bufio: Bufio;
Iobuf: import bufio;
include "string.m";
str: String;
include "draw.m";
include "sh.m";
include "alphabet/reports.m";
reports: Reports;
Report, quit, report: import reports;
include "alphabet/fs.m";
fs: Fs;
Value: import fs;
Fschan, Fsdata, Entrychan, Entry,
Gatechan, Gatequery, Nilentry, Option,
Next, Down, Skip, Quit: import Fs;
Proto: module {};
File: adt {
name: string;
mode: int;
owner: string;
group: string;
old: string;
flags: int;
sub: cyclic array of ref File;
};
Protof: adt {
indent: int;
lastline: string;
iob: ref Iobuf;
};
Star, Plus: con 1<<iota;
types(): string
{
return "xf-rs";
}
badmod(p: string)
{
sys->fprint(sys->fildes(2), "fs: proto: cannot load %s: %r\n", p);
raise "fail:bad module";
}
init()
{
sys = load Sys Sys->PATH;
fs = load Fs Fs->PATH;
if(fs == nil)
badmod(Fs->PATH);
fs->init();
reports = load Reports Reports->PATH;
if(reports == nil)
badmod(Reports->PATH);
readdir = load Readdir Readdir->PATH;
if(readdir == nil)
badmod(Readdir->PATH);
bufio = load Bufio Bufio->PATH;
if(bufio == nil)
badmod(Bufio->PATH);
str = load String String->PATH;
if(str == nil)
badmod(String->PATH);
}
run(nil: ref Draw->Context, report: ref Report,
opts: list of Option, args: list of ref Value): ref Value
{
f := (hd args).f().i;
rootpath: string;
if(opts != nil)
rootpath = (hd (hd opts).args).s().i;
if(rootpath == nil)
rootpath = "/";
root := ref File(rootpath, ~0, nil, nil, nil, 0, nil);
c := chan of (Fsdata, chan of int);
spawn protowalk(c, f, root, report.start("proto"));
return ref Value.Vx(c);
}
protowalk(c: Fschan, f: chan of ref Sys->FD, root: ref File, errorc: chan of string)
{
fd := <-f;
if(fd != nil)
f <-= nil;
else{
sys->pipe(p := array[2] of ref Sys->FD);
f <-= p[1];
fd = p[0];
}
proto := ref Protof(0, nil, nil);
proto.iob = bufio->fopen(fd, Sys->OREAD);
(root.flags, root.sub) = readproto(proto, -1);
d: ref Sys->Dir;
(ok, rd) := sys->stat(root.name);
if(ok != -1)
d = ref rd;
protowalk1(c, root.flags, root.name, file2dir(root, d), root.sub, errorc);
quit(errorc);
}
protowalk1(c: Fschan, flags: int, path: string, d: ref Sys->Dir,
sub: array of ref File, errorc: chan of string): int
{
reply := chan of int;
c <-= ((d, nil), reply);
case r := <-reply {
Quit =>
quit(errorc);
Next or
Skip =>
return r;
}
(a, n) := readdir->init(path, Readdir->NAME|Readdir->COMPACT);
if(len a == 0){
c <-= ((nil, nil), reply);
if(<-reply == Quit)
quit(errorc);
return Next;
}
j := 0;
preventry: string;
useentry: int;
for(i := 0; i < n; i += useentry){
useentry = 1;
for(; j < len sub; j++){
s := sub[j].name;
if(s == preventry){
report(errorc, sys->sprint("duplicate entry %s", pathconcat(path, s)));
continue; # eliminate duplicates in proto
}
if(s >= a[i].name)
break;
# entry has not been found, but we've got a substitute version,
# so save the rest of the entries to match the rest of sub.
if(sub[j].old != nil){
useentry = 0;
break;
}
report(errorc, sys->sprint("%s not found", pathconcat(path, s)));
}
foundsub := j < len sub && (sub[j].name == a[i].name || sub[j].old != nil);
if(foundsub || flags&Plus ||
(flags&Star && (a[i].mode & Sys->DMDIR)==0)){
f: ref File;
if(foundsub){
f = sub[j++];
preventry = f.name;
}
p: string;
d: ref Sys->Dir;
if(foundsub && f.old != nil){
p = f.old;
(ok, xd) := sys->stat(p);
if(ok == -1){
report(errorc, sys->sprint("cannot stat %q: %r", p));
continue;
}
d = ref xd;
}else{
p = pathconcat(path, a[i].name);
d = a[i];
}
d = file2dir(f, d);
r: int;
if((d.mode & Sys->DMDIR) == 0)
r = walkfile(c, p, d, errorc);
else if(flags & Plus)
r = protowalk1(c, Plus, p, d, nil, errorc);
else
r = protowalk1(c, f.flags, p, d, f.sub, errorc);
if(r == Skip)
return Next;
}
}
c <-= ((nil, nil), reply);
if(<-reply == Quit)
quit(errorc);
return Next;
}
pathconcat(p, name: string): string
{
if(p != nil && p[len p - 1] != '/')
p[len p] = '/';
p += name;
return p;
}
# from(ish) walk.b
walkfile(c: Fschan, path: string, d: ref Sys->Dir, errorc: chan of string): int
{
reply := chan of int;
fd := sys->open(path, Sys->OREAD);
if(fd == nil){
report(errorc, sys->sprint("cannot open %q: %r", path));
return Next;
}
c <-= ((d, nil), reply);
case r := <-reply {
Quit =>
quit(errorc);
Next or
Skip =>
return r;
}
length := d.length;
for(n := big 0; n < length; ){
nr := Sys->ATOMICIO;
if(n + big Sys->ATOMICIO > length)
nr = int (length - n);
buf := array[nr] of byte;
nr = sys->read(fd, buf, nr);
if(nr <= 0){
if(nr < 0)
report(errorc, sys->sprint("error reading %q: %r", path));
else
report(errorc, sys->sprint("%q is shorter than expected (%bd/%bd)",
path, n, length));
break;
}else if(nr < len buf)
buf = buf[0:nr];
c <-= ((nil, buf), reply);
case <-reply {
Quit =>
quit(errorc);
Skip =>
return Next;
}
n += big nr;
}
c <-= ((nil, nil), reply);
if(<-reply == Quit)
quit(errorc);
return Next;
}
readproto(proto: ref Protof, indent: int): (int, array of ref File)
{
a := array[10] of ref File;
n := 0;
flags := 0;
while((f := readline(proto, indent)) != nil){
if(f.name == "*")
flags |= Star;
else if(f.name == "+")
flags |= Plus;
else{
(f.flags, f.sub) = readproto(proto, proto.indent);
if(n == len a)
a = (array[n * 2] of ref File)[0:] = a;
a[n++] = f;
}
}
if(n < len a)
a = (array[n] of ref File)[0:] = a[0:n];
mergesort(a, array[n] of ref File);
return (flags, a);
}
readline(proto: ref Protof, indent: int): ref File
{
s: string;
if(proto.lastline != nil){
s = proto.lastline;
proto.lastline = nil;
}else if(proto.indent == -1)
return nil;
else if((s = proto.iob.gets('\n')) == nil){
proto.indent = -1;
return nil;
}
spc := 0;
for(i := 0; i < len s; i++){
c := s[i];
if(c == ' ')
spc++;
else if(c == '\t')
spc += 8;
else
break;
}
if(i == len s || s[i] == '#' || s[i] == '\n')
return readline(proto, indent); # XXX sort out tail recursion!
if(spc <= indent){
proto.lastline = s;
return nil;
}
proto.indent = spc;
(n, toks) := sys->tokenize(s, " \t\n");
f := ref File(nil, ~0, nil, nil, nil, 0, nil);
(f.name, toks) = (getname(hd toks, 0), tl toks);
if(toks == nil)
return f;
(f.mode, toks) = (getmode(hd toks), tl toks);
if(toks == nil)
return f;
(f.owner, toks) = (getname(hd toks, 1), tl toks);
if(toks == nil)
return f;
(f.group, toks) = (getname(hd toks, 1), tl toks);
if(toks == nil)
return f;
(f.old, toks) = (hd toks, tl toks);
return f;
}
mergesort(a, b: array of ref File)
{
r := len a;
if (r > 1) {
m := (r-1)/2 + 1;
mergesort(a[0:m], b[0:m]);
mergesort(a[m:], b[m:]);
b[0:] = a;
for ((i, j, k) := (0, m, 0); i < m && j < r; k++) {
if(b[i].name > b[j].name)
a[k] = b[j++];
else
a[k] = b[i++];
}
if (i < m)
a[k:] = b[i:m];
else if (j < r)
a[k:] = b[j:r];
}
}
getname(s: string, allowminus: int): string
{
if(s == nil)
return nil;
if(allowminus && s == "-")
return nil;
if(s[0] == '$')
return getenv(s[1:]);
return s;
}
getenv(s: string): string
{
# XXX implement env variables
return nil;
}
getmode(s: string): int
{
s = getname(s, 1);
if(s == nil)
return ~0;
m := 0;
i := 0;
if(s[i] == 'd'){
m |= Sys->DMDIR;
i++;
}
if(i < len s && s[i] == 'a'){
m |= Sys->DMAPPEND;
i++;
}
if(i < len s && s[i] == 'l'){
m |= Sys->DMEXCL;
i++;
}
(xmode, t) := str->toint(s, 8);
if(t != nil){
# report(aux.errorc, "bad mode specification %q", s);
return ~0;
}
return xmode | m;
}
file2dir(f: ref File, old: ref Sys->Dir): ref Sys->Dir
{
d := ref Sys->nulldir;
if(old != nil){
if(old.dtype != 'M'){
d.uid = "sys";
d.gid = "sys";
xmode := (old.mode >> 6) & 7;
d.mode = old.mode | xmode | (xmode << 3);
}else{
d.uid = old.uid;
d.gid = old.gid;
d.mode = old.mode;
}
d.length = old.length;
d.mtime = old.mtime;
d.atime = old.atime;
d.muid = old.muid;
d.name = old.name;
}
if(f != nil){
d.name = f.name;
if(f.owner != nil)
d.uid = f.owner;
if(f.group != nil)
d.gid = f.group;
if(f.mode != ~0)
d.mode = f.mode;
}
return d;
}