vipconnectwait.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 <stdlib.h>
#include <string.h>

#include "vipl_priv.h"


VIP_ENTRY_POINT VIP_RETURN
VipConnectWait (VIP_NIC_HANDLE NicHandle,
                VIP_NET_ADDRESS * LocalAddr,
                VIP_ULONG Timeout,
                VIP_NET_ADDRESS * RemoteAddr,
                VIP_VI_ATTRIBUTES * RemoteViAttribs,
                VIP_CONN_HANDLE * ConnHandle)
{
  VIP_GM *vip_gm_ptr;
  VIP_NIC *vip_nic_ptr;
  VIP_CONN *vip_conn_ptr;
  VIP_RETURN vip_status;
  VIP_DEBUG_LABEL (("VipConnectWait"));


  if (LocalAddr == NULL)
    {
      VIP_DEBUG (("LocalAddr is NULL"));
      return VIP_INVALID_PARAMETER;
    }

  if (RemoteAddr == NULL)
    {
      VIP_DEBUG (("RemoteAddr is NULL"));
      return VIP_INVALID_PARAMETER;
    }

  if (RemoteViAttribs == NULL)
    {
      VIP_DEBUG (("RemoteViAttribs is NULL"));
      return VIP_INVALID_PARAMETER;
    }

  if (ConnHandle == NULL)
    {
      VIP_DEBUG (("ConnHandle is NULL"));
      return VIP_INVALID_PARAMETER;
    }

  /* check local address (host part) */
  if (LocalAddr->HostAddressLen != VI_GM_MAC_ADDRESS_LEN)
    {
      VIP_DEBUG (("Host Address Length is invalid (should be %d)",
                  VI_GM_MAC_ADDRESS_LEN));
      return VIP_INVALID_PARAMETER;
    }

  /* check local address (discriminator part) */
  if (LocalAddr->DiscriminatorLen > VI_GM_MAX_DISCRIMINATOR_LEN)
    {
      VIP_DEBUG (("Discriminator Length is too large (max=%d)",
                  VI_GM_MAX_DISCRIMINATOR_LEN));
      return VIP_INVALID_PARAMETER;
    }

  /* check timeout */
  if (Timeout == 0)
    {
      VIP_DEBUG (("Timeout 0 immediat return"));
      return VIP_TIMEOUT;
    }

  /* check nic handle */
  vip_nic_ptr = (VIP_NIC *) NicHandle;
  if (VIP_INVALID_NIC_HANDLE (vip_nic_ptr))
    {
      VIP_DEBUG (("Invalid NIC handle"));
      return VIP_INVALID_PARAMETER;
    }

  vip_gm_ptr = 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 NIC address consistency */
  if (memcmp (vip_gm_ptr->mac_address, LocalAddr->HostAddress,
              LocalAddr->HostAddressLen) != 0)
    {
      VIP_DEBUG (("Host Address does not match NIC id"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_INVALID_PARAMETER;
    }

  /* allocate conn handle */
  vip_conn_ptr =
    (VIP_CONN *) vip_allocate_handle (&(vip_nic_ptr->vip_conn_set));
  if (vip_conn_ptr == NULL)
    {
      VIP_DEBUG (("VIP_CONN alloc failed"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_ERROR_RESOURCE;
    }

  vip_conn_ptr->locale_disc_len = LocalAddr->DiscriminatorLen;
  memcpy (vip_conn_ptr->locale_net_addr, LocalAddr->HostAddress,
          VI_GM_MAC_ADDRESS_LEN + LocalAddr->DiscriminatorLen);
  vip_conn_ptr->type = VIP_CONN_TYPE_SERVER;
  vip_conn_ptr->status = VIP_NOT_DONE;
  VIP_EVENT_INIT (&(vip_conn_ptr->event));
  vip_conn_ptr->vip_vi_ptr = NULL;
  vip_conn_ptr->next_waiting_conn_ptr = NULL;

  /* insert connection in the waiting list */
  if (vip_gm_ptr->head_waiting_conn_ptr == NULL)
    {
      VIP_ASSERT (vip_gm_ptr->tail_waiting_conn_ptr == NULL);
      vip_gm_ptr->head_waiting_conn_ptr = vip_conn_ptr;
      vip_gm_ptr->tail_waiting_conn_ptr = vip_conn_ptr;
      vip_conn_ptr->prev_waiting_conn_ptr = NULL;
    }
  else
    {
      VIP_ASSERT (vip_gm_ptr->tail_waiting_conn_ptr != NULL);
      vip_gm_ptr->tail_waiting_conn_ptr->next_waiting_conn_ptr = vip_conn_ptr;
      vip_conn_ptr->prev_waiting_conn_ptr = vip_gm_ptr->tail_waiting_conn_ptr;
      vip_gm_ptr->tail_waiting_conn_ptr = vip_conn_ptr;
    }
  vip_conn_ptr->waiting_list = VIP_TRUE;

  /* blocks */
  VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
  vip_status = vip_wait_for_notification (Timeout,
                                          (VIP_HANDLE *) vip_conn_ptr,
                                          &(vip_conn_ptr->event),
                                          vip_is_conn_notified, vip_conn_ptr);
  VIP_MUTEX_LOCK (&(vip_nic_ptr->lock));

  /* check return code of blocking wait */
  switch (vip_status)
    {
    case VIP_SUCCESS:
      VIP_ASSERT (vip_conn_ptr->status == VIP_SUCCESS);
      RemoteAddr->HostAddressLen = VI_GM_MAC_ADDRESS_LEN;
      RemoteAddr->DiscriminatorLen = vip_conn_ptr->remote_disc_len;
      memcpy (RemoteAddr->HostAddress, vip_conn_ptr->remote_net_addr,
              VI_GM_MAC_ADDRESS_LEN + vip_conn_ptr->remote_disc_len);
      *RemoteViAttribs = vip_conn_ptr->remote_vi_attribs;
      *ConnHandle = (VIP_CONN_HANDLE) vip_conn_ptr;
      VIP_DEBUG (("Success"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_SUCCESS;

    case VIP_INVALID_PARAMETER:
      vip_remove_conn_waiting_list (vip_gm_ptr, vip_conn_ptr);
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_INVALID_PARAMETER;

    case VIP_TIMEOUT:
      /* timeout and no connection established */
      VIP_ASSERT (vip_conn_ptr->status == VIP_NOT_DONE);
      vip_remove_conn_waiting_list (vip_gm_ptr, vip_conn_ptr);
      vip_free_handle (&(vip_nic_ptr->vip_conn_set),
                       (VIP_HANDLE *) vip_conn_ptr);
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      *ConnHandle = NULL;
      return VIP_TIMEOUT;

    default:
      VIP_ABORT (("Blocking wait return code is invalid"));
    }

  VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
  VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
  return vip_status;
}