Searched refs:osfd (Results 1 – 4 of 4) sorted by relevance
| /f-stack/app/micro_thread/ |
| H A D | mt_notify.cpp | 78 if (osfd < 0) in CreateSocket()
88 close(osfd); in CreateSocket()
89 osfd = -1; in CreateSocket()
100 close(osfd); in CreateSocket()
101 osfd = -1; in CreateSocket()
106 this->SetOsfd(osfd); in CreateSocket()
112 return osfd; in CreateSocket()
117 int osfd = this->GetOsfd(); in CloseSocket() local
118 if (osfd > 0) in CloseSocket()
125 close(osfd); in CloseSocket()
[all …]
|
| H A D | kqueue_proxy.cpp | 369 int osfd = 0; in KqueueRcvEventList() local
377 osfd = _evtlist[i].ident; in KqueueRcvEventList()
379 item = KqFdRefGet(osfd); in KqueueRcvEventList()
383 MTLOG_ERROR("kqfd ref not find, failed, fd: %d", osfd); in KqueueRcvEventList()
397 MTLOG_ERROR("fd notify obj null, failed, fd: %d", osfd); in KqueueRcvEventList()
398 KqueueCtrlDel(osfd, (revents & (KQ_EVENT_READ | KQ_EVENT_WRITE))); in KqueueRcvEventList()
503 int osfd = this->GetOsfd(); in KqueueCtlAdd() local
510 MTLOG_ERROR("kqfd ref conflict, fd: %d, old: %p, now: %p", osfd, old_obj, this); in KqueueCtlAdd()
515 if (!frame->KqueueCtrlAdd(osfd, new_events)) in KqueueCtlAdd()
531 int osfd = this->GetOsfd(); in KqueueCtlDel() local
[all …]
|
| H A D | mt_connection.cpp | 617 int osfd = real_ntfy->GetOsfd(); in CreateSocket() local
618 if (osfd <= 0) in CreateSocket()
620 osfd = real_ntfy->CreateSocket(); in CreateSocket()
621 if (osfd <= 0) { in CreateSocket()
626 _ntfy_obj->SetOsfd(osfd); in CreateSocket()
628 return osfd; in CreateSocket()
|
| H A D | mt_api.cpp | 138 int osfd = conn->CreateSocket(); in mt_tcp_get_keep_conn() local
139 if (osfd < 0) in mt_tcp_get_keep_conn()
142 MTLOG_ERROR("create socket failed, ret[%d]", osfd); in mt_tcp_get_keep_conn()
146 sock = osfd; in mt_tcp_get_keep_conn()
|