mpidi_ch3_impl.h

刚才是说明 现在是安装程序在 LINUX环境下进行编程的MPICH安装文件

/* -*- Mode: C; c-basic-offset:4 ; -*- */
/*
 *  (C) 2001 by Argonne National Laboratory.
 *      See COPYRIGHT in top-level directory.
 */

#if !defined(MPICH_MPIDI_CH3_IMPL_H_INCLUDED)
#define MPICH_MPIDI_CH3_IMPL_H_INCLUDED

#include "mpidi_ch3i_tcp_conf.h"
#include "mpidimpl.h"

#include <unistd.h>
#include <stdlib.h>
#include <assert.h>

#include <sys/param.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <fcntl.h>
#include <errno.h>

/* This value is defined in sys/param.h under Linux but in netdb.h 
   under Solaris */
#ifndef MAXHOSTNAMELEN
#define MAXHOSTNAMELEN 256
#endif
typedef struct MPIDI_CH3I_Process_s
{
    MPIDI_CH3I_Process_group_t * pg;
}
MPIDI_CH3I_Process_t;

extern MPIDI_CH3I_Process_t MPIDI_CH3I_Process;

#define MPIDI_CH3I_SendQ_enqueue(vc, req)				\
{									\
    /* MT - not thread safe! */						\
    MPIDI_DBG_PRINTF((50, FCNAME, "SendQ_enqueue vc=0x%08x req=0x%08x",	\
	              (unsigned long) vc, req->handle));		\
    req->ch3.next = NULL;						\
    if (vc->tcp.sendq_tail != NULL)					\
    {									\
	vc->tcp.sendq_tail->ch3.next = req;				\
    }									\
    else								\
    {									\
	vc->tcp.sendq_head = req;					\
    }									\
    vc->tcp.sendq_tail = req;						\
}

#define MPIDI_CH3I_SendQ_enqueue_head(vc, req)				     \
{									     \
    /* MT - not thread safe! */						     \
    MPIDI_DBG_PRINTF((50, FCNAME, "SendQ_enqueue_head vc=0x%08x req=0x%08x", \
	              (unsigned long) vc, req->handle));		     \
    req->ch3.next = vc->tcp.sendq_tail;					     \
    if (vc->tcp.sendq_tail == NULL)					     \
    {									     \
	vc->tcp.sendq_tail = req;					     \
    }									     \
    vc->tcp.sendq_head = req;						     \
}

#define MPIDI_CH3I_SendQ_dequeue(vc)					\
{									\
    /* MT - not thread safe! */						\
    MPIDI_DBG_PRINTF((50, FCNAME, "SendQ_dequeue vc=0x%08x req=0x%08x",	\
	              (unsigned long) vc, vc->tcp.sendq_head));		\
    vc->tcp.sendq_head = vc->tcp.sendq_head->ch3.next;			\
    if (vc->tcp.sendq_head == NULL)					\
    {									\
	vc->tcp.sendq_tail = NULL;					\
    }									\
}

#define MPIDI_CH3I_SendQ_head(vc) (vc->tcp.sendq_head)

#define MPIDI_CH3I_SendQ_empty(vc) (vc->tcp.sendq_head == NULL)


int MPIDI_CH3I_Progress_init(void);
int MPIDI_CH3I_Progress_finalize(void);
short MPIDI_CH3I_Listener_get_port(void);
int MPIDI_CH3I_TCP_post_connect(MPIDI_VC *);
void MPIDI_CH3I_TCP_post_read(MPIDI_VC *, MPID_Request *);
void MPIDI_CH3I_TCP_post_write(MPIDI_VC *, MPID_Request *);
int MPIDI_CH3I_Request_adjust_iov(MPID_Request *, MPIDI_msg_sz_t);

#endif /* !defined(MPICH_MPIDI_CH3_IMPL_H_INCLUDED) */