vipsendnotify.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
VipSendNotify (VIP_VI_HANDLE ViHandle,
               VIP_PVOID Context,
               void (*Handler) (VIP_PVOID Context,
                                VIP_NIC_HANDLE NicHandle,
                                VIP_VI_HANDLE ViHandle,
                                VIP_DESCRIPTOR * DescriptorPtr))
{
  VIP_GM *vip_gm_ptr;
  VIP_VI *vip_vi_ptr;
  VIP_NIC *vip_nic_ptr;
  VIP_NOTIFY *vip_notify_ptr;
  VIP_VI_QUEUE *vip_vi_queue_ptr;
  VIP_DEBUG_LABEL (("VipSendNotify"));

  /* 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;
    }

  /* check Handler address */
  if (Handler == NULL)
    {
      VIP_DEBUG (("Notify handler is null"));
      return VIP_INVALID_PARAMETER;
    }

  vip_nic_ptr = vip_vi_ptr->handle.vip_nic_ptr;
  vip_gm_ptr = vip_nic_ptr->vip_gm_ptr;
  vip_vi_queue_ptr = &(vip_vi_ptr->send_queue);
  VIP_MUTEX_LOCK (&(vip_gm_ptr->lock));
  VIP_PROGRESSION (vip_gm_ptr);
  VIP_MUTEX_LOCK (&(vip_nic_ptr->lock));

  /* check if send queue associated with completion queue */
  if (vip_vi_queue_ptr->vip_cq_ptr != NULL)
    {
      VIP_DEBUG (("VI send queue is associated with a completion queue"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_ERROR_RESOURCE;
    }

  /* check if send queue empty */
  if (vip_vi_queue_ptr->total_count == 0)
    {
      VIP_DEBUG (("VI send queue is empty"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_DESCRIPTOR_ERROR;
    }

  /* create the notify thread if needed */
  if (vip_vi_queue_ptr->notify_initialized == VIP_FALSE)
    {
      if (VIP_THREAD_CREATE (&(vip_vi_queue_ptr->notify_thread),
                             vip_send_notify_thread, vip_vi_ptr) != 0)
        {
          VIP_DEBUG (("Unable to spawn send notify thread"));
          VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
          VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
          return VIP_ERROR_RESOURCE;
        }

      vip_vi_queue_ptr->notify_initialized = VIP_TRUE;
    }

  /* alloc a notify handle */
  vip_notify_ptr =
    (VIP_NOTIFY *) gm_lookaside_alloc (vip_gm_ptr->notify_lookaside);
  if (vip_notify_ptr == NULL)
    {
      VIP_DEBUG (("Error allocating notify handler"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_ERROR_RESOURCE;
    }

  /* fill the notify handle */
  vip_notify_ptr->handler = Handler;
  vip_notify_ptr->context = Context;
  vip_notify_ptr->next = NULL;

  /* insert it in the pending list */
  if (vip_vi_queue_ptr->first_notify_handler == NULL)
    {
      VIP_ASSERT (vip_vi_queue_ptr->last_notify_handler == NULL);
      vip_vi_queue_ptr->first_notify_handler = vip_notify_ptr;
      vip_vi_queue_ptr->last_notify_handler = vip_notify_ptr;
    }
  else
    {
      VIP_ASSERT (vip_vi_queue_ptr->last_notify_handler != NULL);
      vip_vi_queue_ptr->last_notify_handler->next = vip_notify_ptr;
      vip_vi_queue_ptr->last_notify_handler = vip_notify_ptr;
    }

  /* acknoledge the new notify handler by giving a token to the thread. */
  VIP_SEMAPHORE_POST (&(vip_vi_queue_ptr->notify_tokens));

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