12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802 |
- #include "stdinc.h"
- #include "dat.h"
- #include "fns.h"
- #include "9.h"
- typedef struct Fsys Fsys;
- struct Fsys {
- VtLock* lock;
- char* name; /* copy here & Fs to ease error reporting */
- char* dev;
- char* venti;
- Fs* fs;
- VtSession* session;
- int ref;
- int noauth;
- int noperm;
- int wstatallow;
- Fsys* next;
- };
- static struct {
- VtLock* lock;
- Fsys* head;
- Fsys* tail;
- char* curfsys;
- } sbox;
- static char *_argv0;
- #define argv0 _argv0
- static char FsysAll[] = "all";
- static char EFsysBusy[] = "fsys: '%s' busy";
- static char EFsysExists[] = "fsys: '%s' already exists";
- static char EFsysNoCurrent[] = "fsys: no current fsys";
- static char EFsysNotFound[] = "fsys: '%s' not found";
- static char EFsysNotOpen[] = "fsys: '%s' not open";
- static Fsys*
- _fsysGet(char* name)
- {
- Fsys *fsys;
- if(name == nil || name[0] == '\0')
- name = "main";
- vtRLock(sbox.lock);
- for(fsys = sbox.head; fsys != nil; fsys = fsys->next){
- if(strcmp(name, fsys->name) == 0){
- fsys->ref++;
- break;
- }
- }
- vtRUnlock(sbox.lock);
- if(fsys == nil)
- vtSetError(EFsysNotFound, name);
- return fsys;
- }
- static int
- cmdPrintConfig(int argc, char* argv[])
- {
- Fsys *fsys;
- char *usage = "usage: printconfig";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc)
- return cliError(usage);
- vtRLock(sbox.lock);
- for(fsys = sbox.head; fsys != nil; fsys = fsys->next){
- consPrint("\tfsys %s config %s\n", fsys->name, fsys->dev);
- if(fsys->venti && fsys->venti[0])
- consPrint("\tfsys %s venti %q\n", fsys->name,
- fsys->venti);
- }
- vtRUnlock(sbox.lock);
- return 1;
- }
- Fsys*
- fsysGet(char* name)
- {
- Fsys *fsys;
- if((fsys = _fsysGet(name)) == nil)
- return nil;
- vtLock(fsys->lock);
- if(fsys->fs == nil){
- vtSetError(EFsysNotOpen, fsys->name);
- vtUnlock(fsys->lock);
- fsysPut(fsys);
- return nil;
- }
- vtUnlock(fsys->lock);
- return fsys;
- }
- char*
- fsysGetName(Fsys* fsys)
- {
- return fsys->name;
- }
- Fsys*
- fsysIncRef(Fsys* fsys)
- {
- vtLock(sbox.lock);
- fsys->ref++;
- vtUnlock(sbox.lock);
- return fsys;
- }
- void
- fsysPut(Fsys* fsys)
- {
- vtLock(sbox.lock);
- assert(fsys->ref > 0);
- fsys->ref--;
- vtUnlock(sbox.lock);
- }
- Fs*
- fsysGetFs(Fsys* fsys)
- {
- assert(fsys != nil && fsys->fs != nil);
- return fsys->fs;
- }
- void
- fsysFsRlock(Fsys* fsys)
- {
- vtRLock(fsys->fs->elk);
- }
- void
- fsysFsRUnlock(Fsys* fsys)
- {
- vtRUnlock(fsys->fs->elk);
- }
- int
- fsysNoAuthCheck(Fsys* fsys)
- {
- return fsys->noauth;
- }
- int
- fsysNoPermCheck(Fsys* fsys)
- {
- return fsys->noperm;
- }
- int
- fsysWstatAllow(Fsys* fsys)
- {
- return fsys->wstatallow;
- }
- static char modechars[] = "YUGalLdHSATs";
- static ulong modebits[] = {
- ModeSticky,
- ModeSetUid,
- ModeSetGid,
- ModeAppend,
- ModeExclusive,
- ModeLink,
- ModeDir,
- ModeHidden,
- ModeSystem,
- ModeArchive,
- ModeTemporary,
- ModeSnapshot,
- 0
- };
- char*
- fsysModeString(ulong mode, char *buf)
- {
- int i;
- char *p;
- p = buf;
- for(i=0; modebits[i]; i++)
- if(mode & modebits[i])
- *p++ = modechars[i];
- sprint(p, "%luo", mode&0777);
- return buf;
- }
- int
- fsysParseMode(char* s, ulong* mode)
- {
- ulong x, y;
- char *p;
- x = 0;
- for(; *s < '0' || *s > '9'; s++){
- if(*s == 0)
- return 0;
- p = strchr(modechars, *s);
- if(p == nil)
- return 0;
- x |= modebits[p-modechars];
- }
- y = strtoul(s, &p, 8);
- if(*p != '\0' || y > 0777)
- return 0;
- *mode = x|y;
- return 1;
- }
- File*
- fsysGetRoot(Fsys* fsys, char* name)
- {
- File *root, *sub;
- assert(fsys != nil && fsys->fs != nil);
- root = fsGetRoot(fsys->fs);
- if(name == nil || strcmp(name, "") == 0)
- return root;
- sub = fileWalk(root, name);
- fileDecRef(root);
- return sub;
- }
- static Fsys*
- fsysAlloc(char* name, char* dev)
- {
- Fsys *fsys;
- vtLock(sbox.lock);
- for(fsys = sbox.head; fsys != nil; fsys = fsys->next){
- if(strcmp(fsys->name, name) != 0)
- continue;
- vtSetError(EFsysExists, name);
- vtUnlock(sbox.lock);
- return nil;
- }
- fsys = vtMemAllocZ(sizeof(Fsys));
- fsys->lock = vtLockAlloc();
- fsys->name = vtStrDup(name);
- fsys->dev = vtStrDup(dev);
- fsys->ref = 1;
- if(sbox.tail != nil)
- sbox.tail->next = fsys;
- else
- sbox.head = fsys;
- sbox.tail = fsys;
- vtUnlock(sbox.lock);
- return fsys;
- }
- static int
- fsysClose(Fsys* fsys, int argc, char* argv[])
- {
- char *usage = "usage: [fsys name] close";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc)
- return cliError(usage);
- return cliError("close isn't working yet; halt %s and then kill fossil",
- fsys->name);
- /*
- * Oooh. This could be hard. What if fsys->ref != 1?
- * Also, fsClose() either does the job or panics, can we
- * gracefully detect it's still busy?
- *
- * More thought and care needed here.
- fsClose(fsys->fs);
- fsys->fs = nil;
- vtClose(fsys->session);
- fsys->session = nil;
- if(sbox.curfsys != nil && strcmp(fsys->name, sbox.curfsys) == 0){
- sbox.curfsys = nil;
- consPrompt(nil);
- }
- return 1;
- */
- }
- static int
- fsysVac(Fsys* fsys, int argc, char* argv[])
- {
- uchar score[VtScoreSize];
- char *usage = "usage: [fsys name] vac path";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc != 1)
- return cliError(usage);
- if(!fsVac(fsys->fs, argv[0], score))
- return 0;
- consPrint("vac:%V\n", score);
- return 1;
- }
- static int
- fsysSnap(Fsys* fsys, int argc, char* argv[])
- {
- int doarchive;
- char *usage = "usage: [fsys name] snap [-a] [-s /active] [-d /archive/yyyy/mmmm]";
- char *src, *dst;
- src = nil;
- dst = nil;
- doarchive = 0;
- ARGBEGIN{
- default:
- return cliError(usage);
- case 'a':
- doarchive = 1;
- break;
- case 'd':
- if((dst = ARGF()) == nil)
- return cliError(usage);
- break;
- case 's':
- if((src = ARGF()) == nil)
- return cliError(usage);
- break;
- }ARGEND
- if(argc)
- return cliError(usage);
- if(!fsSnapshot(fsys->fs, src, dst, doarchive))
- return 0;
- return 1;
- }
- static int
- fsysSnapClean(Fsys *fsys, int argc, char* argv[])
- {
- u32int arch, snap, life;
- char *usage = "usage: [fsys name] snapclean [maxminutes]\n";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc > 1)
- return cliError(usage);
- if(argc == 1)
- life = atoi(argv[0]);
- else
- snapGetTimes(fsys->fs->snap, &arch, &snap, &life);
- fsSnapshotCleanup(fsys->fs, life);
- return 1;
- }
- static int
- fsysSnapTime(Fsys* fsys, int argc, char* argv[])
- {
- char buf[128], *x;
- int hh, mm, changed;
- u32int arch, snap, life;
- char *usage = "usage: [fsys name] snaptime [-a hhmm] [-s snapminutes] [-t maxminutes]";
- changed = 0;
- snapGetTimes(fsys->fs->snap, &arch, &snap, &life);
- ARGBEGIN{
- case 'a':
- changed = 1;
- x = ARGF();
- if(x == nil)
- return cliError(usage);
- if(strcmp(x, "none") == 0){
- arch = ~(u32int)0;
- break;
- }
- if(strlen(x) != 4 || strspn(x, "0123456789") != 4)
- return cliError(usage);
- hh = (x[0]-'0')*10 + x[1]-'0';
- mm = (x[2]-'0')*10 + x[3]-'0';
- if(hh >= 24 || mm >= 60)
- return cliError(usage);
- arch = hh*60+mm;
- break;
- case 's':
- changed = 1;
- x = ARGF();
- if(x == nil)
- return cliError(usage);
- if(strcmp(x, "none") == 0){
- snap = ~(u32int)0;
- break;
- }
- snap = atoi(x);
- break;
- case 't':
- changed = 1;
- x = ARGF();
- if(x == nil)
- return cliError(usage);
- if(strcmp(x, "none") == 0){
- life = ~(u32int)0;
- break;
- }
- life = atoi(x);
- break;
- default:
- return cliError(usage);
- }ARGEND
- if(argc > 0)
- return cliError(usage);
- if(changed){
- snapSetTimes(fsys->fs->snap, arch, snap, life);
- return 1;
- }
- snapGetTimes(fsys->fs->snap, &arch, &snap, &life);
- if(arch != ~(u32int)0)
- sprint(buf, "-a %02d%02d", arch/60, arch%60);
- else
- sprint(buf, "-a none");
- if(snap != ~(u32int)0)
- sprint(buf+strlen(buf), " -s %d", snap);
- else
- sprint(buf+strlen(buf), " -s none");
- if(life != ~(u32int)0)
- sprint(buf+strlen(buf), " -t %ud", life);
- else
- sprint(buf+strlen(buf), " -t none");
- consPrint("\tsnaptime %s\n", buf);
- return 1;
- }
- static int
- fsysSync(Fsys* fsys, int argc, char* argv[])
- {
- char *usage = "usage: [fsys name] sync";
- int n;
-
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc > 0)
- return cliError(usage);
- n = cacheDirty(fsys->fs->cache);
- fsSync(fsys->fs);
- consPrint("\t%s sync: wrote %d blocks\n", fsys->name, n);
- return 1;
- }
- static int
- fsysHalt(Fsys *fsys, int argc, char* argv[])
- {
- char *usage = "usage: [fsys name] halt";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc > 0)
- return cliError(usage);
- fsHalt(fsys->fs);
- return 1;
- }
- static int
- fsysUnhalt(Fsys *fsys, int argc, char* argv[])
- {
- char *usage = "usage: [fsys name] unhalt";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc > 0)
- return cliError(usage);
- if(!fsys->fs->halted)
- return cliError("file system %s not halted", fsys->name);
- fsUnhalt(fsys->fs);
- return 1;
- }
- static int
- fsysRemove(Fsys* fsys, int argc, char* argv[])
- {
- File *file;
- char *usage = "usage: [fsys name] remove path ...";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc == 0)
- return cliError(usage);
- vtRLock(fsys->fs->elk);
- while(argc > 0){
- if((file = fileOpen(fsys->fs, argv[0])) == nil)
- consPrint("%s: %R\n", argv[0]);
- else{
- if(!fileRemove(file, uidadm))
- consPrint("%s: %R\n", argv[0]);
- fileDecRef(file);
- }
- argc--;
- argv++;
- }
- vtRUnlock(fsys->fs->elk);
- return 1;
- }
- static int
- fsysClri(Fsys* fsys, int argc, char* argv[])
- {
- char *usage = "usage: [fsys name] clri path ...";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc == 0)
- return cliError(usage);
- vtRLock(fsys->fs->elk);
- while(argc > 0){
- if(!fileClriPath(fsys->fs, argv[0], uidadm))
- consPrint("clri %s: %R\n", argv[0]);
- argc--;
- argv++;
- }
- vtRUnlock(fsys->fs->elk);
- return 1;
- }
- /*
- * Inspect and edit the labels for blocks on disk.
- */
- static int
- fsysLabel(Fsys* fsys, int argc, char* argv[])
- {
- Fs *fs;
- Label l;
- int n, r;
- u32int addr;
- Block *b, *bb;
- char *usage = "usage: [fsys name] label addr [type state epoch epochClose tag]";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc != 1 && argc != 6)
- return cliError(usage);
- r = 0;
- vtRLock(fsys->fs->elk);
- fs = fsys->fs;
- addr = strtoul(argv[0], 0, 0);
- b = cacheLocal(fs->cache, PartData, addr, OReadOnly);
- if(b == nil)
- goto Out0;
- l = b->l;
- consPrint("%slabel %#ux %ud %ud %ud %ud %#x\n",
- argc==6 ? "old: " : "", addr, l.type, l.state,
- l.epoch, l.epochClose, l.tag);
- if(argc == 6){
- if(strcmp(argv[1], "-") != 0)
- l.type = atoi(argv[1]);
- if(strcmp(argv[2], "-") != 0)
- l.state = atoi(argv[2]);
- if(strcmp(argv[3], "-") != 0)
- l.epoch = strtoul(argv[3], 0, 0);
- if(strcmp(argv[4], "-") != 0)
- l.epochClose = strtoul(argv[4], 0, 0);
- if(strcmp(argv[5], "-") != 0)
- l.tag = strtoul(argv[5], 0, 0);
- consPrint("new: label %#ux %ud %ud %ud %ud %#x\n",
- addr, l.type, l.state, l.epoch, l.epochClose, l.tag);
- bb = _blockSetLabel(b, &l);
- if(bb == nil)
- goto Out1;
- n = 0;
- for(;;){
- if(blockWrite(bb)){
- while(bb->iostate != BioClean){
- assert(bb->iostate == BioWriting);
- vtSleep(bb->ioready);
- }
- break;
- }
- consPrint("blockWrite: %R\n");
- if(n++ >= 5){
- consPrint("giving up\n");
- break;
- }
- sleep(5*1000);
- }
- blockPut(bb);
- }
- r = 1;
- Out1:
- blockPut(b);
- Out0:
- vtRUnlock(fs->elk);
- return r;
- }
- /*
- * Inspect and edit the blocks on disk.
- */
- static int
- fsysBlock(Fsys* fsys, int argc, char* argv[])
- {
- Fs *fs;
- char *s;
- Block *b;
- uchar *buf;
- u32int addr;
- int c, count, i, offset;
- char *usage = "usage: [fsys name] block addr offset [count [data]]";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc < 2 || argc > 4)
- return cliError(usage);
- fs = fsys->fs;
- addr = strtoul(argv[0], 0, 0);
- offset = strtoul(argv[1], 0, 0);
- if(offset < 0 || offset >= fs->blockSize){
- vtSetError("bad offset");
- return 0;
- }
- if(argc > 2)
- count = strtoul(argv[2], 0, 0);
- else
- count = 100000000;
- if(offset+count > fs->blockSize)
- count = fs->blockSize - count;
- vtRLock(fs->elk);
- b = cacheLocal(fs->cache, PartData, addr, argc==4 ? OReadWrite : OReadOnly);
- if(b == nil){
- vtSetError("cacheLocal %#ux: %R", addr);
- vtRUnlock(fs->elk);
- return 0;
- }
- consPrint("\t%sblock %#ux %ud %ud %.*H\n",
- argc==4 ? "old: " : "", addr, offset, count, count, b->data+offset);
- if(argc == 4){
- s = argv[3];
- if(strlen(s) != 2*count){
- vtSetError("bad data count");
- goto Out;
- }
- buf = vtMemAllocZ(count);
- for(i = 0; i < count*2; i++){
- if(s[i] >= '0' && s[i] <= '9')
- c = s[i] - '0';
- else if(s[i] >= 'a' && s[i] <= 'f')
- c = s[i] - 'a' + 10;
- else if(s[i] >= 'A' && s[i] <= 'F')
- c = s[i] - 'A' + 10;
- else{
- vtSetError("bad hex");
- vtMemFree(buf);
- goto Out;
- }
- if((i & 1) == 0)
- c <<= 4;
- buf[i>>1] |= c;
- }
- memmove(b->data+offset, buf, count);
- consPrint("\tnew: block %#ux %ud %ud %.*H\n",
- addr, offset, count, count, b->data+offset);
- blockDirty(b);
- }
- Out:
- blockPut(b);
- vtRUnlock(fs->elk);
- return 1;
- }
- /*
- * Free a disk block.
- */
- static int
- fsysBfree(Fsys* fsys, int argc, char* argv[])
- {
- Fs *fs;
- Label l;
- char *p;
- Block *b;
- u32int addr;
- char *usage = "usage: [fsys name] bfree addr ...";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc == 0)
- return cliError(usage);
- fs = fsys->fs;
- vtRLock(fs->elk);
- while(argc > 0){
- addr = strtoul(argv[0], &p, 0);
- if(*p != '\0'){
- consPrint("bad address - '%ud'\n", addr);
- /* syntax error; let's stop */
- vtRUnlock(fs->elk);
- return 0;
- }
- b = cacheLocal(fs->cache, PartData, addr, OReadOnly);
- if(b == nil){
- consPrint("loading %#ux: %R\n", addr);
- continue;
- }
- l = b->l;
- if(l.state == BsFree)
- consPrint("%#ux is already free\n", addr);
- else{
- consPrint("label %#ux %ud %ud %ud %ud %#x\n",
- addr, l.type, l.state, l.epoch, l.epochClose, l.tag);
- l.state = BsFree;
- l.type = BtMax;
- l.tag = 0;
- l.epoch = 0;
- l.epochClose = 0;
- if(!blockSetLabel(b, &l, 0))
- consPrint("freeing %#ux: %R\n", addr);
- }
- blockPut(b);
- argc--;
- argv++;
- }
- vtRUnlock(fs->elk);
- return 1;
- }
- static int
- fsysDf(Fsys *fsys, int argc, char* argv[])
- {
- char *usage = "usage: [fsys name] df";
- u32int used, tot, bsize;
- Fs *fs;
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc != 0)
- return cliError(usage);
- fs = fsys->fs;
- cacheCountUsed(fs->cache, fs->elo, &used, &tot, &bsize);
- consPrint("\t%s: %,llud used + %,llud free = %,llud (%llud%% used)\n",
- fsys->name, used*(vlong)bsize, (tot-used)*(vlong)bsize,
- tot*(vlong)bsize, used*100LL/tot);
- return 1;
- }
- /*
- * Zero an entry or a pointer.
- */
- static int
- fsysClrep(Fsys* fsys, int argc, char* argv[], int ch)
- {
- Fs *fs;
- Entry e;
- Block *b;
- u32int addr;
- int i, max, offset, sz;
- uchar zero[VtEntrySize];
- char *usage = "usage: [fsys name] clr%c addr offset ...";
- ARGBEGIN{
- default:
- return cliError(usage, ch);
- }ARGEND
- if(argc < 2)
- return cliError(usage, ch);
- fs = fsys->fs;
- vtRLock(fsys->fs->elk);
- addr = strtoul(argv[0], 0, 0);
- b = cacheLocal(fs->cache, PartData, addr, argc==4 ? OReadWrite : OReadOnly);
- if(b == nil){
- vtSetError("cacheLocal %#ux: %R", addr);
- Err:
- vtRUnlock(fsys->fs->elk);
- return 0;
- }
- switch(ch){
- default:
- vtSetError("clrep");
- goto Err;
- case 'e':
- if(b->l.type != BtDir){
- vtSetError("wrong block type");
- goto Err;
- }
- sz = VtEntrySize;
- memset(&e, 0, sizeof e);
- entryPack(&e, zero, 0);
- break;
- case 'p':
- if(b->l.type == BtDir || b->l.type == BtData){
- vtSetError("wrong block type");
- goto Err;
- }
- sz = VtScoreSize;
- memmove(zero, vtZeroScore, VtScoreSize);
- break;
- }
- max = fs->blockSize/sz;
- for(i = 1; i < argc; i++){
- offset = atoi(argv[i]);
- if(offset >= max){
- consPrint("\toffset %d too large (>= %d)\n", i, max);
- continue;
- }
- consPrint("\tblock %#ux %d %d %.*H\n", addr, offset*sz, sz, sz, b->data+offset*sz);
- memmove(b->data+offset*sz, zero, sz);
- }
- blockDirty(b);
- blockPut(b);
- vtRUnlock(fsys->fs->elk);
- return 1;
- }
- static int
- fsysClre(Fsys* fsys, int argc, char* argv[])
- {
- return fsysClrep(fsys, argc, argv, 'e');
- }
- static int
- fsysClrp(Fsys* fsys, int argc, char* argv[])
- {
- return fsysClrep(fsys, argc, argv, 'p');
- }
- static int
- fsysEsearch1(File* f, char* s, u32int elo)
- {
- int n, r;
- DirEntry de;
- DirEntryEnum *dee;
- File *ff;
- Entry e, ee;
- char *t;
- dee = deeOpen(f);
- if(dee == nil)
- return 0;
- n = 0;
- for(;;){
- r = deeRead(dee, &de);
- if(r < 0){
- consPrint("\tdeeRead %s/%s: %R\n", s, de.elem);
- break;
- }
- if(r == 0)
- break;
- if(de.mode & ModeSnapshot){
- if((ff = fileWalk(f, de.elem)) == nil)
- consPrint("\tcannot walk %s/%s: %R\n", s, de.elem);
- else{
- if(!fileGetSources(ff, &e, &ee))
- consPrint("\tcannot get sources for %s/%s: %R\n", s, de.elem);
- else if(e.snap != 0 && e.snap < elo){
- consPrint("\t%ud\tclri %s/%s\n", e.snap, s, de.elem);
- n++;
- }
- fileDecRef(ff);
- }
- }
- else if(de.mode & ModeDir){
- if((ff = fileWalk(f, de.elem)) == nil)
- consPrint("\tcannot walk %s/%s: %R\n", s, de.elem);
- else{
- t = smprint("%s/%s", s, de.elem);
- n += fsysEsearch1(ff, t, elo);
- vtMemFree(t);
- fileDecRef(ff);
- }
- }
- deCleanup(&de);
- if(r < 0)
- break;
- }
- deeClose(dee);
- return n;
- }
- static int
- fsysEsearch(Fs* fs, char* path, u32int elo)
- {
- int n;
- File *f;
- DirEntry de;
- f = fileOpen(fs, path);
- if(f == nil)
- return 0;
- if(!fileGetDir(f, &de)){
- consPrint("\tfileGetDir %s failed: %R\n", path);
- fileDecRef(f);
- return 0;
- }
- if((de.mode & ModeDir) == 0){
- fileDecRef(f);
- deCleanup(&de);
- return 0;
- }
- deCleanup(&de);
- n = fsysEsearch1(f, path, elo);
- fileDecRef(f);
- return n;
- }
- static int
- fsysEpoch(Fsys* fsys, int argc, char* argv[])
- {
- Fs *fs;
- int force, n, remove;
- u32int low, old;
- char *usage = "usage: [fsys name] epoch [[-ry] low]";
- force = 0;
- remove = 0;
- ARGBEGIN{
- case 'y':
- force = 1;
- break;
- case 'r':
- remove = 1;
- break;
- default:
- return cliError(usage);
- }ARGEND
- if(argc > 1)
- return cliError(usage);
- if(argc > 0)
- low = strtoul(argv[0], 0, 0);
- else
- low = ~(u32int)0;
- if(low == 0)
- return cliError("low epoch cannot be zero");
- fs = fsys->fs;
- vtRLock(fs->elk);
- consPrint("\tlow %ud hi %ud\n", fs->elo, fs->ehi);
- if(low == ~(u32int)0){
- vtRUnlock(fs->elk);
- return 1;
- }
- n = fsysEsearch(fsys->fs, "/archive", low);
- n += fsysEsearch(fsys->fs, "/snapshot", low);
- consPrint("\t%d snapshot%s found with epoch < %ud\n", n, n==1 ? "" : "s", low);
- vtRUnlock(fs->elk);
- /*
- * There's a small race here -- a new snapshot with epoch < low might
- * get introduced now that we unlocked fs->elk. Low has to
- * be <= fs->ehi. Of course, in order for this to happen low has
- * to be equal to the current fs->ehi _and_ a snapshot has to
- * run right now. This is a small enough window that I don't care.
- */
- if(n != 0 && !force){
- consPrint("\tnot setting low epoch\n");
- return 1;
- }
- old = fs->elo;
- if(!fsEpochLow(fs, low))
- consPrint("\tfsEpochLow: %R\n");
- else{
- consPrint("\told: epoch%s %ud\n", force ? " -y" : "", old);
- consPrint("\tnew: epoch%s %ud\n", force ? " -y" : "", fs->elo);
- if(fs->elo < low)
- consPrint("\twarning: new low epoch < old low epoch\n");
- if(force && remove)
- fsSnapshotRemove(fs);
- }
- return 1;
- }
- static int
- fsysCreate(Fsys* fsys, int argc, char* argv[])
- {
- int r;
- ulong mode;
- char *elem, *p, *path;
- char *usage = "usage: [fsys name] create path uid gid perm";
- DirEntry de;
- File *file, *parent;
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc != 4)
- return cliError(usage);
- if(!fsysParseMode(argv[3], &mode))
- return cliError(usage);
- if(mode&ModeSnapshot)
- return cliError("create - cannot create with snapshot bit set");
- if(strcmp(argv[1], uidnoworld) == 0)
- return cliError("permission denied");
- vtRLock(fsys->fs->elk);
- path = vtStrDup(argv[0]);
- if((p = strrchr(path, '/')) != nil){
- *p++ = '\0';
- elem = p;
- p = path;
- if(*p == '\0')
- p = "/";
- }
- else{
- p = "/";
- elem = path;
- }
- r = 0;
- if((parent = fileOpen(fsys->fs, p)) == nil)
- goto out;
- file = fileCreate(parent, elem, mode, argv[1]);
- fileDecRef(parent);
- if(file == nil){
- vtSetError("create %s/%s: %R", p, elem);
- goto out;
- }
- if(!fileGetDir(file, &de)){
- vtSetError("stat failed after create: %R");
- goto out1;
- }
- if(strcmp(de.gid, argv[2]) != 0){
- vtMemFree(de.gid);
- de.gid = vtStrDup(argv[2]);
- if(!fileSetDir(file, &de, argv[1])){
- vtSetError("wstat failed after create: %R");
- goto out2;
- }
- }
- r = 1;
- out2:
- deCleanup(&de);
- out1:
- fileDecRef(file);
- out:
- vtMemFree(path);
- vtRUnlock(fsys->fs->elk);
- return r;
- }
- static void
- fsysPrintStat(char *prefix, char *file, DirEntry *de)
- {
- char buf[64];
- if(prefix == nil)
- prefix = "";
- consPrint("%sstat %q %q %q %q %s %llud\n", prefix,
- file, de->elem, de->uid, de->gid, fsysModeString(de->mode, buf), de->size);
- }
- static int
- fsysStat(Fsys* fsys, int argc, char* argv[])
- {
- int i;
- File *f;
- DirEntry de;
- char *usage = "usage: [fsys name] stat files...";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc == 0)
- return cliError(usage);
- vtRLock(fsys->fs->elk);
- for(i=0; i<argc; i++){
- if((f = fileOpen(fsys->fs, argv[i])) == nil){
- consPrint("%s: %R\n", argv[i]);
- continue;
- }
- if(!fileGetDir(f, &de)){
- consPrint("%s: %R\n", argv[i]);
- fileDecRef(f);
- continue;
- }
- fsysPrintStat("\t", argv[i], &de);
- deCleanup(&de);
- fileDecRef(f);
- }
- vtRUnlock(fsys->fs->elk);
- return 1;
- }
- static int
- fsysWstat(Fsys *fsys, int argc, char* argv[])
- {
- File *f;
- char *p;
- DirEntry de;
- char *usage = "usage: [fsys name] wstat file elem uid gid mode length\n"
- "\tuse - for any field to mean don't change";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc != 6)
- return cliError(usage);
- vtRLock(fsys->fs->elk);
- if((f = fileOpen(fsys->fs, argv[0])) == nil){
- vtSetError("console wstat - walk - %R");
- vtRUnlock(fsys->fs->elk);
- return 0;
- }
- if(!fileGetDir(f, &de)){
- vtSetError("console wstat - stat - %R");
- fileDecRef(f);
- vtRUnlock(fsys->fs->elk);
- return 0;
- }
- fsysPrintStat("\told: w", argv[0], &de);
- if(strcmp(argv[1], "-") != 0){
- if(!validFileName(argv[1])){
- vtSetError("console wstat - bad elem");
- goto error;
- }
- vtMemFree(de.elem);
- de.elem = vtStrDup(argv[1]);
- }
- if(strcmp(argv[2], "-") != 0){
- if(!validUserName(argv[2])){
- vtSetError("console wstat - bad uid");
- goto error;
- }
- vtMemFree(de.uid);
- de.uid = vtStrDup(argv[2]);
- }
- if(strcmp(argv[3], "-") != 0){
- if(!validUserName(argv[3])){
- vtSetError("console wstat - bad gid");
- goto error;
- }
- vtMemFree(de.gid);
- de.gid = vtStrDup(argv[3]);
- }
- if(strcmp(argv[4], "-") != 0){
- if(!fsysParseMode(argv[4], &de.mode)){
- vtSetError("console wstat - bad mode");
- goto error;
- }
- }
- if(strcmp(argv[5], "-") != 0){
- de.size = strtoull(argv[5], &p, 0);
- if(argv[5][0] == '\0' || *p != '\0' || (vlong)de.size < 0){
- vtSetError("console wstat - bad length");
- goto error;
- }
- }
- if(!fileSetDir(f, &de, uidadm)){
- vtSetError("console wstat - %R");
- goto error;
- }
- deCleanup(&de);
- if(!fileGetDir(f, &de)){
- vtSetError("console wstat - stat2 - %R");
- goto error;
- }
- fsysPrintStat("\tnew: w", argv[0], &de);
- deCleanup(&de);
- fileDecRef(f);
- vtRUnlock(fsys->fs->elk);
- return 1;
- error:
- deCleanup(&de); /* okay to do this twice */
- fileDecRef(f);
- vtRUnlock(fsys->fs->elk);
- return 0;
- }
- static void
- fsckClri(Fsck *fsck, char *name, MetaBlock *mb, int i, Block *b)
- {
- USED(name);
- if((fsck->flags&DoClri) == 0)
- return;
- mbDelete(mb, i);
- mbPack(mb);
- blockDirty(b);
- }
- static void
- fsckClose(Fsck *fsck, Block *b, u32int epoch)
- {
- Label l;
- if((fsck->flags&DoClose) == 0)
- return;
- l = b->l;
- if(l.state == BsFree || (l.state&BsClosed)){
- consPrint("%#ux is already closed\n", b->addr);
- return;
- }
- if(epoch){
- l.state |= BsClosed;
- l.epochClose = epoch;
- }else
- l.state = BsFree;
-
- if(!blockSetLabel(b, &l, 0))
- consPrint("%#ux setlabel: %R\n", b->addr);
- }
- static void
- fsckClre(Fsck *fsck, Block *b, int offset)
- {
- Entry e;
- if((fsck->flags&DoClre) == 0)
- return;
- if(offset<0 || offset*VtEntrySize >= fsck->bsize){
- consPrint("bad clre\n");
- return;
- }
- memset(&e, 0, sizeof e);
- entryPack(&e, b->data, offset);
- blockDirty(b);
- }
- static void
- fsckClrp(Fsck *fsck, Block *b, int offset)
- {
- if((fsck->flags&DoClrp) == 0)
- return;
- if(offset<0 || offset*VtScoreSize >= fsck->bsize){
- consPrint("bad clre\n");
- return;
- }
- memmove(b->data+offset*VtScoreSize, vtZeroScore, VtScoreSize);
- blockDirty(b);
- }
- static int
- fsysCheck(Fsys *fsys, int argc, char *argv[])
- {
- int i, halting;
- char *usage = "usage: [fsys name] check [-v] [options]";
- Fsck fsck;
- Block *b;
- Super super;
- memset(&fsck, 0, sizeof fsck);
- fsck.fs = fsys->fs;
- fsck.clri = fsckClri;
- fsck.clre = fsckClre;
- fsck.clrp = fsckClrp;
- fsck.close = fsckClose;
- fsck.print = consPrint;
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- for(i=0; i<argc; i++){
- if(strcmp(argv[i], "pblock") == 0)
- fsck.printblocks = 1;
- else if(strcmp(argv[i], "pdir") == 0)
- fsck.printdirs = 1;
- else if(strcmp(argv[i], "pfile") == 0)
- fsck.printfiles = 1;
- else if(strcmp(argv[i], "bclose") == 0)
- fsck.flags |= DoClose;
- else if(strcmp(argv[i], "clri") == 0)
- fsck.flags |= DoClri;
- else if(strcmp(argv[i], "clre") == 0)
- fsck.flags |= DoClre;
- else if(strcmp(argv[i], "clrp") == 0)
- fsck.flags |= DoClrp;
- else if(strcmp(argv[i], "fix") == 0)
- fsck.flags |= DoClose|DoClri|DoClre|DoClrp;
- else if(strcmp(argv[i], "venti") == 0)
- fsck.useventi = 1;
- else if(strcmp(argv[i], "snapshot") == 0)
- fsck.walksnapshots = 1;
- else{
- consPrint("unknown option '%s'\n", argv[i]);
- return cliError(usage);
- }
- }
- halting = fsys->fs->halted==0;
- if(halting)
- fsHalt(fsys->fs);
- if(fsys->fs->arch){
- b = superGet(fsys->fs->cache, &super);
- if(b == nil){
- consPrint("could not load super block\n");
- goto Out;
- }
- blockPut(b);
- if(super.current != NilBlock){
- consPrint("cannot check fs while archiver is running; "
- "wait for it to finish\n");
- goto Out;
- }
- }
- fsCheck(&fsck);
- consPrint("fsck: %d clri, %d clre, %d clrp, %d bclose\n",
- fsck.nclri, fsck.nclre, fsck.nclrp, fsck.nclose);
- Out:
- if(halting)
- fsUnhalt(fsys->fs);
- return 1;
- }
- static int
- fsysVenti(char* name, int argc, char* argv[])
- {
- int r;
- char *host;
- char *usage = "usage: [fsys name] venti [address]";
- Fsys *fsys;
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc == 0)
- host = nil;
- else if(argc == 1)
- host = argv[0];
- else
- return cliError(usage);
- if((fsys = _fsysGet(name)) == nil)
- return 0;
- vtLock(fsys->lock);
- if(host == nil)
- host = fsys->venti;
- else{
- vtMemFree(fsys->venti);
- if(host[0])
- fsys->venti = vtStrDup(host);
- else{
- host = nil;
- fsys->venti = nil;
- }
- }
- /* already open: do a redial */
- if(fsys->fs != nil){
- if(fsys->session == nil){
- vtSetError("file system was opened with -V");
- r = 0;
- goto out;
- }
- r = 1;
- if(!vtRedial(fsys->session, host)
- || !vtConnect(fsys->session, 0))
- r = 0;
- goto out;
- }
- /* not yet open: try to dial */
- if(fsys->session)
- vtClose(fsys->session);
- r = 1;
- if((fsys->session = vtDial(host, 0)) == nil
- || !vtConnect(fsys->session, 0))
- r = 0;
- out:
- vtUnlock(fsys->lock);
- fsysPut(fsys);
- return r;
- }
- static int
- fsysOpen(char* name, int argc, char* argv[])
- {
- char *p, *host;
- Fsys *fsys;
- long ncache;
- int noauth, noventi, noperm, rflag, wstatallow;
- char *usage = "usage: fsys name open [-APVWr] [-c ncache]";
- ncache = 1000;
- noauth = noperm = wstatallow = noventi = 0;
- rflag = OReadWrite;
- ARGBEGIN{
- default:
- return cliError(usage);
- case 'A':
- noauth = 1;
- break;
- case 'P':
- noperm = 1;
- break;
- case 'V':
- noventi = 1;
- break;
- case 'W':
- wstatallow = 1;
- break;
- case 'c':
- p = ARGF();
- if(p == nil)
- return cliError(usage);
- ncache = strtol(argv[0], &p, 0);
- if(ncache <= 0 || p == argv[0] || *p != '\0')
- return cliError(usage);
- break;
- case 'r':
- rflag = OReadOnly;
- break;
- }ARGEND
- if(argc)
- return cliError(usage);
- if((fsys = _fsysGet(name)) == nil)
- return 0;
- vtLock(fsys->lock);
- if(fsys->fs != nil){
- vtSetError(EFsysBusy, fsys->name);
- vtUnlock(fsys->lock);
- fsysPut(fsys);
- return 0;
- }
- if(noventi){
- if(fsys->session){
- vtClose(fsys->session);
- fsys->session = nil;
- }
- }
- else if(fsys->session == nil){
- if(fsys->venti && fsys->venti[0])
- host = fsys->venti;
- else
- host = nil;
- fsys->session = vtDial(host, 1);
- if(!vtConnect(fsys->session, nil) && !noventi)
- fprint(2, "warning: connecting to venti: %R\n");
- }
- if((fsys->fs = fsOpen(fsys->dev, fsys->session, ncache, rflag)) == nil){
- vtSetError("fsOpen: %R");
- vtUnlock(fsys->lock);
- fsysPut(fsys);
- return 0;
- }
- fsys->fs->name = fsys->name; /* for better error messages */
- fsys->noauth = noauth;
- fsys->noperm = noperm;
- fsys->wstatallow = wstatallow;
- vtUnlock(fsys->lock);
- fsysPut(fsys);
- if(strcmp(name, "main") == 0)
- usersFileRead(nil);
- return 1;
- }
- static int
- fsysUnconfig(char* name, int argc, char* argv[])
- {
- Fsys *fsys, **fp;
- char *usage = "usage: fsys name unconfig";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc)
- return cliError(usage);
- vtLock(sbox.lock);
- fp = &sbox.head;
- for(fsys = *fp; fsys != nil; fsys = fsys->next){
- if(strcmp(fsys->name, name) == 0)
- break;
- fp = &fsys->next;
- }
- if(fsys == nil){
- vtSetError(EFsysNotFound, name);
- vtUnlock(sbox.lock);
- return 0;
- }
- if(fsys->ref != 0 || fsys->fs != nil){
- vtSetError(EFsysBusy, fsys->name);
- vtUnlock(sbox.lock);
- return 0;
- }
- *fp = fsys->next;
- vtUnlock(sbox.lock);
- if(fsys->session != nil){
- vtClose(fsys->session);
- vtFree(fsys->session);
- }
- if(fsys->venti != nil)
- vtMemFree(fsys->venti);
- if(fsys->dev != nil)
- vtMemFree(fsys->dev);
- if(fsys->name != nil)
- vtMemFree(fsys->name);
- vtMemFree(fsys);
- return 1;
- }
- static int
- fsysConfig(char* name, int argc, char* argv[])
- {
- Fsys *fsys;
- char *usage = "usage: fsys name config dev";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc != 1)
- return cliError(usage);
- if((fsys = _fsysGet(argv[0])) != nil){
- vtLock(fsys->lock);
- if(fsys->fs != nil){
- vtSetError(EFsysBusy, fsys->name);
- vtUnlock(fsys->lock);
- fsysPut(fsys);
- return 0;
- }
- vtMemFree(fsys->dev);
- fsys->dev = vtStrDup(argv[0]);
- vtUnlock(fsys->lock);
- }
- else if((fsys = fsysAlloc(name, argv[0])) == nil)
- return 0;
- fsysPut(fsys);
- return 1;
- }
- static struct {
- char* cmd;
- int (*f)(Fsys*, int, char**);
- int (*f1)(char*, int, char**);
- } fsyscmd[] = {
- { "close", fsysClose, },
- { "config", nil, fsysConfig, },
- { "open", nil, fsysOpen, },
- { "unconfig", nil, fsysUnconfig, },
- { "venti", nil, fsysVenti, },
- { "bfree", fsysBfree, },
- { "block", fsysBlock, },
- { "check", fsysCheck, },
- { "clre", fsysClre, },
- { "clri", fsysClri, },
- { "clrp", fsysClrp, },
- { "create", fsysCreate, },
- { "df", fsysDf, },
- { "epoch", fsysEpoch, },
- { "halt", fsysHalt, },
- { "label", fsysLabel, },
- { "remove", fsysRemove, },
- { "snap", fsysSnap, },
- { "snaptime", fsysSnapTime, },
- { "snapclean", fsysSnapClean, },
- { "stat", fsysStat, },
- { "sync", fsysSync, },
- { "unhalt", fsysUnhalt, },
- { "wstat", fsysWstat, },
- { "vac", fsysVac, },
- { nil, nil, },
- };
- static int
- fsysXXX1(Fsys *fsys, int i, int argc, char* argv[])
- {
- int r;
- vtLock(fsys->lock);
- if(fsys->fs == nil){
- vtUnlock(fsys->lock);
- vtSetError(EFsysNotOpen, fsys->name);
- return 0;
- }
- if(fsys->fs->halted
- && fsyscmd[i].f != fsysUnhalt && fsyscmd[i].f != fsysCheck){
- vtSetError("file system %s is halted", fsys->name);
- vtUnlock(fsys->lock);
- return 0;
- }
- r = (*fsyscmd[i].f)(fsys, argc, argv);
- vtUnlock(fsys->lock);
- return r;
- }
- static int
- fsysXXX(char* name, int argc, char* argv[])
- {
- int i, r;
- Fsys *fsys;
- for(i = 0; fsyscmd[i].cmd != nil; i++){
- if(strcmp(fsyscmd[i].cmd, argv[0]) == 0)
- break;
- }
- if(fsyscmd[i].cmd == nil){
- vtSetError("unknown command - '%s'", argv[0]);
- return 0;
- }
- /* some commands want the name... */
- if(fsyscmd[i].f1 != nil){
- if(strcmp(name, FsysAll) == 0){
- vtSetError("cannot use fsys %#q with %#q command", FsysAll, argv[0]);
- return 0;
- }
- return (*fsyscmd[i].f1)(name, argc, argv);
- }
- /* ... but most commands want the Fsys */
- if(strcmp(name, FsysAll) == 0){
- r = 1;
- vtRLock(sbox.lock);
- for(fsys = sbox.head; fsys != nil; fsys = fsys->next){
- fsys->ref++;
- r = fsysXXX1(fsys, i, argc, argv) && r;
- fsys->ref--;
- }
- vtRUnlock(sbox.lock);
- }else{
- if((fsys = _fsysGet(name)) == nil)
- return 0;
- r = fsysXXX1(fsys, i, argc, argv);
- fsysPut(fsys);
- }
- return r;
- }
- static int
- cmdFsysXXX(int argc, char* argv[])
- {
- char *name;
- if((name = sbox.curfsys) == nil){
- vtSetError(EFsysNoCurrent, argv[0]);
- return 0;
- }
- return fsysXXX(name, argc, argv);
- }
- static int
- cmdFsys(int argc, char* argv[])
- {
- Fsys *fsys;
- char *usage = "usage: fsys [name ...]";
- ARGBEGIN{
- default:
- return cliError(usage);
- }ARGEND
- if(argc == 0){
- vtRLock(sbox.lock);
- for(fsys = sbox.head; fsys != nil; fsys = fsys->next)
- consPrint("\t%s\n", fsys->name);
- vtRUnlock(sbox.lock);
- return 1;
- }
- if(argc == 1){
- fsys = nil;
- if(strcmp(argv[0], FsysAll) != 0 && (fsys = fsysGet(argv[0])) == nil)
- return 0;
- sbox.curfsys = vtStrDup(argv[0]);
- consPrompt(sbox.curfsys);
- if(fsys)
- fsysPut(fsys);
- return 1;
- }
- return fsysXXX(argv[0], argc-1, argv+1);
- }
- int
- fsysInit(void)
- {
- int i;
- fmtinstall('H', encodefmt);
- fmtinstall('V', scoreFmt);
- fmtinstall('R', vtErrFmt);
- fmtinstall('L', labelFmt);
- sbox.lock = vtLockAlloc();
- cliAddCmd("fsys", cmdFsys);
- for(i = 0; fsyscmd[i].cmd != nil; i++){
- if(fsyscmd[i].f != nil)
- cliAddCmd(fsyscmd[i].cmd, cmdFsysXXX);
- }
- /* the venti cmd is special: the fs can be either open or closed */
- cliAddCmd("venti", cmdFsysXXX);
- cliAddCmd("printconfig", cmdPrintConfig);
- return 1;
- }
|