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