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