src/ppu/internal/imoc_spe_thread_ppu.c

Go to the documentation of this file.

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

#include <moc.h>
#include <ppu/moc.h>
#include <internal/imoc.h>
#include <internal/ppu/imoc_core_ppu.h>

/**
 * \addtogroup internal_spu_thread
 **/
//@{

/**
 * Holds the value of currently configured SPU-Threads.
 **/
uint8_t moc_spu_thread_count = 0;

/**
 * Holds the value of currently configured PPU-Threads.
 **/
uint8_t moc_ppu_thread_count = 0;

/**
 * Holds information about the SPU-Threads.
 *
 * order of indices is equal to order of ranks.
 **/
moc_spu_thread_t moc_spu_thread_list[MOC_SPU_THREAD_MAX];

uint32_t moc_spu_buffer_size = MOC_BUFFER_SIZE;

uint8_t moc_spu_queue_size = MOC_QUEUE_SIZE;

void* moc_spe_pthread_func(void *arg)
    {
    moc_spu_thread_t* handle = (moc_spu_thread_t*) arg;
    /* run the SPE context */
    if (spe_cpu_info_get(SPE_COUNT_USABLE_SPES, -1) != 0)
        {
        if (spe_context_run(handle->speid, &handle->spe_entry_adress, 0,
                handle->argp, handle->envp, &handle->stop_info) < 0)
            {
            fprintf(
                    stderr,
                    "FAILED Thread %u: spe_context_run(errno=%d strerror=%s)\n",
                    handle->rank, errno, strerror(errno));
            pthread_exit(NULL);
            }
        }
    else
        {
        fprintf(stderr, "ERROR Thread %u: No usable SPE\n", handle->rank);
        }
    /* destroy the SPE context */
    if (spe_context_destroy(handle->speid) != 0)
        {
        fprintf(
                stderr,
                "FAILED Thread %u: spe_context_destroy(errno=%d strerror=%s)\n",
                handle->rank, errno, strerror(errno));
        pthread_exit(NULL);
        }
    /* check the SPE status */
    if (handle->stop_info.stop_reason == SPE_EXIT)
        {
        if (handle->stop_info.result.spe_exit_code != 0)
            {
            fprintf(
                    stderr,
                    "FAILED Thread %u: SPE returned a non-zero exit status (%i)\n",
                    handle->rank, handle->stop_info.result.spe_exit_code);
            }
        }
    else
        if (handle->stop_info.stop_reason == SPE_STOP_AND_SIGNAL)
            {
            fprintf(
                    stderr,
                    " FAILED Thread %u: SPE Stop and Signal (Signalcode: %i)\n",
                    handle->rank, handle->stop_info.result.spe_signal_code);
            }
        else
            {
            fprintf(
                    stderr,
                    " FAILED Thread %u: SPE abnormally terminated (Reason: %i)\n",
                    handle->rank, handle->stop_info.stop_reason);
            }
    pthread_exit(NULL);
    }
//@}

---