viprecvdone.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
VipRecvDone (VIP_VI_HANDLE ViHandle, VIP_DESCRIPTOR ** DescriptorPtr)
{
  VIP_VI *vip_vi_ptr;
  VIP_GM *vip_gm_ptr;
  VIP_NIC *vip_nic_ptr;
  VIP_DEBUG_LABEL (("VipRecvDone"));

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

  /* check if recv queue empty */
  if (vip_vi_ptr->recv_queue.total_count == 0)
    {
      VIP_DEBUG (("VI recv queue is empty"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      *DescriptorPtr = NULL;
      return VIP_DESCRIPTOR_ERROR;
    }

  /* check if recv descriptor is NULL */
  if (vip_vi_ptr->recv_queue.first == NULL)
    {
      VIP_ASSERT (vip_vi_ptr->recv_queue.total_count > 0);
      vip_vi_ptr->recv_queue.total_count--;
      VIP_DEBUG (("Recv Descriptor was NULL"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      *DescriptorPtr = NULL;
      return VIP_DESCRIPTOR_ERROR;
    }

  /* check if descriptor is complete */
  if ((vip_vi_ptr->recv_queue.first->CS.Status & VIP_STATUS_DONE) == 0)
    {
      VIP_DEBUG (("Descriptor is not complete"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      *DescriptorPtr = NULL;
      return VIP_NOT_DONE;
    }

  /* dequeue the descriptor */
  *DescriptorPtr = vip_vi_ptr->recv_queue.first;
  VIP_ASSERT (vip_vi_ptr->recv_queue.total_count > 0);
  vip_vi_ptr->recv_queue.total_count--;
  vip_vi_ptr->recv_queue.first = (*DescriptorPtr)->CS.Next.Address;
  if (vip_vi_ptr->recv_queue.first == NULL)
    {
      VIP_ASSERT (vip_vi_ptr->recv_queue.last == *DescriptorPtr);
      vip_vi_ptr->recv_queue.last = NULL;
    }

  /* check if error code in status */
  if (((*DescriptorPtr)->CS.Status & VIP_STATUS_ERROR_MASK) != 0)
    {
      VIP_DEBUG (("Descriptor completed with error status"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_DESCRIPTOR_ERROR;
    }

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