vipcreatecq.c

Go to the documentation of this file.

/********************************************************
 * Myricom VI-GM  networking software and documentation *
 * Copyright (c) 2001 by Myricom, Inc.                  *
 * All rights reserved.                                 *
 * See the file `COPYING' for copyright notice.         *
 ********************************************************/

#include <stdlib.h>

#include "vipl_priv.h"


VIP_ENTRY_POINT VIP_RETURN
VipCreateCQ (VIP_NIC_HANDLE NicHandle,
             VIP_ULONG EntryCount, VIP_CQ_HANDLE * CQHandle)
{
  VIP_NIC *vip_nic_ptr;
  VIP_CQ *vip_cq_ptr;
  VIP_DEBUG_LABEL (("VipCreateCQ"));


  if (EntryCount == 0)
    {
      VIP_DEBUG (("EntryCount is 0"));
      return VIP_ERROR_RESOURCE;
    }

  if (EntryCount > VI_GM_MAX_CQ_ENTRIES)
    {
      VIP_DEBUG (("EntryCount too large (max=%d)", VI_GM_MAX_CQ_ENTRIES));
      return VIP_ERROR_RESOURCE;
    }

  if (CQHandle == NULL)
    {
      VIP_DEBUG (("CQHandle is null"));
      return VIP_INVALID_PARAMETER;
    }

  /* check nic handle */
  vip_nic_ptr = (VIP_NIC *) NicHandle;
  if (VIP_INVALID_NIC_HANDLE (vip_nic_ptr))
    {
      VIP_DEBUG (("Invalid NIC handle"));
      return VIP_INVALID_PARAMETER;
    }
  VIP_MUTEX_LOCK (&(vip_nic_ptr->lock));

  /* allocate cq */
  vip_cq_ptr = (VIP_CQ *) vip_allocate_handle (&(vip_nic_ptr->vip_cq_set));
  if (vip_cq_ptr == NULL)
    {
      VIP_DEBUG (("VIP_CQ alloc failed"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_ERROR_RESOURCE;
    }

  /* allocate cq entries */
  vip_cq_ptr->queue = (VIP_CQ_ENTRY *) calloc (EntryCount,
                                               sizeof (VIP_CQ_ENTRY));
  if (vip_cq_ptr->queue == NULL)
    {
      vip_free_handle (&(vip_nic_ptr->vip_cq_set), (VIP_HANDLE *) vip_cq_ptr);
      VIP_DEBUG (("CQ entries alloc failed"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_ERROR_RESOURCE;
    }

  vip_cq_ptr->next_poll = 0;
  vip_cq_ptr->next_completion = 0;
  vip_cq_ptr->count = EntryCount;
  vip_cq_ptr->event_count = 0;
  VIP_EVENT_INIT (&(vip_cq_ptr->event));
  VIP_SEMAPHORE_INIT (&(vip_cq_ptr->notify_tokens), 0);
  vip_cq_ptr->notify_initialized = VIP_FALSE;
  vip_cq_ptr->notify_cancelled = VIP_FALSE;
  vip_cq_ptr->first_notify_handler = NULL;
  vip_cq_ptr->last_notify_handler = NULL;

  *CQHandle = (VIP_CQ_HANDLE) vip_cq_ptr;

  VIP_DEBUG (("Success"));
  VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
  return VIP_SUCCESS;
}