Home
last modified time | relevance | path

Searched refs:conn (Results 1 - 25 of 134) sorted by relevance

123456

/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dnet.c48 void NetconnSetSock(struct FtSocket *sock, struct FtNetconn *conn) in NetconnSetSock() argument
50 sock->netconn = conn; in NetconnSetSock()
51 conn->sock = (void *)sock; in NetconnSetSock()
54 void NetconnSetSendCacheSize(struct FtNetconn *conn, FILLP_UINT32 cacheSize) in NetconnSetSendCacheSize() argument
56 SpungePcbSetSendCacheSize(conn->pcb, cacheSize); in NetconnSetSendCacheSize()
58 void NetconnSetRecvCacheSize(struct FtNetconn *conn, FILLP_UINT32 cacheSize) in NetconnSetRecvCacheSize() argument
60 SpungePcbSetRecvCacheSize(conn->pcb, cacheSize); in NetconnSetRecvCacheSize()
62 void NetconnSetPktSize(struct FtNetconn *conn, FILLP_UINT32 pktSize) in NetconnSetPktSize() argument
64 SpungePcbSetPktSize(conn->pcb, pktSize); in NetconnSetPktSize()
67 void NetconnSetOpersiteRate(struct FtNetconn *conn, FILLP_UINT3 argument
72 NetconnSetSlowStart(struct FtNetconn *conn, FILLP_BOOL slowStart) NetconnSetSlowStart() argument
77 NetconnSetPackInterval(struct FtNetconn *conn, FILLP_UINT32 interval) NetconnSetPackInterval() argument
82 NetconnSetLocalPort(struct FtNetconn *conn, FILLP_INT port) NetconnSetLocalPort() argument
87 NetconnSetAddrType(struct FtNetconn *conn, FILLP_UINT16 addrType) NetconnSetAddrType() argument
92 NetconnSetDirectlySend(struct FtNetconn *conn, FILLP_INT directlySend) NetconnSetDirectlySend() argument
97 NetconnSetConnectTimeout(struct FtNetconn *conn, FILLP_LLONG timeoutUs) NetconnSetConnectTimeout() argument
102 NetconnIsConnectTimeout(struct FtNetconn *conn) NetconnIsConnectTimeout() argument
109 struct FtNetconn *conn = FILLP_NULL_PTR; FillpNetconnAlloc() local
149 FillpNetconnDestroy(struct FtNetconn *conn) FillpNetconnDestroy() argument
235 FillpNetconnSetSafeErr(struct FtNetconn *conn, FILLP_INT err) FillpNetconnSetSafeErr() argument
242 FillpNetconnSetState(struct FtNetconn *conn, FILLP_UINT8 state) FillpNetconnSetState() argument
[all...]
H A Dpcb.c34 struct FtNetconn *conn = (struct FtNetconn *)argConn; in SpungePcbRecv() local
35 struct FtSocket *sock = (struct FtSocket *)conn->sock; in SpungePcbRecv()
36 FillpErrorType err = FillpQueuePush(conn->pcb->fpcb.recv.recvBox, buf, FILLP_TRUE, (FILLP_UINT)count); in SpungePcbRecv()
61 struct FtNetconn *conn = (struct FtNetconn *)arg; in SpungePcbSend() local
63 struct SockOsSocket *osSock = NETCONN_GET_OSSOCK(conn, SPUNGE_GET_CUR_INSTANCE()->instIndex); in SpungePcbSend()
69 FILLP_PKT_SIMPLE_LOG(((struct FtSocket *)conn->sock)->index, in SpungePcbSend()
97 static FILLP_INT SpungePcbSendmsgInner(struct FtNetconn *conn, struct SpungePcb *spcb, in SpungePcbSendmsgInner() argument
104 if (conn->iovCount == 0) { in SpungePcbSendmsgInner()
110 mh.msg_iov = conn->sendIov; in SpungePcbSendmsgInner()
111 mh.msg_iovlen = conn in SpungePcbSendmsgInner()
155 struct FtNetconn *conn = FILLP_NULL_PTR; SpungePcbSendmsg() local
295 struct FtNetconn *conn = FILLP_NULL_PTR; SpungePcbRemove() local
[all...]
H A Dspunge_stack.c109 struct FtNetconn *conn = FILLP_NULL_PTR; in SpungeFreeAcceptBox() local
113 count = FillpQueuePop(sock->acceptBox, (void *)&conn, 1); in SpungeFreeAcceptBox()
115 FillpNetconnDestroy(conn); in SpungeFreeAcceptBox()
336 FILLP_BOOL SpungeConnCheckUnsendBoxEmpty(struct FtNetconn *conn) in SpungeConnCheckUnsendBoxEmpty() argument
344 if ((conn == FILLP_NULL_PTR) || (conn->pcb == FILLP_NULL_PTR)) { in SpungeConnCheckUnsendBoxEmpty()
348 unsendBox = conn->pcb->fpcb.send.unsendBox; in SpungeConnCheckUnsendBoxEmpty()
366 if (item->netconn == (void *)conn) { in SpungeConnCheckUnsendBoxEmpty()
375 static int SpungeDestroyNoWait(struct FillpPcb *pcb, struct FtSocket *sock, struct FtNetconn *conn) in SpungeDestroyNoWait() argument
383 SpungeConnClosed(conn); in SpungeDestroyNoWait()
392 struct FtNetconn *conn = (struct FtNetconn *)argConn; SpungeCheckDisconn() local
453 struct FtNetconn *conn = (struct FtNetconn *)argConn; SpungeSendConnectMsg() local
527 SpungeConnClosed(struct FtNetconn *conn) SpungeConnClosed() argument
[all...]
/foundation/filemanagement/user_file_service/test/fuzztest/fileaccessextconnection_fuzzer/
H A Dfileaccessextconnection_fuzzer.cpp27 bool OnAbilityConnectDoneFuzzTest(sptr<FileAccessExtConnection> conn) in OnAbilityConnectDoneFuzzTest() argument
31 conn->OnAbilityConnectDone(element, remoteObject, 0); in OnAbilityConnectDoneFuzzTest()
35 bool OnAbilityDisconnectDoneFuzzTest(sptr<FileAccessExtConnection> conn) in OnAbilityDisconnectDoneFuzzTest() argument
38 conn->OnAbilityDisconnectDone(element, 0); in OnAbilityDisconnectDoneFuzzTest()
42 bool IsExtAbilityConnectedFuzzTest(sptr<FileAccessExtConnection> conn) in IsExtAbilityConnectedFuzzTest() argument
44 conn->IsExtAbilityConnected(); in IsExtAbilityConnectedFuzzTest()
48 bool GetFileExtProxyFuzzTest(sptr<FileAccessExtConnection> conn) in GetFileExtProxyFuzzTest() argument
50 conn->GetFileExtProxy(); in GetFileExtProxyFuzzTest()
54 bool ConnectFileExtAbility(sptr<FileAccessExtConnection> conn) in ConnectFileExtAbility() argument
58 conn in ConnectFileExtAbility()
62 DisconnectFileExtAbility(sptr<FileAccessExtConnection> conn) DisconnectFileExtAbility() argument
72 auto conn = OHOS::sptr<OHOS::FileAccessFwk::FileAccessExtConnection>(); LLVMFuzzerTestOneInput() local
[all...]
/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/test/unittest/
H A Dvsync_distributor_test.cpp71 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); in HWTEST_F() local
72 ASSERT_EQ(VSyncDistributorTest::vsyncDistributor->AddConnection(conn), VSYNC_ERROR_OK); in HWTEST_F()
73 ASSERT_EQ(VSyncDistributorTest::vsyncDistributor->AddConnection(conn), VSYNC_ERROR_INVALID_ARGUMENTS); in HWTEST_F()
74 ASSERT_EQ(VSyncDistributorTest::vsyncDistributor->RemoveConnection(conn), VSYNC_ERROR_OK); in HWTEST_F()
98 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); in HWTEST_F() local
99 ASSERT_EQ(VSyncDistributorTest::vsyncDistributor->RemoveConnection(conn), VSYNC_ERROR_INVALID_ARGUMENTS); in HWTEST_F()
111 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); in HWTEST_F() local
112 VSyncDistributorTest::vsyncDistributor->AddConnection(conn); in HWTEST_F()
113 ASSERT_EQ(VSyncDistributorTest::vsyncDistributor->RemoveConnection(conn), VSYNC_ERROR_OK); in HWTEST_F()
137 sptr<VSyncConnection> conn in HWTEST_F() local
150 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
165 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
192 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
205 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
220 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
240 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
253 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
346 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
361 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
400 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
414 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "VSyncDistributorTest"); HWTEST_F() local
429 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
433 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_1234"); HWTEST_F() local
451 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
472 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
493 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
514 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
535 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
539 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "test"); HWTEST_F() local
559 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
563 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "test"); HWTEST_F() local
583 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
587 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "test"); HWTEST_F() local
607 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
611 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "test"); HWTEST_F() local
631 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
636 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "test"); HWTEST_F() local
656 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
661 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "test"); HWTEST_F() local
681 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
686 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "test"); HWTEST_F() local
706 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "WM_" + std::to_string(i+1)); HWTEST_F() local
710 sptr<VSyncConnection> conn = new VSyncConnection(vsyncDistributor, "test"); HWTEST_F() local
[all...]
H A Dvsync_receiver_test.cpp39 static inline sptr<VSyncConnection> conn = nullptr; member in OHOS::Rosen::VsyncReceiverTest
59 conn = new VSyncConnection(vsyncDistributor, "VsyncReceiverTest"); in SetUpTestCase()
60 vsyncReceiver = new VSyncReceiver(conn); in SetUpTestCase()
69 conn = nullptr; in TearDownTestCase()
121 vsyncDistributor->AddConnection(conn); in HWTEST_F()
123 vsyncDistributor->RemoveConnection(conn); in HWTEST_F()
177 vsyncDistributor->AddConnection(conn); in HWTEST_F()
179 vsyncDistributor->RemoveConnection(conn); in HWTEST_F()
195 vsyncDistributor->AddConnection(conn); in HWTEST_F()
197 vsyncDistributor->RemoveConnection(conn); in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/
H A Dtrans_tcp_direct_listener.c88 static int32_t StartVerifySession(SessionConn *conn) in StartVerifySession() argument
90 TRANS_LOGI(TRANS_CTRL, "verify enter. channelId=%{public}d, fd=%{public}d", conn->channelId, conn->appInfo.fd); in StartVerifySession()
91 if (SoftBusGenerateSessionKey(conn->appInfo.sessionKey, SESSION_KEY_LENGTH) != SOFTBUS_OK) { in StartVerifySession()
94 conn->channelId, conn->appInfo.fd); in StartVerifySession()
97 SetSessionKeyByChanId(conn->channelId, conn->appInfo.sessionKey, sizeof(conn->appInfo.sessionKey)); in StartVerifySession()
100 bool isLegacyOs = IsPeerDeviceLegacyOs(conn in StartVerifySession()
154 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); CreateSessionConnNode() local
271 SessionConn conn; TransProcDataRes() local
288 ProcessSocketInEvent(SessionConn *conn, int fd) ProcessSocketInEvent() argument
299 ProcessSocketOutEvent(SessionConn *conn, int fd) ProcessSocketOutEvent() argument
332 ProcessSocketSocketExceptionEvent(SessionConn *conn, int fd) ProcessSocketSocketExceptionEvent() argument
344 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); TdcOnDataEvent() local
[all...]
H A Dtrans_tcp_direct_message.c244 static void SendFailToFlushDevice(SessionConn *conn) in SendFailToFlushDevice() argument
246 if (conn->appInfo.routeType == WIFI_STA) { in SendFailToFlushDevice()
248 Anonymize(conn->appInfo.peerData.deviceId, &tmpId); in SendFailToFlushDevice()
251 if (AuthFlushDevice(conn->appInfo.peerData.deviceId) != SOFTBUS_OK) { in SendFailToFlushDevice()
253 LnnRequestLeaveSpecific(conn->appInfo.peerNetWorkId, CONNECTION_ADDR_WLAN); in SendFailToFlushDevice()
281 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in TransTdcPostBytes() local
282 if (conn == NULL) { in TransTdcPostBytes()
283 TRANS_LOGE(TRANS_BYTES, "malloc conn fail"); in TransTdcPostBytes()
287 if (GetSessionConnById(channelId, conn) != SOFTBUS_OK) { in TransTdcPostBytes()
290 SoftBusFree(conn); in TransTdcPostBytes()
307 GetChannelInfoFromConn(ChannelInfo *info, SessionConn *conn, int32_t channelId) GetChannelInfoFromConn() argument
386 SessionConn conn; NotifyChannelOpened() local
439 SessionConn conn; NotifyChannelBind() local
465 NotifyChannelOpenFailedBySessionConn(const SessionConn *conn, int32_t errCode) NotifyChannelOpenFailedBySessionConn() argument
516 SessionConn conn; NotifyChannelOpenFailed() local
526 TransTdcPostFastData(SessionConn *conn) TransTdcPostFastData() argument
622 SessionConn conn; OpenDataBusReply() local
727 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); GetSessionConnFromDataBusRequest() local
746 NotifyFastDataRecv(SessionConn *conn, int32_t channelId) NotifyFastDataRecv() argument
815 ReportTransEventExtra( TransEventExtra *extra, int32_t channelId, SessionConn *conn, NodeInfo *nodeInfo, char *peerUuid) ReportTransEventExtra() argument
908 HandleDataBusReply( SessionConn *conn, int32_t channelId, TransEventExtra *extra, uint32_t flags, uint64_t seq) HandleDataBusReply() argument
934 SessionConn *conn = GetSessionConnFromDataBusRequest(channelId, request); OpenDataBusRequest() local
[all...]
H A Dtrans_tcp_direct_sessionconn.c123 TRANS_LOGE(TRANS_CTRL, "get session conn by requestId failed: requestId=%{public}u", requestId); in GetSessionConnByRequestId()
139 TRANS_LOGE(TRANS_CTRL, "get session conn by req failed: req=%{public}" PRIu64, req); in GetSessionConnByReq()
145 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in CreateNewSessinConn() local
146 if (conn == NULL) { in CreateNewSessinConn()
149 conn->serverSide = isServerSid; in CreateNewSessinConn()
150 conn->channelId = GenerateChannelId(true); in CreateNewSessinConn()
151 if (conn->channelId <= INVALID_CHANNEL_ID) { in CreateNewSessinConn()
152 SoftBusFree(conn); in CreateNewSessinConn()
156 conn->status = TCP_DIRECT_CHANNEL_STATUS_INIT; in CreateNewSessinConn()
157 conn in CreateNewSessinConn()
165 GetSessionConnByFd(int32_t fd, SessionConn *conn) GetSessionConnByFd() argument
185 GetSessionConnById(int32_t channelId, SessionConn *conn) GetSessionConnById() argument
208 SessionConn *conn = NULL; SetAppInfoById() local
226 SessionConn *conn = NULL; GetAppInfoById() local
244 SessionConn *conn = NULL; SetAuthHandleByChanId() local
262 SessionConn *conn = NULL; GetAuthIdByChanId() local
284 SessionConn *conn = NULL; GetAuthHandleByChanId() local
331 TransTdcAddSessionConn(SessionConn *conn) TransTdcAddSessionConn() argument
519 SessionConn *conn = NULL; SetSessionKeyByChanId() local
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/
H A Dl2cap_inst.c66 L2capConnection *conn = NULL; in L2capGetConnection() local
71 conn = ListGetNodeData(node); in L2capGetConnection()
72 if (conn->aclHandle == aclHandle) { in L2capGetConnection()
73 return conn; in L2capGetConnection()
85 L2capConnection *conn = NULL; in L2capGetConnection2() local
90 conn = ListGetNodeData(node); in L2capGetConnection2()
91 if (memcmp(conn->addr.addr, addr->addr, sizeof(addr->addr)) == 0) { in L2capGetConnection2()
92 return conn; in L2capGetConnection2()
104 L2capConnection *conn = NULL; in L2capGetConnection3() local
110 conn in L2capGetConnection3()
127 L2capGetChannel(const L2capConnection *conn, int16_t lcid) L2capGetChannel() argument
145 L2capGetChannel2(uint16_t lcid, L2capConnection **conn, L2capChannel **chan) L2capGetChannel2() argument
164 L2capGetChannel3(uint16_t aclHandle, uint16_t lcid, L2capConnection **conn, L2capChannel **chan) L2capGetChannel3() argument
181 L2capConnection *conn = NULL; L2capGetNewLcid() local
221 L2capNewChannel(L2capConnection *conn, uint16_t lpsm, uint16_t rpsm) L2capNewChannel() argument
326 L2capConnection *conn = NULL; L2capDisconnectTimeout() local
360 L2capDeleteChannel(L2capConnection *conn, L2capChannel *chan, uint16_t removeAcl) L2capDeleteChannel() argument
388 L2capConnection *conn = NULL; L2capNewConnection() local
409 L2capDeleteConnection(L2capConnection *conn) L2capDeleteConnection() argument
[all...]
H A Dl2cap.c31 L2capConnection *conn = NULL; in L2CAP_ConnectReq() local
50 conn = L2capGetConnection2(addr); in L2CAP_ConnectReq()
51 if (conn == NULL) { in L2CAP_ConnectReq()
52 conn = L2capNewConnection(addr, 0); in L2CAP_ConnectReq()
55 chan = L2capNewChannel(conn, lpsm, rpsm); in L2CAP_ConnectReq()
58 if (conn->state == L2CAP_CONNECTION_IDLE) { in L2CAP_ConnectReq()
59 conn->state = L2CAP_CONNECTION_CONNECTING; in L2CAP_ConnectReq()
61 L2capDeleteConnection(conn); in L2CAP_ConnectReq()
68 if ((conn->state == L2CAP_CONNECTION_CONNECTING) || (conn in L2CAP_ConnectReq()
83 L2capConnection *conn = NULL; L2CAP_ConnectRsp() local
118 L2capConnection *conn = NULL; L2CAP_ConfigReq() local
183 L2capConnection *conn = NULL; L2CAP_ConfigRsp() local
239 L2capConnection *conn = NULL; L2CAP_DisconnectionReq() local
263 L2capConnection *conn = NULL; L2CAP_DisconnectionRsp() local
288 L2capConnection *conn = NULL; L2CAP_LocalBusy() local
335 L2capConnection *conn = NULL; L2CAP_SendData() local
419 L2capConnection *conn = NULL; L2CAP_EchoReq() local
442 L2capConnection *conn = NULL; L2CAP_EchoRsp() local
507 L2capConnection *conn = NULL; L2CAP_DeregisterService() local
574 L2capConnection *conn = NULL; L2CAP_Finalize() local
[all...]
H A Dl2cap_le.c140 L2capLeConnection *conn = NULL; in L2capLeGetConnection2() local
145 conn = ListGetNodeData(node); in L2capLeGetConnection2()
146 if (memcmp(&(conn->addr), addr, sizeof(BtAddr)) == 0) { in L2capLeGetConnection2()
147 return conn; in L2capLeGetConnection2()
156 static L2capLeChannel *L2capLeGetChannel(L2capLeConnection *conn, int16_t lcid) in L2capLeGetChannel() argument
161 node = ListGetFirstNode(conn->chanList); in L2capLeGetChannel()
174 static void L2capLeGetChannel2(uint16_t lcid, L2capLeConnection **conn, L2capLeChannel **chan) in L2capLeGetChannel2() argument
181 *conn = ListGetNodeData(node); in L2capLeGetChannel2()
182 *chan = L2capLeGetChannel(*conn, lcid); in L2capLeGetChannel2()
193 static void L2capLeGetChannel3(uint16_t aclHandle, uint16_t lcid, L2capLeConnection **conn, L2capLeChanne argument
204 L2capLeGetChannel4(L2capLeConnection *conn, int16_t ident) L2capLeGetChannel4() argument
228 L2capLeConnection *conn = NULL; L2capLeGetNewLcid() local
252 L2capLeNewChannel(L2capLeConnection *conn, uint16_t lpsm, uint16_t rpsm) L2capLeNewChannel() argument
302 L2capLeDeleteChannel(L2capLeConnection *conn, L2capLeChannel *chan, uint16_t removeAcl) L2capLeDeleteChannel() argument
320 L2capLeConnection *conn = NULL; L2capLeNewConnection() local
338 L2capLeDeleteConnection(L2capLeConnection *conn) L2capLeDeleteConnection() argument
393 L2capLeConnection *conn = NULL; L2capLeResponseTimeout() local
447 L2capSendCreditBasedConnectionReq(L2capLeConnection *conn, L2capLeChannel *chan) L2capSendCreditBasedConnectionReq() argument
470 L2capSendCreditBasedConnectionRsp( L2capLeConnection *conn, L2capLeChannel *chan, uint8_t ident, uint16_t result) L2capSendCreditBasedConnectionRsp() argument
491 L2capLeSendDisconnectionReq(L2capLeConnection *conn, const L2capLeChannel *chan) L2capLeSendDisconnectionReq() argument
510 L2capLeSendDisconnectionRsp(const L2capLeConnection *conn, const L2capLeChannel *chan, uint8_t ident) L2capLeSendDisconnectionRsp() argument
527 L2capLeSendFlowControlCredit(L2capLeConnection *conn, const L2capLeChannel *chan, uint16_t credit) L2capLeSendFlowControlCredit() argument
544 L2capLeTxWithCredit(const L2capLeConnection *conn, L2capLeChannel *chan) L2capLeTxWithCredit() argument
642 L2capLeConnection *conn = NULL; L2capLeProcessConnectionParameterUpdateReq() local
675 L2capLeConnection *conn = NULL; L2capLeProcessConnectionParameterUpdateRsp() local
698 L2capLeConnection *conn = NULL; L2capLeProcessCreditBasedConnectionReq() local
759 L2capLeConnection *conn = NULL; L2capLeProcessCreditBasedConnectionRsp() local
818 L2capLeConnection *conn = NULL; L2capLeProcessDisconnectionReq() local
864 L2capLeConnection *conn = NULL; L2capLeProcessDisconnectionRsp() local
904 L2capLeConnection *conn = NULL; L2capLeProcessFlowControlCredit() local
1004 L2capLeConnection *conn = NULL; L2capLeProcessFixChannelData() local
1044 L2capLeConnection *conn = NULL; L2capLeProcessLeData() local
1111 L2capLeCleanAllChannels(L2capLeConnection *conn, uint8_t status) L2capLeCleanAllChannels() argument
1142 L2capLeAclDisconnectProcess(L2capLeConnection *conn, uint8_t status, uint8_t reason) L2capLeAclDisconnectProcess() argument
1166 L2capLeAclConnectProcess(L2capLeConnection *conn) L2capLeAclConnectProcess() argument
1187 L2capLeConnection *conn = NULL; L2capLeConnectComplete() local
1233 L2capLeConnection *conn = NULL; L2capLeDisconnectComplete() local
1257 L2capLeConnection *conn = NULL; L2CAP_LeCreditBasedConnectionReq() local
1315 L2capLeConnection *conn = NULL; L2CAP_LeCreditBasedConnectionRsp() local
1362 L2capLeConnection *conn = NULL; L2CAP_LeDisconnectionReq() local
1384 L2capLeConnection *conn = NULL; L2CAP_LeDisconnectionRsp() local
1406 L2capLeConnection *conn = NULL; L2CAP_LeSendData() local
1498 L2capLeConnection *conn = NULL; L2CAP_LeDeregisterService() local
1627 L2capLeConnection *conn = NULL; L2CAP_LeSendFixChannelData() local
1698 L2capLeConnection *conn = NULL; L2CAP_LeConnectionParameterUpdateReq() local
1754 L2capLeConnection *conn = NULL; L2CAP_LeConnectionParameterUpdateRsp() local
1803 L2capLeConnection *conn = NULL; L2CAP_LeFinalize() local
[all...]
H A Dl2cap_core.c28 static uint8_t L2capGetNewIdentifier(L2capConnection *conn) in L2capGetNewIdentifier() argument
32 ident = conn->nextIdentifier; in L2capGetNewIdentifier()
34 conn->nextIdentifier = L2CAP_MIN_IDENTIFIER; in L2capGetNewIdentifier()
36 conn->nextIdentifier += 1; in L2capGetNewIdentifier()
60 L2capConnection *conn = NULL; in L2capResponseTimeout() local
70 conn = ListGetNodeData(node); in L2capResponseTimeout()
71 req = L2capGetPendingRequest2(conn->pendingList, parameter); in L2capResponseTimeout()
73 ListRemoveNode(conn->pendingList, req); in L2capResponseTimeout()
85 L2capDisconnect(conn->aclHandle, 0x13); in L2capResponseTimeout()
89 chan = L2capGetChannel(conn, re in L2capResponseTimeout()
107 L2capSendEchoReq(L2capConnection *conn, const uint8_t *data, uint16_t dataLen) L2capSendEchoReq() argument
122 L2capSendEchoRsp(L2capConnection *conn, uint8_t ident, const uint8_t *data, uint16_t dataLen) L2capSendEchoRsp() argument
135 L2capSendConnectionReq(L2capConnection *conn, L2capChannel *chan) L2capSendConnectionReq() argument
157 L2capSendConnectionRsp(L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t result, uint16_t status) L2capSendConnectionRsp() argument
181 L2capSendConfigurationReq(L2capConnection *conn, const L2capChannel *chan) L2capSendConfigurationReq() argument
277 L2capSendConfigurationRsp( const L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t result, const L2capConfigInfo *cfg) L2capSendConfigurationRsp() argument
326 L2capSendDisconnectionReq(L2capConnection *conn, L2capChannel *chan) L2capSendDisconnectionReq() argument
348 L2capSendDisconnectionRsp(const L2capConnection *conn, const L2capChannel *chan, uint8_t ident) L2capSendDisconnectionRsp() argument
366 L2capSendInformationReq(L2capConnection *conn, uint16_t type) L2capSendInformationReq() argument
385 L2capSendInformationRsp(const L2capConnection *conn, uint8_t ident, uint16_t infoType) L2capSendInformationRsp() argument
507 L2capSendSFrame(const L2capConnection *conn, L2capChannel *chan, uint8_t pBit, uint8_t fBit, uint8_t sBit) L2capSendSFrame() argument
586 L2capErfcTxOneFrame(L2capConnection *conn, L2capChannel *chan, uint8_t txSeq) L2capErfcTxOneFrame() argument
665 L2capConnection *conn = NULL; L2capErfcMonitorTimeout() local
714 L2capConnection *conn = NULL; L2capErfcRetransmissionTimeout() local
762 L2capErfcDoTx(L2capConnection *conn, L2capChannel *chan, uint16_t txWindow, const ListNode *node) L2capErfcDoTx() argument
809 L2capErfcTx(L2capConnection *conn, L2capChannel *chan) L2capErfcTx() argument
849 L2capStreamTx(const L2capConnection *conn, L2capChannel *chan) L2capStreamTx() argument
938 L2capSendIFrame(L2capConnection *conn, L2capChannel *chan, Packet *pkt) L2capSendIFrame() argument
1004 L2capErfcProcessSFrame(L2capConnection *conn, L2capChannel *chan, uint8_t ctrl[2]) L2capErfcProcessSFrame() argument
1090 L2capErfcProcessIFrame(L2capConnection *conn, L2capChannel *chan, const Packet *pkt, uint8_t ctrl[2]) L2capErfcProcessIFrame() argument
1264 L2capConfigurationRspReject(const L2capConnection *conn, uint8_t ident, uint16_t rcid) L2capConfigurationRspReject() argument
1283 L2capConfigurationRspUnknownOptions( const L2capConnection *conn, uint8_t ident, uint16_t rcid, L2capOptions *unknown) L2capConfigurationRspUnknownOptions() argument
1308 L2capConfigurationRspContinuation(const L2capConnection *conn, uint8_t ident, uint16_t rcid) L2capConfigurationRspContinuation() argument
1338 L2capProcessConfigurationReqWithContinue( L2capConnection *conn, L2capChannel *chan, L2capSignalHeader *signal, const uint8_t *data, uint16_t optLength) L2capProcessConfigurationReqWithContinue() argument
1370 L2capProcessConfigurationReqContinueOption( L2capConnection *conn, L2capChannel *chan, L2capSignalHeader *signal, const uint8_t *data, uint16_t optLength) L2capProcessConfigurationReqContinueOption() argument
1392 L2capProcessConfigurationReqParse( L2capConnection *conn, L2capChannel *chan, L2capSignalHeader *signal, const uint8_t *data, uint16_t optLength) L2capProcessConfigurationReqParse() argument
1443 L2capConnection *conn = NULL; L2capProcessConfigurationReq() local
1487 L2capConfigurationReqContinuation(L2capConnection *conn, const L2capChannel *chan) L2capConfigurationReqContinuation() argument
1510 L2capConnection *conn = NULL; L2capProcessConfigurationRsp() local
1574 L2capConnection *conn = NULL; L2capProcessConnectionReq() local
1634 L2capConnection *conn = NULL; L2capProcessConnectionRsp() local
1698 L2capConnection *conn = NULL; L2capProcessDisconnectionReq() local
1745 L2capConnection *conn = NULL; L2capProcessDisconnectionRsp() local
1785 L2capConnection *conn = NULL; L2capProcessInformationReq() local
1799 L2capIncomingConnection(const L2capConnection *conn, const L2capChannel *chan) L2capIncomingConnection() argument
1824 L2capConnection *conn = NULL; L2capProcessInformationRsp() local
1878 L2capConnection *conn = NULL; L2capProcessEchoReq() local
1897 L2capConnection *conn = NULL; L2capProcessEchoRsp() local
1915 L2capConnection *conn = NULL; L2capProcessCommandReject() local
2066 L2capProcessErfcData(L2capConnection *conn, L2capChannel *chan, Packet *pkt) L2capProcessErfcData() argument
2103 L2capConnection *conn = NULL; L2capProcessData() local
2206 L2capConnection *conn = NULL; L2capConnectComplete() local
2243 L2capAclDisconnected(L2capConnection *conn, uint8_t status, uint8_t reason) L2capAclDisconnected() argument
2283 L2capConnection *conn = NULL; L2capDisconnectComplete() local
[all...]
H A Dl2cap_core.h70 int L2capSendEchoReq(L2capConnection *conn, const uint8_t *data, uint16_t dataLen);
71 int L2capSendEchoRsp(L2capConnection *conn, uint8_t ident, const uint8_t *data, uint16_t dataLen);
72 int L2capSendConnectionReq(L2capConnection *conn, L2capChannel *chan);
73 int L2capSendConnectionRsp(L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t result, uint16_t status);
74 int L2capSendConfigurationReq(L2capConnection *conn, const L2capChannel *chan);
76 const L2capConnection *conn, L2capChannel *chan, uint8_t ident, uint16_t result, const L2capConfigInfo *cfg);
77 int L2capSendDisconnectionReq(L2capConnection *conn, L2capChannel *chan);
78 int L2capSendDisconnectionRsp(const L2capConnection *conn, const L2capChannel *chan, uint8_t ident);
79 int L2capSendInformationReq(L2capConnection *conn, uint16_t type);
80 int L2capSendInformationRsp(const L2capConnection *conn, uint8_
[all...]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
H A Dnet.h93 void FillpNetconnSetSafeErr(struct FtNetconn *conn, FILLP_INT err);
95 void FillpNetconnSetState(struct FtNetconn *conn, FILLP_UINT8 state);
101 void NetconnSetSendCacheSize(struct FtNetconn *conn, FILLP_UINT32 cacheSize);
102 void NetconnSetRecvCacheSize(struct FtNetconn *conn, FILLP_UINT32 cacheSize);
103 void NetconnSetPktSize(struct FtNetconn *conn, FILLP_UINT32 pktSize);
104 void NetconnSetOpersiteRate(struct FtNetconn *conn, FILLP_UINT32 rate);
105 void NetconnSetSlowStart(struct FtNetconn *conn, FILLP_BOOL slowStart);
106 void NetconnSetPackInterval(struct FtNetconn *conn, FILLP_UINT32 interval);
107 void NetconnSetLocalPort(struct FtNetconn *conn, FILLP_INT port);
108 void NetconnSetAddrType(struct FtNetconn *conn, FILLP_UINT1
[all...]
/foundation/ability/ability_lite/frameworks/abilitymgr_lite/src/
H A Dability_service_manager.cpp49 int AbilityServiceManager::ConnectAbility(const Want &want, const IAbilityConnection &conn, in ConnectAbility() argument
52 if (conn.OnAbilityDisconnectDone == nullptr || conn.OnAbilityConnectDone == nullptr) { in ConnectAbility()
57 StoreArgs *storeArgs = AddStoreArgs(conn, storeArg); in ConnectAbility()
79 int AbilityServiceManager::DisconnectAbility(const IAbilityConnection &conn, uint64_t token) in DisconnectAbility() argument
81 StoreArgs *storeArgs = RemoveStoreArgs(&conn, nullptr); in DisconnectAbility()
92 StoreArgs *AbilityServiceManager::AddStoreArgs(const IAbilityConnection &conn, void *storeArg) in AddStoreArgs() argument
95 if (GetStoreArgs(conn) != nullptr) { in AddStoreArgs()
104 storeArgs->conn = &conn; in AddStoreArgs()
122 RemoveStoreArgs(const IAbilityConnection *conn, StoreArgs *storeArgs) RemoveStoreArgs() argument
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/
H A Dtrans_tcp_direct_message_static_test.cpp86 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn() local
87 if (conn == nullptr) { in TestSetSessionConn()
90 conn->serverSide = true; in TestSetSessionConn()
91 conn->channelId = 1; in TestSetSessionConn()
92 conn->status = TCP_DIRECT_CHANNEL_STATUS_INIT; in TestSetSessionConn()
93 conn->timeout = 0; in TestSetSessionConn()
94 conn->req = INVALID_VALUE; in TestSetSessionConn()
95 conn->authHandle.authId = 1; in TestSetSessionConn()
96 conn->requestId = 1; in TestSetSessionConn()
97 conn in TestSetSessionConn()
130 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
186 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
508 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
647 SessionConn *conn = TestSetSessionConn(); HWTEST_F() local
775 SessionConn conn; HWTEST_F() local
827 SessionConn *conn = TestSetSessionConn(); HWTEST_F() local
[all...]
H A Dtrans_core_tcp_direct_test.cpp91 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn() local
92 if (conn == nullptr) { in TestSetSessionConn()
96 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn)); in TestSetSessionConn()
97 conn->serverSide = true; in TestSetSessionConn()
98 conn->channelId = 1; in TestSetSessionConn()
99 conn->status = TCP_DIRECT_CHANNEL_STATUS_INIT; in TestSetSessionConn()
100 conn->timeout = 0; in TestSetSessionConn()
101 conn->req = INVALID_VALUE; in TestSetSessionConn()
102 conn->authHandle.authId = 1; in TestSetSessionConn()
103 conn in TestSetSessionConn()
172 SessionConn *conn = TestSetSessionConn(); HWTEST_F() local
481 SessionConn* conn = TestSetSessionConn(); HWTEST_F() local
538 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
585 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
[all...]
H A Dtrans_tcp_direct_p2p_test.cpp81 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn() local
82 if (conn == nullptr) { in TestSetSessionConn()
86 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn)); in TestSetSessionConn()
87 conn->serverSide = true; in TestSetSessionConn()
88 conn->channelId = 1; in TestSetSessionConn()
89 conn->status = TCP_DIRECT_CHANNEL_STATUS_INIT; in TestSetSessionConn()
90 conn->timeout = 0; in TestSetSessionConn()
91 conn->req = 1; in TestSetSessionConn()
92 conn->authHandle.authId = 1; in TestSetSessionConn()
93 conn in TestSetSessionConn()
227 SessionConn *conn = TestSetSessionConn(); HWTEST_F() local
450 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
482 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
565 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
638 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); HWTEST_F() local
[all...]
H A Dtrans_tcp_direct_message_test.cpp73 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn() local
74 if (conn == nullptr) { in TestSetSessionConn()
77 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn)); in TestSetSessionConn()
78 conn->serverSide = true; in TestSetSessionConn()
79 conn->channelId = 1; in TestSetSessionConn()
80 conn->status = TCP_DIRECT_CHANNEL_STATUS_INIT; in TestSetSessionConn()
81 conn->timeout = 0; in TestSetSessionConn()
82 conn->req = INVALID_VALUE; in TestSetSessionConn()
83 conn->authHandle.authId = 1; in TestSetSessionConn()
84 conn in TestSetSessionConn()
218 SessionConn *conn = TestSetSessionConn(); HWTEST_F() local
248 SessionConn *conn = TestSetSessionConn(); HWTEST_F() local
278 SessionConn *conn = (SessionConn*)SoftBusMalloc(sizeof(SessionConn)); HWTEST_F() local
308 SessionConn *conn = (SessionConn*)SoftBusMalloc(sizeof(SessionConn)); HWTEST_F() local
[all...]
/foundation/arkui/ui_lite/tools/server/
H A Dtcp_server.py66 def send_message(self, conn, info):
69 conn.send(clientdata)
82 def tcp_connect(self, conn, addr):
87 self.start_test(conn)
89 data = conn.recv(1024)
95 self.send_test_info(conn)
98 self.send_test_info(conn)
101 def send_all_test_finish(self, conn):
103 self.send_message(conn, send_config)
115 def send_test_info(self, conn)
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_adapter_standard.cpp170 uint32_t qosType, std::shared_ptr<SoftBusClient> &conn) in Reuse()
176 conn = connect; in Reuse()
181 void SoftBusAdapter::GetExpireTime(std::shared_ptr<SoftBusClient> &conn) in GetExpireTime() argument
184 auto expireTime = conn->GetExpireTime() > now ? conn->GetExpireTime() : now; in GetExpireTime()
195 std::shared_ptr<SoftBusClient> conn; in SendData() local
199 connects_.Compute(deviceId.deviceId, [&pipeInfo, &deviceId, &conn, qosType, isOHOSType, &isReuse](const auto &key, in SendData()
209 conn = connect; in SendData()
214 conn = connect; in SendData()
218 Reuse(pipeInfo, deviceId, qosType, conn); in SendData()
169 Reuse(const PipeInfo &pipeInfo, const DeviceId &deviceId, uint32_t qosType, std::shared_ptr<SoftBusClient> &conn) Reuse() argument
248 std::shared_ptr<SoftBusClient> conn; StartCloseSessionTask() local
[all...]
/foundation/ability/ability_runtime/frameworks/native/ability/native/ui_extension_ability/
H A Dui_extension_servicehost_stub_impl.cpp24 UIExtensionServiceHostStubImpl::UIExtensionServiceHostStubImpl(wptr<JSUIServiceUIExtConnection> conn) in UIExtensionServiceHostStubImpl() argument
25 :conn_(conn) in UIExtensionServiceHostStubImpl()
31 sptr<JSUIServiceUIExtConnection> conn = conn_.promote(); in SendData() local
32 if (conn != nullptr) { in SendData()
33 return conn->OnSendData(data); in SendData()
/foundation/ability/ability_runtime/frameworks/native/ability/native/ability_runtime/
H A Dui_ability_servicehost_stub_impl.cpp24 UIAbilityServiceHostStubImpl::UIAbilityServiceHostStubImpl(wptr<JSUIServiceExtAbilityConnection> conn) in UIAbilityServiceHostStubImpl() argument
25 :conn_(conn) in UIAbilityServiceHostStubImpl()
31 sptr<JSUIServiceExtAbilityConnection> conn = conn_.promote(); in SendData() local
32 if (conn != nullptr) { in SendData()
33 return conn->OnSendData(data); in SendData()
/foundation/ability/ability_lite/frameworks/abilitymgr_lite/include/
H A Dability_service_manager.h29 const IAbilityConnection *conn; member
42 int ConnectAbility(const Want &want, const IAbilityConnection &conn, uint64_t token, void *storeArg);
43 int DisconnectAbility(const IAbilityConnection &conn, uint64_t token);
47 StoreArgs *AddStoreArgs(const IAbilityConnection &conn, void *storeArg);
48 StoreArgs *GetStoreArgs(const IAbilityConnection &conn) const;
49 StoreArgs *RemoveStoreArgs(const IAbilityConnection *conn, StoreArgs *storeArgs);

Completed in 16 milliseconds

123456