vippostrecv.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
VipPostRecv (VIP_VI_HANDLE ViHandle,
             VIP_DESCRIPTOR * DescriptorPtr, VIP_MEM_HANDLE MemoryHandle)
{
  VIP_VI *vip_vi_ptr;
  VIP_GM *vip_gm_ptr;
  VIP_NIC *vip_nic_ptr;
  VIP_UINT32 vip_vi_ptag_id;
  VIP_DEBUG_LABEL (("VipPostRecv"));

  /* 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_nic_ptr->vip_gm_ptr;
  VIP_MUTEX_LOCK (&(vip_gm_ptr->lock));
  VIP_MUTEX_LOCK (&(vip_nic_ptr->lock));

  vip_vi_ptr->recv_queue.total_count++;

  /* check descriptor */
  if (DescriptorPtr == NULL)
    {
      VIP_DEBUG (("Descriptor is NULL"));
      goto async_post_desc_error;
    }

  /* check VI PTAG handle */
  if (VIP_INVALID_PTAG_HANDLE (vip_vi_ptr->vip_ptag_ptr))
    {
      VIP_DEBUG (("Invalid VI PTAG handle"));
      goto async_post_desc_error;
    }
  vip_vi_ptag_id = vip_vi_ptr->vip_ptag_ptr->id;

  /* check that the descriptor is aligned on a 64 Bytes boundary */
  if ((((VIP_UINTPTR) DescriptorPtr) & 0x3F) != 0)
    {
      VIP_DEBUG (("Descriptor is not aligned on a 64 Bytes boundary"));
      goto async_post_desc_error;
    }

  /* check MemoryHandle */
  if (vip_check_memory_handle (vip_nic_ptr, MemoryHandle,
                               (VIP_UINT64) ((VIP_UINTPTR) DescriptorPtr),
                               sizeof (VIP_CONTROL_SEGMENT),
                               vip_vi_ptag_id) != VIP_SUCCESS)
    {
      VIP_DEBUG (("Control segment Memory Handle check error"));
      goto async_post_desc_error;
    }

  DescriptorPtr->CS.Next.AddressBits = 0;
  DescriptorPtr->CS.NextHandle = 0;
  DescriptorPtr->CS.Status = 0;

  /* queue the recv descriptor */
  if (vip_vi_ptr->recv_queue.last != NULL)
    {
      /* there is already some descriptors in the queue */
      VIP_ASSERT (vip_vi_ptr->recv_queue.first != NULL);
      VIP_ASSERT (vip_vi_ptr->recv_queue.total_count > 1);
      vip_vi_ptr->recv_queue.last->CS.Next.Address = DescriptorPtr;
      vip_vi_ptr->recv_queue.last->CS.NextHandle = MemoryHandle;
      vip_vi_ptr->recv_queue.last = DescriptorPtr;
      if (vip_vi_ptr->recv_queue.count_to_process == 0)
        {
          VIP_ASSERT (vip_vi_ptr->recv_queue.current_desc == NULL);
          vip_vi_ptr->recv_queue.current_desc = DescriptorPtr;
          vip_vi_ptr->recv_queue.current_mem = MemoryHandle;
        }
    }
  else
    {
      VIP_ASSERT (vip_vi_ptr->recv_queue.first == NULL);
      VIP_ASSERT (vip_vi_ptr->recv_queue.current_desc == NULL);
      VIP_ASSERT (vip_vi_ptr->recv_queue.count_to_process == 0);
      VIP_ASSERT (vip_vi_ptr->recv_queue.total_count == 1);
      vip_vi_ptr->recv_queue.first = DescriptorPtr;
      vip_vi_ptr->recv_queue.last = DescriptorPtr;
      vip_vi_ptr->recv_queue.current_desc = DescriptorPtr;
      vip_vi_ptr->recv_queue.current_mem = MemoryHandle;
    }
  vip_vi_ptr->recv_queue.count_to_process++;

  /* check VI state immediately */
  if (vip_vi_ptr->state == VIP_STATE_ERROR)
    {
      VIP_DEBUG (("VI is in error state"));

      /* complete the current descriptor */
      DescriptorPtr->CS.Status |= VIP_STATUS_DESC_FLUSHED_ERROR;
      VIP_ASSERT (vip_vi_ptr->recv_queue.count_to_process == 1);
      vip_notify_desc_completion (DescriptorPtr, vip_vi_ptr, VIP_TRUE);
      vip_vi_ptr->recv_queue.current_desc = NULL;
      vip_vi_ptr->recv_queue.current_mem = 0;
      vip_vi_ptr->recv_queue.count_to_process = 0;
    }

  VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
  VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
  return VIP_SUCCESS;

async_post_desc_error:
  /* generate the asynchronous error */
  vip_generate_async_error (vip_nic_ptr, vip_vi_ptr, NULL, DescriptorPtr,
                            VIP_RESOURCE_DESCRIPTOR, VIP_ERROR_POST_DESC, 0);

  if (vip_vi_ptr->state != VIP_STATE_ERROR)
    {
      /* the VI transition to error state */
      vip_vi_transition_to_error_state (vip_vi_ptr, VIP_TRUE);

      /* a connection lost asynchronous error is generated */
      vip_generate_async_error (vip_nic_ptr, vip_vi_ptr, NULL, NULL,
                                VIP_RESOURCE_VI, VIP_ERROR_CONN_LOST, 0);
    }

  VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
  VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
  VIP_DEBUG (("Post Descriptor error"));
  return VIP_SUCCESS;
}