Subversion Repositories freemyipod

//

//

//    Copyright 2010 TheSeven

//

//

//    This file is part of emBIOS.

//

//    emBIOS is free software: you can redistribute it and/or

//    modify it under the terms of the GNU General Public License as

//    published by the Free Software Foundation, either version 2 of the

//    License, or (at your option) any later version.

//

//    emBIOS 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 General Public License for more details.

//

//    You should have received a copy of the GNU General Public License along

//    with emBIOS.  If not, see <http://www.gnu.org/licenses/>.

//

//

#ifndef __THREAD_H__

#define __THREAD_H__

#include "global.h"

#include "contextswitch.h"

#ifndef SCHEDULER_TICK

#define SCHEDULER_TICK 1048576

#endif

#ifndef SYSTEM_TICK

#define SYSTEM_TICK 10000

#endif

#define TIMEOUT_NONE 0

#define TIMEOUT_BLOCK -1

#define THREAD_FOUND 1

#define THREAD_OK 0

#define THREAD_TIMEOUT -1

#define NO_MORE_THREADS -2

#define INVALID_THREAD -3

#define ALREADY_SUSPENDED -4

#define ALREADY_RESUMED -5

enum thread_state

{

    THREAD_FREE = 0,

    THREAD_READY,

    THREAD_RUNNING,

    THREAD_BLOCKED,

    THREAD_SUSPENDED

};

enum thread_block

{

    THREAD_NOT_BLOCKED = 0,

    THREAD_BLOCK_SLEEP,

    THREAD_BLOCK_MUTEX,

    THREAD_BLOCK_WAKEUP

};

struct scheduler_thread

{

    uint32_t regs[16];

    uint32_t cpsr;

    const char* name;

    uint64_t cputime_total;

    uint32_t cputime_current;

    uint32_t startusec;

    struct scheduler_thread* queue_next;

    uint32_t timeout;

    uint32_t blocked_since;

    void* blocked_by;

    uint32_t* stack;

    enum thread_state state;

    enum thread_block block_type;

    uint8_t priority;

    uint8_t cpuload;

};

struct mutex

{

    struct scheduler_thread* owner;

    struct scheduler_thread* waiters;

    int count;

};

struct wakeup

{

    struct scheduler_thread* waiter;

    bool signalled;

};

void scheduler_init() INITCODE_ATTR;

void scheduler_switch(int thread) ICODE_ATTR;

int thread_create(const char* name, const void* code, void* stack,

                  int stacksize, int priority, bool run);

int thread_suspend(int thread);

int thread_resume(int thread);

int thread_terminate(int thread);

void thread_exit();

void mutex_init(struct mutex* obj) ICODE_ATTR;

int mutex_lock(struct mutex* obj, int timeout) ICODE_ATTR;

int mutex_unlock(struct mutex* obj) ICODE_ATTR;

void wakeup_init(struct wakeup* obj) ICODE_ATTR;

int wakeup_wait(struct wakeup* obj, int timeout) ICODE_ATTR;

int wakeup_signal(struct wakeup* obj) ICODE_ATTR;

void sleep(int usecs) ICODE_ATTR;

static inline void yield()

{

    context_switch();

}

#endif