Home
last modified time | relevance | path

Searched refs:chanInfo (Results 1 - 14 of 14) sorted by relevance

/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_session.c36 int32_t TransProxyTransDataSendMsg(ProxyChannelInfo *chanInfo, const unsigned char *payLoad,
103 ProxyChannelInfo *chanInfo = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in TransProxyPostPacketData() local
104 if (chanInfo == NULL) { in TransProxyPostPacketData()
108 if (TransProxyGetSendMsgChanInfo(channelId, chanInfo) != SOFTBUS_OK) { in TransProxyPostPacketData()
109 SoftBusFree(chanInfo); in TransProxyPostPacketData()
113 (void)memset_s(chanInfo->appInfo.sessionKey, sizeof(chanInfo->appInfo.sessionKey), 0, in TransProxyPostPacketData()
114 sizeof(chanInfo->appInfo.sessionKey)); in TransProxyPostPacketData()
115 int32_t ret = TransProxyTransDataSendMsg(chanInfo, data, len, flags); in TransProxyPostPacketData()
120 SoftBusFree(chanInfo); in TransProxyPostPacketData()
[all...]
H A Dsoftbus_proxychannel_message.c628 int32_t TransProxyUnpackHandshakeAckMsg(const char *msg, ProxyChannelInfo *chanInfo, in TransProxyUnpackHandshakeAckMsg() argument
631 TRANS_CHECK_AND_RETURN_RET_LOGE(msg != NULL && chanInfo != NULL && fastDataSize != NULL, in TransProxyUnpackHandshakeAckMsg()
632 SOFTBUS_INVALID_PARAM, TRANS_CTRL, "msg or chanInfo or fastDataSize is empty."); in TransProxyUnpackHandshakeAckMsg()
634 TRANS_CHECK_AND_RETURN_RET_LOGE(&chanInfo->appInfo != NULL, SOFTBUS_INVALID_PARAM, TRANS_CTRL, "appInfo is null"); in TransProxyUnpackHandshakeAckMsg()
639 if (!GetJsonObjectStringItem(root, JSON_KEY_IDENTITY, chanInfo->identity, sizeof(chanInfo->identity)) || in TransProxyUnpackHandshakeAckMsg()
640 !GetJsonObjectStringItem(root, JSON_KEY_DEVICE_ID, chanInfo->appInfo.peerData.deviceId, in TransProxyUnpackHandshakeAckMsg()
641 sizeof(chanInfo->appInfo.peerData.deviceId))) { in TransProxyUnpackHandshakeAckMsg()
646 if (!GetJsonObjectNumberItem(root, JSON_KEY_MTU_SIZE, (int32_t *)&(chanInfo->appInfo.peerData.dataConfig))) { in TransProxyUnpackHandshakeAckMsg()
649 chanInfo in TransProxyUnpackHandshakeAckMsg()
[all...]
H A Dsoftbus_proxychannel_manager.c455 static int32_t TransProxyResetChan(ProxyChannelInfo *chanInfo) in TransProxyResetChan() argument
466 if (ResetChanIsEqual(removeNode->status, removeNode, chanInfo)) { in TransProxyResetChan()
467 if (memcpy_s(chanInfo, sizeof(ProxyChannelInfo), removeNode, sizeof(ProxyChannelInfo)) != EOK) { in TransProxyResetChan()
480 TRANS_LOGI(TRANS_CTRL, "trans proxy reset channelId=%{public}d", chanInfo->channelId); in TransProxyResetChan()
489 static int32_t TransProxyGetRecvMsgChanInfo(int16_t myId, int16_t peerId, ProxyChannelInfo *chanInfo) in TransProxyGetRecvMsgChanInfo() argument
503 if (memcpy_s(chanInfo, sizeof(ProxyChannelInfo), item, sizeof(ProxyChannelInfo)) != EOK) { in TransProxyGetRecvMsgChanInfo()
516 static int32_t TransProxyKeepAliveChan(ProxyChannelInfo *chanInfo) in TransProxyKeepAliveChan() argument
526 if (ChanIsEqual(item, chanInfo)) { in TransProxyKeepAliveChan()
531 if (memcpy_s(chanInfo, sizeof(ProxyChannelInfo), item, sizeof(ProxyChannelInfo)) != EOK) { in TransProxyKeepAliveChan()
544 int32_t TransProxyGetSendMsgChanInfo(int32_t channelId, ProxyChannelInfo *chanInfo) in TransProxyGetSendMsgChanInfo() argument
[all...]
/foundation/communication/dsoftbus/core/transmission/trans_channel/qos/
H A Dsoftbus_qos_virtual.c20 int32_t NotifyQosChannelOpened(const ChannelInfo *chanInfo) in NotifyQosChannelOpened() argument
22 (void)chanInfo; in NotifyQosChannelOpened()
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/
H A Dsoftbus_proxychannel_manager_test.cpp310 ProxyChannelInfo *chanInfo = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); in HWTEST_F() local
311 chanInfo->channelId = TEST_NUMBER_TEN; in HWTEST_F()
312 chanInfo->peerId = TEST_PARSE_MESSAGE_CHANNEL; in HWTEST_F()
314 int32_t ret = TransProxyKeepAliveChan(chanInfo); in HWTEST_F()
317 chanInfo->peerId = TEST_MESSAGE_CHANNEL_VALID_ID; in HWTEST_F()
318 ret = TransProxyKeepAliveChan(chanInfo); in HWTEST_F()
321 SoftBusFree(chanInfo); in HWTEST_F()
612 * @tc.desc: test proxy get sendmsg chanInfo by chanId.
619 ProxyChannelInfo chanInfo; in HWTEST_F() local
621 int32_t ret = TransProxyGetSendMsgChanInfo(channelId, &chanInfo); in HWTEST_F()
644 ProxyChannelInfo chanInfo; HWTEST_F() local
667 ProxyChannelInfo chanInfo; HWTEST_F() local
785 ProxyChannelInfo chanInfo; HWTEST_F() local
1248 ProxyChannelInfo chanInfo; HWTEST_F() local
1264 ProxyChannelInfo chanInfo; HWTEST_F() local
1314 ProxyChannelInfo *chanInfo = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
1352 ProxyChannelInfo *chanInfo = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); HWTEST_F() local
[all...]
H A Dtrans_proxy_message_test.cpp698 ProxyChannelInfo chanInfo; in HWTEST_F() local
710 chanInfo.appInfo.appType = APP_TYPE_INNER; in HWTEST_F()
712 TransProxyKeepalive(connId, &chanInfo); in HWTEST_F()
714 TransProxyKeepalive(connId, &chanInfo); in HWTEST_F()
716 chanInfo.appInfo.appType = APP_TYPE_AUTH; in HWTEST_F()
717 TransProxyKeepalive(connId, &chanInfo); in HWTEST_F()
722 chanInfo.appInfo.appType = APP_TYPE_INNER; in HWTEST_F()
723 ret = TransProxyAckKeepalive(&chanInfo); in HWTEST_F()
726 ret = TransProxyAckKeepalive(&chanInfo); in HWTEST_F()
728 chanInfo in HWTEST_F()
741 ProxyChannelInfo chanInfo; HWTEST_F() local
[all...]
H A Dtrans_proxy_manager_test.cpp557 * @tc.desc: test proxy get sendmsg chanInfo by chanId.
564 ProxyChannelInfo chanInfo; in HWTEST_F() local
566 int32_t ret = TransProxyGetSendMsgChanInfo(channelId, &chanInfo); in HWTEST_F()
570 ret = TransProxyGetSendMsgChanInfo(channelId, &chanInfo); in HWTEST_F()
576 * @tc.desc: test proxy get sendmsg chanInfo by chanId.
599 ProxyChannelInfo chanInfo; in HWTEST_F() local
600 int32_t ret = TransProxyGetSendMsgChanInfo(m_testProxyConningChannel, &chanInfo); in HWTEST_F()
602 EXPECT_TRUE(PROXY_CHANNEL_STATUS_HANDSHAKEING != (uint32_t)chanInfo.status); in HWTEST_F()
774 ProxyChannelInfo chanInfo; in HWTEST_F() local
775 ret = TransProxyGetSendMsgChanInfo(channelId, &chanInfo); in HWTEST_F()
855 ProxyChannelInfo chanInfo; HWTEST_F() local
874 ProxyChannelInfo chanInfo; HWTEST_F() local
[all...]
H A Dsoftbus_proxychannel_message_test.cpp670 ProxyChannelInfo chanInfo; in HWTEST_F() local
673 chanInfo.appInfo.appType = APP_TYPE_INNER; in HWTEST_F()
675 TransProxyKeepalive(connId, &chanInfo); in HWTEST_F()
677 TransProxyKeepalive(connId, &chanInfo); in HWTEST_F()
679 chanInfo.appInfo.appType = APP_TYPE_AUTH; in HWTEST_F()
680 TransProxyKeepalive(connId, &chanInfo); in HWTEST_F()
685 chanInfo.appInfo.appType = APP_TYPE_INNER; in HWTEST_F()
686 ret = TransProxyAckKeepalive(&chanInfo); in HWTEST_F()
689 ret = TransProxyAckKeepalive(&chanInfo); in HWTEST_F()
691 chanInfo in HWTEST_F()
704 ProxyChannelInfo chanInfo; HWTEST_F() local
[all...]
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/test/unittest/common/distributedcameramgr/
H A Ddcamera_source_controller_test.cpp187 std::shared_ptr<DCameraChannelInfo> chanInfo = std::make_shared<DCameraChannelInfo>(); in HWTEST_F() local
188 int32_t ret = GetLocalDeviceNetworkId(chanInfo->sourceDevId_); in HWTEST_F()
191 chanInfo->detail_.push_back(continueChInfo); in HWTEST_F()
192 chanInfo->detail_.push_back(snapShotChInfo); in HWTEST_F()
199 ret = controller_->ChannelNeg(chanInfo); in HWTEST_F()
213 std::shared_ptr<DCameraChannelInfo> chanInfo = std::make_shared<DCameraChannelInfo>(); in HWTEST_F() local
328 std::shared_ptr<DCameraChannelInfo> chanInfo = std::make_shared<DCameraChannelInfo>(); in HWTEST_F() local
329 int32_t ret = GetLocalDeviceNetworkId(chanInfo->sourceDevId_); in HWTEST_F()
332 chanInfo->detail_.push_back(continueChInfo); in HWTEST_F()
333 chanInfo in HWTEST_F()
374 std::shared_ptr<DCameraChannelInfo> chanInfo = std::make_shared<DCameraChannelInfo>(); HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/transmission/trans_channel/qos/interface/
H A Dsoftbus_qos.h25 int32_t NotifyQosChannelOpened(const ChannelInfo *chanInfo);
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/include/
H A Dsoftbus_proxychannel_message.h164 int32_t TransProxyUnpackHandshakeAckMsg(const char *msg, ProxyChannelInfo *chanInfo,
H A Dsoftbus_proxychannel_manager.h55 int32_t TransProxyGetSendMsgChanInfo(int32_t channelId, ProxyChannelInfo *chanInfo);
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/
H A Ddcamera_source_dev.cpp520 std::shared_ptr<DCameraChannelInfo> chanInfo = std::make_shared<DCameraChannelInfo>(); in ConfigStreams() local
521 ret = GetLocalDeviceNetworkId(chanInfo->sourceDevId_); in ConfigStreams()
529 chanInfo->detail_.push_back(continueChInfo); in ConfigStreams()
530 chanInfo->detail_.push_back(snapShotChInfo); in ConfigStreams()
532 ret = controller_->ChannelNeg(chanInfo); in ConfigStreams()
/foundation/communication/dsoftbus/core/transmission/trans_channel/auth/src/
H A Dtrans_auth_manager.c1167 AuthChannelInfo chanInfo; in TransAuthGetConnOptionByChanId() local
1168 int32_t ret = GetAuthChannelInfoByChanId(channelId, &chanInfo); in TransAuthGetConnOptionByChanId()
1174 if (!chanInfo.isClient) { in TransAuthGetConnOptionByChanId()
1179 if (memcpy_s(connOpt, sizeof(ConnectOption), &(chanInfo.connOpt), sizeof(ConnectOption)) != EOK) { in TransAuthGetConnOptionByChanId()

Completed in 16 milliseconds