shithub: neoventi

ref: 0a0dc432673d0c5f0902b0d053e08c8fe41a0eea
dir: /neoventi.h/

#define	U8GET(p)	((p)[0])
#define	U16GET(p)	(((p)[0]<<8)|(p)[1])
#define	U32GET(p)	((u32int)(((p)[0]<<24)|((p)[1]<<16)|((p)[2]<<8)|(p)[3]))
#define	U64GET(p)	(((u64int)U32GET(p)<<32)|(u64int)U32GET((p)+4))
#define MACHINE "kaladin"

enum {
	VtRerror = 1,
	VtTping,
	VtRping,
	VtThello,
	VtRhello,
	VtTgoodbye,
	VtRgoodbye,
	VtTauth0,
	VtRauth0,
	VtTauth1,
	VtRauth1,
	VtTread,
	VtRread,
	VtTwrite,
	VtRwrite,
	VtTsync,
	VtRsync,
	VtTmax,
};

enum {
	/* blank space at beginning of partition - useful for config
	 * or for when you accidentally {mount /dev/.../arenas /mnt/venti} */
	PartBlank = 256 * 1024,
	NameSize = 64,
	/* FIXME(design break) make arena part head a full block? breaking change for new arena partitions, removes
	 * need for special casing and magic around it. Just read the damn block. */
	HeadSize = 512,
	ArenaPartMagic = 0xa9e4a5e7U,
	ISectMagic = 0xd15c5ec7U,
	IBucketSize		= 6,
	IEntrySize		= 38,
	MaxAMap = 31*1024,
	ClumpInfoSize = 25,
	ABlockLog = 9, /* All reads are of 512 byte sectors??? Yikes. We should probably use a larger size, FIXME. */
};

typedef struct {
	int fd;
	jmp_buf bounce;
} VtConn;

typedef struct {
	char name[NameSize];
	u32int clumpmagic;
	u32int clumpmax;
	u32int blocksize;
	u32int version;
	u32int ctime, wtime;

	/* disk info */
	u64int size;
	u64int base;
	int fd;
	struct {
		u32int clumps;
	} memstats;
} VtArena;

typedef struct {
	int		blocklog;		/* log2(blocksize) */
	int		buckmax;		/* max. entries in a index bucket */
	u32int		tabbase;		/* base address of index config table on disk */
	u32int		tabsize;		/* max. bytes in index config */

	u32int		version;
	u32int		bucketmagic;
	char		name[NameSize];	/* text label */
	char		index[NameSize];	/* index owning the section */
	u32int		blocksize;		/* size of hash buckets in index */
	u32int		blockbase;		/* address of start of on disk index table */
	u32int		blocks;			/* total blocks on disk; some may be unused */
	u32int		start;			/* first bucket in this section */
	u32int		stop;			/* limit of buckets in this section */
	int fd;
} VtISect;

typedef struct {
	char name[NameSize];
	u64int start, stop;
} MapEntry;

struct {
	u32int blocksize;
	u32int buckets;
	VtISect *sects;
	int nsects;
	u32int div;
	u32int namap;
	MapEntry *amap;
} index;

enum
{
	WhackStats	= 8,
	WhackMaxOff	= 16*1024,	/* max allowed offset */

	HashLog		= 14,
	HashSize	= 1<<HashLog,
	HashMask	= HashSize - 1,

	MinMatch	= 3,		/* shortest match possible */

	MinDecode	= 8,			/* minimum bits to decode a match or lit; >= 8 */

	MaxSeqMask	= 8,	/* number of bits in coding block mask */
	MaxSeqStart	= 256,	/* max offset of initial coding block */

	MaxPacketSize = 0x10008, /* largest possible protocol message */
}; 

int	unwhack(uchar *dst, u16int dsize, uchar *src, u16int ssize);
void serve(char *addr);
int readclump(uchar *dst, VtArena arena, u64int addr, u8int blocks);
/* Looks up a score in the index */
int vtreadlookup(u8int *score, VtArena *arena, u64int *addr, u16int *size, u8int *blocks);
int Brdu32(Biobufhdr *bio, u32int *u32);
int stru32int(char *s, u32int *r);
int stru64int(char *s, u64int *r);
int u64log2(u64int v);

void initarenas(void);
void initindex(void);