opensm/libvendor/osm_vendor_mlx_dispatcher.c

67 			   IN osmv_txn_ctx_t * p_txn,
73 			 IN osmv_txn_ctx_t * p_txn,
79 			 IN osmv_txn_ctx_t * p_txn,
85 			 IN osmv_txn_ctx_t * p_txn,
90 			   IN osmv_txn_ctx_t * p_txn,
95 			 IN osmv_txn_ctx_t * p_txn,
123 	osmv_txn_ctx_t *p_txn = NULL;
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);
238 			   IN osmv_txn_ctx_t * p_txn,
268 	if (NULL != p_txn) {
270 		p_req_madw = p_txn->p_madw;
273 		p_mad_buf->trans_id = cl_hton64(osmv_txn_get_tid(p_txn));
279 		osmv_txn_done(h_bind, osmv_txn_get_key(p_txn), FALSE);
300 			 IN osmv_txn_ctx_t * p_txn,
311 	if (NULL == p_txn) {
323 		status = osmv_txn_init(h_bind, /*tid==key */ key, key, &p_txn);
334 	if (OSMV_TXN_RMPP_NONE == osmv_txn_get_rmpp_state(p_txn)) {
342 		    osmv_txn_init_rmpp_receiver(h_bind, p_txn, is_init_by_peer);
348 	switch (osmv_txn_get_rmpp_state(p_txn)) {
352 		    __osmv_dispatch_rmpp_rcv(h_bind, p_mad, p_txn, p_mad_addr);
354 			if (FALSE == osmv_txn_is_rmpp_init_by_peer(p_txn)) {
357 				p_madw = osmv_txn_get_madw(p_txn);
363 			osmv_txn_done(h_bind, osmv_txn_get_key(p_txn), FALSE);
368 		__osmv_dispatch_rmpp_snd(h_bind, p_mad, p_txn, p_mad_addr);
389 			 IN osmv_txn_ctx_t * p_txn,
392 	osmv_rmpp_send_ctx_t *p_send_ctx = osmv_txn_get_rmpp_send_ctx(p_txn);
467 		osmv_txn_remove_timeout_ev(h_bind, osmv_txn_get_key(p_txn));
486 			 IN osmv_txn_ctx_t * p_txn,
490 	osmv_rmpp_recv_ctx_t *p_recv_ctx = osmv_txn_get_rmpp_recv_ctx(p_txn);
496 	uint64_t key = osmv_txn_get_key(p_txn);
497 	uint64_t tid = osmv_txn_get_tid(p_txn);
517 	status = __osmv_dispatch_accept_seg(h_bind, p_txn, p_mad);
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);
603 	p_req_madw = osmv_txn_get_madw(p_txn);
616 	if (FALSE == osmv_txn_is_rmpp_init_by_peer(p_txn)
648 			   IN osmv_txn_ctx_t * p_txn, IN const ib_mad_t * p_mad)
652 	osmv_rmpp_recv_ctx_t *p_recv_ctx = osmv_txn_get_rmpp_recv_ctx(p_txn);
654 	uint64_t tid = osmv_txn_get_tid(p_txn);
694 			 IN osmv_txn_ctx_t * p_txn,
697 	osmv_rmpp_recv_ctx_t *p_recv_ctx = osmv_txn_get_rmpp_recv_ctx(p_txn);