ref: d4124d48f9c7e85fdaa50640035080174c94196e
dir: /sys/src/cmd/9660srv/9660srv.c/
#include <u.h>
#include <libc.h>
#include <auth.h>
#include <fcall.h>
#include "dat.h"
#include "fns.h"
#include "iso9660.h"
static void ireset(void);
static int iattach(Xfile*);
static void iclone(Xfile*, Xfile*);
static void iwalkup(Xfile*);
static void iwalk(Xfile*, char*);
static void iopen(Xfile*, int);
static void icreate(Xfile*, char*, long, int);
static long ireaddir(Xfile*, uchar*, vlong, long);
static long iread(Xfile*, char*, vlong, long);
static long iwrite(Xfile*, char*, vlong, long);
static void iclunk(Xfile*);
static void iremove(Xfile*);
static void istat(Xfile*, Dir*);
static void iwstat(Xfile*, Dir*);
static char* nstr(uchar*, int);
static char* rdate(uchar*, int);
static int getcontin(Xdata*, uchar*, uchar**);
static int getdrec(Xfile*, void*);
static void ungetdrec(Xfile*);
static int opendotdot(Xfile*, Xfile*);
static int showdrec(int, int, void*);
static long gtime(uchar*);
static long l16(void*);
static long l32(void*);
static void newdrec(Xfile*, Drec*);
static int rzdir(Xfs*, Dir*, int, Drec*);
Xfsub isosub =
{
ireset, iattach, iclone, iwalkup, iwalk, iopen, icreate,
ireaddir, iread, iwrite, iclunk, iremove, istat, iwstat
};
static vlong
fakemax(vlong len)
{
if(len == (1UL << 31) - 1) /* max. 9660 size? */
len = (1ULL << 63) - 1; /* pretend it's vast */
return len;
}
static void
ireset(void)
{}
static int
iattach(Xfile *root)
{
Xfs *cd = root->xf;
Iobuf *p; Voldesc *v; Isofile *fp; Drec *dp;
int fmt, blksize, i, n, l, haveplan9;
Iobuf *dirp;
uchar dbuf[256];
Drec *rd = (Drec *)dbuf;
uchar *q, *s;
dirp = nil;
blksize = 0;
fmt = 0;
dp = nil;
haveplan9 = 0;
for(i=VOLDESC;i<VOLDESC+100; i++){ /* +100 for sanity */
p = getbuf(cd->d, i, 1);
v = (Voldesc*)(p->iobuf);
if(memcmp(v->byte, "\01CD001\01", 7) == 0){ /* iso */
if(dirp)
putbuf(dirp);
dirp = p;
fmt = 'z';
dp = (Drec*)v->z.desc.rootdir;
blksize = l16(v->z.desc.blksize);
chat("iso, blksize=%d...", blksize);
v = (Voldesc*)(dirp->iobuf);
haveplan9 = (strncmp((char*)v->z.boot.sysid, "PLAN 9", 6)==0);
if(haveplan9){
if(noplan9) {
chat("ignoring plan9");
haveplan9 = 0;
} else {
fmt = '9';
chat("plan9 iso...");
}
}
continue;
}
if(memcmp(&v->byte[8], "\01CDROM\01", 7) == 0){ /* high sierra */
if(dirp)
putbuf(dirp);
dirp = p;
fmt = 'r';
dp = (Drec*)v->r.desc.rootdir;
blksize = l16(v->r.desc.blksize);
chat("high sierra, blksize=%d...", blksize);
continue;
}
if(haveplan9==0 && !nojoliet
&& memcmp(v->byte, "\02CD001\01", 7) == 0){
chat("%d %d\n", haveplan9, nojoliet);
/*
* The right thing to do is walk the escape sequences looking
* for one of 25 2F 4[035], but Microsoft seems to not honor
* the format, which makes it hard to walk over.
*/
q = v->z.desc.escapes;
if(q[0] == 0x25 && q[1] == 0x2F && (q[2] == 0x40 || q[2] == 0x43 || q[2] == 0x45)){ /* Joliet, it appears */
if(dirp)
putbuf(dirp);
dirp = p;
fmt = 'J';
dp = (Drec*)v->z.desc.rootdir;
if(blksize != l16(v->z.desc.blksize))
fprint(2, "warning: suspicious Joliet blocksize\n");
chat("joliet...");
continue;
}
}
putbuf(p);
if(v->byte[0] == 0xFF)
break;
}
if(fmt == 0){
if(dirp)
putbuf(dirp);
return -1;
}
assert(dirp != nil);
if(chatty)
showdrec(2, fmt, dp);
if(blksize > Sectorsize){
chat("blksize too big...");
putbuf(dirp);
return -1;
}
if(waserror()){
putbuf(dirp);
nexterror();
}
root->len = sizeof(Isofile) - sizeof(Drec) + dp->reclen;
root->ptr = fp = ealloc(root->len);
if(haveplan9)
root->xf->isplan9 = 1;
fp->fmt = fmt;
fp->blksize = blksize;
fp->offset = 0;
fp->doffset = 0;
memmove(&fp->d, dp, dp->reclen);
root->qid.path = l32(dp->addr);
root->qid.type = QTDIR;
putbuf(dirp);
poperror();
if(getdrec(root, rd) >= 0){
n = rd->reclen-(34+rd->namelen);
s = (uchar*)rd->name + rd->namelen;
if((uintptr)s & 1){
s++;
n--;
}
if(n >= 7 && s[0] == 'S' && s[1] == 'P' && s[2] == 7 &&
s[3] == 1 && s[4] == 0xBE && s[5] == 0xEF){
root->xf->issusp = 1;
root->xf->suspoff = s[6];
n -= root->xf->suspoff;
s += root->xf->suspoff;
for(; n >= 4; s += l, n -= l){
l = s[2];
if(s[0] == 'E' && s[1] == 'R'){
if(!norock && s[4] == 10 && memcmp(s+8, "RRIP_1991A", 10) == 0)
root->xf->isrock = 1;
break;
} else if(s[0] == 'C' && s[1] == 'E' && s[2] >= 28){
n = getcontin(root->xf->d, s, &s);
continue;
} else if(s[0] == 'R' && s[1] == 'R'){
if(!norock)
root->xf->isrock = 1;
break;
} else if(s[0] == 'S' && s[1] == 'T')
break;
}
}
}
if(root->xf->isrock)
chat("Rock Ridge...");
fp->offset = 0;
fp->doffset = 0;
return 0;
}
static void
iclone(Xfile *of, Xfile *nf)
{
USED(of, nf);
}
static void
iwalkup(Xfile *f)
{
long paddr;
uchar dbuf[256];
Drec *d = (Drec *)dbuf;
Xfile pf, ppf;
Isofile piso, ppiso;
memset(&pf, 0, sizeof pf);
memset(&ppf, 0, sizeof ppf);
pf.ptr = &piso;
ppf.ptr = &ppiso;
if(opendotdot(f, &pf) < 0)
error("can't open pf");
paddr = l32(pf.ptr->d.addr);
if(l32(f->ptr->d.addr) == paddr)
return;
if(opendotdot(&pf, &ppf) < 0)
error("can't open ppf");
while(getdrec(&ppf, d) >= 0){
if(l32(d->addr) == paddr){
newdrec(f, d);
f->qid.path = paddr;
f->qid.type = QTDIR;
return;
}
}
error("can't find addr of ..");
}
static int
casestrcmp(int isplan9, char *a, char *b)
{
if(isplan9)
return strcmp(a, b);
return cistrcmp(a, b);
}
static void
iwalk(Xfile *f, char *name)
{
Isofile *ip = f->ptr;
uchar dbuf[256];
char nbuf[4*Maxname];
Drec *d = (Drec*)dbuf;
Dir dir;
char *p;
int len, vers, dvers;
vers = -1;
if(p = strchr(name, ';')) { /* assign = */
len = p-name;
if(len >= Maxname)
len = Maxname-1;
memmove(nbuf, name, len);
vers = strtoul(p+1, 0, 10);
name = nbuf;
}
/*
len = strlen(name);
if(len >= Maxname){
len = Maxname-1;
if(name != nbuf){
memmove(nbuf, name, len);
name = nbuf;
}
name[len] = 0;
}
*/
chat("%d \"%s\"...", strlen(name), name);
ip->offset = 0;
setnames(&dir, nbuf);
while(getdrec(f, d) >= 0) {
dvers = rzdir(f->xf, &dir, ip->fmt, d);
if(casestrcmp(f->xf->isplan9||f->xf->isrock, name, dir.name) != 0)
continue;
newdrec(f, d);
f->qid.path = dir.qid.path;
f->qid.type = dir.qid.type;
USED(dvers);
return;
}
USED(vers);
error(Enonexist);
}
static void
iopen(Xfile *f, int mode)
{
mode &= ~OCEXEC;
if(mode != OREAD && mode != OEXEC)
error(Eperm);
f->ptr->offset = 0;
f->ptr->doffset = 0;
}
static void
icreate(Xfile *f, char *name, long perm, int mode)
{
USED(f, name, perm, mode);
error(Eperm);
}
static long
ireaddir(Xfile *f, uchar *buf, vlong offset, long count)
{
Isofile *ip = f->ptr;
Dir d;
char names[4*Maxname];
uchar dbuf[256];
Drec *drec = (Drec *)dbuf;
int n, rcnt;
if(offset==0){
ip->offset = 0;
ip->doffset = 0;
}else if(offset != ip->doffset)
error("seek in directory not allowed");
rcnt = 0;
setnames(&d, names);
while(rcnt < count && getdrec(f, drec) >= 0){
if(drec->namelen == 1){
if(drec->name[0] == 0)
continue;
if(drec->name[0] == 1)
continue;
}
rzdir(f->xf, &d, ip->fmt, drec);
d.qid.vers = f->qid.vers;
if((n = convD2M(&d, buf+rcnt, count-rcnt)) <= BIT16SZ){
ungetdrec(f);
break;
}
rcnt += n;
}
ip->doffset += rcnt;
return rcnt;
}
static long
iread(Xfile *f, char *buf, vlong offset, long count)
{
int n, o, rcnt = 0;
vlong size, addr;
Isofile *ip = f->ptr;
Iobuf *p;
size = fakemax(l32(ip->d.size));
if(offset >= size)
return 0;
if(offset+count > size)
count = size - offset;
addr = ((vlong)l32(ip->d.addr) + ip->d.attrlen)*ip->blksize + offset;
o = addr % Sectorsize;
addr /= Sectorsize;
/*chat("d.addr=%ld, addr=%lld, o=%d...", l32(ip->d.addr), addr, o);*/
n = Sectorsize - o;
while(count > 0){
if(n > count)
n = count;
p = getbuf(f->xf->d, addr, 0);
memmove(&buf[rcnt], &p->iobuf[o], n);
putbuf(p);
count -= n;
rcnt += n;
++addr;
o = 0;
n = Sectorsize;
}
return rcnt;
}
static long
iwrite(Xfile *f, char *buf, vlong offset, long count)
{
USED(f, buf, offset, count);
error(Eperm);
return 0;
}
static void
iclunk(Xfile *f)
{
USED(f);
}
static void
iremove(Xfile *f)
{
USED(f);
error(Eperm);
}
static void
istat(Xfile *f, Dir *d)
{
Isofile *ip = f->ptr;
rzdir(f->xf, d, ip->fmt, &ip->d);
d->qid.vers = f->qid.vers;
if(d->qid.path==f->xf->rootqid.path){
d->qid.path = 0;
d->qid.type = QTDIR;
}
}
static void
iwstat(Xfile *f, Dir *d)
{
USED(f, d);
error(Eperm);
}
static int
showdrec(int fd, int fmt, void *x)
{
Drec *d = (Drec *)x;
int namelen;
int syslen;
if(d->reclen == 0)
return 0;
fprint(fd, "%d %d %ld %ld ",
d->reclen, d->attrlen, l32(d->addr), l32(d->size));
fprint(fd, "%s 0x%2.2x %d %d %ld ",
rdate(d->date, fmt), (fmt=='z' ? d->flags : d->r_flags),
d->unitsize, d->gapsize, l16(d->vseqno));
fprint(fd, "%d %s", d->namelen, nstr(d->name, d->namelen));
if(fmt != 'J'){
namelen = d->namelen + (1-(d->namelen&1));
syslen = d->reclen - 33 - namelen;
if(syslen != 0)
fprint(fd, " %s", nstr(&d->name[namelen], syslen));
}
fprint(fd, "\n");
return d->reclen + (d->reclen&1);
}
static void
newdrec(Xfile *f, Drec *dp)
{
Isofile *x = f->ptr;
Isofile *n;
int len;
len = sizeof(Isofile) - sizeof(Drec) + dp->reclen;
n = ealloc(len);
n->fmt = x->fmt;
n->blksize = x->blksize;
n->offset = 0;
n->doffset = 0;
memmove(&n->d, dp, dp->reclen);
free(x);
f->ptr = n;
f->len = len;
}
static void
ungetdrec(Xfile *f)
{
Isofile *ip = f->ptr;
if(ip->offset >= ip->odelta){
ip->offset -= ip->odelta;
ip->odelta = 0;
}
}
static int
getdrec(Xfile *f, void *buf)
{
Isofile *ip = f->ptr;
int len = 0, boff = 0;
vlong addr;
uvlong size;
Iobuf *p = 0;
if(!ip)
return -1;
size = fakemax(l32(ip->d.size));
while(ip->offset < size){
addr = (l32(ip->d.addr)+ip->d.attrlen)*ip->blksize + ip->offset;
boff = addr % Sectorsize;
if(boff > Sectorsize-34){
ip->offset += Sectorsize-boff;
continue;
}
p = getbuf(f->xf->d, addr/Sectorsize, 1);
len = p->iobuf[boff];
if(len >= 34)
break;
putbuf(p);
p = 0;
ip->offset += Sectorsize-boff;
}
if(p) {
memmove(buf, &p->iobuf[boff], len);
putbuf(p);
ip->odelta = len + (len&1);
ip->offset += ip->odelta;
return 0;
}
return -1;
}
static int
opendotdot(Xfile *f, Xfile *pf)
{
uchar dbuf[256];
Drec *d = (Drec *)dbuf;
Isofile *ip = f->ptr, *pip = pf->ptr;
ip->offset = 0;
if(getdrec(f, d) < 0){
chat("opendotdot: getdrec(.) failed...");
return -1;
}
if(d->namelen != 1 || d->name[0] != 0){
chat("opendotdot: no . entry...");
return -1;
}
if(l32(d->addr) != l32(ip->d.addr)){
chat("opendotdot: bad . address...");
return -1;
}
if(getdrec(f, d) < 0){
chat("opendotdot: getdrec(..) failed...");
return -1;
}
if(d->namelen != 1 || d->name[0] != 1){
chat("opendotdot: no .. entry...");
return -1;
}
pf->xf = f->xf;
pip->fmt = ip->fmt;
pip->blksize = ip->blksize;
pip->offset = 0;
pip->doffset = 0;
pip->d = *d;
return 0;
}
enum {
Hname = 1,
Hmode = 2,
};
static int
rzdir(Xfs *fs, Dir *d, int fmt, Drec *dp)
{
int n, flags, i, j, lj, nl, vers, sysl, mode, l, have;
uchar *s;
char *p;
char buf[Maxname+UTFmax+1];
uchar *q;
Rune r;
have = 0;
flags = 0;
vers = -1;
d->qid.path = l32(dp->addr);
d->qid.type = 0;
d->qid.vers = 0;
n = dp->namelen;
memset(d->name, 0, Maxname);
if(n == 1) {
switch(dp->name[0]){
case 1:
d->name[1] = '.';
/* fall through */
case 0:
d->name[0] = '.';
have = Hname;
break;
default:
d->name[0] = tolower(dp->name[0]);
}
} else {
if(fmt == 'J'){ /* Joliet, 16-bit Unicode */
q = (uchar*)dp->name;
for(i=j=lj=0; i<n && j<Maxname; i+=2){
lj = j;
r = (q[i]<<8)|q[i+1];
j += runetochar(buf+j, &r);
}
if(j >= Maxname)
j = lj;
memmove(d->name, buf, j);
}else{
if(n >= Maxname)
n = Maxname-1;
for(i=0; i<n; i++)
d->name[i] = tolower(dp->name[i]);
}
}
sysl = dp->reclen-(34+dp->namelen);
s = (uchar*)dp->name + dp->namelen;
if(((uintptr)s) & 1) {
s++;
sysl--;
}
if(fs->isplan9 && sysl > 0) {
/*
* get gid, uid, mode and possibly name
* from plan9 directory extension
*/
nl = *s;
if(nl >= Maxname)
nl = Maxname-1;
if(nl) {
memset(d->name, 0, Maxname);
memmove(d->name, s+1, nl);
}
s += 1 + *s;
nl = *s;
if(nl >= Maxname)
nl = Maxname-1;
memset(d->uid, 0, Maxname);
memmove(d->uid, s+1, nl);
s += 1 + *s;
nl = *s;
if(nl >= Maxname)
nl = Maxname-1;
memset(d->gid, 0, Maxname);
memmove(d->gid, s+1, nl);
s += 1 + *s;
if(((uintptr)s) & 1)
s++;
d->mode = l32(s);
if(d->mode & DMDIR)
d->qid.type |= QTDIR;
} else {
d->mode = 0444;
switch(fmt) {
case 'z':
if(fs->isrock)
strcpy(d->gid, "ridge");
else
strcpy(d->gid, "iso9660");
flags = dp->flags;
break;
case 'r':
strcpy(d->gid, "sierra");
flags = dp->r_flags;
break;
case 'J':
strcpy(d->gid, "joliet");
flags = dp->flags;
break;
case '9':
strcpy(d->gid, "plan9");
flags = dp->flags;
break;
}
if(flags & 0x02){
d->qid.type |= QTDIR;
d->mode |= DMDIR|0111;
}
strcpy(d->uid, "cdrom");
if(fmt!='9' && !(d->mode&DMDIR)){
/*
* ISO 9660 actually requires that you always have a . and a ;,
* even if there is no version and no extension. Very few writers
* do this. If the version is present, we use it for qid.vers.
* If there is no extension but there is a dot, we strip it off.
* (VMS heads couldn't comprehend the dot as a file name character
* rather than as just a separator between name and extension.)
*
* We don't do this for directory names because directories are
* not allowed to have extensions and versions.
*/
if((p=strchr(d->name, ';')) != nil){
vers = strtoul(p+1, 0, 0);
d->qid.vers = vers;
*p = '\0';
}
if((p=strchr(d->name, '.')) != nil && *(p+1)=='\0')
*p = '\0';
}
if(fs->issusp){
nl = 0;
s += fs->suspoff;
sysl -= fs->suspoff;
for(; sysl >= 4 && have != (Hname|Hmode); sysl -= l, s += l){
if(s[0] == 0 && ((uintptr)s & 1)){
/* MacOS pads individual entries, contrary to spec */
s++;
sysl--;
}
l = s[2];
if(s[0] == 'P' && s[1] == 'X' && s[3] == 1){
/* posix file attributes */
mode = l32(s+4);
d->mode = mode & 0777;
if((mode & 0170000) == 040000){
d->mode |= DMDIR;
d->qid.type |= QTDIR;
}
have |= Hmode;
} else if(s[0] == 'N' && s[1] == 'M' && s[3] == 1){
/* alternative name */
if((s[4] & ~1) == 0){
i = nl+l-5;
if(i >= Maxname)
i = Maxname-1;
if((i -= nl) > 0){
memmove(d->name+nl, s+5, i);
nl += i;
}
if(s[4] == 0)
have |= Hname;
}
} else if(s[0] == 'C' && s[1] == 'E' && s[2] >= 28){
sysl = getcontin(fs->d, s, &s);
continue;
} else if(s[0] == 'S' && s[1] == 'T')
break;
}
}
}
d->length = 0;
if((d->mode & DMDIR) == 0)
d->length = fakemax(l32(dp->size));
d->type = 0;
d->dev = 0;
d->atime = gtime(dp->date);
d->mtime = d->atime;
return vers;
}
static int
getcontin(Xdata *dev, uchar *p, uchar **s)
{
long bn, off, len;
Iobuf *b;
bn = l32(p+4);
off = l32(p+12);
len = l32(p+20);
chat("getcontin %d...", bn);
b = getbuf(dev, bn, 1);
if(b == 0){
*s = 0;
return 0;
}
*s = b->iobuf+off;
putbuf(b);
return len;
}
static char *
nstr(uchar *p, int n)
{
static char buf[132];
char *q = buf;
while(--n >= 0){
if(*p == '\\')
*q++ = '\\';
if(' ' <= *p && *p <= '~')
*q++ = *p++;
else
q += sprint(q, "\\%2.2ux", *p++);
}
*q = 0;
return buf;
}
static char *
rdate(uchar *p, int fmt)
{
static char buf[64];
int htz, s, n;
n = sprint(buf, "%2.2d.%2.2d.%2.2d %2.2d:%2.2d:%2.2d",
p[0], p[1], p[2], p[3], p[4], p[5]);
if(fmt == 'z'){
htz = p[6];
if(htz >= 128){
htz = 256-htz;
s = '-';
}else
s = '+';
sprint(&buf[n], " (%c%.1f)", s, (float)htz/2);
}
return buf;
}
static char
dmsize[12] =
{
31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31,
};
static int
dysize(int y)
{
if((y%4) == 0)
return 366;
return 365;
}
static long
gtime(uchar *p) /* yMdhmsz */
{
long t;
int i, y, M, d, h, m, s, tz;
y=p[0]; M=p[1]; d=p[2];
h=p[3]; m=p[4]; s=p[5]; tz=p[6];
USED(tz);
y += 1900;
if (y < 1970)
return 0;
if (M < 1 || M > 12)
return 0;
if (d < 1 || d > dmsize[M-1])
if (!(M == 2 && d == 29 && dysize(y) == 366))
return 0;
if (h > 23)
return 0;
if (m > 59)
return 0;
if (s > 59)
return 0;
t = 0;
for(i=1970; i<y; i++)
t += dysize(i);
if (dysize(y)==366 && M >= 3)
t++;
while(--M)
t += dmsize[M-1];
t += d-1;
t = 24*t + h;
t = 60*t + m;
t = 60*t + s;
return t;
}
#define p ((uchar*)arg)
static long
l16(void *arg)
{
long v;
v = ((long)p[1]<<8)|p[0];
if (v >= 0x8000L)
v -= 0x10000L;
return v;
}
static long
l32(void *arg)
{
return ((((((long)p[3]<<8)|p[2])<<8)|p[1])<<8)|p[0];
}
#undef p