src/noarch/communication/moc_wait.c

Go to the documentation of this file.

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

int MOC_Wait(MOC_Request *request, MOC_Status *status)
    {
    int err;
    if (request == 0)
        {
        return MOC_ERR_REQUEST;
        }

    switch (request->request_type)
        {
    case MOC_REQ_TYPE_DMA:
        if (0 != (err = IMOC_wait_dma(&request->request_data.dma_data)))
            return err;
        if (status != 0)
            {
            status->message_size = request->request_data.dma_data.size;
            status->MOC_ERROR = 0;
            status->MOC_TAG = 0;
            status->MOC_SOURCE = node_handle.rank;
            }
        return 0;
    case MOC_REQ_TYPE_ISSEND:
        if (!request->request_data.issend_request.isFinished)
            {
            IMOC_waitForMessageCompletion(
                    request->request_data.issend_request.mid);
            node_handle.status_array_base[request->request_data.issend_request.mid].flags.value
                    = 0;
            request->request_data.issend_request.isFinished = 1;
            status->MOC_ERROR = 0;
            status->MOC_SOURCE = request->request_data.issend_request.source;
            status->MOC_TAG = request->request_data.issend_request.tag;
            status->message_size
                    = request->request_data.issend_request.message_size;
            }
        return 0;
    default:
        return MOC_ERR_REQUEST;
        }

    }

---