ref: b502a62da2ec6058923db94f87ecc2d29db2fa77
dir: /liblogfs/log.c/
#include "logfsos.h"
#include "logfs.h"
#include "local.h"
#include "fcall.h"
void
logfsflashaddr2spo(LogfsServer *server, u32 flashaddr, long *seq, int *page, int *offset)
{
LogfsLowLevel *ll = server->ll;
flashaddr &= ~LogAddr;
*offset = flashaddr & ((1 << ll->l2pagesize) - 1);
flashaddr >>= ll->l2pagesize;
*page = flashaddr & ((1 << ll->l2pagesperblock) - 1);
flashaddr >>= ll->l2pagesperblock;
*seq = flashaddr;
}
u32
logfsspo2flashaddr(LogfsServer *server, long seq, int page, int offset)
{
//print("logfsspo2flashaddr(%ld, %d, %d)\n", seq, page, offset);
return (((seq << server->ll->l2pagesperblock) + page) << server->ll->l2pagesize) + offset;
}
void
logfsflashaddr2o(LogfsServer *server, u32 flashaddr, int *offset)
{
LogfsLowLevel *ll = server->ll;
flashaddr &= ~LogAddr;
*offset = flashaddr & ((1 << ll->l2pagesize) - 1);
}
char *
logfslogsegmentnew(LogfsServer *server, int gen, LogSegment **segp)
{
LogSegment *seg;
seg = logfsrealloc(nil, sizeof(LogSegment) + (server->ll->blocks - 1) * sizeof(long));
if(seg == nil)
return Enomem;
seg->pagebuf = logfsrealloc(nil, 1 << server->ll->l2pagesize);
if(seg->pagebuf == nil) {
logfsfreemem(seg);
return Enomem;
}
seg->curpage = -1;
seg->curblockindex = -1;
seg->gen = gen;
*segp = seg;
return nil;
}
void
logfslogsegmentfree(LogSegment **segp)
{
LogSegment *seg = *segp;
if(seg) {
logfsfreemem(seg->pagebuf);
logfsfreemem(seg);
*segp = nil;
}
}
char *
logfslogsegmentflush(LogfsServer *server, int active)
{
LogSegment *seg;
seg = active ? server->activelog : server->sweptlog;
if(seg == nil)
return nil;
if(seg->curpage >= 0 && seg->nbytes) {
char *errmsg;
LogfsLowLevel *ll = server->ll;
int pagesize = 1 << ll->l2pagesize;
//print("curblockindex %ld curpage %d nbytes %d\n", seg->curblockindex, seg->curpage, seg->nbytes);
if(seg->nbytes < pagesize)
seg->pagebuf[seg->nbytes++] = LogfsLogTend;
memset(seg->pagebuf + seg->nbytes, 0xff, pagesize - seg->nbytes);
for(;;) {
errmsg = (*ll->writepage)(ll, seg->pagebuf,
seg->blockmap[seg->curblockindex], seg->curpage);
if(errmsg == nil)
break;
if(strcmp(errmsg, Eio) != 0)
return errmsg;
errmsg = logfsserverreplacelogblock(server, seg, seg->curblockindex);
if(errmsg)
return errmsg;
}
seg->curpage++;
if(seg->curpage == (1 << ll->l2pagesperblock))
seg->curpage = -1;
seg->nbytes = 0;
}
return nil;
}
static char *
logspace(LogfsServer *server, int active, int takearisk, int nbytes, uchar **where, u32 *flashaddr)
{
char *errmsg;
LogfsLowLevel *ll = server->ll;
int pagesize = 1 << ll->l2pagesize;
LogSegment *seg;
if(nbytes > pagesize)
return logfselogmsgtoobig;
retry:
seg = active ? server->activelog : server->sweptlog;
for(;;) {
//print("curpage %d nbytes %d\n", seg->curpage, seg->nbytes);
if(seg->curpage >= 0) {
if(seg->nbytes + nbytes < pagesize)
break;
errmsg = logfslogsegmentflush(server, active);
if(errmsg)
return errmsg;
}
if(seg->curpage < 0) {
long block;
long path;
block = logfsfindfreeblock(ll,
active ? (takearisk ? AllocReasonLogExtend : AllocReasonDataExtend) : AllocReasonTransfer);
if(block < 0) {
if(active) {
int didsomething;
errmsg = logfsserverlogsweep(server, 0, &didsomething);
if(errmsg)
return errmsg;
if(didsomething)
goto retry;
}
return logfselogfull;
}
seg->blockmap[++seg->curblockindex] = block;
path = mklogpath(seg->curblockindex, seg->gen, 0);
(*ll->setblocktag)(ll, block, LogfsTlog);
(*ll->setblockpath)(ll, block, path);
seg->curpage = 0;
#ifdef FUTURE
/* TODO - do we need one of these if the underlying system supports erase counting? */
seg->pagebuf[0] = LogfsLogTstart;
PBIT16(seg->pagebuf + 1, 8);
PBIT32(seg->pagebuf + 3, path); /* TODO duplicate information */
PBIT32(seg->pagebuf + 7, 0); /* TODO don't have this - discuss with forsyth */
seg->nbytes = 11;
#else
seg->nbytes = 0;
#endif
}
}
*where = seg->pagebuf + seg->nbytes;
if(flashaddr)
*flashaddr = logfsspo2flashaddr(server, seg->curblockindex, seg->curpage, seg->nbytes);
seg->nbytes += nbytes;
return nil;
}
static void
logdirty(LogfsServer *server, int active)
{
if(active)
server->activelog->dirty = 1;
else
server->sweptlog->dirty = 1;
}
char *
logfslogbytes(LogfsServer *server, int active, uchar *msg, uint size)
{
char *errmsg;
uchar *p;
errmsg = logspace(server, active, 0, size, &p, nil);
if(errmsg)
return errmsg;
memmove(p, msg, size);
logdirty(server, active);
return nil;
}
char *
logfslog(LogfsServer *server, int active, LogMessage *s)
{
uint size = logfssizeS2M(s);
char *errmsg;
uchar *p;
int takearisk;
if(server->trace > 1) {
print("%c<< ", active ? 'A' : 'S');
logfsdumpS(s);
print("\n");
}
if(active) {
switch(s->type) {
case LogfsLogTremove:
case LogfsLogTtrunc:
takearisk = 1;
break;
default:
takearisk = 0;
}
}
else
takearisk = 0;
errmsg = logspace(server, active, takearisk, size, &p, nil);
if(errmsg)
return errmsg;
if(logfsconvS2M(s, p, size) != size)
return "bad conversion";
logdirty(server, active);
return nil;
}
int
lognicesizeforwrite(LogfsServer *server, int active, u32 count, int muidlen)
{
int rawspace;
LogSegment *seg;
if(count > LogDataLimit)
return 0;
seg = active ? server->activelog : server->sweptlog;
if(seg->curpage < 0)
return LogDataLimit;
rawspace = (1 << server->ll->l2pagesize) - seg->nbytes;
if(rawspace < 5 * 4 + 2 + muidlen + 1)
return LogDataLimit;
return 5 * 4 + 2 + muidlen - rawspace;
}
char *
logfslogwrite(LogfsServer *server, int active, u32 path, u32 offset, int count, u32 mtime, u32 cvers,
char *muid, uchar *data, u32 *flashaddr)
{
/* 'w' size[2] path[4] offset[4] count[2] mtime[4] cvers[4] muid[s] flashaddr[4] [data[n]] */
LogMessage s;
uint size;
char *errmsg;
uchar *p;
u32 faddr;
uint asize;
s.type = LogfsLogTwrite;
s.path = path;
s.u.write.offset = offset;
s.u.write.count = count;
s.u.write.mtime = mtime;
s.u.write.cvers = cvers;
s.u.write.muid = muid;
s.u.write.data = data;
size = logfssizeS2M(&s);
errmsg = logspace(server, active, 0, size, &p, &faddr);
if(errmsg)
return errmsg;
if(data)
*flashaddr = (faddr + size - count) | LogAddr;
s.u.write.flashaddr = *flashaddr;
if(server->trace > 1) {
print("%c<< ", active ? 'A' : 'S');
logfsdumpS(&s);
print("\n");
}
if((asize = logfsconvS2M(&s, p, size)) != size) {
print("expected %d actual %d\n", size, asize);
return "bad conversion";
}
logdirty(server, active);
return nil;
}