Home
last modified time | relevance | path

Searched refs:MtFrame (Results 1 – 11 of 11) sorted by relevance

/f-stack/app/micro_thread/
H A Dmicro_thread.cpp301 MtFrame* frame = MtFrame::Instance(); in ScheduleThread()
307 MtFrame* frame = MtFrame::Instance(); in ScheduleGetTime()
321 MtFrame* frame = MtFrame::Instance(); in ScheduleSleep()
334 MtFrame* frame = MtFrame::Instance(); in SchedulePend()
347 MtFrame* frame = MtFrame::Instance(); in ScheduleUnpend()
360 MtFrame* frame = MtFrame::Instance(); in ScheduleReclaim()
372 MtFrame* frame = MtFrame::Instance(); in ScheduleStartRun()
504 MtFrame *MtFrame::_instance = NULL;
505 inline MtFrame* MtFrame::Instance () in Instance()
638 MtFrame* mtframe = MtFrame::Instance(); in CreateThread()
[all …]
H A Dmt_api.cpp244 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv()
307 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv_short()
503 MtFrame* mtframe = MtFrame::Instance(); in mt_exec_all_task()
580 return MtFrame::Instance()->InitFrame(); in mt_init_frame()
610 return MtFrame::read(fd, buf, nbyte, timeout); in mt_read()
615 return MtFrame::write(fd, buf, nbyte, timeout); in mt_write()
630 MtFrame::sleep(ms); in mt_sleep()
635 return MtFrame::Instance()->GetLastClock(); in mt_time_ms()
650 return MtFrame::Instance()->GetActiveThread(); in mt_active_thread()
655 MtFrame::Instance()->WaitNotify(ms); in mt_thread_wait()
[all …]
H A Dmt_notify.cpp59 MtFrame* frame = MtFrame::Instance(); in NotifyWriteWait()
108 MtFrame* frame = MtFrame::Instance(); in CreateSocket()
120 MtFrame* frame = MtFrame::Instance(); in CloseSocket()
217 MtFrame* frame = MtFrame::Instance(); in InputNotify()
234 MtFrame* frame = MtFrame::Instance(); in HangupNotify()
248 MtFrame* frame = MtFrame::Instance(); in KqueueCtlAdd()
273 MtFrame* frame = MtFrame::Instance(); in KqueueCtlDel()
H A Dmt_concurrent.cpp77 MtFrame* mtframe = MtFrame::Instance(); in mt_multi_netfd_poll()
152 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_open()
195 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_open()
228 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_sendto()
277 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_sendto()
311 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_recvfrom()
357 action->SetCost(MtFrame::Instance()->GetLastClock() - start_ms); in mt_multi_recvfrom()
361 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_recvfrom()
385 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_sendrcv_ex()
404 curr_ms = MtFrame::Instance()->GetLastClock(); in mt_multi_sendrcv_ex()
[all …]
H A Dmicro_thread.h398 class MtFrame : public KqueueProxy, public ThreadPool
401 static MtFrame* _instance;
420 static MtFrame* Instance (void);
505 MtFrame():_realtime(1){ _curr_thread = NULL; }; in MtFrame() function
543 register NS_MICRO_THREAD::MtFrame *fm = NS_MICRO_THREAD::MtFrame::Instance(); \
553 register NS_MICRO_THREAD::MtFrame *fm = NS_MICRO_THREAD::MtFrame::Instance(); \
563 register NS_MICRO_THREAD::MtFrame *fm = NS_MICRO_THREAD::MtFrame::Instance(); \
573 register NS_MICRO_THREAD::MtFrame *fm = NS_MICRO_THREAD::MtFrame::Instance(); \
582 register NS_MICRO_THREAD::MtFrame *fm = NS_MICRO_THREAD::MtFrame::Instance(); \
H A Dkqueue_proxy.cpp461 MtFrame* frame = MtFrame::Instance(); in InputNotify()
482 MtFrame* frame = MtFrame::Instance(); in OutputNotify()
492 MtFrame* frame = MtFrame::Instance(); in HangupNotify()
499 MtFrame* frame = MtFrame::Instance(); in KqueueCtlAdd()
527 MtFrame* frame = MtFrame::Instance(); in KqueueCtlDel()
H A Dmt_sys_hook.cpp173 return MtFrame::connect(fd, address, (int)address_len, hook_fd->write_timeout); in connect()
190 return MtFrame::read(fd, buf, nbyte, hook_fd->read_timeout); in read()
207 return MtFrame::write(fd, buf, nbyte, hook_fd->write_timeout); in write()
225 return MtFrame::sendto(fd, message, (int)length, flags, in sendto()
244 … return MtFrame::recvfrom(fd, buffer, length, flags, address, address_len, hook_fd->read_timeout); in recvfrom()
262 return MtFrame::recv(fd, buffer, length, flags, hook_fd->read_timeout); in recv()
279 return MtFrame::send(fd, buf, nbyte, flags, hook_fd->write_timeout); in send()
H A Dmt_net.cpp299 MtFrame* mtframe = MtFrame::Instance(); in WaitConnect()
347 MtFrame* mtframe = MtFrame::Instance(); in WaitSend()
387 MtFrame* mtframe = MtFrame::Instance(); in WaitRecv()
406 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in SendRecv()
632 MtFrame* mtframe = MtFrame::Instance(); in RegistSession()
703 static MtFrame* frame = NULL; in NotifyThread()
705 frame = MtFrame::Instance(); in NotifyThread()
812 MtFrame::Instance()->KqueueDelObj(this); in Close()
871 if (!MtFrame::Instance()->KqueueAddObj(this)) in CreateSock()
1479 CTimerMng* timer = MtFrame::Instance()->GetTimerMng(); in Reset()
[all …]
H A Dheap_timer.cpp55 utime64_t now_ms = MtFrame::Instance()->GetLastClock(); in start_timer()
82 utime64_t now = MtFrame::Instance()->GetLastClock(); in check_expired()
H A Dmt_action.cpp67 MtFrame* mtframe = MtFrame::Instance(); in InitConnEnv()
H A Dmt_connection.cpp414 CTimerMng* timer = MtFrame::Instance()->GetTimerMng(); in IdleAttach()
421 if (MtFrame::Instance()->KqueueAddObj(&_keep_ntfy)) in IdleAttach()
448 CTimerMng* timer = MtFrame::Instance()->GetTimerMng(); in IdleDetach()
454 if (MtFrame::Instance()->KqueueDelObj(&_keep_ntfy)) in IdleDetach()