/*
* drive HP optical-disc jukeboxes (e.g. HP 1200EX).
* used to issue SCSI commands directly to the host adapter;
* now (via scsi.c) it issues them via scsi(2) using
* /dev/sdXX/raw to run the robotics, and uses normal i/o
* on /dev/sdXX/data to run the drives.
*/
#include "all.h"
#include "io.h"
enum {
SCSInone = SCSIread,
MAXDRIVE = 10,
MAXSIDE = 500, /* max. disc sides */
TWORM = MINUTE(10),
THYSTER = SECOND(10),
Sectorsz = 512, /* usual disk sector size */
Jukemagic = 0xbabfece2,
};
typedef struct Side Side;
struct Side
{
QLock; /* protects loading/unloading */
int elem; /* element number */
int drive; /* if loaded, where */
uchar status; /* Sunload, etc */
uchar rot; /* if backside */
int ord; /* ordinal number for labeling */
Timet time; /* time since last access, to unspin */
Timet stime; /* time since last spinup, for hysteresis */
long nblock; /* number of native blocks */
long block; /* bytes per native block */
long mult; /* multiplier to get plan9 blocks */
long max; /* max size in plan9 blocks */
};
typedef struct Juke Juke;
struct Juke
{
QLock; /* protects drive mechanism */
Side side[MAXSIDE];
int nside; /* # of storage elements (*2 if rev) */
int ndrive; /* # of transfer elements */
Device* juke; /* devworm of changer */
Device* drive[MAXDRIVE]; /* devworm for i/o */
uchar offline[MAXDRIVE]; /* drives removed from service */
int isfixedsize; /* flag: one size fits all? */
long fixedsize; /* the one size that fits all */
int probeok; /* wait for init to probe */
Scsi* robot; /* scsi(2) interface to robotics */
char* robotdir; /* /dev/sdXX name */
/*
* geometry returned by mode sense.
* a *0 number (such as mt0) is the `element number' of the
* first element of that type (e.g., mt, or motor transport).
* an n* number is the quantity of them.
*/
int mt0, nmt; /* motor transports (robot pickers) */
int se0, nse; /* storage elements (discs, slots) */
int ie0, nie; /* interchange elements (mailbox slots) */
int dt0, ndt; /* drives (data transfer?) */
int rot; /* if true, discs are double-sided */
ulong magic;
Juke* link;
};
static Juke* jukelist;
enum
{
Sempty = 0, /* does not exist */
Sunload, /* on the shelf */
Sstart, /* loaded and spinning */
};
static int bestdrive(Juke*, int);
static void element(Juke*, int);
static int mmove(Juke*, int, int, int, int);
static void shelves(void);
static int waitready(Juke *, Device*);
static int wormsense(Device*);
static Side* wormunit(Device*);
/* create a new label and try to write it */
static void
newlabel(Device *d, Off labelblk, char *labelbuf, unsigned vord)
{
Label *label = (Label *)labelbuf;
memset(labelbuf, 0, RBUFSIZE);
label->magic = Labmagic;
label->ord = vord;
strncpy(label->service, service, sizeof label->service);
if (!okay("write new label"))
print("NOT writing new label\n");
else if (wormwrite(d, labelblk, labelbuf))
/* wormwrite will have complained in detail */
fprint(2, "can't write new label on side %d\n", vord);
else if (chatty)
print("wrote new label on side %d\n", vord);
}
/* check for label in last block. call with v qlocked. */
Side*
wormlabel(Device *d, Side *v)
{
int vord;
Off labelblk = v->max - 1; /* last block */
char labelbuf[RBUFSIZE];
Label *label = (Label *)labelbuf;
Juke *w = d->private;
/* wormread calls wormunit, which locks v */
vord = v->ord;
qunlock(v);
memset(label, 0, sizeof *label);
if (wormread(d, labelblk, labelbuf)) {
/*
* wormread will have complained in detail about the error;
* no need to repeat most of that detail.
* probably an unwritten WORM-disc label; write a new one.
*/
fprint(2, "error reading label block of side %d\n", vord);
newlabel(d, labelblk, labelbuf, vord);
} else if (label->magic != Labmagic) {
swab8(&label->magic);
if (label->magic == Labmagic) {
fprint(2, "side %d's label magic byte-swapped; filsys should be configured with xD",
vord);
swab2(&label->ord);
/* could look for Devswab in Juke's filsys */
} else {
/*
* magic # is wrong in both byte orders, thus
* probably the label is empty on RW media,
* so create a new one and try to write it.
*/
fprint(2, "bad magic number in label of side %d\n", vord);
newlabel(d, labelblk, labelbuf, vord);
}
}
qlock(v);
if (v->ord != vord)
panic("wormlabel: side %d switched ordinal to %d underfoot",
vord, v->ord);
if (label->ord != vord) {
fprint(2, "labelled worm side %Z has wrong ordinal in label (%d, want %d)",
d, label->ord, vord);
qunlock(v);
cmd_wormreset(0, nil); /* put discs away */
panic("wrong ordinal in label");
}
if(chatty)
fprint(2, "label %Z ordinal %d\n", d, v->ord);
qunlock(v);
/*
* wormunit should return without calling us again,
* since v is now known.
*/
if (w != d->private)
panic("wormlabel: w != %Z->private", d);
return wormunit(d);
}
/*
* mounts and spins up the device
* locks the structure
*/
static Side*
wormunit(Device *d) /* d is l0 or r2 (e.g.) */
{
int p, drive;
Device *dr; /* w0 or w1.2.0 (e.g.) */
Side *v;
Juke *w;
Dir *dir;
w = d->private;
if (w == nil)
panic("wormunit %Z nil juke", d);
if (w->magic != Jukemagic)
panic("bad magic in Juke for %Z", d);
p = d->wren.targ;
if(p < 0 || w && p >= w->nside) {
panic("wormunit: target %d out of range for %Z", p, d);
return 0;
}
/*
* if disk is unloaded, must load it
* into next (circular) logical unit
*/
v = &w->side[p];
qlock(v);
if(v->status == Sunload) {
for(;;) {
qlock(w);
drive = bestdrive(w, p);
if(drive >= 0)
break;
qunlock(w);
delay(100);
}
if(chatty)
fprint(2, "\tload r%zd drive %Z\n", v-w->side, w->drive[drive]);
if(mmove(w, w->mt0, v->elem, w->dt0+drive, v->rot)) {
qunlock(w);
goto sbad;
}
v->drive = drive;
v->status = Sstart;
v->stime = toytime();
qunlock(w);
dr = w->drive[drive];
if (!waitready(w, dr))
goto sbad;
v->stime = toytime();
} else
dr = w->drive[v->drive];
if(v->status != Sstart) {
if(v->status == Sempty)
fprint(2, "worm: unit empty %Z\n", d);
else
fprint(2, "worm: not started %Z\n", d);
goto sbad;
}
v->time = toytime();
if(v->block) /* side is known already */
return v;
/*
* load and record information about side
*/
if (dr->wren.file)
dr->wren.sddata = dataof(dr->wren.file);
else {
if (dr->wren.sddir == nil) {
if (dr->type == Devwren)
dr->wren.sddir = sdof(dr);
if (dr->wren.sddir == nil)
panic("wormunit: %Z for %Z not a wren", dr, d);
}
dr->wren.sddata = smprint("%s/data", dr->wren.sddir);
}
if (dr->wren.fd == 0)
dr->wren.fd = open(dr->wren.sddata, ORDWR);
if (dr->wren.fd < 0) {
fprint(2, "wormunit: can't open %s for %Z: %r\n", dr->wren.sddata, d);
goto sbad;
}
v->block = inqsize(dr->wren.sddata);
if(v->block <= 0) {
if(chatty)
fprint(2, "\twormunit %Z block size %ld, setting to %d\n",
d, v->block, Sectorsz);
v->block = Sectorsz;
}
dir = dirfstat(dr->wren.fd);
v->nblock = dir->length / v->block;
free(dir);
v->mult = (RBUFSIZE + v->block - 1) / v->block;
v->max = (v->nblock + 1) / v->mult;
if(chatty){
fprint(2, "\tworm %Z: drive %Z (juke drive %d)\n",
d, w->drive[v->drive], v->drive);
fprint(2, "\t\t%,ld %ld-byte sectors, ", v->nblock, v->block);
fprint(2, "%,ld %d-byte blocks\n", v->max, RBUFSIZE);
fprint(2, "\t\t%ld multiplier\n", v->mult);
}
if(d->type == Devlworm)
return wormlabel(d, v);
else
return v;
sbad:
qunlock(v);
return 0;
}
/* wait 10s for optical drive to spin up */
static int
waitready(Juke *w, Device *d)
{
int p, e, rv;
char *datanm;
if (w->magic != Jukemagic)
panic("waitready: bad magic in Juke (d->private) for %Z", d);
p = d->wren.targ;
if(p < 0 || p >= w->nside) {
fprint(2, "waitready: target %d out of range for %Z\n", p, d);
return 0;
}
if (d->type == Devwren && d->wren.file)
datanm = strdup(d->wren.file);
else {
if (d->wren.sddir)
free(d->wren.sddir);
if (d->type == Devwren)
d->wren.sddir = sdof(d);
if (d->wren.sddir == nil)
panic("waitready: d->wren.sddir not set for %Z", d);
datanm = smprint("%s/data", d->wren.sddir);
}
rv = 0;
for(e=0; e < 100; e++) {
if(e == 10 && chatty)
fprint(2, "waitready: waiting for %s to exist\n", datanm);
if(access(datanm, AEXIST) >= 0){
rv = 1;
break;
}
delay(200);
}
if(rv == 0)
fprint(2, "waitready: %s for %Z didn't come ready\n", datanm, d);
free(datanm);
return rv;
}
static int
bestdrive(Juke *w, int side)
{
Side *v, *bv[MAXDRIVE];
int i, e, drive;
Timet t, t0;
loop:
/* build table of what platters on what drives */
for(i=0; i<w->ndt; i++)
bv[i] = 0;
v = &w->side[0];
for(i=0; i < w->nside; i++, v++)
if(v->status == Sstart) {
drive = v->drive;
if(drive >= 0 && drive < w->ndt)
bv[drive] = v;
}
/*
* find oldest drive, but must be
* at least THYSTER old.
*/
e = w->side[side].elem;
t0 = toytime() - THYSTER;
t = t0;
drive = -1;
for(i=0; i<w->ndt; i++) {
v = bv[i];
if(v == 0) { /* 2nd priority: empty drive */
if(w->offline[i])
continue;
if(w->drive[i] != devnone) {
drive = i;
t = 0;
}
continue;
}
if(v->elem == e) { /* 1st priority: other side */
drive = -1;
if(v->stime < t0)
drive = i;
break;
}
if(v->stime < t) { /* 3rd priority: by time */
drive = i;
t = v->stime;
}
}
if(drive >= 0) {
v = bv[drive];
if(v) {
qlock(v);
if(v->status != Sstart) {
qunlock(v);
goto loop;
}
if(chatty)
fprint(2, "\tunload r%zd drive %Z\n",
v-w->side, w->drive[drive]);
if(mmove(w, w->mt0, w->dt0+drive, v->elem, v->rot)) {
qunlock(v);
goto loop;
}
v->status = Sunload;
qunlock(v);
}
}
return drive;
}
Devsize
wormsize(Device *d)
{
Side *v;
Juke *w;
Devsize size;
w = d->private;
if (w->magic != Jukemagic)
fprint(2, "wormsize: bad magic in Juke (d->private) for %Z\n", d);
if(w->isfixedsize && w->fixedsize != 0)
size = w->fixedsize; /* fixed size is now known */
else {
if (w != d->private)
panic("wormsize: w != %Z->private", d);
v = wormunit(d);
if(v == nil)
return 0;
size = v->max;
qunlock(v);
/*
* set fixed size for whole Juke from
* size of first disc examined.
*/
if(w->isfixedsize)
w->fixedsize = size;
}
if(d->type == Devlworm)
return size-1; /* lie: last block is for label */
return size;
}
/*
* return a Devjuke or an mcat (normally of sides) from within d (or nil).
* if it's an mcat, the caller must walk it.
*/
static Device *
devtojuke(Device *d, Device *top)
{
while (d != nil)
switch(d->type) {
default:
fprint(2, "devtojuke: type of device %Z of %Z unknown\n", d, top);
return nil;
case Devjuke:
/* jackpot! d->private is a (Juke *) with nside, &c. */
/* FALL THROUGH */
case Devmcat:
case Devmlev:
case Devmirr:
/* squint hard & call an mlev or a mirr an mcat */
return d;
case Devworm:
case Devlworm:
/*
* d->private is a (Juke *) with nside, etc.,
* but we're not supposed to get here.
*/
if(chatty)
fprint(2, "devtojuke: (l)worm %Z of %Z encountered\n", d, top);
/* FALL THROUGH */
case Devwren:
return nil;
case Devcw:
d = d->cw.w; /* usually juke */
break;
case Devro:
d = d->ro.parent; /* cw */
break;
case Devfworm:
d = d->fw.fw;
break;
case Devpart:
d = d->part.d;
break;
case Devswab:
d = d->swab.d;
break;
}
return d;
}
static int
devisside(Device *d)
{
return d->type == Devworm || d->type == Devlworm;
}
static Device *
findside(Device *juke, int side, Device *top)
{
int i = 0;
Device *mcat = juke->j.m, *x;
Juke *w = juke->private;
for (x = mcat->cat.first; x != nil; x = x->link) {
if (!devisside(x)) {
fprint(2, "wormsizeside: %Z of %Z of %Z type not (l)worm\n",
x, mcat, top);
return nil;
}
i = x->wren.targ;
if (i < 0 || i >= w->nside)
panic("wormsizeside: side %d in %Z out of range",
i, mcat);
if (i == side)
break;
}
if (x == nil)
return nil;
if (w->side[i].time == 0) {
fprint(2, "wormsizeside: side %d not in jukebox %Z\n", i, juke);
return nil;
}
return x;
}
typedef struct {
int sleft; /* sides still to visit to reach desired side */
int starget; /* side of topdev we want */
Device *topdev;
int sawjuke; /* passed by a jukebox */
int sized; /* flag: asked wormsize for size of starget */
} Visit;
/*
* walk the Device tree from d looking for Devjukes, counting sides.
* the main complication is mcats and the like with Devjukes in them.
* use Devjuke's d->private as Juke* and see sides.
*/
static Off
visitsides(Device *d, Device *parentj, Visit *vp)
{
Off size = 0;
Device *x;
Juke *w;
/*
* find the first juke or mcat.
* d==nil means we couldn't find one; typically harmless, due to a
* mirror of dissimilar devices.
*/
d = devtojuke(d, vp->topdev);
if (d == nil || vp->sleft < 0)
return 0;
if (d->type == Devjuke) { /* jackpot! d->private is a (Juke *) */
vp->sawjuke = 1;
w = d->private;
/*
* if there aren't enough sides in this jukebox to reach
* the desired one, subtract these sides and pass.
*/
if (vp->sleft >= w->nside) {
vp->sleft -= w->nside;
return 0;
}
/* else this is the right juke, paw through mcat of sides */
return visitsides(d->j.m, d, vp);
}
/*
* d will usually be an mcat of sides, but it could be an mcat of
* jukes, for example. in that case, we need to walk the mcat,
* recursing as needed, until we find the right juke, then stop at
* the right side within its mcat of sides, by comparing side
* numbers, not just by counting (to allow for unused slots).
*/
x = d->cat.first;
if (x == nil) {
fprint(2, "visitsides: %Z of %Z: empty mcat\n", d, vp->topdev);
return 0;
}
if (!devisside(x)) {
for (; x != nil && !vp->sized; x = x->link)
size = visitsides(x, parentj, vp);
return size;
}
/* the side we want is in this jukebox, thus this mcat (d) */
if (parentj == nil) {
fprint(2, "visitsides: no parent juke for sides mcat %Z\n", d);
vp->sleft = -1;
return 0;
}
if (d != parentj->j.m)
panic("visitsides: mcat mismatch %Z vs %Z", d, parentj->j.m);
x = findside(parentj, vp->sleft, vp->topdev);
if (x == nil) {
vp->sleft = -1;
return 0;
}
/* we've turned vp->starget into the right Device* */
vp->sleft = 0;
vp->sized = 1;
return wormsize(x);
}
/*
* d must be, or be within, a filesystem config that also contains
* the jukebox that `side' resides on.
* d is normally a Devcw, but could be Devwren, Devide, Devpart, Devfworm,
* etc. if called from chk.c Ctouch code. Note too that the worm part of
* the Devcw might be other than a Devjuke.
*/
Devsize
wormsizeside(Device *d, int side)
{
Devsize size;
Visit visit;
memset(&visit, 0, sizeof visit);
visit.starget = visit.sleft = side;
visit.topdev = d;
size = visitsides(d, nil, &visit);
if (visit.sawjuke && (visit.sleft != 0 || !visit.sized)) {
fprint(2, "wormsizeside: fewer than %d sides in %Z\n", side, d);
return 0;
}
return size;
}
/*
* returns starts (in blocks) of side #side and #(side+1) of dev in *stp.
* dev should be a Devcw.
*/
void
wormsidestarts(Device *dev, int side, Sidestarts *stp)
{
int s;
Devsize dstart;
for (dstart = s = 0; s < side; s++)
dstart += wormsizeside(dev, s);
stp->sstart = dstart;
stp->s1start = dstart + wormsizeside(dev, side);
}
int
wormread(Device *d, Off b, void *c)
{
int r = 0;
long max;
char name[128];
Side *v = wormunit(d);
Juke *w = d->private;
Device *dr;
if (v == nil)
panic("wormread: nil wormunit(%Z)", d);
dr = w->drive[v->drive];
if (dr->wren.fd < 0)
panic("wormread: unopened fd for %Z", d);
max = (d->type == Devlworm? v->max + 1: v->max);
if(b >= max) {
fprint(2, "wormread: block out of range %Z(%lld)\n", d, (Wideoff)b);
r = 0x071;
} else if (pread(dr->wren.fd, c, RBUFSIZE, (vlong)b*RBUFSIZE) != RBUFSIZE) {
fd2path(dr->wren.fd, name, sizeof name);
fprint(2, "wormread: error on %Z(%lld) on %s in %s: %r\n",
d, (Wideoff)b, name, dr->wren.sddir);
cons.nwormre++;
r = 1;
}
qunlock(v);
return r;
}
int
wormwrite(Device *d, Off b, void *c)
{
int r = 0;
long max;
char name[128];
Side *v = wormunit(d);
Juke *w = d->private;
Device *dr;
if (v == nil)
panic("wormwrite: nil wormunit(%Z)", d);
dr = w->drive[v->drive];
if (dr->wren.fd < 0)
panic("wormwrite: unopened fd for %Z", d);
max = (d->type == Devlworm? v->max + 1: v->max);
if(b >= max) {
fprint(2, "wormwrite: block out of range %Z(%lld)\n", d, (Wideoff)b);
r = 0x071;
} else if (pwrite(dr->wren.fd, c, RBUFSIZE, (vlong)b*RBUFSIZE) != RBUFSIZE) {
fd2path(dr->wren.fd, name, sizeof name);
fprint(2, "wormwrwite: error on %Z(%lld) on %s in %s: %r\n",
d, (Wideoff)b, name, dr->wren.sddir);
cons.nwormwe++;
r = 1;
}
qunlock(v);
return r;
}
static int
mmove(Juke *w, int trans, int from, int to, int rot)
{
int s;
uchar cmd[12], buf[4];
static int recur = 0;
memset(cmd, 0, sizeof cmd);
cmd[0] = 0xa5; /* move medium */
cmd[2] = trans>>8;
cmd[3] = trans;
cmd[4] = from>>8;
cmd[5] = from;
cmd[6] = to>>8;
cmd[7] = to;
if(rot)
cmd[10] = 1;
s = scsiio(w->juke, SCSInone, cmd, sizeof cmd, buf, 0); /* mmove */
if(s) {
fprint(2, "scsio status #%x\n", s);
fprint(2, "move medium t=%d fr=%d to=%d rot=%d\n",
trans, from, to, rot);
// panic("mmove");
if(recur == 0) {
recur = 1;
fprint(2, "element from=%d\n", from);
element(w, from);
fprint(2, "element to=%d\n", to);
element(w, to);
fprint(2, "element trans=%d\n", trans);
element(w, trans);
recur = 0;
}
return 1;
}
return 0;
}
static void
geometry(Juke *w)
{
int s;
uchar cmd[6], buf[4+20];
memset(cmd, 0, sizeof cmd);
memset(buf, 0, sizeof buf);
cmd[0] = 0x1a; /* mode sense */
cmd[2] = 0x1d; /* element address assignment */
cmd[4] = sizeof buf; /* allocation length */
s = scsiio(w->juke, SCSIread, cmd, sizeof cmd, buf, sizeof buf); /* mode sense elem addrs */
if(s)
panic("geometry #%x", s);
w->mt0 = (buf[4+2]<<8) | buf[4+3];
w->nmt = (buf[4+4]<<8) | buf[4+5];
w->se0 = (buf[4+6]<<8) | buf[4+7];
w->nse = (buf[4+8]<<8) | buf[4+9];
w->ie0 = (buf[4+10]<<8) | buf[4+11];
w->nie = (buf[4+12]<<8) | buf[4+13];
w->dt0 = (buf[4+14]<<8) | buf[4+15];
w->ndt = (buf[4+16]<<8) | buf[4+17];
memset(cmd, 0, 6);
memset(buf, 0, sizeof buf);
cmd[0] = 0x1a; /* mode sense */
cmd[2] = 0x1e; /* transport geometry */
cmd[4] = sizeof buf; /* allocation length */
s = scsiio(w->juke, SCSIread, cmd, sizeof cmd, buf, sizeof buf); /* mode sense geometry */
if(s)
panic("geometry #%x", s);
w->rot = buf[4+2] & 1;
fprint(2, "\tmt %d %d\n", w->mt0, w->nmt);
fprint(2, "\tse %d %d\n", w->se0, w->nse);
fprint(2, "\tie %d %d\n", w->ie0, w->nie);
fprint(2, "\tdt %d %d\n", w->dt0, w->ndt);
fprint(2, "\trot %d\n", w->rot);
}
/*
* read element e's status from jukebox w, move any disc in drive back to its
* slot, and update and print software status.
*/
static void
element(Juke *w, int e)
{
uchar cmd[12], buf[8+8+88];
int s, t;
memset(cmd, 0, sizeof cmd);
memset(buf, 0, sizeof buf);
cmd[0] = 0xb8; /* read element status */
cmd[2] = e>>8; /* starting element */
cmd[3] = e;
cmd[5] = 1; /* number of elements */
cmd[9] = sizeof buf; /* allocation length */
s = scsiio(w->juke, SCSIread, cmd, sizeof cmd, buf, sizeof buf); /* read elem sts */
if(s) {
fprint(2, "scsiio #%x\n", s);
goto bad;
}
s = (buf[0]<<8) | buf[1];
if(s != e) {
fprint(2, "element = %d\n", s);
goto bad;
}
if(buf[3] != 1) {
fprint(2, "number reported = %d\n", buf[3]);
goto bad;
}
s = (buf[8+8+0]<<8) | buf[8+8+1];
if(s != e) {
fprint(2, "element1 = %d\n", s);
goto bad;
}
switch(buf[8+0]) { /* element type */
default:
fprint(2, "unknown element %d: %d\n", e, buf[8+0]);
goto bad;
case 1: /* transport */
s = e - w->mt0;
if(s < 0 || s >= w->nmt)
goto bad;
if(buf[8+8+2] & 1)
fprint(2, "transport %d full %d.%d\n", s,
(buf[8+8+10]<<8) | buf[8+8+11],
(buf[8+8+9]>>6) & 1);
break;
case 2: /* storage */
s = e - w->se0;
if(s < 0 || s >= w->nse)
goto bad;
w->side[s].status = Sempty;
if(buf[8+8+2] & 1)
w->side[s].status = Sunload;
if(w->rot)
w->side[w->nse+s].status = w->side[s].status;
break;
case 3: /* import/export */
s = e - w->ie0;
if(s < 0 || s >= w->nie)
goto bad;
if(chatty)
fprint(2, "import/export %d #%.2x %d.%d\n", s,
buf[8+8+2],
(buf[8+8+10]<<8) | buf[8+8+11],
(buf[8+8+9]>>6) & 1);
break;
case 4: /* data transfer */
s = e - w->dt0;
if(s < 0 || s >= w->ndt)
goto bad;
if(chatty)
fprint(2, "data transfer %d #%.2x %d.%d\n", s,
buf[8+8+2],
(buf[8+8+10]<<8) | buf[8+8+11],
(buf[8+8+9]>>6) & 1);
if(buf[8+8+2] & 1) {
t = ((buf[8+8+10]<<8) | buf[8+8+11]) - w->se0;
if (t < 0 || t >= w->nse || t >= MAXSIDE ||
s >= MAXDRIVE) {
fprint(2, "element: juke %Z lies; claims side %d is in drive %d\n",
w->juke, t, s); /* lying sack of ... */
/*
* at minimum, we've avoided corrupting our
* data structures. if we know that numbers
* like w->nside are valid here, we could use
* them in more stringent tests.
* perhaps should whack the jukebox upside the
* head here to knock some sense into it.
*/
goto bad;
}
if(chatty)
fprint(2, "r%d in drive %d\n", t, s);
if(mmove(w, w->mt0, w->dt0+s, w->se0+t,(buf[8+8+9]>>6) & 1)){
fprint(2, "mmove initial unload\n");
goto bad;
}
w->side[t].status = Sunload;
if(w->rot)
w->side[w->nse+t].status = Sunload;
}
if(buf[8+8+2] & 4){
fprint(2, "drive w%d has exception #%.2x #%.2x\n", s,
buf[8+8+4], buf[8+8+5]);
goto bad;
}
break;
}
return;
bad:
/* panic("element") */ ;
}
/*
* read all elements' status from jukebox w, move any discs in drives back
* to their slots, and update and print software status.
*/
static void
positions(Juke *w)
{
int i, f;
/* mark empty shelves */
for(i=0; i<w->nse; i++)
element(w, w->se0+i);
for(i=0; i<w->nmt; i++)
element(w, w->mt0+i);
for(i=0; i<w->nie; i++)
element(w, w->ie0+i);
for(i=0; i<w->ndt; i++)
element(w, w->dt0+i);
f = 0;
for(i=0; i<w->nse; i++)
if(w->side[i].status == Sempty) {
if(f) {
print("r%d\n", i-1);
f = 0;
}
} else {
if(!f) {
print("\tshelves r%d-", i);
f = 1;
}
}
if(f)
print("r%d\n", i-1);
}
static void
jinit(Juke *w, Device *d, int o)
{
int p;
Device *dev = d;
switch(d->type) {
default:
fprint(2, "juke platter not (devmcat of) dev(l)worm: %Z\n", d);
panic("jinit: type");
case Devmcat:
/*
* we don't call mcatinit(d) here, so we have to set d->cat.ndev
* ourselves.
*/
for(d=d->cat.first; d; d=d->link)
jinit(w, d, o++);
dev->cat.ndev = o;
break;
case Devlworm:
p = d->wren.targ;
if(p < 0 || p >= w->nside)
panic("jinit partition %Z", d);
w->side[p].ord = o;
/* FALL THROUGH */
case Devworm:
if(d->private) {
fprint(2, "juke platter private pointer set %p\n",
d->private);
panic("jinit: private");
}
d->private = w;
break;
}
}
Side*
wormi(char *arg)
{
int i, j;
Juke *w;
Side *v;
i = number(arg, -1, 10) - 1;
w = jukelist;
if(i < 0 || i >= w->nside) {
fprint(2, "bad unit number %s (%d)\n", arg, i+1);
return 0;
}
j = i;
if(j >= w->nse)
j -= w->nse;
if(j < w->nside) {
v = &w->side[j];
qlock(v);
if(v->status == Sstart) {
if(mmove(w, w->mt0, w->dt0+v->drive, v->elem, v->rot)) {
qunlock(v);
return 0;
}
v->status = Sunload;
}
qunlock(v);
}
j += w->nse;
if(j < w->nside) {
v = &w->side[j];
qlock(v);
if(v->status == Sstart) {
if(mmove(w, w->mt0, w->dt0+v->drive, v->elem, v->rot)) {
qunlock(v);
return 0;
}
v->status = Sunload;
}
qunlock(v);
}
v = &w->side[i];
qlock(v);
return v;
}
static void
cmd_wormoffline(int argc, char *argv[])
{
int u, i;
Juke *w;
if(argc <= 1) {
print("usage: wormoffline drive\n");
return;
}
u = number(argv[1], -1, 10);
w = jukelist;
if(u < 0 || u >= w->ndrive) {
fprint(2, "bad drive %s (0<=%d<%d)\n", argv[1], u, w->ndrive);
return;
}
if(w->offline[u])
print("drive %d already offline\n", u);
w->offline[u] = 1;
for(i=0; i<w->ndrive; i++)
if(w->offline[i] == 0)
return;
print("that would take all drives offline\n");
w->offline[u] = 0;
}
static void
cmd_wormonline(int argc, char *argv[])
{
int u;
Juke *w;
if(argc <= 1) {
print("usage: wormonline drive\n");
return;
}
u = number(argv[1], -1, 10);
w = jukelist;
if(u < 0 || u >= w->ndrive) {
print("bad drive %s (0<=%d<%d)\n", argv[1], u, w->ndrive);
return;
}
if(w->offline[u] == 0)
print("drive %d already online\n", u);
w->offline[u] = 0;
}
void
cmd_wormreset(int, char *[])
{
Juke *w;
for(w=jukelist; w; w=w->link) {
qlock(w);
positions(w);
qunlock(w);
}
}
static void
cmd_wormeject(int argc, char *argv[])
{
Juke *w;
Side *v;
if(argc <= 1) {
print("usage: wormeject unit\n");
return;
}
v = wormi(argv[1]);
if(v == 0)
return;
w = jukelist;
mmove(w, w->mt0, v->elem, w->ie0, 0);
qunlock(v);
}
static void
cmd_wormingest(int argc, char *argv[])
{
Juke *w;
Side *v;
if(argc <= 1) {
print("usage: wormingest unit\n");
return;
}
v = wormi(argv[1]);
if(v == 0)
return;
w = jukelist;
mmove(w, w->mt0, w->ie0, v->elem, 0);
qunlock(v);
}
static void
newside(Side *v, int rot, int elem)
{
qlock(v);
qunlock(v);
// v->name = "shelf";
v->elem = elem;
v->rot = rot;
v->status = Sempty;
v->time = toytime();
}
/*
* query jukebox robotics for geometry;
* argument is the wren dev of the changer.
* result is actually Juke*, but that type is only known in this file.
*/
void *
querychanger(Device *xdev)
{
Juke *w;
Side *v;
int i;
if (xdev == nil)
panic("querychanger: nil Device");
if(xdev->type != Devwren) {
fprint(2, "juke changer not wren %Z\n", xdev);
goto bad;
}
for(w=jukelist; w; w=w->link)
if(xdev == w->juke)
return w;
/*
* allocate a juke structure
* no locking problems.
*/
w = ialloc(sizeof(Juke), 0);
w->magic = Jukemagic;
w->isfixedsize = FIXEDSIZE;
w->link = jukelist;
jukelist = w;
if(chatty)
fprint(2, "alloc juke %Z\n", xdev);
qlock(w);
qunlock(w);
// w->name = "juke";
w->juke = xdev;
w->robotdir = sdof(xdev);
w->robot = openscsi(w->robotdir);
if (w->robot == nil)
panic("can't openscsi(%s): %r", w->robotdir);
newscsi(xdev, w->robot);
geometry(w);
/*
* pick up each side
*/
w->nside = w->nse;
if(w->rot)
w->nside += w->nside;
if(w->nside > MAXSIDE) {
fprint(2, "too many sides: %d max %d\n", w->nside, MAXSIDE);
goto bad;
}
for(i=0; i < w->nse; i++) {
v = &w->side[i];
newside(v, 0, w->se0 + i);
if(w->rot)
newside(v + w->nse, 1, w->se0 + i);
}
positions(w);
w->ndrive = w->ndt;
if(w->ndrive > MAXDRIVE) {
if(chatty)
fprint(2, "ndrives truncated to %d\n", MAXDRIVE);
w->ndrive = MAXDRIVE;
}
/*
* pick up each drive
*/
for(i=0; i<w->ndrive; i++)
w->drive[i] = devnone;
return w;
bad:
panic("querychanger: %Z", xdev);
return nil;
}
void
jukeinit(Device *d)
{
Juke *w;
Device *xdev;
int i;
static int beenhere = 0;
/* j(w<changer>w<station0>...)(r<platters>) */
if (d == nil)
panic("jukeinit: nil Device");
xdev = d->j.j;
if(xdev == nil || xdev->type != Devmcat) {
fprint(2, "juke union not mcat\n");
goto bad;
}
/*
* pick up the changer device
*/
xdev = xdev->cat.first;
w = querychanger(xdev);
if (!beenhere) {
beenhere = 1;
cmd_install("wormreset",
"-- put drives back where jukebox thinks they belong",
cmd_wormreset);
cmd_install("wormeject", "unit -- shelf to outside",
cmd_wormeject);
cmd_install("wormingest", "unit -- outside to shelf",
cmd_wormingest);
cmd_install("wormoffline", "unit -- disable drive",
cmd_wormoffline);
cmd_install("wormonline", "unit -- enable drive",
cmd_wormonline);
}
/* walk through the worm drives */
i = 0;
while(xdev = xdev->link) {
if(xdev->type != Devwren) {
fprint(2, "drive not devwren: %Z\n", xdev);
goto bad;
}
if(w->drive[i]->type != Devnone &&
xdev != w->drive[i]) {
fprint(2, "double init drive %d %Z %Z\n",
i, w->drive[i], xdev);
goto bad;
}
if(i >= w->ndrive) {
fprint(2, "too many drives %Z\n", xdev);
goto bad;
}
w->drive[i++] = xdev;
}
if(i <= 0) {
fprint(2, "no drives\n");
goto bad;
}
/*
* put w pointer in each platter
*/
d->private = w;
jinit(w, d->j.m, 0);
w->probeok = 1;
return;
bad:
panic("juke init");
}
/*
* called periodically
*/
void
wormprobe(void)
{
int i, drive;
Timet t;
Side *v;
Juke *w;
t = toytime() - TWORM;
for(w=jukelist; w; w=w->link) {
if(w->probeok == 0 || !canqlock(w))
continue;
for(i=0; i<w->nside; i++) {
v = &w->side[i];
if(!canqlock(v))
continue;
if(v->status == Sstart && t > v->time) {
drive = v->drive;
if(chatty)
fprint(2, "\ttime r%zd drive %Z\n",
v-w->side, w->drive[drive]);
mmove(w, w->mt0, w->dt0+drive, v->elem, v->rot);
v->status = Sunload;
}
qunlock(v);
}
qunlock(w);
}
}
