src/noarch/communication/moc_isend.c

Go to the documentation of this file.

#include <stdio.h>
#include <string.h>

#include <moc.h>
#include <internal/imoc.h>
#ifdef __SPU__
#include <spu/moc_datatype_spu.h>
#include <internal/spu/imoc_core_spu.h>
#include <internal/spu/imoc_dma_spu.h>
#include <internal/imoc_macros.h>
#else
#include <ppu/moc_datatype_ppu.h>
#include <internal/ppu/imoc_core_ppu.h>
#include <internal/ppu/imoc_dma_ppu.h>
#include <internal/ppu/imoc_macros_ppu.h>
#endif

int MOC_ISend(void* buf, int count, MOC_Datatype datatype, int dest, int tag,
        MOC_Comm comm, MOC_Request *request)
    {
    int bytecount;

    if (((datatype & 0xF0) >> 4) == 0)
        bytecount = count;
    else
        bytecount = count * (((datatype & 0xF0) >> 4) * 2);

    /** byte-count <= 4096 ==> buffered send **/
    if (bytecount <= MOC_SEND_TRESHOLD)
        {
        uint32_t err = MOC_Bsend(buf, count, datatype, dest, tag, comm);
        if (!err)
            {
            request->request_type = MOC_REQ_TYPE_ISSEND;
            request->request_data.issend_request.isFinished = 1;
            request->request_data.issend_request.source = node_handle.rank;
            request->request_data.issend_request.tag = tag;
            request->request_data.issend_request.message_size = bytecount;
            }
        else
            {
            request->request_data.issend_request.isFinished = 1;
            return err;
            }
        }
    /** other ==> true non-blocking send **/
    else
        {
        return MOC_ISsend(buf, count, datatype, dest, tag, comm, request);
        }

    return 0;
    }

---