vipcreatevi.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 "vipl_priv.h"


VIP_ENTRY_POINT VIP_RETURN
VipCreateVi (VIP_NIC_HANDLE NicHandle,
             VIP_VI_ATTRIBUTES * ViAttribs,
             VIP_CQ_HANDLE SendCQHandle,
             VIP_CQ_HANDLE RecvCQHandle, VIP_VI_HANDLE * ViHandle)
{
  VIP_VI *vip_vi_ptr;
  VIP_NIC *vip_nic_ptr;
  VIP_PTAG *vip_ptag_ptr;
  VIP_UINT16 index;
  VIP_CQ *send_vip_cq_ptr = NULL;
  VIP_CQ *recv_vip_cq_ptr = NULL;
  VIP_DEBUG_LABEL (("VipCreateVi"));


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

  if (ViAttribs->EnableRdmaRead != VI_GM_ENABLE_RDMAREAD)
    {
      VIP_DEBUG (("Invalid EnableRdmaRead in ViAttribs"));
      return VIP_INVALID_RDMAREAD;
    }

  if (((ViAttribs->ReliabilityLevel & VI_GM_RELIABILITY_SUPPORT) == 0)
      || ((ViAttribs->ReliabilityLevel != VIP_SERVICE_RELIABLE_RECEPTION)
          && (ViAttribs->ReliabilityLevel != VIP_SERVICE_RELIABLE_DELIVERY)
          && (ViAttribs->ReliabilityLevel != VIP_SERVICE_UNRELIABLE)))
    {
      VIP_DEBUG (("Invalid ReliabilityLevel in ViAttribs"));
      return VIP_INVALID_RELIABILITY_LEVEL;
    }

  if (ViAttribs->MaxTransferSize > VI_GM_MAX_TRANSFER_SIZE)
    {
      VIP_DEBUG (("Invalid MaxTransferSize in ViAttribs"));
      return VIP_INVALID_MTU;
    }

  if (ViAttribs->QoS != NULL)
    {
      VIP_DEBUG (("Invalid QoS in ViAttribs (Only NULL supported)"));
      return VIP_INVALID_QOS;
    }

  if ((ViAttribs->EnableRdmaWrite != VIP_TRUE)
      && (ViAttribs->EnableRdmaWrite != VIP_FALSE))
    {
      VIP_DEBUG (("Invalid EnableRdmaWrite in ViAttribs"));
      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));

  /* check send cq handle */
  if (SendCQHandle != NULL)
    {
      send_vip_cq_ptr = (VIP_CQ *) SendCQHandle;
      if (VIP_INVALID_CQ_HANDLE (send_vip_cq_ptr))
        {
          VIP_DEBUG (("Invalid Send CQ handle"));
          VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
          return VIP_INVALID_PARAMETER;
        }

      if (send_vip_cq_ptr->handle.vip_nic_ptr != vip_nic_ptr)
        {
          VIP_DEBUG (("Inconsistent NIC in Send CQ handle"));
          VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
          return VIP_INVALID_PARAMETER;
        }
    }

  /* check recv cq handle */
  if (RecvCQHandle != NULL)
    {
      recv_vip_cq_ptr = (VIP_CQ *) RecvCQHandle;
      if (VIP_INVALID_CQ_HANDLE (recv_vip_cq_ptr))
        {
          VIP_DEBUG (("Invalid Recv CQ handle"));
          VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
          return VIP_INVALID_PARAMETER;
        }
      
      if (recv_vip_cq_ptr->handle.vip_nic_ptr != vip_nic_ptr)
        {
          VIP_DEBUG (("Inconsistent NIC in Recv CQ handle"));
          VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
          return VIP_INVALID_PARAMETER;
        }
    }

  /* check ptag */
  vip_ptag_ptr = (VIP_PTAG *) ViAttribs->Ptag;
  if (VIP_INVALID_PTAG_HANDLE (vip_ptag_ptr))
    {
      VIP_DEBUG (("Invalid PTAG handle"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_INVALID_PTAG;
    }

  /* check ptag's NIC */
  if (vip_ptag_ptr->handle.vip_nic_ptr != vip_nic_ptr)
    {
      VIP_DEBUG (("PTAG handle's NIC inconsistency"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_INVALID_PTAG;
    }

  /* allocate vi */
  vip_vi_ptr = (VIP_VI *) vip_allocate_handle (&(vip_nic_ptr->vip_vi_set));
  if (vip_vi_ptr == NULL)
    {
      VIP_DEBUG (("VIP_VI alloc failed"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_ERROR_RESOURCE;
    }

  vip_ptag_ptr->handle.ref_count++;
  vip_vi_ptr->vip_ptag_ptr = vip_ptag_ptr;

  if (send_vip_cq_ptr != NULL)
    {
      vip_vi_ptr->send_queue.vip_cq_ptr = send_vip_cq_ptr;
      send_vip_cq_ptr->handle.ref_count++;
    }
  else
    {
      vip_vi_ptr->send_queue.vip_cq_ptr = NULL;
    }

  if (recv_vip_cq_ptr != NULL)
    {
      vip_vi_ptr->recv_queue.vip_cq_ptr = recv_vip_cq_ptr;
      recv_vip_cq_ptr->handle.ref_count++;
    }
  else
    {
      vip_vi_ptr->recv_queue.vip_cq_ptr = NULL;
    }

  vip_vi_ptr->send_queue.first = NULL;
  vip_vi_ptr->send_queue.last = NULL;
  vip_vi_ptr->send_queue.current_desc = NULL;
  vip_vi_ptr->send_queue.current_mem = 0;
  vip_vi_ptr->send_queue.total_count = 0;
  vip_vi_ptr->send_queue.count_to_process = 0;
  vip_vi_ptr->send_queue.event_count = 0;
  VIP_EVENT_INIT (&(vip_vi_ptr->send_queue.event));
  VIP_SEMAPHORE_INIT (&(vip_vi_ptr->send_queue.notify_tokens), 0);
  vip_vi_ptr->send_queue.notify_initialized = VIP_FALSE;
  vip_vi_ptr->send_queue.notify_cancelled = VIP_FALSE;
  vip_vi_ptr->send_queue.first_notify_handler = NULL;
  vip_vi_ptr->send_queue.last_notify_handler = NULL;

  vip_vi_ptr->recv_queue.first = NULL;
  vip_vi_ptr->recv_queue.last = NULL;
  vip_vi_ptr->recv_queue.current_desc = NULL;
  vip_vi_ptr->recv_queue.current_mem = 0;
  vip_vi_ptr->recv_queue.total_count = 0;
  vip_vi_ptr->recv_queue.count_to_process = 0;
  vip_vi_ptr->recv_queue.event_count = 0;
  VIP_EVENT_INIT (&(vip_vi_ptr->recv_queue.event));
  VIP_SEMAPHORE_INIT (&(vip_vi_ptr->recv_queue.notify_tokens), 0);
  vip_vi_ptr->recv_queue.notify_initialized = VIP_FALSE;
  vip_vi_ptr->recv_queue.notify_cancelled = VIP_FALSE;
  vip_vi_ptr->recv_queue.first_notify_handler = NULL;
  vip_vi_ptr->recv_queue.last_notify_handler = NULL;

  vip_vi_ptr->conn_ptr = NULL;
  vip_vi_ptr->net_remote_nic_index =  VIP_HTON_UINT16 (0);
  vip_vi_ptr->net_remote_vi_index =  VIP_HTON_UINT16 (0);
  vip_vi_ptr->mtu = ViAttribs->MaxTransferSize;
  vip_vi_ptr->qos = ViAttribs->QoS;
  vip_vi_ptr->gm_dest_id = 0;
  vip_vi_ptr->gm_dest_port = 0;
  vip_vi_ptr->rdma_write = ViAttribs->EnableRdmaWrite;
  vip_vi_ptr->reliability = ViAttribs->ReliabilityLevel;
  vip_vi_ptr->pending_callbacks = 0;
  vip_vi_ptr->state = VIP_STATE_IDLE;

  /* register the VI handle pointer into the VI pts tab */
  index = vip_nic_ptr->vip_vi_index_free;
  vip_nic_ptr->vip_vi_index_free =
    (((VIP_UINTPTR) (vip_nic_ptr->vip_vi_ptrs[index])) & 0xFFFF);
  vip_nic_ptr->vip_vi_ptrs[index] = vip_vi_ptr;
  vip_vi_ptr->index = index;

  *ViHandle = (VIP_VI_HANDLE) vip_vi_ptr;
  VIP_DEBUG (("Success"));
  VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
  return VIP_SUCCESS;
}