commit 7643b2635cb8f0688144ecf8e5b57b605258b6a7 from: rsc date: Wed Jul 13 10:52:39 2005 UTC cleanup commit - d7b202dfbd0935c012e1b6b712614a8afcea5cc7 commit + 7643b2635cb8f0688144ecf8e5b57b605258b6a7 blob - e8241aa2ac19a0b1272f758c1c7bba97ed7eafe0 blob + 09ca5ea837a5c53c46b3f04133163c1f7f045b2d --- src/libventi/cache.c +++ src/libventi/cache.c @@ -429,7 +429,6 @@ vtcacheglobal(VtCache *c, uchar score[VtScoreSize], in vtzeroextend(type, b->data, n, c->blocksize); b->iostate = BioVenti; b->nlock = 1; - b->decrypted = 0; return b; } blob - ddee7cc090b62046755c50000e7f8e8de4202a6f blob + bb102c9ffea43b4c09b9b6843b664881b5590fd1 --- src/libventi/client.c +++ src/libventi/client.c @@ -22,16 +22,16 @@ vtfcallrpc(VtConn *z, VtFcall *ou, VtFcall *in) } if(chattyventi) fprint(2, "%s <- %F\n", argv0, in); - if(in->type == VtRerror){ + if(in->msgtype == VtRerror){ werrstr(in->error); vtfcallclear(in); packetfree(p); return -1; } - if(in->type != ou->type+1){ + if(in->msgtype != ou->msgtype+1){ werrstr("type mismatch: sent %c%d got %c%d", - "TR"[ou->type&1], ou->type>>1, - "TR"[in->type&1], in->type>>1); + "TR"[ou->msgtype&1], ou->msgtype>>1, + "TR"[in->msgtype&1], in->msgtype>>1); vtfcallclear(in); packetfree(p); return -1; @@ -46,7 +46,7 @@ vthello(VtConn *z) VtFcall tx, rx; memset(&tx, 0, sizeof tx); - tx.type = VtThello; + tx.msgtype = VtThello; tx.version = z->version; tx.uid = z->uid; if(tx.uid == nil) @@ -68,8 +68,8 @@ vtreadpacket(VtConn *z, uchar score[VtScoreSize], uint return packetalloc(); memset(&tx, 0, sizeof tx); - tx.type = VtTread; - tx.dtype = type; + tx.msgtype = VtTread; + tx.blocktype = type; tx.count = n; memmove(tx.score, score, VtScoreSize); if(vtfcallrpc(z, &tx, &rx) < 0) @@ -114,8 +114,8 @@ vtwritepacket(VtConn *z, uchar score[VtScoreSize], uin memmove(score, vtzeroscore, VtScoreSize); return 0; } - tx.type = VtTwrite; - tx.dtype = type; + tx.msgtype = VtTwrite; + tx.blocktype = type; tx.data = p; if(ventidoublechecksha1) packetsha1(p, score); @@ -148,7 +148,7 @@ vtsync(VtConn *z) { VtFcall tx, rx; - tx.type = VtTsync; + tx.msgtype = VtTsync; return vtfcallrpc(z, &tx, &rx); } @@ -157,7 +157,7 @@ vtping(VtConn *z) { VtFcall tx, rx; - tx.type = VtTping; + tx.msgtype = VtTping; return vtfcallrpc(z, &tx, &rx); } blob - 9e2fefa45c1eac61e718c8921e2ceead4aa87773 blob + 9f721b426367cb35acb5ccd703361c9dbfd1a338 --- src/libventi/fcall.c +++ src/libventi/fcall.c @@ -10,13 +10,13 @@ vtfcallpack(VtFcall *f) p = packetalloc(); - buf[0] = f->type; + buf[0] = f->msgtype; buf[1] = f->tag; packetappend(p, buf, 2); - switch(f->type){ + switch(f->msgtype){ default: - werrstr("vtfcallpack: unknown packet type %d", f->type); + werrstr("vtfcallpack: unknown packet type %d", f->msgtype); goto Err; case VtRerror: @@ -56,7 +56,7 @@ vtfcallpack(VtFcall *f) case VtTread: packetappend(p, f->score, VtScoreSize); - buf[0] = vttodisktype(f->dtype); + buf[0] = vttodisktype(f->blocktype); if(~buf[0] == 0) goto Err; buf[1] = 0; @@ -70,7 +70,7 @@ vtfcallpack(VtFcall *f) break; case VtTwrite: - buf[0] = vttodisktype(f->dtype); + buf[0] = vttodisktype(f->blocktype); if(~buf[0] == 0) goto Err; buf[1] = 0; @@ -108,12 +108,12 @@ vtfcallunpack(VtFcall *f, Packet *p) if(packetconsume(p, buf, 2) < 0) return -1; - f->type = buf[0]; + f->msgtype = buf[0]; f->tag = buf[1]; - switch(f->type){ + switch(f->msgtype){ default: - werrstr("vtfcallunpack: unknown bad packet type %d", f->type); + werrstr("vtfcallunpack: unknown bad packet type %d", f->msgtype); vtfcallclear(f); return -1; @@ -165,8 +165,8 @@ vtfcallunpack(VtFcall *f, Packet *p) if(packetconsume(p, f->score, VtScoreSize) < 0 || packetconsume(p, buf, 4) < 0) goto Err; - f->dtype = vtfromdisktype(buf[0]); - if(~f->dtype == 0) + f->blocktype = vtfromdisktype(buf[0]); + if(~f->blocktype == 0) goto Err; f->count = (buf[2] << 8) | buf[3]; break; @@ -179,8 +179,8 @@ vtfcallunpack(VtFcall *f, Packet *p) case VtTwrite: if(packetconsume(p, buf, 4) < 0) goto Err; - f->dtype = vtfromdisktype(buf[0]); - if(~f->dtype == 0) + f->blocktype = vtfromdisktype(buf[0]); + if(~f->blocktype == 0) goto Err; f->data = packetalloc(); packetconcat(f->data, p); blob - 23e13efff830d6089618be5ff78d58aa6a48d602 blob + 9b493f9aa9bcb0900ce7c6cb85bd431281242954 --- src/libventi/fcallfmt.c +++ src/libventi/fcallfmt.c @@ -12,9 +12,9 @@ vtfcallfmt(Fmt *f) fmtprint(f, ""); return 0; } - switch(t->type){ + switch(t->msgtype){ default: - return fmtprint(f, "%c%d tag %ud", "TR"[t->type&1], t->type>>1, t->tag); + return fmtprint(f, "%c%d tag %ud", "TR"[t->msgtype&1], t->msgtype>>1, t->tag); case VtRerror: return fmtprint(f, "Rerror tag %ud error %s", t->tag, t->error); case VtTping: @@ -40,11 +40,11 @@ vtfcallfmt(Fmt *f) case VtRauth1: return fmtprint(f, "Rauth1 tag %ud auth %.*H", t->tag, t->nauth, t->auth); case VtTread: - return fmtprint(f, "Tread tag %ud score %V dtype %d count %d", t->tag, t->score, t->dtype, t->count); + return fmtprint(f, "Tread tag %ud score %V blocktype %d count %d", t->tag, t->score, t->blocktype, t->count); case VtRread: return fmtprint(f, "Rread tag %ud count %d", t->tag, packetsize(t->data)); case VtTwrite: - return fmtprint(f, "Twrite tag %ud dtype %d count %d", t->tag, t->dtype, packetsize(t->data)); + return fmtprint(f, "Twrite tag %ud blocktype %d count %d", t->tag, t->blocktype, packetsize(t->data)); case VtRwrite: return fmtprint(f, "Rwrite tag %ud score %V", t->tag, t->score); case VtTsync: blob - ddaa97f81732afff7e0fda22aa960ff42d48c26f blob + 1fb3c14bcbf6ba822354d0d6febdfeff7ea06b1b --- src/libventi/server.c +++ src/libventi/server.c @@ -151,7 +151,7 @@ if(first && chattyventi){ if(chattyventi) fprint(2, "%s <- %F\n", argv0, &r->tx); packetfree(p); - if(r->tx.type == VtTgoodbye) + if(r->tx.msgtype == VtTgoodbye) break; r->rx.tag = r->tx.tag; r->sc = sc; @@ -195,7 +195,7 @@ vtrespond(VtReq *r) sc = r->sc; if(r->rx.tag != r->tx.tag) abort(); - if(r->rx.type != r->tx.type+1 && r->rx.type != VtRerror) + if(r->rx.msgtype != r->tx.msgtype+1 && r->rx.msgtype != VtRerror) abort(); if(chattyventi) fprint(2, "%s -> %F\n", argv0, &r->rx); blob - 0af5a32d9b2c8ec8f82b1178cbb2d9151dcaab74 blob + ca34221e6864df5e1491e55129898280c320d554 --- src/libventi/srvhello.c +++ src/libventi/srvhello.c @@ -17,9 +17,9 @@ vtsrvhello(VtConn *z) } packetfree(p); - if(tx.type != VtThello){ + if(tx.msgtype != VtThello){ vtfcallclear(&tx); - werrstr("bad packet type %d; want Thello %d", tx.type, VtThello); + werrstr("bad packet type %d; want Thello %d", tx.msgtype, VtThello); return -1; } if(tx.tag != 0){ @@ -38,7 +38,7 @@ vtsrvhello(VtConn *z) vtfcallclear(&tx); memset(&rx, 0, sizeof rx); - rx.type = VtRhello; + rx.msgtype = VtRhello; rx.tag = tx.tag; rx.sid = "anonymous"; if((p = vtfcallpack(&rx)) == nil)