source: proiecte/swift/trunk/src/swift_context.c @ 176

/*
 * swift_context.c
 *
 * (c) 2009 Ionut Rosoiu <ionut.rosoiu@gmail.com>
 *
 */

#include "swift_context.h"
#include <stdlib.h>
#include <string.h>

void swift_context_init(swift_context_t *context, swift_size_t nprocs) {
        //TODO: check
        swift_thread_t *thread;
        int i;
#ifdef SWIFT_USE_CUSTOM_ALLOCATOR
        int j;
#endif

        context->thread_num = nprocs;
        context->parallel_finished = 0;

        context->threads = (swift_thread_t*) swift_malloc_system(nprocs * sizeof(swift_thread_t));

        //TODO: check
        for (i=0; i<nprocs; i++) {
                thread = &context->threads[i];

#ifdef SWIFT_USE_CUSTOM_ALLOCATOR
                thread->heap = swift_malloc_system(SWIFT_HEAP_SIZE);
                thread->buckets = (swift_allocator_list_t**) swift_malloc_system(SWIFT_BUCKET_COUNT * sizeof(void*));
                swift_assert(thread->heap && thread->buckets);

                thread->heap_top = thread->heap;
                thread->heap_limit = ((char*)thread->heap + SWIFT_HEAP_SIZE);

                for (j=0; j<SWIFT_BUCKET_COUNT; j++) {
                        thread->buckets[j] = NULL;
                }
#endif

                swift_deque_init(thread,
                                                 &thread->workque,
                                                 SWIFT_DEQUE_SIZE);

                //TODO: check
                thread->context = context;
                thread->id = i;
                thread->stats = 0;
                thread->stop = 0;
                thread->round_robin_id = i;
                thread->last_sleep_time = i * 10 + 1;
                thread->frame_no = 0;
        }
}

void swift_context_destroy(swift_context_t *context) {
        int i;
#ifdef SWIFT_USE_CUSTOM_ALLOCATOR
        int j;
#endif

        for (i=0; i<context->thread_num; i++) {
                swift_deque_destroy(&context->threads[i], &context->threads[i].workque);

#ifdef SWIFT_USE_CUSTOM_ALLOCATOR
                for (j=0; j<SWIFT_BUCKET_COUNT; j++) {
                        context->threads[i].buckets[j] = NULL;
                }
                swift_free_system(context->threads[i].buckets);
#endif

        }

        swift_free_system(context->threads);
}