/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */

/* Copyright © 2003-2011 Emulex. All rights reserved.  */

/*
 * Source file containing the implementation of the MailBox queue handling
 * and related helper functions
 */

#include <oce_impl.h>

/*
 * function to drain a MCQ and process its CQEs
 *
 * dev - software handle to the device
 * cq - pointer to the cq to drain
 *
 * return the number of CQEs processed
 */
uint16_t
oce_drain_mq_cq(void *arg)
{
	struct oce_mq_cqe *cqe = NULL;
	uint16_t num_cqe = 0;
	link_state_t link_status;
	struct oce_async_cqe_link_state *acqe;
	struct oce_mq *mq;
	struct oce_cq  *cq;
	struct oce_dev *dev;

	/* do while we do not reach a cqe that is not valid */
	mq = (struct oce_mq *)arg;
	cq = mq->cq;
	dev = mq->parent;
	mutex_enter(&mq->lock);
	cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring, struct oce_mq_cqe);
	while (cqe->u0.dw[3]) {
		DW_SWAP(u32ptr(cqe), sizeof (struct oce_mq_cqe));
		if (cqe->u0.s.async_event) {
			acqe = (struct oce_async_cqe_link_state *)cqe;
			if (acqe->u0.s.event_code ==
			    ASYNC_EVENT_CODE_LINK_STATE) {
				/*
				 * don't care logical or not,
				 * just check up down
				 */

				link_status = ((acqe->u0.s.link_status &
				    ~ASYNC_EVENT_LOGICAL) ==
				    ASYNC_EVENT_LINK_UP) ?
				    LINK_STATE_UP: LINK_STATE_DOWN;
				mac_link_update(dev->mac_handle, link_status);
				dev->link_status = link_status;
				dev->link_speed = -1;
			}
		}
		cqe->u0.dw[3] = 0;
		RING_GET(cq->ring, 1);
		cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring, struct oce_mq_cqe);
		num_cqe++;
	} /* for all valid CQE */
	mutex_exit(&mq->lock);
	oce_arm_cq(dev, cq->cq_id, num_cqe, B_TRUE);
	return (num_cqe);
} /* oce_drain_mq_cq */

int
oce_start_mq(struct oce_mq *mq)
{
	oce_arm_cq(mq->parent, mq->cq->cq_id, 0, B_TRUE);
	return (0);
}


void
oce_clean_mq(struct oce_mq *mq)
{
	struct oce_cq  *cq;
	struct oce_dev *dev;
	uint16_t num_cqe = 0;
	struct oce_mq_cqe *cqe = NULL;

	cq = mq->cq;
	dev = mq->parent;
	cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring, struct oce_mq_cqe);
	while (cqe->u0.dw[3]) {
		DW_SWAP(u32ptr(cqe), sizeof (struct oce_mq_cqe));
		cqe->u0.dw[3] = 0;
		RING_GET(cq->ring, 1);
		cqe = RING_GET_CONSUMER_ITEM_VA(cq->ring, struct oce_mq_cqe);
		num_cqe++;
	} /* for all valid CQE */
	if (num_cqe)
		oce_arm_cq(dev, cq->cq_id, num_cqe, B_FALSE);
	/* Drain the Event queue now */
	oce_drain_eq(mq->cq->eq);
}