Home
last modified time | relevance | path

Searched refs:dataInfo (Results 1 - 25 of 129) sorted by relevance

123456

/foundation/ai/ai_engine/services/common/platform/os_wrapper/ipc/source/
H A Daie_ipc.cpp48 * @param [in] dataInfo Data need to transfer.
51 void IpcIoPushSharedMemory(IpcIo *request, const DataInfo *dataInfo, const uid_t receiverUid) in IpcIoPushSharedMemory() argument
56 while ((shmId = shmget(shmKey, dataInfo->length, SHM_READ_WRITE_PERMISSIONS | IPC_CREAT | IPC_EXCL)) < 0) { in IpcIoPushSharedMemory()
77 if ((retCode = memcpy_s(shared, dataInfo->length, dataInfo->data, dataInfo->length)) != EOK) { in IpcIoPushSharedMemory()
104 WriteInt32(request, dataInfo->length); in IpcIoPushSharedMemory()
111 * @param [out] dataInfo Data received.
114 int IpcIoPopSharedMemory(IpcIo *request, DataInfo *dataInfo) in IpcIoPopSharedMemory() argument
119 ReadInt32(request, &(dataInfo in IpcIoPopSharedMemory()
180 IpcIoPopMemory(IpcIo *request, DataInfo *dataInfo) IpcIoPopMemory() argument
211 ParcelDataInfo(IpcIo *request, const DataInfo *dataInfo, const uid_t receiverUid) ParcelDataInfo() argument
244 UnParcelDataInfo(IpcIo *request, DataInfo *dataInfo) UnParcelDataInfo() argument
272 FreeDataInfo(DataInfo *dataInfo) FreeDataInfo() argument
[all...]
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_control.c39 ProxyDataInfo dataInfo = {0}; in TransProxySendInnerMessage() local
46 dataInfo.inData = (uint8_t *)payLoad; in TransProxySendInnerMessage()
47 dataInfo.inLen = payLoadLen; in TransProxySendInnerMessage()
48 if (TransProxyPackMessage(&msgHead, info->authHandle, &dataInfo) != SOFTBUS_OK) { in TransProxySendInnerMessage()
52 return TransProxyTransSendMsg(info->connId, dataInfo.outData, dataInfo.outLen, in TransProxySendInnerMessage()
114 ProxyDataInfo dataInfo = {0}; in TransProxyHandshake() local
132 dataInfo.inData = (uint8_t *)payLoad; in TransProxyHandshake()
133 dataInfo.inLen = strlen(payLoad) + 1; in TransProxyHandshake()
134 if (TransProxyPackMessage(&msgHead, info->authHandle, &dataInfo) ! in TransProxyHandshake()
163 ProxyDataInfo dataInfo = {0}; TransProxyAckHandshake() local
209 ProxyDataInfo dataInfo = {0}; TransProxyKeepalive() local
245 ProxyDataInfo dataInfo = {0}; TransProxyAckKeepalive() local
284 ProxyDataInfo dataInfo = {0}; TransProxyResetPeer() local
[all...]
H A Dsoftbus_proxychannel_message.c297 int32_t PackPlaintextMessage(ProxyMessageHead *msg, ProxyDataInfo *dataInfo) in PackPlaintextMessage() argument
299 if (msg == NULL || dataInfo == NULL) { in PackPlaintextMessage()
304 uint32_t size = PROXY_CHANNEL_HEAD_LEN + connHeadLen + dataInfo->inLen; in PackPlaintextMessage()
312 dataInfo->inData, dataInfo->inLen) != EOK) { in PackPlaintextMessage()
317 dataInfo->outData = buf; in PackPlaintextMessage()
318 dataInfo->outLen = size; in PackPlaintextMessage()
322 static int32_t PackEncryptedMessage(ProxyMessageHead *msg, AuthHandle authHandle, ProxyDataInfo *dataInfo) in PackEncryptedMessage() argument
329 AuthGetEncryptSize(authHandle.authId, dataInfo->inLen); in PackEncryptedMessage()
338 if (AuthEncrypt(&authHandle, dataInfo in PackEncryptedMessage()
348 TransProxyPackMessage(ProxyMessageHead *msg, AuthHandle authHandle, ProxyDataInfo *dataInfo) TransProxyPackMessage() argument
941 TransProxyPackFastDataHead(ProxyDataInfo *dataInfo, const AppInfo *appInfo) TransProxyPackFastDataHead() argument
981 TransProxyMessageData(const AppInfo *appInfo, ProxyDataInfo *dataInfo) TransProxyMessageData() argument
998 TransProxyByteData(const AppInfo *appInfo, ProxyDataInfo *dataInfo) TransProxyByteData() argument
1021 ProxyDataInfo dataInfo = {0}; TransProxyPackFastData() local
[all...]
/foundation/ai/ai_engine/services/common/utils/encdec/include/
H A Dencdec_facade.h34 * 1. the memory in dataInfo should be released manually by the caller,
37 * MallocPointerGuard<unsigned char> dataInfoGuard(dataInfo.data);
54 static int ProcessEncode(DataInfo &dataInfo, const Type &arg, const Types &...args) in ProcessEncode() argument
67 retCode = dataEncoder.GetSerializedData(dataInfo); in ProcessEncode()
73 if (dataInfo.length <= 0 || dataInfo.data == nullptr) { in ProcessEncode()
74 HILOGE("[Encdec]dataInfo is invalid."); in ProcessEncode()
91 static int ProcessDecode(const DataInfo &dataInfo, Type &arg, Types &...args) in ProcessDecode() argument
93 if (dataInfo.data == nullptr || dataInfo in ProcessDecode()
[all...]
H A Ddata_decoder.h31 explicit DataDecoder(const DataInfo dataInfo) : buffer_(dataInfo.data), size_(dataInfo.length), pos_(0) in DataDecoder() argument
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_local_db_observer.cpp29 for (const auto &dataInfo : data) { in OnChange()
30 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_INSERT); in OnChange()
31 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_UPDATE); in OnChange()
32 Convert(dataInfo, changeInfo, RdbStoreObserver::ChangeType::CHG_TYPE_DELETE); in OnChange()
39 void RdbStoreLocalDbObserver::Convert(const DistributedDB::ChangedData &dataInfo, in Convert() argument
46 changeInfo.try_emplace(dataInfo.tableName); in Convert()
47 for (const auto &primary : dataInfo.primaryData[changeType]) { in Convert()
50 changeInfo[dataInfo.tableName][changeType].push_back(std::move(primaryKey)); in Convert()
/foundation/multimedia/drm_framework/interfaces/kits/c/drm_capi/common/
H A Dnative_drm_object.h109 unsigned char *dataInfo = nullptr; variable
111 dataInfo = (unsigned char *)malloc(data.size());
112 DRM_CHECK_AND_RETURN_LOG(dataInfo != nullptr, "malloc faild!");
113 errno_t ret = memcpy_s(dataInfo, data.size(), data.data(), data.size());
116 free(dataInfo); variable
117 dataInfo = nullptr;
123 callback_(eventMap_[event], dataInfo, data.size(), std::to_string(extra).data());
126 systemCallback_(system_, eventMap_[event], dataInfo, data.size(), std::to_string(extra).data());
129 if (dataInfo != nullptr) {
130 free(dataInfo); variable
203 unsigned char *dataInfo = nullptr; global() variable
210 free(dataInfo); global() variable
225 free(dataInfo); global() variable
[all...]
/foundation/ai/ai_engine/services/common/utils/encdec/source/
H A Ddata_encoder.cpp66 int DataEncoder::GetSerializedData(DataInfo &dataInfo) in GetSerializedData() argument
74 dataInfo.length = pos_; in GetSerializedData()
75 dataInfo.data = reinterpret_cast<unsigned char*>(malloc(dataInfo.length)); in GetSerializedData()
76 if (dataInfo.data == nullptr) { in GetSerializedData()
79 errno_t res = memcpy_s(dataInfo.data, dataInfo.length, buffer_->data, pos_); in GetSerializedData()
81 free(dataInfo.data); in GetSerializedData()
82 dataInfo.data = nullptr; in GetSerializedData()
83 dataInfo in GetSerializedData()
[all...]
/foundation/ai/ai_engine/test/common/encdec/
H A Dencdec_test.cpp149 void PolluteData(DataInfo &dataInfo) in PolluteData() argument
151 *(reinterpret_cast<size_t*>(dataInfo.data + dataInfo.length - sizeof(size_t))) = 0U; in PolluteData()
156 DataInfo dataInfo {}; in BasicTypesCheck()
157 int retCode = EncdecFacade::ProcessEncode(dataInfo, g_int, g_char, g_float, g_long, g_string, g_emptyString); in BasicTypesCheck()
158 MallocPointerGuard<unsigned char> dataInfoGuard(dataInfo.data); in BasicTypesCheck()
161 PolluteData(dataInfo); in BasicTypesCheck()
170 retCode = EncdecFacade::ProcessDecode(dataInfo, outInt, outChar, outFloat, outLong, outString, in BasicTypesCheck()
187 DataInfo dataInfo {}; in StructCheck()
192 int retCode = EncdecFacade::ProcessEncode(dataInfo, structWithPaddin in StructCheck()
[all...]
/foundation/communication/dsoftbus/tests/core/common/dfx/statistics/unittest/
H A Dtrans_network_statistics_test.cpp108 const void *dataInfo = "testData"; in HWTEST_F() local
110 EXPECT_EQ(SOFTBUS_INVALID_PARAM, ChannelStatisticsInfoInit(nullptr, channelId, dataInfo, len)); in HWTEST_F()
115 * @tc.desc: Test ChannelStatisticsInfoInit when dataInfo is nullptr.
137 const void *dataInfo = "testData"; in HWTEST_F() local
139 EXPECT_EQ(SOFTBUS_INVALID_PARAM, ChannelStatisticsInfoInit(&info, channelId, dataInfo, len)); in HWTEST_F()
152 const void *dataInfo = "testData"; in HWTEST_F() local
154 EXPECT_EQ(SOFTBUS_OK, ChannelStatisticsInfoInit(&info, channelId, dataInfo, len)); in HWTEST_F()
262 * @tc.desc: Test UpdateNetworkResourceByLaneId when dataInfo is nullptr.
271 const void *dataInfo = nullptr; in HWTEST_F() local
273 UpdateNetworkResourceByLaneId(channelId, channelType, laneId, dataInfo, le in HWTEST_F()
[all...]
/foundation/ai/ai_engine/services/common/platform/os_wrapper/ipc/include/
H A Daie_ipc.h31 * @param [in] dataInfo Data to transfer.
34 void ParcelDataInfo(IpcIo *request, const DataInfo *dataInfo, const uid_t receiverUid);
38 * Note: the returned dataInfo must release by {@link FreeDataInfo}.
41 * @param [out] dataInfo Data received.
44 int UnParcelDataInfo(IpcIo *request, DataInfo *dataInfo);
47 * Free dataInfo.
49 * @param [in] dataInfo data to be freed.
51 void FreeDataInfo(DataInfo *dataInfo);
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/
H A Dclient_trans_proxy_manager.c401 static int32_t ClientTransProxyDecryptPacketData(int32_t channelId, int32_t seq, ClientProxyDataInfo *dataInfo) in ClientTransProxyDecryptPacketData() argument
416 &cipherKey, dataInfo->inData, dataInfo->inLen, dataInfo->outData, &(dataInfo->outLen), seq); in ClientTransProxyDecryptPacketData()
523 ClientProxyDataInfo dataInfo = { 0 }; in ClientTransProxyProcessSessionData() local
532 dataInfo.outData = (unsigned char *)SoftBusCalloc(outLen); in ClientTransProxyProcessSessionData()
533 if (dataInfo.outData == NULL) { in ClientTransProxyProcessSessionData()
537 dataInfo.inData = (unsigned char *)data; in ClientTransProxyProcessSessionData()
538 dataInfo in ClientTransProxyProcessSessionData()
914 ClientTransProxyPackBytes( int32_t channelId, ClientProxyDataInfo *dataInfo, int seq, char *sessionKey, SessionPktType flag) ClientTransProxyPackBytes() argument
978 ClientProxyDataInfo dataInfo = { (uint8_t *)data, len, (uint8_t *)data, len }; TransProxyPackAndSendData() local
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/
H A Dsoftbus_proxychannel_message_test.cpp400 ProxyDataInfo dataInfo; in HWTEST_F() local
402 int32_t ret = TransProxyPackMessage(NULL, authHandle, &dataInfo); in HWTEST_F()
408 dataInfo.inData = NULL; in HWTEST_F()
409 ret = TransProxyPackMessage(&msg, authHandle, &dataInfo); in HWTEST_F()
412 dataInfo.inData = 0; in HWTEST_F()
413 ret = TransProxyPackMessage(&msg, authHandle, &dataInfo); in HWTEST_F()
418 ret = TransProxyPackMessage(&msg, authHandle, &dataInfo); in HWTEST_F()
421 dataInfo.inData = (uint8_t *)"1"; in HWTEST_F()
422 dataInfo.inLen = strlen((const char*)dataInfo in HWTEST_F()
438 ProxyDataInfo dataInfo; HWTEST_F() local
762 ProxyDataInfo *dataInfo = (ProxyDataInfo *)SoftBusCalloc(sizeof(ProxyDataInfo)); HWTEST_F() local
811 ProxyDataInfo *dataInfo = (ProxyDataInfo *)SoftBusCalloc(sizeof(ProxyDataInfo)); HWTEST_F() local
1094 ProxyDataInfo dataInfo; HWTEST_F() local
[all...]
H A Dtrans_proxy_message_test.cpp340 ProxyDataInfo dataInfo; in HWTEST_F() local
341 int32_t ret = TransProxyPackMessage(NULL, authHandle, &dataInfo); in HWTEST_F()
347 dataInfo.inData = NULL; in HWTEST_F()
348 ret = TransProxyPackMessage(&msg, authHandle, &dataInfo); in HWTEST_F()
351 dataInfo.inData = 0; in HWTEST_F()
352 ret = TransProxyPackMessage(&msg, authHandle, &dataInfo); in HWTEST_F()
357 ret = TransProxyPackMessage(&msg, authHandle, &dataInfo); in HWTEST_F()
360 dataInfo.inData = (uint8_t *)"1"; in HWTEST_F()
361 dataInfo.inLen = strlen((const char*)dataInfo in HWTEST_F()
378 ProxyDataInfo dataInfo; HWTEST_F() local
[all...]
/foundation/ai/ai_engine/test/sample/source/
H A Dsample_plugin_2.cpp33 void FreeDataInfo(DataInfo *dataInfo) in FreeDataInfo() argument
35 if (dataInfo != nullptr && dataInfo->data != nullptr) { in FreeDataInfo()
36 free(dataInfo->data); in FreeDataInfo()
37 dataInfo->data = nullptr; in FreeDataInfo()
38 dataInfo->length = 0; in FreeDataInfo()
H A Dsample_plugin_1.cpp33 void FreeDataInfo(DataInfo *dataInfo) in FreeDataInfo() argument
35 if (dataInfo != nullptr && dataInfo->data != nullptr) { in FreeDataInfo()
36 free(dataInfo->data); in FreeDataInfo()
37 dataInfo->data = nullptr; in FreeDataInfo()
38 dataInfo->length = 0; in FreeDataInfo()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/
H A Dapp_pipe_mgr.cpp57 Status AppPipeMgr::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, in SendData() argument
60 if (dataInfo.length > MAX_TRANSFER_SIZE || dataInfo.length <= 0 || dataInfo.data == nullptr in SendData()
62 LOG_WARN("Input is invalid, maxSize:%{public}d, current size:%{public}u", MAX_TRANSFER_SIZE, dataInfo.length); in SendData()
65 LOG_DEBUG("pipeInfo:%{public}s ,size:%{public}u", pipeInfo.pipeId.c_str(), dataInfo.length); in SendData()
76 return appPipeHandler->SendData(pipeInfo, deviceId, dataInfo, totalLength, info); in SendData()
/foundation/ai/ai_engine/test/performance/reliability/aie_client/
H A Daie_client_reliability_test.cpp72 static void FreeDataInfo(DataInfo &dataInfo) in FreeDataInfo() argument
74 if (dataInfo.data == nullptr || dataInfo.length <= 0) { in FreeDataInfo()
77 free(dataInfo.data); in FreeDataInfo()
78 dataInfo.data = nullptr; in FreeDataInfo()
79 dataInfo.length = 0; in FreeDataInfo()
/foundation/communication/dsoftbus/tests/core/authentication/fuzztest/authdata_fuzzer/
H A Dauthdata_fuzzer.cpp60 AuthTransData *dataInfo = (AuthTransData *)SoftBusMalloc(sizeof(AuthTransData)); in AuthDataFuzzTest() local
61 if (dataInfo == nullptr) { in AuthDataFuzzTest()
62 COMM_LOGE(COMM_TEST, "dataInfo is NULL"); in AuthDataFuzzTest()
65 if (memcpy_s(dataInfo, sizeof(AuthTransData), outData, sizeof(AuthTransData)) != EOK) { in AuthDataFuzzTest()
67 SoftBusFree(dataInfo); in AuthDataFuzzTest()
70 AuthPostTransData(authHandle, dataInfo); in AuthDataFuzzTest()
71 SoftBusFree(dataInfo); in AuthDataFuzzTest()
/foundation/multimedia/image_effect/test/unittest/
H A Dimage_effect_inner_unittest.cpp179 DataInfo dataInfo; in HWTEST_F() local
185 dataInfo.dataType_ = DataType::PATH; in HWTEST_F()
186 dataInfo.path_ = "path"; in HWTEST_F()
187 EXPECT_EQ(imageEffect->ParseDataInfo(dataInfo, effectBuffer, true), ErrorCode::SUCCESS); in HWTEST_F()
189 dataInfo.dataType_ = DataType::NATIVE_WINDOW; in HWTEST_F()
190 EXPECT_EQ(imageEffect->ParseDataInfo(dataInfo, effectBuffer, false), ErrorCode::SUCCESS); in HWTEST_F()
192 dataInfo.dataType_ = DataType::UNKNOWN; in HWTEST_F()
193 EXPECT_EQ(imageEffect->ParseDataInfo(dataInfo, effectBuffer, false), ErrorCode::ERR_NO_DATA); in HWTEST_F()
195 dataInfo.dataType_ = static_cast<DataType>(100); in HWTEST_F()
196 EXPECT_EQ(imageEffect->ParseDataInfo(dataInfo, effectBuffe in HWTEST_F()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dapp_pipe_mgr.cpp61 Status AppPipeMgr::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo &dataInfo, in SendData() argument
64 if (dataInfo.length > DataBuffer::MAX_TRANSFER_SIZE || dataInfo.length == 0 || dataInfo.data == nullptr || in SendData()
66 ZLOGW("Input is invalid, maxSize:%u, current size:%u", DataBuffer::MAX_TRANSFER_SIZE, dataInfo.length); in SendData()
69 ZLOGD("pipeInfo:%s ,size:%u, total length:%u", pipeInfo.pipeId.c_str(), dataInfo.length, totalLength); in SendData()
80 return appPipeHandler->SendData(pipeInfo, deviceId, dataInfo, totalLength, info); in SendData()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dvirtual_cloud_syncer.cpp114 DataInfo dataInfo; in CallTagStatusByStrategy() local
115 dataInfo.localInfo = localInfo; in CallTagStatusByStrategy()
116 dataInfo.cloudLogInfo = cloudInfo; in CallTagStatusByStrategy()
117 return CloudSyncer::TagStatusByStrategy(isExist, param, dataInfo, strategyOpResult); in CallTagStatusByStrategy()
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/accessor/src/
H A Dmetadata_accessor_factory.cpp51 DataInfo dataInfo {buffer, size}; in Create()
53 return Create(dataInfo, error, mode); in Create()
68 std::shared_ptr<MetadataAccessor> MetadataAccessorFactory::Create(const DataInfo &dataInfo, uint32_t &error, in Create() argument
73 if (dataInfo.buffer == nullptr) { in Create()
76 std::shared_ptr<MetadataStream> stream = std::make_shared<BufferMetadataStream>(dataInfo.buffer, dataInfo.size, in Create()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/
H A Dapp_pipe_mgr_test.cpp261 const DataInfo dataInfo = { const_cast<uint8_t *>(ptr), size }; in HWTEST_F() local
265 auto ret = appPipeMgr.SendData(pipeInfo, deviceId, dataInfo, size, messageInfo); in HWTEST_F()
271 ret = appPipeMgr.SendData(pipeInfo1, deviceId1, dataInfo, size, messageInfo); in HWTEST_F()
274 // dataInfo.length is less than or equal to 0 in HWTEST_F()
280 // dataInfo.length exceeds limit in HWTEST_F()
286 // dataInfo.data is nullptr in HWTEST_F()
304 const DataInfo dataInfo = { const_cast<uint8_t *>(ptr), size }; in HWTEST_F() local
307 auto ret = appPipeMgr->SendData(pipeInfo, deviceId, dataInfo, size, messageInfo); in HWTEST_F()
323 const DataInfo dataInfo = { const_cast<uint8_t *>(ptr), size }; in HWTEST_F() local
328 ret = appPipeMgr.SendData(pipeInfo, deviceId, dataInfo, siz in HWTEST_F()
[all...]
/foundation/ai/ai_engine/services/server/communication_adapter/source/
H A Dsa_server.c84 DataInfo dataInfo = {NULL, 0}; in UnParcelClientInfo() local
85 int retCode = UnParcelDataInfo(request, &dataInfo); in UnParcelClientInfo()
87 clientInfo->extendLen = dataInfo.length; in UnParcelClientInfo()
88 clientInfo->extendMsg = dataInfo.data; in UnParcelClientInfo()
114 DataInfo dataInfo = {NULL, 0}; in UnParcelAlgorithmInfo() local
115 int retCode = UnParcelDataInfo(request, &dataInfo); in UnParcelAlgorithmInfo()
117 algorithmInfo->extendLen = dataInfo.length; in UnParcelAlgorithmInfo()
118 algorithmInfo->extendMsg = dataInfo.data; in UnParcelAlgorithmInfo()
144 static int UnParcelInfo(IpcIo *req, ClientInfo *clientInfo, AlgorithmInfo *algorithmInfo, DataInfo *dataInfo) in UnParcelInfo() argument
159 retCode = UnParcelDataInfo(req, dataInfo); in UnParcelInfo()
[all...]

Completed in 13 milliseconds

123456