| 699 | } |
| 700 | |
| 701 | void CSockLink::NotifyThread(CNetHandler* item, int32_t result) |
| 702 | { |
| 703 | static MtFrame* frame = NULL; |
| 704 | if (frame == NULL) { |
| 705 | frame = MtFrame::Instance(); |
| 706 | } |
| 707 | |
| 708 | if (result != RC_SUCCESS) |
| 709 | { |
| 710 | item->SetErrNo(result); |
| 711 | } |
| 712 | |
| 713 | MicroThread* thread = item->GetThread(); |
| 714 | if ((thread != NULL) && (thread->HasFlag(MicroThread::IO_LIST))) |
| 715 | { |
| 716 | frame->RemoveIoWait(thread); |
| 717 | frame->InsertRunable(thread); |
| 718 | } |
| 719 | } |
| 720 | |
| 721 | void CSockLink::NotifyAll(int32_t result) |
| 722 | { |
no test coverage detected