ref: a7080788265dd441b5446bea5c4d31fccf7dea1f
dir: /appl/grid/blurdemo.b/
implement Blurdemo;
include "sys.m";
sys : Sys;
include "draw.m";
draw: Draw;
Display, Rect, Image: import draw;
include "tk.m";
tk: Tk;
include "tkclient.m";
tkclient: Tkclient;
include "readdir.m";
readdir: Readdir;
include "sh.m";
include "registries.m";
registries: Registries;
Registry, Attributes, Service: import registries;
include "grid/pathreader.m";
reader: PathReader;
include "grid/browser.m";
browser: Browser;
Browse, Select, File, Parameter,
DESELECT, SELECT, TOGGLE: import browser;
include "grid/srvbrowse.m";
srvbrowse: Srvbrowse;
include "grid/announce.m";
announce: Announce;
include "grid/readjpg.m";
readjpg: Readjpg;
srvfilter: list of list of (string, string);
currstep: int;
currsrv: ref Service;
currattach: ref Registries->Attached;
ctxt: ref Draw->Context;
display: ref Draw->Display;
sysname : string;
IMAGE: con 0;
MOUNT: con 4;
imgcache: ref Image;
br: ref Browse;
sel: ref Select;
Blurdemo : module {
init : fn (context : ref Draw->Context, argv : list of string);
readpath: fn (dir: File): (array of ref sys->Dir, int);
};
init(context : ref Draw->Context, argv: list of string)
{
ctxt = context;
display = ctxt.display;
sys = load Sys Sys->PATH;
if (sys == nil)
badmod(Sys->PATH);
readdir = load Readdir Readdir->PATH;
if (readdir == nil)
badmod(Readdir->PATH);
draw = load Draw Draw->PATH;
if (draw == nil)
badmod(Draw->PATH);
tk = load Tk Tk->PATH;
if (tk == nil)
badmod(Tk->PATH);
tkclient = load Tkclient Tkclient->PATH;
if (tkclient == nil)
badmod(Tkclient->PATH);
tkclient->init();
registries = load Registries Registries->PATH;
if (registries == nil)
badmod(Registries->PATH);
registries->init();
browser = load Browser Browser->PATH;
if (browser == nil)
badmod(Browser->PATH);
browser->init();
srvbrowse = load Srvbrowse Srvbrowse->PATH;
if (srvbrowse == nil)
badmod(Srvbrowse->PATH);
srvbrowse->init();
announce = load Announce Announce->PATH;
if (announce == nil)
badmod(Announce->PATH);
announce->init();
reader = load PathReader "$self";
if (reader == nil)
badmod("PathReader");
readjpg = load Readjpg Readjpg->PATH;
if (readjpg == nil)
badmod(Readjpg->PATH);
readjpg->init(display);
sys->pctl(sys->FORKNS | sys->NEWPGRP, nil);
if (ctxt == nil) {
sys->print("no draw context found!\n");
exit;
}
sysname = readfile("/dev/sysname");
if (sysname == "")
sysname = "Localhost";
imgcache = nil;
setsrvfilter();
root := "/";
currsrv = nil;
attribs := ("resource", "Cpu Pool") :: nil;
lcpupool := srvbrowse->find(attribs :: nil);
if (lcpupool == nil) {
browser->dialog(ctxt, nil, "ok" :: nil, "Alert","Cannot find a Cpu Pool Resource");
raise "fail: error cannot find a Cpu Pool resource";
}
(top, titlebar) := tkclient->toplevel(ctxt,"","BlurDemo", tkclient->Appl);
butchan := chan of string;
tk->namechan(top, butchan, "butchan");
browsechan := chan of string;
tk->namechan(top, browsechan, "browsechan");
selectchan := chan of string;
tk->namechan(top, selectchan, "selectchan");
br = Browse.new(top, "browsechan", "services/", "Services", 1, reader);
bropened := array[] of {
"services/",
"services/Data source/",
"services/Camera/",
"/n/remote/",
"/" ,
};
for (i := 0; i < len bropened; i++)
br.addopened(File (bropened[i], nil), 1);
sel = Select.new(top, "selectchan");
for (ik := 0; ik < len mainscreen; ik++)
tkcmd(top,mainscreen[ik]);
currstep = -1;
sel.addframe("image", "Select a '.bit' image");
changestep(top, IMAGE, nil);
tkcmd(top, "pack .f -fill both -expand 1; pack propagate . 0");
released := 1;
title := "";
resize(top, ref Rect ((0,0), (400,400)));
tkclient->onscreen(top, nil);
tkclient->startinput(top, "kbd"::"ptr"::nil);
tkpath: string;
selected := array[2] of File;
if (tl argv != nil)
spawn initimg(butchan, hd tl argv);
main: for (;;) {
alt {
s := <-top.ctxt.kbd =>
tk->keyboard(top, s);
s := <-top.ctxt.ptr =>
tk->pointer(top, *s);
inp := <-browsechan =>
(nil, lst) := sys->tokenize(inp, " \n\t");
if (len lst > 1)
tkpath = hd tl lst;
selected[0] = br.getselected(0);
selected[1] = br.getselected(1);
br.defaultaction(lst, nil);
i = -1;
if (!File.eq(selected[0], br.getselected(0)))
i = 0;
if (!File.eq(selected[1], br.getselected(1)))
i = 1;
if (i != -1) {
sel.select(sel.currfname,nil,DESELECT);
actionbutton(top, br.selected[i].file.path, br.selected[i].tkpath);
}
tkcmd(top, "update");
inp := <-selectchan =>
(nil, lst) := sys->tokenize(inp, " \n\t");
case hd lst {
"but3" =>
tkpath = hd tl lst;
x := string (int hd tl tl lst - 5);
y := string (int hd tl tl tl lst - 5);
path := tkcmd(top, tkpath+" cget -text");
s := blursrvc.attrs.get("name") + " ("+blursrvc.addr+")";
tk->cmd(top, "destroy .m2");
tkcmd(top, "menu .m2 -font /fonts/charon/plain.normal.font");
tkcmd(top, ".m2 add command -label {"+path+"}");
tkcmd(top, ".m2 add separator");
tkcmd(top, ".m2 add command -label {"+s+"}");
tkcmd(top, ".m2 post "+x+" "+y);
"double1" =>
tkpath = hd tl lst;
path := tkcmd(top, tkpath+" cget -text");
qid := "";
(n, nil) := sys->tokenize(path, "/");
if (currstep == IMAGE) {
qid = srvbrowse->getqid(blursrvc);
(res,name) := srvbrowse->getresname(blursrvc);
path = "services/"+res+"/"+name+"/";
}
else if (currsrv.addr != blursrvc.addr)
break;
else if (blursrvc.addr != "Local Machine")
path = "/n/remote" + path;
tkpath = br.gotoselectfile(File(path,qid));
if (tkpath != nil) {
sel.select(sel.currfname, nil, DESELECT);
actionbutton(top, path, tkpath);
}
"but1" =>
if (currstep == IMAGE)
br.selectfile(0, DESELECT, File (nil, nil), nil);
else
br.selectfile(1, DESELECT, File (nil, nil), nil);
sel.defaultaction(lst);
actionbutton(top, sel.getselected(sel.currfname), hd tl lst);
* =>
sel.defaultaction(lst);
}
tkcmd(top, "update");
inp := <-butchan =>
# sys->print("inp: %s\n",inp);
(nil, lst) := sys->tokenize(inp, " \n\t");
if (len lst > 1)
tkpath = hd tl lst;
case hd lst {
"refresh" =>
# ! check to see if anything is mounted first
if (currstep == IMAGE) {
# addlocalservice();
srvbrowse->refreshservices(srvfilter);
}
br.refresh();
"back" =>
changestep(top, IMAGE, nil);
"run" =>
spawn run(ctxt, getcoords(top));
"preview" =>
spawn previewwin(top, butchan, hd tl lst);
"add" =>
additem(top, hd tl lst, int hd tl tl lst);
"del" =>
sel.delselection("image", hd tl lst);
tkcmd (top, ".f.ftop.bn configure -state disabled");
blurimage = nil;
blurtkpath = nil;
blursrvc = nil;
actionbutton(top, sel.getselected(sel.currfname), hd tl lst);
"mount" =>
file := br.getpath(tkpath);
(nsrv, lsrv) := sys->tokenize(file.path, "/");
if (currstep != IMAGE)
break;
if (nsrv != 3)
break;
if (hd tl tl lsrv != "Local Filestore") {
ok := mountsrv(file.path, file.qid, getcoords(top));
if (!ok)
break;
changestep(top, MOUNT, hd tl tl lsrv);
}
else {
srv : Service;
srv.attrs = Attributes.new(("name", sysname) :: nil);
srv.addr = "Local Machine";
currsrv = ref srv;
changestep(top, MOUNT, hd tl tl lsrv);
}
}
tkcmd(top, "update");
title = <-top.ctxt.ctl or
title = <-top.wreq or
title = <-titlebar =>
if (title == "exit")
break main;
e := tkclient->wmctl(top, title);
if (e == nil && title[0] == '!') {
(nil, lst) := sys->tokenize(title, " \t\n");
if (len lst >= 2 && hd lst == "!size" && hd tl lst == ".")
resize(top, nil);
}
}
}
currattach = nil;
killg(sys->pctl(0,nil));
}
resize(top: ref Tk->Toplevel, r: ref Draw->Rect)
{
if (r != nil) {
sw := (*r).dx();
sh := (*r).dy();
ww := int tkcmd(top, ". cget -actwidth");
wh := int tkcmd(top, ". cget -actheight");
if (ww > sw)
tkcmd(top, ". configure -x 0 -width "+string sw);
if (wh > sh)
tkcmd(top, ". configure -y 0 -height "+string sh);
}
w := int tkcmd(top, ".fselect cget -actwidth");
h := int tkcmd(top, ".fselect cget -actheight");
sel.resize(w,h);
}
nactionbuttons := 0;
actionbutton(top: ref Tk->Toplevel, path, tkpath: string)
{
for (i := 0; i < nactionbuttons; i++) {
tkcmd(top, "grid forget .f.ftop.baction"+string i);
tkcmd(top, "destroy .f.ftop.baction"+string i);
}
if (path == nil) {
nactionbuttons = 0;
return;
}
buttons : list of (string,string) = nil;
(n, nil) := sys->tokenize(path, "/");
if (len tkpath > 8 && tkpath[:8] == ".fselect")
buttons = ("Remove", "del "+tkpath) :: buttons;
else {
if (currstep == IMAGE) {
if (n == 3)
buttons = ("Mount", "mount "+tkpath) :: buttons;
}
else {
if (len path > 4) {
if (path[len path - 4:] == ".bit") {
buttons = ("Select", "add "+path+" 0") ::
("Preview", "preview "+path) :: buttons;
}
else if (path[len path - 4:] == ".jpg")
buttons = ("Select", "add "+path+" 0") :: buttons;
}
}
}
nactionbuttons = len buttons;
for (i = 0; i < nactionbuttons; i++) {
name := ".f.ftop.baction"+string i+" ";
(text,cmd) := hd buttons;
tkcmd(top, "button "+name+"-text {"+text+"} "+
"-font /fonts/charon/bold.normal.font "+
"-command {send butchan "+cmd+"}");
tkcmd(top, "grid "+name+" -row 0 -column "+string (4+i));
buttons = tl buttons;
}
}
initimg(butchan: chan of string, imgpath: string)
{
srv : Service;
srv.attrs = Attributes.new(("name", sysname) :: nil);
srv.addr = "Local Machine";
currsrv = ref srv;
butchan <-= "add "+imgpath+" 0";
butchan <-= "back";
}
blurimage := "";
blurtkpath := "";
blursrvc: ref Service;
additem(top: ref Tk->Toplevel, path: string, overwrite: int)
{
if (blurimage != nil) {
if (overwrite || browser->dialog(ctxt, top, "ok" :: "cancel" :: nil,
"Alert","Replace existing image '"
+nopath(blurimage)+"' with '"+nopath(path)+"'?") == 0) {
sel.delselection("image", blurtkpath);
}
else
return;
}
imgpath := path;
if (currsrv.addr != "Local Machine")
path = path[len "/n/remote":];
blurtkpath = sel.addselection("image", path, nil, 0);
tkcmd(top, "update");
blurimage = path;
blursrvc = currsrv;
if (overwrite)
spawn getpreview(blurtkpath, nil, imgcache);
else
spawn getpreview(blurtkpath, imgpath, nil);
}
nopath(file: string): string
{
return file[len browser->prevpath(file):];
}
runscr := array[] of {
"frame .f",
"frame .f.f1",
"label .f.f1.l -text {Select no of CPUs} -font /fonts/charon/plain.normal.font",
"scale .f.f1.s -orient horizontal -height 16 -showvalue 0 -from 1 -to 20 -command {.f.f1.ls configure -text}",
"label .f.f1.ls -text {1} -font /fonts/charon/plain.normal.font -width 30",
"button .f.f1.b -text {Run} -font /fonts/charon/plain.normal.font -command {send butchan go}",
"pack .f.f1.l .f.f1.s .f.f1.ls .f.f1.b -side left",
"frame .f.f2",
"text .f.f2.t -width 250 -height 150 -borderwidth 1 -bg white -font /fonts/charon/plain.normal.font -yscrollcommand { .f.f2.sy set }",
"scrollbar .f.f2.sy -command { .f.f2.t yview }",
"pack .f.f2.sy -side left -fill y",
"pack .f.f2.t -fill both -expand 1",
"bind .Wm_t <Button-1> +{focus .Wm_t}",
"bind .Wm_t.title <Button-1> +{focus .Wm_t}",
"focus .Wm_t",
"pack .f.f1 -side top",
"pack .f.f2 -fill both -expand 1",
};
run(ctxt: ref Draw->Context, coords: draw->Rect)
{
(top, titlectl) := tkclient->toplevel(ctxt, "", nil, tkclient->Resize);
butchan := chan of string;
sync := chan of int;
quit := chan of int;
tk->namechan(top, butchan, "butchan");
tkcmds(top, runscr);
tkcmd(top, ". configure "+getcentre(top, coords));
tkcmd(top, "pack .f -fill both -expand 1; pack propagate . 0; focus .; update");
tkclient->onscreen(top, "exact");
tkclient->startinput(top, "kbd"::"ptr"::nil);
done := 1;
loop: for (;;) {
alt {
s := <-top.ctxt.kbd =>
tk->keyboard(top, s);
s := <-top.ctxt.ptr =>
tk->pointer(top, *s);
<-sync =>
tkcmd(top, ".f.f1.b configure -state normal; update");
done = 1;
inp := <-butchan =>
(nil, lst) := sys->tokenize(inp, " \n\t");
case hd lst {
"go" =>
tkcmd(top, ".f.f1.b configure -state disabled");
ncpus := int tkcmd(top, ".f.f1.s get");
done = 0;
spawn startit(ncpus, butchan, sync, quit);
"output" =>
tkcmd(top, ".f.f2.t insert end {"+inp[len "output ":]+"}");
"error" =>
tkcmd(top, ".f.f2.t insert end {Error: "+inp[len "error ":]+"\n}");
tkcmd(top, ".f.f1.b configure -state normal");
"fewcpu" =>
i := browser->dialog(ctxt, top, "ok" :: "cancel" :: nil, "Alert",
"Only found "+hd tl lst+" cpus available. Continue?");
quit <-= i;
if (i == 1)
return;
}
tkcmd(top, "update");
s := <-top.ctxt.ctl or
s = <-top.wreq or
s = <- titlectl =>
if (s == "exit") {
if (done)
return;
break loop;
}
else
tkclient->wmctl(top, s);
}
}
top = nil;
for (;;) alt {
<- butchan =>
;
<-sync =>
return;
}
}
startit(ncpus: int, butchan: chan of string, sync, quit: chan of int)
{
imgattached : ref Registries->Attached;
imgpath := blurimage;
if (blursrvc.addr != "Local Machine") {
imgattached = blursrvc.attach(nil, nil);
if (imgattached == nil) {
butchan <-= "error cannot connect to data source: "+blursrvc.attrs.get("name");
return;
}
if (sys->mount(imgattached.fd, nil, "/n/local", sys->MREPL, nil) == -1) {
butchan <-= sys->sprint("error img mount failed: %r");
return;
}
imgpath = "/n/local" + imgpath;
butchan <-= "output Found image namespace\n";
}
sys->pctl(sys->FORKNS, nil);
attribs := ("resource", "Cpu Pool") :: nil;
lsrv := srvbrowse->find(attribs :: nil);
if (lsrv == nil) {
butchan <-= "error cannot find Cpu Pool resource";
return;
}
cpupoolsrvc := hd lsrv;
attached := cpupoolsrvc.attach(nil, nil);
if (attached == nil) {
butchan <-= "error cannot connect to Cpu Pool resource";
return;
}
if (sys->mount(attached.fd, nil, "/n/remote", sys->MREPL, nil) == -1) {
butchan <-= sys->sprint("error Cpu Pool mount failed: %r");
return;
}
butchan <-= "output Connected to Cpu Pool resource\n";
if (blurimage[len blurimage - 4:] == ".jpg") {
butchan <-= "output Converting jpg => bit image\n";
chanin := chan of string;
killchan := chan of int;
spawn jpgprog(butchan, chanin, killchan);
img := readjpg->jpg2img(imgpath, "", chan of string, chanin);
killchan <-= 1;
butchan <-= "output \n";
if (img == nil) {
butchan <-= "error Error converting jpg";
return;
}
sys->remove("/n/remote/data/blurimage.bit");
fd := sys->create("/n/remote/data/blurimage.bit", sys->OWRITE, 8r666);
if (fd == nil || display.writeimage(fd, img) == -1) {
butchan <-= sys->sprint("error Error saving bit: %r");
return;
}
imgpath = "/n/remote/data/blurimage.bit";
}
afd := array[ncpus] of ref sys->FD;
ngot := 0;
for (i := 0; i < ncpus; i++) {
afd[ngot] = sys->open("/n/remote/clone", sys->ORDWR);
if (afd[ngot] == nil)
break;
ngot++;
}
if (ngot == 0) {
butchan <-= "error no cpu resources available";
return;
}
if (ngot < ncpus) {
butchan <-= "fewcpu "+string ngot;
q := <-quit;
if (q)
return;
}
butchan <-= "output Found "+string ngot+" Cpu resource(s)\n";
sh := load Sh Sh->PATH;
if (sh == nil)
badmod(Sh->PATH);
sys->create("/n/remote/data/blur", sys->OREAD, 8r777 | sys->DMDIR);
done := chan of int;
for (i = 0; i < ngot; i++)
spawn go(afd[i], i, butchan, done);
err := sh->run(ctxt, "/dis/grid/demo/blur.dis" :: "/n/remote/data" :: imgpath :: nil);
if (err != nil)
butchan <-= "error "+err;
finished := 0;
for (;;) {
<-done;
finished++;
if (finished == ngot)
break;
}
sys->unmount(nil, "/n/remote");
butchan <-= "output Finished\n";
sync <-= 1;
}
jpgprog(butchan, chanin: chan of string, killchan: chan of int)
{
i := 0;
for (;;) alt {
<-killchan =>
return;
<-chanin =>
i = (i+1) % 2;
if (i)
butchan <-= "output .";
}
}
go(fd: ref sys->FD, id: int, butchan: chan of string, done: chan of int)
{
op := "output Cpu "+string id+": ";
sys->fprint(fd, "/dis/grid/demo/blur.dis /data/");
buf := array[sys->ATOMICIO] of byte;
sys->seek(fd, big 0, sys->SEEKSTART);
i := sys->read(fd, buf, len buf);
if (i < 1)
sys->print("Error reading dir name: %r\n");
dir := string buf[:i];
if (dir[len dir - 1] == '\n')
dir = dir[:len dir -1];
fdout := sys->open("/n/remote/"+dir+"/data", sys->OREAD);
if (fdout == nil) {
butchan <-= op+"Cannot read from stdout";
done <-= 1;
return;
}
for (;;) {
i = sys->read(fdout, buf, len buf);
if (i < 1)
break;
s := string buf[:i];
if (s[len s - 1] != '\n')
s[len s] = '\n';
butchan <-= op+s;
}
done <-= 1;
}
kill(pid: int)
{
if ((fd := sys->open("/prog/" + string pid + "/ctl", Sys->OWRITE)) != nil)
sys->fprint(fd, "kill");
}
killg(pid: int)
{
if ((fd := sys->open("/prog/" + string pid + "/ctl", Sys->OWRITE)) != nil)
sys->fprint(fd, "killgrp");
}
mainscreen := array[] of {
"frame .f",
"frame .f.ftop",
"variable opt command",
"button .f.ftop.bp -text {Services} -command {send butchan back} -font /fonts/charon/bold.normal.font -state disabled -state disabled",
"button .f.ftop.bn -text {Run} -command {send butchan run} -font /fonts/charon/bold.normal.font -state disabled",
"button .f.ftop.br -text {Refresh} -command {send butchan refresh} -font /fonts/charon/bold.normal.font",
"grid .f.ftop.br .f.ftop.bp .f.ftop.bn -row 0",
"grid columnconfigure .f.ftop 3 -minsize 30",
"label .f.l -text { } -height 1 -bg red",
"grid .f.l -row 1 -column 0 -sticky ew",
"grid .f.ftop -row 0 -column 0 -pady 2 -sticky w",
"grid .fbrowse -in .f -row 2 -column 0 -sticky nsew",
"grid .fselect -in .f -row 3 -column 0 -sticky nsew",
"grid columnconfigure .f 0 -weight 1",
"grid rowconfigure .f 2 -weight 1",
"grid rowconfigure .f 3 -weight 1",
"bind .Wm_t <Button-1> +{focus .Wm_t}",
"bind .Wm_t.title <Button-1> +{focus .Wm_t}",
"focus .Wm_t",
};
readpath(dir: File): (array of ref sys->Dir, int)
{
if (currstep == MOUNT) {
(dirs, nil) := readdir->init(dir.path, readdir->NAME | readdir->COMPACT);
dirs2 := array[len dirs] of ref sys->Dir;
num := 0;
for (i := 0; i < len dirs; i++)
if (dirs[i].mode & sys->DMDIR ||
(len dirs[i].name > 4 && (
dirs[i].name[len dirs[i].name - 4:] == ".bit" ||
dirs[i].name[len dirs[i].name - 4:] == ".jpg")))
dirs2[num++] = dirs[i];
return (dirs2[:num], 0);
}
else
return srvbrowse->servicepath2Dir(dir.path, int dir.qid);
return (nil, 0);
}
badmod(path: string)
{
sys->print("Blurdemo: failed to load %s: %r\n",path);
exit;
}
mountscr := array[] of {
"frame .f -borderwidth 2 -relief raised",
"text .f.t -width 200 -height 60 -borderwidth 1 -bg white -font /fonts/charon/plain.normal.font",
"button .f.b -text {Cancel} -command {send butchan cancel} -width 70 -font /fonts/charon/plain.normal.font",
"grid .f.t -row 0 -column 0 -padx 10 -pady 10",
"grid .f.b -row 1 -column 0 -sticky n",
"grid rowconfigure .f 1 -minsize 30",
};
mountsrv(srvpath, qid: string, coords: draw->Rect):int
{
(top, nil) := tkclient->toplevel(ctxt, "", nil, tkclient->Plain);
ctlchan := chan of string;
butchan := chan of string;
tk->namechan(top, butchan, "butchan");
tkcmds(top, mountscr);
tkcmd(top, ". configure "+getcentre(top, coords)+"; pack .f; update");
spawn mountit(srvpath, qid, ctlchan);
pid := int <-ctlchan;
tkclient->onscreen(top, "exact");
tkclient->startinput(top, "kbd"::"ptr"::nil);
for (;;) {
alt {
s := <-top.ctxt.kbd =>
tk->keyboard(top, s);
s := <-top.ctxt.ptr =>
tk->pointer(top, *s);
e := <- ctlchan =>
if (e[0] == '!') {
tkcmd(top, ".f.t insert end {"+e[1:]+"}");
tkcmd(top, ".f.b configure -text {close}; update");
pid = -1;
}
else if (e == "ok")
return 1;
else
tkcmd(top, ".f.t insert end {"+e+"}; update");
<- butchan =>
if (pid != -1)
kill(pid);
return 0;
}
}
return 0;
}
mountit(srvpath, qid: string, ctlchan: chan of string)
{
ctlchan <-= string sys->pctl(0,nil);
n := 0;
(nil, lst) := sys->tokenize(srvpath, "/");
stype := hd tl lst;
name := hd tl tl lst;
addr := "";
ctlchan <-= "Connecting...\n";
lsrv := srvbrowse->servicepath2Service(srvpath, qid);
if (len lsrv < 1) {
ctlchan <-= "!could not find service";
return;
}
srvc := hd lsrv;
currattach = srvc.attach(nil, nil);
if (currattach == nil) {
ctlchan <-= "!attach failed";
return;
}
ctlchan <-= "Mounting...\n";
if (sys->mount(currattach.fd, nil, "/n/remote", sys->MREPL, nil) != -1) {
ctlchan <-= "ok";
currsrv = srvc;
}
else
ctlchan <-= "!mount failed";
}
getcoords(top: ref Tk->Toplevel): draw->Rect
{
h := int tkcmd(top, ". cget -height");
w := int tkcmd(top, ". cget -width");
x := int tkcmd(top, ". cget -actx");
y := int tkcmd(top, ". cget -acty");
r := draw->Rect((x,y),(x+w,y+h));
return r;
}
getcentre(top: ref Tk->Toplevel, winr: draw->Rect): string
{
h := int tkcmd(top, ".f cget -height");
w := int tkcmd(top, ".f cget -width");
midx := winr.min.x + (winr.dx() / 2);
midy := winr.min.y + (winr.dy() / 2);
newx := midx - (w/2);
newy := midy - (h/2);
return "-x "+string newx+" -y "+string newy;
}
changestep(top: ref Tk->Toplevel, step: int, label: string)
{
root, rlabel: string;
if (step == MOUNT) {
tkcmd (top, ".f.ftop.bp configure -state normal");
br.changeview(2);
rlabel = label;
if (currsrv.addr == "Local Machine")
root = "/";
else
root = "/n/remote/";
}
else if (step == IMAGE) {
br.changeview(1);
if (currsrv != nil) {
sys->unmount(nil, "/n/remote");
currattach = nil;
currsrv = nil;
}
srvbrowse->refreshservices(srvfilter);
root = "services/";
rlabel = "Image Services";
sel.showframe("image");
tkcmd (top, ".f.ftop.bp configure -state disabled");
# addlocalservice();
sel.select("image", nil, DESELECT);
}
currstep = step;
br.selectfile(1, DESELECT, File (nil, nil), nil);
br.selectfile(0, DESELECT,File (nil, nil), nil);
actionbutton(top, nil, nil);
br.newroot(root, rlabel);
if (currstep == MOUNT)
br.selectfile(0, SELECT, File (root, nil), ".fbrowse.fl.f0.l");
tkcmd(top, "update");
}
addlocalservice()
{
lsrv : Service;
attrs := ("resource", "Data source") ::
("name", "Local Filestore") ::
("type", "styx") :: nil;
lsrv.attrs = Attributes.new(attrs);
lsrv.addr = "@your local filestore";
srvbrowse->addservice(ref lsrv);
}
tkcmd(top: ref Tk->Toplevel, cmd: string): string
{
e := tk->cmd(top, cmd);
if (e != "" && e[0] == '!')
sys->print("Tk error: '%s': %s\n",cmd,e);
return e;
}
tkcmds(top: ref Tk->Toplevel, a: array of string)
{
for (j := 0; j < len a; j++)
tkcmd(top, a[j]);
}
readfile(f: string): string
{
fd := sys->open(f, sys->OREAD);
if(fd == nil)
return nil;
buf := array[8192] of byte;
n := sys->read(fd, buf, len buf);
if(n < 0)
return nil;
return string buf[:n];
}
setsrvfilter()
{
imagefilter := ("proto", "styx") :: ("auth", "none") :: ("Image resource", "1") :: nil;
srvfilter = imagefilter :: nil;
}
getpreview(tkpath, imgpath: string, img: ref Image)
{
if (imgpath != nil && imgpath[len imgpath - 4:] == ".jpg") {
tkcmd (sel.top, ".f.ftop.bn configure -state normal");
return;
}
if (img == nil) {
img = display.open(imgpath);
if (img == nil) {
browser->dialog(ctxt, sel.top, "ok" :: nil, "Alert",
sys->sprint("Invalid '.bit' image: %r"));
sel.delselection("image", blurtkpath);
blurimage = nil;
blursrvc = nil;
return;
}
}
previmg := preview(img, 100);
tk->cmd(sel.top, "destroy .preview");
tkcmd(sel.top, "image create bitmap .preview");
tk->putimage(sel.top, ".preview", previmg, nil);
tkcmd(sel.top, sys->sprint("%s configure -image .preview -width %d -height %d",
tkpath, previmg.r.dx(), previmg.r.dy()));
tkcmd(sel.top, "grid forget "+tkpath+"; grid "+tkpath+" -row 1 "+
"-column 0 -columnspan 3 -pady 5 -sticky ew;");
sel.setscrollr(sel.currfname);
tkcmd (sel.top, ".f.ftop.bn configure -state normal");
tkcmd(sel.top, "update;");
}
preview(img: ref Image, maxsize: int): ref Image
{
mx := max(img.r.dx(), img.r.dy());
if (mx <= maxsize) {
imgcache = img;
return img;
}
prevr := Rect ((0,0), (img.r.dx()*maxsize/mx, img.r.dy()*maxsize/mx));
tmpimg := display.newimage(img.r, Draw->RGB24, 0, Draw->White);
previmg := display.newimage(prevr, Draw->RGB24, 0, Draw->White);
tmpimg.draw(img.r, img, nil, (0,0));
getr := Rect ((0,0), (img.r.dx() / prevr.dx(), img.r.dy() / prevr.dy()));
nopixels := getr.dx() * getr.dy();
getrgb := array[nopixels * 3] of byte;
newrgb := array[3] of byte;
for (y := 0; y < prevr.dy(); y++) {
for (x := 0; x < prevr.dx(); x++) {
tmpimg.readpixels(getr.addpt((x*getr.dx(), y*getr.dy())), getrgb);
tmprgb := array[] of { 0, 0, 0 };
for (i := 0; i < len getrgb; i++)
tmprgb[i%3] += int getrgb[i];
for (i = 0; i < 3; i++)
newrgb[i] = byte (tmprgb[i] / nopixels);
previmg.writepixels(((x,y),(x+1,y+1)), newrgb);
}
}
imgcache = previmg;
return previmg;
}
max(a,b: int): int
{
if (a > b)
return a;
return b;
}
previewscr := array[] of {
"frame .f",
"panel .f.p -borderwidth 2 -relief raised",
"button .f.bs -text Select -font /fonts/charon/plain.normal.font -command {send prevchan select} -state disabled",
"button .f.bc -text Close -font /fonts/charon/plain.normal.font -command {send prevchan close} -state disabled",
"pack .f",
"grid .f.p -row 0 -column 0 -columnspan 2 -padx 5 -pady 5",
"grid .f.bs .f.bc -row 1 -padx 5 -pady 5",
"update",
};
previewwin(oldtop: ref Tk->Toplevel, chanout: chan of string, path: string)
{
(top, titlectl) := tkclient->toplevel(ctxt, "", "Loading...", 0);
prevchan := chan of string;
tk->namechan(top, prevchan, "prevchan");
tkclient->onscreen(top, "exact");
img := display.open(path);
if (img == nil) {
browser->dialog(ctxt, oldtop, "ok" :: nil, "Alert", "Invalid '.bit' image");
return;
}
previmg := preview(img, 100);
tkcmds(top, previewscr);
tk->putimage(top, ".f.p", previmg, nil);
tkcmd(top, ".Wm_t.title configure -text Preview");
tkcmd(top, ".f.p dirty; update");
browser->setcentre(oldtop, top);
tkcmd(top, ".f.bs configure -state normal; .f.bc configure -state normal");
tkclient->startinput(top, "kbd"::"ptr"::nil);
main: for(;;) alt {
s := <-top.ctxt.kbd =>
tk->keyboard(top, s);
s := <-top.ctxt.ptr =>
tk->pointer(top, *s);
s := <- prevchan =>
if (s == "select")
chanout <-= "add "+path+" 1";
break main;
s := <-top.ctxt.ctl or
s = <-top.wreq or
s = <- titlectl =>
if (s == "exit")
break main;
else
tkclient->wmctl(top, s);
}
}