opensm/libvendor/osm_vendor_mlx_dispatcher.c

61 __osmv_dispatch_route(IN osm_bind_handle_t h_bind,
65 __osmv_dispatch_simple_mad(IN osm_bind_handle_t h_bind,
71 __osmv_dispatch_rmpp_mad(IN osm_bind_handle_t h_bind,
77 __osmv_dispatch_rmpp_snd(IN osm_bind_handle_t h_bind,
83 __osmv_dispatch_rmpp_rcv(IN osm_bind_handle_t h_bind,
89 __osmv_dispatch_accept_seg(IN osm_bind_handle_t h_bind,
93 __osmv_dispatch_send_ack(IN osm_bind_handle_t h_bind,
110  *   h_bind                The bind handle
116 osmv_dispatch_mad(IN osm_bind_handle_t h_bind,
122 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
128 	CL_ASSERT(NULL != h_bind && NULL != p_mad && NULL != p_mad_addr);
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);
191 __osmv_dispatch_route(IN osm_bind_handle_t h_bind,
195 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
202 	ret = osmv_txn_lookup(h_bind, key, pp_txn);
236 __osmv_dispatch_simple_mad(IN osm_bind_handle_t h_bind,
244 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
252 	    osm_mad_pool_get(p_bo->p_osm_pool, h_bind, MAD_BLOCK_SIZE,
279 		osmv_txn_done(h_bind, osmv_txn_get_key(p_txn), FALSE);
298 __osmv_dispatch_rmpp_mad(IN osm_bind_handle_t h_bind,
306 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
323 		status = osmv_txn_init(h_bind, /*tid==key */ key, key, &p_txn);
342 		    osmv_txn_init_rmpp_receiver(h_bind, p_txn, is_init_by_peer);
352 		    __osmv_dispatch_rmpp_rcv(h_bind, p_mad, p_txn, p_mad_addr);
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);
387 __osmv_dispatch_rmpp_snd(IN osm_bind_handle_t h_bind,
398 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
425 		osmv_rmpp_send_nak(h_bind, p_mad, p_mad_addr,
443 		osmv_rmpp_send_nak(h_bind, p_mad, p_mad_addr,
467 		osmv_txn_remove_timeout_ev(h_bind, osmv_txn_get_key(p_txn));
484 __osmv_dispatch_rmpp_rcv(IN osm_bind_handle_t h_bind,
491 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
517 	status = __osmv_dispatch_accept_seg(h_bind, p_txn, 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,
592 	    osm_mad_pool_get(p_bo->p_osm_pool, h_bind, size, p_mad_addr);
619 		osmv_txn_done(h_bind, key, FALSE);
647 __osmv_dispatch_accept_seg(IN osm_bind_handle_t h_bind,
653 	osmv_bind_obj_t *p_bo = (osmv_bind_obj_t *) h_bind;
692 __osmv_dispatch_send_ack(IN osm_bind_handle_t h_bind,
709 	osmv_rmpp_send_ack(h_bind, p_req_mad, seg_num, nwl, p_mad_addr);