Home
last modified time | relevance | path

Searched refs:listenFd (Results 1 - 17 of 17) sorted by relevance

/foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/include/
H A Dsocket_exec.h200 void SetTcpExtraOptions(int listenFd, const TCPExtraOptions& option) in SetTcpExtraOptions() argument
202 tcpExtraOptions_.EnsureInsert(listenFd, option); in SetTcpExtraOptions()
205 bool GetTcpExtraOptions(int listenFd, TCPExtraOptions& option) in GetTcpExtraOptions() argument
207 return tcpExtraOptions_.Find(listenFd, option); in GetTcpExtraOptions()
210 void AddNewListenSocket(int listenFd) in AddNewListenSocket() argument
212 tcpClients_.Insert(listenFd, {}); in AddNewListenSocket()
215 void AddNewAcceptSocket(int listenFd, int acceptFd) in AddNewAcceptSocket() argument
221 if (tcpClients_.Find(listenFd, fdSet)) { in AddNewAcceptSocket()
222 tcpClients_.ChangeValueByLambda(listenFd, fn); in AddNewAcceptSocket()
228 tcpClients_.Iterate([acceptFd](int listenFd, st in RemoveAcceptSocket()
235 GetClients(int listenFd) GetClients() argument
242 RemoveServerSocket(int listenFd) RemoveServerSocket() argument
[all...]
/foundation/communication/ipc/ipc/native/src/mock/include/
H A Ddbinder_base_invoker_process.h23 template <class T> void DBinderBaseInvoker<T>::ProcessTransaction(dbinder_transaction_data *tr, int32_t listenFd) in ProcessTransaction() argument
36 ZLOGE(LOG_LABEL, "DBinderSendAllocator failed, listenFd:%{public}d", listenFd); in ProcessTransaction()
37 DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_SEND_ALLOCATOR_FAIL, __FUNCTION__); in ProcessTransaction()
41 ZLOGE(LOG_LABEL, "SetAllocator failed, listenFd:%{public}d", listenFd); in ProcessTransaction()
42 DfxReportFailListenEvent(DbinderErrorCode::RPC_DRIVER, listenFd, RADAR_SET_ALLOCATOR_FAIL, __FUNCTION__); in ProcessTransaction()
60 if (CheckAndSetCallerInfo(listenFd, tr->cookie) != ERR_NONE) { in ProcessTransaction()
61 ZLOGE(LOG_LABEL, "check and set caller info failed, cmd:%{public}u listenFd:%{public}d", tr->code, listenFd); in ProcessTransaction()
120 ProcessReply(dbinder_transaction_data *tr, int32_t listenFd) ProcessReply() argument
[all...]
H A Ddbinder_base_invoker_interface.h30 ZLOGE(LOG_LABEL, "session is not exist for listenFd:%{public}d handle:%{public}d", socketId, handle); in WriteTransaction()
37 ZLOGE(LOG_LABEL, "seqNum invalid, listenFd:%{public}d handle:%{public}d", socketId, handle); in WriteTransaction()
45 ZLOGE(LOG_LABEL, "send rawdata failed, listenFd:%{public}d handle:%{public}d", socketId, handle); in WriteTransaction()
52 ZLOGE(LOG_LABEL, "send normal data failed, listenFd:%{public}d handle:%{public}d", socketId, handle); in WriteTransaction()
58 ZLOGE(LOG_LABEL, "move transaction data to buffer failed, listenFd:%{public}d handle:%{public}d", in WriteTransaction()
147 int32_t listenFd = processInfo->listenFd; in OnTransaction() local
150 if (package == nullptr || listenFd < 0) { in OnTransaction()
151 ZLOGE(LOG_LABEL, "package is null or listenFd:%{public}d invalid!", listenFd); in OnTransaction()
[all...]
H A Ddbinder_base_invoker_define.h112 void ProcessTransaction(dbinder_transaction_data *tr, int32_t listenFd);
113 void ProcessReply(dbinder_transaction_data *tr, int32_t listenFd);
/foundation/communication/dsoftbus/core/connection/common/src/
H A Dsoftbus_base_listener.c60 int32_t listenFd; member
212 node->info.listenFd = -1; in CreateSpecifiedListenerModule()
379 int32_t listenFd = -1; in StartServerListenUnsafe() local
383 listenFd = socketIf->OpenServerSocket(info); in StartServerListenUnsafe()
384 if (listenFd < 0) { in StartServerListenUnsafe()
385 CONN_LOGE(CONN_COMMON, "create server socket failed: module=%{public}d, listenFd=%{public}d", in StartServerListenUnsafe()
386 module, listenFd); in StartServerListenUnsafe()
387 status = listenFd; in StartServerListenUnsafe()
390 status = SoftBusSocketListen(listenFd, DEFAULT_BACKLOG); in StartServerListenUnsafe()
395 listenPort = socketIf->GetSockPort(listenFd); in StartServerListenUnsafe()
574 int32_t listenFd = node->info.listenFd; ShutdownBaseListener() local
837 ProcessSpecifiedServerAcceptEvent(ListenerModule module, int32_t listenFd, ConnectType connectType, const SocketInterface *socketIf, const SoftbusBaseListener *listener, int32_t wakeupTrace) ProcessSpecifiedServerAcceptEvent() argument
938 CloseInvalidListenForcely(SoftbusListenerNode *node, int32_t listenFd, const char *anomizedIp, int32_t reason) CloseInvalidListenForcely() argument
969 int32_t listenFd = -1; ProcessSpecifiedListenerNodeEvent() local
[all...]
/foundation/communication/ipc/ipc/native/test/fuzztest/core/ipcprocessskeleton_fuzzer/
H A Dipcprocessskeleton_fuzzer.cpp33 int32_t listenFd; in AttachToDetachAppInfoToStubIndexTest001() local
35 if (!GenerateUint32(pid) || !GenerateUint32(uid) || !GenerateUint32(tokenId) || !GenerateInt32(listenFd) || in AttachToDetachAppInfoToStubIndexTest001()
43 current->AttachAppInfoToStubIndex(pid, uid, tokenId, deviceId, stubIndex, listenFd); in AttachToDetachAppInfoToStubIndexTest001()
44 current->QueryAppInfoToStubIndex(pid, uid, tokenId, deviceId, stubIndex, listenFd); in AttachToDetachAppInfoToStubIndexTest001()
46 current->AttachAppInfoToStubIndex(pid, uid, tokenId, deviceId, stubIndex, listenFd); in AttachToDetachAppInfoToStubIndexTest001()
47 current->DetachAppInfoToStubIndex(pid, uid, tokenId, deviceId, stubIndex, listenFd); in AttachToDetachAppInfoToStubIndexTest001()
56 int32_t listenFd; in AttachToDetachAppInfoToStubIndexTest002() local
58 if (!GenerateUint32(pid) || !GenerateUint32(uid) || !GenerateUint32(tokenId) || !GenerateInt32(listenFd) || in AttachToDetachAppInfoToStubIndexTest002()
66 current->AttachAppInfoToStubIndex(pid, uid, tokenId, deviceId, listenFd); in AttachToDetachAppInfoToStubIndexTest002()
67 current->DetachAppInfoToStubIndex(listenFd); in AttachToDetachAppInfoToStubIndexTest002()
[all...]
/foundation/communication/ipc/ipc/native/src/core/include/
H A Dipc_process_skeleton.h64 int32_t listenFd; member
194 uint64_t stubIndex, int32_t listenFd);
196 const std::string &deviceId, int32_t listenFd);
198 std::list<uint64_t> DetachAppInfoToStubIndex(int32_t listenFd);
200 uint64_t stubIndex, int32_t listenFd);
202 int32_t listenFd);
204 uint64_t stubIndex, int32_t listenFd);
H A Ddbinder_error_code.h155 inline void DfxReportFailListenEvent(int type, int listenFd, int errorCode, const char *func) in DfxReportFailListenEvent() argument
165 "ERROR_CODE", abs(errorCode), "LISTEN_FD", listenFd, "TYPE", type); in DfxReportFailListenEvent()
/foundation/communication/ipc/ipc/native/test/unittest/common/
H A Dipc_process_skeleton_unittest.cpp1017 int32_t listenFd = 1; in HWTEST_F() local
1021 { stubIndex, listenFd } in HWTEST_F()
1025 bool ret = skeleton->DetachAppInfoToStubIndex(pid, uid, tokenId, deviceId, stubIndex, listenFd); in HWTEST_F()
1046 int32_t listenFd = 1; in HWTEST_F() local
1050 { stubIndex, listenFd } in HWTEST_F()
1054 bool ret = skeleton->DetachAppInfoToStubIndex(pid, uid, tokenId, deviceId, index, listenFd); in HWTEST_F()
1074 int32_t listenFd = 1; in HWTEST_F() local
1078 { stubIndex, listenFd } in HWTEST_F()
1082 auto ret = skeleton->DetachAppInfoToStubIndex(pid, uid, tokenId, deviceId, listenFd); in HWTEST_F()
1103 int32_t listenFd in HWTEST_F() local
1125 int32_t listenFd = 1; HWTEST_F() local
1154 int32_t listenFd = 1; HWTEST_F() local
1184 int32_t listenFd = 1; HWTEST_F() local
1212 int32_t listenFd = 1; HWTEST_F() local
[all...]
H A Dipc_binder_databus_invoker_unittest.cpp1171 int32_t listenFd = 1;
1185 { stubIndex, listenFd }
1208 int32_t listenFd = 1;
1221 { stubIndex, listenFd }
1243 int32_t listenFd = 1;
1256 { stubIndex, listenFd }
1280 int32_t listenFd = 1;
1293 { stubIndex, listenFd }
/foundation/communication/wifi/wifi/base/cRPC/src/
H A Dserver.c48 int fd = accept(server->listenFd, NULL, NULL); in OnAccept()
90 server->listenFd = ret; in CreateRpcServer()
100 if (AddFdEvent(server->loop, server->listenFd, READ_EVENT) < 0) { in CreateRpcServer()
233 if (fd == server->listenFd) { in RunRpcLoop()
252 if (server->listenFd > 0) { in ReleaseRpcServer()
253 close(server->listenFd); in ReleaseRpcServer()
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/include/mini_discover/
H A Dcoap_app.h42 int32_t listenFd; member
/foundation/communication/wifi/wifi/base/cRPC/include/
H A Dserver.h42 int listenFd; member
/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_process_skeleton.cpp1017 const std::string &deviceId, uint64_t stubIndex, int32_t listenFd) in DetachAppInfoToStubIndex()
1028 if (it2 != indexes.end() && it2->second == listenFd) { in DetachAppInfoToStubIndex()
1037 " listenFd:%{public}u result:%{public}d", pid, uid, tokenId, ConvertToSecureString(deviceId).c_str(), in DetachAppInfoToStubIndex()
1038 stubIndex, listenFd, result); in DetachAppInfoToStubIndex()
1043 const std::string &deviceId, int32_t listenFd) in DetachAppInfoToStubIndex()
1057 if (it2->second == listenFd) { in DetachAppInfoToStubIndex()
1070 ZLOGI(LOG_LABEL, "pid:%{public}u uid:%{public}u tokenId:%{public}u deviceId:%{public}s listenFd:%{public}d" in DetachAppInfoToStubIndex()
1072 pid, uid, tokenId, ConvertToSecureString(deviceId).c_str(), listenFd, indexCnt, appInfoErase); in DetachAppInfoToStubIndex()
1094 std::list<uint64_t> IPCProcessSkeleton::DetachAppInfoToStubIndex(int32_t listenFd) in DetachAppInfoToStubIndex() argument
1104 if (it2->second == listenFd) { in DetachAppInfoToStubIndex()
1016 DetachAppInfoToStubIndex(uint32_t pid, uint32_t uid, uint32_t tokenId, const std::string &deviceId, uint64_t stubIndex, int32_t listenFd) DetachAppInfoToStubIndex() argument
1042 DetachAppInfoToStubIndex(uint32_t pid, uint32_t uid, uint32_t tokenId, const std::string &deviceId, int32_t listenFd) DetachAppInfoToStubIndex() argument
1124 AttachAppInfoToStubIndex(uint32_t pid, uint32_t uid, uint32_t tokenId, const std::string &deviceId, uint64_t stubIndex, int32_t listenFd) AttachAppInfoToStubIndex() argument
1145 AttachAppInfoToStubIndex(uint32_t pid, uint32_t uid, uint32_t tokenId, const std::string &deviceId, int32_t listenFd) AttachAppInfoToStubIndex() argument
1166 QueryAppInfoToStubIndex(uint32_t pid, uint32_t uid, uint32_t tokenId, const std::string &deviceId, uint64_t stubIndex, int32_t listenFd) QueryAppInfoToStubIndex() argument
[all...]
H A Dipc_object_stub.cpp238 int32_t listenFd = invoker->GetClientFd(); in DBinderIncRefsTransaction() local
239 // update listenFd in DBinderIncRefsTransaction()
240 ZLOGW(LABEL, "update app info, listenFd:%{public}d stubIndex:%{public}" PRIu64 " tokenId:%{public}u", in DBinderIncRefsTransaction()
241 listenFd, stubIndex, tokenId); in DBinderIncRefsTransaction()
242 AppAuthInfo appAuthInfo = { callerPid, callerUid, tokenId, listenFd, stubIndex, nullptr, callerDevId }; in DBinderIncRefsTransaction()
267 int32_t listenFd = invoker->GetClientFd(); in DBinderDecRefsTransaction() local
269 AppAuthInfo appAuthInfo = { callerPid, callerUid, tokenId, listenFd, stubIndex, this, callerDevId }; in DBinderDecRefsTransaction()
/foundation/communication/ipc/ipc/native/test/fuzztest/mock/dbinderdatabusinvoker_fuzzer/
H A Ddbinderdatabusinvoker_fuzzer.cpp247 uint32_t listenFd = *(reinterpret_cast<const uint32_t*>(data)); in ProcessTransactionTest() local
249 invoker.ProcessTransaction(tr, listenFd); in ProcessTransactionTest()
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/mini_discover/
H A Dcoap_app.c367 int32_t listenFd = CoapCreateUdpServer(COAP_SRV_DEFAULT_ADDR, COAP_SRV_DEFAULT_PORT); in CoapServerInit() local
368 if (listenFd < 0) { in CoapServerInit()
374 g_coapCtx.task.taskfd = listenFd; in CoapServerInit()

Completed in 15 milliseconds