1 /*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License (the "License").
6 * You may not use this file except in compliance with the License.
7 *
8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 * or http://www.opensolaris.org/os/licensing.
10 * See the License for the specific language governing permissions
11 * and limitations under the License.
12 *
13 * When distributing Covered Code, include this CDDL HEADER in each
14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 * If applicable, add the following below this CDDL HEADER, with the
16 * fields enclosed by brackets "[]" replaced with your own identifying
17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 *
19 * CDDL HEADER END
20 */
21
22 /*
23 * Copyright 2009 Sun Microsystems, Inc. All rights reserved.
24 * Use is subject to license terms.
25 */
26
27
28 /*
29 * srn Provide apm-like interfaces to Xorg
30 */
31
32 #include <sys/types.h>
33 #include <sys/errno.h>
34 #include <sys/modctl.h>
35 #include <sys/conf.h> /* driver flags and functions */
36 #include <sys/open.h> /* OTYP_CHR definition */
37 #include <sys/stat.h> /* S_IFCHR definition */
38 #include <sys/pathname.h> /* name -> dev_info xlation */
39 #include <sys/kmem.h> /* memory alloc stuff */
40 #include <sys/debug.h>
41 #include <sys/pm.h>
42 #include <sys/ddi.h>
43 #include <sys/sunddi.h>
44 #include <sys/epm.h>
45 #include <sys/vfs.h>
46 #include <sys/mode.h>
47 #include <sys/mkdev.h>
48 #include <sys/promif.h>
49 #include <sys/consdev.h>
50 #include <sys/ddi_impldefs.h>
51 #include <sys/poll.h>
52 #include <sys/note.h>
53 #include <sys/taskq.h>
54 #include <sys/policy.h>
55 #include <sys/srn.h>
56
57 /*
58 * Minor number is instance<<8 + clone minor from range 1-255;
59 * But only one will be allocated
60 */
61 #define SRN_MINOR_TO_CLONE(minor) ((minor) & (SRN_MAX_CLONE - 1))
62 #define SU 0x002
63 #define SG 0x004
64
65 extern kmutex_t srn_clone_lock; /* protects srn_clones array */
66 extern kcondvar_t srn_clones_cv[SRN_MAX_CLONE];
67 extern uint_t srn_poll_cnt[SRN_MAX_CLONE];
68
69 /*
70 * The soft state of the srn driver. Since there will only be
71 * one of these, just reference it through a static struct.
72 */
73 static struct srnstate {
74 dev_info_t *srn_dip; /* ptr to our dev_info node */
75 int srn_instance; /* for ddi_get_instance() */
76 uchar_t srn_clones[SRN_MAX_CLONE]; /* unique opens */
77 struct cred *srn_cred[SRN_MAX_CLONE]; /* cred for each open */
78 int srn_type[SRN_MAX_CLONE]; /* type of handshake */
79 int srn_delivered[SRN_MAX_CLONE];
80 srn_event_info_t srn_pending[SRN_MAX_CLONE];
81 int srn_fault[SRN_MAX_CLONE];
82 } srn = { NULL, -1};
83 typedef struct srnstate *srn_state_t;
84
85 kcondvar_t srn_clones_cv[SRN_MAX_CLONE];
86 uint_t srn_poll_cnt[SRN_MAX_CLONE]; /* count of events for poll */
87 int srn_apm_count;
88 int srn_autosx_count;
89 /* Number of seconds to wait for clients to ack a poll */
90 int srn_timeout = 10;
91
92 struct pollhead srn_pollhead[SRN_MAX_CLONE];
93
94 static int srn_open(dev_t *, int, int, cred_t *);
95 static int srn_close(dev_t, int, int, cred_t *);
96 static int srn_ioctl(dev_t, int, intptr_t, int, cred_t *, int *);
97 static int srn_chpoll(dev_t, short, int, short *, struct pollhead **);
98
99 static struct cb_ops srn_cb_ops = {
100 srn_open, /* open */
101 srn_close, /* close */
102 nodev, /* strategy */
103 nodev, /* print */
104 nodev, /* dump */
105 nodev, /* read */
106 nodev, /* write */
107 srn_ioctl, /* ioctl */
108 nodev, /* devmap */
109 nodev, /* mmap */
110 nodev, /* segmap */
111 srn_chpoll, /* poll */
112 ddi_prop_op, /* prop_op */
113 NULL, /* streamtab */
114 D_NEW | D_MP /* driver compatibility flag */
115 };
116
117 static int srn_getinfo(dev_info_t *dip, ddi_info_cmd_t infocmd, void *arg,
118 void **result);
119 static int srn_attach(dev_info_t *dip, ddi_attach_cmd_t cmd);
120 static int srn_detach(dev_info_t *dip, ddi_detach_cmd_t cmd);
121 static void srn_notify(int type, int event);
122
123 static struct dev_ops srn_ops = {
124 DEVO_REV, /* devo_rev */
125 0, /* refcnt */
126 srn_getinfo, /* info */
127 nulldev, /* identify */
128 nulldev, /* probe */
129 srn_attach, /* attach */
130 srn_detach, /* detach */
131 nodev, /* reset */
132 &srn_cb_ops, /* driver operations */
133 NULL, /* bus operations */
134 NULL, /* power */
135 ddi_quiesce_not_needed, /* quiesce */
136 };
137
138 static struct modldrv modldrv = {
139 &mod_driverops,
140 "srn driver",
141 &srn_ops
142 };
143
144 static struct modlinkage modlinkage = {
145 MODREV_1, &modldrv, 0
146 };
147
148 /* Local functions */
149
150 int
151 _init(void)
152 {
153 return (mod_install(&modlinkage));
154 }
155
156 int
157 _fini(void)
158 {
159 return (mod_remove(&modlinkage));
160 }
161
162 int
163 _info(struct modinfo *modinfop)
164 {
165 return (mod_info(&modlinkage, modinfop));
166 }
167
168 static int
169 srn_attach(dev_info_t *dip, ddi_attach_cmd_t cmd)
170 {
171 int i;
172 extern void (*srn_signal)(int, int);
173
174 switch (cmd) {
175
176 case DDI_ATTACH:
177 if (srn.srn_instance != -1) /* Only allow one instance */
178 return (DDI_FAILURE);
179 srn.srn_instance = ddi_get_instance(dip);
180 if (ddi_create_minor_node(dip, "srn", S_IFCHR,
181 (srn.srn_instance << 8) + 0, DDI_PSEUDO, 0)
182 != DDI_SUCCESS) {
183 return (DDI_FAILURE);
184 }
185 srn.srn_dip = dip; /* srn_init and getinfo depend on it */
186
187 for (i = 0; i < SRN_MAX_CLONE; i++)
188 cv_init(&srn_clones_cv[i], NULL, CV_DEFAULT, NULL);
189
190 srn.srn_instance = ddi_get_instance(dip);
191 mutex_enter(&srn_clone_lock);
192 srn_signal = srn_notify;
193 mutex_exit(&srn_clone_lock);
194 ddi_report_dev(dip);
195 return (DDI_SUCCESS);
196
197 default:
198 return (DDI_FAILURE);
199 }
200 }
201
202 /* ARGSUSED */
203 static int
204 srn_detach(dev_info_t *dip, ddi_detach_cmd_t cmd)
205 {
206 int i;
207 extern int srn_inuse;
208 extern void (*srn_signal)(int, int);
209
210 switch (cmd) {
211 case DDI_DETACH:
212
213 mutex_enter(&srn_clone_lock);
214 while (srn_inuse) {
215 mutex_exit(&srn_clone_lock);
216 delay(1);
217 mutex_enter(&srn_clone_lock);
218 }
219 srn_signal = NULL;
220 mutex_exit(&srn_clone_lock);
221
222 for (i = 0; i < SRN_MAX_CLONE; i++)
223 cv_destroy(&srn_clones_cv[i]);
224
225 ddi_remove_minor_node(dip, NULL);
226 srn.srn_instance = -1;
227 return (DDI_SUCCESS);
228
229 default:
230 return (DDI_FAILURE);
231 }
232 }
233
234
235 #ifdef DEBUG
236 char *srn_cmd_string;
237 int srn_cmd;
238 #endif
239
240 /*
241 * Returns true if permission granted by credentials
242 * XXX
243 */
244 static int
245 srn_perms(int perm, cred_t *cr)
246 {
247 if ((perm & SU) && secpolicy_power_mgmt(cr) == 0) /* privileged? */
248 return (1);
249 if ((perm & SG) && (crgetgid(cr) == 0)) /* group 0 is ok */
250 return (1);
251 return (0);
252 }
253
254 static int
255 srn_chpoll(dev_t dev, short events, int anyyet, short *reventsp,
256 struct pollhead **phpp)
257 {
258 extern struct pollhead srn_pollhead[];
259 int clone;
260
261 clone = SRN_MINOR_TO_CLONE(getminor(dev));
262 if ((events & (POLLIN | POLLRDNORM)) && srn_poll_cnt[clone]) {
263 *reventsp |= (POLLIN | POLLRDNORM);
264 } else {
265 *reventsp = 0;
266 if (!anyyet) {
267 *phpp = &srn_pollhead[clone];
268 }
269 }
270 return (0);
271 }
272
273 /*ARGSUSED*/
274 static int
275 srn_getinfo(dev_info_t *dip, ddi_info_cmd_t infocmd, void *arg, void **result)
276 {
277 dev_t dev;
278 int instance;
279
280 switch (infocmd) {
281 case DDI_INFO_DEVT2DEVINFO:
282 if (srn.srn_instance == -1)
283 return (DDI_FAILURE);
284 *result = srn.srn_dip;
285 return (DDI_SUCCESS);
286
287 case DDI_INFO_DEVT2INSTANCE:
288 dev = (dev_t)arg;
289 instance = getminor(dev) >> 8;
290 *result = (void *)(uintptr_t)instance;
291 return (DDI_SUCCESS);
292
293 default:
294 return (DDI_FAILURE);
295 }
296 }
297
298
299 /*ARGSUSED1*/
300 static int
301 srn_open(dev_t *devp, int flag, int otyp, cred_t *cr)
302 {
303 int clone;
304
305 if (otyp != OTYP_CHR)
306 return (EINVAL);
307
308 mutex_enter(&srn_clone_lock);
309 for (clone = 1; clone < SRN_MAX_CLONE - 1; clone++)
310 if (!srn.srn_clones[clone])
311 break;
312
313 if (clone == SRN_MAX_CLONE) {
314 mutex_exit(&srn_clone_lock);
315 return (ENXIO);
316 }
317 srn.srn_cred[clone] = cr;
318 ASSERT(srn_apm_count >= 0);
319 srn_apm_count++;
320 srn.srn_type[clone] = SRN_TYPE_APM;
321 crhold(cr);
322
323 *devp = makedevice(getmajor(*devp), (srn.srn_instance << 8) +
324 clone);
325 srn.srn_clones[clone] = 1;
326 srn.srn_cred[clone] = cr;
327 crhold(cr);
328 mutex_exit(&srn_clone_lock);
329 PMD(PMD_SX, ("srn open OK\n"))
330 return (0);
331 }
332
333 /*ARGSUSED1*/
334 static int
335 srn_close(dev_t dev, int flag, int otyp, cred_t *cr)
336 {
337 int clone;
338
339 if (otyp != OTYP_CHR)
340 return (EINVAL);
341
342 clone = SRN_MINOR_TO_CLONE(getminor(dev));
343 PMD(PMD_SX, ("srn_close: minor %x, clone %x\n", getminor(dev),
344 clone))
345 mutex_enter(&srn_clone_lock);
346 crfree(srn.srn_cred[clone]);
347 srn.srn_cred[clone] = 0;
348 srn_poll_cnt[clone] = 0;
349 srn.srn_fault[clone] = 0;
350 if (srn.srn_pending[clone].ae_type || srn.srn_delivered[clone]) {
351 srn.srn_pending[clone].ae_type = 0;
352 srn.srn_delivered[clone] = 0;
353 cv_signal(&srn_clones_cv[clone]);
354 }
355 switch (srn.srn_type[clone]) {
356 case SRN_TYPE_AUTOSX:
357 ASSERT(srn_autosx_count);
358 srn_autosx_count--;
359 break;
360 case SRN_TYPE_APM:
361 ASSERT(srn_apm_count);
362 srn_apm_count--;
363 break;
364 default:
365 ASSERT(0);
366 return (EINVAL);
367 }
368 srn.srn_clones[clone] = 0;
369 mutex_exit(&srn_clone_lock);
370 return (0);
371 }
372
373 /*ARGSUSED*/
374 static int
375 srn_ioctl(dev_t dev, int cmd, intptr_t arg, int mode, cred_t *cr, int *rval_p)
376 {
377 int clone = SRN_MINOR_TO_CLONE(getminor(dev));
378
379 PMD(PMD_SX, ("ioctl: %x: begin\n", cmd))
380
381 switch (cmd) {
382 case SRN_IOC_NEXTEVENT:
383 case SRN_IOC_SUSPEND:
384 case SRN_IOC_RESUME:
385 case SRN_IOC_AUTOSX:
386 break;
387 default:
388 return (ENOTTY);
389 }
390
391 if (!srn_perms(SU | SG, srn.srn_cred[clone])) {
392 return (EPERM);
393 }
394 switch (cmd) {
395 case SRN_IOC_AUTOSX:
396 PMD(PMD_SX, ("SRN_IOC_AUTOSX entered\n"))
397 mutex_enter(&srn_clone_lock);
398 if (!srn.srn_clones[clone]) {
399 PMD(PMD_SX, (" ioctl !srn_clones--EINVAL\n"))
400 mutex_exit(&srn_clone_lock);
401 return (EINVAL);
402 }
403 if (srn.srn_pending[clone].ae_type) {
404 PMD(PMD_SX, ("AUTOSX while pending--EBUSY\n"))
405 mutex_exit(&srn_clone_lock);
406 return (EBUSY);
407 }
408 if (srn.srn_type[clone] == SRN_TYPE_AUTOSX) {
409 PMD(PMD_SX, ("AUTOSX already--EBUSY\n"))
410 mutex_exit(&srn_clone_lock);
411 return (EBUSY);
412 }
413 ASSERT(srn.srn_type[clone] == SRN_TYPE_APM);
414 srn.srn_type[clone] = SRN_TYPE_AUTOSX;
415 srn.srn_fault[clone] = 0;
416 srn_apm_count--;
417 ASSERT(srn_apm_count >= 0);
418 ASSERT(srn_autosx_count >= 0);
419 srn_autosx_count++;
420 mutex_exit(&srn_clone_lock);
421 PMD(PMD_SX, ("SRN_IOC_AUTOSX returns success\n"))
422 return (0);
423
424 case SRN_IOC_NEXTEVENT:
425 /*
426 * return the next suspend or resume event; there should
427 * be one, cause we only get called if we've signalled a
428 * poll data completion
429 * then wake up the kernel thread sleeping for the delivery
430 */
431 PMD(PMD_SX, ("SRN_IOC_NEXTEVENT entered\n"))
432 if (srn.srn_fault[clone]) {
433 PMD(PMD_SX, ("SRN_IOC_NEXTEVENT clone %d fault "
434 "cleared\n", clone))
435 srn.srn_fault[clone] = 0;
436 }
437 mutex_enter(&srn_clone_lock);
438 if (srn_poll_cnt[clone] == 0) {
439 mutex_exit(&srn_clone_lock);
440 PMD(PMD_SX, ("SRN_IOC_NEXTEVENT clone %d "
441 "EWOULDBLOCK\n", clone))
442 return (EWOULDBLOCK);
443 }
444 ASSERT(srn.srn_pending[clone].ae_type);
445 if (ddi_copyout(&srn.srn_pending[clone], (void *)arg,
446 sizeof (srn_event_info_t), mode) != 0) {
447 mutex_exit(&srn_clone_lock);
448 PMD(PMD_SX, ("SRN_IOC_NEXTEVENT clone %d EFAULT\n",
449 clone))
450 return (EFAULT);
451 }
452 if (srn.srn_type[clone] == SRN_TYPE_APM)
453 srn.srn_delivered[clone] =
454 srn.srn_pending[clone].ae_type;
455 PMD(PMD_SX, ("SRN_IOC_NEXTEVENT clone %d delivered %x\n",
456 clone, srn.srn_pending[clone].ae_type))
457 srn_poll_cnt[clone] = 0;
458 mutex_exit(&srn_clone_lock);
459 return (0);
460
461 case SRN_IOC_SUSPEND:
462 /* ack suspend */
463 PMD(PMD_SX, ("SRN_IOC_SUSPEND entered clone %d\n", clone))
464 if (srn.srn_fault[clone]) {
465 PMD(PMD_SX, ("SRN_IOC_SUSPEND clone %d fault "
466 "cleared\n", clone))
467 srn.srn_fault[clone] = 0;
468 }
469 mutex_enter(&srn_clone_lock);
470 if (srn.srn_delivered[clone] != SRN_SUSPEND_REQ) {
471 mutex_exit(&srn_clone_lock);
472 PMD(PMD_SX, ("SRN_IOC_SUSPEND EINVAL\n"))
473 return (EINVAL);
474 }
475 srn.srn_delivered[clone] = 0;
476 srn.srn_pending[clone].ae_type = 0;
477 /* notify the kernel suspend thread to continue */
478 PMD(PMD_SX, ("SRN_IOC_SUSPEND clone %d ok\n", clone))
479 cv_signal(&srn_clones_cv[clone]);
480 mutex_exit(&srn_clone_lock);
481 return (0);
482
483 case SRN_IOC_RESUME:
484 /* ack resume */
485 PMD(PMD_SX, ("SRN_IOC_RESUME entered clone %d\n", clone))
486 if (srn.srn_fault[clone]) {
487 PMD(PMD_SX, ("SRN_IOC_RESUME clone %d fault "
488 "cleared\n", clone))
489 srn.srn_fault[clone] = 0;
490 }
491 mutex_enter(&srn_clone_lock);
492 if (srn.srn_delivered[clone] != SRN_NORMAL_RESUME) {
493 mutex_exit(&srn_clone_lock);
494 PMD(PMD_SX, ("SRN_IOC_RESUME EINVAL\n"))
495 return (EINVAL);
496 }
497 srn.srn_delivered[clone] = 0;
498 srn.srn_pending[clone].ae_type = 0;
499 /* notify the kernel resume thread to continue */
500 PMD(PMD_SX, ("SRN_IOC_RESUME ok for clone %d\n", clone))
501 cv_signal(&srn_clones_cv[clone]);
502 mutex_exit(&srn_clone_lock);
503 return (0);
504
505 default:
506 PMD(PMD_SX, ("srn_ioctl unknown cmd EINVAL\n"))
507 return (EINVAL);
508 }
509 }
510 /*
511 * A very simple handshake with the srn driver,
512 * only one outstanding event at a time.
513 * The OS delivers the event and depending on type,
514 * either blocks waiting for the ack, or drives on
515 */
516 void
517 srn_notify(int type, int event)
518 {
519 int clone, count;
520 PMD(PMD_SX, ("srn_notify entered with type %d, event 0x%x\n",
521 type, event));
522 ASSERT(mutex_owned(&srn_clone_lock));
523 switch (type) {
524 case SRN_TYPE_APM:
525 if (srn_apm_count == 0) {
526 PMD(PMD_SX, ("no apm types\n"))
527 return;
528 }
529 count = srn_apm_count;
530 break;
531 case SRN_TYPE_AUTOSX:
532 if (srn_autosx_count == 0) {
533 PMD(PMD_SX, ("no autosx types\n"))
534 return;
535 }
536 count = srn_autosx_count;
537 break;
538 default:
539 ASSERT(0);
540 break;
541 }
542 ASSERT(count > 0);
543 PMD(PMD_SX, ("count %d\n", count))
544 for (clone = 0; clone < SRN_MAX_CLONE; clone++) {
545 if (srn.srn_type[clone] == type) {
546 #ifdef DEBUG
547 if (type == SRN_TYPE_APM && !srn.srn_fault[clone]) {
548 ASSERT(srn.srn_pending[clone].ae_type == 0);
549 ASSERT(srn_poll_cnt[clone] == 0);
550 ASSERT(srn.srn_delivered[clone] == 0);
551 }
552 #endif
553 srn.srn_pending[clone].ae_type = event;
554 srn_poll_cnt[clone] = 1;
555 PMD(PMD_SX, ("pollwake %d\n", clone))
556 pollwakeup(&srn_pollhead[clone], (POLLRDNORM | POLLIN));
557 count--;
558 if (count == 0)
559 break;
560 }
561 }
562 if (type == SRN_TYPE_AUTOSX) { /* we don't wait */
563 PMD(PMD_SX, ("Not waiting for AUTOSX ack\n"))
564 return;
565 }
566 ASSERT(type == SRN_TYPE_APM);
567 /* otherwise wait for acks */
568 restart:
569 /*
570 * We wait until all of the pending events are cleared.
571 * We have to start over every time we do a cv_wait because
572 * we give up the mutex and can be re-entered
573 */
574 for (clone = 1; clone < SRN_MAX_CLONE; clone++) {
575 if (srn.srn_clones[clone] == 0 ||
576 srn.srn_type[clone] != SRN_TYPE_APM)
577 continue;
578 if (srn.srn_pending[clone].ae_type && !srn.srn_fault[clone]) {
579 PMD(PMD_SX, ("srn_notify waiting for ack for clone %d, "
580 "event %x\n", clone, event))
581 if (cv_timedwait(&srn_clones_cv[clone],
582 &srn_clone_lock, ddi_get_lbolt() +
583 drv_usectohz(srn_timeout * 1000000)) == -1) {
584 /*
585 * Client didn't respond, mark it as faulted
586 * and continue as if a regular signal.
587 */
588 PMD(PMD_SX, ("srn_notify: clone %d did not "
589 "ack event %x\n", clone, event))
590 cmn_err(CE_WARN, "srn_notify: clone %d did "
591 "not ack event %x\n", clone, event);
592 srn.srn_fault[clone] = 1;
593 }
594 goto restart;
595 }
596 }
597 PMD(PMD_SX, ("srn_notify done with %x\n", event))
598 }