fibre-channel/ulp/fcip.c

145 static int fcip_open(queue_t *wq, dev_t *devp, int flag,
148 static int fcip_start(queue_t *wq, mblk_t *mp, struct fcip *fptr,
162 static void fcip_spareq(queue_t *wq, mblk_t *mp);
163 static void fcip_pareq(queue_t *wq, mblk_t *mp);
164 static void fcip_ubreq(queue_t *wq, mblk_t *mp);
165 static void fcip_breq(queue_t *wq, mblk_t *mp);
166 static void fcip_dreq(queue_t *wq, mblk_t *mp);
167 static void fcip_areq(queue_t *wq, mblk_t *mp);
168 static void fcip_udreq(queue_t *wq, mblk_t *mp);
169 static void fcip_ireq(queue_t *wq, mblk_t *mp);
170 static void fcip_dl_ioc_hdr_info(queue_t *wq, mblk_t *mp);
3736 fcip_ioctl(queue_t *wq, mblk_t *mp)
3739 	struct fcipstr		*slp = (struct fcipstr *)wq->q_ptr;
3749 		miocack(wq, mp, 0, 0);
3753 		fcip_dl_ioc_hdr_info(wq, mp);
3757 		miocnak(wq, mp, 0, EINVAL);
3767 fcip_wput(queue_t *wq, mblk_t *mp)
3769 	struct fcipstr *slp = (struct fcipstr *)wq->q_ptr;
3790 			merror(wq, mp, EPROTO);
3799 		 * write queue and qenable() puts the queue (wq) on
3802 		if (wq->q_first) {
3803 			(void) putq(wq, mp);
3805 			qenable(wq);
3811 			(void) putq(wq, mp);
3812 			qenable(wq);
3819 				merror(wq, mp, EPROTO);
3825 			(void) fcip_start(wq, mp, fptr, fdestp, KM_SLEEP);
3837 		(void) putq(wq, mp);
3838 		qenable(wq);
3842 		fcip_ioctl(wq, mp);
3847 			flushq(wq, FLUSHALL);
3856 			 * of using the RD(wq) queue on its reply
3858 			qreply(wq, mp);
3879 fcip_proto(queue_t *wq, mblk_t *mp)
3885 	slp = (struct fcipstr *)wq->q_ptr;
3891 		tnf_opaque, wq, wq,
3905 		fcip_udreq(wq, mp);
3912 		fcip_areq(wq, mp);
3919 		fcip_dreq(wq, mp);
3926 		fcip_breq(wq, mp);
3933 		fcip_ubreq(wq, mp);
3940 		fcip_ireq(wq, mp);
3948 		fcip_spareq(wq, mp);
3955 		fcip_pareq(wq, mp);
3963 		dlerrorack(wq, mp, prim, DL_UNSUPPORTED, 0);
3971 		dlerrorack(wq, mp, prim, DL_UNSUPPORTED, 0);
3979 		dlerrorack(wq, mp, prim, DL_UNSUPPORTED, 0);
3987 		dlerrorack(wq, mp, prim, DL_UNSUPPORTED, 0);
3993 		dlerrorack(wq, mp, prim, DL_UNSUPPORTED, 0);
4000  * Always enqueue M_PROTO and M_PCPROTO messages pn the wq and M_DATA
4009  * and an attempt is made to xmit all messages on the wq.
4013 fcip_wsrv(queue_t *wq)
4021 	slp = (struct fcipstr *)wq->q_ptr;
4026 		tnf_opaque, wq, wq));
4029 	while (mp = getq(wq)) {
4040 				if (fcip_start(wq, mp, fptr, fdestp,
4053 			fcip_proto(wq, mp);
4072 fcip_start(queue_t *wq, mblk_t *mp, struct fcip *fptr,
4083 	    tnf_string, msg, "enter", tnf_opaque, wq, wq,
4141 		(void) putbq(wq, mp);
4146 	fcip_pkt->fcip_pkt_wq = wq;
4209 		(void) putbq(wq, mp);
5119 fcip_ireq(queue_t *wq, mblk_t *mp)
5129 	slp = (struct fcipstr *)wq->q_ptr;
5140 		dlerrorack(wq, mp, DL_INFO_REQ, DL_BADPRIM, 0);
5148 	if ((mp = mexchange(wq, mp, size, M_PCPROTO, DL_INFO_ACK)) == NULL) {
5175 	qreply(wq, mp);
5184 fcip_udreq(queue_t *wq, mblk_t *mp)
5204 	slp = (struct fcipstr *)wq->q_ptr;
5207 		dlerrorack(wq, mp, DL_UNITDATA_REQ, DL_OUTSTATE, 0);
5214 		dlerrorack(wq, mp, DL_UNITDATA_REQ, DL_OUTSTATE, 0);
5228 		dluderrorind(wq, mp, (mp->b_rptr + off), len, DL_BADADDR, 0);
5237 		dluderrorind(wq, mp, (mp->b_rptr + off), len, DL_BADDATA, 0);
5251 		dluderrorind(wq, mp, (mp->b_rptr + off), len, DL_BADDATA, 0));
5338 	(void) fcip_start(wq, mp, fptr, fdestp, KM_SLEEP);
5347 fcip_areq(queue_t *wq, mblk_t *mp)
5355 	slp = (struct fcipstr *)wq->q_ptr;
5359 		dlerrorack(wq, mp, DL_ATTACH_REQ, DL_BADPRIM, 0);
5364 		dlerrorack(wq, mp, DL_ATTACH_REQ, DL_OUTSTATE, 0);
5398 			dlerrorack(wq, mp, DL_ATTACH_REQ, DL_BADPPA, 0);
5414 			dlerrorack(wq, mp, DL_ATTACH_REQ, DL_BADPPA, 0);
5435 	dlokack(wq, mp, DL_ATTACH_REQ);
5443 fcip_dreq(queue_t *wq, mblk_t *mp)
5447 	slp = (struct fcipstr *)wq->q_ptr;
5450 		dlerrorack(wq, mp, DL_DETACH_REQ, DL_BADPRIM, 0);
5455 		dlerrorack(wq, mp, DL_DETACH_REQ, DL_OUTSTATE, 0);
5460 	dlokack(wq, mp, DL_DETACH_REQ);
5469 fcip_breq(queue_t *wq, mblk_t *mp)
5478 	slp = (struct fcipstr *)wq->q_ptr;
5481 		dlerrorack(wq, mp, DL_BIND_REQ, DL_BADPRIM, 0);
5486 		dlerrorack(wq, mp, DL_BIND_REQ, DL_OUTSTATE, 0);
5494 		dlerrorack(wq, mp, DL_BIND_REQ, DL_OUTSTATE, 0);
5503 		dlerrorack(wq, mp, DL_BIND_REQ, DL_NOAUTO, 0);
5510 		dlerrorack(wq, mp, dlp->dl_primitive, DL_BADSAP, 0);
5521 	dlbindack(wq, mp, sap, &fcipaddr, FCIPADDRL, 0, 0);
5530 fcip_ubreq(queue_t *wq, mblk_t *mp)
5534 	slp = (struct fcipstr *)wq->q_ptr;
5537 		dlerrorack(wq, mp, DL_UNBIND_REQ, DL_BADPRIM, 0);
5542 		dlerrorack(wq, mp, DL_UNBIND_REQ, DL_OUTSTATE, 0);
5549 	(void) putnextctl1(RD(wq), M_FLUSH, FLUSHRW);
5550 	dlokack(wq, mp, DL_UNBIND_REQ);
5559 fcip_pareq(queue_t *wq, mblk_t *mp)
5568 	slp = (struct fcipstr *)wq->q_ptr;
5571 		dlerrorack(wq, mp, DL_PHYS_ADDR_REQ, DL_BADPRIM, 0);
5580 		dlerrorack(wq, mp, DL_PHYS_ADDR_REQ, DL_OUTSTATE, 0);
5602 		dlerrorack(wq, mp, DL_PHYS_ADDR_REQ, DL_NOTSUPPORTED, 0);
5605 	dlphysaddrack(wq, mp, &addr, ETHERADDRL);
5612 fcip_spareq(queue_t *wq, mblk_t *mp)
5622 	slp = (struct fcipstr *)wq->q_ptr;
5625 		dlerrorack(wq, mp, DL_SET_PHYS_ADDR_REQ, DL_BADPRIM, 0);
5634 		dlerrorack(wq, mp, DL_SET_PHYS_ADDR_REQ, DL_BADPRIM, 0);
5648 		dlerrorack(wq, mp, DL_SET_PHYS_ADDR_REQ, DL_BADADDR, 0);
5656 		dlerrorack(wq, mp, DL_SET_PHYS_ADDR_REQ, DL_OUTSTATE, 0);
5671 		dlerrorack(wq, mp, DL_SET_PHYS_ADDR_REQ, DL_BADADDR, 0);
5691 		dlerrorack(wq, mp, DL_SET_PHYS_ADDR_REQ, DL_BADPRIM, 0);
5695 	dlokack(wq, mp, DL_SET_PHYS_ADDR_REQ);
5725 fcip_dl_ioc_hdr_info(queue_t *wq, mblk_t *mp)
5740 	slp = (struct fcipstr *)wq->q_ptr;
5745 		miocnak(wq, mp, 0, EINVAL);
5753 		miocnak(wq, mp, 0, error);
5770 		miocnak(wq, mp, 0, EINVAL);
5787 		miocnak(wq, mp, 0, ENOMEM);
5825 	miocack(wq, mp, msgsize(mp->b_cont), 0);