opensm/libvendor/osm_vendor_mlx_dispatcher.c

62 		      IN const ib_mad_t * p_mad, OUT osmv_txn_ctx_t ** pp_txn);
66 			   IN const ib_mad_t * p_mad,
72 			 IN const ib_mad_t * p_mad,
78 			 IN const ib_mad_t * p_mad,
84 			 IN const ib_mad_t * p_mad,
91 			   IN const ib_mad_t * p_mad);
121 	const ib_mad_t *p_mad = (ib_mad_t *) p_mad_buf;
128 	CL_ASSERT(NULL != h_bind && NULL != p_mad && NULL != p_mad_addr);
153 						p_mad) == TRUE) {
160 	switch (__osmv_dispatch_route(h_bind, p_mad, &p_txn)) {
166 		__osmv_dispatch_simple_mad(h_bind, p_mad, p_txn, p_mad_addr);
170 		__osmv_dispatch_rmpp_mad(h_bind, p_mad, p_txn, p_mad_addr);
192 		      IN const ib_mad_t * p_mad, OUT osmv_txn_ctx_t ** pp_txn)
196 	boolean_t is_resp = ib_mad_is_response(p_mad);
198 	uint64_t key = cl_ntoh64(p_mad->trans_id);
212 	if (TRUE == osmv_mad_is_rmpp(p_mad)) {
237 			   IN const ib_mad_t * p_mad,
266 	memcpy((void *)p_mad_buf, (void *)p_mad, MAD_BLOCK_SIZE);
299 			 IN const ib_mad_t * p_mad,
304 	uint64_t key = cl_ntoh64(p_mad->trans_id);
312 		if (FALSE == osmv_rmpp_is_data(p_mad)
313 		    || FALSE == osmv_rmpp_is_first(p_mad)) {
352 		    __osmv_dispatch_rmpp_rcv(h_bind, p_mad, p_txn, p_mad_addr);
368 		__osmv_dispatch_rmpp_snd(h_bind, p_mad, p_txn, p_mad_addr);
388 			 IN const ib_mad_t * p_mad,
396 	uint32_t seg_num = cl_ntoh32(((ib_rmpp_mad_t *) p_mad)->seg_num);
397 	uint32_t new_wl = cl_ntoh32(((ib_rmpp_mad_t *) p_mad)->paylen_newwin);
402 	if (TRUE == osmv_rmpp_is_abort_stop(p_mad)) {
411 	if (FALSE == osmv_rmpp_is_ack(p_mad)) {
425 		osmv_rmpp_send_nak(h_bind, p_mad, p_mad_addr,
443 		osmv_rmpp_send_nak(h_bind, p_mad, p_mad_addr,
485 			 IN const ib_mad_t * p_mad,
501 	if (TRUE == osmv_rmpp_is_ack(p_mad)) {
508 	if (TRUE == osmv_rmpp_is_abort_stop(p_mad)) {
517 	status = __osmv_dispatch_accept_seg(h_bind, p_txn, p_mad);
524 		is_last1 = osmv_rmpp_is_last(p_mad);
538 			osmv_rmpp_send_nak(h_bind, p_mad, p_mad_addr,
549 		__osmv_dispatch_send_ack(h_bind, p_mad, p_txn, p_mad_addr);
554 		__osmv_dispatch_send_ack(h_bind, p_mad, p_txn, p_mad_addr);
559 		osmv_rmpp_send_nak(h_bind, p_mad, p_mad_addr,
617 	    || FALSE == osmv_mad_is_multi_resp(p_mad)) {
648 			   IN osmv_txn_ctx_t * p_txn, IN const ib_mad_t * p_mad)
651 	uint32_t seg_num = cl_ntoh32(((ib_rmpp_mad_t *) p_mad)->seg_num);
668 	ret = osmv_rmpp_recv_ctx_store_mad_seg(p_recv_ctx, (uint8_t *) p_mad);