ib_post_read.c

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

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

#ifdef WITH_METHOD_IB

int ib_post_read(MPIDI_VC *vc_ptr, MM_Car *car_ptr)
{
    MPIDI_STATE_DECL(MPID_STATE_IB_POST_READ);
    MPIDI_FUNC_ENTER(MPID_STATE_IB_POST_READ);

    MPIU_dbg_printf("ib_post_read\n");
    ib_car_enqueue_read(vc_ptr, car_ptr);

    MPIDI_FUNC_EXIT(MPID_STATE_IB_POST_READ);
    return MPI_SUCCESS;
}

int ib_post_read_pkt(MPIDI_VC *vc_ptr)
{
    /*int result;*/
    MPIDI_STATE_DECL(MPID_STATE_IB_POST_READ_PKT);
    MPIDI_FUNC_ENTER(MPID_STATE_IB_POST_READ_PKT);

    vc_ptr->data.ib.reading_header = TRUE;
    /*
    result = ibu_post_receive(vc_ptr);
    if (result != MPI_SUCCESS)
    {
	err_printf("ib_post_read_pkt: unable to post a read packet.\n");
    }
    */

    MPIDI_FUNC_EXIT(MPID_STATE_IB_POST_READ_PKT);
    return MPI_SUCCESS;
}

static void PrintHeader(MPID_Header_pkt *p)
{
    char *type;
    /*
    MPIU_dbg_printf("Header Packet:\n");
    MPIU_dbg_printf(" context: %d\n", p->context);
    MPIU_dbg_printf(" sender_car_ptr: 0x%x\n", p->sender_car_ptr);
    MPIU_dbg_printf(" size: %d\n", p->size);
    MPIU_dbg_printf(" src: %d\n", p->src);
    MPIU_dbg_printf(" tag: %d\n", p->tag);
    MPIU_dbg_printf(" type: %d\n", p->type);
    */

    switch (p->type)
    {
    case MPID_INVALID_PKT:
	type = "MPID_INVALID_PKT";
	break;
    case MPID_EAGER_PKT:
	type = "MPID_EAGER_PKT";
	break;
    case MPID_RNDV_REQUEST_TO_SEND_PKT:
	type = "MPID_RNDV_REQUEST_TO_SEND_PKT";
	break;
    case MPID_RNDV_CLEAR_TO_SEND_PKT:
	type = "MPID_RNDV_CLEAR_TO_SEND_PKT";
	break;
    case MPID_RNDV_DATA_PKT:
	type = "MPID_RNDV_DATA_PKT";
	break;
    case MPID_RDMA_ACK_PKT:
	type = "MPID_RDMA_ACK_PKT";
	break;
    case MPID_RDMA_DATA_ACK_PKT:
	type = "MPID_RDMA_DATA_ACK_PKT";
	break;
    case MPID_RDMA_REQUEST_DATA_ACK_PKT:
	type = "MPID_RDMA_REQUEST_DATA_ACK_PKT";
	break;
    case MPID_CONTEXT_PKT:
	type = "MPID_CONTEXT_PKT";
	break;
    case MPID_ACK_PKT:
	type = "MPID_ACK_PKT";
	break;
    default:
	type = "unknown";
	break;
    }

    MPIU_dbg_printf("Header Packet: %s, src %d, tag %d, size %d, ctx %d, car 0x%x\n", 
	type, p->src, p->tag, p->size, p->context, p->sender_car_ptr);
}

int ib_handle_read(MPIDI_VC *vc_ptr, void *mem_ptr, int num_bytes)
{
    MPIDI_STATE_DECL(MPID_STATE_IB_HANDLE_READ);
    MPIDI_FUNC_ENTER(MPID_STATE_IB_HANDLE_READ);

    if (vc_ptr == NULL)
    {
	MPIDI_FUNC_EXIT(MPID_STATE_IB_HANDLE_READ);
	return MPI_SUCCESS;
    }

    if (vc_ptr->data.ib.reading_header)
    {
	MPIU_dbg_printf("ib_handle_read() received header - %d bytes\n", num_bytes);
	memcpy(&vc_ptr->pkt_car.msg_header.pkt.u.hdr, mem_ptr, num_bytes);
	/*BlockFree(vc_ptr->data.ib.info.m_allocator, mem_ptr);*/
	PrintHeader(&vc_ptr->pkt_car.msg_header.pkt.u.hdr);
	mm_cq_enqueue(&vc_ptr->pkt_car);
	MPIDI_FUNC_EXIT(MPID_STATE_SOCKET_HANDLE_READ);
	return MPI_SUCCESS;
    }

    MPIU_dbg_printf("ib_handle_read() received data - %d bytes\n", num_bytes);
    ib_handle_read_data(vc_ptr, mem_ptr, num_bytes);
    /*BlockFree(vc_ptr->data.ib.info.m_allocator, mem_ptr);*/

    MPIDI_FUNC_EXIT(MPID_STATE_IB_HANDLE_READ);
    return -1;
}

#endif