| /foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket_listener.cpp | 33 epollFd_ = epoll_create1(EPOLL_CLOEXEC); in Initialize()
35 if (epollFd_ == -1 || stopFd_ == -1) { in Initialize()
45 CHECK_EXCEPT_INTR(ret = epoll_ctl(epollFd_, EPOLL_CTL_ADD, stopFd_, &event)); in Initialize()
67 if (epollFd_ != -1) { in Uninitialize()
68 close(epollFd_); in Uninitialize()
69 epollFd_ = -1; in Uninitialize()
97 ret = epoll_ctl(epollFd_, EPOLL_CTL_MOD, fd, &event); in AddSocket()
101 ret = epoll_ctl(epollFd_, EPOLL_CTL_ADD, fd, &event); in AddSocket()
104 LOG_INFO("[SocketListener]: epollFd: %{public}d, fd:%{public}d, errno:%{public}d", epollFd_, fd, errno); in AddSocket()
119 CHECK_EXCEPT_INTR(nfds = epoll_wait(epollFd_, event in OnListenEvents()
[all...] |
| H A D | socket_listener.h | 94 int epollFd_ {-1};
|
| /foundation/multimodalinput/input/intention/common/epoll/src/ |
| H A D | epoll_manager.cpp | 39 if (epollFd_ != -1) { in Open()
42 epollFd_ = ::epoll_create1(EPOLL_CLOEXEC); in Open()
43 if (epollFd_ == -1) { in Open()
52 if (epollFd_ != -1) { in Close()
53 if (::close(epollFd_) != 0) { in Close()
54 FI_HILOGE("close(%{public}d) failed:%{public}s", epollFd_, ::strerror(errno)); in Close()
56 epollFd_ = -1; in Close()
67 int32_t ret = ::epoll_ctl(epollFd_, EPOLL_CTL_ADD, source.GetFd(), &ev); in Add()
78 int32_t ret = ::epoll_ctl(epollFd_, EPOLL_CTL_DEL, source.GetFd(), nullptr); in Remove()
91 int32_t ret = ::epoll_ctl(epollFd_, EPOLL_CTL_MO in Update()
[all...] |
| /foundation/multimodalinput/input/util/socket/src/ |
| H A D | uds_socket.cpp | 38 epollFd_ = epoll_create(size); in EpollCreate()
39 if (epollFd_ < 0) { in EpollCreate()
40 MMI_HILOGE("epoll_create return %{public}d", epollFd_); in EpollCreate()
42 MMI_HILOGI("epoll_create, epollFd_:%{public}d", epollFd_); in EpollCreate()
44 return epollFd_; in EpollCreate()
54 epollFd = epollFd_; in EpollCtl()
67 MMI_HILOGE("epoll_ctl return %{public}d,epollFd_:%{public}d," in EpollCtl()
77 epollFd = epollFd_; in EpollWait()
134 if (epollFd_ > in EpollClose()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_loop_epoll.cpp | 35 if (epollFd_.IsValid()) { in ~EventLoopEpoll()
36 epollFd_.Close(); in ~EventLoopEpoll()
42 if (epollFd_.IsValid()) { in Initialize()
54 epollFd_ = EventFd(epoll_create(EPOLL_INIT_REVENTS)); in Initialize()
55 if (!epollFd_.IsValid()) { in Initialize()
65 errCode = epoll_ctl(epollFd_, EPOLL_CTL_ADD, wakeUpFd_, &event); in Initialize()
68 epollFd_.Close(); in Initialize()
94 int nReady = epoll_wait(epollFd_, &revents_[0], revents_.size(), sleepTime); in Poll()
148 epollFd_.Close(); in Exit()
222 int errCode = epoll_ctl(epollFd_, operatio in EpollCtl()
[all...] |
| H A D | event_loop_epoll.h | 51 EventFd epollFd_; member in DistributedDB::EventLoopEpoll
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/util/internal/ |
| H A D | timer_linux.cpp | 47 int epollFd_ {-1};
75 if (epollFd_ != -1) { in ~TimerManager()
76 close(epollFd_); in ~TimerManager()
85 epollFd_ = epoll_create1(EPOLL_CLOEXEC); in Initialize()
87 if ((epollFd_ == -1) || (stopFd_ == -1)) { in Initialize()
98 CHECK_EXCEPT_INTR(ret = epoll_ctl(epollFd_, EPOLL_CTL_ADD, stopFd_, &event)); in Initialize()
136 CHECK_EXCEPT_INTR(nfds = epoll_wait(epollFd_, events, MAXEPOLLEVENTS, -1)); in OnTimer()
175 if (epoll_ctl(epollFd_, EPOLL_CTL_ADD, timer.fd_, &event) == -1) { in AddTimer()
185 if (epoll_ctl(epollFd_, EPOLL_CTL_DEL, timer.fd_, nullptr) == -1) { in RemoveTimer()
|
| /foundation/multimodalinput/input/intention/services/test/unittest/src/ |
| H A D | device_manager_test.cpp | 168 FI_HILOGI("AddEpoll, epollfd:%{public}d, fd:%{public}d", epollFd_, delegateTasks_.GetReadFd()); in InitDelegateTasks()
175 epollFd_ = ::epoll_create1(EPOLL_CLOEXEC); in EpollCreate()
176 if (epollFd_ < 0) { in EpollCreate()
238 if (epollFd_ >= 0) { in EpollClose()
239 if (close(epollFd_) < 0) { in EpollClose()
240 FI_HILOGE("Close epoll fd failed, error:%{public}s, epollFd_:%{public}d", strerror(errno), epollFd_); in EpollClose()
242 epollFd_ = -1; in EpollClose()
253 if (epollFd_ < 0) { in EpollCtl()
254 FI_HILOGE("Invalid epollFd:%{public}d", epollFd_); in EpollCtl()
[all...] |
| /foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/ |
| H A D | dns_proxy_listen.cpp | 55 if (epollFd_ > 0) { in ~DnsProxyListen()
56 close(epollFd_); in ~DnsProxyListen()
57 epollFd_ = -1; in ~DnsProxyListen()
144 epoll_ctl(epollFd_, EPOLL_CTL_DEL, socketFd, nullptr); in SendRequest2Server()
157 if (epoll_ctl(epollFd_, EPOLL_CTL_ADD, socketFd, iter->second.GetEventPtr()) < 0) { in SendRequest2Server()
220 epoll_wait(epollFd_, eventsReceived, EPOLL_TASK_NUMBER, serverIdxOfSocket.empty() ? -1 : EPOLL_TIMEOUT); in StartListen()
333 epollFd_ = epoll_create1(0); in InitForListening()
334 if (epollFd_ < 0) { in InitForListening()
342 if (epoll_ctl(epollFd_, EPOLL_CTL_ADD, proxySockFd_, &proxyEvent) < 0) { in InitForListening()
351 if (epoll_ctl(epollFd_, EPOLL_CTL_AD in InitForListening()
[all...] |
| /foundation/multimodalinput/input/intention/common/epoll/include/ |
| H A D | epoll_manager.h | 52 int32_t epollFd_ { -1 };
57 return epollFd_; in GetFd()
|
| /foundation/multimodalinput/input/util/socket/include/ |
| H A D | uds_socket.h | 57 return epollFd_; in GetEpollFd()
62 int32_t epollFd_ { -1 };
|
| /foundation/communication/netstack/frameworks/js/napi/socket/async_context/include/ |
| H A D | local_socket_server_context.h | 48 int epollFd_ = 0; member
71 epollFd_ = epoll_create1(0); in StartEpoll()
72 return epollFd_; in StartEpoll()
76 return epoll_wait(epollFd_, events_, MAX_EVENTS - 1, EPOLL_TIMEOUT_MS); in EpollWait()
83 return epoll_ctl(epollFd_, EPOLL_CTL_ADD, sockfd, &event); in RegisterEpollEvent()
137 epoll_ctl(epollFd_, EPOLL_CTL_DEL, ite->second, nullptr); in RemoveAccept()
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/ |
| H A D | i_stream_socket.h | 52 epollFd_ = -1; in IStreamSocket()
138 int epollFd_; member in Communication::SoftBus::IStreamSocket
|
| H A D | vtp_stream_socket.cpp | 484 epollFd_ = FtEpollCreate(); in CreateServer()
485 if (epollFd_ < 0) { in CreateServer()
503 "CreateServer end, listenFd=%{public}d, epollFd=%{public}d, streamType=%{public}d", listenFd_, epollFd_, in CreateServer()
530 if (epollFd_ != -1) { in DestroyStreamSocket()
531 TRANS_LOGI(TRANS_STREAM, "epollFd_ enter FtClose"); in DestroyStreamSocket()
532 FtClose(epollFd_); in DestroyStreamSocket()
533 epollFd_ = -1; in DestroyStreamSocket()
572 epollFd_ = FtEpollCreate(); in Connect()
573 if (epollFd_ < 0) { in Connect()
971 FILLP_INT fdNum = FtEpollWait(epollFd_, event in EpollTimeout()
[all...] |
| /foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_manager_test/ |
| H A D | dns_proxy_listen_test.cpp | 129 instance_->epollFd_ = epoll_create1(0); in HWTEST_F()
133 EXPECT_EQ(instance_->epollFd_, -1); in HWTEST_F()
|
| /foundation/multimodalinput/input/service/module_loader/src/ |
| H A D | uds_server.cpp | 45 if (epollFd_ != -1) { in UdsStop()
46 close(epollFd_); in UdsStop()
47 epollFd_ = -1; in UdsStop()
|
| H A D | mmi_service.cpp | 341 auto ret = AddEpoll(EPOLL_EVENT_SOCKET, epollFd_); in InitService()
354 MMI_HILOGI("AddEpoll, epollfd:%{public}d, fd:%{public}d", mmiFd_, epollFd_); in InitService()
|
| /foundation/multimodalinput/input/intention/services/test/unittest/include/ |
| H A D | device_manager_test.h | 99 int32_t epollFd_ { -1 };
|
| /foundation/communication/netmanager_base/services/netmanagernative/include/netsys/ |
| H A D | dns_proxy_listen.h | 94 int32_t epollFd_ = -1; member in OHOS::nmd::DnsProxyListen
|
| /foundation/distributedhardware/distributed_input/common/include/ |
| H A D | input_hub.cpp | 48 InputHub::InputHub(bool isPluginMonitor) : epollFd_(-1), iNotifyFd_(-1), inputWd_(-1), in InputHub()
63 epollFd_ = epoll_create1(EPOLL_CLOEXEC); in Initialize()
64 if (epollFd_ < 0) { in Initialize()
81 int result = epoll_ctl(epollFd_, EPOLL_CTL_ADD, iNotifyFd_, &eventItem); in Initialize()
96 if (epollFd_ != -1) { in Release()
97 ::close(epollFd_); in Release()
98 epollFd_ = -1; in Release()
484 int pollResult = epoll_wait(epollFd_, mPendingEventItems, EPOLL_MAX_EVENTS, EPOLL_WAITTIME); in RefreshEpollItem()
1017 if (epoll_ctl(epollFd_, EPOLL_CTL_ADD, fd, &eventItem)) { in RegisterFdForEpoll()
1069 if (epoll_ctl(epollFd_, EPOLL_CTL_DE in UnregisterFdFromEpoll()
[all...] |
| H A D | input_hub.h | 213 int epollFd_; member in OHOS::DistributedHardware::DistributedInput::InputHub
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/vtp_stream_socket_test/ |
| H A D | vtp_stream_socket_test.cpp | 167 vtpStreamSocket->epollFd_ = 2; in HWTEST_F()
172 vtpStreamSocket->epollFd_ = -1; in HWTEST_F()
1068 vtpStreamSocket->epollFd_ = 2; in HWTEST_F()
|
| /foundation/communication/netstack/frameworks/js/napi/socket/socket_module/src/ |
| H A D | socket_module.cpp | 160 close(serverMgr->epollFd_); in FinalizeLocalsocketServer()
420 close(pManager->epollFd_); in MakeLocalServerSocket()
|
| /foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/ |
| H A D | local_socket_exec.cpp | 1040 if (mgr->epollFd_ > 0) { in ExecLocalSocketServerEnd()
1041 close(mgr->epollFd_); in ExecLocalSocketServerEnd()
1042 mgr->epollFd_ = -1; in ExecLocalSocketServerEnd()
|