vipdestroyvi.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
VipDestroyVi (VIP_VI_HANDLE ViHandle)
{
  VIP_VI *vip_vi_ptr;
  VIP_NIC *vip_nic_ptr;
  VIP_DEBUG_LABEL (("VipDestroyVi"));

  /* check vi handle */
  vip_vi_ptr = (VIP_VI *) ViHandle;
  if (VIP_INVALID_VI_HANDLE (vip_vi_ptr))
    {
      VIP_DEBUG (("Invalid NIC handle"));
      return VIP_INVALID_PARAMETER;
    }
  vip_nic_ptr = vip_vi_ptr->handle.vip_nic_ptr;
  VIP_MUTEX_LOCK (&(vip_nic_ptr->lock));

  /* check vi ref count */
  if (vip_vi_ptr->handle.ref_count > 0)
    {
      VIP_DEBUG (("Pending network operation on the VI"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_ERROR_RESOURCE;
    }

  /* check vi state */
  if (vip_vi_ptr->state != VIP_STATE_IDLE)
    {
      VIP_DEBUG (("VI is not in idle state"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_INVALID_STATE;
    }

  /* check for pending send descriptors */
  if (vip_vi_ptr->send_queue.total_count > 0)
    {
      VIP_DEBUG (("VI has pending send descriptors"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_INVALID_STATE;
    }

  /* check for pending receive descriptors */
  if (vip_vi_ptr->recv_queue.total_count > 0)
    {
      VIP_DEBUG (("VI has pending receive descriptors"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      return VIP_INVALID_STATE;
    }

  /* cancel the send notify thread if needed */
  if (vip_vi_ptr->send_queue.notify_initialized == VIP_TRUE)
    {
      vip_vi_ptr->send_queue.notify_cancelled = VIP_TRUE;
      VIP_SEMAPHORE_POST (&(vip_vi_ptr->send_queue.notify_tokens));
      VIP_MUTEX_LOCK (&(vip_nic_ptr->vip_gm_ptr->lock));
      VIP_EVENT_SIGNAL (&(vip_vi_ptr->send_queue.event));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->vip_gm_ptr->lock));
      VIP_THREAD_JOIN (vip_vi_ptr->send_queue.notify_thread);
    }

  /* cancel the recv notify thread if needed */
  if (vip_vi_ptr->recv_queue.notify_initialized == VIP_TRUE)
    {
      vip_vi_ptr->recv_queue.notify_cancelled = VIP_TRUE;
      VIP_SEMAPHORE_POST (&(vip_vi_ptr->recv_queue.notify_tokens));
      VIP_MUTEX_LOCK (&(vip_nic_ptr->vip_gm_ptr->lock));
      VIP_EVENT_SIGNAL (&(vip_vi_ptr->recv_queue.event));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->vip_gm_ptr->lock));
      VIP_THREAD_JOIN (vip_vi_ptr->recv_queue.notify_thread);
    }

  /* decrease send CQ reference counter if needed */
  if (vip_vi_ptr->send_queue.vip_cq_ptr != NULL)
    {
      VIP_ASSERT (vip_vi_ptr->send_queue.vip_cq_ptr->handle.ref_count > 0);
      vip_vi_ptr->send_queue.vip_cq_ptr->handle.ref_count--;
    }

  /* decrease recv CQ reference counter if needed */
  if (vip_vi_ptr->recv_queue.vip_cq_ptr != NULL)
    {
      VIP_ASSERT (vip_vi_ptr->recv_queue.vip_cq_ptr->handle.ref_count > 0);
      vip_vi_ptr->recv_queue.vip_cq_ptr->handle.ref_count--;
    }

  /* decrease ptag reference counter */
  VIP_ASSERT (vip_vi_ptr->vip_ptag_ptr->handle.ref_count > 0);
  vip_vi_ptr->vip_ptag_ptr->handle.ref_count--;

  /* free the index in the VI ptrs tab and the vi handle itself */
  vip_nic_ptr->vip_vi_ptrs[vip_vi_ptr->index] =
    ((VIP_VI *) ((VIP_UINTPTR) (vip_nic_ptr->vip_vi_index_free)));
  vip_nic_ptr->vip_vi_index_free = vip_vi_ptr->index;
  vip_vi_ptr->index = 0;
  vip_free_handle (&(vip_nic_ptr->vip_vi_set), (VIP_HANDLE *) vip_vi_ptr);

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