#include "os_task.h"
#include "os_clock.h"
// extern int OS_TickFlag = 0;
static OS_TASK_MSG *g_p_task = NULL; 
static int g_task_cnt = 0;           
static int g_task_pos = 0;          

/**
 * @brief 
 * 
 * @param p_task 
 * @param cnt 
 * @return int 
 */
int InitOSTaskQueue(OS_TASK_MSG *p_task, int cnt)
{
    int i = 0;
    g_p_task = p_task;
    g_task_cnt = cnt;
    for (i = 0; i < g_task_cnt; i++)
    {
        g_p_task[i].func = NULL;
    }

    return 0;
}

/**
 * @brief 
 * 
 * @param func 
 * @param tick 
 * @param work_tick 
 * @param par 
 * @return int 
 */
int OSTaskCreate(TASK_FUNC func, int tick, int work_tick, void *par)
{
    if (g_task_pos < g_task_cnt)
    {
        g_p_task[g_task_pos].func = func;
        g_p_task[g_task_pos].cycle_tick = tick;
        g_p_task[g_task_pos].work_tick = work_tick;
        g_p_task[g_task_pos].par = par;
        g_task_pos++;
        return 0;
    }
    else
    {
        return -1;
    }
}

/**
 * @brief 
 * 
 * @param GetTick 
 */
void OSSchedule(GETTICK_t GetTick)
{
    int i = 0;

    if (NULL == GetTick)
    {
        return;
    }
    while (1)
    {
        GetTick();
        for (i = 0; i < g_task_pos; i++)
        {
            g_p_task[i].cur_tick++; 
            if ((g_p_task[i].cur_tick == g_p_task[i].work_tick) && (g_p_task[i].func != NULL))
            {
                g_p_task[i].func(g_p_task[i].par);
            }
            if (g_p_task[i].cur_tick >= g_p_task[i].cycle_tick)
            {
                g_p_task[i].cur_tick = 0;
            }
        }
    }
}

void OS_GetTick(void)
{
    while (1 != os_GetTickFlag())
        ;
    os_ClearTickFlag();
}