/foundation/communication/netmanager_base/frameworks/js/napi/netpolicy/src/ |
H A D | napi_net_policy.cpp | 101 EventListener listen; in ExecOn() local 102 listen.callbackRef = context->callbackRef; in ExecOn() 103 listen.env = env; in ExecOn() 104 listen.eventId = context->eventPolicyId; in ExecOn() 105 context->policyResult = NetPolicyEventListenerContext::GetInstance().AddEventListener(listen); in ExecOn() 116 EventListener listen; in ExecOff() local 117 listen.callbackRef = context->callbackRef; in ExecOff() 118 listen.env = env; in ExecOff() 119 listen.eventId = context->eventPolicyId; in ExecOff() 120 context->policyResult = NetPolicyEventListenerContext::GetInstance().RemoveEventListener(listen); in ExecOff() [all...] |
/foundation/systemabilitymgr/samgr/services/samgr/native/test/unittest/src/ |
H A D | system_ability_test_tool.cpp | 259 sptr<MockSaStatusChange> listen = new MockSaStatusChange();
in DoSubscribe() local 260 int32_t res = sm->SubscribeSystemAbility(said, listen);
in DoSubscribe() 273 sptr<MockSaStatusChange> listen = new MockSaStatusChange();
in DoUnSubscribe() local 274 int32_t res = sm->UnSubscribeSystemAbility(said, listen);
in DoUnSubscribe()
|
/foundation/communication/dhcp/test/unittest/services/dhcp_client/ |
H A D | mock_system_func.h | 41 MOCK_METHOD2(listen, int(int __fd, int __n));
|
H A D | mock_system_func.cpp | 130 return MockSystemFunc::GetInstance().listen(__fd, __n); in __wrap_listen()
|
/foundation/communication/dhcp/test/unittest/services/dhcp_server/unittest/ |
H A D | system_func_mock.h | 40 MOCK_METHOD2(listen, int(int __fd, int __n));
|
H A D | system_func_mock.cpp | 167 return SystemFuncMock::GetInstance().listen(__fd, __n); in __wrap_listen()
|
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/ |
H A D | sysio.h | 35 int (*listen)(void *argSock); member
|
/foundation/arkui/ui_lite/tools/server/ |
H A D | tcp_server.py | 60 self.tcp_server_socket.listen(128)
|
/foundation/communication/wifi/wifi/base/cRPC/src/ |
H A D | net.c | 154 if (listen(sock, backlog) < 0) { in CreateUnixServer() 155 LOGE("listen failed, errno: %{public}d!", errno); in CreateUnixServer()
|
/foundation/arkui/ace_engine/frameworks/core/components/calendar/ |
H A D | calendar_data_adapter.h | 260 for (const auto& listen : allListeners_) { in RegisterDataListener() 261 listen->UpdateCardCalendarAttr(std::move(calendarAttr_)); in RegisterDataListener()
|
H A D | calendar_data_adapter.cpp | 288 for (const auto& listen : allListeners_) { in UpdateCardCalendarAttr() 289 listen->UpdateCardCalendarAttr(std::move(attr)); in UpdateCardCalendarAttr()
|
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/tcp/ |
H A D | tcp_socket.cpp | 106 if (::listen(socket_, backlog) < RET_OK) { in Listen() 107 CLOGE("Socket listen error: errno = %{public}d, errmsg = %{public}s.", errno, strerror(errno)); in Listen()
|
/foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/tcp/ |
H A D | tcp_socket.cpp | 106 if (::listen(socket_, backlog) < RET_OK) { in Listen() 107 CLOGE("Socket listen error: errno = %{public}d, errmsg = %{public}s.", errno, strerror(errno)); in Listen()
|
/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/ |
H A D | rs_profiler_socket.cpp | 136 if (listen(socket_, maxConnections) != 0) { in Open()
|
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/ |
H A D | fwmark_network.cpp | 184 int32_t result = listen(serverSockfd, MAX_CONCURRENT_CONNECTION_REQUESTS); in StartListener() 186 NETNATIVE_LOGE("FwmarkNetwork: listen failed result %{public}d, errno: %{public}d", result, errno); in StartListener()
|
/foundation/CastEngine/castengine_wifi_display/tests/unittest/interaction/domain/ |
H A D | domain_unit_test.cpp | 606 auto listen = std::make_shared<IDomainPeerListenerImpl>(); in HWTEST_F() local 607 EXPECT_NE(listen, nullptr); in HWTEST_F() 608 domainRpcService->SetPeerListener(listen); in HWTEST_F()
|
/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/include/ |
H A D | vsync_generator.h | 141 int64_t ComputeListenerNextVSyncTimeStamp(const Listener &listen, int64_t now, int64_t referenceTime);
|
/foundation/multimedia/av_codec/test/nativedemo/avdemuxer/server_demo/ |
H A D | file_server_demo.cpp | 63 listen(listenFd_, DEFAULT_LISTEN); in StartServer()
|
/foundation/multimedia/av_codec/test/unittest/common/ |
H A D | http_server_demo.cpp | 69 listen(listenFd_, DEFAULT_LISTEN); in StartServer()
|
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/ |
H A D | dns_resolv_listen.cpp | 374 // listen
in StartListen() 375 if (listen(serverSockFd_, MAX_LISTEN_NUM) < 0) {
in StartListen() 376 NETNATIVE_LOGE("listen errno %{public}d", errno);
in StartListen() 381 NETNATIVE_LOGE("begin listen");
in StartListen()
|
/foundation/communication/ipc/ipc/test/rpc/socket_trans/src/ |
H A D | rpc_mini_socket_trans.c | 171 if (listen(fd, DEFAULT_BACKLOG) != 0) { in OpenTcpServerSocket() 172 RPC_LOG_ERROR("listen failed"); in OpenTcpServerSocket()
|
H A D | rpc_socket_trans.c | 166 if (listen(fd, DEFAULT_BACKLOG) != 0) { in OpenTcpServerSocket() 167 RPC_LOG_ERROR("listen failed"); in OpenTcpServerSocket()
|
/foundation/communication/netmanager_base/services/netmanagernative/src/manager/ |
H A D | vpn_manager.cpp | 295 if (listen(serverfd, MAX_UNIX_SOCKET_CLIENT) < 0) { in StartUnixSocketListen() 297 NETNATIVE_LOGE("listen socket error: %{public}d", errno); in StartUnixSocketListen()
|
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
H A D | spunge_message.c | 165 /* For server socket, should listen on every instance */ in SpungeListenMsgCheckState() 221 if (!OS_SOCK_OPS_FUNC_VALID(osSock, listen) || osSock->ioSock->ops->listen(sock) != ERR_OK) { in SpungeHandleMsgListen() 503 /* Copy the traace handle from server listen socket to newly accepting socket */ in SpungeHandleMsgConnAccepted()
|
/foundation/CastEngine/castengine_wifi_display/services/network/socket/ |
H A D | socket_utils.cpp | 154 if (::listen(fd, backlog) == -1) { in ListenSocket()
|