136 lines
2.4 KiB
C
136 lines
2.4 KiB
C
#include "acd.h"
|
|
|
|
int debug;
|
|
|
|
void
|
|
usage(void)
|
|
{
|
|
fprint(2, "usage: acd dev\n");
|
|
threadexitsall("usage");
|
|
}
|
|
|
|
Alt
|
|
mkalt(Channel *c, void *v, int op)
|
|
{
|
|
Alt a;
|
|
|
|
memset(&a, 0, sizeof(a));
|
|
a.c = c;
|
|
a.v = v;
|
|
a.op = op;
|
|
return a;
|
|
}
|
|
|
|
void
|
|
freetoc(Toc *t)
|
|
{
|
|
int i;
|
|
|
|
free(t->title);
|
|
for(i=0; i<t->ntrack; i++)
|
|
free(t->track[i].title);
|
|
}
|
|
|
|
void
|
|
eventwatcher(Drive *d)
|
|
{
|
|
enum { STATUS, WEVENT, TOCDISP, DBREQ, DBREPLY, NALT };
|
|
Alt alts[NALT+1];
|
|
Toc nt, tdb;
|
|
Event *e;
|
|
Window *w;
|
|
Cdstatus s;
|
|
char buf[40];
|
|
|
|
w = d->w;
|
|
|
|
alts[STATUS] = mkalt(d->cstatus, &s, CHANRCV);
|
|
alts[WEVENT] = mkalt(w->cevent, &e, CHANRCV);
|
|
alts[TOCDISP] = mkalt(d->ctocdisp, &nt, CHANRCV);
|
|
alts[DBREQ] = mkalt(d->cdbreq, &tdb, CHANNOP);
|
|
alts[DBREPLY] = mkalt(d->cdbreply, &nt, CHANRCV);
|
|
alts[NALT] = mkalt(nil, nil, CHANEND);
|
|
for(;;) {
|
|
switch(alt(alts)) {
|
|
case STATUS:
|
|
//DPRINT(2, "s...");
|
|
d->status = s;
|
|
if(s.state == Scompleted) {
|
|
s.state = Sunknown;
|
|
advancetrack(d, w);
|
|
}
|
|
//DPRINT(2, "status %d %d %d %M %M\n", s.state, s.track, s.index, s.abs, s.rel);
|
|
sprint(buf, "%d:%2.2d", s.rel.m, s.rel.s);
|
|
setplaytime(w, buf);
|
|
break;
|
|
case WEVENT:
|
|
//DPRINT(2, "w...");
|
|
acmeevent(d, w, e);
|
|
break;
|
|
case TOCDISP:
|
|
//DPRINT(2,"td...");
|
|
freetoc(&d->toc);
|
|
d->toc = nt;
|
|
drawtoc(w, d, &d->toc);
|
|
tdb = nt;
|
|
alts[DBREQ].op = CHANSND;
|
|
break;
|
|
case DBREQ: /* sent */
|
|
//DPRINT(2,"dreq...");
|
|
alts[DBREQ].op = CHANNOP;
|
|
break;
|
|
case DBREPLY:
|
|
//DPRINT(2,"drep...");
|
|
freetoc(&d->toc);
|
|
d->toc = nt;
|
|
redrawtoc(w, &d->toc);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
void
|
|
threadmain(int argc, char **argv)
|
|
{
|
|
Scsi *s;
|
|
Drive *d;
|
|
char buf[80];
|
|
|
|
ARGBEGIN{
|
|
case 'v':
|
|
debug++;
|
|
scsiverbose++;
|
|
}ARGEND
|
|
|
|
if(argc != 1)
|
|
usage();
|
|
|
|
fmtinstall('M', msfconv);
|
|
|
|
if((s = openscsi(argv[0])) == nil)
|
|
error("opening scsi: %r");
|
|
|
|
d = malloc(sizeof(*d));
|
|
if(d == nil)
|
|
error("out of memory");
|
|
memset(d, 0, sizeof d);
|
|
|
|
d->scsi = s;
|
|
d->w = newwindow();
|
|
d->ctocdisp = chancreate(sizeof(Toc), 0);
|
|
d->cdbreq = chancreate(sizeof(Toc), 0);
|
|
d->cdbreply = chancreate(sizeof(Toc), 0);
|
|
d->cstatus = chancreate(sizeof(Cdstatus), 0);
|
|
|
|
proccreate(wineventproc, d->w, STACK);
|
|
proccreate(cddbproc, d, STACK);
|
|
proccreate(cdstatusproc, d, STACK);
|
|
|
|
cleanname(argv[0]);
|
|
snprint(buf, sizeof(buf), "%s/", argv[0]);
|
|
winname(d->w, buf);
|
|
|
|
wintagwrite(d->w, "Stop Pause Resume Eject Ingest ", 5+6+7+6+7);
|
|
eventwatcher(d);
|
|
}
|