Subversion Repositories planix.SVN

#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);
}