Searched refs:MicroThread (Results 1 – 10 of 10) sorted by relevance
203 MicroThread::MicroThread(ThreadType type) in MicroThread() function in MicroThread216 void MicroThread::CleanState() in CleanState()228 void MicroThread::Run() in Run()264 void MicroThread::AddSubThread(MicroThread* sub) in AddSubThread()276 void MicroThread::RemoveSubThread(MicroThread* sub) in RemoveSubThread()348 MicroThread* thread = (MicroThread*)pthread; in ScheduleUnpend()559 _primo = new MicroThread(MicroThread::PRIMORDIAL); in InitFrame()598 MicroThread* thread = dynamic_cast<MicroThread*>(_sleeplist.HeapPop()); in Destroy()612 MicroThread* tmp; in Destroy()752 MicroThread* thread = dynamic_cast<MicroThread*>(_sleeplist.HeapTop()); in WakeupTimeout()[all …]
165 class MicroThread : public Thread203 ~MicroThread(){}; in ~MicroThread()247 MicroThread* GetParent() { in GetParent()252 void AddSubThread(MicroThread* sub);295 MicroThread* _parent;383 MicroThread* AllocThread(void);407 MicroThread* _daemon;408 MicroThread* _primo;409 MicroThread* _curr_thread;447 MicroThread *GetRootThread();[all …]
32 class MicroThread; variable57 MicroThread* GetOwnerThread(){ in GetOwnerThread()60 void SetOwnerThread(MicroThread* thread) { in SetOwnerThread()90 MicroThread* _thread;
93 class MicroThread; variable102 MicroThread* _thread;147 void SetOwnerThread(MicroThread* thread) { _thread = thread; }; in SetOwnerThread()148 MicroThread* GetOwnerThread() { return _thread; }; in GetOwnerThread()
61 MicroThread* thread = NULL; in NotifyWriteWait()67 if (thread && thread->HasFlag(MicroThread::IO_LIST)) in NotifyWriteWait()198 MicroThread* thread = session->GetOwnerThread(); in InputNotify()215 if (thread->HasFlag(MicroThread::IO_LIST)) in InputNotify()
504 MicroThread* thread = mtframe->GetActiveThread(); in mt_exec_all_task()506 MicroThread* sub = NULL; in mt_exec_all_task()507 MicroThread* tmp = NULL; in mt_exec_all_task()510 MicroThread::SubThreadList list; in mt_exec_all_task()529 sub->SetType(MicroThread::SUB_THREAD); in mt_exec_all_task()557 MicroThread *msg_thread = MtFrame::Instance()->GetRootThread(); in mt_set_msg_private()564 MicroThread *msg_thread = MtFrame::Instance()->GetRootThread(); in mt_get_msg_private()660 MtFrame::Instance()->NotifyThread((MicroThread *) thread_p); in mt_thread_wakeup_wait()
451 MicroThread* thread = this->GetOwnerThread(); in InputNotify()459 if (thread->HasFlag(MicroThread::IO_LIST)) in InputNotify()471 MicroThread* thread = this->GetOwnerThread(); in OutputNotify()480 if (thread->HasFlag(MicroThread::IO_LIST)) in OutputNotify()
225 MicroThread* GetThread() { in GetThread()244 MicroThread* _thread;
122 MicroThread* thread = mtframe->GetActiveThread(); in InitConnEnv()
713 MicroThread* thread = item->GetThread(); in NotifyThread()714 if ((thread != NULL) && (thread->HasFlag(MicroThread::IO_LIST))) in NotifyThread()