Home
last modified time | relevance | path

Searched refs:channelInfo (Results 1 - 25 of 28) sorted by relevance

12

/foundation/communication/dsoftbus/core/common/dfx/statistics/instant/
H A Dinstant_statistics.cpp369 InstantChannelInfo *channelInfo = static_cast<InstantChannelInfo *>(SoftBusCalloc(sizeof(InstantChannelInfo)));
370 if (channelInfo == NULL) {
374 ListInit(&channelInfo->node);
375 ListAdd(&remoteInfo->channels, &channelInfo->node);
377 return channelInfo;
386 InstantChannelInfo *channelInfo = InstCreateAndAddChannelInfo(remoteInfo);
387 if (channelInfo == NULL) {
390 channelInfo->serverSide = conn->serverSide;
391 channelInfo->laneLinkType = conn->appInfo.linkType;
392 channelInfo
[all...]
/foundation/distributedhardware/distributed_camera/services/cameraservice/base/src/
H A Ddcamera_channel_info_cmd.cpp34 cJSON *channelInfo = cJSON_CreateObject(); in Marshal() local
35 if (channelInfo == nullptr) { in Marshal()
39 cJSON_AddStringToObject(channelInfo, "SourceDevId", value_->sourceDevId_.c_str()); in Marshal()
40 cJSON_AddItemToObject(rootValue, "Value", channelInfo); in Marshal()
47 cJSON_AddItemToObject(channelInfo, "Detail", details); in Marshal()
104 std::shared_ptr<DCameraChannelInfo> channelInfo = std::make_shared<DCameraChannelInfo>(); in Unmarshal() local
105 channelInfo->sourceDevId_ = sourceDevId->valuestring; in Unmarshal()
111 if (UnmarshalDetails(details, channelInfo) != DCAMERA_OK) { in Unmarshal()
115 value_ = channelInfo; in Unmarshal()
120 int32_t DCameraChannelInfoCmd::UnmarshalDetails(cJSON *details, std::shared_ptr<DCameraChannelInfo> channelInfo) in UnmarshalDetails() argument
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/proxy/
H A Dclient_trans_proxy_manager_test.cpp198 ChannelInfo channelInfo = {0}; in HWTEST_F() local
199 ret = ClientTransProxyOnChannelOpened(g_proxySessionName, &channelInfo); in HWTEST_F()
228 ChannelInfo channelInfo; in HWTEST_F() local
229 channelInfo.channelId = channelId; in HWTEST_F()
230 channelInfo.sessionKey = g_sessionKey; in HWTEST_F()
231 channelInfo.isEncrypt = true; in HWTEST_F()
232 int32_t ret = ClientTransProxyOnChannelOpened(g_proxySessionName, &channelInfo); in HWTEST_F()
347 ChannelInfo channelInfo; in HWTEST_F() local
348 channelInfo.channelId = channelId; in HWTEST_F()
349 channelInfo in HWTEST_F()
376 ChannelInfo channelInfo; HWTEST_F() local
405 ChannelInfo channelInfo; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/file/
H A Dtrans_sdk_file_test.cpp67 ChannelInfo *channelInfo = (ChannelInfo *)SoftBusCalloc(sizeof(ChannelInfo)); in TransAddChannleInfoTest() local
68 if (channelInfo == NULL) { in TransAddChannleInfoTest()
71 channelInfo->channelId = 1; in TransAddChannleInfoTest()
72 channelInfo->channelType = 1; in TransAddChannleInfoTest()
73 channelInfo->businessType = 1; in TransAddChannleInfoTest()
74 channelInfo->fd = 1; in TransAddChannleInfoTest()
75 channelInfo->isServer = true; in TransAddChannleInfoTest()
76 channelInfo->isEnabled = true; in TransAddChannleInfoTest()
77 channelInfo->peerUid = 1; in TransAddChannleInfoTest()
78 channelInfo in TransAddChannleInfoTest()
369 ChannelInfo *channelInfo = (ChannelInfo *)SoftBusCalloc(sizeof(ChannelInfo)); HWTEST_F() local
416 ChannelInfo *channelInfo = TransAddChannleInfoTest(); HWTEST_F() local
557 ChannelInfo *channelInfo = (ChannelInfo *)SoftBusCalloc(sizeof(ChannelInfo)); HWTEST_F() local
604 ChannelInfo *channelInfo = TransAddChannleInfoTest(); HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/common/dfx/statistics/
H A Dtrans_network_statistics.c36 char *channelInfo; member
80 ChannelDfxInfo *channelInfo = (ChannelDfxInfo *)SoftBusCalloc(sizeof(ChannelDfxInfo)); in AddChannelStatisticsInfo() local
81 if (channelInfo == NULL) { in AddChannelStatisticsInfo()
86 channelInfo->channelId = channelId; in AddChannelStatisticsInfo()
87 channelInfo->channelType = channelType; in AddChannelStatisticsInfo()
88 ListAdd(&g_channelDfxInfoList->list, &channelInfo->node); in AddChannelStatisticsInfo()
203 info->channelInfo = (char *)SoftBusCalloc(len + 1); in ChannelStatisticsInfoInit()
204 if (info->channelInfo == NULL) { in ChannelStatisticsInfoInit()
208 if (memcpy_s(info->channelInfo, len + 1, (char *)dataInfo, len) != EOK) { in ChannelStatisticsInfoInit()
210 SoftBusFree(info->channelInfo); in ChannelStatisticsInfoInit()
[all...]
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/test/sinkfuzztest/sinkproxychannelneg_fuzzer/
H A Dsinkproxychannelneg_fuzzer.cpp35 std::string channelInfo(reinterpret_cast<const char*>(data), size); in SinkProxyChannelNegFuzzTest()
43 dCSinkProxy->ChannelNeg(dhId, channelInfo); in SinkProxyChannelNegFuzzTest()
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/test/sinkfuzztest/sinkservicechannelneg_fuzzer/
H A Dsinkservicechannelneg_fuzzer.cpp36 std::string channelInfo(reinterpret_cast<const char*>(data), size); in SinkServiceChannelNegFuzzTest()
43 sinkService->ChannelNeg(dhId, channelInfo); in SinkServiceChannelNegFuzzTest()
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_manager.c201 int32_t TransProxySpecialUpdateChanInfo(ProxyChannelInfo *channelInfo) in TransProxySpecialUpdateChanInfo() argument
203 TRANS_CHECK_AND_RETURN_RET_LOGE((g_proxyChannelList != NULL && channelInfo != NULL), SOFTBUS_INVALID_PARAM, in TransProxySpecialUpdateChanInfo()
204 TRANS_CTRL, "g_proxyChannelList or channelInfo is NULL!"); in TransProxySpecialUpdateChanInfo()
211 if (item->channelId == channelInfo->channelId) { in TransProxySpecialUpdateChanInfo()
212 if (channelInfo->reqId != -1) { in TransProxySpecialUpdateChanInfo()
213 item->reqId = channelInfo->reqId; in TransProxySpecialUpdateChanInfo()
215 if (channelInfo->isServer != -1) { in TransProxySpecialUpdateChanInfo()
216 item->isServer = channelInfo->isServer; in TransProxySpecialUpdateChanInfo()
218 if (channelInfo->type != CONNECT_TYPE_MAX) { in TransProxySpecialUpdateChanInfo()
219 item->type = channelInfo in TransProxySpecialUpdateChanInfo()
424 TransProxyDelByChannelId(int32_t channelId, ProxyChannelInfo *channelInfo) TransProxyDelByChannelId() argument
1518 ProxyChannelInfo *channelInfo = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); TransProxyNegoSessionKeySucc() local
1553 ProxyChannelInfo *channelInfo = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); TransProxyNegoSessionKeyFail() local
1572 ProxyChannelInfo *channelInfo = (ProxyChannelInfo *)SoftBusCalloc(sizeof(ProxyChannelInfo)); TransProxyOpenProxyChannelSuccess() local
[all...]
H A Dsoftbus_proxychannel_transceiver.c671 ProxyChannelInfo channelInfo = { in TransProxyConnExistProc() local
680 TransProxySpecialUpdateChanInfo(&channelInfo); in TransProxyConnExistProc()
683 ProxyChannelInfo channelInfo = { in TransProxyConnExistProc() local
691 TransProxySpecialUpdateChanInfo(&channelInfo); in TransProxyConnExistProc()
719 ProxyChannelInfo channelInfo = { in TransProxyOpenNewConnChannel() local
727 TransProxySpecialUpdateChanInfo(&channelInfo); in TransProxyOpenNewConnChannel()
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/test/unittest/common/distributedcamera/
H A Dmock_distributed_camera_sink_stub.h59 int32_t ChannelNeg(const std::string &dhId, std::string& channelInfo) in ChannelNeg() argument
62 (void)channelInfo; in ChannelNeg()
H A Ddistributed_camera_sink_stub_test.cpp177 std::string channelInfo = "channelInfo000"; in HWTEST_F() local
178 int32_t ret = sinkProxy.ChannelNeg(dhId, channelInfo); in HWTEST_F()
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/
H A Dsoftbus_proxychannel_manager_test.cpp898 * @tc.desc: test release channelInfo
1842 ProxyChannelInfo channelInfo; in HWTEST_F() local
1843 memset_s(&channelInfo, sizeof(ProxyChannelInfo), 0, sizeof(ProxyChannelInfo)); in HWTEST_F()
1846 channelInfo.channelId = TEST_MESSAGE_CHANNEL_ID; in HWTEST_F()
1847 channelInfo.reqId = -1; in HWTEST_F()
1848 channelInfo.isServer = -1; in HWTEST_F()
1849 channelInfo.type = CONNECT_BR; in HWTEST_F()
1850 channelInfo.status = -1; in HWTEST_F()
1851 channelInfo.status = PROXY_CHANNEL_STATUS_HANDSHAKEING; in HWTEST_F()
1852 channelInfo in HWTEST_F()
1868 ProxyChannelInfo channelInfo; HWTEST_F() local
[all...]
H A Dtrans_proxy_message_test.cpp663 ProxyChannelInfo channelInfo; in HWTEST_F() local
664 /* test channelInfo is null */ in HWTEST_F()
670 channelInfo.appInfo.appType = APP_TYPE_NOT_CARE; in HWTEST_F()
671 ret = TransProxyAckHandshake(connId, &channelInfo, retCode); in HWTEST_F()
680 ret = TransProxyAckHandshake(connId, &channelInfo, retCode); in HWTEST_F()
684 ret = TransProxyAckHandshake(connId, &channelInfo, retCode); in HWTEST_F()
686 ret = TransProxyAckHandshake(connId, &channelInfo, retCode); in HWTEST_F()
H A Dsoftbus_proxychannel_message_test.cpp641 ProxyChannelInfo channelInfo; in HWTEST_F() local
642 /* test channelInfo is null */ in HWTEST_F()
648 channelInfo.appInfo.appType = APP_TYPE_NOT_CARE; in HWTEST_F()
649 ret = TransProxyAckHandshake(connId, &channelInfo, retCode); in HWTEST_F()
653 ret = TransProxyAckHandshake(connId, &channelInfo, retCode); in HWTEST_F()
656 ret = TransProxyAckHandshake(connId, &channelInfo, retCode); in HWTEST_F()
658 ret = TransProxyAckHandshake(connId, &channelInfo, retCode); in HWTEST_F()
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/src/distributedcameramgr/
H A Ddcamera_sink_dev.cpp95 int32_t DCameraSinkDev::ChannelNeg(std::string& channelInfo) in ChannelNeg() argument
98 if (channelInfo.empty()) { in ChannelNeg()
99 DHLOGE("channelInfo is empty"); in ChannelNeg()
104 int32_t ret = channelInfoCmd.Unmarshal(channelInfo); in ChannelNeg()
106 DHLOGE("channelInfo unmarshal failed, dhId: %{public}s, ret: %{public}d", in ChannelNeg()
/foundation/communication/dsoftbus/core/transmission/trans_channel/auth/src/
H A Dtrans_auth_manager.c168 ChannelInfo channelInfo = {0}; in NotifyOpenAuthChannelSuccess() local
169 channelInfo.channelType = CHANNEL_TYPE_AUTH; in NotifyOpenAuthChannelSuccess()
170 channelInfo.isServer = isServer; in NotifyOpenAuthChannelSuccess()
171 channelInfo.isEnabled = true; in NotifyOpenAuthChannelSuccess()
172 channelInfo.channelId = appInfo->myData.channelId; in NotifyOpenAuthChannelSuccess()
173 channelInfo.peerDeviceId = strlen(appInfo->peerNetWorkId) == 0 ? in NotifyOpenAuthChannelSuccess()
175 channelInfo.peerSessionName = (char *)appInfo->peerData.sessionName; in NotifyOpenAuthChannelSuccess()
176 channelInfo.businessType = BUSINESS_TYPE_NOT_CARE; in NotifyOpenAuthChannelSuccess()
177 channelInfo.groupId = (char *)AUTH_GROUP_ID; in NotifyOpenAuthChannelSuccess()
178 channelInfo in NotifyOpenAuthChannelSuccess()
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/
H A Dtrans_tcp_direct_test.cpp828 ChannelInfo *channelInfo = (ChannelInfo *)SoftBusCalloc(sizeof(ChannelInfo)); in HWTEST_F() local
829 ASSERT_TRUE(channelInfo != nullptr); in HWTEST_F()
830 (void)memset_s(channelInfo, sizeof(ChannelInfo), 0, sizeof(ChannelInfo)); in HWTEST_F()
831 channelInfo->peerSessionName = (char *)g_sessionName; in HWTEST_F()
832 channelInfo->channelId = 1; in HWTEST_F()
833 channelInfo->channelType = CHANNEL_TYPE_TCP_DIRECT; in HWTEST_F()
834 channelInfo->sessionKey = (char *)g_sessionkey; in HWTEST_F()
835 channelInfo->fd = g_fd; in HWTEST_F()
843 SoftBusFree(channelInfo); in HWTEST_F()
/foundation/distributedhardware/distributed_camera/services/cameraservice/base/include/
H A Ddcamera_channel_info_cmd.h57 int32_t UnmarshalDetails(cJSON *details, std::shared_ptr<DCameraChannelInfo> channelInfo);
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/include/distributedcameramgr/
H A Ddcamera_sink_dev.h39 int32_t ChannelNeg(std::string& channelInfo);
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/camera_sink/include/
H A Ddistributed_camera_sink_proxy.h40 int32_t ChannelNeg(const std::string& dhId, std::string& channelInfo) override;
H A Didistributed_camera_sink.h35 virtual int32_t ChannelNeg(const std::string& dhId, std::string& channelInfo) = 0;
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/src/distributedcamera/
H A Ddistributed_camera_sink_stub.cpp214 std::string channelInfo = data.ReadString(); in ChannelNegInner() local
215 if (dhId.empty() || dhId.size() > DID_MAX_SIZE || channelInfo.empty() || in ChannelNegInner()
216 channelInfo.size() > PARAM_MAX_SIZE) { in ChannelNegInner()
221 ret = ChannelNeg(dhId, channelInfo); in ChannelNegInner()
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/camera_sink/src/
H A Ddistributed_camera_sink_proxy.cpp174 int32_t DistributedCameraSinkProxy::ChannelNeg(const std::string& dhId, std::string& channelInfo) in ChannelNeg() argument
177 if (dhId.empty() || dhId.size() > DID_MAX_SIZE || channelInfo.empty() || in ChannelNeg()
178 channelInfo.size() > PARAM_MAX_SIZE) { in ChannelNeg()
195 if (!data.WriteString(dhId) || !data.WriteString(channelInfo)) { in ChannelNeg()
/foundation/distributedhardware/distributed_camera/services/cameraservice/sinkservice/include/distributedcamera/
H A Ddistributed_camera_sink_service.h42 int32_t ChannelNeg(const std::string& dhId, std::string& channelInfo) override;
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/include/
H A Dsoftbus_proxychannel_manager.h73 int32_t TransProxySpecialUpdateChanInfo(ProxyChannelInfo *channelInfo);

Completed in 18 milliseconds

12