sources/native/native_sched.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;

/*
** GLOBALS
*/

hlx_scheduler   gl_scheduler;

/*
** PROTOTYPES
*/

hlx_group* hlx_sheduler_find_lighter_group(void);
hlx_task* hlx_scheduler_init_task(hlx_task_func task_func, void* data, hlx_group* group, hlx_task_callback callback);
void hlx_scheduler_schedule(void);
int  hlx_scheduler_schedule_group(hlx_group*);

/*
** FUNCTIONS
*/

void hlx_core_add_task_in_group_callback(hlx_task_func task_func, void* data, hlx_group_id group_id, hlx_group_id self_group_id, hlx_task_callback callback)
{
        hlx_task* task;
        hlx_group* group;

    HLX_UNUSED(self_group_id);
        group = (hlx_group*)group_id;
        task = hlx_scheduler_init_task(task_func, data, group, callback);
        if (!task)
                return;
        hlx_group_add_task(group, task);
}

void hlx_core_add_task_in_group(hlx_task_func task_func, void* data, hlx_group_id group_id)
{
        hlx_core_add_task_in_group_callback(task_func, data, group_id, 0, 0);
}

void hlx_core_add_task_callback(hlx_task_func task_func, void* data, hlx_group_id self_group_id, hlx_task_callback callback)
{
        hlx_core_add_task_in_group_callback(task_func, data, hlx_sheduler_find_lighter_group()->id, self_group_id, callback);
}

void hlx_scheduler_schedule()
{
        hlx_list_node* it;
        unsigned int i;
        unsigned int count;
        unsigned int flag_try;

        count = 1;
        flag_try = 0;
        gl_scheduler.loop = 1;
        while (gl_scheduler.loop && count)
        {
                count = 0;
                for (i = 0, it = gl_scheduler.groups.first; it != 0; it = it->next, ++i)
                        count += hlx_scheduler_schedule_group(it->data);
                if (flag_try && count)
                        flag_try = 0;
                if (!count && !flag_try)
                {
                        count = 1;
                        flag_try = 1;
                }
        }
}

#endif /* HLX_BUILD_WITH_PARALLEL_THREADING */

#ifdef __cplusplus
}
#endif

/*
** END OF FILE
*/