common/rpc/rpcmod.c

208 void rmm_rput(queue_t *, mblk_t *);
209 void rmm_wput(queue_t *, mblk_t *);
217 static	void	rpcmodwput_other(queue_t *, mblk_t *);
221 static	void	mir_rput(queue_t *q, mblk_t *mp);
223 static	void	mir_wput(queue_t *q, mblk_t *mp);
304 	mblk_t *info_ack;
315 	mblk_t	*mir_head_mp;		/* RPC msg in progress */
321 	mblk_t	*mir_tail_mp;		/* Last mblk in mir_head_mp */
406 	mblk_t	*mir_svc_pend_mp;	/* Pending T_ORDREL_IND or */
418 void tmp_rput(queue_t *q, mblk_t *mp);
430 tmp_rput(queue_t *q, mblk_t *mp)
463 	mblk_t *bp;
536 rmm_rput(queue_t *q, mblk_t  *mp)
548 rmm_wput(queue_t *q, mblk_t *mp)
565 static void rpcmod_release(queue_t *, mblk_t *);
576 	extern void (*rpc_rele)(queue_t *, mblk_t *);
697 rpcmodrput(queue_t *q, mblk_t *mp)
715 		mblk_t *nmp = copymsg(mp);
722 		mblk_t *nmp;
775 			mblk_t *nmp;
911 rpcmodwput(queue_t *q, mblk_t *mp)
959 rpcmodwput_other(queue_t *q, mblk_t *mp)
1006 	mblk_t		*mp = NULL;
1029 rpcmod_release(queue_t *q, mblk_t *bp)
1079 static int	mir_clnt_dup_request(queue_t *q, mblk_t *mp);
1080 static void	mir_rput_proto(queue_t *q, mblk_t *mp);
1082 static void	mir_svc_release(queue_t *wq, mblk_t *mp);
1090 static void	mir_wput(queue_t *q, mblk_t *mp);
1091 static void	mir_wput_other(queue_t *q, mblk_t *mp);
1094 static	int	mir_check_len(queue_t *, int32_t, mblk_t *);
1097 extern void	(*mir_rele)(queue_t *, mblk_t *);
1172 mir_clnt_dup_request(queue_t *q, mblk_t *mp)
1174 	mblk_t  *mp1;
1198 	mblk_t	*mp;
1404 mir_rput(queue_t *q, mblk_t *mp)
1408 	mblk_t	*cont_mp, *head_mp, *tail_mp, *mp1;
1711 mir_rput_proto(queue_t *q, mblk_t *mp)
1731 				mir->mir_head_mp = (mblk_t *)0;
1732 				mir->mir_tail_mp = (mblk_t *)0;
1952 	mblk_t	*mp;
1953 	mblk_t	*cmp = NULL;
2071 	mblk_t	*mp;
2136 mir_svc_release(queue_t *wq, mblk_t *mp)
2139 	mblk_t	*cmp = NULL;
2391 mir_wput(queue_t *q, mblk_t *mp)
2499 mir_wput_other(queue_t *q, mblk_t *mp)
2758 	mblk_t	*mp;
2924 mir_check_len(queue_t *q, int32_t frag_len, mblk_t *head_mp)