vipconnectpeerwait.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 "vipl_priv.h"


VIP_ENTRY_POINT VIP_RETURN
VipConnectPeerWait (VIP_VI_HANDLE ViHandle,
                    VIP_VI_ATTRIBUTES * RemoteViAttribs)
{
  VIP_GM *vip_gm_ptr;
  VIP_VI *vip_vi_ptr;
  VIP_NIC *vip_nic_ptr;
  VIP_CONN *vip_conn_ptr;
  VIP_RETURN vip_status;
  VIP_DEBUG_LABEL (("VipConnectPeerWait"));

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

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

  /* check VI state */
  if (vip_vi_ptr->state != VIP_STATE_CONNECT_PENDING)
    {
      VIP_DEBUG (("VI is not in CONNECT_PENDING state"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_INVALID_STATE;
    }

  /* check if connection has been initiated */
  if (vip_vi_ptr->conn_ptr == NULL)
    {
      VIP_DEBUG (("VI is not engaged in a connection"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_INVALID_PARAMETER;
    }

  /* check conn handle */
  vip_conn_ptr = vip_vi_ptr->conn_ptr;
  if (VIP_INVALID_CONN_HANDLE (vip_conn_ptr))
    {
      VIP_DEBUG (("Invalid Peer CONN handle in VI"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_INVALID_PARAMETER;
    }

  /* check if connection is a peer connection */
  if (vip_conn_ptr->type != VIP_CONN_TYPE_PEER)
    {
      VIP_DEBUG (("VI is not engaged in a PEER connection"));
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
      return VIP_INVALID_PARAMETER;
    }

  if (vip_conn_ptr->status == VIP_NOT_DONE)
    {
      /* blocks */
      VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
      vip_status = vip_wait_for_notification (VIP_INFINITE,
                                              (VIP_HANDLE *) vip_conn_ptr,
                                              &(vip_conn_ptr->event),
                                              vip_is_conn_notified,
                                              vip_conn_ptr);
      VIP_MUTEX_LOCK (&(vip_nic_ptr->lock));

      if (vip_status == VIP_INVALID_PARAMETER)
        {
          if (vip_conn_ptr->status != VIP_TIMEOUT)
            {
              gm_cancel_alarm (&(vip_conn_ptr->peer_timeout_alarm));
              vip_remove_conn_waiting_list (vip_nic_ptr->vip_gm_ptr,
                                            vip_conn_ptr);
              VIP_MUTEX_UNLOCK (&(vip_nic_ptr->lock));
              VIP_MUTEX_UNLOCK (&(vip_gm_ptr->lock));
              return VIP_INVALID_PARAMETER;
            }
        }

      VIP_ASSERT (vip_status == VIP_SUCCESS);
    }

  vip_status = vip_conn_ptr->status;
  switch (vip_status)
    {
    case VIP_NOT_DONE:
      VIP_ABORT (("Should never get a VIP_NOT_DONE after blocking"));

    case VIP_SUCCESS:
      /* connection established */
      vip_vi_ptr->state = VIP_STATE_CONNECTED;
      *RemoteViAttribs = vip_conn_ptr->remote_vi_attribs;
      VIP_DEBUG (("Success"));
      break;

    case VIP_INVALID_RELIABILITY_LEVEL:
      vip_vi_ptr->state = VIP_STATE_IDLE;
      VIP_DEBUG (("Invalid Reliability level"));
      break;

    case VIP_INVALID_MTU:
      vip_vi_ptr->state = VIP_STATE_IDLE;
      VIP_DEBUG (("Invalid MTU"));
      break;

    case VIP_INVALID_QOS:
      vip_vi_ptr->state = VIP_STATE_IDLE;
      VIP_DEBUG (("Invalid QoS"));
      break;

    case VIP_TIMEOUT:
      vip_vi_ptr->state = VIP_STATE_IDLE;
      VIP_DEBUG (("Connection Timeout"));
      break;

    default:
      VIP_ABORT (("Invalid status in Peer connection"));
    }

  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));
  return vip_status;
}