sources/parallel/parallel_core.c

Go to the documentation of this file.

/*
** Copyright 2009-2011, helixis.org
** All rights reserved.
**
** Redistribution and use in source and binary forms, with or without modification, are permitted provided
** that the following conditions are met:
**
** Redistributions of source code must retain the above copyright notice, this list of conditions and the
** following disclaimer.
**
** Redistributions in binary form must reproduce the above copyright notice, this list of conditions and
** the following disclaimer in the documentation and/or other materials provided with the distribution.
**
** Neither the name of the helixis.org nor the names of its contributors may be used to endorse or promote
** products derived from this software without specific prior written permission.
**
** THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED
** WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
** PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR
** ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED
** TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
** HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
** NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
** POSSIBILITY OF SUCH DAMAGE.
*/

/*
** INCLUDES
*/

#include "hlx/core.h"
#include "helixis_internal.h"

#if defined(HLX_BUILD_WITH_PARALLEL_THREADING)

#ifdef __cplusplus
extern "C"      {
#endif

/*
** EXTERNALS
*/

extern hlx_api gl_api;
extern hlx_scheduler    gl_scheduler;

/*
** PROTOTYPES
*/

void hlx_scheduler_schedule(void);
void hlx_scheduler_construct(void);
void hlx_sheduler_end_all_threads(void);
void hlx_scheduler_destruct(void);

/*
** FUNCTIONS
*/

int hlx_core_init(void)
{
        if (gl_api.memcpy_entry == 0)
                gl_api.memcpy_entry = hlx_memcpy;
    if (gl_api.malloc_entry == 0 || gl_api.free_entry == 0 ||
        gl_api.atomic_cas_entry == 0 || gl_api.atomic_dcas_entry == 0 ||
        gl_api.atomic_incr_entry == 0 || gl_api.atomic_decr_entry == 0 ||
        gl_api.aligned_free_entry == 0 || gl_api.aligned_malloc_entry == 0)
       return (0);
    if (gl_api.thread_api.thread_construct == 0 || gl_api.thread_api.thread_destruct == 0 ||
        gl_api.thread_api.thread_execute == 0 || gl_api.thread_api.thread_pause_if_needed == 0 ||
        gl_api.thread_api.thread_resume == 0 || gl_api.thread_api.thread_suspend == 0 ||
        gl_api.thread_api.thread_wait_for == 0 || gl_api.thread_api.thread_yield == 0)
       return (0);
        _init_channel_manager();
        hlx_scheduler_construct();
        return (1);
}

void hlx_core_start(void)
{
        hlx_scheduler_schedule();
}

void hlx_core_stop(void)
{
 hlx_sheduler_end_all_threads();
}

void hlx_core_destroy(void)
{
        hlx_scheduler_destruct();
        _destroy_channel_manager();
}

#endif /* !HLX_BUILD_WITH_KERNEL_THREAD */

#ifdef __cplusplus
}
#endif

/*
** END OF FILE
*/