1*0Sstevel@tonic-gate /* 2*0Sstevel@tonic-gate * CDDL HEADER START 3*0Sstevel@tonic-gate * 4*0Sstevel@tonic-gate * The contents of this file are subject to the terms of the 5*0Sstevel@tonic-gate * Common Development and Distribution License, Version 1.0 only 6*0Sstevel@tonic-gate * (the "License"). You may not use this file except in compliance 7*0Sstevel@tonic-gate * with the License. 8*0Sstevel@tonic-gate * 9*0Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 10*0Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing. 11*0Sstevel@tonic-gate * See the License for the specific language governing permissions 12*0Sstevel@tonic-gate * and limitations under the License. 13*0Sstevel@tonic-gate * 14*0Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each 15*0Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 16*0Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the 17*0Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying 18*0Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner] 19*0Sstevel@tonic-gate * 20*0Sstevel@tonic-gate * CDDL HEADER END 21*0Sstevel@tonic-gate */ 22*0Sstevel@tonic-gate /* 23*0Sstevel@tonic-gate * Copyright 2004 Sun Microsystems, Inc. All rights reserved. 24*0Sstevel@tonic-gate * Use is subject to license terms. 25*0Sstevel@tonic-gate */ 26*0Sstevel@tonic-gate 27*0Sstevel@tonic-gate #pragma ident "%Z%%M% %I% %E% SMI" 28*0Sstevel@tonic-gate 29*0Sstevel@tonic-gate /* 30*0Sstevel@tonic-gate * This module implements the services provided by the rlogin daemon 31*0Sstevel@tonic-gate * after the connection is set up. Mainly this means responding to 32*0Sstevel@tonic-gate * interrupts and window size changes. It begins operation in "disabled" 33*0Sstevel@tonic-gate * state, and sends a T_DATA_REQ to the daemon to indicate that it is 34*0Sstevel@tonic-gate * in place and ready to be enabled. The daemon can then know when all 35*0Sstevel@tonic-gate * data which sneaked passed rlmod (before it was pushed) has been received. 36*0Sstevel@tonic-gate * The daemon may process this data, or send data back to be inserted in 37*0Sstevel@tonic-gate * the read queue at the head with the RL_IOC_ENABLE ioctl. 38*0Sstevel@tonic-gate */ 39*0Sstevel@tonic-gate 40*0Sstevel@tonic-gate #include <sys/types.h> 41*0Sstevel@tonic-gate #include <sys/param.h> 42*0Sstevel@tonic-gate #include <sys/stream.h> 43*0Sstevel@tonic-gate #include <sys/stropts.h> 44*0Sstevel@tonic-gate #include <sys/strsun.h> 45*0Sstevel@tonic-gate #include <sys/kmem.h> 46*0Sstevel@tonic-gate #include <sys/errno.h> 47*0Sstevel@tonic-gate #include <sys/ddi.h> 48*0Sstevel@tonic-gate #include <sys/sunddi.h> 49*0Sstevel@tonic-gate #include <sys/tihdr.h> 50*0Sstevel@tonic-gate #include <sys/ptem.h> 51*0Sstevel@tonic-gate #include <sys/conf.h> 52*0Sstevel@tonic-gate #include <sys/debug.h> 53*0Sstevel@tonic-gate #include <sys/modctl.h> 54*0Sstevel@tonic-gate #include <sys/vtrace.h> 55*0Sstevel@tonic-gate #include <sys/rlioctl.h> 56*0Sstevel@tonic-gate #include <sys/termios.h> 57*0Sstevel@tonic-gate #include <sys/termio.h> 58*0Sstevel@tonic-gate #include <sys/byteorder.h> 59*0Sstevel@tonic-gate #include <sys/cmn_err.h> 60*0Sstevel@tonic-gate #include <sys/cryptmod.h> 61*0Sstevel@tonic-gate 62*0Sstevel@tonic-gate extern struct streamtab rloginmodinfo; 63*0Sstevel@tonic-gate 64*0Sstevel@tonic-gate static struct fmodsw fsw = { 65*0Sstevel@tonic-gate "rlmod", 66*0Sstevel@tonic-gate &rloginmodinfo, 67*0Sstevel@tonic-gate D_MTQPAIR | D_MP 68*0Sstevel@tonic-gate }; 69*0Sstevel@tonic-gate 70*0Sstevel@tonic-gate /* 71*0Sstevel@tonic-gate * Module linkage information for the kernel. 72*0Sstevel@tonic-gate */ 73*0Sstevel@tonic-gate 74*0Sstevel@tonic-gate static struct modlstrmod modlstrmod = { 75*0Sstevel@tonic-gate &mod_strmodops, 76*0Sstevel@tonic-gate "rloginmod module", 77*0Sstevel@tonic-gate &fsw 78*0Sstevel@tonic-gate }; 79*0Sstevel@tonic-gate 80*0Sstevel@tonic-gate static struct modlinkage modlinkage = { 81*0Sstevel@tonic-gate MODREV_1, &modlstrmod, NULL 82*0Sstevel@tonic-gate }; 83*0Sstevel@tonic-gate 84*0Sstevel@tonic-gate 85*0Sstevel@tonic-gate int 86*0Sstevel@tonic-gate _init(void) 87*0Sstevel@tonic-gate { 88*0Sstevel@tonic-gate return (mod_install(&modlinkage)); 89*0Sstevel@tonic-gate } 90*0Sstevel@tonic-gate 91*0Sstevel@tonic-gate int 92*0Sstevel@tonic-gate _fini(void) 93*0Sstevel@tonic-gate { 94*0Sstevel@tonic-gate return (mod_remove(&modlinkage)); 95*0Sstevel@tonic-gate } 96*0Sstevel@tonic-gate 97*0Sstevel@tonic-gate int 98*0Sstevel@tonic-gate _info(struct modinfo *modinfop) 99*0Sstevel@tonic-gate { 100*0Sstevel@tonic-gate return (mod_info(&modlinkage, modinfop)); 101*0Sstevel@tonic-gate } 102*0Sstevel@tonic-gate 103*0Sstevel@tonic-gate struct rlmod_info; /* forward reference for function prototype */ 104*0Sstevel@tonic-gate 105*0Sstevel@tonic-gate static int rlmodopen(queue_t *, dev_t *, int, int, cred_t *); 106*0Sstevel@tonic-gate static int rlmodclose(queue_t *, int, cred_t *); 107*0Sstevel@tonic-gate static int rlmodrput(queue_t *, mblk_t *); 108*0Sstevel@tonic-gate static int rlmodrsrv(queue_t *); 109*0Sstevel@tonic-gate static int rlmodwput(queue_t *, mblk_t *); 110*0Sstevel@tonic-gate static int rlmodwsrv(queue_t *); 111*0Sstevel@tonic-gate static int rlmodrmsg(queue_t *, mblk_t *); 112*0Sstevel@tonic-gate static mblk_t *make_expmblk(char); 113*0Sstevel@tonic-gate static int rlwinctl(queue_t *, mblk_t *); 114*0Sstevel@tonic-gate static mblk_t *rlwinsetup(queue_t *, mblk_t *, unsigned char *); 115*0Sstevel@tonic-gate 116*0Sstevel@tonic-gate static void rlmod_timer(void *); 117*0Sstevel@tonic-gate static void rlmod_buffer(void *); 118*0Sstevel@tonic-gate static boolean_t tty_flow(queue_t *, struct rlmod_info *, mblk_t *); 119*0Sstevel@tonic-gate static boolean_t rlmodwioctl(queue_t *, mblk_t *); 120*0Sstevel@tonic-gate static void recover(queue_t *, mblk_t *, size_t); 121*0Sstevel@tonic-gate static void recover1(queue_t *, size_t); 122*0Sstevel@tonic-gate 123*0Sstevel@tonic-gate #define RLMOD_ID 106 124*0Sstevel@tonic-gate #define SIMWAIT (1*hz) 125*0Sstevel@tonic-gate 126*0Sstevel@tonic-gate /* 127*0Sstevel@tonic-gate * Stream module data structure definitions. 128*0Sstevel@tonic-gate * generally pushed onto tcp by rlogin daemon 129*0Sstevel@tonic-gate * 130*0Sstevel@tonic-gate */ 131*0Sstevel@tonic-gate static struct module_info rloginmodiinfo = { 132*0Sstevel@tonic-gate RLMOD_ID, /* module id number */ 133*0Sstevel@tonic-gate "rlmod", /* module name */ 134*0Sstevel@tonic-gate 0, /* minimum packet size */ 135*0Sstevel@tonic-gate INFPSZ, /* maximum packet size */ 136*0Sstevel@tonic-gate 512, /* hi-water mark */ 137*0Sstevel@tonic-gate 256 /* lo-water mark */ 138*0Sstevel@tonic-gate }; 139*0Sstevel@tonic-gate 140*0Sstevel@tonic-gate static struct qinit rloginmodrinit = { 141*0Sstevel@tonic-gate rlmodrput, 142*0Sstevel@tonic-gate rlmodrsrv, 143*0Sstevel@tonic-gate rlmodopen, 144*0Sstevel@tonic-gate rlmodclose, 145*0Sstevel@tonic-gate nulldev, 146*0Sstevel@tonic-gate &rloginmodiinfo, 147*0Sstevel@tonic-gate NULL 148*0Sstevel@tonic-gate }; 149*0Sstevel@tonic-gate 150*0Sstevel@tonic-gate static struct qinit rloginmodwinit = { 151*0Sstevel@tonic-gate rlmodwput, 152*0Sstevel@tonic-gate rlmodwsrv, 153*0Sstevel@tonic-gate NULL, 154*0Sstevel@tonic-gate NULL, 155*0Sstevel@tonic-gate nulldev, 156*0Sstevel@tonic-gate &rloginmodiinfo, 157*0Sstevel@tonic-gate NULL 158*0Sstevel@tonic-gate }; 159*0Sstevel@tonic-gate 160*0Sstevel@tonic-gate struct streamtab rloginmodinfo = { 161*0Sstevel@tonic-gate &rloginmodrinit, 162*0Sstevel@tonic-gate &rloginmodwinit, 163*0Sstevel@tonic-gate NULL, 164*0Sstevel@tonic-gate NULL 165*0Sstevel@tonic-gate }; 166*0Sstevel@tonic-gate 167*0Sstevel@tonic-gate /* 168*0Sstevel@tonic-gate * Per-instance state struct for the rloginmod module. 169*0Sstevel@tonic-gate */ 170*0Sstevel@tonic-gate struct rlmod_info 171*0Sstevel@tonic-gate { 172*0Sstevel@tonic-gate int flags; 173*0Sstevel@tonic-gate bufcall_id_t wbufcid; 174*0Sstevel@tonic-gate bufcall_id_t rbufcid; 175*0Sstevel@tonic-gate timeout_id_t wtimoutid; 176*0Sstevel@tonic-gate timeout_id_t rtimoutid; 177*0Sstevel@tonic-gate int rl_expdat; 178*0Sstevel@tonic-gate int stopmode; 179*0Sstevel@tonic-gate mblk_t *unbind_mp; 180*0Sstevel@tonic-gate char startc; 181*0Sstevel@tonic-gate char stopc; 182*0Sstevel@tonic-gate char oobdata[1]; 183*0Sstevel@tonic-gate mblk_t *wndw_sz_hd_mp; 184*0Sstevel@tonic-gate }; 185*0Sstevel@tonic-gate 186*0Sstevel@tonic-gate /* 187*0Sstevel@tonic-gate * Flag used in flags 188*0Sstevel@tonic-gate */ 189*0Sstevel@tonic-gate #define RL_DISABLED 0x1 190*0Sstevel@tonic-gate #define RL_IOCPASSTHRU 0x2 191*0Sstevel@tonic-gate 192*0Sstevel@tonic-gate /*ARGSUSED*/ 193*0Sstevel@tonic-gate static void 194*0Sstevel@tonic-gate dummy_callback(void *arg) 195*0Sstevel@tonic-gate {} 196*0Sstevel@tonic-gate 197*0Sstevel@tonic-gate /* 198*0Sstevel@tonic-gate * rlmodopen - open routine gets called when the 199*0Sstevel@tonic-gate * module gets pushed onto the stream. 200*0Sstevel@tonic-gate */ 201*0Sstevel@tonic-gate /*ARGSUSED*/ 202*0Sstevel@tonic-gate static int 203*0Sstevel@tonic-gate rlmodopen(queue_t *q, dev_t *devp, int oflag, int sflag, cred_t *cred) 204*0Sstevel@tonic-gate { 205*0Sstevel@tonic-gate struct rlmod_info *rmip; 206*0Sstevel@tonic-gate union T_primitives *tp; 207*0Sstevel@tonic-gate mblk_t *bp; 208*0Sstevel@tonic-gate int error; 209*0Sstevel@tonic-gate 210*0Sstevel@tonic-gate if (sflag != MODOPEN) 211*0Sstevel@tonic-gate return (EINVAL); 212*0Sstevel@tonic-gate 213*0Sstevel@tonic-gate if (q->q_ptr != NULL) { 214*0Sstevel@tonic-gate /* It's already attached. */ 215*0Sstevel@tonic-gate return (0); 216*0Sstevel@tonic-gate } 217*0Sstevel@tonic-gate 218*0Sstevel@tonic-gate /* 219*0Sstevel@tonic-gate * Allocate state structure. 220*0Sstevel@tonic-gate */ 221*0Sstevel@tonic-gate rmip = kmem_zalloc(sizeof (*rmip), KM_SLEEP); 222*0Sstevel@tonic-gate 223*0Sstevel@tonic-gate /* 224*0Sstevel@tonic-gate * Cross-link. 225*0Sstevel@tonic-gate */ 226*0Sstevel@tonic-gate q->q_ptr = rmip; 227*0Sstevel@tonic-gate WR(q)->q_ptr = rmip; 228*0Sstevel@tonic-gate rmip->rl_expdat = 0; 229*0Sstevel@tonic-gate rmip->stopmode = TIOCPKT_DOSTOP; 230*0Sstevel@tonic-gate rmip->startc = CTRL('q'); 231*0Sstevel@tonic-gate rmip->stopc = CTRL('s'); 232*0Sstevel@tonic-gate rmip->oobdata[0] = (char)TIOCPKT_WINDOW; 233*0Sstevel@tonic-gate rmip->wndw_sz_hd_mp = NULL; 234*0Sstevel@tonic-gate /* 235*0Sstevel@tonic-gate * Allow only non-M_DATA blocks to pass up to in.rlogind until 236*0Sstevel@tonic-gate * it is ready for M_DATA (indicated by RL_IOC_ENABLE). 237*0Sstevel@tonic-gate */ 238*0Sstevel@tonic-gate rmip->flags |= RL_DISABLED; 239*0Sstevel@tonic-gate 240*0Sstevel@tonic-gate qprocson(q); 241*0Sstevel@tonic-gate 242*0Sstevel@tonic-gate /* 243*0Sstevel@tonic-gate * Since TCP operates in the TLI-inspired brain-dead fashion, 244*0Sstevel@tonic-gate * the connection will revert to bound state if the connection 245*0Sstevel@tonic-gate * is reset by the client. We must send a T_UNBIND_REQ in 246*0Sstevel@tonic-gate * that case so the port doesn't get "wedged" (preventing 247*0Sstevel@tonic-gate * inetd from being able to restart the listener). Allocate 248*0Sstevel@tonic-gate * it here, so that we don't need to worry about allocb() 249*0Sstevel@tonic-gate * failures later. 250*0Sstevel@tonic-gate */ 251*0Sstevel@tonic-gate while ((rmip->unbind_mp = allocb(sizeof (union T_primitives), 252*0Sstevel@tonic-gate BPRI_HI)) == NULL) { 253*0Sstevel@tonic-gate bufcall_id_t id = qbufcall(q, sizeof (union T_primitives), 254*0Sstevel@tonic-gate BPRI_HI, dummy_callback, NULL); 255*0Sstevel@tonic-gate if (!qwait_sig(q)) { 256*0Sstevel@tonic-gate qunbufcall(q, id); 257*0Sstevel@tonic-gate error = EINTR; 258*0Sstevel@tonic-gate goto fail; 259*0Sstevel@tonic-gate } 260*0Sstevel@tonic-gate qunbufcall(q, id); 261*0Sstevel@tonic-gate } 262*0Sstevel@tonic-gate rmip->unbind_mp->b_wptr = rmip->unbind_mp->b_rptr + 263*0Sstevel@tonic-gate sizeof (struct T_unbind_req); 264*0Sstevel@tonic-gate rmip->unbind_mp->b_datap->db_type = M_PROTO; 265*0Sstevel@tonic-gate tp = (union T_primitives *)rmip->unbind_mp->b_rptr; 266*0Sstevel@tonic-gate tp->type = T_UNBIND_REQ; 267*0Sstevel@tonic-gate 268*0Sstevel@tonic-gate /* 269*0Sstevel@tonic-gate * Send a M_PROTO msg of type T_DATA_REQ (this is unique for 270*0Sstevel@tonic-gate * read queue since only write queue can get T_DATA_REQ). 271*0Sstevel@tonic-gate * Readstream routine in the daemon will do a getmsg() till 272*0Sstevel@tonic-gate * it receives this proto message. 273*0Sstevel@tonic-gate */ 274*0Sstevel@tonic-gate while ((bp = allocb(sizeof (union T_primitives), BPRI_HI)) == NULL) { 275*0Sstevel@tonic-gate bufcall_id_t id = qbufcall(q, sizeof (union T_primitives), 276*0Sstevel@tonic-gate BPRI_HI, dummy_callback, NULL); 277*0Sstevel@tonic-gate if (!qwait_sig(q)) { 278*0Sstevel@tonic-gate qunbufcall(q, id); 279*0Sstevel@tonic-gate error = EINTR; 280*0Sstevel@tonic-gate goto fail; 281*0Sstevel@tonic-gate } 282*0Sstevel@tonic-gate qunbufcall(q, id); 283*0Sstevel@tonic-gate } 284*0Sstevel@tonic-gate bp->b_datap->db_type = M_PROTO; 285*0Sstevel@tonic-gate bp->b_wptr = bp->b_rptr + sizeof (union T_primitives); 286*0Sstevel@tonic-gate tp = (union T_primitives *)bp->b_rptr; 287*0Sstevel@tonic-gate tp->type = T_DATA_REQ; 288*0Sstevel@tonic-gate tp->data_req.MORE_flag = 0; 289*0Sstevel@tonic-gate 290*0Sstevel@tonic-gate putnext(q, bp); 291*0Sstevel@tonic-gate return (0); 292*0Sstevel@tonic-gate fail: 293*0Sstevel@tonic-gate qprocsoff(q); 294*0Sstevel@tonic-gate if (rmip->unbind_mp != NULL) { 295*0Sstevel@tonic-gate freemsg(rmip->unbind_mp); 296*0Sstevel@tonic-gate } 297*0Sstevel@tonic-gate kmem_free(rmip, sizeof (struct rlmod_info)); 298*0Sstevel@tonic-gate q->q_ptr = NULL; 299*0Sstevel@tonic-gate WR(q)->q_ptr = NULL; 300*0Sstevel@tonic-gate return (error); 301*0Sstevel@tonic-gate } 302*0Sstevel@tonic-gate 303*0Sstevel@tonic-gate 304*0Sstevel@tonic-gate /* 305*0Sstevel@tonic-gate * rlmodclose - This routine gets called when the module 306*0Sstevel@tonic-gate * gets popped off of the stream. 307*0Sstevel@tonic-gate */ 308*0Sstevel@tonic-gate 309*0Sstevel@tonic-gate /*ARGSUSED*/ 310*0Sstevel@tonic-gate static int 311*0Sstevel@tonic-gate rlmodclose(queue_t *q, int flag, cred_t *credp) 312*0Sstevel@tonic-gate { 313*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 314*0Sstevel@tonic-gate mblk_t *mp; 315*0Sstevel@tonic-gate 316*0Sstevel@tonic-gate /* 317*0Sstevel@tonic-gate * Flush any write-side data downstream. Ignoring flow 318*0Sstevel@tonic-gate * control at this point is known to be safe because the 319*0Sstevel@tonic-gate * M_HANGUP below poisons the stream such that no modules can 320*0Sstevel@tonic-gate * be pushed again. 321*0Sstevel@tonic-gate */ 322*0Sstevel@tonic-gate while (mp = getq(WR(q))) 323*0Sstevel@tonic-gate putnext(WR(q), mp); 324*0Sstevel@tonic-gate 325*0Sstevel@tonic-gate /* Poison the stream head so that we can't be pushed again. */ 326*0Sstevel@tonic-gate (void) putnextctl(q, M_HANGUP); 327*0Sstevel@tonic-gate 328*0Sstevel@tonic-gate qprocsoff(q); 329*0Sstevel@tonic-gate if (rmip->wbufcid) { 330*0Sstevel@tonic-gate qunbufcall(q, rmip->wbufcid); 331*0Sstevel@tonic-gate rmip->wbufcid = 0; 332*0Sstevel@tonic-gate } 333*0Sstevel@tonic-gate if (rmip->rbufcid) { 334*0Sstevel@tonic-gate qunbufcall(q, rmip->rbufcid); 335*0Sstevel@tonic-gate rmip->rbufcid = 0; 336*0Sstevel@tonic-gate } 337*0Sstevel@tonic-gate if (rmip->wtimoutid) { 338*0Sstevel@tonic-gate (void) quntimeout(q, rmip->wtimoutid); 339*0Sstevel@tonic-gate rmip->wtimoutid = 0; 340*0Sstevel@tonic-gate } 341*0Sstevel@tonic-gate if (rmip->rtimoutid) { 342*0Sstevel@tonic-gate (void) quntimeout(q, rmip->rtimoutid); 343*0Sstevel@tonic-gate rmip->rtimoutid = 0; 344*0Sstevel@tonic-gate } 345*0Sstevel@tonic-gate 346*0Sstevel@tonic-gate if (rmip->unbind_mp != NULL) { 347*0Sstevel@tonic-gate freemsg(rmip->unbind_mp); 348*0Sstevel@tonic-gate } 349*0Sstevel@tonic-gate 350*0Sstevel@tonic-gate if (rmip->wndw_sz_hd_mp != NULL) { 351*0Sstevel@tonic-gate freemsg(rmip->wndw_sz_hd_mp); 352*0Sstevel@tonic-gate } 353*0Sstevel@tonic-gate 354*0Sstevel@tonic-gate kmem_free(q->q_ptr, sizeof (struct rlmod_info)); 355*0Sstevel@tonic-gate q->q_ptr = WR(q)->q_ptr = NULL; 356*0Sstevel@tonic-gate return (0); 357*0Sstevel@tonic-gate } 358*0Sstevel@tonic-gate 359*0Sstevel@tonic-gate /* 360*0Sstevel@tonic-gate * rlmodrput - Module read queue put procedure. 361*0Sstevel@tonic-gate * This is called from the module or 362*0Sstevel@tonic-gate * driver downstream. 363*0Sstevel@tonic-gate */ 364*0Sstevel@tonic-gate 365*0Sstevel@tonic-gate static int 366*0Sstevel@tonic-gate rlmodrput(queue_t *q, mblk_t *mp) 367*0Sstevel@tonic-gate { 368*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 369*0Sstevel@tonic-gate union T_primitives *tip; 370*0Sstevel@tonic-gate 371*0Sstevel@tonic-gate TRACE_2(TR_FAC_RLOGINP, TR_RLOGINP_RPUT_IN, "rlmodrput start: " 372*0Sstevel@tonic-gate "q %p, mp %p", q, mp); 373*0Sstevel@tonic-gate 374*0Sstevel@tonic-gate 375*0Sstevel@tonic-gate /* if low (normal) priority... */ 376*0Sstevel@tonic-gate if ((mp->b_datap->db_type < QPCTL) && 377*0Sstevel@tonic-gate /* ...and data is already queued... */ 378*0Sstevel@tonic-gate ((q->q_first) || 379*0Sstevel@tonic-gate /* ...or currently disabled and this is M_DATA... */ 380*0Sstevel@tonic-gate ((rmip->flags & RL_DISABLED) && 381*0Sstevel@tonic-gate (mp->b_datap->db_type == M_DATA)))) { 382*0Sstevel@tonic-gate /* ...delay delivery of the message */ 383*0Sstevel@tonic-gate (void) putq(q, mp); 384*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_RPUT_OUT, 385*0Sstevel@tonic-gate "rlmodrput end: q %p, mp %p, %s", q, mp, "flow"); 386*0Sstevel@tonic-gate return (0); 387*0Sstevel@tonic-gate } 388*0Sstevel@tonic-gate 389*0Sstevel@tonic-gate switch (mp->b_datap->db_type) { 390*0Sstevel@tonic-gate 391*0Sstevel@tonic-gate case M_PROTO: 392*0Sstevel@tonic-gate case M_PCPROTO: 393*0Sstevel@tonic-gate tip = (union T_primitives *)mp->b_rptr; 394*0Sstevel@tonic-gate switch (tip->type) { 395*0Sstevel@tonic-gate 396*0Sstevel@tonic-gate case T_ORDREL_IND: 397*0Sstevel@tonic-gate case T_DISCON_IND: 398*0Sstevel@tonic-gate /* Make into M_HANGUP and putnext */ 399*0Sstevel@tonic-gate mp->b_datap->db_type = M_HANGUP; 400*0Sstevel@tonic-gate mp->b_wptr = mp->b_rptr; 401*0Sstevel@tonic-gate if (mp->b_cont) { 402*0Sstevel@tonic-gate freemsg(mp->b_cont); 403*0Sstevel@tonic-gate mp->b_cont = NULL; 404*0Sstevel@tonic-gate } 405*0Sstevel@tonic-gate /* 406*0Sstevel@tonic-gate * If we haven't already, send T_UNBIND_REQ to prevent 407*0Sstevel@tonic-gate * TCP from going into "BOUND" state and locking up the 408*0Sstevel@tonic-gate * port. 409*0Sstevel@tonic-gate */ 410*0Sstevel@tonic-gate if (tip->type == T_DISCON_IND && rmip->unbind_mp != 411*0Sstevel@tonic-gate NULL) { 412*0Sstevel@tonic-gate putnext(q, mp); 413*0Sstevel@tonic-gate qreply(q, rmip->unbind_mp); 414*0Sstevel@tonic-gate rmip->unbind_mp = NULL; 415*0Sstevel@tonic-gate } else { 416*0Sstevel@tonic-gate putnext(q, mp); 417*0Sstevel@tonic-gate } 418*0Sstevel@tonic-gate break; 419*0Sstevel@tonic-gate 420*0Sstevel@tonic-gate /* 421*0Sstevel@tonic-gate * We only get T_OK_ACK when we issue the unbind, and it can 422*0Sstevel@tonic-gate * be ignored safely. 423*0Sstevel@tonic-gate */ 424*0Sstevel@tonic-gate case T_OK_ACK: 425*0Sstevel@tonic-gate ASSERT(rmip->unbind_mp == NULL); 426*0Sstevel@tonic-gate freemsg(mp); 427*0Sstevel@tonic-gate break; 428*0Sstevel@tonic-gate 429*0Sstevel@tonic-gate default: 430*0Sstevel@tonic-gate cmn_err(CE_NOTE, 431*0Sstevel@tonic-gate "rlmodrput: got 0x%x type M_PROTO/M_PCPROTO msg", 432*0Sstevel@tonic-gate tip->type); 433*0Sstevel@tonic-gate freemsg(mp); 434*0Sstevel@tonic-gate } 435*0Sstevel@tonic-gate break; 436*0Sstevel@tonic-gate 437*0Sstevel@tonic-gate case M_DATA: 438*0Sstevel@tonic-gate if (canputnext(q) && q->q_first == NULL) { 439*0Sstevel@tonic-gate (void) rlmodrmsg(q, mp); 440*0Sstevel@tonic-gate } else { 441*0Sstevel@tonic-gate (void) putq(q, mp); 442*0Sstevel@tonic-gate } 443*0Sstevel@tonic-gate break; 444*0Sstevel@tonic-gate 445*0Sstevel@tonic-gate case M_FLUSH: 446*0Sstevel@tonic-gate /* 447*0Sstevel@tonic-gate * Since M_FLUSH came from TCP, we mark it bound for 448*0Sstevel@tonic-gate * daemon, not tty. This only happens when TCP expects 449*0Sstevel@tonic-gate * to do a connection reset. 450*0Sstevel@tonic-gate */ 451*0Sstevel@tonic-gate mp->b_flag |= MSGMARK; 452*0Sstevel@tonic-gate if (*mp->b_rptr & FLUSHR) 453*0Sstevel@tonic-gate flushq(q, FLUSHALL); 454*0Sstevel@tonic-gate 455*0Sstevel@tonic-gate putnext(q, mp); 456*0Sstevel@tonic-gate break; 457*0Sstevel@tonic-gate 458*0Sstevel@tonic-gate case M_PCSIG: 459*0Sstevel@tonic-gate case M_ERROR: 460*0Sstevel@tonic-gate case M_IOCACK: 461*0Sstevel@tonic-gate case M_IOCNAK: 462*0Sstevel@tonic-gate case M_SETOPTS: 463*0Sstevel@tonic-gate if (mp->b_datap->db_type <= QPCTL && !canputnext(q)) 464*0Sstevel@tonic-gate (void) putq(q, mp); 465*0Sstevel@tonic-gate else 466*0Sstevel@tonic-gate putnext(q, mp); 467*0Sstevel@tonic-gate break; 468*0Sstevel@tonic-gate 469*0Sstevel@tonic-gate default: 470*0Sstevel@tonic-gate #ifdef DEBUG 471*0Sstevel@tonic-gate cmn_err(CE_NOTE, "rlmodrput: unexpected msg type 0x%x", 472*0Sstevel@tonic-gate mp->b_datap->db_type); 473*0Sstevel@tonic-gate #endif 474*0Sstevel@tonic-gate freemsg(mp); 475*0Sstevel@tonic-gate } 476*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_RPUT_OUT, "rlmodrput end: q %p, " 477*0Sstevel@tonic-gate "mp %p, %s", q, mp, "done"); 478*0Sstevel@tonic-gate return (0); 479*0Sstevel@tonic-gate } 480*0Sstevel@tonic-gate 481*0Sstevel@tonic-gate /* 482*0Sstevel@tonic-gate * rlmodrsrv - module read service procedure 483*0Sstevel@tonic-gate */ 484*0Sstevel@tonic-gate static int 485*0Sstevel@tonic-gate rlmodrsrv(queue_t *q) 486*0Sstevel@tonic-gate { 487*0Sstevel@tonic-gate mblk_t *mp; 488*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 489*0Sstevel@tonic-gate union T_primitives *tip; 490*0Sstevel@tonic-gate 491*0Sstevel@tonic-gate TRACE_1(TR_FAC_RLOGINP, TR_RLOGINP_RSRV_IN, "rlmodrsrv start: " 492*0Sstevel@tonic-gate "q %p", q); 493*0Sstevel@tonic-gate while ((mp = getq(q)) != NULL) { 494*0Sstevel@tonic-gate 495*0Sstevel@tonic-gate switch (mp->b_datap->db_type) { 496*0Sstevel@tonic-gate case M_DATA: 497*0Sstevel@tonic-gate if (rmip->flags & RL_DISABLED) { 498*0Sstevel@tonic-gate (void) putbq(q, mp); 499*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_RSRV_OUT, 500*0Sstevel@tonic-gate "rlmodrsrv end: q %p, mp %p, %s", q, mp, 501*0Sstevel@tonic-gate "disabled"); 502*0Sstevel@tonic-gate return (0); 503*0Sstevel@tonic-gate } 504*0Sstevel@tonic-gate if (!canputnext(q)) { 505*0Sstevel@tonic-gate (void) putbq(q, mp); 506*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_RSRV_OUT, 507*0Sstevel@tonic-gate "rlmodrsrv end: q %p, mp %p, %s", 508*0Sstevel@tonic-gate q, mp, "!canputnext"); 509*0Sstevel@tonic-gate return (0); 510*0Sstevel@tonic-gate } 511*0Sstevel@tonic-gate if (!rlmodrmsg(q, mp)) { 512*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_RSRV_OUT, 513*0Sstevel@tonic-gate "rlmodrsrv end: q %p, mp %p, %s", 514*0Sstevel@tonic-gate q, mp, "!rlmodrmsg"); 515*0Sstevel@tonic-gate return (0); 516*0Sstevel@tonic-gate } 517*0Sstevel@tonic-gate break; 518*0Sstevel@tonic-gate 519*0Sstevel@tonic-gate case M_PROTO: 520*0Sstevel@tonic-gate tip = (union T_primitives *)mp->b_rptr; 521*0Sstevel@tonic-gate switch (tip->type) { 522*0Sstevel@tonic-gate 523*0Sstevel@tonic-gate case T_ORDREL_IND: 524*0Sstevel@tonic-gate case T_DISCON_IND: 525*0Sstevel@tonic-gate /* Make into M_HANGUP and putnext */ 526*0Sstevel@tonic-gate mp->b_datap->db_type = M_HANGUP; 527*0Sstevel@tonic-gate mp->b_wptr = mp->b_rptr; 528*0Sstevel@tonic-gate if (mp->b_cont) { 529*0Sstevel@tonic-gate freemsg(mp->b_cont); 530*0Sstevel@tonic-gate mp->b_cont = NULL; 531*0Sstevel@tonic-gate } 532*0Sstevel@tonic-gate /* 533*0Sstevel@tonic-gate * If we haven't already, send T_UNBIND_REQ 534*0Sstevel@tonic-gate * to prevent TCP from going into "BOUND" 535*0Sstevel@tonic-gate * state and locking up the port. 536*0Sstevel@tonic-gate */ 537*0Sstevel@tonic-gate if (tip->type == T_DISCON_IND && 538*0Sstevel@tonic-gate rmip->unbind_mp != NULL) { 539*0Sstevel@tonic-gate putnext(q, mp); 540*0Sstevel@tonic-gate qreply(q, rmip->unbind_mp); 541*0Sstevel@tonic-gate rmip->unbind_mp = NULL; 542*0Sstevel@tonic-gate } else { 543*0Sstevel@tonic-gate putnext(q, mp); 544*0Sstevel@tonic-gate } 545*0Sstevel@tonic-gate break; 546*0Sstevel@tonic-gate 547*0Sstevel@tonic-gate /* 548*0Sstevel@tonic-gate * We only get T_OK_ACK when we issue the unbind, and 549*0Sstevel@tonic-gate * it can be ignored safely. 550*0Sstevel@tonic-gate */ 551*0Sstevel@tonic-gate case T_OK_ACK: 552*0Sstevel@tonic-gate ASSERT(rmip->unbind_mp == NULL); 553*0Sstevel@tonic-gate freemsg(mp); 554*0Sstevel@tonic-gate break; 555*0Sstevel@tonic-gate 556*0Sstevel@tonic-gate default: 557*0Sstevel@tonic-gate cmn_err(CE_NOTE, 558*0Sstevel@tonic-gate "rlmodrsrv: got 0x%x type PROTO msg", 559*0Sstevel@tonic-gate tip->type); 560*0Sstevel@tonic-gate freemsg(mp); 561*0Sstevel@tonic-gate } 562*0Sstevel@tonic-gate break; 563*0Sstevel@tonic-gate 564*0Sstevel@tonic-gate case M_SETOPTS: 565*0Sstevel@tonic-gate if (!canputnext(q)) { 566*0Sstevel@tonic-gate (void) putbq(q, mp); 567*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_RSRV_OUT, 568*0Sstevel@tonic-gate "rlmodrsrv end: q %p, mp %p, %s", 569*0Sstevel@tonic-gate q, mp, "!canputnext M_SETOPTS"); 570*0Sstevel@tonic-gate return (0); 571*0Sstevel@tonic-gate } 572*0Sstevel@tonic-gate putnext(q, mp); 573*0Sstevel@tonic-gate break; 574*0Sstevel@tonic-gate 575*0Sstevel@tonic-gate default: 576*0Sstevel@tonic-gate #ifdef DEBUG 577*0Sstevel@tonic-gate cmn_err(CE_NOTE, 578*0Sstevel@tonic-gate "rlmodrsrv: unexpected msg type 0x%x", 579*0Sstevel@tonic-gate mp->b_datap->db_type); 580*0Sstevel@tonic-gate #endif 581*0Sstevel@tonic-gate freemsg(mp); 582*0Sstevel@tonic-gate } 583*0Sstevel@tonic-gate } 584*0Sstevel@tonic-gate 585*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_RSRV_OUT, "rlmodrsrv end: q %p, " 586*0Sstevel@tonic-gate "mp %p, %s", q, mp, "empty"); 587*0Sstevel@tonic-gate 588*0Sstevel@tonic-gate return (0); 589*0Sstevel@tonic-gate } 590*0Sstevel@tonic-gate 591*0Sstevel@tonic-gate /* 592*0Sstevel@tonic-gate * rlmodwput - Module write queue put procedure. 593*0Sstevel@tonic-gate * All non-zero messages are send downstream unchanged 594*0Sstevel@tonic-gate */ 595*0Sstevel@tonic-gate static int 596*0Sstevel@tonic-gate rlmodwput(queue_t *q, mblk_t *mp) 597*0Sstevel@tonic-gate { 598*0Sstevel@tonic-gate char cntl; 599*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 600*0Sstevel@tonic-gate mblk_t *tmpmp; 601*0Sstevel@tonic-gate int rw; 602*0Sstevel@tonic-gate 603*0Sstevel@tonic-gate TRACE_2(TR_FAC_RLOGINP, TR_RLOGINP_WPUT_IN, "rlmodwput start: " 604*0Sstevel@tonic-gate "q %p, mp %p", q, mp); 605*0Sstevel@tonic-gate 606*0Sstevel@tonic-gate if (rmip->rl_expdat) { 607*0Sstevel@tonic-gate /* 608*0Sstevel@tonic-gate * call make_expmblk to create an expedited 609*0Sstevel@tonic-gate * message block. 610*0Sstevel@tonic-gate */ 611*0Sstevel@tonic-gate cntl = rmip->oobdata[0] | TIOCPKT_FLUSHWRITE; 612*0Sstevel@tonic-gate 613*0Sstevel@tonic-gate if (!canputnext(q)) { 614*0Sstevel@tonic-gate (void) putq(q, mp); 615*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WPUT_OUT, 616*0Sstevel@tonic-gate "rlmodwput end: q %p, mp %p, %s", 617*0Sstevel@tonic-gate q, mp, "expdata && !canputnext"); 618*0Sstevel@tonic-gate return (0); 619*0Sstevel@tonic-gate } 620*0Sstevel@tonic-gate if ((tmpmp = make_expmblk(cntl))) { 621*0Sstevel@tonic-gate putnext(q, tmpmp); 622*0Sstevel@tonic-gate rmip->rl_expdat = 0; 623*0Sstevel@tonic-gate } else { 624*0Sstevel@tonic-gate recover1(q, sizeof (mblk_t)); /* XXX.sparker */ 625*0Sstevel@tonic-gate } 626*0Sstevel@tonic-gate } 627*0Sstevel@tonic-gate 628*0Sstevel@tonic-gate if ((q->q_first || rmip->rl_expdat) && mp->b_datap->db_type < QPCTL) { 629*0Sstevel@tonic-gate (void) putq(q, mp); 630*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WPUT_OUT, "rlmodwput end: " 631*0Sstevel@tonic-gate "q %p, mp %p, %s", q, mp, "queued data"); 632*0Sstevel@tonic-gate return (0); 633*0Sstevel@tonic-gate } 634*0Sstevel@tonic-gate switch (mp->b_datap->db_type) { 635*0Sstevel@tonic-gate 636*0Sstevel@tonic-gate case M_DATA: 637*0Sstevel@tonic-gate if (!canputnext(q)) 638*0Sstevel@tonic-gate (void) putq(q, mp); 639*0Sstevel@tonic-gate else 640*0Sstevel@tonic-gate putnext(q, mp); 641*0Sstevel@tonic-gate break; 642*0Sstevel@tonic-gate 643*0Sstevel@tonic-gate case M_FLUSH: 644*0Sstevel@tonic-gate /* 645*0Sstevel@tonic-gate * We must take care to create and forward out-of-band data 646*0Sstevel@tonic-gate * indicating the flush to the far side. 647*0Sstevel@tonic-gate */ 648*0Sstevel@tonic-gate rw = *mp->b_rptr; 649*0Sstevel@tonic-gate *mp->b_rptr &= ~FLUSHW; 650*0Sstevel@tonic-gate qreply(q, mp); 651*0Sstevel@tonic-gate if (rw & FLUSHW) { 652*0Sstevel@tonic-gate /* 653*0Sstevel@tonic-gate * Since all rlogin protocol data is sent in this 654*0Sstevel@tonic-gate * direction as urgent data, and TCP does not flush 655*0Sstevel@tonic-gate * urgent data, it is okay to actually forward this 656*0Sstevel@tonic-gate * flush. (telmod cannot.) 657*0Sstevel@tonic-gate */ 658*0Sstevel@tonic-gate flushq(q, FLUSHDATA); 659*0Sstevel@tonic-gate /* 660*0Sstevel@tonic-gate * The putnextctl1() call can only fail if we're 661*0Sstevel@tonic-gate * out of memory. Ideally, we might set a state 662*0Sstevel@tonic-gate * bit and reschedule ourselves when memory 663*0Sstevel@tonic-gate * becomes available, so we make sure not to miss 664*0Sstevel@tonic-gate * sending the FLUSHW to TCP before the urgent 665*0Sstevel@tonic-gate * byte. Not doing this just means in some cases 666*0Sstevel@tonic-gate * a bit more trash passes before the flush takes 667*0Sstevel@tonic-gate * hold. 668*0Sstevel@tonic-gate */ 669*0Sstevel@tonic-gate (void) putnextctl1(q, M_FLUSH, FLUSHW); 670*0Sstevel@tonic-gate /* 671*0Sstevel@tonic-gate * Notify peer of the write flush request. 672*0Sstevel@tonic-gate */ 673*0Sstevel@tonic-gate cntl = rmip->oobdata[0] | TIOCPKT_FLUSHWRITE; 674*0Sstevel@tonic-gate if (!canputnext(q)) { 675*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WPUT_OUT, 676*0Sstevel@tonic-gate "rlmodwput end: q %p, mp %p, %s", 677*0Sstevel@tonic-gate q, mp, "flushw && !canputnext"); 678*0Sstevel@tonic-gate return (0); 679*0Sstevel@tonic-gate } 680*0Sstevel@tonic-gate if ((mp = make_expmblk(cntl)) == NULL) { 681*0Sstevel@tonic-gate rmip->rl_expdat = 1; 682*0Sstevel@tonic-gate recover1(q, sizeof (mblk_t)); 683*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WPUT_OUT, 684*0Sstevel@tonic-gate "rlmodwput end: q %p, mp %p, %s", 685*0Sstevel@tonic-gate q, mp, "!make_expmblk"); 686*0Sstevel@tonic-gate return (0); 687*0Sstevel@tonic-gate } 688*0Sstevel@tonic-gate putnext(q, mp); 689*0Sstevel@tonic-gate } 690*0Sstevel@tonic-gate break; 691*0Sstevel@tonic-gate 692*0Sstevel@tonic-gate case M_IOCTL: 693*0Sstevel@tonic-gate if (!rlmodwioctl(q, mp)) 694*0Sstevel@tonic-gate (void) putq(q, mp); 695*0Sstevel@tonic-gate break; 696*0Sstevel@tonic-gate 697*0Sstevel@tonic-gate case M_PROTO: 698*0Sstevel@tonic-gate switch (((union T_primitives *)mp->b_rptr)->type) { 699*0Sstevel@tonic-gate case T_EXDATA_REQ: 700*0Sstevel@tonic-gate case T_ORDREL_REQ: 701*0Sstevel@tonic-gate case T_DISCON_REQ: 702*0Sstevel@tonic-gate putnext(q, mp); 703*0Sstevel@tonic-gate break; 704*0Sstevel@tonic-gate 705*0Sstevel@tonic-gate default: 706*0Sstevel@tonic-gate #ifdef DEBUG 707*0Sstevel@tonic-gate cmn_err(CE_NOTE, 708*0Sstevel@tonic-gate "rlmodwput: unexpected TPI primitive 0x%x", 709*0Sstevel@tonic-gate ((union T_primitives *)mp->b_rptr)->type); 710*0Sstevel@tonic-gate #endif 711*0Sstevel@tonic-gate freemsg(mp); 712*0Sstevel@tonic-gate } 713*0Sstevel@tonic-gate break; 714*0Sstevel@tonic-gate 715*0Sstevel@tonic-gate case M_PCPROTO: 716*0Sstevel@tonic-gate if (((struct T_exdata_req *)mp->b_rptr)->PRIM_type == 717*0Sstevel@tonic-gate T_DISCON_REQ) { 718*0Sstevel@tonic-gate putnext(q, mp); 719*0Sstevel@tonic-gate } else { 720*0Sstevel@tonic-gate /* XXX.sparker Log unexpected message */ 721*0Sstevel@tonic-gate freemsg(mp); 722*0Sstevel@tonic-gate } 723*0Sstevel@tonic-gate break; 724*0Sstevel@tonic-gate 725*0Sstevel@tonic-gate default: 726*0Sstevel@tonic-gate #ifdef DEBUG 727*0Sstevel@tonic-gate cmn_err(CE_NOTE, 728*0Sstevel@tonic-gate "rlmodwput: unexpected msg type 0x%x", 729*0Sstevel@tonic-gate mp->b_datap->db_type); 730*0Sstevel@tonic-gate #endif 731*0Sstevel@tonic-gate freemsg(mp); 732*0Sstevel@tonic-gate break; 733*0Sstevel@tonic-gate } 734*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WPUT_OUT, "rlmodwput end: " 735*0Sstevel@tonic-gate "q %p, mp %p, %s", q, mp, "done"); 736*0Sstevel@tonic-gate return (0); 737*0Sstevel@tonic-gate } 738*0Sstevel@tonic-gate 739*0Sstevel@tonic-gate /* 740*0Sstevel@tonic-gate * rlmodwsrv - module write service procedure 741*0Sstevel@tonic-gate */ 742*0Sstevel@tonic-gate static int 743*0Sstevel@tonic-gate rlmodwsrv(queue_t *q) 744*0Sstevel@tonic-gate { 745*0Sstevel@tonic-gate mblk_t *mp, *tmpmp; 746*0Sstevel@tonic-gate char cntl; 747*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 748*0Sstevel@tonic-gate 749*0Sstevel@tonic-gate TRACE_1(TR_FAC_RLOGINP, TR_RLOGINP_WSRV_IN, "rlmodwsrv " 750*0Sstevel@tonic-gate "start: q %p", q); 751*0Sstevel@tonic-gate if (rmip->rl_expdat) { 752*0Sstevel@tonic-gate /* 753*0Sstevel@tonic-gate * call make_expmblk to create an expedited 754*0Sstevel@tonic-gate * message block. 755*0Sstevel@tonic-gate */ 756*0Sstevel@tonic-gate cntl = rmip->oobdata[0] | TIOCPKT_FLUSHWRITE; 757*0Sstevel@tonic-gate if (!canputnext(q)) { 758*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WSRV_OUT, 759*0Sstevel@tonic-gate "rlmodwsrv end: q %p, mp %p, %s", 760*0Sstevel@tonic-gate q, NULL, "!canputnext && expdat"); 761*0Sstevel@tonic-gate return (0); 762*0Sstevel@tonic-gate } 763*0Sstevel@tonic-gate if ((tmpmp = make_expmblk(cntl))) { 764*0Sstevel@tonic-gate putnext(q, tmpmp); 765*0Sstevel@tonic-gate rmip->rl_expdat = 0; 766*0Sstevel@tonic-gate } else { 767*0Sstevel@tonic-gate recover1(q, sizeof (mblk_t)); 768*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WSRV_OUT, 769*0Sstevel@tonic-gate "rlmodwsrv end: q %p, mp %p, %s", 770*0Sstevel@tonic-gate q, NULL, "!make_expmblk"); 771*0Sstevel@tonic-gate return (0); 772*0Sstevel@tonic-gate } 773*0Sstevel@tonic-gate } 774*0Sstevel@tonic-gate while ((mp = getq(q)) != NULL) { 775*0Sstevel@tonic-gate 776*0Sstevel@tonic-gate if (!canputnext(q) || rmip->rl_expdat) { 777*0Sstevel@tonic-gate (void) putbq(q, mp); 778*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WSRV_OUT, 779*0Sstevel@tonic-gate "rlmodwsrv end: q %p, mp %p, %s", 780*0Sstevel@tonic-gate q, mp, "!canputnext || expdat"); 781*0Sstevel@tonic-gate return (0); 782*0Sstevel@tonic-gate } 783*0Sstevel@tonic-gate if (mp->b_datap->db_type == M_IOCTL) { 784*0Sstevel@tonic-gate if (!rlmodwioctl(q, mp)) { 785*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WSRV_OUT, 786*0Sstevel@tonic-gate "rlmodwsrv end: q %p, mp %p, %s", 787*0Sstevel@tonic-gate q, mp, "!rlmodwioctl"); 788*0Sstevel@tonic-gate (void) putbq(q, mp); 789*0Sstevel@tonic-gate return (0); 790*0Sstevel@tonic-gate } 791*0Sstevel@tonic-gate continue; 792*0Sstevel@tonic-gate } 793*0Sstevel@tonic-gate putnext(q, mp); 794*0Sstevel@tonic-gate } 795*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WSRV_OUT, "rlmodwsrv end: q %p, " 796*0Sstevel@tonic-gate "mp %p, %s", q, mp, "done"); 797*0Sstevel@tonic-gate return (0); 798*0Sstevel@tonic-gate } 799*0Sstevel@tonic-gate 800*0Sstevel@tonic-gate /* 801*0Sstevel@tonic-gate * This routine returns a message block with an expedited 802*0Sstevel@tonic-gate * data request 803*0Sstevel@tonic-gate */ 804*0Sstevel@tonic-gate static mblk_t * 805*0Sstevel@tonic-gate make_expmblk(char cntl) 806*0Sstevel@tonic-gate { 807*0Sstevel@tonic-gate mblk_t *mp; 808*0Sstevel@tonic-gate mblk_t *bp; 809*0Sstevel@tonic-gate struct T_exdata_req *data_req; 810*0Sstevel@tonic-gate 811*0Sstevel@tonic-gate bp = allocb(sizeof (struct T_exdata_req), BPRI_MED); 812*0Sstevel@tonic-gate if (bp == NULL) 813*0Sstevel@tonic-gate return (NULL); 814*0Sstevel@tonic-gate if ((mp = allocb(sizeof (char), BPRI_MED)) == NULL) { 815*0Sstevel@tonic-gate freeb(bp); 816*0Sstevel@tonic-gate return (NULL); 817*0Sstevel@tonic-gate } 818*0Sstevel@tonic-gate bp->b_datap->db_type = M_PROTO; 819*0Sstevel@tonic-gate data_req = (struct T_exdata_req *)bp->b_rptr; 820*0Sstevel@tonic-gate data_req->PRIM_type = T_EXDATA_REQ; 821*0Sstevel@tonic-gate data_req->MORE_flag = 0; 822*0Sstevel@tonic-gate 823*0Sstevel@tonic-gate bp->b_wptr += sizeof (struct T_exdata_req); 824*0Sstevel@tonic-gate /* 825*0Sstevel@tonic-gate * Send a 1 byte data message block with appropriate 826*0Sstevel@tonic-gate * control character. 827*0Sstevel@tonic-gate */ 828*0Sstevel@tonic-gate mp->b_datap->db_type = M_DATA; 829*0Sstevel@tonic-gate mp->b_wptr = mp->b_rptr + 1; 830*0Sstevel@tonic-gate (*(char *)(mp->b_rptr)) = cntl; 831*0Sstevel@tonic-gate bp->b_cont = mp; 832*0Sstevel@tonic-gate return (bp); 833*0Sstevel@tonic-gate } 834*0Sstevel@tonic-gate /* 835*0Sstevel@tonic-gate * This routine parses M_DATA messages checking for window size protocol 836*0Sstevel@tonic-gate * from a given message block. It returns TRUE if no resource exhaustion 837*0Sstevel@tonic-gate * conditions are found. This is for use in the service procedure, which 838*0Sstevel@tonic-gate * needs to know whether to continue, or stop processing the queue. 839*0Sstevel@tonic-gate */ 840*0Sstevel@tonic-gate static int 841*0Sstevel@tonic-gate rlmodrmsg(queue_t *q, mblk_t *mp) 842*0Sstevel@tonic-gate { 843*0Sstevel@tonic-gate unsigned char *tmp, *tmp1; 844*0Sstevel@tonic-gate mblk_t *newmp; 845*0Sstevel@tonic-gate size_t sz; 846*0Sstevel@tonic-gate ssize_t count, newcount = 0; 847*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 848*0Sstevel@tonic-gate 849*0Sstevel@tonic-gate /* 850*0Sstevel@tonic-gate * Eliminate any zero length messages here, so we don't filter EOFs 851*0Sstevel@tonic-gate * accidentally. 852*0Sstevel@tonic-gate */ 853*0Sstevel@tonic-gate if (msgdsize(mp) == 0) { 854*0Sstevel@tonic-gate ASSERT(rmip->wndw_sz_hd_mp == NULL); 855*0Sstevel@tonic-gate goto out; 856*0Sstevel@tonic-gate } 857*0Sstevel@tonic-gate /* 858*0Sstevel@tonic-gate * Check if we have stored a previous message block because a window 859*0Sstevel@tonic-gate * update was split over TCP segments. If so, append the new one to 860*0Sstevel@tonic-gate * the stored one and process the stored one as if it just arrived. 861*0Sstevel@tonic-gate */ 862*0Sstevel@tonic-gate if (rmip->wndw_sz_hd_mp != NULL) { 863*0Sstevel@tonic-gate linkb(rmip->wndw_sz_hd_mp, mp); 864*0Sstevel@tonic-gate mp = rmip->wndw_sz_hd_mp; 865*0Sstevel@tonic-gate rmip->wndw_sz_hd_mp = NULL; 866*0Sstevel@tonic-gate } 867*0Sstevel@tonic-gate newmp = mp; 868*0Sstevel@tonic-gate 869*0Sstevel@tonic-gate while (mp) { 870*0Sstevel@tonic-gate tmp = mp->b_rptr; 871*0Sstevel@tonic-gate /* 872*0Sstevel@tonic-gate * scan through the entire message block 873*0Sstevel@tonic-gate */ 874*0Sstevel@tonic-gate while (tmp < mp->b_wptr) { 875*0Sstevel@tonic-gate /* 876*0Sstevel@tonic-gate * check for FF (rlogin magic escape sequence) 877*0Sstevel@tonic-gate */ 878*0Sstevel@tonic-gate if (tmp[0] == RLOGIN_MAGIC) { 879*0Sstevel@tonic-gate /* 880*0Sstevel@tonic-gate * Update bytes read so far. 881*0Sstevel@tonic-gate */ 882*0Sstevel@tonic-gate count = newcount + tmp - mp->b_rptr; 883*0Sstevel@tonic-gate /* 884*0Sstevel@tonic-gate * Pull together message chain in case 885*0Sstevel@tonic-gate * window escape is split across blocks. 886*0Sstevel@tonic-gate */ 887*0Sstevel@tonic-gate if ((pullupmsg(newmp, -1)) == 0) { 888*0Sstevel@tonic-gate sz = msgdsize(newmp); 889*0Sstevel@tonic-gate recover(q, newmp, sz); 890*0Sstevel@tonic-gate return (NULL); 891*0Sstevel@tonic-gate } 892*0Sstevel@tonic-gate /* 893*0Sstevel@tonic-gate * pullupmsg results in newmp consuming 894*0Sstevel@tonic-gate * all message blocks in this chain, and 895*0Sstevel@tonic-gate * therefor mp wants updating. 896*0Sstevel@tonic-gate */ 897*0Sstevel@tonic-gate mp = newmp; 898*0Sstevel@tonic-gate 899*0Sstevel@tonic-gate /* 900*0Sstevel@tonic-gate * adjust tmp to where we 901*0Sstevel@tonic-gate * stopped - count keeps track 902*0Sstevel@tonic-gate * of bytes read so far. 903*0Sstevel@tonic-gate * reset newcount = 0. 904*0Sstevel@tonic-gate */ 905*0Sstevel@tonic-gate tmp = mp->b_rptr + count; 906*0Sstevel@tonic-gate newcount = 0; 907*0Sstevel@tonic-gate 908*0Sstevel@tonic-gate /* 909*0Sstevel@tonic-gate * Use the variable tmp1 to compute where 910*0Sstevel@tonic-gate * the end of the window escape (currently 911*0Sstevel@tonic-gate * the only rlogin protocol sequence), then 912*0Sstevel@tonic-gate * check to see if we got all those bytes. 913*0Sstevel@tonic-gate */ 914*0Sstevel@tonic-gate tmp1 = tmp + 4 + sizeof (struct winsize); 915*0Sstevel@tonic-gate 916*0Sstevel@tonic-gate if (tmp1 > mp->b_wptr) { 917*0Sstevel@tonic-gate /* 918*0Sstevel@tonic-gate * All the window escape bytes aren't 919*0Sstevel@tonic-gate * in this TCP segment. Store this 920*0Sstevel@tonic-gate * mblk to one side so we can append 921*0Sstevel@tonic-gate * the rest of the escape to it when 922*0Sstevel@tonic-gate * its segment arrives. 923*0Sstevel@tonic-gate */ 924*0Sstevel@tonic-gate rmip->wndw_sz_hd_mp = mp; 925*0Sstevel@tonic-gate return (TRUE); 926*0Sstevel@tonic-gate } 927*0Sstevel@tonic-gate /* 928*0Sstevel@tonic-gate * check for FF FF s s pattern 929*0Sstevel@tonic-gate */ 930*0Sstevel@tonic-gate if ((tmp[1] == RLOGIN_MAGIC) && 931*0Sstevel@tonic-gate (tmp[2] == 's') && (tmp[3] == 's')) { 932*0Sstevel@tonic-gate 933*0Sstevel@tonic-gate /* 934*0Sstevel@tonic-gate * If rlwinsetup returns an error, 935*0Sstevel@tonic-gate * we do recover with newmp which 936*0Sstevel@tonic-gate * points to new chain of mblks after 937*0Sstevel@tonic-gate * doing window control ioctls. 938*0Sstevel@tonic-gate * rlwinsetup returns newmp which 939*0Sstevel@tonic-gate * contains only data part. 940*0Sstevel@tonic-gate * Note that buried inside rlwinsetup 941*0Sstevel@tonic-gate * is where we do the putnext. 942*0Sstevel@tonic-gate */ 943*0Sstevel@tonic-gate if (rlwinsetup(q, mp, tmp) == NULL) { 944*0Sstevel@tonic-gate sz = msgdsize(mp); 945*0Sstevel@tonic-gate recover(q, mp, sz); 946*0Sstevel@tonic-gate return (NULL); 947*0Sstevel@tonic-gate } 948*0Sstevel@tonic-gate /* 949*0Sstevel@tonic-gate * We have successfully consumed the 950*0Sstevel@tonic-gate * window sequence, but rlwinsetup() 951*0Sstevel@tonic-gate * and its children have moved memory 952*0Sstevel@tonic-gate * up underneath us. This means that 953*0Sstevel@tonic-gate * the byte underneath *tmp has not 954*0Sstevel@tonic-gate * been scanned now. We will now need 955*0Sstevel@tonic-gate * to rescan it. 956*0Sstevel@tonic-gate */ 957*0Sstevel@tonic-gate continue; 958*0Sstevel@tonic-gate } 959*0Sstevel@tonic-gate } 960*0Sstevel@tonic-gate tmp++; 961*0Sstevel@tonic-gate } 962*0Sstevel@tonic-gate /* 963*0Sstevel@tonic-gate * bump newcount to include size of this particular block. 964*0Sstevel@tonic-gate */ 965*0Sstevel@tonic-gate newcount += (mp->b_wptr - mp->b_rptr); 966*0Sstevel@tonic-gate mp = mp->b_cont; 967*0Sstevel@tonic-gate } 968*0Sstevel@tonic-gate /* 969*0Sstevel@tonic-gate * If we trimmed the message down to nothing to forward, don't 970*0Sstevel@tonic-gate * send any M_DATA message. (Don't want to send EOF!) 971*0Sstevel@tonic-gate */ 972*0Sstevel@tonic-gate if (msgdsize(newmp) == 0) { 973*0Sstevel@tonic-gate freemsg(newmp); 974*0Sstevel@tonic-gate newmp = NULL; 975*0Sstevel@tonic-gate } 976*0Sstevel@tonic-gate out: 977*0Sstevel@tonic-gate if (newmp) { 978*0Sstevel@tonic-gate if (!canputnext(q)) { 979*0Sstevel@tonic-gate (void) putbq(q, newmp); 980*0Sstevel@tonic-gate return (NULL); 981*0Sstevel@tonic-gate } else { 982*0Sstevel@tonic-gate putnext(q, newmp); 983*0Sstevel@tonic-gate } 984*0Sstevel@tonic-gate } 985*0Sstevel@tonic-gate return (TRUE); 986*0Sstevel@tonic-gate } 987*0Sstevel@tonic-gate 988*0Sstevel@tonic-gate 989*0Sstevel@tonic-gate /* 990*0Sstevel@tonic-gate * This routine is called to handle window size changes. 991*0Sstevel@tonic-gate * The routine returns 1 on success and 0 on error (allocb failure). 992*0Sstevel@tonic-gate */ 993*0Sstevel@tonic-gate static int 994*0Sstevel@tonic-gate rlwinctl(queue_t *q, mblk_t *mp) 995*0Sstevel@tonic-gate { 996*0Sstevel@tonic-gate mblk_t *rl_msgp; 997*0Sstevel@tonic-gate struct iocblk *iocbp; 998*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 999*0Sstevel@tonic-gate 1000*0Sstevel@tonic-gate TRACE_2(TR_FAC_RLOGINP, TR_RLOGINP_WINCTL_IN, "rlwinctl start: q %p, " 1001*0Sstevel@tonic-gate "mp %p", q, mp); 1002*0Sstevel@tonic-gate 1003*0Sstevel@tonic-gate rmip->oobdata[0] &= ~TIOCPKT_WINDOW; /* we know he heard */ 1004*0Sstevel@tonic-gate 1005*0Sstevel@tonic-gate if ((rl_msgp = mkiocb(TIOCSWINSZ)) == NULL) { 1006*0Sstevel@tonic-gate TRACE_2(TR_FAC_RLOGINP, TR_RLOGINP_WINCTL_OUT, "rlwinctl end: " 1007*0Sstevel@tonic-gate "q %p, mp %p, allocb failed", q, mp); 1008*0Sstevel@tonic-gate return (0); 1009*0Sstevel@tonic-gate } 1010*0Sstevel@tonic-gate 1011*0Sstevel@tonic-gate /* 1012*0Sstevel@tonic-gate * create an M_IOCTL message type. 1013*0Sstevel@tonic-gate */ 1014*0Sstevel@tonic-gate rl_msgp->b_cont = mp; 1015*0Sstevel@tonic-gate iocbp = (struct iocblk *)rl_msgp->b_rptr; 1016*0Sstevel@tonic-gate iocbp->ioc_count = msgdsize(mp); 1017*0Sstevel@tonic-gate 1018*0Sstevel@tonic-gate putnext(q, rl_msgp); 1019*0Sstevel@tonic-gate TRACE_2(TR_FAC_RLOGINP, TR_RLOGINP_WINCTL_OUT, "rlwinctl end: " 1020*0Sstevel@tonic-gate "q %p, mp %p, done", q, mp); 1021*0Sstevel@tonic-gate return (1); 1022*0Sstevel@tonic-gate } 1023*0Sstevel@tonic-gate 1024*0Sstevel@tonic-gate /* 1025*0Sstevel@tonic-gate * This routine sets up window size change protocol. 1026*0Sstevel@tonic-gate * The routine returns the new mblk after issuing rlwinctl 1027*0Sstevel@tonic-gate * for window size changes. New mblk contains only data part 1028*0Sstevel@tonic-gate * of the message block. The routine returns 0 on error. 1029*0Sstevel@tonic-gate */ 1030*0Sstevel@tonic-gate static mblk_t * 1031*0Sstevel@tonic-gate rlwinsetup(queue_t *q, mblk_t *mp, unsigned char *blk) 1032*0Sstevel@tonic-gate { 1033*0Sstevel@tonic-gate mblk_t *mp1; 1034*0Sstevel@tonic-gate unsigned char *jmpmp; 1035*0Sstevel@tonic-gate ssize_t left = 0; 1036*0Sstevel@tonic-gate struct winsize win; 1037*0Sstevel@tonic-gate 1038*0Sstevel@tonic-gate /* 1039*0Sstevel@tonic-gate * Set jmpmp to where to jump, to get just past the end of the 1040*0Sstevel@tonic-gate * window size protocol sequence. 1041*0Sstevel@tonic-gate */ 1042*0Sstevel@tonic-gate jmpmp = (blk + 4 + sizeof (struct winsize)); 1043*0Sstevel@tonic-gate left = mp->b_wptr - jmpmp; 1044*0Sstevel@tonic-gate 1045*0Sstevel@tonic-gate if ((mp1 = allocb(sizeof (struct winsize), BPRI_MED)) == NULL) 1046*0Sstevel@tonic-gate return (0); 1047*0Sstevel@tonic-gate mp1->b_datap->db_type = M_DATA; 1048*0Sstevel@tonic-gate mp1->b_wptr = mp1->b_rptr + sizeof (struct winsize); 1049*0Sstevel@tonic-gate bcopy(blk + 4, &win, sizeof (struct winsize)); 1050*0Sstevel@tonic-gate win.ws_row = ntohs(win.ws_row); 1051*0Sstevel@tonic-gate win.ws_col = ntohs(win.ws_col); 1052*0Sstevel@tonic-gate win.ws_xpixel = ntohs(win.ws_xpixel); 1053*0Sstevel@tonic-gate win.ws_ypixel = ntohs(win.ws_ypixel); 1054*0Sstevel@tonic-gate bcopy(&win, mp1->b_rptr, sizeof (struct winsize)); 1055*0Sstevel@tonic-gate 1056*0Sstevel@tonic-gate if ((rlwinctl(q, mp1)) == NULL) { 1057*0Sstevel@tonic-gate freeb(mp1); 1058*0Sstevel@tonic-gate return (0); 1059*0Sstevel@tonic-gate } 1060*0Sstevel@tonic-gate if (left > 0) { 1061*0Sstevel@tonic-gate /* 1062*0Sstevel@tonic-gate * Must delete the window size protocol sequence. We do 1063*0Sstevel@tonic-gate * this by sliding all the stuff after the sequence (jmpmp) 1064*0Sstevel@tonic-gate * to where the sequence itself began (blk). 1065*0Sstevel@tonic-gate */ 1066*0Sstevel@tonic-gate bcopy(jmpmp, blk, left); 1067*0Sstevel@tonic-gate mp->b_wptr = blk + left; 1068*0Sstevel@tonic-gate } else 1069*0Sstevel@tonic-gate mp->b_wptr = blk; 1070*0Sstevel@tonic-gate return (mp); 1071*0Sstevel@tonic-gate } 1072*0Sstevel@tonic-gate 1073*0Sstevel@tonic-gate /* 1074*0Sstevel@tonic-gate * When an ioctl changes software flow control on the tty, we must notify 1075*0Sstevel@tonic-gate * the rlogin client, so it can adjust its behavior appropriately. This 1076*0Sstevel@tonic-gate * routine, called from either the put or service routine, determines if 1077*0Sstevel@tonic-gate * the flow handling has changed. If so, it tries to send the indication 1078*0Sstevel@tonic-gate * to the client. It returns true or false depending upon whether the 1079*0Sstevel@tonic-gate * message was fully processed. If it wasn't fully processed it queues 1080*0Sstevel@tonic-gate * the message for retry later when resources 1081*0Sstevel@tonic-gate * (allocb/canputnext) are available. 1082*0Sstevel@tonic-gate */ 1083*0Sstevel@tonic-gate static boolean_t 1084*0Sstevel@tonic-gate tty_flow(queue_t *q, struct rlmod_info *rmip, mblk_t *mp) 1085*0Sstevel@tonic-gate { 1086*0Sstevel@tonic-gate struct iocblk *ioc; 1087*0Sstevel@tonic-gate struct termios *tp; 1088*0Sstevel@tonic-gate struct termio *ti; 1089*0Sstevel@tonic-gate int stop, ixon; 1090*0Sstevel@tonic-gate mblk_t *tmpmp; 1091*0Sstevel@tonic-gate char cntl; 1092*0Sstevel@tonic-gate int error; 1093*0Sstevel@tonic-gate 1094*0Sstevel@tonic-gate ioc = (struct iocblk *)mp->b_rptr; 1095*0Sstevel@tonic-gate switch (ioc->ioc_cmd) { 1096*0Sstevel@tonic-gate 1097*0Sstevel@tonic-gate /* 1098*0Sstevel@tonic-gate * If it is a tty ioctl, save the output flow 1099*0Sstevel@tonic-gate * control flag and the start and stop flow control 1100*0Sstevel@tonic-gate * characters if they are available. 1101*0Sstevel@tonic-gate */ 1102*0Sstevel@tonic-gate case TCSETS: 1103*0Sstevel@tonic-gate case TCSETSW: 1104*0Sstevel@tonic-gate case TCSETSF: 1105*0Sstevel@tonic-gate error = miocpullup(mp, sizeof (struct termios)); 1106*0Sstevel@tonic-gate if (error != 0) { 1107*0Sstevel@tonic-gate miocnak(q, mp, 0, error); 1108*0Sstevel@tonic-gate return (B_TRUE); 1109*0Sstevel@tonic-gate } 1110*0Sstevel@tonic-gate tp = (struct termios *)(mp->b_cont->b_rptr); 1111*0Sstevel@tonic-gate rmip->stopc = tp->c_cc[VSTOP]; 1112*0Sstevel@tonic-gate rmip->startc = tp->c_cc[VSTART]; 1113*0Sstevel@tonic-gate ixon = tp->c_iflag & IXON; 1114*0Sstevel@tonic-gate break; 1115*0Sstevel@tonic-gate 1116*0Sstevel@tonic-gate case TCSETA: 1117*0Sstevel@tonic-gate case TCSETAW: 1118*0Sstevel@tonic-gate case TCSETAF: 1119*0Sstevel@tonic-gate error = miocpullup(mp, sizeof (struct termio)); 1120*0Sstevel@tonic-gate if (error != 0) { 1121*0Sstevel@tonic-gate miocnak(q, mp, 0, error); 1122*0Sstevel@tonic-gate return (B_TRUE); 1123*0Sstevel@tonic-gate } 1124*0Sstevel@tonic-gate ti = (struct termio *)(mp->b_cont->b_rptr); 1125*0Sstevel@tonic-gate ixon = ti->c_iflag & IXON; 1126*0Sstevel@tonic-gate break; 1127*0Sstevel@tonic-gate 1128*0Sstevel@tonic-gate default: 1129*0Sstevel@tonic-gate /* 1130*0Sstevel@tonic-gate * This function must never be called for an M_IOCTL 1131*0Sstevel@tonic-gate * except the listed ones. 1132*0Sstevel@tonic-gate */ 1133*0Sstevel@tonic-gate #ifdef DEBUG 1134*0Sstevel@tonic-gate cmn_err(CE_PANIC, 1135*0Sstevel@tonic-gate "rloginmod: tty_flow: bad ioctl 0x%x", ioc->ioc_cmd); 1136*0Sstevel@tonic-gate #else 1137*0Sstevel@tonic-gate miocnak(q, mp, 0, EINVAL); 1138*0Sstevel@tonic-gate return (B_TRUE); 1139*0Sstevel@tonic-gate #endif 1140*0Sstevel@tonic-gate } 1141*0Sstevel@tonic-gate /* 1142*0Sstevel@tonic-gate * If tty ioctl processing is done, check for stopmode 1143*0Sstevel@tonic-gate */ 1144*0Sstevel@tonic-gate stop = (ixon && (rmip->stopc == CTRL('s')) && 1145*0Sstevel@tonic-gate (rmip->startc == CTRL('q'))); 1146*0Sstevel@tonic-gate if (rmip->stopmode == TIOCPKT_NOSTOP) { 1147*0Sstevel@tonic-gate if (stop) { 1148*0Sstevel@tonic-gate cntl = rmip->oobdata[0] | TIOCPKT_DOSTOP; 1149*0Sstevel@tonic-gate if ((tmpmp = make_expmblk(cntl)) == NULL) { 1150*0Sstevel@tonic-gate recover(q, mp, sizeof (mblk_t)); 1151*0Sstevel@tonic-gate return (B_FALSE); 1152*0Sstevel@tonic-gate } 1153*0Sstevel@tonic-gate if (!canputnext(q)) { 1154*0Sstevel@tonic-gate freemsg(tmpmp); 1155*0Sstevel@tonic-gate return (B_FALSE); 1156*0Sstevel@tonic-gate } 1157*0Sstevel@tonic-gate putnext(q, tmpmp); 1158*0Sstevel@tonic-gate rmip->stopmode = TIOCPKT_DOSTOP; 1159*0Sstevel@tonic-gate } 1160*0Sstevel@tonic-gate } else { 1161*0Sstevel@tonic-gate if (!stop) { 1162*0Sstevel@tonic-gate cntl = rmip->oobdata[0] | TIOCPKT_NOSTOP; 1163*0Sstevel@tonic-gate if ((tmpmp = make_expmblk(cntl)) == NULL) { 1164*0Sstevel@tonic-gate recover(q, mp, sizeof (mblk_t)); 1165*0Sstevel@tonic-gate return (B_FALSE); 1166*0Sstevel@tonic-gate } 1167*0Sstevel@tonic-gate if (!canputnext(q)) { 1168*0Sstevel@tonic-gate freemsg(tmpmp); 1169*0Sstevel@tonic-gate return (B_FALSE); 1170*0Sstevel@tonic-gate } 1171*0Sstevel@tonic-gate putnext(q, tmpmp); 1172*0Sstevel@tonic-gate rmip->stopmode = TIOCPKT_NOSTOP; 1173*0Sstevel@tonic-gate } 1174*0Sstevel@tonic-gate } 1175*0Sstevel@tonic-gate 1176*0Sstevel@tonic-gate miocack(q, mp, 0, 0); 1177*0Sstevel@tonic-gate return (B_TRUE); 1178*0Sstevel@tonic-gate } 1179*0Sstevel@tonic-gate 1180*0Sstevel@tonic-gate /* rlmodwioctl - handle M_IOCTL messages on the write queue. */ 1181*0Sstevel@tonic-gate 1182*0Sstevel@tonic-gate static boolean_t 1183*0Sstevel@tonic-gate rlmodwioctl(queue_t *q, mblk_t *mp) 1184*0Sstevel@tonic-gate { 1185*0Sstevel@tonic-gate struct iocblk *ioc; 1186*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 1187*0Sstevel@tonic-gate int error; 1188*0Sstevel@tonic-gate 1189*0Sstevel@tonic-gate ioc = (struct iocblk *)mp->b_rptr; 1190*0Sstevel@tonic-gate switch (ioc->ioc_cmd) { 1191*0Sstevel@tonic-gate 1192*0Sstevel@tonic-gate /* 1193*0Sstevel@tonic-gate * This is a special ioctl to reenable the queue. 1194*0Sstevel@tonic-gate * The initial data read from the stream head is 1195*0Sstevel@tonic-gate * put back on the queue. 1196*0Sstevel@tonic-gate */ 1197*0Sstevel@tonic-gate case RL_IOC_ENABLE: 1198*0Sstevel@tonic-gate /* 1199*0Sstevel@tonic-gate * Send negative ack if RL_DISABLED flag is not set 1200*0Sstevel@tonic-gate */ 1201*0Sstevel@tonic-gate 1202*0Sstevel@tonic-gate if (!(rmip->flags & RL_DISABLED)) { 1203*0Sstevel@tonic-gate miocnak(q, mp, 0, EINVAL); 1204*0Sstevel@tonic-gate break; 1205*0Sstevel@tonic-gate } 1206*0Sstevel@tonic-gate if (mp->b_cont) { 1207*0Sstevel@tonic-gate (void) putbq(RD(q), mp->b_cont); 1208*0Sstevel@tonic-gate mp->b_cont = NULL; 1209*0Sstevel@tonic-gate } 1210*0Sstevel@tonic-gate 1211*0Sstevel@tonic-gate if (rmip->flags & RL_DISABLED) 1212*0Sstevel@tonic-gate rmip->flags &= ~RL_DISABLED; 1213*0Sstevel@tonic-gate qenable(RD(q)); 1214*0Sstevel@tonic-gate miocack(q, mp, 0, 0); 1215*0Sstevel@tonic-gate TRACE_3(TR_FAC_RLOGINP, TR_RLOGINP_WPUT_OUT, 1216*0Sstevel@tonic-gate "rlmodwput end: q %p, mp %p, %s", 1217*0Sstevel@tonic-gate q, mp, "IOCACK enable"); 1218*0Sstevel@tonic-gate return (B_TRUE); 1219*0Sstevel@tonic-gate 1220*0Sstevel@tonic-gate /* 1221*0Sstevel@tonic-gate * If it is a tty ioctl, save the output flow 1222*0Sstevel@tonic-gate * control flag and the start and stop flow control 1223*0Sstevel@tonic-gate * characters if they are available. 1224*0Sstevel@tonic-gate */ 1225*0Sstevel@tonic-gate case TCSETS: 1226*0Sstevel@tonic-gate case TCSETSW: 1227*0Sstevel@tonic-gate case TCSETSF: 1228*0Sstevel@tonic-gate case TCSETA: 1229*0Sstevel@tonic-gate case TCSETAW: 1230*0Sstevel@tonic-gate case TCSETAF: 1231*0Sstevel@tonic-gate return (tty_flow(q, rmip, mp)); 1232*0Sstevel@tonic-gate 1233*0Sstevel@tonic-gate #ifdef DEBUG 1234*0Sstevel@tonic-gate case TIOCSWINSZ: 1235*0Sstevel@tonic-gate case TIOCSTI: 1236*0Sstevel@tonic-gate case TCSBRK: 1237*0Sstevel@tonic-gate miocnak(q, mp, 0, EINVAL); 1238*0Sstevel@tonic-gate break; 1239*0Sstevel@tonic-gate #endif 1240*0Sstevel@tonic-gate case CRYPTPASSTHRU: 1241*0Sstevel@tonic-gate error = miocpullup(mp, sizeof (uchar_t)); 1242*0Sstevel@tonic-gate if (error != 0) { 1243*0Sstevel@tonic-gate miocnak(q, mp, 0, error); 1244*0Sstevel@tonic-gate break; 1245*0Sstevel@tonic-gate } 1246*0Sstevel@tonic-gate if (*(mp->b_cont->b_rptr) == 0x01) 1247*0Sstevel@tonic-gate rmip->flags |= RL_IOCPASSTHRU; 1248*0Sstevel@tonic-gate else 1249*0Sstevel@tonic-gate rmip->flags &= ~RL_IOCPASSTHRU; 1250*0Sstevel@tonic-gate 1251*0Sstevel@tonic-gate miocack(q, mp, NULL, 0); 1252*0Sstevel@tonic-gate break; 1253*0Sstevel@tonic-gate 1254*0Sstevel@tonic-gate default: 1255*0Sstevel@tonic-gate if (rmip->flags & RL_IOCPASSTHRU) { 1256*0Sstevel@tonic-gate putnext(q, mp); 1257*0Sstevel@tonic-gate } else { 1258*0Sstevel@tonic-gate #ifdef DEBUG 1259*0Sstevel@tonic-gate cmn_err(CE_NOTE, 1260*0Sstevel@tonic-gate "rlmodwioctl: unexpected ioctl type 0x%x", 1261*0Sstevel@tonic-gate ioc->ioc_cmd); 1262*0Sstevel@tonic-gate #endif 1263*0Sstevel@tonic-gate miocnak(q, mp, 0, EINVAL); 1264*0Sstevel@tonic-gate } 1265*0Sstevel@tonic-gate } 1266*0Sstevel@tonic-gate return (B_TRUE); 1267*0Sstevel@tonic-gate } 1268*0Sstevel@tonic-gate 1269*0Sstevel@tonic-gate static void 1270*0Sstevel@tonic-gate rlmod_timer(void *arg) 1271*0Sstevel@tonic-gate { 1272*0Sstevel@tonic-gate queue_t *q = arg; 1273*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 1274*0Sstevel@tonic-gate 1275*0Sstevel@tonic-gate ASSERT(rmip); 1276*0Sstevel@tonic-gate if (q->q_flag & QREADR) { 1277*0Sstevel@tonic-gate ASSERT(rmip->rtimoutid); 1278*0Sstevel@tonic-gate rmip->rtimoutid = 0; 1279*0Sstevel@tonic-gate } else { 1280*0Sstevel@tonic-gate ASSERT(rmip->wtimoutid); 1281*0Sstevel@tonic-gate rmip->wtimoutid = 0; 1282*0Sstevel@tonic-gate } 1283*0Sstevel@tonic-gate enableok(q); 1284*0Sstevel@tonic-gate qenable(q); 1285*0Sstevel@tonic-gate } 1286*0Sstevel@tonic-gate 1287*0Sstevel@tonic-gate static void 1288*0Sstevel@tonic-gate rlmod_buffer(void *arg) 1289*0Sstevel@tonic-gate { 1290*0Sstevel@tonic-gate queue_t *q = arg; 1291*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 1292*0Sstevel@tonic-gate 1293*0Sstevel@tonic-gate ASSERT(rmip); 1294*0Sstevel@tonic-gate if (q->q_flag & QREADR) { 1295*0Sstevel@tonic-gate ASSERT(rmip->rbufcid); 1296*0Sstevel@tonic-gate rmip->rbufcid = 0; 1297*0Sstevel@tonic-gate } else { 1298*0Sstevel@tonic-gate ASSERT(rmip->wbufcid); 1299*0Sstevel@tonic-gate rmip->wbufcid = 0; 1300*0Sstevel@tonic-gate } 1301*0Sstevel@tonic-gate enableok(q); 1302*0Sstevel@tonic-gate qenable(q); 1303*0Sstevel@tonic-gate } 1304*0Sstevel@tonic-gate 1305*0Sstevel@tonic-gate static void 1306*0Sstevel@tonic-gate recover(queue_t *q, mblk_t *mp, size_t size) 1307*0Sstevel@tonic-gate { 1308*0Sstevel@tonic-gate /* 1309*0Sstevel@tonic-gate * Avoid re-enabling the queue. 1310*0Sstevel@tonic-gate */ 1311*0Sstevel@tonic-gate ASSERT(mp->b_datap->db_type < QPCTL); 1312*0Sstevel@tonic-gate 1313*0Sstevel@tonic-gate noenable(q); 1314*0Sstevel@tonic-gate (void) putbq(q, mp); 1315*0Sstevel@tonic-gate recover1(q, size); 1316*0Sstevel@tonic-gate } 1317*0Sstevel@tonic-gate 1318*0Sstevel@tonic-gate static void 1319*0Sstevel@tonic-gate recover1(queue_t *q, size_t size) 1320*0Sstevel@tonic-gate { 1321*0Sstevel@tonic-gate struct rlmod_info *rmip = (struct rlmod_info *)q->q_ptr; 1322*0Sstevel@tonic-gate timeout_id_t tid; 1323*0Sstevel@tonic-gate bufcall_id_t bid; 1324*0Sstevel@tonic-gate 1325*0Sstevel@tonic-gate /* 1326*0Sstevel@tonic-gate * Make sure there is at most one outstanding request per queue. 1327*0Sstevel@tonic-gate */ 1328*0Sstevel@tonic-gate if (q->q_flag & QREADR) { 1329*0Sstevel@tonic-gate if (rmip->rtimoutid || rmip->rbufcid) 1330*0Sstevel@tonic-gate return; 1331*0Sstevel@tonic-gate } else { 1332*0Sstevel@tonic-gate if (rmip->wtimoutid || rmip->wbufcid) 1333*0Sstevel@tonic-gate return; 1334*0Sstevel@tonic-gate } 1335*0Sstevel@tonic-gate if (!(bid = qbufcall(RD(q), size, BPRI_MED, rlmod_buffer, q))) { 1336*0Sstevel@tonic-gate tid = qtimeout(RD(q), rlmod_timer, q, SIMWAIT); 1337*0Sstevel@tonic-gate if (q->q_flag & QREADR) 1338*0Sstevel@tonic-gate rmip->rtimoutid = tid; 1339*0Sstevel@tonic-gate else 1340*0Sstevel@tonic-gate rmip->wtimoutid = tid; 1341*0Sstevel@tonic-gate } else { 1342*0Sstevel@tonic-gate if (q->q_flag & QREADR) 1343*0Sstevel@tonic-gate rmip->rbufcid = bid; 1344*0Sstevel@tonic-gate else 1345*0Sstevel@tonic-gate rmip->wbufcid = bid; 1346*0Sstevel@tonic-gate } 1347*0Sstevel@tonic-gate } 1348