mcinternal.h

Go to the documentation of this file.

/*
 * Copyright (c) 2012 by Albert-Jan N. Yzelman
 *
 * This file is part of MulticoreBSP in C --
 *        a port of the original Java-based MulticoreBSP.
 *
 * MulticoreBSP for C is distributed as part of the original
 * MulticoreBSP and is free software: you can redistribute
 * it and/or modify it under the terms of the GNU Lesser 
 * General Public License as published by the Free Software 
 * Foundation, either version 3 of the License, or 
 * (at your option) any later version.
 * MulticoreBSP is distributed in the hope that it will be
 * useful, but WITHOUT ANY WARRANTY; without even the 
 * implied warranty of MERCHANTABILITY or FITNESS FOR A 
 * PARTICULAR PURPOSE. See the GNU Lesser General Public 
 * License for more details.
 *
 * You should have received a copy of the GNU Lesser General 
 * Public License along with MulticoreBSP. If not, see
 * <http://www.gnu.org/licenses/>.
 */

#ifndef _H_MCINTERNAL
#define _H_MCINTERNAL

#include "mcbsp-internal.h"
#include "mcutil.h"

#include <stdio.h>
#include <errno.h>
#include <stdlib.h>
#include <assert.h>
#include <pthread.h>
#include <stdbool.h>

#ifdef __MACH__
 #include <mach/mach.h>
 #include <mach/clock.h>
 #include <mach/mach_error.h>
#endif

#ifdef _WIN32
 #include <windows.h>
#endif

struct mcbsp_init_data {

        void (*spmd)(void);

        void *bsp_program;

        int argc;

        char **argv;

        pthread_t *threads;

        MCBSP_PROCESSOR_INDEX_DATATYPE P;

        volatile bool abort;

        bool ended;

        MCBSP_PROCESSOR_INDEX_DATATYPE sync_entry_counter;

        MCBSP_PROCESSOR_INDEX_DATATYPE sync_exit_counter;

        pthread_mutex_t mutex;

#ifdef MCBSP_USE_SPINLOCK

        unsigned char * condition;

        unsigned char * mid_condition;
#else

        pthread_cond_t condition;

        pthread_cond_t mid_condition;
#endif

        struct mcbsp_util_address_table global2local;

        struct mcbsp_thread_data **threadData;

        struct mcbsp_thread_data *prev_data;

        size_t tagSize;

};

struct mcbsp_thread_data {

        struct mcbsp_init_data *init;

        MCBSP_PROCESSOR_INDEX_DATATYPE bsp_id;

#ifdef __MACH__

        clock_serv_t clock;

        mach_timespec_t start;
#elif _WIN32

        LARGE_INTEGER start;

        LARGE_INTEGER frequency;
#else

        struct timespec start;
#endif

        struct mcbsp_util_address_map local2global;

        unsigned long int localC;

        struct mcbsp_util_stack removedGlobals;

        struct mcbsp_util_stack localsToRemove;

        struct mcbsp_util_stack * request_queues;

        struct mcbsp_util_stack * queues;

        struct mcbsp_util_stack * hpsend_queues;

        size_t newTagSize;

        struct mcbsp_util_stack bsmp;

        struct mcbsp_util_stack localsToPush;

        struct mcbsp_util_stack globalsToPush;

};

struct mcbsp_get_request {

        void * source;

        void * destination;

        size_t length;

};

struct mcbsp_message {
        
        void * destination;

        size_t length;

};

struct mcbsp_hpsend_request {

        const void * payload;

        const void * tag;

        size_t payload_size;

};

struct mcbsp_push_request {

        void * address;

        MCBSP_BYTESIZE_TYPE size;

};

extern pthread_key_t mcbsp_internal_init_data;

extern pthread_key_t mcbsp_internal_thread_data;

extern pthread_key_t mcbsp_internal_init_data;

extern bool mcbsp_internal_keys_allocated;

extern pthread_mutex_t mcbsp_internal_key_mutex;

void bsp_init_internal( struct mcbsp_init_data * const initialisationData );

struct mcbsp_init_data * bsp_begin_check();

struct mcbsp_util_machine_info *mcbsp_internal_getMachineInfo();

void mcbsp_internal_check_keys_allocated();

void* mcbsp_internal_spmd();

void mcbsp_internal_check_aborted();

#ifdef MCBSP_USE_SPINLOCK

void mcbsp_internal_sync( struct mcbsp_init_data * const init, const size_t bsp_id );
#else

void mcbsp_internal_sync( struct mcbsp_init_data * const init );
#endif

#ifdef MCBSP_USE_SPINLOCK

void mcbsp_internal_syncWithCondition( struct mcbsp_init_data * const init,
        volatile unsigned char * const condition, const size_t bsp_id );
#else

void mcbsp_internal_syncWithCondition( struct mcbsp_init_data * const init,
        pthread_cond_t * const condition );
#endif

const struct mcbsp_thread_data * mcbsp_internal_const_prefunction();

struct mcbsp_thread_data * mcbsp_internal_prefunction();

extern int main( int argc, char** argv );

#endif