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