Home
last modified time | relevance | path

Searched refs:chan (Results 1 - 25 of 29) sorted by relevance

12

/foundation/communication/bluetooth_service/services/bluetooth/stack/src/l2cap/
H A Dl2cap.c32 L2capChannel *chan = NULL; in L2CAP_ConnectReq() local
55 chan = L2capNewChannel(conn, lpsm, rpsm); in L2CAP_ConnectReq()
56 *lcid = chan->lcid; in L2CAP_ConnectReq()
75 L2capSendConnectionReq(conn, chan); in L2CAP_ConnectReq()
84 L2capChannel *chan = NULL; in L2CAP_ConnectRsp() local
98 L2capGetChannel2(lcid, &conn, &chan); in L2CAP_ConnectRsp()
99 if (chan == NULL) { in L2CAP_ConnectRsp()
103 if (chan->state != L2CAP_CHANNEL_CONNECT_IN_REQ) { in L2CAP_ConnectRsp()
107 L2capSendConnectionRsp(conn, chan, id, result, status); in L2CAP_ConnectRsp()
110 L2capDeleteChannel(conn, chan, in L2CAP_ConnectRsp()
119 L2capChannel *chan = NULL; L2CAP_ConfigReq() local
184 L2capChannel *chan = NULL; L2CAP_ConfigRsp() local
240 L2capChannel *chan = NULL; L2CAP_DisconnectionReq() local
264 L2capChannel *chan = NULL; L2CAP_DisconnectionRsp() local
289 L2capChannel *chan = NULL; L2CAP_LocalBusy() local
336 L2capChannel *chan = NULL; L2CAP_SendData() local
508 L2capChannel *chan = NULL; L2CAP_DeregisterService() local
[all...]
H A Dl2cap_core.c42 static void L2capDisconnectAbnormal(const L2capChannel *chan, uint8_t reason) in L2capDisconnectAbnormal() argument
46 psm = L2capGetPsm(chan->lpsm); in L2capDisconnectAbnormal()
49 "L2capCallback disconnectAbnormal:%{public}d begin, cid = 0x%04X, reason = %hhu", __LINE__, chan->lcid, reason); in L2capDisconnectAbnormal()
50 psm->service.disconnectAbnormal(chan->lcid, reason, psm->ctx); in L2capDisconnectAbnormal()
87 L2capChannel *chan = NULL; in L2capResponseTimeout() local
89 chan = L2capGetChannel(conn, req->lcid); in L2capResponseTimeout()
90 if (chan != NULL) { in L2capResponseTimeout()
91 L2capDisconnectAbnormal(chan, 0); in L2capResponseTimeout()
92 L2capDeleteChannel(conn, chan, 1); in L2capResponseTimeout()
135 int L2capSendConnectionReq(L2capConnection *conn, L2capChannel *chan) in 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
230 L2capChannelConnected(L2capChannel *chan) L2capChannelConnected() argument
243 L2capSendConfigurationRspRfcProcess( L2capChannel *chan, L2capSignalHeader *signal, uint8_t *buff, uint16_t result, const L2capConfigInfo *cfg) L2capSendConfigurationRspRfcProcess() 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
479 L2capBuildSFrame(const L2capChannel *chan, const L2capErfcSControl *sCtrl) L2capBuildSFrame() argument
507 L2capSendSFrame(const L2capConnection *conn, L2capChannel *chan, uint8_t pBit, uint8_t fBit, uint8_t sBit) L2capSendSFrame() argument
529 L2capProcessRxReqSeq(L2capChannel *chan, uint16_t reqSeq) L2capProcessRxReqSeq() argument
586 L2capErfcTxOneFrame(L2capConnection *conn, L2capChannel *chan, uint8_t txSeq) L2capErfcTxOneFrame() argument
630 L2capErfcRemoteBusyProcess(L2capChannel *chan, uint8_t isBusy) L2capErfcRemoteBusyProcess() argument
664 L2capChannel *chan = NULL; L2capErfcMonitorTimeout() local
699 L2capErfcStartMonitorTimer(L2capChannel *chan) L2capErfcStartMonitorTimer() argument
715 L2capChannel *chan = NULL; L2capErfcRetransmissionTimeout() local
747 L2capErfcStartRetransmissionTimer(L2capChannel *chan) L2capErfcStartRetransmissionTimer() argument
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
879 L2capBuildIFrame(L2capChannel *chan, const Packet *pkt, uint8_t sar, uint16_t sduLength) L2capBuildIFrame() argument
918 L2capAddNewPacket(L2capChannel *chan, Packet *pkt) L2capAddNewPacket() argument
938 L2capSendIFrame(L2capConnection *conn, L2capChannel *chan, Packet *pkt) L2capSendIFrame() argument
990 L2capErfcProcessFBit(L2capChannel *chan, uint8_t fBit, uint8_t reqSeq) L2capErfcProcessFBit() 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
1131 L2capStreamProcessIFrame(L2capChannel *chan, const Packet *pkt, L2capErfcIControl *iCtrl) L2capStreamProcessIFrame() argument
1327 L2capDestroyPartOption(L2capChannel *chan) L2capDestroyPartOption() 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
1444 L2capChannel *chan = NULL; L2capProcessConfigurationReq() local
1487 L2capConfigurationReqContinuation(L2capConnection *conn, const L2capChannel *chan) L2capConfigurationReqContinuation() argument
1511 L2capChannel *chan = NULL; L2capProcessConfigurationRsp() local
1575 L2capChannel *chan = NULL; L2capProcessConnectionReq() local
1635 L2capChannel *chan = NULL; L2capProcessConnectionRsp() local
1699 L2capChannel *chan = NULL; L2capProcessDisconnectionReq() local
1746 L2capChannel *chan = NULL; L2capProcessDisconnectionRsp() local
1799 L2capIncomingConnection(const L2capConnection *conn, const L2capChannel *chan) L2capIncomingConnection() argument
1856 L2capChannel *chan = NULL; L2capProcessInformationRsp() local
1916 L2capChannel *chan = NULL; L2capProcessCommandReject() local
2044 L2capProcessStreamData(L2capChannel *chan, Packet *pkt) L2capProcessStreamData() argument
2066 L2capProcessErfcData(L2capConnection *conn, L2capChannel *chan, Packet *pkt) L2capProcessErfcData() argument
2087 L2capProcessBasicData(const L2capChannel *chan, Packet *pkt) L2capProcessBasicData() argument
2104 L2capChannel *chan = NULL; L2capProcessData() local
2180 L2capChannel *chan = NULL; L2capAclConnectFailed() local
2245 L2capChannel *chan = NULL; L2capAclDisconnected() local
[all...]
H A Dl2cap_le.c174 static void L2capLeGetChannel2(uint16_t lcid, L2capLeConnection **conn, L2capLeChannel **chan) in L2capLeGetChannel2() argument
182 *chan = L2capLeGetChannel(*conn, lcid); in L2capLeGetChannel2()
183 if ((*chan) != NULL) { in L2capLeGetChannel2()
193 static void L2capLeGetChannel3(uint16_t aclHandle, uint16_t lcid, L2capLeConnection **conn, L2capLeChannel **chan) in L2capLeGetChannel3() argument
200 *chan = L2capLeGetChannel(*conn, lcid); in L2capLeGetChannel3()
206 L2capLeChannel *chan = NULL; in L2capLeGetChannel4() local
211 chan = ListGetNodeData(node); in L2capLeGetChannel4()
212 if (chan->connIdentifier == ident) { in L2capLeGetChannel4()
213 return chan; in L2capLeGetChannel4()
229 L2capLeChannel *chan in L2capLeGetNewLcid() local
254 L2capLeChannel *chan = NULL; L2capLeNewChannel() local
273 L2capLeDestroyChannel(L2capLeChannel *chan) L2capLeDestroyChannel() argument
302 L2capLeDeleteChannel(L2capLeConnection *conn, L2capLeChannel *chan, uint16_t removeAcl) L2capLeDeleteChannel() argument
344 L2capLeChannel *chan = NULL; L2capLeDeleteConnection() local
418 L2capLeChannel *chan = 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
602 L2capLeSegmentPacketWithCredit(const L2capLeChannel *chan, Packet *pkt) L2capLeSegmentPacketWithCredit() argument
699 L2capLeChannel *chan = NULL; L2capLeProcessCreditBasedConnectionReq() local
760 L2capLeChannel *chan = NULL; L2capLeProcessCreditBasedConnectionRsp() local
819 L2capLeChannel *chan = NULL; L2capLeProcessDisconnectionReq() local
865 L2capLeChannel *chan = NULL; L2capLeProcessDisconnectionRsp() local
905 L2capLeChannel *chan = NULL; L2capLeProcessFlowControlCredit() local
1027 L2capLeDataCallback(const L2capLeChannel *chan, Packet *pkt) L2capLeDataCallback() argument
1045 L2capLeChannel *chan = NULL; L2capLeProcessLeData() local
1113 L2capLeChannel *chan = NULL; L2capLeCleanAllChannels() local
1168 L2capLeChannel *chan = NULL; L2capLeAclConnectProcess() local
1258 L2capLeChannel *chan = NULL; L2CAP_LeCreditBasedConnectionReq() local
1316 L2capLeChannel *chan = NULL; L2CAP_LeCreditBasedConnectionRsp() local
1361 L2capLeChannel *chan = NULL; L2CAP_LeDisconnectionReq() local
1385 L2capLeChannel *chan = NULL; L2CAP_LeDisconnectionRsp() local
1407 L2capLeChannel *chan = NULL; L2CAP_LeSendData() local
1514 L2capLeChannel *chan = NULL; L2CAP_LeDeregisterService() local
1537 L2CAP_LeRegisterFixChannel(uint16_t cid, const L2capLeFixChannel *chan) L2CAP_LeRegisterFixChannel() argument
[all...]
H A Dl2cap_inst.c101 L2capConnection *L2capGetConnection3(const L2capChannel *chan) in L2capGetConnection3() argument
114 if (ListGetNodeData(nodeChan) == chan) { in L2capGetConnection3()
129 L2capChannel *chan = NULL; in L2capGetChannel() local
134 chan = ListGetNodeData(node); in L2capGetChannel()
135 if (chan->lcid == lcid) { in L2capGetChannel()
136 return chan; in L2capGetChannel()
145 void L2capGetChannel2(uint16_t lcid, L2capConnection **conn, L2capChannel **chan) in L2capGetChannel2() argument
153 *chan = L2capGetChannel(*conn, lcid); in L2capGetChannel2()
154 if ((*chan) != NULL) { in L2capGetChannel2()
164 void L2capGetChannel3(uint16_t aclHandle, uint16_t lcid, L2capConnection **conn, L2capChannel **chan) in L2capGetChannel3() argument
182 L2capChannel *chan = NULL; L2capGetNewLcid() local
223 L2capChannel *chan = NULL; L2capNewChannel() local
258 L2capDestroyChannelTx(L2capChannel *chan) L2capDestroyChannelTx() argument
295 L2capDestroyChannel(L2capChannel *chan) L2capDestroyChannel() argument
360 L2capDeleteChannel(L2capConnection *conn, L2capChannel *chan, uint16_t removeAcl) L2capDeleteChannel() argument
415 L2capChannel *chan = NULL; L2capDeleteConnection() local
[all...]
H A Dl2cap_core.h72 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);
82 int L2capSendSFrame(const L2capConnection *conn, L2capChannel *chan, uint8_t pBit, uint8_t fBit, uint8_t sBit);
83 int L2capSendIFrame(L2capConnection *conn, L2capChannel *chan, Packet *pkt);
85 void L2capErfcStartRetransmissionTimer(L2capChannel *chan);
86 void L2capErfcStartMonitorTimer(L2capChannel *chan);
[all...]
H A Dl2cap_inst.h182 L2capConnection *L2capGetConnection3(const L2capChannel *chan);
185 void L2capGetChannel2(uint16_t lcid, L2capConnection **conn, L2capChannel **chan);
186 void L2capGetChannel3(uint16_t aclHandle, uint16_t lcid, L2capConnection **conn, L2capChannel **chan);
189 void L2capDestroyChannel(L2capChannel *chan);
190 void L2capDeleteChannel(L2capConnection *conn, L2capChannel *chan, uint16_t removeAcl);
H A Dl2cap_le_if.c341 L2capLeFixChannel chan; member
352 result = L2CAP_LeRegisterFixChannel(ctx->cid, &(ctx->chan)); in L2cifLeRegisterFixChannel()
361 int L2CIF_LeRegisterFixChannel(uint16_t cid, const L2capLeFixChannel *chan, void (*cb)(uint16_t cid, int result)) in L2CIF_LeRegisterFixChannel() argument
365 if (chan == NULL) { in L2CIF_LeRegisterFixChannel()
375 (void)memcpy_s(&(ctx->chan), sizeof(L2capLeFixChannel), chan, sizeof(L2capLeFixChannel)); in L2CIF_LeRegisterFixChannel()
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/
H A Dsoftbus_proxychannel_manager_test.cpp176 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in BuildProxyChannelInfo() local
177 if (chan == NULL) { in BuildProxyChannelInfo()
180 chan->authHandle.authId = channelId; in BuildProxyChannelInfo()
181 chan->connId = channelId; in BuildProxyChannelInfo()
182 chan->myId = channelId; in BuildProxyChannelInfo()
183 chan->peerId = channelId; in BuildProxyChannelInfo()
184 chan->reqId = channelId; in BuildProxyChannelInfo()
185 chan->channelId = channelId; in BuildProxyChannelInfo()
186 chan->seq = channelId; in BuildProxyChannelInfo()
187 (void)strcpy_s(chan in BuildProxyChannelInfo()
195 ProxyChannelInfo *chan = BuildProxyChannelInfo(channelId, identity, status); TestTransProxyAddAuthChannel() local
205 ProxyChannelInfo *chan = BuildProxyChannelInfo(channelId, identity, status); TestTransProxyAddNormalChannel() local
289 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
350 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
443 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
538 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
567 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
719 ProxyChannelInfo chan; HWTEST_F() local
865 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
887 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
904 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
922 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
969 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
991 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1019 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1047 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1067 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1087 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1201 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1279 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1299 ProxyChannelInfo chan; HWTEST_F() local
1340 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
1399 ProxyChannelInfo *chan = NULL; HWTEST_F() local
1537 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1558 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1580 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1610 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1640 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1672 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
1781 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
1893 ProxyChannelInfo chan; HWTEST_F() local
2000 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
2043 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
2065 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
2092 ProxyChannelInfo *chan = reinterpret_cast<ProxyChannelInfo *>(SoftBusCalloc(sizeof(ProxyChannelInfo))); HWTEST_F() local
[all...]
H A Dtrans_proxy_manager_test.cpp188 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TestTransProxyAddAuthChannel() local
189 ASSERT_TRUE(NULL != chan); in TestTransProxyAddAuthChannel()
190 chan->authId = channelId; in TestTransProxyAddAuthChannel()
191 chan->connId = channelId; in TestTransProxyAddAuthChannel()
192 chan->myId = channelId; in TestTransProxyAddAuthChannel()
193 chan->peerId = channelId; in TestTransProxyAddAuthChannel()
194 chan->reqId = channelId; in TestTransProxyAddAuthChannel()
195 chan->channelId = channelId; in TestTransProxyAddAuthChannel()
196 chan->seq = channelId; in TestTransProxyAddAuthChannel()
197 (void)strcpy_s(chan in TestTransProxyAddAuthChannel()
216 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); TestTransProxyAddNormalChannel() local
326 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
532 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
693 ProxyChannelInfo chan; HWTEST_F() local
900 ProxyChannelInfo chan; HWTEST_F() local
923 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
[all...]
H A Dtrans_proxy_channel_test.cpp128 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TestAddTestProxyChannel() local
129 if (chan == NULL) { in TestAddTestProxyChannel()
133 chan->myId = m_testProxyChannelId; in TestAddTestProxyChannel()
134 chan->channelId = m_testProxyChannelId; in TestAddTestProxyChannel()
135 chan->authHandle.authId = authId; in TestAddTestProxyChannel()
136 chan->appInfo.appType = APP_TYPE_NORMAL; in TestAddTestProxyChannel()
137 chan->status = PROXY_CHANNEL_STATUS_PYH_CONNECTED; in TestAddTestProxyChannel()
138 if (TransProxyAddChanItem(chan) != SOFTBUS_OK) { in TestAddTestProxyChannel()
140 SoftBusFree(chan); in TestAddTestProxyChannel()
160 ProxyChannelInfo *chan in HWTEST_F() local
182 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
[all...]
H A Dtrans_proxy_message_test.cpp95 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TestMessageAddProxyChannel() local
96 ASSERT_TRUE(NULL != chan); in TestMessageAddProxyChannel()
97 chan->authId = channelId; in TestMessageAddProxyChannel()
98 chan->connId = channelId; in TestMessageAddProxyChannel()
99 chan->myId = channelId; in TestMessageAddProxyChannel()
100 chan->peerId = channelId; in TestMessageAddProxyChannel()
101 chan->reqId = channelId; in TestMessageAddProxyChannel()
102 chan->channelId = channelId; in TestMessageAddProxyChannel()
103 chan->seq = channelId; in TestMessageAddProxyChannel()
104 (void)strcpy_s(chan in TestMessageAddProxyChannel()
173 ProxyChannelInfo chan; HWTEST_F() local
204 ProxyChannelInfo chan; HWTEST_F() local
[all...]
H A Dtrans_proxy_session_test.cpp137 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TestAddProxyChannel() local
138 ASSERT_TRUE(NULL != chan); in TestAddProxyChannel()
139 chan->authId = channelId; in TestAddProxyChannel()
140 chan->connId = channelId; in TestAddProxyChannel()
141 chan->myId = channelId; in TestAddProxyChannel()
142 chan->peerId = channelId; in TestAddProxyChannel()
143 chan->reqId = channelId; in TestAddProxyChannel()
144 chan->channelId = channelId; in TestAddProxyChannel()
145 chan->seq = channelId; in TestAddProxyChannel()
146 (void)strcpy_s(chan in TestAddProxyChannel()
[all...]
H A Dsoftbus_proxy_session_test.cpp120 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TestAddProxyChannel() local
121 ASSERT_TRUE(NULL != chan); in TestAddProxyChannel()
122 chan->authHandle.authId = channelId; in TestAddProxyChannel()
123 chan->connId = channelId; in TestAddProxyChannel()
124 chan->myId = channelId; in TestAddProxyChannel()
125 chan->peerId = channelId; in TestAddProxyChannel()
126 chan->reqId = channelId; in TestAddProxyChannel()
127 chan->channelId = channelId; in TestAddProxyChannel()
128 chan->seq = channelId; in TestAddProxyChannel()
129 (void)strcpy_s(chan in TestAddProxyChannel()
[all...]
H A Dsoftbus_proxychannel_message_test.cpp168 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TestMessageAddProxyChannel() local
169 ASSERT_TRUE(NULL != chan); in TestMessageAddProxyChannel()
170 chan->authHandle.authId = channelId; in TestMessageAddProxyChannel()
171 chan->connId = channelId; in TestMessageAddProxyChannel()
172 chan->myId = channelId; in TestMessageAddProxyChannel()
173 chan->peerId = channelId; in TestMessageAddProxyChannel()
174 chan->reqId = channelId; in TestMessageAddProxyChannel()
175 chan->channelId = channelId; in TestMessageAddProxyChannel()
176 chan->seq = channelId; in TestMessageAddProxyChannel()
177 (void)strcpy_s(chan in TestMessageAddProxyChannel()
248 ProxyChannelInfo chan; HWTEST_F() local
279 ProxyChannelInfo chan; HWTEST_F() local
[all...]
H A Dsoftbus_trans_proxy_transceiver_test.cpp293 ProxyChannelInfo chan; in HWTEST_F() local
299 chan.isServer = false; in HWTEST_F()
300 int32_t ret = TransProxyConnExistProc(&conn, &chan, chanNewId); in HWTEST_F()
304 ret = TransProxyConnExistProc(&conn, &chan, chanNewId); in HWTEST_F()
507 ProxyConnInfo chan; in HWTEST_F() local
508 int32_t ret = TransAddConnItem(&chan); in HWTEST_F()
698 const char *chan = "testchan"; in HWTEST_F() local
700 0, const_cast<char *>(chan)); in HWTEST_F()
730 ProxyChannelInfo chan; in HWTEST_F() local
735 msg->obj = reinterpret_cast<void *>(&chan); in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_manager.c188 static int32_t TransProxyAddChanItem(ProxyChannelInfo *chan) in TransProxyAddChanItem() argument
190 TRANS_CHECK_AND_RETURN_RET_LOGE((g_proxyChannelList != NULL && chan != NULL), SOFTBUS_INVALID_PARAM, TRANS_CTRL, in TransProxyAddChanItem()
195 ListAdd(&(g_proxyChannelList->list), &(chan->node)); in TransProxyAddChanItem()
235 int32_t TransProxyGetChanByChanId(int32_t chanId, ProxyChannelInfo *chan) in TransProxyGetChanByChanId() argument
237 TRANS_CHECK_AND_RETURN_RET_LOGE((g_proxyChannelList != NULL && chan != NULL), SOFTBUS_INVALID_PARAM, TRANS_CTRL, in TransProxyGetChanByChanId()
247 if (memcpy_s(chan, sizeof(ProxyChannelInfo), item, sizeof(ProxyChannelInfo)) != EOK) { in TransProxyGetChanByChanId()
261 int32_t TransProxyGetChanByReqId(int32_t reqId, ProxyChannelInfo *chan) in TransProxyGetChanByReqId() argument
271 *chan = *item; in TransProxyGetChanByReqId()
885 static int32_t TransProxyGetLocalInfo(ProxyChannelInfo *chan) in TransProxyGetLocalInfo() argument
887 bool noNeedGetPkg = (chan in TransProxyGetLocalInfo()
933 ConstructProxyChannelInfo( ProxyChannelInfo *chan, const ProxyMessage *msg, int16_t newChanId, const ConnectionInfo *info) ConstructProxyChannelInfo() argument
1008 TransProxyFillChannelInfo(const ProxyMessage *msg, ProxyChannelInfo *chan) TransProxyFillChannelInfo() argument
1080 TransProxyFastDataRecv(ProxyChannelInfo *chan) TransProxyFastDataRecv() argument
1104 ReleaseChannelInfo(ProxyChannelInfo *chan) ReleaseChannelInfo() argument
1115 FillProxyHandshakeExtra( TransEventExtra *extra, ProxyChannelInfo *chan, char *socketName, NodeInfo *nodeInfo) FillProxyHandshakeExtra() argument
1144 TransProxyProcessHandshake(ProxyChannelInfo *chan, const ProxyMessage *msg) TransProxyProcessHandshake() argument
1180 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); TransProxyProcessHandshakeMsg() local
1471 CopyAppInfoFastTransData(ProxyChannelInfo *chan, const AppInfo *appInfo) CopyAppInfoFastTransData() argument
1489 TransProxyCreateChanInfo(ProxyChannelInfo *chan, int32_t channelId, const AppInfo *appInfo) TransProxyCreateChanInfo() argument
1861 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); TransProxyGetNameByChanId() local
2023 TransProxyGetProxyChannelInfoByChannelId(int32_t channelId, ProxyChannelInfo *chan) TransProxyGetProxyChannelInfoByChannelId() argument
2073 ProxyChannelInfo chan; TransProxyGetConnOptionByChanId() local
[all...]
H A Dsoftbus_proxychannel_transceiver.c180 ProxyChannelInfo *chan = NULL; in TransProxyLoopMsgHandler() local
189 chan = (ProxyChannelInfo *)msg->obj; in TransProxyLoopMsgHandler()
190 TRANS_CHECK_AND_RETURN_LOGE(chan != NULL, TRANS_MSG, "LOOP_DISCONNECT_MSG, chan is null"); in TransProxyLoopMsgHandler()
191 TransProxyCloseConnChannelReset(connectionId, (isServer == 0), isServer, chan->deviceTypeIsWinpc); in TransProxyLoopMsgHandler()
195 chan = (ProxyChannelInfo *)msg->obj; in TransProxyLoopMsgHandler()
196 TRANS_CHECK_AND_RETURN_LOGE(chan != NULL, TRANS_MSG, "LOOP_OPENFAIL_MSG, chan is null"); in TransProxyLoopMsgHandler()
197 TransProxyOpenProxyChannelFail(chan->channelId, &(chan in TransProxyLoopMsgHandler()
259 TransProxyPostResetPeerMsgToLoop(const ProxyChannelInfo *chan) TransProxyPostResetPeerMsgToLoop() argument
291 TransProxyPostDisConnectMsgToLoop(uint32_t connId, bool isServer, const ProxyChannelInfo *chan) TransProxyPostDisConnectMsgToLoop() argument
302 TransProxyPostKeepAliveMsgToLoop(const ProxyChannelInfo *chan) TransProxyPostKeepAliveMsgToLoop() argument
319 TransProxyPostOpenFailMsgToLoop(const ProxyChannelInfo *chan, int32_t errCode) TransProxyPostOpenFailMsgToLoop() argument
336 TransProxyPostOpenClosedMsgToLoop(const ProxyChannelInfo *chan) TransProxyPostOpenClosedMsgToLoop() argument
435 TransAddConnItem(ProxyConnInfo *chan) TransAddConnItem() argument
660 TransProxyConnExistProc(ProxyConnInfo *conn, ProxyChannelInfo *chan, int32_t chanNewId) TransProxyConnExistProc() argument
759 TransReportStartConnectEvent(const AppInfo *appInfo, const ProxyChannelInfo *chan, int32_t channelId) TransReportStartConnectEvent() argument
787 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); TransProxyOpenConnChannel() local
[all...]
H A Dsoftbus_proxychannel_control.c156 int32_t TransProxyAckHandshake(uint32_t connId, ProxyChannelInfo *chan, int32_t retCode) in TransProxyAckHandshake() argument
158 if (chan == NULL) { in TransProxyAckHandshake()
167 if (chan->appInfo.appType != APP_TYPE_AUTH) { in TransProxyAckHandshake()
170 msgHead.myId = chan->myId; in TransProxyAckHandshake()
171 msgHead.peerId = chan->peerId; in TransProxyAckHandshake()
176 retCode, chan->myId, chan->peerId); in TransProxyAckHandshake()
180 chan->myId, chan->peerId); in TransProxyAckHandshake()
181 payLoad = TransProxyPackHandshakeAckMsg(chan); in TransProxyAckHandshake()
[all...]
H A Dsoftbus_proxychannel_message.c528 char *TransProxyPackHandshakeAckMsg(ProxyChannelInfo *chan) in TransProxyPackHandshakeAckMsg() argument
532 AppInfo *appInfo = &(chan->appInfo); in TransProxyPackHandshakeAckMsg()
544 if (!AddStringToJsonObject(root, JSON_KEY_IDENTITY, chan->identity) || in TransProxyPackHandshakeAckMsg()
803 static int32_t TransProxyGetJsonObject(cJSON *root, const char *msg, int32_t len, ProxyChannelInfo *chan) in TransProxyGetJsonObject() argument
805 if (!GetJsonObjectNumberItem(root, JSON_KEY_TYPE, (int32_t *)&(chan->appInfo.appType)) || in TransProxyGetJsonObject()
806 !GetJsonObjectStringItem(root, JSON_KEY_IDENTITY, chan->identity, sizeof(chan->identity)) || in TransProxyGetJsonObject()
807 !GetJsonObjectStringItem(root, JSON_KEY_DEVICE_ID, chan->appInfo.peerData.deviceId, in TransProxyGetJsonObject()
808 sizeof(chan->appInfo.peerData.deviceId)) || in TransProxyGetJsonObject()
809 !GetJsonObjectStringItem(root, JSON_KEY_SRC_BUS_NAME, chan in TransProxyGetJsonObject()
825 TransProxyUnpackHandshakeMsg(const char *msg, ProxyChannelInfo *chan, int32_t len) TransProxyUnpackHandshakeMsg() argument
[all...]
H A Dsoftbus_proxychannel_listener.c187 ProxyChannelInfo *chan = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TransProxyGetChannelIsServer() local
188 if (chan == NULL) { in TransProxyGetChannelIsServer()
192 if (TransProxyGetChanByChanId(channelId, chan) != SOFTBUS_OK) { in TransProxyGetChannelIsServer()
193 SoftBusFree(chan); in TransProxyGetChannelIsServer()
196 *isServer = chan->isServer; in TransProxyGetChannelIsServer()
197 SoftBusFree(chan); in TransProxyGetChannelIsServer()
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/include/
H A Dsoftbus_proxychannel_transceiver.h38 void TransProxyPostResetPeerMsgToLoop(const ProxyChannelInfo *chan);
40 void TransProxyPostDisConnectMsgToLoop(uint32_t connId, bool isServer, const ProxyChannelInfo *chan);
41 void TransProxyPostOpenClosedMsgToLoop(const ProxyChannelInfo *chan);
42 void TransProxyPostOpenFailMsgToLoop(const ProxyChannelInfo *chan, int32_t errCode);
43 void TransProxyPostKeepAliveMsgToLoop(const ProxyChannelInfo *chan);
H A Dsoftbus_proxychannel_manager.h47 int32_t TransProxyGetChanByChanId(int32_t chanId, ProxyChannelInfo *chan);
48 int32_t TransProxyGetChanByReqId(int32_t reqId, ProxyChannelInfo *chan);
57 int32_t TransProxyCreateChanInfo(ProxyChannelInfo *chan, int32_t channelId, const AppInfo *appInfo);
H A Dsoftbus_proxychannel_control.h26 int32_t TransProxyAckHandshake(uint32_t connId, ProxyChannelInfo *chan, int32_t retCode);
H A Dsoftbus_proxychannel_message.h166 char* TransProxyPackHandshakeAckMsg(ProxyChannelInfo *chan);
171 int32_t TransProxyUnpackHandshakeMsg(const char *msg, ProxyChannelInfo *chan, int32_t len);
/foundation/communication/dsoftbus/tests/core/transmission/fuzztest/softbusproxychannelmanager_fuzzer/
H A Dsoftbusproxychannelmanager_fuzzer.cpp155 ProxyChannelInfo chan; in TransProxyGetChanByChanIdTest() local
157 (void)TransProxyGetChanByChanId(chanId, &chan); in TransProxyGetChanByChanIdTest()
163 ProxyChannelInfo chan; in TransProxyGetChanByReqIdTest() local
165 (void)TransProxyGetChanByReqId(reqId, &chan); in TransProxyGetChanByReqIdTest()
201 ProxyChannelInfo chan; in TransProxyGetSendMsgChanInfoTest() local
203 (void)TransProxyGetSendMsgChanInfo(channelId, &chan); in TransProxyGetSendMsgChanInfoTest()

Completed in 26 milliseconds

12