Searched refs:GetOsfd (Results 1 – 5 of 5) sorted by relevance
| /f-stack/app/micro_thread/ |
| H A D | kqueue_proxy.cpp | 125 MTLOG_ERROR("kqobj add failed, fd: %d", kqobj->GetOsfd()); in KqueueAdd()
159 MTLOG_ERROR("epobj del failed, fd: %d", kqobj->GetOsfd()); in KqueueDel()
321 KqFdRef* item = KqFdRefGet(obj->GetOsfd()); in KqueueAddObj()
325 MTLOG_ERROR("kqfd ref not find, failed, fd: %d", obj->GetOsfd()); in KqueueAddObj()
332 MTLOG_ERROR("kqueue ctrl callback failed, fd: %d, obj: %p", obj->GetOsfd(), obj); in KqueueAddObj()
347 KqFdRef* item = KqFdRefGet(obj->GetOsfd()); in KqueueDelObj()
351 MTLOG_ERROR("kqfd ref not find, failed, fd: %d", obj->GetOsfd()); in KqueueDelObj()
358 MTLOG_ERROR("kqueue ctrl callback failed, fd: %d, obj: %p", obj->GetOsfd(), obj); in KqueueDelObj()
493 frame->KqueueCtrlDel(this->GetOsfd(), this->GetEvents()); in HangupNotify()
503 int osfd = this->GetOsfd(); in KqueueCtlAdd()
[all …]
|
| H A D | mt_notify.cpp | 117 int osfd = this->GetOsfd(); in CloseSocket()
146 int osfd = this->GetOsfd(); in InputNotify()
235 frame->KqueueCtrlDel(this->GetOsfd(), this->GetEvents()); in HangupNotify()
237 MTLOG_ERROR("sesson obj %p, recv error event. fd %d", this, this->GetOsfd()); in HangupNotify()
252 int osfd = this->GetOsfd(); in KqueueCtlAdd()
277 int osfd = this->GetOsfd(); in KqueueCtlDel()
|
| H A D | mt_connection.cpp | 617 int osfd = real_ntfy->GetOsfd(); in CreateSocket()
644 …int ret = ff_hook_sendto(_ntfy_obj->GetOsfd(), _msg_buff->GetMsgBuff(), _msg_buff->GetMsgLen(), 0, in SendData()
654 MTLOG_ERROR("socket send failed, fd %d, errno %d(%s)", _ntfy_obj->GetOsfd(), in SendData()
|
| H A D | kqueue_proxy.h | 131 int GetOsfd() { return _fd; }; in GetOsfd() function
|
| H A D | mt_notify.h | 171 this->SetOsfd(obj->GetOsfd()); in SetRealNtfyObj()
|