common/io/tl.c

428 static void tl_wput(queue_t *, mblk_t *);
544 typedef void (tlproc_t)(mblk_t *, tl_endpt_t *);
554 	mblk_t		*ti_mp;		/* b_next list of data + ordrel_ind */
641 	mblk_t		te_closemp;	/* for entering serializer on close */
642 	mblk_t		te_rsrvmp;	/* for entering serializer on rsrv */
643 	mblk_t		te_wsrvmp;	/* for entering serializer on wsrv */
826 static void tl_do_proto(mblk_t *, tl_endpt_t *);
827 static void tl_do_ioctl(mblk_t *, tl_endpt_t *);
828 static void tl_do_ioctl_ser(mblk_t *, tl_endpt_t *);
829 static void tl_error_ack(queue_t *, mblk_t *, t_scalar_t, t_scalar_t,
831 static void tl_bind(mblk_t *, tl_endpt_t *);
832 static void tl_bind_ser(mblk_t *, tl_endpt_t *);
833 static void tl_ok_ack(queue_t *, mblk_t  *mp, t_scalar_t);
834 static void tl_unbind(mblk_t *, tl_endpt_t *);
835 static void tl_optmgmt(queue_t *, mblk_t *);
836 static void tl_conn_req(queue_t *, mblk_t *);
837 static void tl_conn_req_ser(mblk_t *, tl_endpt_t *);
838 static void tl_conn_res(mblk_t *, tl_endpt_t *);
839 static void tl_discon_req(mblk_t *, tl_endpt_t *);
840 static void tl_capability_req(mblk_t *, tl_endpt_t *);
841 static void tl_info_req_ser(mblk_t *, tl_endpt_t *);
842 static void tl_info_req(mblk_t *, tl_endpt_t *);
843 static void tl_addr_req(mblk_t *, tl_endpt_t *);
844 static void tl_connected_cots_addr_req(mblk_t *, tl_endpt_t *);
845 static void tl_data(mblk_t  *, tl_endpt_t *);
846 static void tl_exdata(mblk_t *, tl_endpt_t *);
847 static void tl_ordrel(mblk_t *, tl_endpt_t *);
848 static void tl_unitdata(mblk_t *, tl_endpt_t *);
849 static void tl_unitdata_ser(mblk_t *, tl_endpt_t *);
850 static void tl_uderr(queue_t *, mblk_t *, t_scalar_t);
856 static mblk_t *tl_resizemp(mblk_t *, ssize_t);
858 static mblk_t *tl_discon_ind_alloc(uint32_t, t_scalar_t);
859 static mblk_t *tl_ordrel_ind_alloc(void);
861 static void tl_icon_queuemsg(tl_endpt_t *, t_scalar_t, mblk_t *);
863 static void tl_icon_sendmsgs(tl_endpt_t *, mblk_t **);
864 static void tl_icon_freemsgs(mblk_t **);
865 static void tl_merror(queue_t *, mblk_t *, int);
871 static void tl_memrecover(queue_t *, mblk_t *, size_t);
880 static void tl_serializer_enter(tl_endpt_t *, tlproc_t, mblk_t *);
888 static void tl_close_ser(mblk_t *, tl_endpt_t *);
889 static void tl_close_finish_ser(mblk_t *, tl_endpt_t *);
890 static void tl_wput_data_ser(mblk_t *, tl_endpt_t *);
891 static void tl_proto_ser(mblk_t *, tl_endpt_t *);
892 static void tl_putq_ser(mblk_t *, tl_endpt_t *);
893 static void tl_wput_common_ser(mblk_t *, tl_endpt_t *);
894 static void tl_wput_ser(mblk_t *, tl_endpt_t *);
895 static void tl_wsrv_ser(mblk_t *, tl_endpt_t *);
896 static void tl_rsrv_ser(mblk_t *, tl_endpt_t *);
1279 tl_serializer_enter(tl_endpt_t *tep, tlproc_t tlproc, mblk_t *mp)
1634 tl_close_ser(mblk_t *mp, tl_endpt_t *tep)
1680 tl_close_finish_ser(mblk_t *mp, tl_endpt_t *tep)
1717 tl_wput(queue_t *wq, mblk_t *mp)
1883 tl_putq_ser(mblk_t *mp, tl_endpt_t *tep)
1896 tl_wput_common_ser(mblk_t *mp, tl_endpt_t *tep)
1917 tl_wput_ser(mblk_t *mp, tl_endpt_t *tep)
1928 tl_wput_data_ser(mblk_t *mp, tl_endpt_t *tep)
2013 tl_wsrv_ser(mblk_t *ser_mp, tl_endpt_t *tep)
2015 	mblk_t *mp;
2076 tl_rsrv_ser(mblk_t *mp, tl_endpt_t *tep)
2107 tl_do_proto(mblk_t *mp, tl_endpt_t *tep)
2192 tl_do_ioctl_ser(mblk_t *mp, tl_endpt_t *tep)
2204 tl_do_ioctl(mblk_t *mp, tl_endpt_t *tep)
2271 tl_error_ack(queue_t *wq, mblk_t *mp, t_scalar_t tli_err,
2275 	mblk_t *ackmp = tpi_ack_alloc(mp, sizeof (struct T_error_ack),
2303 tl_ok_ack(queue_t *wq, mblk_t *mp, t_scalar_t type)
2306 	mblk_t *ackmp = tpi_ack_alloc(mp, sizeof (struct T_ok_ack),
2325 tl_bind_ser(mblk_t *mp, tl_endpt_t *tep)
2341 tl_bind(mblk_t *mp, tl_endpt_t *tep)
2346 	mblk_t			*ackmp, *bamp;
2648 tl_unbind(mblk_t *mp, tl_endpt_t *tep)
2651 	mblk_t *ackmp;
2725 tl_optmgmt(queue_t *wq, mblk_t *mp)
2728 	mblk_t *ackmp;
2794 tl_conn_req(queue_t *wq, mblk_t *mp)
2801 	mblk_t			*ackmp;
2802 	mblk_t			*dimp;
3035 tl_conn_req_ser(mblk_t *mp, tl_endpt_t *tep)
3039 	mblk_t		*confmp, *cimp, *indmp;
3041 	mblk_t		*ackmp = mp;
3315 tl_conn_res(mblk_t *mp, tl_endpt_t *tep)
3326 	mblk_t			*ackmp, *respmp;
3327 	mblk_t			*dimp, *ccmp = NULL;
3847 tl_discon_req(mblk_t *mp, tl_endpt_t *tep)
3856 	mblk_t			*ackmp, *dimp, *respmp;
4164 tl_addr_req(mblk_t *mp, tl_endpt_t *tep)
4168 	mblk_t			*ackmp;
4234 tl_connected_cots_addr_req(mblk_t *mp, tl_endpt_t *tep)
4238 	mblk_t			*ackmp;
4306 tl_capability_req(mblk_t *mp, tl_endpt_t *tep)
4308 	mblk_t			*ackmp;
4346 tl_info_req_ser(mblk_t *mp, tl_endpt_t *tep)
4358 tl_info_req(mblk_t *mp, tl_endpt_t *tep)
4360 	mblk_t *ackmp;
4387 tl_data(mblk_t *mp, tl_endpt_t *tep)
4588 tl_exdata(mblk_t *mp, tl_endpt_t *tep)
4752 tl_ordrel(mblk_t *mp, tl_endpt_t *tep)
4878 tl_uderr(queue_t *wq, mblk_t *mp, t_scalar_t err)
4883 	mblk_t			*err_mp;
4949 tl_unitdata_ser(mblk_t *mp, tl_endpt_t *tep)
4970 tl_unitdata(mblk_t *mp, tl_endpt_t *tep)
5193 		mblk_t *ui_mp;
5419 static mblk_t *
5420 tl_resizemp(mblk_t *mp, ssize_t new_size)
5459 	mblk_t		*d_mp;
5663 	mblk_t *d_mp;
5692 static mblk_t *
5695 	mblk_t *mp;
5714 static mblk_t *
5717 	mblk_t *mp;
5753 tl_icon_queuemsg(tl_endpt_t *tep, t_scalar_t seqno, mblk_t *nmp)
5756 	mblk_t			**mpp, *mp;
5811 		mblk_t *mp;
5825 tl_icon_sendmsgs(tl_endpt_t *tep, mblk_t **mpp)
5827 	mblk_t			*mp;
5886 tl_icon_freemsgs(mblk_t **mpp)
5888 	mblk_t *mp;
5905 tl_merror(queue_t *wq, mblk_t *mp, int error)
6165 tl_memrecover(queue_t *wq, mblk_t *mp, size_t size)