/*

 * Copyright (c) 2004-2009 Voltaire, Inc. All rights reserved.

 * Copyright (c) 2002-2007,2009 Mellanox Technologies LTD. All rights reserved.

 * Copyright (c) 1996-2003 Intel Corporation. All rights reserved.

 * Copyright (c) 2009,2010 HNR Consulting. All rights reserved.

 *

 * This software is available to you under a choice of one of two

 * licenses.  You may choose to be licensed under the terms of the GNU

 * General Public License (GPL) Version 2, available from the file

 * COPYING in the main directory of this source tree, or the

 * OpenIB.org BSD license below:

 *

 *     Redistribution and use in source and binary forms, with or

 *     without modification, are permitted provided that the following

 *     conditions are met:

 *

 *      - Redistributions of source code must retain the above

 *        copyright notice, this list of conditions and the following

 *        disclaimer.

 *

 *      - Redistributions in binary form must reproduce the above

 *        copyright notice, this list of conditions and the following

 *        disclaimer in the documentation and/or other materials

 *        provided with the distribution.

 *

 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,

 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND

 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS

 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN

 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN

 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

 * SOFTWARE.

 *

 */

#if HAVE_CONFIG_H

#  include <config.h>

#endif				/* HAVE_CONFIG_H */

#include <stdlib.h>

#include <string.h>

#include <sys/time.h>

#include <vendor/osm_vendor_api.h>

#include <vendor/osm_vendor_sa_api.h>

#include <complib/cl_event.h>

/* this struct is the internal rep of the bind handle */

typedef struct _osmv_sa_bind_info {

	osm_bind_handle_t h_bind;

	osm_log_t *p_log;

	osm_vendor_t *p_vendor;

	osm_mad_pool_t *p_mad_pool;

	cl_event_t sync_event;

	time_t last_lids_update_sec;

} osmv_sa_bind_info_t;

/*

  Call back on new mad received:

  We basically only need to set the context of the query.

  Or report an error.

  A pointer to the actual context of the request (a copy of the oriignal

  request structure) is attached as the p_madw->context.ni_context.node_guid

*/

static void

__osmv_sa_mad_rcv_cb(IN osm_madw_t * p_madw,

		     IN void *bind_context, IN osm_madw_t * p_req_madw)

{

	osmv_sa_bind_info_t *p_bind = (osmv_sa_bind_info_t *) bind_context;

	osmv_query_req_t *p_query_req_copy = NULL;

	osmv_query_res_t query_res;

	ib_sa_mad_t *p_sa_mad;

	ib_net16_t mad_status;

	OSM_LOG_ENTER(p_bind->p_log);

	if (!p_req_madw) {

		OSM_LOG(p_bind->p_log, OSM_LOG_DEBUG,

			"Ignoring a non-response mad\n");

		osm_mad_pool_put(p_bind->p_mad_pool, p_madw);

		goto Exit;

	}

	/* obtain the sent context since we store it during send in the ni_ctx */

	p_query_req_copy = (osmv_query_req_t *)

            (uintptr_t)(osm_madw_get_ni_context_ptr(p_req_madw)->node_guid);

	/* provide the context of the original request in the result */

	query_res.query_context = p_query_req_copy->query_context;

	/* provide the resulting madw */

	query_res.p_result_madw = p_madw;

	/* update the req fields */

	p_sa_mad = (ib_sa_mad_t *) p_madw->p_mad;

	/* if we got a remote error track it in the status */

	mad_status = (ib_net16_t) (p_sa_mad->status & IB_SMP_STATUS_MASK);

	if (mad_status != IB_SUCCESS) {

		OSM_LOG(p_bind->p_log, OSM_LOG_ERROR, "ERR 5501: "

			"Remote error: 0x%04X\n", cl_ntoh16(mad_status));

		query_res.status = IB_REMOTE_ERROR;

	} else

		query_res.status = IB_SUCCESS;

	/* what if we have got back an empty mad ? */

	if (!p_madw->mad_size) {

		OSM_LOG(p_bind->p_log, OSM_LOG_ERROR, "ERR 5502: "

			"Got an empty mad\n");

		query_res.status = IB_ERROR;

	}

	if (IB_SUCCESS == mad_status) {

		/* if we are in not in a method response of an rmpp nature we must get only 1 */

		/* HACK: in the future we might need to be smarter for other methods... */

		if (p_sa_mad->method != IB_MAD_METHOD_GETTABLE_RESP) {

			query_res.result_cnt = 1;

		} else {

#ifndef VENDOR_RMPP_SUPPORT

			if (mad_status != IB_SUCCESS)

				query_res.result_cnt = 0;

			else

				query_res.result_cnt = 1;

#else

			if (ib_get_attr_size(p_sa_mad->attr_offset)) {

				/* we used the offset value to calculate the

				   number of records in here */

				query_res.result_cnt =

				    (p_madw->mad_size - IB_SA_MAD_HDR_SIZE) /

				    ib_get_attr_size(p_sa_mad->attr_offset);

				OSM_LOG(p_bind->p_log, OSM_LOG_DEBUG,

					"Count = %u = %zu / %u (%zu)\n",

					query_res.result_cnt,

					p_madw->mad_size - IB_SA_MAD_HDR_SIZE,

					ib_get_attr_size(p_sa_mad->attr_offset),

					(p_madw->mad_size -

					 IB_SA_MAD_HDR_SIZE) %

					ib_get_attr_size(p_sa_mad->attr_offset));

			} else

				query_res.result_cnt = 0;

#endif

		}

	}

	query_res.query_type = p_query_req_copy->query_type;

	p_query_req_copy->pfn_query_cb(&query_res);

	if ((p_query_req_copy->flags & OSM_SA_FLAGS_SYNC) == OSM_SA_FLAGS_SYNC)

		cl_event_signal(&p_bind->sync_event);

Exit:

	/* free the copied query request if found */

	if (p_query_req_copy)

		free(p_query_req_copy);

	/* put back the request madw */

	if (p_req_madw)

		osm_mad_pool_put(p_bind->p_mad_pool, p_req_madw);

	OSM_LOG_EXIT(p_bind->p_log);

}

/*

  Send Error Callback:

  Only report the error and get rid of the mad wrapper

*/

static void __osmv_sa_mad_err_cb(IN void *bind_context, IN osm_madw_t * p_madw)

{

	osmv_sa_bind_info_t *p_bind = (osmv_sa_bind_info_t *) bind_context;

	osmv_query_req_t *p_query_req_copy = NULL;

	osmv_query_res_t query_res;

	OSM_LOG_ENTER(p_bind->p_log);

	/* Obtain the sent context etc */

	p_query_req_copy = (osmv_query_req_t *)

            (uintptr_t)(osm_madw_get_ni_context_ptr(p_madw)->node_guid);

	/* provide the context of the original request in the result */

	query_res.query_context = p_query_req_copy->query_context;

	query_res.p_result_madw = p_madw;

	query_res.status = IB_TIMEOUT;

	query_res.result_cnt = 0;

	query_res.query_type = p_query_req_copy->query_type;

	p_query_req_copy->pfn_query_cb(&query_res);

	if ((p_query_req_copy->flags & OSM_SA_FLAGS_SYNC) == OSM_SA_FLAGS_SYNC)

		cl_event_signal(&p_bind->sync_event);

	free(p_query_req_copy);

	OSM_LOG_EXIT(p_bind->p_log);

}

/*****************************************************************************

 Update lids of vendor umad_port.

 *****************************************************************************/

static ib_api_status_t update_umad_port(osm_vendor_t * p_vend)

{

	umad_port_t port;

	if (umad_get_port(p_vend->umad_port.ca_name,

			  p_vend->umad_port.portnum, &port) < 0)

		return IB_ERROR;

	p_vend->umad_port.base_lid = port.base_lid;

	p_vend->umad_port.sm_lid = port.sm_lid;

	umad_release_port(&port);

	return IB_SUCCESS;

}

osm_bind_handle_t

osmv_bind_sa(IN osm_vendor_t * const p_vend,

	     IN osm_mad_pool_t * const p_mad_pool, IN ib_net64_t port_guid)

{

	osm_bind_info_t bind_info;

	osm_log_t *p_log = p_vend->p_log;

	osmv_sa_bind_info_t *p_sa_bind_info;

	cl_status_t cl_status;

	OSM_LOG_ENTER(p_log);

	OSM_LOG(p_log, OSM_LOG_DEBUG,

		"Binding to port 0x%" PRIx64 "\n", cl_ntoh64(port_guid));

	bind_info.port_guid = port_guid;

	bind_info.mad_class = IB_MCLASS_SUBN_ADM;

	bind_info.class_version = 2;

	bind_info.is_responder = FALSE;

	bind_info.is_trap_processor = FALSE;

	bind_info.is_report_processor = FALSE;

	bind_info.send_q_size = OSM_SM_DEFAULT_QP1_RCV_SIZE;

	bind_info.recv_q_size = OSM_SM_DEFAULT_QP1_SEND_SIZE;

	bind_info.timeout = p_vend->timeout;

	bind_info.retries = OSM_DEFAULT_RETRY_COUNT;

	/* allocate the new sa bind info */

	p_sa_bind_info =

	    (osmv_sa_bind_info_t *) malloc(sizeof(osmv_sa_bind_info_t));

	if (!p_sa_bind_info) {

		OSM_LOG(p_log, OSM_LOG_ERROR, "ERR 5505: "

			"Failed to allocate new bind structure\n");

		p_sa_bind_info = OSM_BIND_INVALID_HANDLE;

		goto Exit;

	}

	/* store some important context */

	p_sa_bind_info->p_log = p_log;

	p_sa_bind_info->p_mad_pool = p_mad_pool;

	p_sa_bind_info->p_vendor = p_vend;

	/* Bind to the lower level */

	p_sa_bind_info->h_bind = osm_vendor_bind(p_vend, &bind_info, p_mad_pool, __osmv_sa_mad_rcv_cb, __osmv_sa_mad_err_cb, p_sa_bind_info);	/* context provided to CBs */

	if (p_sa_bind_info->h_bind == OSM_BIND_INVALID_HANDLE) {

		free(p_sa_bind_info);

		p_sa_bind_info = OSM_BIND_INVALID_HANDLE;

		OSM_LOG(p_log, OSM_LOG_ERROR, "ERR 5506: "

			"Failed to bind to vendor GSI\n");

		goto Exit;

	}

	/* update time umad_port is initialized now */

	p_sa_bind_info->last_lids_update_sec = time(NULL);

	/* initialize the sync_event */

	cl_event_construct(&p_sa_bind_info->sync_event);

	cl_status = cl_event_init(&p_sa_bind_info->sync_event, TRUE);

	if (cl_status != CL_SUCCESS) {

		OSM_LOG(p_log, OSM_LOG_ERROR, "ERR 5508: "

			"cl_init_event failed: %s\n", ib_get_err_str(cl_status));

		free(p_sa_bind_info);

		p_sa_bind_info = OSM_BIND_INVALID_HANDLE;

	}

Exit:

	OSM_LOG_EXIT(p_log);

	return (p_sa_bind_info);

}

/****t* OSM Vendor SA Client/osmv_sa_mad_data

 * NAME

 *    osmv_sa_mad_data

 *

 * DESCRIPTION

 * Extra fields required to perform a mad query

 *  This struct is passed to the actual send method

 *

 * SYNOPSIS

 */

typedef struct _osmv_sa_mad_data {

	/* MAD data. */

	uint8_t method;

	ib_net16_t attr_id;

	ib_net16_t attr_offset;

	ib_net32_t attr_mod;

	ib_net64_t comp_mask;

	void *p_attr;

} osmv_sa_mad_data_t;

/*

 * method

 *    The method of the mad to be sent

 *

 *  attr_id

 *     Attribute ID

 *

 *  attr_offset

 *     Offset as defined by RMPP

 *

 *  attr_mod

 *     Attribute modifier

 *

 *  comp_mask

 *     The component mask of the query

 *

 *  p_attr

 *     A pointer to the record of the attribute to be sent.

 *

 *****/

/* Send a MAD out on the GSI interface */

static ib_api_status_t

__osmv_send_sa_req(IN osmv_sa_bind_info_t * p_bind,

		   IN const osmv_sa_mad_data_t * const p_sa_mad_data,

		   IN const osmv_query_req_t * const p_query_req)

{

	ib_api_status_t status;

	ib_mad_t *p_mad_hdr;

	ib_sa_mad_t *p_sa_mad;

	osm_madw_t *p_madw;

	osm_log_t *p_log = p_bind->p_log;

	static atomic32_t trans_id;

	boolean_t sync;

	osmv_query_req_t *p_query_req_copy;

	uint32_t sa_size;

	OSM_LOG_ENTER(p_log);

	/*

	   since the sm_lid might change we obtain it every send

	   (actually it is cached in the bind object and refreshed

	   every 30sec by this proc)

	 */

	if (time(NULL) > p_bind->last_lids_update_sec + 30) {

		status = update_umad_port(p_bind->p_vendor);

		if (status != IB_SUCCESS) {

			OSM_LOG(p_log, OSM_LOG_ERROR, "ERR 5509: "

				"Failed to obtain the SM lid\n");

			goto Exit;

		}

		p_bind->last_lids_update_sec = time(NULL);

	}

	/* Get a MAD wrapper for the send */

	p_madw = osm_mad_pool_get(p_bind->p_mad_pool,

				  p_bind->h_bind, MAD_BLOCK_SIZE, NULL);

	if (p_madw == NULL) {

		OSM_LOG(p_log, OSM_LOG_ERROR, "ERR 5510: "

			"Unable to acquire MAD\n");

		status = IB_INSUFFICIENT_RESOURCES;

		goto Exit;

	}

	/* Initialize the Sent MAD: */

	/* Initialize the MAD buffer for the send operation. */

	p_mad_hdr = osm_madw_get_mad_ptr(p_madw);

	p_sa_mad = osm_madw_get_sa_mad_ptr(p_madw);

	/* Get a new transaction Id */

	cl_atomic_inc(&trans_id);

	/* Cleanup the MAD from any residue */

	memset(p_sa_mad, 0, MAD_BLOCK_SIZE);

	/* Initialize the standard MAD header. */

	ib_mad_init_new(p_mad_hdr,	/* mad pointer */

			IB_MCLASS_SUBN_ADM,	/* class */

			(uint8_t) 2,	/* version */

			p_sa_mad_data->method,	/* method */

			cl_hton64((uint64_t) trans_id),	/* tid */

			p_sa_mad_data->attr_id,	/* attr id */

			p_sa_mad_data->attr_mod	/* attr mod */);

	/* Set the query information. */

	p_sa_mad->sm_key = p_query_req->sm_key;

	p_sa_mad->attr_offset = 0;

	p_sa_mad->comp_mask = p_sa_mad_data->comp_mask;

#ifdef DUAL_SIDED_RMPP

	if (p_sa_mad->method == IB_MAD_METHOD_GETMULTI)

		p_sa_mad->rmpp_flags = IB_RMPP_FLAG_ACTIVE;

#endif

	if (p_sa_mad->comp_mask) {

		p_sa_mad_data->attr_offset ? (sa_size = ib_get_attr_size(p_sa_mad_data->attr_offset)) : (sa_size = IB_SA_DATA_SIZE);

		memcpy(p_sa_mad->data, p_sa_mad_data->p_attr, sa_size);

	}

	/*

	   Provide the address to send to

	 */

	p_madw->mad_addr.dest_lid =

	    cl_hton16(p_bind->p_vendor->umad_port.sm_lid);

	p_madw->mad_addr.addr_type.smi.source_lid =

	    cl_hton16(p_bind->p_vendor->umad_port.base_lid);

	p_madw->mad_addr.addr_type.gsi.remote_qp = CL_HTON32(1);

	p_madw->resp_expected = TRUE;

	p_madw->fail_msg = CL_DISP_MSGID_NONE;

	/*

	   add grh

	 */

	if (p_query_req->with_grh) {

		OSM_LOG(p_log, OSM_LOG_DEBUG, "sending sa query with GRH "

			"GID 0x%016" PRIx64 " 0x%016" PRIx64 "\n",

			cl_ntoh64(p_query_req->gid.unicast.prefix),

			cl_ntoh64(p_query_req->gid.unicast.interface_id));

		p_madw->mad_addr.addr_type.gsi.global_route = 1;

		memset(&p_madw->mad_addr.addr_type.gsi.grh_info, 0,

		       sizeof(p_madw->mad_addr.addr_type.gsi.grh_info));

		memcpy(&p_madw->mad_addr.addr_type.gsi.grh_info.dest_gid, &(p_query_req->gid), 16);

	}

	/*

	   Provide MAD context such that the call back will know what to do.

	   We have to keep the entire request structure so we know the CB.

	   Since we can not rely on the client to keep it around until

	   the response - we duplicate it and will later dispose it (in CB).

	   To store on the MADW we cast it into what opensm has:

	   p_madw->context.ni_context.node_guid

	 */

	p_query_req_copy = malloc(sizeof(*p_query_req_copy));

	if (!p_query_req_copy) {

		OSM_LOG(p_log, OSM_LOG_ERROR, "ERR 5511: "

			"Unable to acquire memory for query copy\n");

		osm_mad_pool_put(p_bind->p_mad_pool, p_madw);

		status = IB_INSUFFICIENT_RESOURCES;

		goto Exit;

	}

	*p_query_req_copy = *p_query_req;

	osm_madw_get_ni_context_ptr(p_madw)->node_guid =

	    (ib_net64_t) (uintptr_t)p_query_req_copy;

	/* we can support async as well as sync calls */

	sync = ((p_query_req->flags & OSM_SA_FLAGS_SYNC) == OSM_SA_FLAGS_SYNC);

	/* send the mad asynchronously */

	status = osm_vendor_send(osm_madw_get_bind_handle(p_madw),

				 p_madw, p_madw->resp_expected);

	/* if synchronous - wait on the event */

	if (sync) {

		OSM_LOG(p_log, OSM_LOG_DEBUG, "Waiting for async event\n");

		cl_event_wait_on(&p_bind->sync_event, EVENT_NO_TIMEOUT, FALSE);

		cl_event_reset(&p_bind->sync_event);

		status = p_madw->status;

	}

Exit:

	OSM_LOG_EXIT(p_log);

	return status;

}

/*

 * Query the SA based on the user's request.

 */

ib_api_status_t

osmv_query_sa(IN osm_bind_handle_t h_bind,

	      IN const osmv_query_req_t * const p_query_req)

{

	union {

		ib_service_record_t svc_rec;

		ib_node_record_t node_rec;

		ib_portinfo_record_t port_info;

		ib_path_rec_t path_rec;

#ifdef DUAL_SIDED_RMPP

		ib_multipath_rec_t multipath_rec;

#endif

		ib_class_port_info_t class_port_info;

	} u;

	osmv_sa_mad_data_t sa_mad_data;

	osmv_sa_bind_info_t *p_bind = (osmv_sa_bind_info_t *) h_bind;

	osmv_user_query_t *p_user_query;

#ifdef DUAL_SIDED_RMPP

	osmv_multipath_req_t *p_mpr_req;

	int i, j;

#endif

	osm_log_t *p_log = p_bind->p_log;

	ib_api_status_t status;

	OSM_LOG_ENTER(p_log);

	/* Set the request information. */

	sa_mad_data.method = IB_MAD_METHOD_GETTABLE;

	sa_mad_data.attr_mod = 0;

	sa_mad_data.attr_offset = 0;

	/* Set the MAD attributes and component mask correctly. */

	switch (p_query_req->query_type) {

	case OSMV_QUERY_USER_DEFINED:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 USER_DEFINED\n");

		p_user_query = (osmv_user_query_t *) p_query_req->p_query_input;

		if (p_user_query->method)

			sa_mad_data.method = p_user_query->method;

#ifdef DUAL_SIDED_RMPP

		if (sa_mad_data.method == IB_MAD_METHOD_GETMULTI ||

		    sa_mad_data.method == IB_MAD_METHOD_GETTRACETABLE)

			sa_mad_data.attr_offset = p_user_query->attr_offset;

#endif

		sa_mad_data.attr_id = p_user_query->attr_id;

		sa_mad_data.attr_mod = p_user_query->attr_mod;

		sa_mad_data.comp_mask = p_user_query->comp_mask;

		sa_mad_data.p_attr = p_user_query->p_attr;

		break;

	case OSMV_QUERY_ALL_SVC_RECS:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 SVC_REC_BY_NAME\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_SERVICE_RECORD;

		sa_mad_data.comp_mask = 0;

		sa_mad_data.p_attr = &u.svc_rec;

		break;

	case OSMV_QUERY_SVC_REC_BY_NAME:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 SVC_REC_BY_NAME\n");

		sa_mad_data.method = IB_MAD_METHOD_GET;

		sa_mad_data.attr_id = IB_MAD_ATTR_SERVICE_RECORD;

		sa_mad_data.comp_mask = IB_SR_COMPMASK_SNAME;

		sa_mad_data.p_attr = &u.svc_rec;

		memcpy(u.svc_rec.service_name, p_query_req->p_query_input,

		       sizeof(ib_svc_name_t));

		break;

	case OSMV_QUERY_SVC_REC_BY_ID:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 SVC_REC_BY_ID\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_SERVICE_RECORD;

		sa_mad_data.comp_mask = IB_SR_COMPMASK_SID;

		sa_mad_data.p_attr = &u.svc_rec;

		u.svc_rec.service_id =

		    *(ib_net64_t *) (p_query_req->p_query_input);

		break;

	case OSMV_QUERY_CLASS_PORT_INFO:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 CLASS_PORT_INFO\n");

		sa_mad_data.method = IB_MAD_METHOD_GET;

		sa_mad_data.attr_id = IB_MAD_ATTR_CLASS_PORT_INFO;

		sa_mad_data.comp_mask = 0;

		sa_mad_data.p_attr = &u.class_port_info;

		break;

	case OSMV_QUERY_NODE_REC_BY_NODE_GUID:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 NODE_REC_BY_NODE_GUID\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_NODE_RECORD;

		sa_mad_data.comp_mask = IB_NR_COMPMASK_NODEGUID;

		sa_mad_data.p_attr = &u.node_rec;

		u.node_rec.node_info.node_guid =

		    *(ib_net64_t *) (p_query_req->p_query_input);

		break;

	case OSMV_QUERY_PORT_REC_BY_LID:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 PORT_REC_BY_LID\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_PORTINFO_RECORD;

		sa_mad_data.comp_mask = IB_PIR_COMPMASK_LID;

		sa_mad_data.p_attr = &u.port_info;

		u.port_info.lid = *(ib_net16_t *) (p_query_req->p_query_input);

		break;

	case OSMV_QUERY_PORT_REC_BY_LID_AND_NUM:

		sa_mad_data.method = IB_MAD_METHOD_GET;

		p_user_query = (osmv_user_query_t *) p_query_req->p_query_input;

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 PORT_REC_BY_LID_AND_NUM\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_PORTINFO_RECORD;

		sa_mad_data.comp_mask =

		    IB_PIR_COMPMASK_LID | IB_PIR_COMPMASK_PORTNUM;

		sa_mad_data.p_attr = p_user_query->p_attr;

		break;

	case OSMV_QUERY_VLARB_BY_LID_PORT_BLOCK:

		sa_mad_data.method = IB_MAD_METHOD_GET;

		p_user_query = (osmv_user_query_t *) p_query_req->p_query_input;

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 OSMV_QUERY_VLARB_BY_LID_PORT_BLOCK\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_VLARB_RECORD;

		sa_mad_data.comp_mask =

		    IB_VLA_COMPMASK_LID | IB_VLA_COMPMASK_OUT_PORT |

		    IB_VLA_COMPMASK_BLOCK;

		sa_mad_data.p_attr = p_user_query->p_attr;

		break;

	case OSMV_QUERY_SLVL_BY_LID_AND_PORTS:

		sa_mad_data.method = IB_MAD_METHOD_GET;

		p_user_query = (osmv_user_query_t *) p_query_req->p_query_input;

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 OSMV_QUERY_VLARB_BY_LID_PORT_BLOCK\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_SLVL_RECORD;

		sa_mad_data.comp_mask =

		    IB_SLVL_COMPMASK_LID | IB_SLVL_COMPMASK_OUT_PORT |

		    IB_SLVL_COMPMASK_IN_PORT;

		sa_mad_data.p_attr = p_user_query->p_attr;

		break;

	case OSMV_QUERY_PATH_REC_BY_PORT_GUIDS:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 PATH_REC_BY_PORT_GUIDS\n");

		memset(&u.path_rec, 0, sizeof(ib_path_rec_t));

		sa_mad_data.attr_id = IB_MAD_ATTR_PATH_RECORD;

		sa_mad_data.comp_mask =

		    (IB_PR_COMPMASK_DGID | IB_PR_COMPMASK_SGID | IB_PR_COMPMASK_NUMBPATH);

		u.path_rec.num_path = 0x7f;

		sa_mad_data.p_attr = &u.path_rec;

		ib_gid_set_default(&u.path_rec.dgid,

				   ((osmv_guid_pair_t *) (p_query_req->

							  p_query_input))->

							  dest_guid);

		ib_gid_set_default(&u.path_rec.sgid,

				   ((osmv_guid_pair_t *) (p_query_req->

							  p_query_input))->

							  src_guid);

		break;

	case OSMV_QUERY_PATH_REC_BY_GIDS:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 PATH_REC_BY_GIDS\n");

		memset(&u.path_rec, 0, sizeof(ib_path_rec_t));

		sa_mad_data.attr_id = IB_MAD_ATTR_PATH_RECORD;

		sa_mad_data.comp_mask =

		    (IB_PR_COMPMASK_DGID | IB_PR_COMPMASK_SGID | IB_PR_COMPMASK_NUMBPATH);

		u.path_rec.num_path = 0x7f;

		sa_mad_data.p_attr = &u.path_rec;

		memcpy(&u.path_rec.dgid,

		       &((osmv_gid_pair_t *) (p_query_req->p_query_input))->

					      dest_gid,

		       sizeof(ib_gid_t));

		memcpy(&u.path_rec.sgid,

		       &((osmv_gid_pair_t *) (p_query_req->p_query_input))->

					      src_gid,

		       sizeof(ib_gid_t));

		break;

	case OSMV_QUERY_PATH_REC_BY_LIDS:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 PATH_REC_BY_LIDS\n");

		memset(&u.path_rec, 0, sizeof(ib_path_rec_t));

		sa_mad_data.method = IB_MAD_METHOD_GET;

		sa_mad_data.attr_id = IB_MAD_ATTR_PATH_RECORD;

		sa_mad_data.comp_mask =

		    (IB_PR_COMPMASK_DLID | IB_PR_COMPMASK_SLID);

		sa_mad_data.p_attr = &u.path_rec;

		u.path_rec.dlid =

		    ((osmv_lid_pair_t *) (p_query_req->p_query_input))->dest_lid;

		u.path_rec.slid =

		    ((osmv_lid_pair_t *) (p_query_req->p_query_input))->src_lid;

		break;

	case OSMV_QUERY_UD_MULTICAST_SET:

		sa_mad_data.method = IB_MAD_METHOD_SET;

		p_user_query = (osmv_user_query_t *) p_query_req->p_query_input;

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 OSMV_QUERY_UD_MULTICAST_SET\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_MCMEMBER_RECORD;

		sa_mad_data.comp_mask = p_user_query->comp_mask;

		sa_mad_data.p_attr = p_user_query->p_attr;

		break;

	case OSMV_QUERY_UD_MULTICAST_DELETE:

		sa_mad_data.method = IB_MAD_METHOD_DELETE;

		p_user_query = (osmv_user_query_t *) p_query_req->p_query_input;

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 OSMV_QUERY_UD_MULTICAST_DELETE\n");

		sa_mad_data.attr_id = IB_MAD_ATTR_MCMEMBER_RECORD;

		sa_mad_data.comp_mask = p_user_query->comp_mask;

		sa_mad_data.p_attr = p_user_query->p_attr;

		break;

#ifdef DUAL_SIDED_RMPP

	case OSMV_QUERY_MULTIPATH_REC:

		OSM_LOG(p_log, OSM_LOG_DEBUG, "DBG:001 MULTIPATH_REC\n");

		/* Validate sgid/dgid counts against SA client limit */

		p_mpr_req = (osmv_multipath_req_t *) p_query_req->p_query_input;

		if (p_mpr_req->sgid_count + p_mpr_req->dgid_count >

		    IB_MULTIPATH_MAX_GIDS) {

			OSM_LOG(p_log, OSM_LOG_ERROR, "DBG:001 MULTIPATH_REC "

				"SGID count %d DGID count %d max count %d\n",

				p_mpr_req->sgid_count, p_mpr_req->dgid_count,

				IB_MULTIPATH_MAX_GIDS);

			CL_ASSERT(0);

			return IB_ERROR;

		}

		memset(&u.multipath_rec, 0, sizeof(ib_multipath_rec_t));

		sa_mad_data.method = IB_MAD_METHOD_GETMULTI;

		sa_mad_data.attr_id = IB_MAD_ATTR_MULTIPATH_RECORD;

		sa_mad_data.attr_offset =

		    ib_get_attr_offset(sizeof(ib_multipath_rec_t));

		sa_mad_data.p_attr = &u.multipath_rec;

		sa_mad_data.comp_mask = p_mpr_req->comp_mask;

		u.multipath_rec.num_path = p_mpr_req->num_path;

		if (p_mpr_req->reversible)

			u.multipath_rec.num_path |= 0x80;

		else

			u.multipath_rec.num_path &= ~0x80;

		u.multipath_rec.pkey = p_mpr_req->pkey;

		ib_multipath_rec_set_sl(&u.multipath_rec, p_mpr_req->sl);

		ib_multipath_rec_set_qos_class(&u.multipath_rec, 0);

		u.multipath_rec.independence = p_mpr_req->independence;

		u.multipath_rec.sgid_count = p_mpr_req->sgid_count;

		u.multipath_rec.dgid_count = p_mpr_req->dgid_count;

		j = 0;

		for (i = 0; i < p_mpr_req->sgid_count; i++, j++)

			u.multipath_rec.gids[j] = p_mpr_req->gids[j];

		for (i = 0; i < p_mpr_req->dgid_count; i++, j++)

			u.multipath_rec.gids[j] = p_mpr_req->gids[j];

		break;

#endif

	default:

		OSM_LOG(p_log, OSM_LOG_ERROR, "DBG:001 UNKNOWN\n");

		CL_ASSERT(0);

		return IB_ERROR;

	}

	status = __osmv_send_sa_req(h_bind, &sa_mad_data, p_query_req);

	OSM_LOG_EXIT(p_log);

	return status;

}