shithub: gefs

ref: c5b298956bde7c034464c88be0c85d9e12bc5d0a
dir: /fns.h/

#pragma varargck type "M"	Msg*
#pragma varargck type "P"	Kvp*
#pragma varargck type "K"	Key*
#pragma varargck type "V"	Val*
#pragma varargck type "B"	Bptr
#pragma varargck type "R"	Arange*
#pragma varargck type "X"	char*
#pragma varargck type "Q"	Qid

extern Gefs	*fs;
extern int	debug;

Blk*	newblk(int type);
Blk*	getroot(Tree*, int*);
Blk*	getblk(Bptr, int);
Blk*	refblk(Blk*);
Blk*	cacheblk(Blk*);
Blk*	lookupblk(vlong);
Blk*	readblk(vlong, int);
Arena*	getarena(vlong);
void	putblk(Blk*);
int	syncblk(Blk*);
void	enqueue(Blk*);
void	freeblk(Blk*);
ushort	blkfill(Blk*);
uvlong	blkhash(Blk*);
u32int	ihash(vlong);
void	finalize(Blk*);
char*	fillsuper(Blk*);
int	snapshot(void);
uvlong	siphash(void*, usize);
void	reamfs(char*);
int	loadarena(Arena*, vlong);
void	loadfs(char*);
int	sync(void);
int	loadlog(Arena*);
int	endfs(void);
int	compresslog(Arena*);
void	setval(Blk*, int, Kvp*);

int	btupsert(Tree*, Msg*, int);
char	*btlookup(Tree*, Key*, Kvp*, char*, int);
char	*btlookupat(Blk*, int, Key*, Kvp*, char*, int);
char	*btscan(Tree*, Scan*, char*, int);
char	*btnext(Scan*, Kvp*, int*);
void	btdone(Scan*);


void	setflag(Blk *b, int);
int	chkflag(Blk *b, int);

char*	estrdup(char*);

int	keycmp(Key *, Key *);

/* for dumping */
void	getval(Blk *, int, Kvp *);
void	getmsg(Blk *, int, Msg *);

void	initshow(void);
void	showblk(Blk*, char*, int);
void	showpath(Path*, int);
void	showfs(int, char*);
void	showfids(int);
void	showcache(int);
void	showfree(int, char*);
int	checkfs(void);

#define dprint(...) \
	do{ \
		if(debug) fprint(2, __VA_ARGS__); \
	}while(0)

char	*pack8(int*, char*, char*, uchar);
char	*pack16(int*, char*, char*, ushort);
char	*pack32(int*, char*, char*, uint);
char	*pack64(int*, char*, char*, uvlong);
char	*packstr(int*, char*, char*, char*);

/* void* is a bit hacky, but we want both signed and unsigned to work */
char	*unpack8(int*, char*, char*, void*);
char	*unpack16(int*, char*, char*, void*);
char	*unpack32(int*, char*, char*, void*);
char	*unpack64(int*, char*, char*, void*);
char	*unpackstr(int*, char*, char*, char**);
int	dir2kv(vlong, Dir*, Kvp*, char*, int);
int	kv2statbuf(Kvp*, char*, int);
int	kv2dir(Kvp*, Dir*);
int	kv2qid(Kvp*, Qid*);

char	*packbp(char*, Bptr*);
Bptr	unpackbp(char*);

/* fmt */
int	Bconv(Fmt*);
int	Mconv(Fmt*);
int	Pconv(Fmt*);
int	Rconv(Fmt*);
int	Kconv(Fmt*);
int	Qconv(Fmt*);

/* scratch */
void	setmsg(Blk *, int, Msg *);
void	bufinsert(Blk *, Msg *);
void	victim(Blk *b, Path *p);

Chan	*mkchan(int);
Fmsg	*chrecv(Chan*);
void	chsend(Chan*, Fmsg*);
void	runfs(void*);
void	runwrite(void*);
void	runread(void*);
void	runcons(void*);

/* it's in libc... */
extern int cas(long *, long, long);