#ifndef DEF_THREAD_CLASS_H #define DEF_THREAD_CLASS_H #include #include #define T_ZOMBIE 0 #define T_RUNNING 1 #define T_SLEEPING 2 #define T_IRQWAIT 3 typedef u32int(*thread_entry_t)(void*); class Thread : public Ressource { friend class Process; //This might be useful protected: static void run(Thread* thread, void* data, thread_entry_t entry_point); Thread(); //Creates a thread without initializing anything. Used by Process::createKernel(); Process *m_process; //Associated process u32int m_esp, m_ebp, m_eip; u8int m_state; //Is one of T_* defined above void* m_xchgspace; union { //What the thread might be waiting for u32int m_time; u8int m_irq; //An IRQ number } waitfor; bool m_isKernel; //Says if stack is in kernel pagedir, and if thread should run in ring 0 struct { void* addr; u32int size; } m_userStack, m_kernelStack; void setup(Process* process, thread_entry_t entry_point, void* data, bool isKernel); //Syscalls static call_t m_callTable[]; u32int sleepSC(u32int msecs); u32int finishSC(u32int errcode); bool accessible(); public: static u32int scall(u8int, u32int, u32int, u32int, u32int); Thread(thread_entry_t entry_point, void* data, bool iskernel = false); //Assumes process is current process, or is kprocess if isk Thread(Process* process, thread_entry_t entry_point, void* data); ~Thread(); void finish(u32int errcode); //Called by run() when thread returns, and by exception handler. Can also be called by the thread itself virtual void handleException(registers_t *regs, int no); void setState(u32int esp, u32int ebp, u32int eip); void setKernelStack(); u32int getEsp(); u32int getEbp(); u32int getEip(); Process* getProcess(); void* mkXchgSpace(u32int sz); void sleep(u32int msecs); void waitIRQ(u8int irq); bool runnable(); //Called by scheduler inline bool irqHappens(u8int irq) { //Inline for speed if (m_state == T_IRQWAIT and waitfor.m_irq == irq) { m_state = T_RUNNING; return true; } return false; } }; #endif