145 lines
3.0 KiB
C
145 lines
3.0 KiB
C
|
/*
|
||
|
|
* This file is part of the UCB release of Plan 9. It is subject to the license
|
||
|
|
* terms in the LICENSE file found in the top-level directory of this
|
||
|
|
* distribution and at http://akaros.cs.berkeley.edu/files/Plan9License. No
|
||
|
|
* part of the UCB release of Plan 9, including this file, may be copied,
|
||
|
|
* modified, propagated, or distributed except according to the terms contained
|
||
|
|
* in the LICENSE file.
|
||
|
|
*/
|
||
|
|
|
||
|
|
/*
|
||
|
|
* exportfs.h - definitions for exporting file server
|
||
|
|
*/
|
||
|
|
|
||
|
|
#define DEBUG if(!dbg){}else fprint
|
||
|
|
#define DFD 9
|
||
|
|
#define fidhash(s) fhash[s%FHASHSIZE]
|
||
|
|
|
||
|
|
typedef struct Fsrpc Fsrpc;
|
||
|
|
typedef struct Fid Fid;
|
||
|
|
typedef struct File File;
|
||
|
|
typedef struct Proc Proc;
|
||
|
|
typedef struct Qidtab Qidtab;
|
||
|
|
|
||
|
|
struct Fsrpc
|
||
|
|
{
|
||
|
|
int busy; /* Work buffer has pending rpc to service */
|
||
|
|
uintptr_t pid; /* Pid of slave process executing the rpc */
|
||
|
|
int canint; /* Interrupt gate */
|
||
|
|
int flushtag; /* Tag on which to reply to flush */
|
||
|
|
Fcall work; /* Plan 9 incoming Fcall */
|
||
|
|
uint8_t *buf; /* Data buffer */
|
||
|
|
};
|
||
|
|
|
||
|
|
struct Fid
|
||
|
|
{
|
||
|
|
int fid; /* system fd for i/o */
|
||
|
|
File *f; /* File attached to this fid */
|
||
|
|
int mode;
|
||
|
|
int nr; /* fid number */
|
||
|
|
int mid; /* Mount id */
|
||
|
|
Fid *next; /* hash link */
|
||
|
|
|
||
|
|
/* for preaddir -- ARRGH! */
|
||
|
|
Dir *dir; /* buffer for reading directories */
|
||
|
|
int ndir; /* number of entries in dir */
|
||
|
|
int cdir; /* number of consumed entries in dir */
|
||
|
|
int gdir; /* glue index */
|
||
|
|
int64_t offset; /* offset in virtual directory */
|
||
|
|
};
|
||
|
|
|
||
|
|
struct File
|
||
|
|
{
|
||
|
|
char *name;
|
||
|
|
int ref;
|
||
|
|
Qid qid;
|
||
|
|
Qidtab *qidt;
|
||
|
|
int inval;
|
||
|
|
File *parent;
|
||
|
|
File *child;
|
||
|
|
File *childlist;
|
||
|
|
};
|
||
|
|
|
||
|
|
struct Proc
|
||
|
|
{
|
||
|
|
uintptr_t pid;
|
||
|
|
int busy;
|
||
|
|
Proc *next;
|
||
|
|
};
|
||
|
|
|
||
|
|
struct Qidtab
|
||
|
|
{
|
||
|
|
int ref;
|
||
|
|
int type;
|
||
|
|
int dev;
|
||
|
|
int64_t path;
|
||
|
|
int64_t uniqpath;
|
||
|
|
Qidtab *next;
|
||
|
|
};
|
||
|
|
|
||
|
|
enum
|
||
|
|
{
|
||
|
|
MAXPROC = 50,
|
||
|
|
FHASHSIZE = 64,
|
||
|
|
Nr_workbufs = 50,
|
||
|
|
Fidchunk = 1000,
|
||
|
|
Npsmpt = 32,
|
||
|
|
Nqidbits = 5,
|
||
|
|
Nqidtab = (1<<Nqidbits),
|
||
|
|
};
|
||
|
|
|
||
|
|
extern Fsrpc *Workq;
|
||
|
|
extern int dbg;
|
||
|
|
extern File *root;
|
||
|
|
extern File *psmpt;
|
||
|
|
extern Fid **fhash;
|
||
|
|
extern Fid *fidfree;
|
||
|
|
extern Proc *Proclist;
|
||
|
|
extern char psmap[Npsmpt];
|
||
|
|
extern Qidtab *qidtab[Nqidtab];
|
||
|
|
extern uint32_t messagesize;
|
||
|
|
extern char Enomem[];
|
||
|
|
extern int srvfd;
|
||
|
|
extern char* patternfile;
|
||
|
|
|
||
|
|
/* File system protocol service procedures */
|
||
|
|
void Xattach(Fsrpc*);
|
||
|
|
void Xauth(Fsrpc*);
|
||
|
|
void Xclunk(Fsrpc*);
|
||
|
|
void Xcreate(Fsrpc*);
|
||
|
|
void Xflush(Fsrpc*);
|
||
|
|
void Xnop(Fsrpc*);
|
||
|
|
void Xremove(Fsrpc*);
|
||
|
|
void Xstat(Fsrpc*);
|
||
|
|
void Xversion(Fsrpc*);
|
||
|
|
void Xwalk(Fsrpc*);
|
||
|
|
void Xwstat(Fsrpc*);
|
||
|
|
void slave(Fsrpc*);
|
||
|
|
|
||
|
|
void reply(Fcall*, Fcall*, char*);
|
||
|
|
Fid *getfid(int);
|
||
|
|
int freefid(int);
|
||
|
|
Fid *newfid(int);
|
||
|
|
Fsrpc *getsbuf(void);
|
||
|
|
void initroot(void);
|
||
|
|
void fatal(char*, ...);
|
||
|
|
char* makepath(File*, char*);
|
||
|
|
File *file(File*, char*);
|
||
|
|
void freefile(File*);
|
||
|
|
void slaveopen(Fsrpc*);
|
||
|
|
void slaveread(Fsrpc*);
|
||
|
|
void slavewrite(Fsrpc*);
|
||
|
|
void blockingslave(void);
|
||
|
|
void reopen(Fid *f);
|
||
|
|
void noteproc(int, char*);
|
||
|
|
void flushaction(void*, char*);
|
||
|
|
void pushfcall(char*);
|
||
|
|
Qidtab* uniqueqid(Dir*);
|
||
|
|
void freeqid(Qidtab*);
|
||
|
|
char* estrdup(char*);
|
||
|
|
void* emallocz(uint32_t);
|
||
|
|
int readmessage(int, char*, int);
|
||
|
|
void exclusions(void);
|
||
|
|
int excludefile(char*);
|
||
|
|
int preaddir(Fid*, uint8_t*, int, int64_t);
|