Lines Matching refs:mp
100 extern void rds_ioctl_copyin_done(queue_t *q, mblk_t *mp);
282 rds_deliver_new_msg(mblk_t *mp, ipaddr_t local_addr, ipaddr_t rem_addr,
295 ASSERT(mp->b_datap->db_type == M_DATA);
300 freemsg(mp);
310 freemsg(mp);
314 mp1->b_cont = mp;
315 mp = mp1;
316 mp->b_datap->db_type = M_PROTO;
317 tudi = (struct T_unitdata_ind *)(uintptr_t)mp->b_rptr;
318 mp->b_wptr = (uchar_t *)tudi + udi_size;
332 putnext(rds->rds_ulpd, mp);
385 rds_err_ack(queue_t *q, mblk_t *mp, t_scalar_t t_error, int sys_error)
387 if ((mp = mi_tpi_err_ack_alloc(mp, t_error, sys_error)) != NULL)
388 qreply(q, mp);
392 rds_capability_req(queue_t *q, mblk_t *mp)
398 ((struct T_capability_req *)(uintptr_t)mp->b_rptr)->CAP_bits1;
400 mp = tpi_ack_alloc(mp, sizeof (struct T_capability_ack),
401 mp->b_datap->db_type, T_CAPABILITY_ACK);
402 if (mp == NULL)
404 tcap = (struct T_capability_ack *)(uintptr_t)mp->b_rptr;
412 qreply(q, mp);
420 mblk_t *mp;
423 mp = tpi_ack_alloc(omp, sizeof (struct T_info_ack), M_PCPROTO,
425 if (mp == NULL)
427 tap = (struct T_info_ack *)(uintptr_t)mp->b_rptr;
431 qreply(q, mp);
439 rds_bind(queue_t *q, mblk_t *mp)
452 if (((uintptr_t)mp->b_wptr - (uintptr_t)mp->b_rptr) < sizeof (*tbr)) {
453 rds_err_ack(q, mp, TPROTO, 0);
461 rds_err_ack(q, mp, TOUTSTATE, 0);
465 tbr = (struct T_bind_req *)(uintptr_t)mp->b_rptr;
468 sin = (sin_t *)(uintptr_t)mi_offset_param(mp, tbr->ADDR_offset,
471 rds_err_ack(q, mp, TSYSERR, EINVAL);
476 rds_err_ack(q, mp, TSYSERR, EAFNOSUPPORT);
480 rds_err_ack(q, mp, TBADADDR, 0);
490 rds_err_ack(q, mp, TBADADDR, 0);
497 rds_err_ack(q, mp, TBADADDR, 0);
559 rds_err_ack(q, mp, TADDRBUSY, 0);
571 rds_err_ack(q, mp, TNOADDR, 0);
594 mp->b_datap->db_type = M_PCPROTO;
595 tba = (struct T_bind_ack *)(uintptr_t)mp->b_rptr;
605 qreply(q, mp);
609 rds_wput_other(queue_t *q, mblk_t *mp)
611 uchar_t *rptr = mp->b_rptr;
615 db = mp->b_datap;
619 freemsg(mp);
623 if ((uintptr_t)mp->b_wptr - (uintptr_t)rptr <
625 freemsg(mp);
630 rds_capability_req(q, mp);
634 rds_info_req(q, mp);
638 rds_bind(q, mp);
649 cr = msg_getcred(mp, NULL);
652 rds_err_ack(q, mp, TSYSERR, EINVAL);
657 svr4_optcom_req(q, mp, cr, &rds_opt_obj);
659 tpi_optcom_req(q, mp, cr, &rds_opt_obj);
681 rds_ioctl(q, mp);
685 if (mi_copy_state(q, mp, NULL) == -1) {
699 if (MI_COPY_DIRECTION(mp) == MI_COPY_IN)
700 rds_ioctl_copyin_done(q, mp);
702 mi_copyout(q, mp);
711 rds_wput(queue_t *q, mblk_t *mp)
714 uchar_t *rptr = mp->b_rptr;
716 db = mp->b_datap;
720 ASSERT(((uintptr_t)mp->b_wptr - (uintptr_t)rptr) <=
722 if ((uintptr_t)mp->b_wptr - (uintptr_t)rptr >=
734 rds_wput_other(q, mp);
740 rds_wput_data(queue_t *q, mblk_t *mp, uio_t *uiop)
742 uchar_t *rptr = mp->b_rptr;
757 freemsg(mp);
761 mp1 = mp->b_cont;
762 mp->b_cont = NULL;
765 freemsg(mp);
780 mp->b_wptr) {
812 freemsg(mp);
824 mblk_t *mp = dp->d_mp;
829 db = mp->b_datap;
830 rptr = mp->b_rptr;
834 ASSERT(((uintptr_t)mp->b_wptr - (uintptr_t)rptr) <=
836 if ((uintptr_t)mp->b_wptr - (uintptr_t)rptr >=
846 if (isuioq(q) && (error = struioget(q, mp, dp, 0))) {
853 rds_wput_other(q, mp);
858 error = rds_wput_data(q, mp, &dp->d_uio);