NetBSD/sys/coda/coda_venus.c
1998-08-29 21:26:45 +00:00

655 lines
17 KiB
C

/*
Coda: an Experimental Distributed File System
Release 3.1
Copyright (c) 1987-1998 Carnegie Mellon University
All Rights Reserved
Permission to use, copy, modify and distribute this software and its
documentation is hereby granted, provided that both the copyright
notice and this permission notice appear in all copies of the
software, derivative works or modified versions, and any portions
thereof, and that both notices appear in supporting documentation, and
that credit is given to Carnegie Mellon University in all documents
and publicity pertaining to direct or indirect use of this code or its
derivatives.
CODA IS AN EXPERIMENTAL SOFTWARE SYSTEM AND IS KNOWN TO HAVE BUGS,
SOME OF WHICH MAY HAVE SERIOUS CONSEQUENCES. CARNEGIE MELLON ALLOWS
FREE USE OF THIS SOFTWARE IN ITS "AS IS" CONDITION. CARNEGIE MELLON
DISCLAIMS ANY LIABILITY OF ANY KIND FOR ANY DAMAGES WHATSOEVER
RESULTING DIRECTLY OR INDIRECTLY FROM THE USE OF THIS SOFTWARE OR OF
ANY DERIVATIVE WORK.
Carnegie Mellon encourages users of this software to return any
improvements or extensions that they make, and to grant Carnegie
Mellon the rights to redistribute these changes without encumbrance.
*/
/* $Header: /cvsroot/src/sys/coda/coda_venus.c,v 1.1.1.1 1998/08/29 21:26:45 rvb Exp $ */
#include <sys/param.h>
#include <sys/systm.h>
#include <sys/malloc.h>
#include <sys/proc.h>
#include <sys/select.h>
#ifdef __FreeBSD_version
#include <sys/ioccom.h>
#else
#include <sys/ioctl.h>
#endif
/* for CNV_OFLAGS below */
#include <sys/fcntl.h>
#include <cfs/coda.h>
#include <cfs/cnode.h>
#include <cfs/cfs_venus.h>
#include <cfs/pioctl.h>
#define DECL_NO_IN(name) \
struct cfs_in_hdr *inp; \
struct name ## _out *outp; \
int name ## _size = sizeof (struct cfs_in_hdr); \
int Isize = sizeof (struct cfs_in_hdr); \
int Osize = sizeof (struct name ## _out); \
int error
#define DECL(name) \
struct name ## _in *inp; \
struct name ## _out *outp; \
int name ## _size = sizeof (struct name ## _in); \
int Isize = sizeof (struct name ## _in); \
int Osize = sizeof (struct name ## _out); \
int error
#define DECL_NO_OUT(name) \
struct name ## _in *inp; \
struct cfs_out_hdr *outp; \
int name ## _size = sizeof (struct name ## _in); \
int Isize = sizeof (struct name ## _in); \
int Osize = sizeof (struct cfs_out_hdr); \
int error
#define ALLOC_NO_IN(name) \
if (Osize > name ## _size) \
name ## _size = Osize; \
CFS_ALLOC(inp, struct cfs_in_hdr *, name ## _size);\
outp = (struct name ## _out *) inp
#define ALLOC(name) \
if (Osize > name ## _size) \
name ## _size = Osize; \
CFS_ALLOC(inp, struct name ## _in *, name ## _size);\
outp = (struct name ## _out *) inp
#define ALLOC_NO_OUT(name) \
if (Osize > name ## _size) \
name ## _size = Osize; \
CFS_ALLOC(inp, struct name ## _in *, name ## _size);\
outp = (struct cfs_out_hdr *) inp
#define STRCPY(struc, name, len) \
bcopy(name, (char *)inp + (int)inp->struc, len); \
((char*)inp + (int)inp->struc)[len++] = 0; \
Isize += len
#define INIT_IN(in, op, ident, p) \
(in)->opcode = (op); \
(in)->pid = p ? p->p_pid : -1; \
(in)->pgid = p ? p->p_pgid : -1; \
(in)->sid = (p && p->p_session && p->p_session->s_leader) ? (p->p_session->s_leader->p_pid) : -1; \
if (ident != NOCRED) { \
(in)->cred.cr_uid = ident->cr_uid; \
(in)->cred.cr_groupid = ident->cr_gid; \
} else { \
bzero(&((in)->cred),sizeof(struct coda_cred)); \
(in)->cred.cr_uid = -1; \
(in)->cred.cr_groupid = -1; \
} \
#define CNV_OFLAG(to, from) \
do { \
to = 0; \
if (from & FREAD) to |= C_O_READ; \
if (from & FWRITE) to |= C_O_WRITE; \
if (from & O_TRUNC) to |= C_O_TRUNC; \
if (from & O_EXCL) to |= C_O_EXCL; \
} while (0)
#define CNV_VV2V_ATTR(top, fromp) \
do { \
(top)->va_type = (fromp)->va_type; \
(top)->va_mode = (fromp)->va_mode; \
(top)->va_nlink = (fromp)->va_nlink; \
(top)->va_uid = (fromp)->va_uid; \
(top)->va_gid = (fromp)->va_gid; \
(top)->va_fsid = VNOVAL; \
(top)->va_fileid = (fromp)->va_fileid; \
(top)->va_size = (fromp)->va_size; \
(top)->va_blocksize = (fromp)->va_blocksize; \
(top)->va_atime = (fromp)->va_atime; \
(top)->va_mtime = (fromp)->va_mtime; \
(top)->va_ctime = (fromp)->va_ctime; \
(top)->va_gen = (fromp)->va_gen; \
(top)->va_flags = (fromp)->va_flags; \
(top)->va_rdev = (fromp)->va_rdev; \
(top)->va_bytes = (fromp)->va_bytes; \
(top)->va_filerev = (fromp)->va_filerev; \
(top)->va_vaflags = VNOVAL; \
(top)->va_spare = VNOVAL; \
} while (0)
#define CNV_V2VV_ATTR(top, fromp) \
do { \
(top)->va_type = (fromp)->va_type; \
(top)->va_mode = (fromp)->va_mode; \
(top)->va_nlink = (fromp)->va_nlink; \
(top)->va_uid = (fromp)->va_uid; \
(top)->va_gid = (fromp)->va_gid; \
(top)->va_fileid = (fromp)->va_fileid; \
(top)->va_size = (fromp)->va_size; \
(top)->va_blocksize = (fromp)->va_blocksize; \
(top)->va_atime = (fromp)->va_atime; \
(top)->va_mtime = (fromp)->va_mtime; \
(top)->va_ctime = (fromp)->va_ctime; \
(top)->va_gen = (fromp)->va_gen; \
(top)->va_flags = (fromp)->va_flags; \
(top)->va_rdev = (fromp)->va_rdev; \
(top)->va_bytes = (fromp)->va_bytes; \
(top)->va_filerev = (fromp)->va_filerev; \
} while (0)
int
venus_root(void *mdp,
struct ucred *cred, struct proc *p,
/*out*/ ViceFid *VFid)
{
DECL_NO_IN(cfs_root); /* sets Isize & Osize */
ALLOC_NO_IN(cfs_root); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(inp, CFS_ROOT, cred, p);
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error)
*VFid = outp->VFid;
CFS_FREE(inp, cfs_root_size);
return error;
}
int
venus_open(void *mdp, ViceFid *fid, int flag,
struct ucred *cred, struct proc *p,
/*out*/ dev_t *dev, ino_t *inode)
{
int cflag;
DECL(cfs_open); /* sets Isize & Osize */
ALLOC(cfs_open); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_OPEN, cred, p);
inp->VFid = *fid;
CNV_OFLAG(cflag, flag);
inp->flags = cflag;
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error) {
*dev = outp->dev;
*inode = outp->inode;
}
CFS_FREE(inp, cfs_open_size);
return error;
}
int
venus_close(void *mdp, ViceFid *fid, int flag,
struct ucred *cred, struct proc *p)
{
int cflag;
DECL_NO_OUT(cfs_close); /* sets Isize & Osize */
ALLOC_NO_OUT(cfs_close); /* sets inp & outp */
INIT_IN(&inp->ih, CFS_CLOSE, cred, p);
inp->VFid = *fid;
CNV_OFLAG(cflag, flag);
inp->flags = cflag;
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_close_size);
return error;
}
/*
* these two calls will not exist!!! the container file is read/written
* directly.
*/
void
venus_read(void)
{
}
void
venus_write(void)
{
}
/*
* this is a bit sad too. the ioctl's are for the control file, not for
* normal files.
*/
int
venus_ioctl(void *mdp, ViceFid *fid,
int com, int flag, caddr_t data,
struct ucred *cred, struct proc *p)
{
DECL(cfs_ioctl); /* sets Isize & Osize */
struct PioctlData *iap = (struct PioctlData *)data;
int tmp;
cfs_ioctl_size = VC_MAXMSGSIZE;
ALLOC(cfs_ioctl); /* sets inp & outp */
INIT_IN(&inp->ih, CFS_IOCTL, cred, p);
inp->VFid = *fid;
/* command was mutated by increasing its size field to reflect the
* path and follow args. we need to subtract that out before sending
* the command to venus.
*/
inp->cmd = (com & ~(IOCPARM_MASK << 16));
tmp = ((com >> 16) & IOCPARM_MASK) - sizeof (char *) - sizeof (int);
inp->cmd |= (tmp & IOCPARM_MASK) << 16;
inp->rwflag = flag;
inp->len = iap->vi.in_size;
inp->data = (char *)(sizeof (struct cfs_ioctl_in));
error = copyin(iap->vi.in, (char*)inp + (int)inp->data,
iap->vi.in_size);
if (error) {
CFS_FREE(inp, cfs_ioctl_size);
return(error);
}
Osize = VC_MAXMSGSIZE;
error = cfscall(mdp, Isize + iap->vi.in_size, &Osize, (char *)inp);
/* copy out the out buffer. */
if (!error) {
if (outp->len > iap->vi.out_size) {
error = EINVAL;
} else {
error = copyout((char *)outp + (int)outp->data,
iap->vi.out, iap->vi.out_size);
}
}
CFS_FREE(inp, cfs_ioctl_size);
return error;
}
int
venus_getattr(void *mdp, ViceFid *fid,
struct ucred *cred, struct proc *p,
/*out*/ struct vattr *vap)
{
DECL(cfs_getattr); /* sets Isize & Osize */
ALLOC(cfs_getattr); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_GETATTR, cred, p);
inp->VFid = *fid;
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error) {
CNV_VV2V_ATTR(vap, &outp->attr);
}
CFS_FREE(inp, cfs_getattr_size);
return error;
}
int
venus_setattr(void *mdp, ViceFid *fid, struct vattr *vap,
struct ucred *cred, struct proc *p)
{
DECL_NO_OUT(cfs_setattr); /* sets Isize & Osize */
ALLOC_NO_OUT(cfs_setattr); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_SETATTR, cred, p);
inp->VFid = *fid;
CNV_V2VV_ATTR(&inp->attr, vap);
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_setattr_size);
return error;
}
int
venus_access(void *mdp, ViceFid *fid, int mode,
struct ucred *cred, struct proc *p)
{
DECL_NO_OUT(cfs_access); /* sets Isize & Osize */
ALLOC_NO_OUT(cfs_access); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_ACCESS, cred, p);
inp->VFid = *fid;
#ifdef NetBSD1_3
inp->flags = mode;
#else
inp->flags = mode>>6;
#endif
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_access_size);
return error;
}
int
venus_readlink(void *mdp, ViceFid *fid,
struct ucred *cred, struct proc *p,
/*out*/ char **str, int *len)
{
DECL(cfs_readlink); /* sets Isize & Osize */
cfs_readlink_size += CFS_MAXPATHLEN;
ALLOC(cfs_readlink); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_READLINK, cred, p);
inp->VFid = *fid;
Osize += CFS_MAXPATHLEN;
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error) {
CFS_ALLOC(*str, char *, outp->count);
*len = outp->count;
bcopy((char *)outp + (int)outp->data, *str, *len);
}
CFS_FREE(inp, cfs_readlink_size);
return error;
}
int
venus_fsync(void *mdp, ViceFid *fid,
struct ucred *cred, struct proc *p)
{
DECL_NO_OUT(cfs_fsync); /* sets Isize & Osize */
ALLOC_NO_OUT(cfs_fsync); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_FSYNC, cred, p);
inp->VFid = *fid;
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_fsync_size);
return error;
}
int
venus_lookup(void *mdp, ViceFid *fid,
const char *nm, int len,
struct ucred *cred, struct proc *p,
/*out*/ ViceFid *VFid, int *vtype)
{
DECL(cfs_lookup); /* sets Isize & Osize */
cfs_lookup_size += len + 1;
ALLOC(cfs_lookup); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_LOOKUP, cred, p);
inp->VFid = *fid;
inp->name = Isize;
STRCPY(name, nm, len); /* increments Isize */
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error) {
*VFid = outp->VFid;
*vtype = outp->vtype;
}
CFS_FREE(inp, cfs_lookup_size);
return error;
}
int
venus_create(void *mdp, ViceFid *fid,
const char *nm, int len, int exclusive, int mode, struct vattr *va,
struct ucred *cred, struct proc *p,
/*out*/ ViceFid *VFid, struct vattr *attr)
{
DECL(cfs_create); /* sets Isize & Osize */
cfs_create_size += len + 1;
ALLOC(cfs_create); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_CREATE, cred, p);
inp->VFid = *fid;
inp->excl = exclusive ? C_O_EXCL : 0;
#ifdef NetBSD1_3
inp->mode = mode<<6;
#else
inp->mode = mode;
#endif
CNV_V2VV_ATTR(&inp->attr, va);
inp->name = Isize;
STRCPY(name, nm, len); /* increments Isize */
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error) {
*VFid = outp->VFid;
CNV_VV2V_ATTR(attr, &outp->attr);
}
CFS_FREE(inp, cfs_create_size);
return error;
}
int
venus_remove(void *mdp, ViceFid *fid,
const char *nm, int len,
struct ucred *cred, struct proc *p)
{
DECL_NO_OUT(cfs_remove); /* sets Isize & Osize */
cfs_remove_size += len + 1;
ALLOC_NO_OUT(cfs_remove); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_REMOVE, cred, p);
inp->VFid = *fid;
inp->name = Isize;
STRCPY(name, nm, len); /* increments Isize */
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_remove_size);
return error;
}
int
venus_link(void *mdp, ViceFid *fid, ViceFid *tfid,
const char *nm, int len,
struct ucred *cred, struct proc *p)
{
DECL_NO_OUT(cfs_link); /* sets Isize & Osize */
cfs_link_size += len + 1;
ALLOC_NO_OUT(cfs_link); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_LINK, cred, p);
inp->sourceFid = *fid;
inp->destFid = *tfid;
inp->tname = Isize;
STRCPY(tname, nm, len); /* increments Isize */
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_link_size);
return error;
}
int
venus_rename(void *mdp, ViceFid *fid, ViceFid *tfid,
const char *nm, int len, const char *tnm, int tlen,
struct ucred *cred, struct proc *p)
{
DECL_NO_OUT(cfs_rename); /* sets Isize & Osize */
cfs_rename_size += len + 1 + tlen + 1;
ALLOC_NO_OUT(cfs_rename); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_RENAME, cred, p);
inp->sourceFid = *fid;
inp->destFid = *tfid;
inp->srcname = Isize;
STRCPY(srcname, nm, len); /* increments Isize */
inp->destname = Isize;
STRCPY(destname, tnm, tlen); /* increments Isize */
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_rename_size);
return error;
}
int
venus_mkdir(void *mdp, ViceFid *fid,
const char *nm, int len, struct vattr *va,
struct ucred *cred, struct proc *p,
/*out*/ ViceFid *VFid, struct vattr *ova)
{
DECL(cfs_mkdir); /* sets Isize & Osize */
cfs_mkdir_size += len + 1;
ALLOC(cfs_mkdir); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_MKDIR, cred, p);
inp->VFid = *fid;
CNV_V2VV_ATTR(&inp->attr, va);
inp->name = Isize;
STRCPY(name, nm, len); /* increments Isize */
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error) {
*VFid = outp->VFid;
CNV_VV2V_ATTR(ova, &outp->attr);
}
CFS_FREE(inp, cfs_mkdir_size);
return error;
}
int
venus_rmdir(void *mdp, ViceFid *fid,
const char *nm, int len,
struct ucred *cred, struct proc *p)
{
DECL_NO_OUT(cfs_rmdir); /* sets Isize & Osize */
cfs_rmdir_size += len + 1;
ALLOC_NO_OUT(cfs_rmdir); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_RMDIR, cred, p);
inp->VFid = *fid;
inp->name = Isize;
STRCPY(name, nm, len); /* increments Isize */
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_rmdir_size);
return error;
}
int
venus_symlink(void *mdp, ViceFid *fid,
const char *lnm, int llen, const char *nm, int len, struct vattr *va,
struct ucred *cred, struct proc *p)
{
DECL_NO_OUT(cfs_symlink); /* sets Isize & Osize */
cfs_symlink_size += llen + 1 + len + 1;
ALLOC_NO_OUT(cfs_symlink); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_SYMLINK, cred, p);
inp->VFid = *fid;
CNV_V2VV_ATTR(&inp->attr, va);
inp->srcname = Isize;
STRCPY(srcname, lnm, llen); /* increments Isize */
inp->tname = Isize;
STRCPY(tname, nm, len); /* increments Isize */
error = cfscall(mdp, Isize, &Osize, (char *)inp);
CFS_FREE(inp, cfs_symlink_size);
return error;
}
int
venus_readdir(void *mdp, ViceFid *fid,
int count, int offset,
struct ucred *cred, struct proc *p,
/*out*/ char *buffer, int *len)
{
DECL(cfs_readdir); /* sets Isize & Osize */
cfs_readdir_size = VC_MAXMSGSIZE;
ALLOC(cfs_readdir); /* sets inp & outp */
/* send the open to venus. */
INIT_IN(&inp->ih, CFS_READDIR, cred, p);
inp->VFid = *fid;
inp->count = count;
inp->offset = offset;
Osize = VC_MAXMSGSIZE;
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error) {
bcopy((char *)outp + (int)outp->data, buffer, outp->size);
*len = outp->size;
}
CFS_FREE(inp, cfs_readdir_size);
return error;
}
int
venus_fhtovp(void *mdp, ViceFid *fid,
struct ucred *cred, struct proc *p,
/*out*/ ViceFid *VFid, int *vtype)
{
DECL(cfs_vget); /* sets Isize & Osize */
ALLOC(cfs_vget); /* sets inp & outp */
/* Send the open to Venus. */
INIT_IN(&inp->ih, CFS_VGET, cred, p);
inp->VFid = *fid;
error = cfscall(mdp, Isize, &Osize, (char *)inp);
if (!error) {
*VFid = outp->VFid;
*vtype = outp->vtype;
}
CFS_FREE(inp, cfs_vget_size);
return error;
}