xref: /titanic_50/usr/src/uts/common/io/wscons.c (revision cb8a054b1ab30d5caa746e6c44f29d4c9d3071c1)
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 (c) 1987, 2010, Oracle and/or its affiliates. All rights reserved.
24  */
25 
26 /*
27  * "Workstation console" multiplexor driver for Sun.
28  *
29  * Sends output to the primary frame buffer using the PROM monitor;
30  * gets input from a stream linked below us that is the "keyboard
31  * driver", below which is linked the primary keyboard.
32  */
33 
34 /*
35  * Locking Policy:
36  * This module has a D_MTPERMOD inner perimeter which means STREAMS
37  * only allows one thread to enter this module through STREAMS entry
38  * points each time -- open() close() put() srv() qtimeout().
39  * So for the most time we do not need locking in this module, but with
40  * the following exceptions:
41  *
42  *   - wc shares three global variables (wc_dip, vc_active_console,
43  *     vc_cons_user, vc_avl_root) with virtual console devname part
44  *    (fs/dev/sdev_vtops.c) which get compiled into genunix.
45  *
46  *   - wc_modechg_cb() is a callback function which will triggered when
47  *     framebuffer display mode is changed.
48  *
49  *   - vt_send_hotkeys() is triggered by timeout() which is not STREAMS MT
50  *     safe.
51  *
52  * Based on the fact that virtual console devname part and wc_modechg_cb()
53  * only do read access to the above mentioned shared four global variables,
54  * It is safe to do locking this way:
55  * 1) all read access to the four global variables in THIS WC MODULE do not
56  *    need locking;
57  * 2) all write access to the four global variables in THIS WC MODULE must
58  *    hold vc_lock;
59  * 3) any access to the four global variables in either DEVNAME PART or the
60  *    CALLBACK must hold vc_lock;
61  * 4) other global variables which are only shared in this wc module and only
62  *    accessible through STREAMS entry points such as "vc_last_console",
63  *    "vc_inuse_max_minor", "vc_target_console" and "vc_waitactive_list"
64  *    do not need explict locking.
65  *
66  * wc_modechg_cb() does read access to vc_state_t::vc_flags,
67  * vc_state_t::vc_state_lock is used to protect concurrently accesses to
68  * vc_state_t::vc_flags which may happen from both through STREAMS entry
69  * points and wc_modechg_cb().
70  * Since wc_modechg_cb() only does read access to vc_state_t::vc_flags,
71  * The other parts of wc module (except wc_modechg_cb()) only has to hold
72  * vc_state_t::vc_flags when writing to vc_state_t::vc_flags.
73  *
74  * vt_send_hotkeys() could access vt_pending_vtno at the same time with
75  * the rest of wc module, vt_pending_vtno_lock is used to protect
76  * vt_pending_vtno.
77  *
78  * Lock order: vc_lock -> vc_state_t::vc_state_lock.
79  * No overlap between vc_lock and vt_pending_vtno_lock.
80  */
81 
82 #include <sys/types.h>
83 #include <sys/param.h>
84 #include <sys/signal.h>
85 #include <sys/cred.h>
86 #include <sys/vnode.h>
87 #include <sys/termios.h>
88 #include <sys/termio.h>
89 #include <sys/ttold.h>
90 #include <sys/stropts.h>
91 #include <sys/stream.h>
92 #include <sys/strsun.h>
93 #include <sys/tty.h>
94 #include <sys/buf.h>
95 #include <sys/uio.h>
96 #include <sys/stat.h>
97 #include <sys/sysmacros.h>
98 #include <sys/errno.h>
99 #include <sys/proc.h>
100 #include <sys/procset.h>
101 #include <sys/fault.h>
102 #include <sys/siginfo.h>
103 #include <sys/debug.h>
104 #include <sys/session.h>
105 #include <sys/kmem.h>
106 #include <sys/cpuvar.h>
107 #include <sys/kbio.h>
108 #include <sys/strredir.h>
109 #include <sys/fs/snode.h>
110 #include <sys/consdev.h>
111 #include <sys/conf.h>
112 #include <sys/cmn_err.h>
113 #include <sys/console.h>
114 #include <sys/promif.h>
115 #include <sys/note.h>
116 #include <sys/polled_io.h>
117 #include <sys/systm.h>
118 #include <sys/ddi.h>
119 #include <sys/sunddi.h>
120 #include <sys/sunndi.h>
121 #include <sys/esunddi.h>
122 #include <sys/sunldi.h>
123 #include <sys/debug.h>
124 #include <sys/console.h>
125 #include <sys/ddi_impldefs.h>
126 #include <sys/policy.h>
127 #include <sys/modctl.h>
128 #include <sys/tem.h>
129 #include <sys/wscons.h>
130 #include <sys/vt_impl.h>
131 
132 /* streams stuff */
133 _NOTE(SCHEME_PROTECTS_DATA("Unshared data", copyreq))
134 _NOTE(SCHEME_PROTECTS_DATA("Unshared data", copyresp))
135 _NOTE(SCHEME_PROTECTS_DATA("Unshared data", datab))
136 _NOTE(SCHEME_PROTECTS_DATA("Unshared data", iocblk))
137 _NOTE(SCHEME_PROTECTS_DATA("Unshared data", msgb))
138 _NOTE(SCHEME_PROTECTS_DATA("Unshared data", queue))
139 
140 #define	MINLINES	10
141 #define	MAXLINES	48
142 #define	LOSCREENLINES	34
143 #define	HISCREENLINES	48
144 
145 #define	MINCOLS		10
146 #define	MAXCOLS		120
147 #define	LOSCREENCOLS	80
148 #define	HISCREENCOLS	120
149 
150 struct wscons_state {
151 	dev_t	wc_dev;			/* major/minor for this device */
152 #ifdef _HAVE_TEM_FIRMWARE
153 	int	wc_defer_output;	/* set if output device is "slow" */
154 #endif /* _HAVE_TEM_FIRMWARE */
155 	queue_t	*wc_kbdqueue;		/* "console keyboard" device queue */
156 					/* below us */
157 	cons_polledio_t		wc_polledio; /* polled I/O function pointers */
158 	cons_polledio_t		*wc_kb_polledio; /* keyboard's polledio */
159 	unsigned int	wc_kb_getpolledio_id; /* id for kb CONSOPENPOLLEDIO */
160 	queue_t *wc_pending_wq;
161 	mblk_t	*wc_pending_link;	/* I_PLINK pending for kb polledio */
162 } wscons;
163 
164 /*
165  * This module has a D_MTPERMOD inner perimeter, so we don't need to protect
166  * the variables only shared within this module
167  */
168 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", wscons))
169 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", wscons_state))
170 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", vt_stat))
171 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", vc_waitactive_msg))
172 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", tty_common))
173 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", vt_mode))
174 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", vt_dispinfo))
175 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", winsize))
176 _NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data", vc_last_console))
177 
178 #ifdef _HAVE_TEM_FIRMWARE
179 ssize_t wc_cons_wrtvec(promif_redir_arg_t arg, uchar_t *s, size_t n);
180 #endif /* _HAVE_TEM_FIRMWARE */
181 
182 static int	wcopen(queue_t *, dev_t *, int, int, cred_t *);
183 static int	wcclose(queue_t *, int, cred_t *);
184 static int	wcuwput(queue_t *, mblk_t *);
185 static int	wclrput(queue_t *, mblk_t *);
186 
187 static struct module_info wcm_info = {
188 	0,
189 	"wc",
190 	0,
191 	INFPSZ,
192 	2048,
193 	128
194 };
195 
196 static struct qinit wcurinit = {
197 	putq,
198 	NULL,
199 	wcopen,
200 	wcclose,
201 	NULL,
202 	&wcm_info,
203 	NULL
204 };
205 
206 static struct qinit wcuwinit = {
207 	wcuwput,
208 	NULL,
209 	wcopen,
210 	wcclose,
211 	NULL,
212 	&wcm_info,
213 	NULL
214 };
215 
216 static struct qinit wclrinit = {
217 	wclrput,
218 	NULL,
219 	NULL,
220 	NULL,
221 	NULL,
222 	&wcm_info,
223 	NULL
224 };
225 
226 /*
227  * We always putnext directly to the underlying queue.
228  */
229 static struct qinit wclwinit = {
230 	NULL,
231 	NULL,
232 	NULL,
233 	NULL,
234 	NULL,
235 	&wcm_info,
236 	NULL
237 };
238 
239 static struct streamtab wcinfo = {
240 	&wcurinit,
241 	&wcuwinit,
242 	&wclrinit,
243 	&wclwinit,
244 };
245 
246 static int wc_info(dev_info_t *, ddi_info_cmd_t, void *, void **result);
247 static int wc_attach(dev_info_t *, ddi_attach_cmd_t);
248 
249 DDI_DEFINE_STREAM_OPS(wc_ops, nulldev, nulldev, wc_attach, nodev, nodev,
250     wc_info, D_MTPERMOD | D_MP, &wcinfo, ddi_quiesce_not_supported);
251 
252 static void	wcreioctl(void *);
253 static void 	wcioctl(queue_t *, mblk_t *);
254 #ifdef _HAVE_TEM_FIRMWARE
255 static void	wcopoll(void *);
256 static void	wconsout(void *);
257 #endif /* _HAVE_TEM_FIRMWARE */
258 static void	wcrstrt(void *);
259 static void	wcstart(void *);
260 static void	wc_open_kb_polledio(struct wscons_state *wc, queue_t *q,
261 		    mblk_t *mp);
262 static void	wc_close_kb_polledio(struct wscons_state *wc, queue_t *q,
263 		    mblk_t *mp);
264 static void	wc_polled_putchar(cons_polledio_arg_t arg,
265 			unsigned char c);
266 static boolean_t wc_polled_ischar(cons_polledio_arg_t arg);
267 static int	wc_polled_getchar(cons_polledio_arg_t arg);
268 static void	wc_polled_enter(cons_polledio_arg_t arg);
269 static void	wc_polled_exit(cons_polledio_arg_t arg);
270 void	wc_get_size(vc_state_t *pvc);
271 static void	wc_modechg_cb(tem_modechg_cb_arg_t arg);
272 
273 static struct dev_ops wc_ops;
274 
275 /*
276  * Debug printing
277  */
278 #ifndef DPRINTF
279 #ifdef DEBUG
280 /*PRINTFLIKE1*/
281 static void	wc_dprintf(const char *fmt, ...) __KPRINTFLIKE(1);
282 #define	DPRINTF(l, m, args) \
283 	(((l) >= wc_errlevel) && ((m) & wc_errmask) ?	\
284 		wc_dprintf args :			\
285 		(void) 0)
286 /*
287  * Severity levels for printing
288  */
289 #define	PRINT_L0	0	/* print every message */
290 #define	PRINT_L1	1	/* debug */
291 #define	PRINT_L2	2	/* quiet */
292 
293 /*
294  * Masks
295  */
296 #define	PRINT_MASK_ALL		0xFFFFFFFFU
297 uint_t	wc_errmask = PRINT_MASK_ALL;
298 uint_t	wc_errlevel = PRINT_L2;
299 
300 #else
301 #define	DPRINTF(l, m, args)	/* NOTHING */
302 #endif
303 #endif
304 
305 /*
306  * Module linkage information for the kernel.
307  */
308 static struct modldrv modldrv = {
309 	&mod_driverops, /* Type of module.  This one is a pseudo driver */
310 	"Workstation multiplexer Driver 'wc'",
311 	&wc_ops,	/* driver ops */
312 };
313 
314 static struct modlinkage modlinkage = {
315 	MODREV_1,
316 	&modldrv,
317 	NULL
318 };
319 
320 int
321 _init(void)
322 {
323 	int rc;
324 	if ((rc = mod_install(&modlinkage)) == 0)
325 		vt_init();
326 	return (rc);
327 }
328 
329 int
330 _fini(void)
331 {
332 	return (mod_remove(&modlinkage));
333 }
334 
335 int
336 _info(struct modinfo *modinfop)
337 {
338 	return (mod_info(&modlinkage, modinfop));
339 }
340 
341 /*ARGSUSED*/
342 static int
343 wc_attach(dev_info_t *devi, ddi_attach_cmd_t cmd)
344 {
345 	/* create minor node for workstation hard console */
346 	if (ddi_create_minor_node(devi, "wscons", S_IFCHR,
347 	    0, DDI_PSEUDO, NULL) == DDI_FAILURE) {
348 		ddi_remove_minor_node(devi, NULL);
349 		return (DDI_FAILURE);
350 	}
351 
352 	mutex_enter(&vc_lock);
353 
354 	wc_dip = devi;
355 
356 	bzero(&(wscons.wc_polledio), sizeof (wscons.wc_polledio));
357 
358 	vt_resize(VC_DEFAULT_COUNT);
359 
360 	mutex_exit(&vc_lock);
361 
362 	return (DDI_SUCCESS);
363 }
364 
365 /* ARGSUSED */
366 static int
367 wc_info(dev_info_t *dip, ddi_info_cmd_t infocmd, void *arg,
368 	void **result)
369 {
370 	int error;
371 
372 	switch (infocmd) {
373 	case DDI_INFO_DEVT2DEVINFO:
374 		if (wc_dip == NULL) {
375 			error = DDI_FAILURE;
376 		} else {
377 			*result = (void *) wc_dip;
378 			error = DDI_SUCCESS;
379 		}
380 		break;
381 	case DDI_INFO_DEVT2INSTANCE:
382 		*result = (void *)0;
383 		error = DDI_SUCCESS;
384 		break;
385 	default:
386 		error = DDI_FAILURE;
387 	}
388 	return (error);
389 }
390 
391 #ifdef _HAVE_TEM_FIRMWARE
392 /*
393  * Output buffer. Protected by the per-module inner perimeter.
394  */
395 #define	MAXHIWAT	2000
396 static char obuf[MAXHIWAT];
397 #endif /* _HAVE_TEM_FIRMWARE */
398 
399 static void
400 wc_init_polledio(void)
401 {
402 	static boolean_t polledio_inited = B_FALSE;
403 	_NOTE(SCHEME_PROTECTS_DATA("D_MTPERMOD protected data",
404 	    polledio_inited))
405 
406 	if (polledio_inited)
407 		return;
408 
409 	polledio_inited = B_TRUE;
410 
411 	/*
412 	 * Initialize the parts of the polled I/O struct that
413 	 * are common to both input and output modes, but which
414 	 * don't flag to the upper layers, which if any of the
415 	 * two modes are available.  We don't know at this point
416 	 * if system is configured CONS_KFB, but we will when
417 	 * consconfig_dacf asks us with CONSOPENPOLLED I/O.
418 	 */
419 	bzero(&(wscons.wc_polledio), sizeof (wscons.wc_polledio));
420 	wscons.wc_polledio.cons_polledio_version =
421 	    CONSPOLLEDIO_V0;
422 	wscons.wc_polledio.cons_polledio_argument =
423 	    (cons_polledio_arg_t)&wscons;
424 	wscons.wc_polledio.cons_polledio_enter =
425 	    wc_polled_enter;
426 	wscons.wc_polledio.cons_polledio_exit =
427 	    wc_polled_exit;
428 
429 #ifdef _HAVE_TEM_FIRMWARE
430 	/*
431 	 * If we're talking directly to a framebuffer, we assume
432 	 * that it's a "slow" device, so that rendering should
433 	 * be deferred to a timeout or softcall so that we write
434 	 * a bunch of characters at once.
435 	 */
436 	wscons.wc_defer_output = prom_stdout_is_framebuffer();
437 #endif /* _HAVE_TEM_FIRMWARE */
438 }
439 
440 /*ARGSUSED*/
441 static int
442 wcopen(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *crp)
443 {
444 	int minor;
445 
446 	wc_init_polledio();
447 	minor = (int)getminor(*devp);
448 	return (vt_open(minor, q, crp));
449 }
450 
451 /*ARGSUSED*/
452 static int
453 wcclose(queue_t *q, int flag, cred_t *crp)
454 {
455 	vc_state_t *pvc = (vc_state_t *)q->q_ptr;
456 
457 	qprocsoff(q);
458 
459 	mutex_enter(&vc_lock);
460 
461 	/*
462 	 * If we are closing the VT node which
463 	 * /dev/vt/console_user points to, revert
464 	 * /dev/vt/console to /dev/console
465 	 */
466 	if (vc_cons_user == pvc->vc_minor)
467 		vc_cons_user = VT_MINOR_INVALID;
468 
469 	if (pvc->vc_minor == 0 || pvc->vc_minor == vc_active_console) {
470 
471 		/*
472 		 * If we lose the system console,
473 		 * no any other active consoles.
474 		 */
475 		if (pvc->vc_minor == 0 && pvc->vc_minor == vc_active_console) {
476 			vc_active_console = VT_MINOR_INVALID;
477 			vc_last_console = VT_MINOR_INVALID;
478 		}
479 
480 		/*
481 		 * just clean for our primary console
482 		 * and active console
483 		 */
484 		mutex_enter(&pvc->vc_state_lock);
485 		vt_clean(q, pvc);
486 		mutex_exit(&pvc->vc_state_lock);
487 
488 		mutex_exit(&vc_lock);
489 
490 		return (0);
491 	}
492 	vt_close(q, pvc, crp);
493 
494 	mutex_exit(&vc_lock);
495 
496 	return (0);
497 }
498 
499 /*
500  * Put procedure for upper write queue.
501  * Respond to M_STOP, M_START, M_IOCTL, and M_FLUSH messages here;
502  * queue up M_BREAK, M_DELAY, and M_DATA messages for processing by
503  * the start routine, and then call the start routine; discard
504  * everything else.
505  */
506 static int
507 wcuwput(queue_t *q, mblk_t *mp)
508 {
509 	vc_state_t *pvc = (vc_state_t *)q->q_ptr;
510 
511 	switch (mp->b_datap->db_type) {
512 
513 	case M_STOP:
514 		mutex_enter(&pvc->vc_state_lock);
515 		pvc->vc_flags |= WCS_STOPPED;
516 		mutex_exit(&pvc->vc_state_lock);
517 
518 		freemsg(mp);
519 		break;
520 
521 	case M_START:
522 		mutex_enter(&pvc->vc_state_lock);
523 		pvc->vc_flags &= ~WCS_STOPPED;
524 		mutex_exit(&pvc->vc_state_lock);
525 
526 		wcstart(pvc);
527 		freemsg(mp);
528 		break;
529 
530 	case M_IOCTL: {
531 		struct iocblk *iocp;
532 		struct linkblk *linkp;
533 
534 		iocp = (struct iocblk *)(void *)mp->b_rptr;
535 		switch (iocp->ioc_cmd) {
536 
537 		case I_LINK:	/* stupid, but permitted */
538 		case I_PLINK:
539 			if (wscons.wc_kbdqueue != NULL) {
540 				/* somebody already linked */
541 				miocnak(q, mp, 0, EINVAL);
542 				return (0);
543 			}
544 			linkp = (struct linkblk *)(void *)mp->b_cont->b_rptr;
545 			wscons.wc_kbdqueue = WR(linkp->l_qbot);
546 			mp->b_datap->db_type = M_IOCACK;
547 			iocp->ioc_count = 0;
548 			wc_open_kb_polledio(&wscons, q, mp);
549 			break;
550 
551 		case I_UNLINK:	/* stupid, but permitted */
552 		case I_PUNLINK:
553 			linkp = (struct linkblk *)(void *)mp->b_cont->b_rptr;
554 			if (wscons.wc_kbdqueue != WR(linkp->l_qbot)) {
555 				/* not us */
556 				miocnak(q, mp, 0, EINVAL);
557 				return (0);
558 			}
559 
560 			mp->b_datap->db_type = M_IOCACK;
561 			iocp->ioc_count = 0;
562 			wc_close_kb_polledio(&wscons, q, mp);
563 			break;
564 
565 		case TCSETSW:
566 		case TCSETSF:
567 		case TCSETAW:
568 		case TCSETAF:
569 		case TCSBRK:
570 			/*
571 			 * The changes do not take effect until all
572 			 * output queued before them is drained.
573 			 * Put this message on the queue, so that
574 			 * "wcstart" will see it when it's done
575 			 * with the output before it.  Poke the
576 			 * start routine, just in case.
577 			 */
578 			(void) putq(q, mp);
579 			wcstart(pvc);
580 			break;
581 
582 		case CONSSETABORTENABLE:
583 		case CONSGETABORTENABLE:
584 		case KIOCSDIRECT:
585 			if (wscons.wc_kbdqueue != NULL) {
586 				wscons.wc_pending_wq = q;
587 				(void) putnext(wscons.wc_kbdqueue, mp);
588 				break;
589 			}
590 			/* fall through */
591 
592 		default:
593 			/*
594 			 * Do it now.
595 			 */
596 			wcioctl(q, mp);
597 			break;
598 		}
599 		break;
600 	}
601 
602 	case M_FLUSH:
603 		if (*mp->b_rptr & FLUSHW) {
604 			/*
605 			 * Flush our write queue.
606 			 */
607 			flushq(q, FLUSHDATA);	/* XXX doesn't flush M_DELAY */
608 			*mp->b_rptr &= ~FLUSHW;	/* it has been flushed */
609 		}
610 		if (*mp->b_rptr & FLUSHR) {
611 			flushq(RD(q), FLUSHDATA);
612 			qreply(q, mp);	/* give the read queues a crack at it */
613 		} else
614 			freemsg(mp);
615 		break;
616 
617 	case M_BREAK:
618 		/*
619 		 * Ignore these, as they make no sense.
620 		 */
621 		freemsg(mp);
622 		break;
623 
624 	case M_DELAY:
625 	case M_DATA:
626 		/*
627 		 * Queue the message up to be transmitted,
628 		 * and poke the start routine.
629 		 */
630 		(void) putq(q, mp);
631 		wcstart(pvc);
632 		break;
633 
634 	case M_IOCDATA:
635 		vt_miocdata(q, mp);
636 		break;
637 
638 	default:
639 		/*
640 		 * "No, I don't want a subscription to Chain Store Age,
641 		 * thank you anyway."
642 		 */
643 		freemsg(mp);
644 		break;
645 	}
646 
647 	return (0);
648 }
649 
650 /*
651  * Retry an "ioctl", now that "qbufcall" claims we may be able to allocate
652  * the buffer we need.
653  */
654 /*ARGSUSED*/
655 static void
656 wcreioctl(void *arg)
657 {
658 	vc_state_t *pvc = (vc_state_t *)arg;
659 	queue_t *q;
660 	mblk_t *mp;
661 
662 	pvc->vc_bufcallid = 0;
663 	q = pvc->vc_ttycommon.t_writeq;
664 	if ((mp = pvc->vc_ttycommon.t_iocpending) != NULL) {
665 		/* not pending any more */
666 		pvc->vc_ttycommon.t_iocpending = NULL;
667 		wcioctl(q, mp);
668 	}
669 }
670 
671 static int
672 wc_getterm(mblk_t *mp)
673 {
674 	char *term;
675 	intptr_t arg;
676 	int flag = ((struct iocblk *)(void *)mp->b_rptr)->ioc_flag;
677 
678 	STRUCT_DECL(cons_getterm, wcterm);
679 	STRUCT_INIT(wcterm, flag);
680 
681 	arg = *((intptr_t *)(void *)mp->b_cont->b_rptr);
682 
683 	if (ddi_copyin((void *)arg, STRUCT_BUF(wcterm),
684 	    STRUCT_SIZE(wcterm), flag) != 0) {
685 		return (EFAULT);
686 	}
687 
688 	if (consmode == CONS_FW) {
689 		/* PROM terminal emulator */
690 		term = "sun";
691 	} else {
692 		/* Kernel terminal emulator */
693 		ASSERT(consmode == CONS_KFB);
694 		term = "sun-color";
695 	}
696 
697 	if (STRUCT_FGET(wcterm, cn_term_len) <
698 	    strlen(term) + 1) {
699 		return (EOVERFLOW);
700 	}
701 
702 	if (ddi_copyout(term,
703 	    STRUCT_FGETP(wcterm, cn_term_type),
704 	    strlen(term) + 1, flag) != 0) {
705 		return (EFAULT);
706 	}
707 
708 	return (0);
709 }
710 
711 /*
712  * Process an "ioctl" message sent down to us.
713  */
714 static void
715 wcioctl(queue_t *q, mblk_t *mp)
716 {
717 	vc_state_t *pvc = (vc_state_t *)q->q_ptr;
718 	struct iocblk *iocp;
719 	size_t datasize;
720 	int error;
721 	long len;
722 
723 	iocp = (struct iocblk *)(void *)mp->b_rptr;
724 
725 	if ((iocp->ioc_cmd & VTIOC) == VTIOC ||
726 	    (iocp->ioc_cmd & KDIOC) == KDIOC) {
727 		vt_ioctl(q, mp);
728 		return;
729 	}
730 
731 	switch (iocp->ioc_cmd) {
732 	case TIOCSWINSZ:
733 		/*
734 		 * Ignore all attempts to set the screen size; the
735 		 * value in the EEPROM is guaranteed (modulo PROM bugs)
736 		 * to be the value used by the PROM monitor code, so it
737 		 * is by definition correct.  Many programs (e.g.,
738 		 * "login" and "tset") will attempt to reset the size
739 		 * to (0, 0) or (34, 80), neither of which is
740 		 * necessarily correct.
741 		 * We just ACK the message, so as not to disturb
742 		 * programs that set the sizes.
743 		 */
744 		iocp->ioc_count = 0;	/* no data returned */
745 		mp->b_datap->db_type = M_IOCACK;
746 		qreply(q, mp);
747 		return;
748 
749 	case CONSOPENPOLLEDIO:
750 		DPRINTF(PRINT_L1, PRINT_MASK_ALL,
751 		    ("wcioctl: CONSOPENPOLLEDIO\n"));
752 
753 		error = miocpullup(mp, sizeof (struct cons_polledio *));
754 		if (error != 0) {
755 			miocnak(q, mp, 0, error);
756 			return;
757 		}
758 
759 		/*
760 		 * We are given an appropriate-sized data block,
761 		 * and return a pointer to our structure in it.
762 		 */
763 		if (consmode == CONS_KFB)
764 			wscons.wc_polledio.cons_polledio_putchar =
765 			    wc_polled_putchar;
766 		*(struct cons_polledio **)(void *)mp->b_cont->b_rptr =
767 		    &wscons.wc_polledio;
768 
769 		mp->b_datap->db_type = M_IOCACK;
770 
771 		qreply(q, mp);
772 		break;
773 
774 	case CONS_GETTERM:
775 		if ((error = wc_getterm(mp)) != 0)
776 			miocnak(q, mp, 0, error);
777 		else
778 			miocack(q, mp, 0, 0);
779 		return;
780 
781 	case WC_OPEN_FB:
782 		/*
783 		 * Start out pessimistic, so that we can just jump to
784 		 * the reply to bail out.
785 		 */
786 		mp->b_datap->db_type = M_IOCNAK;
787 
788 		/*
789 		 * First test:  really, this should be done only from
790 		 * inside the kernel.  Unfortunately, that information
791 		 * doesn't seem to be available in a streams ioctl,
792 		 * so restrict it to root only.  (Perhaps we could check
793 		 * for ioc_cr == kcred.)
794 		 */
795 		if ((iocp->ioc_error = secpolicy_console(iocp->ioc_cr)) != 0)
796 			goto open_fail;
797 
798 		/*
799 		 * Some miscellaneous checks...
800 		 */
801 		iocp->ioc_error = EINVAL;
802 
803 		/*
804 		 * If we don't have exactly one continuation block, fail.
805 		 */
806 		if (mp->b_cont == NULL ||
807 		    mp->b_cont->b_cont != NULL)
808 			goto open_fail;
809 
810 		/*
811 		 * If there's no null terminator in the string, fail.
812 		 */
813 		/* LINTED E_PTRDIFF_OVERFLOW */
814 		len = mp->b_cont->b_wptr - mp->b_cont->b_rptr;
815 		if (memchr(mp->b_cont->b_rptr, 0, len) == NULL)
816 			goto open_fail;
817 
818 		/*
819 		 * NOTE:  should eventually get default
820 		 * dimensions from a property, e.g. screen-#rows.
821 		 */
822 		iocp->ioc_error = tem_info_init((char *)mp->b_cont->b_rptr,
823 		    iocp->ioc_cr);
824 		/*
825 		 * Of course, if the terminal emulator initialization
826 		 * failed, fail.
827 		 */
828 		if (iocp->ioc_error != 0)
829 			goto open_fail;
830 
831 #ifdef	_HAVE_TEM_FIRMWARE
832 		if (prom_stdout_is_framebuffer()) {
833 			/*
834 			 * Drivers in the console stream may emit additional
835 			 * messages before we are ready. This causes text
836 			 * overwrite on the screen. So we set the redirection
837 			 * here. It is safe because the ioctl in consconfig_dacf
838 			 * will succeed and consmode will be set to CONS_KFB.
839 			 */
840 			prom_set_stdout_redirect(wc_cons_wrtvec,
841 			    (promif_redir_arg_t)NULL);
842 
843 		}
844 #endif	/* _HAVE_TEM_FIRMWARE */
845 
846 		tem_register_modechg_cb(wc_modechg_cb,
847 		    (tem_modechg_cb_arg_t)&wscons);
848 
849 		/*
850 		 * ... and succeed.
851 		 */
852 		mp->b_datap->db_type = M_IOCACK;
853 
854 open_fail:
855 		qreply(q, mp);
856 		break;
857 
858 	case WC_CLOSE_FB:
859 		/*
860 		 * There's nothing that can call this, so it's not
861 		 * really implemented.
862 		 */
863 		mp->b_datap->db_type = M_IOCNAK;
864 		/*
865 		 * However, if it were implemented, it would clearly
866 		 * be root-only.
867 		 */
868 		if ((iocp->ioc_error = secpolicy_console(iocp->ioc_cr)) != 0)
869 			goto close_fail;
870 
871 		iocp->ioc_error = EINVAL;
872 
873 close_fail:
874 		qreply(q, mp);
875 		break;
876 
877 	default:
878 
879 		/*
880 		 * The only way in which "ttycommon_ioctl" can fail is
881 		 * if the "ioctl" requires a response containing data
882 		 * to be returned to the user, and no mblk could be
883 		 * allocated for the data.  No such "ioctl" alters our
884 		 * state.  Thus, we always go ahead and do any
885 		 * state-changes the "ioctl" calls for.  If we couldn't
886 		 * allocate the data, "ttycommon_ioctl" has stashed the
887 		 * "ioctl" away safely, so we just call "qbufcall" to
888 		 * request that we be called back when we stand a
889 		 * better chance of allocating the data.
890 		 */
891 		datasize = ttycommon_ioctl(&pvc->vc_ttycommon, q, mp, &error);
892 		if (datasize != 0) {
893 			if (pvc->vc_bufcallid != 0)
894 				qunbufcall(q, pvc->vc_bufcallid);
895 			pvc->vc_bufcallid = qbufcall(q, datasize, BPRI_HI,
896 			    wcreioctl, pvc);
897 			return;
898 		}
899 
900 		if (error < 0) {
901 			if (iocp->ioc_cmd == TCSBRK)
902 				error = 0;
903 			else
904 				error = EINVAL;
905 		}
906 		if (error != 0) {
907 			iocp->ioc_error = error;
908 			mp->b_datap->db_type = M_IOCNAK;
909 		}
910 		qreply(q, mp);
911 		break;
912 	}
913 }
914 
915 /*
916  * This function gets the polled I/O structures from the lower
917  * keyboard driver.  If any initialization or resource allocation
918  * needs to be done by the lower driver, it will be done when
919  * the lower driver services this message.
920  */
921 static void
922 wc_open_kb_polledio(struct wscons_state *wscons, queue_t *q, mblk_t *mp)
923 {
924 	mblk_t *mp2;
925 	struct iocblk *iocp;
926 
927 	DPRINTF(PRINT_L1, PRINT_MASK_ALL,
928 	    ("wc_open_kb_polledio: sending CONSOPENPOLLEDIO\n"));
929 
930 	mp2 = mkiocb(CONSOPENPOLLEDIO);
931 
932 	if (mp2 == NULL) {
933 		/*
934 		 * If we can't get an mblk, then wait for it.
935 		 */
936 		goto nomem;
937 	}
938 
939 	mp2->b_cont = allocb(sizeof (struct cons_polledio *), BPRI_HI);
940 
941 	if (mp2->b_cont == NULL) {
942 		/*
943 		 * If we can't get an mblk, then wait for it, and release
944 		 * the mblk that we have already allocated.
945 		 */
946 		freemsg(mp2);
947 		goto nomem;
948 	}
949 
950 	iocp = (struct iocblk *)(void *)mp2->b_rptr;
951 
952 	iocp->ioc_count = sizeof (struct cons_polledio *);
953 	mp2->b_cont->b_wptr = mp2->b_cont->b_rptr +
954 	    sizeof (struct cons_polledio *);
955 
956 	wscons->wc_pending_wq = q;
957 	wscons->wc_pending_link = mp;
958 	wscons->wc_kb_getpolledio_id = iocp->ioc_id;
959 
960 	putnext(wscons->wc_kbdqueue, mp2);
961 
962 	return;
963 
964 nomem:
965 	iocp = (struct iocblk *)(void *)mp->b_rptr;
966 	iocp->ioc_error = ENOMEM;
967 	mp->b_datap->db_type = M_IOCNAK;
968 	qreply(q, mp);
969 }
970 
971 /*
972  * This function releases the polled I/O structures from the lower
973  * keyboard driver.  If any de-initialization needs to be done, or
974  * any resources need to be released, it will be done when the lower
975  * driver services this message.
976  */
977 static void
978 wc_close_kb_polledio(struct wscons_state *wscons, queue_t *q, mblk_t *mp)
979 {
980 	mblk_t *mp2;
981 	struct iocblk *iocp;
982 
983 	DPRINTF(PRINT_L1, PRINT_MASK_ALL,
984 	    ("wc_close_kb_polledio: sending CONSCLOSEPOLLEDIO\n"));
985 
986 	mp2 = mkiocb(CONSCLOSEPOLLEDIO);
987 
988 	if (mp2 == NULL) {
989 		/*
990 		 * If we can't get an mblk, then wait for it.
991 		 */
992 		goto nomem;
993 	}
994 
995 	mp2->b_cont = allocb(sizeof (struct cons_polledio *), BPRI_HI);
996 
997 	if (mp2->b_cont == NULL) {
998 		/*
999 		 * If we can't get an mblk, then wait for it, and release
1000 		 * the mblk that we have already allocated.
1001 		 */
1002 		freemsg(mp2);
1003 
1004 		goto nomem;
1005 	}
1006 
1007 	iocp = (struct iocblk *)(void *)mp2->b_rptr;
1008 
1009 	iocp->ioc_count = 0;
1010 
1011 	wscons->wc_pending_wq = q;
1012 	wscons->wc_pending_link = mp;
1013 	wscons->wc_kb_getpolledio_id = iocp->ioc_id;
1014 
1015 	putnext(wscons->wc_kbdqueue, mp2);
1016 
1017 	return;
1018 
1019 nomem:
1020 	iocp = (struct iocblk *)(void *)mp->b_rptr;
1021 	iocp->ioc_error = ENOMEM;
1022 	mp->b_datap->db_type = M_IOCNAK;
1023 	qreply(q, mp);
1024 }
1025 
1026 #ifdef _HAVE_TEM_FIRMWARE
1027 /* ARGSUSED */
1028 static void
1029 wcopoll(void *arg)
1030 {
1031 	vc_state_t *pvc = (vc_state_t *)arg;
1032 	queue_t *q;
1033 
1034 	q = pvc->vc_ttycommon.t_writeq;
1035 	pvc->vc_timeoutid = 0;
1036 
1037 	mutex_enter(&pvc->vc_state_lock);
1038 
1039 	/* See if we can continue output */
1040 	if ((pvc->vc_flags & WCS_BUSY) && pvc->vc_pendc != -1) {
1041 		if (prom_mayput((char)pvc->vc_pendc) == 0) {
1042 			pvc->vc_pendc = -1;
1043 			pvc->vc_flags &= ~WCS_BUSY;
1044 			if (!(pvc->vc_flags&(WCS_DELAY|WCS_STOPPED)))
1045 				wcstart(pvc);
1046 		} else
1047 			pvc->vc_timeoutid = qtimeout(q, wcopoll, pvc, 1);
1048 	}
1049 
1050 	mutex_exit(&pvc->vc_state_lock);
1051 }
1052 #endif	/* _HAVE_TEM_FIRMWARE */
1053 
1054 /*
1055  * Restart output on the console after a timeout.
1056  */
1057 /* ARGSUSED */
1058 static void
1059 wcrstrt(void *arg)
1060 {
1061 	vc_state_t *pvc = (vc_state_t *)arg;
1062 
1063 	ASSERT(pvc->vc_ttycommon.t_writeq != NULL);
1064 
1065 	mutex_enter(&pvc->vc_state_lock);
1066 	pvc->vc_flags &= ~WCS_DELAY;
1067 	mutex_exit(&pvc->vc_state_lock);
1068 
1069 	wcstart(pvc);
1070 }
1071 
1072 /*
1073  * get screen terminal for current output
1074  */
1075 static tem_vt_state_t
1076 wc_get_screen_tem(vc_state_t *pvc)
1077 {
1078 	if (!tem_initialized(pvc->vc_tem) ||
1079 	    tem_get_fbmode(pvc->vc_tem) != KD_TEXT)
1080 		return (NULL);
1081 
1082 	return (pvc->vc_tem);
1083 }
1084 
1085 /*
1086  * Start console output
1087  */
1088 static void
1089 wcstart(void *arg)
1090 {
1091 	vc_state_t *pvc = (vc_state_t *)arg;
1092 	tem_vt_state_t ptem = NULL;
1093 #ifdef _HAVE_TEM_FIRMWARE
1094 	int c;
1095 	ssize_t cc;
1096 #endif /* _HAVE_TEM_FIRMWARE */
1097 	queue_t *q;
1098 	mblk_t *bp;
1099 	mblk_t *nbp;
1100 
1101 	/*
1102 	 * If we're waiting for something to happen (delay timeout to
1103 	 * expire, current transmission to finish, output to be
1104 	 * restarted, output to finish draining), don't grab anything
1105 	 * new.
1106 	 */
1107 	if (pvc->vc_flags & (WCS_DELAY|WCS_BUSY|WCS_STOPPED))
1108 		return;
1109 
1110 	q = pvc->vc_ttycommon.t_writeq;
1111 	/*
1112 	 * assumes that we have been called by whoever holds the
1113 	 * exclusionary lock on the write-side queue (protects
1114 	 * vc_flags and vc_pendc).
1115 	 */
1116 	for (;;) {
1117 		if ((bp = getq(q)) == NULL)
1118 			return;	/* nothing to transmit */
1119 
1120 		/*
1121 		 * We have a new message to work on.
1122 		 * Check whether it's a delay or an ioctl (the latter
1123 		 * occurs if the ioctl in question was waiting for the output
1124 		 * to drain).  If it's one of those, process it immediately.
1125 		 */
1126 		switch (bp->b_datap->db_type) {
1127 
1128 		case M_DELAY:
1129 			/*
1130 			 * Arrange for "wcrstrt" to be called when the
1131 			 * delay expires; it will turn WCS_DELAY off,
1132 			 * and call "wcstart" to grab the next message.
1133 			 */
1134 			if (pvc->vc_timeoutid != 0)
1135 				(void) quntimeout(q, pvc->vc_timeoutid);
1136 			pvc->vc_timeoutid = qtimeout(q, wcrstrt, pvc,
1137 			    (clock_t)(*(unsigned char *)bp->b_rptr + 6));
1138 
1139 			mutex_enter(&pvc->vc_state_lock);
1140 			pvc->vc_flags |= WCS_DELAY;
1141 			mutex_exit(&pvc->vc_state_lock);
1142 
1143 			freemsg(bp);
1144 			return;	/* wait for this to finish */
1145 
1146 		case M_IOCTL:
1147 			/*
1148 			 * This ioctl was waiting for the output ahead of
1149 			 * it to drain; obviously, it has.  Do it, and
1150 			 * then grab the next message after it.
1151 			 */
1152 			wcioctl(q, bp);
1153 			continue;
1154 		}
1155 
1156 #ifdef _HAVE_TEM_FIRMWARE
1157 		if (consmode == CONS_KFB) {
1158 #endif /* _HAVE_TEM_FIRMWARE */
1159 			if ((ptem = wc_get_screen_tem(pvc)) != NULL) {
1160 
1161 				for (nbp = bp; nbp != NULL; nbp = nbp->b_cont) {
1162 					if (nbp->b_wptr > nbp->b_rptr) {
1163 						(void) tem_write(ptem,
1164 						    nbp->b_rptr,
1165 						    /* LINTED */
1166 						    nbp->b_wptr - nbp->b_rptr,
1167 						    kcred);
1168 					}
1169 				}
1170 
1171 			}
1172 
1173 			freemsg(bp);
1174 
1175 #ifdef _HAVE_TEM_FIRMWARE
1176 			continue;
1177 		}
1178 
1179 		/* consmode = CONS_FW */
1180 		if (pvc->vc_minor != 0) {
1181 			freemsg(bp);
1182 			continue;
1183 		}
1184 
1185 		/* LINTED E_PTRDIFF_OVERFLOW */
1186 		if ((cc = bp->b_wptr - bp->b_rptr) == 0) {
1187 			freemsg(bp);
1188 			continue;
1189 		}
1190 		/*
1191 		 * Direct output to the frame buffer if this device
1192 		 * is not the "hardware" console.
1193 		 */
1194 		if (wscons.wc_defer_output) {
1195 			/*
1196 			 * Never do output here;
1197 			 * it takes forever.
1198 			 */
1199 			mutex_enter(&pvc->vc_state_lock);
1200 			pvc->vc_flags |= WCS_BUSY;
1201 			mutex_exit(&pvc->vc_state_lock);
1202 
1203 			pvc->vc_pendc = -1;
1204 			(void) putbq(q, bp);
1205 			if (q->q_count > 128) { /* do it soon */
1206 				softcall(wconsout, pvc);
1207 			} else {	/* wait a bit */
1208 				if (pvc->vc_timeoutid != 0)
1209 					(void) quntimeout(q,
1210 					    pvc->vc_timeoutid);
1211 				pvc->vc_timeoutid = qtimeout(q, wconsout,
1212 				    pvc, hz / 30);
1213 			}
1214 			return;
1215 		}
1216 		for (;;) {
1217 			c = *bp->b_rptr++;
1218 			cc--;
1219 			if (prom_mayput((char)c) != 0) {
1220 
1221 				mutex_enter(&pvc->vc_state_lock);
1222 				pvc->vc_flags |= WCS_BUSY;
1223 				mutex_exit(&pvc->vc_state_lock);
1224 
1225 				pvc->vc_pendc = c;
1226 				if (pvc->vc_timeoutid != 0)
1227 					(void) quntimeout(q,
1228 					    pvc->vc_timeoutid);
1229 				pvc->vc_timeoutid = qtimeout(q, wcopoll,
1230 				    pvc, 1);
1231 				if (bp != NULL)
1232 					/* not done with this message yet */
1233 					(void) putbq(q, bp);
1234 				return;
1235 			}
1236 			while (cc <= 0) {
1237 				nbp = bp;
1238 				bp = bp->b_cont;
1239 				freeb(nbp);
1240 				if (bp == NULL)
1241 					return;
1242 				/* LINTED E_PTRDIFF_OVERFLOW */
1243 				cc = bp->b_wptr - bp->b_rptr;
1244 			}
1245 		}
1246 #endif /* _HAVE_TEM_FIRMWARE */
1247 	}
1248 }
1249 
1250 #ifdef _HAVE_TEM_FIRMWARE
1251 /*
1252  * Output to frame buffer console.
1253  * It takes a long time to scroll.
1254  */
1255 /* ARGSUSED */
1256 static void
1257 wconsout(void *arg)
1258 {
1259 	vc_state_t *pvc = (vc_state_t *)arg;
1260 	uchar_t *cp;
1261 	ssize_t cc;
1262 	queue_t *q;
1263 	mblk_t *bp;
1264 	mblk_t *nbp;
1265 	char *current_position;
1266 	ssize_t bytes_left;
1267 
1268 	if ((q = pvc->vc_ttycommon.t_writeq) == NULL) {
1269 		return;	/* not attached to a stream */
1270 	}
1271 
1272 	/*
1273 	 * Set up to copy up to MAXHIWAT bytes.
1274 	 */
1275 	current_position = &obuf[0];
1276 	bytes_left = MAXHIWAT;
1277 	while ((bp = getq(q)) != NULL) {
1278 		if (bp->b_datap->db_type == M_IOCTL) {
1279 			/*
1280 			 * This ioctl was waiting for the output ahead of
1281 			 * it to drain; obviously, it has.  Put it back
1282 			 * so that "wcstart" can handle it, and transmit
1283 			 * what we've got.
1284 			 */
1285 			(void) putbq(q, bp);
1286 			goto transmit;
1287 		}
1288 
1289 		do {
1290 			cp = bp->b_rptr;
1291 			/* LINTED E_PTRDIFF_OVERFLOW */
1292 			cc = bp->b_wptr - cp;
1293 			while (cc != 0) {
1294 				if (bytes_left == 0) {
1295 					/*
1296 					 * Out of buffer space; put this
1297 					 * buffer back on the queue, and
1298 					 * transmit what we have.
1299 					 */
1300 					bp->b_rptr = cp;
1301 					(void) putbq(q, bp);
1302 					goto transmit;
1303 				}
1304 				*current_position++ = *cp++;
1305 				cc--;
1306 				bytes_left--;
1307 			}
1308 			nbp = bp;
1309 			bp = bp->b_cont;
1310 			freeb(nbp);
1311 		} while (bp != NULL);
1312 	}
1313 
1314 transmit:
1315 	if ((cc = MAXHIWAT - bytes_left) != 0)
1316 		console_puts(obuf, cc);
1317 
1318 	mutex_enter(&pvc->vc_state_lock);
1319 	pvc->vc_flags &= ~WCS_BUSY;
1320 	mutex_exit(&pvc->vc_state_lock);
1321 
1322 	wcstart(pvc);
1323 }
1324 #endif /* _HAVE_TEM_FIRMWARE */
1325 
1326 /*
1327  * Put procedure for lower read queue.
1328  * Pass everything up to queue above "upper half".
1329  */
1330 static int
1331 wclrput(queue_t *q, mblk_t *mp)
1332 {
1333 	vc_state_t *pvc;
1334 	queue_t *upq;
1335 	struct iocblk *iocp;
1336 
1337 	pvc = vt_minor2vc(VT_ACTIVE);
1338 
1339 	DPRINTF(PRINT_L1, PRINT_MASK_ALL,
1340 	    ("wclrput: wclrput type = 0x%x\n", mp->b_datap->db_type));
1341 
1342 	switch (mp->b_datap->db_type) {
1343 
1344 	case M_FLUSH:
1345 		if (*mp->b_rptr == FLUSHW || *mp->b_rptr == FLUSHRW) {
1346 			/*
1347 			 * Flush our write queue.
1348 			 */
1349 			/* XXX doesn't flush M_DELAY */
1350 			flushq(WR(q), FLUSHDATA);
1351 			*mp->b_rptr = FLUSHR;	/* it has been flushed */
1352 		}
1353 		if (*mp->b_rptr == FLUSHR || *mp->b_rptr == FLUSHRW) {
1354 			flushq(q, FLUSHDATA);
1355 			*mp->b_rptr = FLUSHW;	/* it has been flushed */
1356 			qreply(q, mp);	/* give the read queues a crack at it */
1357 		} else
1358 			freemsg(mp);
1359 		break;
1360 
1361 	case M_DATA:
1362 		if (consmode == CONS_KFB && vt_check_hotkeys(mp)) {
1363 			freemsg(mp);
1364 			break;
1365 		}
1366 
1367 		if ((upq = pvc->vc_ttycommon.t_readq) != NULL) {
1368 			if (!canput(upq->q_next)) {
1369 				ttycommon_qfull(&pvc->vc_ttycommon, upq);
1370 				wcstart(pvc);
1371 				freemsg(mp);
1372 			} else {
1373 				putnext(upq, mp);
1374 			}
1375 		} else
1376 			freemsg(mp);
1377 		break;
1378 
1379 	case M_IOCACK:
1380 	case M_IOCNAK:
1381 		iocp = (struct iocblk *)(void *)mp->b_rptr;
1382 		if (wscons.wc_pending_link != NULL &&
1383 		    iocp->ioc_id == wscons.wc_kb_getpolledio_id) {
1384 			switch (mp->b_datap->db_type) {
1385 
1386 			case M_IOCACK:
1387 				switch (iocp->ioc_cmd) {
1388 
1389 				case CONSOPENPOLLEDIO:
1390 					DPRINTF(PRINT_L1, PRINT_MASK_ALL,
1391 					    ("wclrput: "
1392 					    "ACK CONSOPENPOLLEDIO\n"));
1393 					wscons.wc_kb_polledio =
1394 					    *(struct cons_polledio **)
1395 					    (void *)mp->b_cont->b_rptr;
1396 					wscons.wc_polledio.
1397 					    cons_polledio_getchar =
1398 					    wc_polled_getchar;
1399 					wscons.wc_polledio.
1400 					    cons_polledio_ischar =
1401 					    wc_polled_ischar;
1402 					break;
1403 
1404 				case CONSCLOSEPOLLEDIO:
1405 					DPRINTF(PRINT_L1, PRINT_MASK_ALL,
1406 					    ("wclrput: "
1407 					    "ACK CONSCLOSEPOLLEDIO\n"));
1408 					wscons.wc_kb_polledio = NULL;
1409 					wscons.wc_kbdqueue = NULL;
1410 					wscons.wc_polledio.
1411 					    cons_polledio_getchar = NULL;
1412 					wscons.wc_polledio.
1413 					    cons_polledio_ischar = NULL;
1414 					break;
1415 				default:
1416 					DPRINTF(PRINT_L1, PRINT_MASK_ALL,
1417 					    ("wclrput: "
1418 					    "ACK UNKNOWN\n"));
1419 				}
1420 
1421 				break;
1422 			case M_IOCNAK:
1423 				/*
1424 				 * Keyboard may or may not support polled I/O.
1425 				 * This ioctl may have been rejected because
1426 				 * we only have the wc->conskbd chain built,
1427 				 * and the keyboard driver has not been linked
1428 				 * underneath conskbd yet.
1429 				 */
1430 				DPRINTF(PRINT_L1, PRINT_MASK_ALL,
1431 				    ("wclrput: NAK\n"));
1432 
1433 				switch (iocp->ioc_cmd) {
1434 
1435 				case CONSCLOSEPOLLEDIO:
1436 					wscons.wc_kb_polledio = NULL;
1437 					wscons.wc_kbdqueue = NULL;
1438 					wscons.wc_polledio.
1439 					    cons_polledio_getchar = NULL;
1440 					wscons.wc_polledio.
1441 					    cons_polledio_ischar = NULL;
1442 					break;
1443 				}
1444 				break;
1445 			}
1446 
1447 			/*
1448 			 * Discard the response, replace it with the
1449 			 * pending response to the I_PLINK, then let it
1450 			 * flow upward.
1451 			 */
1452 			freemsg(mp);
1453 			mp = wscons.wc_pending_link;
1454 			wscons.wc_pending_link = NULL;
1455 			wscons.wc_kb_getpolledio_id = 0;
1456 		}
1457 		/* FALLTHROUGH */
1458 
1459 	default:	/* inc M_ERROR, M_HANGUP, M_IOCACK, M_IOCNAK, ... */
1460 		if (wscons.wc_pending_wq != NULL) {
1461 			qreply(wscons.wc_pending_wq, mp);
1462 			wscons.wc_pending_wq = NULL;
1463 			break;
1464 		}
1465 
1466 		if ((upq = pvc->vc_ttycommon.t_readq) != NULL) {
1467 			putnext(upq, mp);
1468 		} else {
1469 			DPRINTF(PRINT_L1, PRINT_MASK_ALL,
1470 			    ("wclrput: Message DISCARDED\n"));
1471 			freemsg(mp);
1472 		}
1473 		break;
1474 	}
1475 
1476 	return (0);
1477 }
1478 
1479 #ifdef _HAVE_TEM_FIRMWARE
1480 /*
1481  *  This routine exists so that prom_write() can redirect writes
1482  *  to the framebuffer through the kernel terminal emulator, if
1483  *  that configuration is selected during consconfig.
1484  *  When the kernel terminal emulator is enabled, consconfig_dacf
1485  *  sets up the PROM output redirect vector to enter this function.
1486  *  During panic the console will already be powered up as part of
1487  *  calling into the prom_*() layer.
1488  */
1489 /* ARGSUSED */
1490 ssize_t
1491 wc_cons_wrtvec(promif_redir_arg_t arg, uchar_t *s, size_t n)
1492 {
1493 	vc_state_t *pvc;
1494 
1495 	pvc = vt_minor2vc(VT_ACTIVE);
1496 
1497 	if (pvc->vc_tem == NULL)
1498 		return (0);
1499 
1500 	ASSERT(consmode == CONS_KFB);
1501 
1502 	if (panicstr)
1503 		polled_io_cons_write(s, n);
1504 	else
1505 		(void) tem_write(pvc->vc_tem, s, n, kcred);
1506 
1507 	return (n);
1508 }
1509 #endif /* _HAVE_TEM_FIRMWARE */
1510 
1511 /*
1512  * These are for systems without OBP, and for devices that cannot be
1513  * shared between Solaris and the OBP.
1514  */
1515 static void
1516 wc_polled_putchar(cons_polledio_arg_t arg, unsigned char c)
1517 {
1518 	vc_state_t *pvc;
1519 
1520 	pvc = vt_minor2vc(VT_ACTIVE);
1521 
1522 	if (c == '\n')
1523 		wc_polled_putchar(arg, '\r');
1524 
1525 	if (pvc->vc_tem == NULL) {
1526 		/*
1527 		 * We have no terminal emulator configured.  We have no
1528 		 * recourse but to drop the output on the floor.
1529 		 */
1530 		return;
1531 	}
1532 
1533 	tem_safe_polled_write(pvc->vc_tem, &c, 1);
1534 }
1535 
1536 /*
1537  * These are for systems without OBP, and for devices that cannot be
1538  * shared between Solaris and the OBP.
1539  */
1540 static int
1541 wc_polled_getchar(cons_polledio_arg_t arg)
1542 {
1543 	struct wscons_state *wscons = (struct wscons_state *)arg;
1544 
1545 	if (wscons->wc_kb_polledio == NULL) {
1546 		prom_printf("wscons:  getchar with no keyboard support");
1547 		prom_printf("Halted...");
1548 		for (;;)
1549 			/* HANG FOREVER */;
1550 	}
1551 
1552 	return (wscons->wc_kb_polledio->cons_polledio_getchar(
1553 	    wscons->wc_kb_polledio->cons_polledio_argument));
1554 }
1555 
1556 static boolean_t
1557 wc_polled_ischar(cons_polledio_arg_t arg)
1558 {
1559 	struct wscons_state *wscons = (struct wscons_state *)arg;
1560 
1561 	if (wscons->wc_kb_polledio == NULL)
1562 		return (B_FALSE);
1563 
1564 	return (wscons->wc_kb_polledio->cons_polledio_ischar(
1565 	    wscons->wc_kb_polledio->cons_polledio_argument));
1566 }
1567 
1568 static void
1569 wc_polled_enter(cons_polledio_arg_t arg)
1570 {
1571 	struct wscons_state *wscons = (struct wscons_state *)arg;
1572 
1573 	if (wscons->wc_kb_polledio == NULL)
1574 		return;
1575 
1576 	if (wscons->wc_kb_polledio->cons_polledio_enter != NULL) {
1577 		wscons->wc_kb_polledio->cons_polledio_enter(
1578 		    wscons->wc_kb_polledio->cons_polledio_argument);
1579 	}
1580 }
1581 
1582 static void
1583 wc_polled_exit(cons_polledio_arg_t arg)
1584 {
1585 	struct wscons_state *wscons = (struct wscons_state *)arg;
1586 
1587 	if (wscons->wc_kb_polledio == NULL)
1588 		return;
1589 
1590 	if (wscons->wc_kb_polledio->cons_polledio_exit != NULL) {
1591 		wscons->wc_kb_polledio->cons_polledio_exit(
1592 		    wscons->wc_kb_polledio->cons_polledio_argument);
1593 	}
1594 }
1595 
1596 
1597 #ifdef DEBUG
1598 static void
1599 wc_dprintf(const char *fmt, ...)
1600 {
1601 	char buf[256];
1602 	va_list ap;
1603 
1604 	va_start(ap, fmt);
1605 	(void) vsprintf(buf, fmt, ap);
1606 	va_end(ap);
1607 
1608 	cmn_err(CE_WARN, "wc: %s", buf);
1609 }
1610 #endif
1611 
1612 /*ARGSUSED*/
1613 static void
1614 update_property(vc_state_t *pvc, char *name, ushort_t value)
1615 {
1616 	char data[8];
1617 
1618 	(void) snprintf(data, sizeof (data), "%u", value);
1619 
1620 	(void) ddi_prop_update_string(wscons.wc_dev, wc_dip, name, data);
1621 }
1622 
1623 /*
1624  * Gets the number of text rows and columns and the
1625  * width and height (in pixels) of the console.
1626  */
1627 void
1628 wc_get_size(vc_state_t *pvc)
1629 {
1630 	struct winsize *t = &pvc->vc_ttycommon.t_size;
1631 	ushort_t r = LOSCREENLINES, c = LOSCREENCOLS, x = 0, y = 0;
1632 
1633 	if (pvc->vc_tem != NULL)
1634 		tem_get_size(&r, &c, &x, &y);
1635 #ifdef _HAVE_TEM_FIRMWARE
1636 	else
1637 		console_get_size(&r, &c, &x, &y);
1638 #endif /* _HAVE_TEM_FIRMWARE */
1639 
1640 	mutex_enter(&pvc->vc_ttycommon.t_excl);
1641 	t->ws_col = c;
1642 	t->ws_row = r;
1643 	t->ws_xpixel = x;
1644 	t->ws_ypixel = y;
1645 	mutex_exit(&pvc->vc_ttycommon.t_excl);
1646 
1647 	if (pvc->vc_minor != 0)
1648 		return;
1649 
1650 	/* only for the wscons:0 */
1651 	update_property(pvc, "screen-#cols",  c);
1652 	update_property(pvc, "screen-#rows",  r);
1653 	update_property(pvc, "screen-width",  x);
1654 	update_property(pvc, "screen-height", y);
1655 }
1656 
1657 /*ARGSUSED*/
1658 static void
1659 wc_modechg_cb(tem_modechg_cb_arg_t arg)
1660 {
1661 	minor_t index;
1662 	vc_state_t *pvc;
1663 
1664 	mutex_enter(&vc_lock);
1665 	for (index = 0; index < VC_INSTANCES_COUNT; index++) {
1666 		pvc = vt_minor2vc(index);
1667 
1668 		mutex_enter(&pvc->vc_state_lock);
1669 
1670 		if ((pvc->vc_flags & WCS_ISOPEN) &&
1671 		    (pvc->vc_flags & WCS_INIT))
1672 			wc_get_size(pvc);
1673 
1674 		mutex_exit(&pvc->vc_state_lock);
1675 	}
1676 	mutex_exit(&vc_lock);
1677 }
1678