vippostsend.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
VipPostSend (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 (("VipPostSend"));

  /* 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->send_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 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 send descriptor */
  if (vip_vi_ptr->send_queue.last != NULL)
    {
      /* there is already some descriptors in the queue */
      VIP_ASSERT (vip_vi_ptr->send_queue.first != NULL);
      VIP_ASSERT (vip_vi_ptr->send_queue.total_count > 1);
      vip_vi_ptr->send_queue.last->CS.Next.Address = DescriptorPtr;
      vip_vi_ptr->send_queue.last->CS.NextHandle = MemoryHandle;
      vip_vi_ptr->send_queue.last = DescriptorPtr;

      if (vip_vi_ptr->send_queue.count_to_process == 0)
        {
          VIP_ASSERT (vip_vi_ptr->send_queue.current_desc == NULL);
          vip_vi_ptr->send_queue.current_desc = DescriptorPtr;
          vip_vi_ptr->send_queue.current_mem = MemoryHandle;
        }
    }
  else
    {
      /* send queue is empty */
      VIP_ASSERT (vip_vi_ptr->send_queue.first == NULL);
      VIP_ASSERT (vip_vi_ptr->send_queue.current_desc == NULL);
      VIP_ASSERT (vip_vi_ptr->send_queue.count_to_process == 0);
      VIP_ASSERT (vip_vi_ptr->send_queue.total_count == 1);
      vip_vi_ptr->send_queue.first = DescriptorPtr;
      vip_vi_ptr->send_queue.last = DescriptorPtr;
      vip_vi_ptr->send_queue.current_desc = DescriptorPtr;
      vip_vi_ptr->send_queue.current_mem = MemoryHandle;
    }

  vip_vi_ptr->send_queue.count_to_process++;

  /* process the send descriptor, if it's the right moment for that */
  if (vip_vi_ptr->send_queue.current_desc == DescriptorPtr)
    {
      vip_process_send_desc (vip_vi_ptr);
    }

  VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
  VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
  VIP_DEBUG (("Success"));
  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;
}