Home | History | Annotate | Line # | Download | only in coda
coda_psdev.c revision 1.4
      1  1.4  rvb /*	$NetBSD: coda_psdev.c,v 1.4 1998/09/15 02:02:59 rvb Exp $	*/
      2  1.2  rvb 
      3  1.1  rvb /*
      4  1.2  rvb  *
      5  1.2  rvb  *             Coda: an Experimental Distributed File System
      6  1.2  rvb  *                              Release 3.1
      7  1.2  rvb  *
      8  1.2  rvb  *           Copyright (c) 1987-1998 Carnegie Mellon University
      9  1.2  rvb  *                          All Rights Reserved
     10  1.2  rvb  *
     11  1.2  rvb  * Permission  to  use, copy, modify and distribute this software and its
     12  1.2  rvb  * documentation is hereby granted,  provided  that  both  the  copyright
     13  1.2  rvb  * notice  and  this  permission  notice  appear  in  all  copies  of the
     14  1.2  rvb  * software, derivative works or  modified  versions,  and  any  portions
     15  1.2  rvb  * thereof, and that both notices appear in supporting documentation, and
     16  1.2  rvb  * that credit is given to Carnegie Mellon University  in  all  documents
     17  1.2  rvb  * and publicity pertaining to direct or indirect use of this code or its
     18  1.2  rvb  * derivatives.
     19  1.2  rvb  *
     20  1.2  rvb  * CODA IS AN EXPERIMENTAL SOFTWARE SYSTEM AND IS  KNOWN  TO  HAVE  BUGS,
     21  1.2  rvb  * SOME  OF  WHICH MAY HAVE SERIOUS CONSEQUENCES.  CARNEGIE MELLON ALLOWS
     22  1.2  rvb  * FREE USE OF THIS SOFTWARE IN ITS "AS IS" CONDITION.   CARNEGIE  MELLON
     23  1.2  rvb  * DISCLAIMS  ANY  LIABILITY  OF  ANY  KIND  FOR  ANY  DAMAGES WHATSOEVER
     24  1.2  rvb  * RESULTING DIRECTLY OR INDIRECTLY FROM THE USE OF THIS SOFTWARE  OR  OF
     25  1.2  rvb  * ANY DERIVATIVE WORK.
     26  1.2  rvb  *
     27  1.2  rvb  * Carnegie  Mellon  encourages  users  of  this  software  to return any
     28  1.2  rvb  * improvements or extensions that  they  make,  and  to  grant  Carnegie
     29  1.2  rvb  * Mellon the rights to redistribute these changes without encumbrance.
     30  1.2  rvb  *
     31  1.4  rvb  * 	@(#) coda/coda_psdev.c,v 1.1.1.1 1998/08/29 21:26:45 rvb Exp $
     32  1.2  rvb  */
     33  1.1  rvb 
     34  1.1  rvb /*
     35  1.1  rvb  * Mach Operating System
     36  1.1  rvb  * Copyright (c) 1989 Carnegie-Mellon University
     37  1.1  rvb  * All rights reserved.  The CMU software License Agreement specifies
     38  1.1  rvb  * the terms and conditions for use and redistribution.
     39  1.1  rvb  */
     40  1.1  rvb 
     41  1.1  rvb /*
     42  1.1  rvb  * This code was written for the Coda file system at Carnegie Mellon
     43  1.1  rvb  * University.  Contributers include David Steere, James Kistler, and
     44  1.1  rvb  * M. Satyanarayanan.  */
     45  1.1  rvb 
     46  1.1  rvb /* These routines define the psuedo device for communication between
     47  1.1  rvb  * Coda's Venus and Minicache in Mach 2.6. They used to be in cfs_subr.c,
     48  1.1  rvb  * but I moved them to make it easier to port the Minicache without
     49  1.1  rvb  * porting coda. -- DCS 10/12/94
     50  1.1  rvb  */
     51  1.1  rvb 
     52  1.1  rvb /*
     53  1.1  rvb  * HISTORY
     54  1.4  rvb  * $Log: coda_psdev.c,v $
     55  1.4  rvb  * Revision 1.4  1998/09/15 02:02:59  rvb
     56  1.4  rvb  * Final piece of rename cfs->coda
     57  1.4  rvb  *
     58  1.4  rvb  * Revision 1.3  1998/09/12 15:05:48  rvb
     59  1.3  rvb  * Change cfs/CFS in symbols, strings and constants to coda/CODA
     60  1.3  rvb  * to avoid fs conflicts.
     61  1.3  rvb  *
     62  1.2  rvb  * Revision 1.2  1998/09/08 17:12:47  rvb
     63  1.2  rvb  * Pass2 complete
     64  1.2  rvb  *
     65  1.1  rvb  * Revision 1.1.1.1  1998/08/29 21:26:45  rvb
     66  1.1  rvb  * Very Preliminary Coda
     67  1.1  rvb  *
     68  1.1  rvb  * Revision 1.9  1998/08/28 18:12:17  rvb
     69  1.1  rvb  * Now it also works on FreeBSD -current.  This code will be
     70  1.1  rvb  * committed to the FreeBSD -current and NetBSD -current
     71  1.1  rvb  * trees.  It will then be tailored to the particular platform
     72  1.1  rvb  * by flushing conditional code.
     73  1.1  rvb  *
     74  1.1  rvb  * Revision 1.8  1998/08/18 17:05:15  rvb
     75  1.1  rvb  * Don't use __RCSID now
     76  1.1  rvb  *
     77  1.1  rvb  * Revision 1.7  1998/08/18 16:31:41  rvb
     78  1.1  rvb  * Sync the code for NetBSD -current; test on 1.3 later
     79  1.1  rvb  *
     80  1.1  rvb  * Revision 1.8  1998/06/09 23:30:42  rvb
     81  1.1  rvb  * Try to allow ^C -- take 1
     82  1.1  rvb  *
     83  1.1  rvb  * Revision 1.5.2.8  98/01/23  11:21:04  rvb
     84  1.1  rvb  * Sync with 2.2.5
     85  1.1  rvb  *
     86  1.1  rvb  * Revision 1.5.2.7  98/01/22  22:22:21  rvb
     87  1.3  rvb  * sync 1.2 and 1.3
     88  1.1  rvb  *
     89  1.1  rvb  * Revision 1.5.2.6  98/01/22  13:11:24  rvb
     90  1.1  rvb  * Move make_coda_node ctlfid later so vfsp is known; work on ^c and ^z
     91  1.1  rvb  *
     92  1.1  rvb  * Revision 1.5.2.5  97/12/16  22:01:27  rvb
     93  1.1  rvb  * Oops add cfs_subr.h cfs_venus.h; sync with peter
     94  1.1  rvb  *
     95  1.1  rvb  * Revision 1.5.2.4  97/12/16  12:40:05  rvb
     96  1.3  rvb  * Sync with 1.3
     97  1.1  rvb  *
     98  1.1  rvb  * Revision 1.5.2.3  97/12/10  14:08:24  rvb
     99  1.1  rvb  * Fix O_ flags; check result in coda_call
    100  1.1  rvb  *
    101  1.1  rvb  * Revision 1.5.2.2  97/12/10  11:40:24  rvb
    102  1.1  rvb  * No more ody
    103  1.1  rvb  *
    104  1.1  rvb  * Revision 1.5.2.1  97/12/06  17:41:20  rvb
    105  1.1  rvb  * Sync with peters coda.h
    106  1.1  rvb  *
    107  1.1  rvb  * Revision 1.5  97/12/05  10:39:16  rvb
    108  1.1  rvb  * Read CHANGES
    109  1.1  rvb  *
    110  1.1  rvb  * Revision 1.4.18.9  97/12/05  08:58:07  rvb
    111  1.1  rvb  * peter found this one
    112  1.1  rvb  *
    113  1.1  rvb  * Revision 1.4.18.8  97/11/26  15:28:57  rvb
    114  1.1  rvb  * Cant make downcall pbuf == union cfs_downcalls yet
    115  1.1  rvb  *
    116  1.1  rvb  * Revision 1.4.18.7  97/11/25  09:40:49  rvb
    117  1.1  rvb  * Final cfs_venus.c w/o macros, but one locking bug
    118  1.1  rvb  *
    119  1.1  rvb  * Revision 1.4.18.6  97/11/20  11:46:41  rvb
    120  1.1  rvb  * Capture current cfs_venus
    121  1.1  rvb  *
    122  1.1  rvb  * Revision 1.4.18.5  97/11/18  10:27:15  rvb
    123  1.1  rvb  * cfs_nbsd.c is DEAD!!!; integrated into cfs_vf/vnops.c
    124  1.1  rvb  * cfs_nb_foo and cfs_foo are joined
    125  1.1  rvb  *
    126  1.1  rvb  * Revision 1.4.18.4  97/11/13  22:02:59  rvb
    127  1.1  rvb  * pass2 cfs_NetBSD.h mt
    128  1.1  rvb  *
    129  1.1  rvb  * Revision 1.4.18.3  97/11/12  12:09:38  rvb
    130  1.1  rvb  * reorg pass1
    131  1.1  rvb  *
    132  1.1  rvb  * Revision 1.4.18.2  97/10/29  16:06:09  rvb
    133  1.1  rvb  * Kill DYING
    134  1.1  rvb  *
    135  1.1  rvb  * Revision 1.4.18.1  1997/10/28 23:10:15  rvb
    136  1.1  rvb  * >64Meg; venus can be killed!
    137  1.1  rvb  *
    138  1.1  rvb  * Revision 1.4  1996/12/12 22:10:58  bnoble
    139  1.1  rvb  * Fixed the "downcall invokes venus operation" deadlock in all known cases.
    140  1.1  rvb  * There may be more
    141  1.1  rvb  *
    142  1.1  rvb  * Revision 1.3  1996/11/13 04:14:20  bnoble
    143  1.1  rvb  * Merging BNOBLE_WORK_6_20_96 into main line
    144  1.1  rvb  *
    145  1.1  rvb  * Revision 1.2.8.1  1996/08/22 14:25:04  bnoble
    146  1.1  rvb  * Added a return code from vc_nb_close
    147  1.1  rvb  *
    148  1.1  rvb  * Revision 1.2  1996/01/02 16:56:58  bnoble
    149  1.3  rvb  * Added support for Coda MiniCache and raw inode calls (final commit)
    150  1.1  rvb  *
    151  1.1  rvb  * Revision 1.1.2.1  1995/12/20 01:57:24  bnoble
    152  1.1  rvb  * Added CODA-specific files
    153  1.1  rvb  *
    154  1.1  rvb  * Revision 1.1  1995/03/14  20:52:15  bnoble
    155  1.1  rvb  * Initial revision
    156  1.1  rvb  *
    157  1.1  rvb  */
    158  1.3  rvb 
    159  1.1  rvb /* These routines are the device entry points for Venus. */
    160  1.3  rvb 
    161  1.1  rvb extern int coda_nc_initialized;    /* Set if cache has been initialized */
    162  1.1  rvb 
    163  1.1  rvb #include <vcoda.h>
    164  1.1  rvb #include <sys/param.h>
    165  1.1  rvb #include <sys/systm.h>
    166  1.1  rvb #include <sys/kernel.h>
    167  1.1  rvb #include <sys/malloc.h>
    168  1.1  rvb #include <sys/proc.h>
    169  1.1  rvb #include <sys/mount.h>
    170  1.1  rvb #include <sys/file.h>
    171  1.1  rvb #include <sys/ioctl.h>
    172  1.4  rvb #include <sys/poll.h>
    173  1.4  rvb #include <sys/select.h>
    174  1.4  rvb 
    175  1.4  rvb #include <coda/coda.h>
    176  1.1  rvb #include <coda/cnode.h>
    177  1.2  rvb #include <coda/coda_namecache.h>
    178  1.2  rvb #include <coda/coda_io.h>
    179  1.3  rvb 
    180  1.3  rvb #define CTL_C
    181  1.3  rvb 
    182  1.1  rvb int coda_psdev_print_entry = 0;
    183  1.3  rvb 
    184  1.1  rvb #define ENTRY if(coda_psdev_print_entry) myprintf(("Entered %s\n",__FUNCTION__))
    185  1.1  rvb 
    186  1.1  rvb void vcodaattach(int n);
    187  1.1  rvb int vc_nb_open(dev_t dev, int flag, int mode, struct proc *p);
    188  1.1  rvb int vc_nb_close (dev_t dev, int flag, int mode, struct proc *p);
    189  1.1  rvb int vc_nb_read(dev_t dev, struct uio *uiop, int flag);
    190  1.1  rvb int vc_nb_write(dev_t dev, struct uio *uiop, int flag);
    191  1.1  rvb int vc_nb_ioctl(dev_t dev, int cmd, caddr_t addr, int flag, struct proc *p);
    192  1.1  rvb int vc_nb_poll(dev_t dev, int events, struct proc *p);
    193  1.1  rvb 
    194  1.1  rvb struct vmsg {
    195  1.1  rvb     struct queue vm_chain;
    196  1.1  rvb     caddr_t	 vm_data;
    197  1.1  rvb     u_short	 vm_flags;
    198  1.1  rvb     u_short      vm_inSize;	/* Size is at most 5000 bytes */
    199  1.1  rvb     u_short	 vm_outSize;
    200  1.1  rvb     u_short	 vm_opcode; 	/* copied from data to save ptr lookup */
    201  1.1  rvb     int		 vm_unique;
    202  1.1  rvb     caddr_t	 vm_sleep;	/* Not used by Mach. */
    203  1.1  rvb };
    204  1.1  rvb 
    205  1.1  rvb #define	VM_READ	    1
    206  1.3  rvb #define	VM_WRITE    2
    207  1.1  rvb #define	VM_INTR	    4
    208  1.3  rvb 
    209  1.1  rvb /* vcodaattach: do nothing */
    210  1.1  rvb void
    211  1.1  rvb vcodaattach(n)
    212  1.1  rvb     int n;
    213  1.1  rvb {
    214  1.1  rvb }
    215  1.1  rvb 
    216  1.1  rvb /*
    217  1.1  rvb  * These functions are written for NetBSD.
    218  1.1  rvb  */
    219  1.1  rvb int
    220  1.1  rvb vc_nb_open(dev, flag, mode, p)
    221  1.1  rvb     dev_t        dev;
    222  1.1  rvb     int          flag;
    223  1.1  rvb     int          mode;
    224  1.1  rvb     struct proc *p;             /* NetBSD only */
    225  1.1  rvb {
    226  1.1  rvb     register struct vcomm *vcp;
    227  1.3  rvb 
    228  1.1  rvb     ENTRY;
    229  1.1  rvb 
    230  1.3  rvb     if (minor(dev) >= NVCODA || minor(dev) < 0)
    231  1.3  rvb 	return(ENXIO);
    232  1.1  rvb 
    233  1.3  rvb     if (!coda_nc_initialized)
    234  1.1  rvb 	coda_nc_init();
    235  1.1  rvb 
    236  1.1  rvb     vcp = &coda_mnttbl[minor(dev)].mi_vcomm;
    237  1.1  rvb     if (VC_OPEN(vcp))
    238  1.1  rvb 	return(EBUSY);
    239  1.1  rvb 
    240  1.1  rvb     bzero(&(vcp->vc_selproc), sizeof (struct selinfo));
    241  1.1  rvb     INIT_QUEUE(vcp->vc_requests);
    242  1.3  rvb     INIT_QUEUE(vcp->vc_replys);
    243  1.3  rvb     MARK_VC_OPEN(vcp);
    244  1.1  rvb 
    245  1.1  rvb     coda_mnttbl[minor(dev)].mi_vfsp = NULL;
    246  1.1  rvb     coda_mnttbl[minor(dev)].mi_rootvp = NULL;
    247  1.1  rvb 
    248  1.1  rvb     return(0);
    249  1.1  rvb }
    250  1.1  rvb 
    251  1.1  rvb int
    252  1.1  rvb vc_nb_close (dev, flag, mode, p)
    253  1.1  rvb     dev_t        dev;
    254  1.1  rvb     int          flag;
    255  1.1  rvb     int          mode;
    256  1.1  rvb     struct proc *p;
    257  1.3  rvb {
    258  1.1  rvb     register struct vcomm *vcp;
    259  1.1  rvb     register struct vmsg *vmp;
    260  1.1  rvb     struct coda_mntinfo *mi;
    261  1.1  rvb     int                 err;
    262  1.3  rvb 
    263  1.1  rvb     ENTRY;
    264  1.1  rvb 
    265  1.3  rvb     if (minor(dev) >= NVCODA || minor(dev) < 0)
    266  1.1  rvb 	return(ENXIO);
    267  1.1  rvb 
    268  1.1  rvb     mi = &coda_mnttbl[minor(dev)];
    269  1.1  rvb     vcp = &(mi->mi_vcomm);
    270  1.1  rvb 
    271  1.1  rvb     if (!VC_OPEN(vcp))
    272  1.1  rvb 	panic("vcclose: not open");
    273  1.1  rvb 
    274  1.1  rvb     /* prevent future operations on this vfs from succeeding by auto-
    275  1.1  rvb      * unmounting any vfs mounted via this device. This frees user or
    276  1.1  rvb      * sysadm from having to remember where all mount points are located.
    277  1.1  rvb      * Put this before WAKEUPs to avoid queuing new messages between
    278  1.1  rvb      * the WAKEUP and the unmount (which can happen if we're unlucky)
    279  1.1  rvb      */
    280  1.1  rvb     if (mi->mi_rootvp) {
    281  1.1  rvb 	/* Let unmount know this is for real */
    282  1.3  rvb 	VTOC(mi->mi_rootvp)->c_flags |= C_UNMOUNTING;
    283  1.1  rvb 	if (vfs_busy(mi->mi_vfsp, 0, 0))
    284  1.1  rvb 	    return (EBUSY);
    285  1.1  rvb 	coda_unmounting(mi->mi_vfsp);
    286  1.1  rvb 	err = dounmount(mi->mi_vfsp, flag, p);
    287  1.1  rvb 	if (err)
    288  1.1  rvb 	    myprintf(("Error %d unmounting vfs in vcclose(%d)\n",
    289  1.1  rvb 		      err, minor(dev)));
    290  1.1  rvb     }
    291  1.1  rvb 
    292  1.1  rvb     /* Wakeup clients so they can return. */
    293  1.1  rvb     for (vmp = (struct vmsg *)GETNEXT(vcp->vc_requests);
    294  1.1  rvb 	 !EOQ(vmp, vcp->vc_requests);
    295  1.1  rvb 	 vmp = (struct vmsg *)GETNEXT(vmp->vm_chain))
    296  1.3  rvb     {
    297  1.3  rvb 	/* Free signal request messages and don't wakeup cause
    298  1.3  rvb 	   no one is waiting. */
    299  1.1  rvb 	if (vmp->vm_opcode == CODA_SIGNAL) {
    300  1.1  rvb 	    CODA_FREE((caddr_t)vmp->vm_data, (u_int)VC_IN_NO_DATA);
    301  1.1  rvb 	    CODA_FREE((caddr_t)vmp, (u_int)sizeof(struct vmsg));
    302  1.1  rvb 	    continue;
    303  1.1  rvb 	}
    304  1.1  rvb 
    305  1.1  rvb 	wakeup(&vmp->vm_sleep);
    306  1.1  rvb     }
    307  1.1  rvb 
    308  1.1  rvb     for (vmp = (struct vmsg *)GETNEXT(vcp->vc_replys);
    309  1.1  rvb 	 !EOQ(vmp, vcp->vc_replys);
    310  1.1  rvb 	 vmp = (struct vmsg *)GETNEXT(vmp->vm_chain))
    311  1.1  rvb     {
    312  1.1  rvb 	wakeup(&vmp->vm_sleep);
    313  1.1  rvb     }
    314  1.1  rvb 
    315  1.1  rvb     MARK_VC_CLOSED(vcp);
    316  1.1  rvb     return 0;
    317  1.1  rvb }
    318  1.1  rvb 
    319  1.1  rvb int
    320  1.1  rvb vc_nb_read(dev, uiop, flag)
    321  1.1  rvb     dev_t        dev;
    322  1.1  rvb     struct uio  *uiop;
    323  1.1  rvb     int          flag;
    324  1.1  rvb {
    325  1.1  rvb     register struct vcomm *	vcp;
    326  1.1  rvb     register struct vmsg *vmp;
    327  1.1  rvb     int error = 0;
    328  1.3  rvb 
    329  1.1  rvb     ENTRY;
    330  1.1  rvb 
    331  1.3  rvb     if (minor(dev) >= NVCODA || minor(dev) < 0)
    332  1.1  rvb 	return(ENXIO);
    333  1.1  rvb 
    334  1.1  rvb     vcp = &coda_mnttbl[minor(dev)].mi_vcomm;
    335  1.1  rvb     /* Get message at head of request queue. */
    336  1.1  rvb     if (EMPTY(vcp->vc_requests))
    337  1.1  rvb 	return(0);	/* Nothing to read */
    338  1.1  rvb 
    339  1.1  rvb     vmp = (struct vmsg *)GETNEXT(vcp->vc_requests);
    340  1.1  rvb 
    341  1.1  rvb     /* Move the input args into userspace */
    342  1.1  rvb     uiop->uio_rw = UIO_READ;
    343  1.1  rvb     error = uiomove(vmp->vm_data, vmp->vm_inSize, uiop);
    344  1.1  rvb     if (error) {
    345  1.1  rvb 	myprintf(("vcread: error (%d) on uiomove\n", error));
    346  1.1  rvb 	error = EINVAL;
    347  1.1  rvb     }
    348  1.1  rvb 
    349  1.1  rvb #ifdef DIAGNOSTIC
    350  1.1  rvb     if (vmp->vm_chain.forw == 0 || vmp->vm_chain.back == 0)
    351  1.1  rvb 	panic("vc_nb_read: bad chain");
    352  1.1  rvb #endif
    353  1.1  rvb 
    354  1.1  rvb     REMQUE(vmp->vm_chain);
    355  1.3  rvb 
    356  1.3  rvb     /* If request was a signal, free up the message and don't
    357  1.1  rvb        enqueue it in the reply queue. */
    358  1.1  rvb     if (vmp->vm_opcode == CODA_SIGNAL) {
    359  1.3  rvb 	if (codadebug)
    360  1.3  rvb 	    myprintf(("vcread: signal msg (%d, %d)\n",
    361  1.1  rvb 		      vmp->vm_opcode, vmp->vm_unique));
    362  1.1  rvb 	CODA_FREE((caddr_t)vmp->vm_data, (u_int)VC_IN_NO_DATA);
    363  1.1  rvb 	CODA_FREE((caddr_t)vmp, (u_int)sizeof(struct vmsg));
    364  1.1  rvb 	return(error);
    365  1.1  rvb     }
    366  1.1  rvb 
    367  1.1  rvb     vmp->vm_flags |= VM_READ;
    368  1.1  rvb     INSQUE(vmp->vm_chain, vcp->vc_replys);
    369  1.1  rvb 
    370  1.1  rvb     return(error);
    371  1.1  rvb }
    372  1.1  rvb 
    373  1.1  rvb int
    374  1.1  rvb vc_nb_write(dev, uiop, flag)
    375  1.1  rvb     dev_t        dev;
    376  1.1  rvb     struct uio  *uiop;
    377  1.1  rvb     int          flag;
    378  1.3  rvb {
    379  1.1  rvb     register struct vcomm *	vcp;
    380  1.1  rvb     register struct vmsg *vmp;
    381  1.1  rvb     struct coda_out_hdr *out;
    382  1.1  rvb     u_long seq;
    383  1.1  rvb     u_long opcode;
    384  1.1  rvb     int buf[2];
    385  1.1  rvb     int error = 0;
    386  1.3  rvb 
    387  1.1  rvb     ENTRY;
    388  1.1  rvb 
    389  1.3  rvb     if (minor(dev) >= NVCODA || minor(dev) < 0)
    390  1.1  rvb 	return(ENXIO);
    391  1.1  rvb 
    392  1.1  rvb     vcp = &coda_mnttbl[minor(dev)].mi_vcomm;
    393  1.1  rvb 
    394  1.1  rvb     /* Peek at the opcode, unique without transfering the data. */
    395  1.1  rvb     uiop->uio_rw = UIO_WRITE;
    396  1.1  rvb     error = uiomove((caddr_t)buf, sizeof(int) * 2, uiop);
    397  1.1  rvb     if (error) {
    398  1.1  rvb 	myprintf(("vcwrite: error (%d) on uiomove\n", error));
    399  1.1  rvb 	return(EINVAL);
    400  1.1  rvb     }
    401  1.1  rvb 
    402  1.3  rvb     opcode = buf[0];
    403  1.1  rvb     seq = buf[1];
    404  1.1  rvb 
    405  1.1  rvb     if (codadebug)
    406  1.1  rvb 	myprintf(("vcwrite got a call for %ld.%ld\n", opcode, seq));
    407  1.1  rvb 
    408  1.1  rvb     if (DOWNCALL(opcode)) {
    409  1.1  rvb 	union outputArgs pbuf;
    410  1.3  rvb 
    411  1.1  rvb 	/* get the rest of the data. */
    412  1.1  rvb 	uiop->uio_rw = UIO_WRITE;
    413  1.1  rvb 	error = uiomove((caddr_t)&pbuf.coda_purgeuser.oh.result, sizeof(pbuf) - (sizeof(int)*2), uiop);
    414  1.1  rvb 	if (error) {
    415  1.1  rvb 	    myprintf(("vcwrite: error (%d) on uiomove (Op %ld seq %ld)\n",
    416  1.1  rvb 		      error, opcode, seq));
    417  1.1  rvb 	    return(EINVAL);
    418  1.1  rvb 	    }
    419  1.1  rvb 
    420  1.1  rvb 	return handleDownCall(opcode, &pbuf);
    421  1.1  rvb     }
    422  1.1  rvb 
    423  1.1  rvb     /* Look for the message on the (waiting for) reply queue. */
    424  1.1  rvb     for (vmp = (struct vmsg *)GETNEXT(vcp->vc_replys);
    425  1.1  rvb 	 !EOQ(vmp, vcp->vc_replys);
    426  1.1  rvb 	 vmp = (struct vmsg *)GETNEXT(vmp->vm_chain))
    427  1.1  rvb     {
    428  1.1  rvb 	if (vmp->vm_unique == seq) break;
    429  1.3  rvb     }
    430  1.1  rvb 
    431  1.1  rvb     if (EOQ(vmp, vcp->vc_replys)) {
    432  1.1  rvb 	if (codadebug)
    433  1.1  rvb 	    myprintf(("vcwrite: msg (%ld, %ld) not found\n", opcode, seq));
    434  1.1  rvb 
    435  1.1  rvb 	return(ESRCH);
    436  1.1  rvb 	}
    437  1.1  rvb 
    438  1.1  rvb     /* Remove the message from the reply queue */
    439  1.3  rvb     REMQUE(vmp->vm_chain);
    440  1.1  rvb 
    441  1.1  rvb     /* move data into response buffer. */
    442  1.1  rvb     out = (struct coda_out_hdr *)vmp->vm_data;
    443  1.1  rvb     /* Don't need to copy opcode and uniquifier. */
    444  1.1  rvb 
    445  1.1  rvb     /* get the rest of the data. */
    446  1.1  rvb     if (vmp->vm_outSize < uiop->uio_resid) {
    447  1.1  rvb 	myprintf(("vcwrite: more data than asked for (%d < %d)\n",
    448  1.1  rvb 		  vmp->vm_outSize, uiop->uio_resid));
    449  1.1  rvb 	wakeup(&vmp->vm_sleep); 	/* Notify caller of the error. */
    450  1.1  rvb 	return(EINVAL);
    451  1.1  rvb     }
    452  1.1  rvb 
    453  1.1  rvb     buf[0] = uiop->uio_resid; 	/* Save this value. */
    454  1.1  rvb     uiop->uio_rw = UIO_WRITE;
    455  1.1  rvb     error = uiomove((caddr_t) &out->result, vmp->vm_outSize - (sizeof(int) * 2), uiop);
    456  1.1  rvb     if (error) {
    457  1.1  rvb 	myprintf(("vcwrite: error (%d) on uiomove (op %ld seq %ld)\n",
    458  1.1  rvb 		  error, opcode, seq));
    459  1.1  rvb 	return(EINVAL);
    460  1.1  rvb     }
    461  1.1  rvb 
    462  1.1  rvb     /* I don't think these are used, but just in case. */
    463  1.1  rvb     /* XXX - aren't these two already correct? -bnoble */
    464  1.1  rvb     out->opcode = opcode;
    465  1.1  rvb     out->unique = seq;
    466  1.1  rvb     vmp->vm_outSize	= buf[0];	/* Amount of data transferred? */
    467  1.1  rvb     vmp->vm_flags |= VM_WRITE;
    468  1.1  rvb     wakeup(&vmp->vm_sleep);
    469  1.1  rvb 
    470  1.1  rvb     return(0);
    471  1.1  rvb }
    472  1.1  rvb 
    473  1.1  rvb int
    474  1.1  rvb vc_nb_ioctl(dev, cmd, addr, flag, p)
    475  1.1  rvb     dev_t         dev;
    476  1.1  rvb     int           cmd;
    477  1.1  rvb     caddr_t       addr;
    478  1.1  rvb     int           flag;
    479  1.1  rvb     struct proc  *p;
    480  1.1  rvb {
    481  1.3  rvb     ENTRY;
    482  1.3  rvb 
    483  1.3  rvb     switch(cmd) {
    484  1.1  rvb     case CODARESIZE: {
    485  1.1  rvb 	struct coda_resize *data = (struct coda_resize *)addr;
    486  1.3  rvb 	return(coda_nc_resize(data->hashsize, data->heapsize, IS_DOWNCALL));
    487  1.3  rvb 	break;
    488  1.3  rvb     }
    489  1.1  rvb     case CODASTATS:
    490  1.1  rvb 	if (coda_nc_use) {
    491  1.1  rvb 	    coda_nc_gather_stats();
    492  1.1  rvb 	    return(0);
    493  1.1  rvb 	} else {
    494  1.3  rvb 	    return(ENODEV);
    495  1.3  rvb 	}
    496  1.3  rvb 	break;
    497  1.1  rvb     case CODAPRINT:
    498  1.1  rvb 	if (coda_nc_use) {
    499  1.1  rvb 	    print_coda_nc();
    500  1.1  rvb 	    return(0);
    501  1.1  rvb 	} else {
    502  1.1  rvb 	    return(ENODEV);
    503  1.1  rvb 	}
    504  1.1  rvb 	break;
    505  1.1  rvb     default :
    506  1.1  rvb 	return(EINVAL);
    507  1.1  rvb 	break;
    508  1.1  rvb     }
    509  1.1  rvb }
    510  1.1  rvb 
    511  1.1  rvb int
    512  1.1  rvb vc_nb_poll(dev, events, p)
    513  1.1  rvb     dev_t         dev;
    514  1.1  rvb     int           events;
    515  1.1  rvb     struct proc  *p;
    516  1.1  rvb {
    517  1.1  rvb     register struct vcomm *vcp;
    518  1.1  rvb     int event_msk = 0;
    519  1.3  rvb 
    520  1.1  rvb     ENTRY;
    521  1.1  rvb 
    522  1.3  rvb     if (minor(dev) >= NVCODA || minor(dev) < 0)
    523  1.1  rvb 	return(ENXIO);
    524  1.1  rvb 
    525  1.1  rvb     vcp = &coda_mnttbl[minor(dev)].mi_vcomm;
    526  1.1  rvb 
    527  1.1  rvb     event_msk = events & (POLLIN|POLLRDNORM);
    528  1.1  rvb     if (!event_msk)
    529  1.1  rvb 	return(0);
    530  1.1  rvb 
    531  1.1  rvb     if (!EMPTY(vcp->vc_requests))
    532  1.1  rvb 	return(events & (POLLIN|POLLRDNORM));
    533  1.1  rvb 
    534  1.1  rvb     selrecord(p, &(vcp->vc_selproc));
    535  1.1  rvb 
    536  1.1  rvb     return(0);
    537  1.1  rvb }
    538  1.1  rvb 
    539  1.3  rvb /*
    540  1.1  rvb  * Statistics
    541  1.1  rvb  */
    542  1.1  rvb struct coda_clstat coda_clstat;
    543  1.1  rvb 
    544  1.1  rvb /*
    545  1.1  rvb  * Key question: whether to sleep interuptably or uninteruptably when
    546  1.1  rvb  * waiting for Venus.  The former seems better (cause you can ^C a
    547  1.1  rvb  * job), but then GNU-EMACS completion breaks. Use tsleep with no
    548  1.1  rvb  * timeout, and no longjmp happens. But, when sleeping
    549  1.1  rvb  * "uninterruptibly", we don't get told if it returns abnormally
    550  1.1  rvb  * (e.g. kill -9).
    551  1.3  rvb  */
    552  1.1  rvb 
    553  1.3  rvb /* If you want this to be interruptible, set this to > PZERO */
    554  1.1  rvb int coda_call_sleep = PZERO - 1;
    555  1.1  rvb #ifdef	CTL_C
    556  1.1  rvb int coda_pcatch = PCATCH;
    557  1.1  rvb #else
    558  1.3  rvb #endif
    559  1.3  rvb 
    560  1.1  rvb int
    561  1.1  rvb coda_call(mntinfo, inSize, outSize, buffer)
    562  1.1  rvb      struct coda_mntinfo *mntinfo; int inSize; int *outSize; caddr_t buffer;
    563  1.1  rvb {
    564  1.1  rvb 	struct vcomm *vcp;
    565  1.1  rvb 	struct vmsg *vmp;
    566  1.4  rvb 	int error;
    567  1.1  rvb #ifdef	CTL_C
    568  1.4  rvb 	struct proc *p = curproc;
    569  1.1  rvb 	sigset_t psig_omask;
    570  1.1  rvb 	int i;
    571  1.1  rvb 	psig_omask = p->p_siglist;	/* array assignment */
    572  1.1  rvb #endif
    573  1.1  rvb 	if (mntinfo == NULL) {
    574  1.1  rvb 	    /* Unlikely, but could be a race condition with a dying warden */
    575  1.1  rvb 	    return ENODEV;
    576  1.1  rvb 	}
    577  1.3  rvb 
    578  1.3  rvb 	vcp = &(mntinfo->mi_vcomm);
    579  1.1  rvb 
    580  1.1  rvb 	coda_clstat.ncalls++;
    581  1.1  rvb 	coda_clstat.reqs[((struct coda_in_hdr *)buffer)->opcode]++;
    582  1.1  rvb 
    583  1.3  rvb 	if (!VC_OPEN(vcp))
    584  1.1  rvb 	    return(ENODEV);
    585  1.1  rvb 
    586  1.1  rvb 	CODA_ALLOC(vmp,struct vmsg *,sizeof(struct vmsg));
    587  1.1  rvb 	/* Format the request message. */
    588  1.1  rvb 	vmp->vm_data = buffer;
    589  1.1  rvb 	vmp->vm_flags = 0;
    590  1.3  rvb 	vmp->vm_inSize = inSize;
    591  1.1  rvb 	vmp->vm_outSize
    592  1.3  rvb 	    = *outSize ? *outSize : inSize; /* |buffer| >= inSize */
    593  1.1  rvb 	vmp->vm_opcode = ((struct coda_in_hdr *)buffer)->opcode;
    594  1.1  rvb 	vmp->vm_unique = ++vcp->vc_seq;
    595  1.1  rvb 	if (codadebug)
    596  1.1  rvb 	    myprintf(("Doing a call for %d.%d\n",
    597  1.3  rvb 		      vmp->vm_opcode, vmp->vm_unique));
    598  1.1  rvb 
    599  1.1  rvb 	/* Fill in the common input args. */
    600  1.1  rvb 	((struct coda_in_hdr *)buffer)->unique = vmp->vm_unique;
    601  1.1  rvb 
    602  1.1  rvb 	/* Append msg to request queue and poke Venus. */
    603  1.1  rvb 	INSQUE(vmp->vm_chain, vcp->vc_requests);
    604  1.1  rvb 	selwakeup(&(vcp->vc_selproc));
    605  1.1  rvb 
    606  1.1  rvb 	/* We can be interrupted while we wait for Venus to process
    607  1.1  rvb 	 * our request.  If the interrupt occurs before Venus has read
    608  1.1  rvb 	 * the request, we dequeue and return. If it occurs after the
    609  1.1  rvb 	 * read but before the reply, we dequeue, send a signal
    610  1.1  rvb 	 * message, and return. If it occurs after the reply we ignore
    611  1.1  rvb 	 * it. In no case do we want to restart the syscall.  If it
    612  1.1  rvb 	 * was interrupted by a venus shutdown (vcclose), return
    613  1.1  rvb 	 * ENODEV.  */
    614  1.3  rvb 
    615  1.1  rvb 	/* Ignore return, We have to check anyway */
    616  1.1  rvb #ifdef	CTL_C
    617  1.1  rvb 	/* This is work in progress.  Setting coda_pcatch lets tsleep reawaken
    618  1.1  rvb 	   on a ^c or ^z.  The problem is that emacs sets certain interrupts
    619  1.1  rvb 	   as SA_RESTART.  This means that we should exit sleep handle the
    620  1.1  rvb 	   "signal" and then go to sleep again.  Mostly this is done by letting
    621  1.1  rvb 	   the syscall complete and be restarted.  We are not idempotent and
    622  1.1  rvb 	   can not do this.  A better solution is necessary.
    623  1.3  rvb 	 */
    624  1.1  rvb 	i = 0;
    625  1.1  rvb 	do {
    626  1.1  rvb 	    error = tsleep(&vmp->vm_sleep, (coda_call_sleep|coda_pcatch), "coda_call", hz*2);
    627  1.3  rvb 	    if (error == 0)
    628  1.4  rvb 	    	break;
    629  1.4  rvb 	    else if (error == EWOULDBLOCK) {
    630  1.3  rvb 		    printf("coda_call: tsleep TIMEOUT %d sec\n", 2+2*i);
    631  1.1  rvb     	    } else if (sigismember(&p->p_siglist, SIGIO)) {
    632  1.4  rvb 		    sigaddset(&p->p_sigmask, SIGIO);
    633  1.4  rvb 		    printf("coda_call: tsleep returns %d SIGIO, cnt %d\n", error, i);
    634  1.4  rvb 	    } else {
    635  1.4  rvb 		    sigset_t tmp;
    636  1.3  rvb 		    tmp = p->p_siglist;		/* array assignment */
    637  1.4  rvb 		    sigminusset(&p->p_sigmask, &tmp);
    638  1.4  rvb 
    639  1.4  rvb 		    printf("coda_call: tsleep returns %d, cnt %d\n", error, i);
    640  1.4  rvb 		    printf("coda_call: siglist = %x.%x.%x.%x, sigmask = %x.%x.%x.%x, mask %x.%x.%x.%x\n",
    641  1.4  rvb 			    p->p_siglist.__bits[0], p->p_siglist.__bits[1],
    642  1.4  rvb 			    p->p_siglist.__bits[2], p->p_siglist.__bits[3],
    643  1.1  rvb 			    p->p_sigmask.__bits[0], p->p_sigmask.__bits[1],
    644  1.4  rvb 			    p->p_sigmask.__bits[2], p->p_sigmask.__bits[3],
    645  1.4  rvb 			    tmp.__bits[0], tmp.__bits[1], tmp.__bits[2], tmp.__bits[3]);
    646  1.4  rvb 		    break;
    647  1.4  rvb 		    sigminusset(&p->p_sigmask, &p->p_siglist);
    648  1.4  rvb 		    printf("coda_call: siglist = %x.%x.%x.%x, sigmask = %x.%x.%x.%x\n",
    649  1.4  rvb 			    p->p_siglist.__bits[0], p->p_siglist.__bits[1],
    650  1.1  rvb 			    p->p_siglist.__bits[2], p->p_siglist.__bits[3],
    651  1.1  rvb 			    p->p_sigmask.__bits[0], p->p_sigmask.__bits[1],
    652  1.4  rvb 			    p->p_sigmask.__bits[2], p->p_sigmask.__bits[3]);
    653  1.1  rvb 	    }
    654  1.3  rvb 	} while (error && i++ < 128);
    655  1.1  rvb 	p->p_siglist = psig_omask;	/* array assignment */
    656  1.1  rvb #else
    657  1.1  rvb 	(void) tsleep(&vmp->vm_sleep, coda_call_sleep, "coda_call", 0);
    658  1.1  rvb #endif
    659  1.1  rvb 	if (VC_OPEN(vcp)) {	/* Venus is still alive */
    660  1.1  rvb  	/* Op went through, interrupt or not... */
    661  1.1  rvb 	    if (vmp->vm_flags & VM_WRITE) {
    662  1.1  rvb 		error = 0;
    663  1.1  rvb 		*outSize = vmp->vm_outSize;
    664  1.1  rvb 	    }
    665  1.3  rvb 
    666  1.1  rvb 	    else if (!(vmp->vm_flags & VM_READ)) {
    667  1.1  rvb 		/* Interrupted before venus read it. */
    668  1.1  rvb 		if (codadebug||1)
    669  1.1  rvb 		    myprintf(("interrupted before read: op = %d.%d, flags = %x\n",
    670  1.1  rvb 			   vmp->vm_opcode, vmp->vm_unique, vmp->vm_flags));
    671  1.1  rvb 		REMQUE(vmp->vm_chain);
    672  1.1  rvb 		error = EINTR;
    673  1.1  rvb 	    }
    674  1.1  rvb 
    675  1.1  rvb 	    else {
    676  1.3  rvb 		/* (!(vmp->vm_flags & VM_WRITE)) means interrupted after
    677  1.1  rvb                    upcall started */
    678  1.1  rvb 		/* Interrupted after start of upcall, send venus a signal */
    679  1.3  rvb 		struct coda_in_hdr *dog;
    680  1.1  rvb 		struct vmsg *svmp;
    681  1.1  rvb 
    682  1.1  rvb 		if (codadebug||1)
    683  1.1  rvb 		    myprintf(("Sending Venus a signal: op = %d.%d, flags = %x\n",
    684  1.1  rvb 			   vmp->vm_opcode, vmp->vm_unique, vmp->vm_flags));
    685  1.1  rvb 
    686  1.3  rvb 		REMQUE(vmp->vm_chain);
    687  1.1  rvb 		error = EINTR;
    688  1.3  rvb 
    689  1.3  rvb 		CODA_ALLOC(svmp, struct vmsg *, sizeof (struct vmsg));
    690  1.1  rvb 
    691  1.1  rvb 		CODA_ALLOC((svmp->vm_data), char *, sizeof (struct coda_in_hdr));
    692  1.3  rvb 		dog = (struct coda_in_hdr *)svmp->vm_data;
    693  1.1  rvb 
    694  1.3  rvb 		svmp->vm_flags = 0;
    695  1.3  rvb 		dog->opcode = svmp->vm_opcode = CODA_SIGNAL;
    696  1.1  rvb 		dog->unique = svmp->vm_unique = vmp->vm_unique;
    697  1.3  rvb 		svmp->vm_inSize = sizeof (struct coda_in_hdr);
    698  1.3  rvb /*??? rvb */	svmp->vm_outSize = sizeof (struct coda_in_hdr);
    699  1.1  rvb 
    700  1.1  rvb 		if (codadebug)
    701  1.1  rvb 		    myprintf(("coda_call: enqueing signal msg (%d, %d)\n",
    702  1.1  rvb 			   svmp->vm_opcode, svmp->vm_unique));
    703  1.1  rvb 
    704  1.1  rvb 		/* insert at head of queue! */
    705  1.1  rvb 		INSQUE(svmp->vm_chain, vcp->vc_requests);
    706  1.1  rvb 		selwakeup(&(vcp->vc_selproc));
    707  1.1  rvb 	    }
    708  1.3  rvb 	}
    709  1.1  rvb 
    710  1.1  rvb 	else {	/* If venus died (!VC_OPEN(vcp)) */
    711  1.1  rvb 	    if (codadebug)
    712  1.1  rvb 		myprintf(("vcclose woke op %d.%d flags %d\n",
    713  1.1  rvb 		       vmp->vm_opcode, vmp->vm_unique, vmp->vm_flags));
    714  1.1  rvb 
    715  1.3  rvb 		error = ENODEV;
    716  1.1  rvb 	}
    717  1.1  rvb 
    718  1.3  rvb 	CODA_FREE(vmp, sizeof(struct vmsg));
    719  1.1  rvb 
    720  1.1  rvb 	if (!error)
    721  1.4  rvb 		error = ((struct coda_out_hdr *)buffer)->result;
    722           	return(error);
    723           }
    724           
    725