src/spu/system/moc_init_spu.c

Go to the documentation of this file.

#include <stdlib.h>
#include <string.h>
#include <malloc_align.h>
#include <free_align.h>
#include <stdio.h>
#include <spu_mfcio.h>

#include <internal/spu/imoc_core_spu.h>
#include <internal/imoc.h>
#include <spu/moc.h>

int MOC_Init(unsigned long long argp __attribute__((unused)), int length __attribute__((unused)), void* buffer __attribute__((unused)) )
    {
    char temp[24];
    uint32_t tag_id;
    /* wait till four messages from PPU are received */
    while (spu_stat_in_mbox() < 4)
        ;
    /* read messages */
    *((uint32_t*) &temp[0]) = spu_read_in_mbox();
    *((uint32_t*) &temp[4]) = spu_read_in_mbox();
    *((uint32_t*) &temp[8]) = spu_read_in_mbox();
    *((uint32_t*) &temp[12]) = spu_read_in_mbox();
    /* wait till two messages from PPU are received */
    while (spu_stat_in_mbox() < 2)
        ;
    /* read messages */
    *((uint32_t*) &temp[16]) = spu_read_in_mbox();
    *((uint32_t*) &temp[20]) = spu_read_in_mbox();
    /* create own node-handle and data-structures */
    node_handle.rank = temp[0];
    node_handle.comm_size = temp[1];
    node_handle.queue_size = temp[2];
    node_handle.buffer_size = *((uint32_t*) &temp[4]);
    node_handle.buffer_base = *((uint64_t*) &temp[8]);
    node_handle.ls_base = *((uint64_t*) &temp[16]);
    node_handle.message_queue_base = _malloc_align(
            sizeof(moc_message_envelope_t) * (node_handle.comm_size - 1)
                    * node_handle.queue_size, 4);
    if (node_handle.message_queue_base == 0)
        return MOC_ERR_NO_MEMORY;
    node_handle.status_array_base = _malloc_align(sizeof(moc_message_status_t)
            * (node_handle.comm_size - 1) * node_handle.queue_size, 4);
    if (node_handle.status_array_base == 0)
        return MOC_ERR_NO_MEMORY;
    /* send memory addresses of message-queue and status-array to PPU */
    spu_write_out_mbox((uint32_t) node_handle.message_queue_base);
    spu_write_out_mbox((uint32_t) node_handle.status_array_base);
    /* allocate space for process-list */
    node_handle.moc_process_list = _malloc_align(sizeof(moc_process_t)
            * node_handle.comm_size, 4);
    if (node_handle.moc_process_list == 0)
        return MOC_ERR_NO_MEMORY;
    /* receive memory-address of prozess-list in main-memory from PPU */
    while (spu_stat_in_mbox() < 2)
        ;
    *((uint32_t*) &temp[0]) = spu_read_in_mbox();
    *((uint32_t*) &temp[4]) = spu_read_in_mbox();
    /* get process-list from main-memory via DMA */
    if ((tag_id = mfc_tag_reserve()) == MFC_TAG_INVALID)
        return MOC_ERR_INTERN;
    mfc_get((void*) node_handle.moc_process_list, *((uint64_t*) &temp[0]),
            sizeof(moc_process_t) * node_handle.comm_size, tag_id, 0, 0);
    mfc_write_tag_mask(1 << tag_id);
    mfc_read_tag_status_all();
    mfc_tag_release(tag_id);
    return 0;
    }

---