/foundation/resourceschedule/ffrt/src/sync/ |
H A D | poller.h | 55 : fd(fdVal), data(dataVal), cb(cbVal), task(taskVal) in WakeDataWithCb() 59 void* data = nullptr; member 68 : data(dataVal), cb(cbVal), task(taskVal), repeat(repeat), timeout(timeout) in TimerDataWithCb() 71 void* data = nullptr; member 98 int AddFdEvent(int op, uint32_t events, int fd, void* data, ffrt_poller_cb cb) noexcept; 105 int RegisterTimer(uint64_t timeout, void* data, ffrt_timer_cb cb, bool repeat = false) noexcept; 126 void RegisterTimerImpl(const TimerDataWithCb& data) noexcept;
|
/foundation/window/window_manager/test/fuzztest/window_scene/screensessionmanagerclientstub_fuzzer/ |
H A D | screensessionmanagerclientstub_fuzzer.cpp | 37 size_t GetObject(T &object, const uint8_t *data, size_t size) in GetObject() argument 43 return memcpy_s(&object, objectSize, data, objectSize) == EOK ? objectSize : 0; in GetObject() 109 bool DoSomethingInterestingWithMyAPI(const uint8_t* data, size_t size) in DoSomethingInterestingWithMyAPI() argument 111 if (data == nullptr || size < DATA_MIN_SIZE) { in DoSomethingInterestingWithMyAPI() 120 parcel.WriteBuffer(data, size); in DoSomethingInterestingWithMyAPI() 129 extern "C" int LLVMFuzzerTestOneInput(const uint8_t* data, size_t size) in LLVMFuzzerTestOneInput() argument 131 /* Run your code on data */ in LLVMFuzzerTestOneInput() 132 OHOS::DoSomethingInterestingWithMyAPI(data, size); in LLVMFuzzerTestOneInput()
|
/foundation/communication/netmanager_base/test/fuzztest/netbasebranch_fuzzer/ |
H A D | net_base_branch_fuzzer.cpp | 75 void NetHttpProbeBranchFuzzTest(const uint8_t *data, size_t size) in NetHttpProbeBranchFuzzTest() argument 77 if ((data == nullptr) || (size < 1)) { in NetHttpProbeBranchFuzzTest() 118 void NetPolicyRuleBranchFuzzTest(const uint8_t *data, size_t size) in NetPolicyRuleBranchFuzzTest() argument 120 if ((data == nullptr) || (size < 1)) { in NetPolicyRuleBranchFuzzTest() 141 extern "C" int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) in LLVMFuzzerTestOneInput() argument 143 /* Run your code on data */ in LLVMFuzzerTestOneInput() 144 OHOS::NetManagerStandard::NetHttpProbeBranchFuzzTest(data, size); in LLVMFuzzerTestOneInput() 145 OHOS::NetManagerStandard::NetPolicyRuleBranchFuzzTest(data, size); in LLVMFuzzerTestOneInput()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/iprocesscommunicator_fuzzer/ |
H A D | iprocesscommunicator_fuzzer.cpp | 90 void FuzzOnDataReceive(const DistributedDB::DeviceInfos &devInfo, const uint8_t* data, size_t size) in FuzzOnDataReceive() argument 95 onDataReceive_(devInfo, data, size); in FuzzOnDataReceive() 150 void CommunicatorFuzzer(const uint8_t *data, size_t size) in CommunicatorFuzzer() argument 153 std::string rawString(reinterpret_cast<const char*>(data), size); in CommunicatorFuzzer() 176 communicator->FuzzOnDataReceive(device, data, size); in CommunicatorFuzzer() 185 extern "C" int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) in LLVMFuzzerTestOneInput() argument 191 OHOS::CommunicatorFuzzer(data, size); in LLVMFuzzerTestOneInput()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | rdb_result_set_stub_test.cpp | 62 uint8_t *data = &value;
in HWTEST_F() local 66 request2.WriteBuffer(data, size);
in HWTEST_F() 97 uint8_t *data = &value;
in HWTEST_F() local 101 request1.WriteBuffer(data, size);
in HWTEST_F() 112 request2.WriteBuffer(data, size);
in HWTEST_F() 136 uint8_t *data = &value;
in HWTEST_F() local 140 request.WriteBuffer(data, size);
in HWTEST_F()
|
/foundation/filemanagement/app_file_service/interfaces/kits/js/backup/ |
H A D | general_callbacks.cpp | 50 work->data = static_cast<void *>(ctx_); in ~BackupRestoreCallback() 55 LibN::NAsyncContextCallback *ctx = static_cast<LibN::NAsyncContextCallback *>(work->data); in ~BackupRestoreCallback() 73 static void DoCallJsMethod(napi_env env, void *data, InputArgsParser argParser) in DoCallJsMethod() argument 82 auto ctx = static_cast<LibN::NAsyncContextCallback *>(data); in DoCallJsMethod() 100 napi_status status = napi_call_function(env, global, callback, argv.size(), argv.data(), &result); in DoCallJsMethod() 125 work->data = reinterpret_cast<void *>(workArgs.get()); in CallJsMethod() 133 auto workArgs = reinterpret_cast<WorkArgs *>(work->data); in CallJsMethod()
|
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/ |
H A D | message_handler.cpp | 41 bool MessageHandler::PackData(uint8_t *data, uint32_t totalLen) in PackData() argument 43 if (!data || totalLen < dataSize_) { in PackData() 48 uint8_t *ptr = data; in PackData() 77 uint8_t *end = data + totalLen; in PackData() 86 bool MessageHandler::UnPackData(uint8_t *data, uint32_t totalLen) in UnPackData() argument 88 if (!data || totalLen < sizeof(MessageHeader)) { in UnPackData() 89 LOGE("invalid input data, totalLen:%{public}d", totalLen); in UnPackData() 93 uint8_t *ptr = data; in UnPackData() 102 LOGE("not valid data"); in UnPackData()
|
/foundation/ai/ai_engine/services/server/plugin/asr/keyword_spotting/source/ |
H A D | kws_plugin.cpp | 33 const std::string PLUGIN_MODEL_PATH = "/storage/data/keyword_spotting.wk";
157 if (inputInfo.data == nullptr || inputInfo.length <= 0) {
in SyncProcess() 158 HILOGE("[KWSPlugin]SyncProcess inputInfo data is nullptr");
in SyncProcess() 163 .data = nullptr,
in SyncProcess() 177 .data = nullptr,
in SyncProcess() 186 .data = nullptr,
in SyncProcess() 203 .data = static_cast<void *>(input.data),
in GetNormedFeatures() 208 .data = nullptr,
in GetNormedFeatures() 218 .data in GetNormedFeatures() [all...] |
/foundation/ai/intelligent_voice_framework/utils/ |
H A D | huks_aes_adapter.cpp | 98 .data = reinterpret_cast<uint8_t*>(g_aadValue) in CreateEncryptParamSet() 104 .data = encryptNonce->data in CreateEncryptParamSet() 144 .data = reinterpret_cast<uint8_t*>(g_aadValue) in CreateDecryptParamSet() 150 .data = decryptNonce->data in CreateDecryptParamSet() 156 .data = decryptAead->data in CreateDecryptParamSet() 212 (void)memcpy_s(encryptData.get(), NONCE_SIZE, encryptNonce.data, encryptNonce.size); in Encrypt() 265 outBuffer = CreateArrayBuffer<uint8_t>(outData.size, outData.data); in Decrypt() [all...] |
/foundation/CastEngine/castengine_wifi_display/services/utils/ |
H A D | utils.cpp | 190 void SaveFile(const char *data, int32_t dataSize, const std::string &fileName) in SaveFile() argument 192 RETURN_IF_NULL(data); in SaveFile() 199 out.write(data, dataSize); in SaveFile() 285 uint8_t *data = (uint8_t *)p; in SetBE24() local 286 data[0] = val >> 16; // 16: byte offset in SetBE24() 287 data[1] = val >> 8; // 8: byte offset in SetBE24() 288 data[2] = val; // 2: transformed position in SetBE24() 294 uint8_t *data = (uint8_t *)p; in SetBE32() local 295 data[3] = val; // 3: transformed position in SetBE32() 296 data[ in SetBE32() 304 uint8_t *data = (uint8_t *)p; SetLE32() local [all...] |
/foundation/multimedia/audio_framework/frameworks/native/pulseaudio/modules/capturer/ |
H A D | module_inner_capturer_sink.c | 99 static int SinkProcessMsg(pa_msgobject *o, int code, void *data, int64_t offset, pa_memchunk *chunk) in SinkProcessMsg() argument 103 *((int64_t*) data) = 0; in SinkProcessMsg() 109 return pa_sink_process_msg(o, code, data, offset, chunk); in SinkProcessMsg() 318 /* Render some data and drop it immediately */ in ThreadFunc() 365 pa_sink_new_data data; in CreateSink() local 377 pa_sink_new_data_init(&data); in CreateSink() 378 data.driver = __FILE__; in CreateSink() 379 data.module = m; in CreateSink() 380 pa_sink_new_data_set_name(&data, pa_modargs_get_value(ma, "sink_name", DEFAULT_SINK_NAME)); in CreateSink() 381 pa_sink_new_data_set_sample_spec(&data, in CreateSink() [all...] |
/foundation/multimedia/av_codec/test/nativedemo/audio_demo/ |
H A D | avcodec_audio_aac_encoder_demo.cpp | 40 constexpr string_view INPUT_FILE_PATH = "/data/test/media/aac_2c_44100hz_199k.pcm"; 41 constexpr string_view OUTPUT_FILE_PATH = "/data/test/media/encode2.aac"; 60 static void OnInputBufferAvailable(OH_AVCodec *codec, uint32_t index, OH_AVMemory *data, void *userData) in OnInputBufferAvailable() argument 66 signal->inBufferQueue_.push(data); in OnInputBufferAvailable() 70 static void OnOutputBufferAvailable(OH_AVCodec *codec, uint32_t index, OH_AVMemory *data, OH_AVCodecBufferAttr *attr, in OnOutputBufferAvailable() argument 77 signal->outBufferQueue_.push(data); in OnOutputBufferAvailable() 94 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_CHANNEL_COUNT.data(), CHANNEL_COUNT); in RunCase() 95 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_SAMPLE_RATE.data(), SAMPLE_RATE); in RunCase() 96 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_AUDIO_SAMPLE_FORMAT.data(), SAMPLE_FORMAT); in RunCase() 107 OH_AVFormat_GetIntValue(fmt, MediaDescriptionKey::MD_KEY_CHANNEL_COUNT.data(), in RunCase() 353 OH_AVMemory *data = signal_->outBufferQueue_.front(); OutputFunc() local [all...] |
H A D | avcodec_audio_g711mu_encoder_demo.cpp | 40 constexpr string_view INPUT_FILE_PATH = "/data/test/media/g711mu_8kHz_10s.pcm"; 41 constexpr string_view OUTPUT_FILE_PATH = "/data/test/media/g711mu_8kHz_10s_afterEncode.raw"; 60 static void OnInputBufferAvailable(OH_AVCodec *codec, uint32_t index, OH_AVMemory *data, void *userData) in OnInputBufferAvailable() argument 66 signal->inBufferQueue_.push(data); in OnInputBufferAvailable() 70 static void OnOutputBufferAvailable(OH_AVCodec *codec, uint32_t index, OH_AVMemory *data, OH_AVCodecBufferAttr *attr, in OnOutputBufferAvailable() argument 77 signal->outBufferQueue_.push(data); in OnOutputBufferAvailable() 94 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_CHANNEL_COUNT.data(), CHANNEL_COUNT); in RunCase() 95 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_SAMPLE_RATE.data(), SAMPLE_RATE); in RunCase() 96 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_AUDIO_SAMPLE_FORMAT.data(), SAMPLE_FORMAT); in RunCase() 107 OH_AVFormat_GetIntValue(fmt, MediaDescriptionKey::MD_KEY_CHANNEL_COUNT.data(), in RunCase() 319 OH_AVMemory *data = signal_->outBufferQueue_.front(); OutputFunc() local [all...] |
/foundation/multimedia/av_codec/test/nativedemo/video_demo/ |
H A D | avcodec_video_decoder_demo.cpp | 51 constexpr string_view inputFilePath = "/data/test/media/out_320_240_10s.h264"; 52 constexpr string_view outputFilePath = "/data/test/media/out_320_240_10s.yuv"; 53 constexpr string_view outputSurfacePath = "/data/test/media/out_320_240_10s.rgba"; 74 static void OnInputBufferAvailable(OH_AVCodec *codec, uint32_t index, OH_AVMemory *data, void *userData) in OnInputBufferAvailable() argument 81 signal_->inBufferQueue_.push(data); in OnInputBufferAvailable() 85 static void OnOutputBufferAvailable(OH_AVCodec *codec, uint32_t index, OH_AVMemory *data, OH_AVCodecBufferAttr *attr, in OnOutputBufferAvailable() argument 94 signal_->outBufferQueue_.push(data); in OnOutputBufferAvailable() 109 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_WIDTH.data(), DEFAULT_WIDTH); in RunCase() 110 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_HEIGHT.data(), DEFAULT_HEIGHT); in RunCase() 111 OH_AVFormat_SetIntValue(format, MediaDescriptionKey::MD_KEY_PIXEL_FORMAT.data(), in RunCase() 433 OH_AVMemory *data = signal_->outBufferQueue_.front(); OutputFunc() local [all...] |
/foundation/multimedia/media_library/frameworks/js/src/ |
H A D | highlight_album_napi.cpp | 146 static void JSGetHighlightAlbumInfoExecute(napi_env env, void *data) in JSGetHighlightAlbumInfoExecute() argument 151 auto *context = static_cast<HighlightAlbumNapiAsyncContext*>(data); in JSGetHighlightAlbumInfoExecute() 193 static void JSGetHighlightAlbumInfoCompleteCallback(napi_env env, napi_status status, void *data) in JSGetHighlightAlbumInfoCompleteCallback() argument 198 auto *context = static_cast<HighlightAlbumNapiAsyncContext *>(data); in JSGetHighlightAlbumInfoCompleteCallback() 204 CHECK_ARGS_RET_VOID(env, napi_get_undefined(env, &jsContext->data), JS_INNER_FAIL); in JSGetHighlightAlbumInfoCompleteCallback() 208 NAPI_AUTO_LENGTH, &jsContext->data), JS_INNER_FAIL); in JSGetHighlightAlbumInfoCompleteCallback() 222 static void JSSetHighlightUserActionDataExecute(napi_env env, void *data) in JSSetHighlightUserActionDataExecute() argument 227 auto *context = static_cast<HighlightAlbumNapiAsyncContext*>(data); in JSSetHighlightUserActionDataExecute() 245 NAPI_ERR_LOG("highlight user action data get rdbstore failed"); in JSSetHighlightUserActionDataExecute() 256 NAPI_ERR_LOG("highlight user action data resultSe in JSSetHighlightUserActionDataExecute() 262 JSSetHighlightUserActionDataCompleteCallback(napi_env env, napi_status status, void *data) JSSetHighlightUserActionDataCompleteCallback() argument 301 JSGetHighlightResourceExecute(napi_env env, void *data) JSGetHighlightResourceExecute() argument 343 JSGetHighlightResourceCompleteCallback(napi_env env, napi_status status, void *data) JSGetHighlightResourceCompleteCallback() argument [all...] |
/foundation/communication/ipc/ipc/native/src/core/source/ |
H A D | message_parcel.cpp | 298 uintptr_t data = GetData(); in ClearFileDescriptor() local 299 if (data == 0) { in ClearFileDescriptor() 300 ZLOGE(LOG_LABEL, "data get by GetData() is invalid"); in ClearFileDescriptor() 303 flat = reinterpret_cast<flat_binder_object *>(data + object[i]); in ClearFileDescriptor() 328 uintptr_t data = GetData(); in ContainFileDescriptors() local 329 if (data == 0) { in ContainFileDescriptors() 330 ZLOGE(LOG_LABEL, "data get by GetData() is invalid"); in ContainFileDescriptors() 333 flat = reinterpret_cast<flat_binder_object *>(data + object[i]); in ContainFileDescriptors() 375 bool MessageParcel::WriteRawData(const void *data, size_t size) in WriteRawData() argument 377 if (data in WriteRawData() 557 Append(MessageParcel &data) Append() argument 619 auto data = reinterpret_cast<const uint8_t *>(GetData()); PrintBuffer() local [all...] |
/foundation/filemanagement/app_file_service/tools/backup_tool/src/ |
H A D | tools_op_incremental_restore_async.cpp | 91 return "\tThis operation helps to restore application data.\n" in GenHelpMsg() 104 // Only manage.json was in data/backup/receive; in OnFileReady() 105 // Other flles and tars was in data/backup/receive + bundle + path is manage.json in OnFileReady() 111 // data path: /data/backup/incrementalreceived/bundleName/{timestamp}/incremental/{filename} in OnFileReady() 116 if (access(tmpPath.data(), F_OK) != 0) { in OnFileReady() 121 UniqueFd fdLocal(open(tmpPath.data(), O_RDONLY)); in OnFileReady() 186 // To support file with different path but same name, create directories in /data/backup/receive in ReadyExtManage() 191 if (!ForceCreateDirectory(realPathInReceive.data())) { in ReadyExtManage() 195 if (rename(currentNameInReceive.data(), realNameInReceiv in ReadyExtManage() [all...] |
/foundation/distributedhardware/distributed_screen/services/screentransport/screendatachannel/src/ |
H A D | screen_data_channel_impl.cpp | 39 DHLOGE("%{public}s: Create data session failed ret: %{public}" PRId32, DSCREEN_LOG_TAG, ret); in CreateSession() 45 DHLOGE("%{public}s: Register data adapter listener failed ret: %{public}" PRId32, DSCREEN_LOG_TAG, ret); in CreateSession() 77 DHLOGE("%{public}s: Release data session failed ret: %{public}" PRId32, DSCREEN_LOG_TAG, ret); in ReleaseSession() 82 DHLOGE("%{public}s: UnRegister data adapter listener failed ret: %{public}" PRId32, DSCREEN_LOG_TAG, ret); in ReleaseSession() 114 DHLOGE("%{public}s: Register data adapter listener failed ret: %{public}" PRId32, DSCREEN_LOG_TAG, ret); in OpenSession() 120 DHLOGE("%{public}s: Open data session failed, ret: %{public}" PRId32, DSCREEN_LOG_TAG, sessionId); in OpenSession() 121 ReportOptFail(DSCREEN_OPT_FAIL, sessionId, "Open data session failed"); in OpenSession() 174 DHLOGE("%{public}s: Screen data is null", DSCREEN_LOG_TAG); in SendData() 181 DHLOGE("%{public}s: send dirty data failed, ret: %{public}" PRId32, DSCREEN_LOG_TAG, ret); in SendData() 187 DHLOGE("%{public}s: send full data faile in SendData() 201 StreamData data = {reinterpret_cast<char *>(screenData->Data()), screenData->Capacity()}; SendFullData() local 222 StreamData data = {reinterpret_cast<char *>(screenData->Data()), screenData->Capacity()}; SendDirtyData() local 281 OnBytesReceived(int32_t sessionId, const void *data, uint32_t dataLen) OnBytesReceived() argument 290 OnStreamReceived(int32_t sessionId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceived() argument 309 ProcessDullData(const StreamData *data, std::shared_ptr<DataBuffer> dataBuffer) ProcessDullData() argument 327 ProcessDirtyData(const StreamData *data, std::shared_ptr<DataBuffer> dataBuffer, const StreamData *ext) ProcessDirtyData() argument [all...] |
/foundation/arkui/napi/sample/native_module_storage/ |
H A D | js_storage.cpp | 214 [](napi_env env, void* data) { in CreateAsyncWorkOfGet() 215 StorageAsyncContext* asyncContext = (StorageAsyncContext*)data; in CreateAsyncWorkOfGet() 228 [](napi_env env, napi_status status, void* data) { in CreateAsyncWorkOfGet() 229 StorageAsyncContext* asyncContext = (StorageAsyncContext*)data; in CreateAsyncWorkOfGet() 264 [](napi_env env, void* data) { in CreateAsyncWorkOfSet() 265 StorageAsyncContext* asyncContext = (StorageAsyncContext*)data; in CreateAsyncWorkOfSet() 274 [](napi_env env, napi_status status, void* data) { in CreateAsyncWorkOfSet() 275 StorageAsyncContext* asyncContext = (StorageAsyncContext*)data; in CreateAsyncWorkOfSet() 312 [](napi_env env, void* data) { in CreateAsyncWorkOfDelete() 313 StorageAsyncContext* asyncContext = (StorageAsyncContext*)data; in CreateAsyncWorkOfDelete() 407 void* data = nullptr; JSStorageConstructor() local 435 void* data = nullptr; JSStorageGet() local 473 void* data = nullptr; JSStorageSet() local 509 void* data = nullptr; JSStorageDelete() local 546 void* data = nullptr; JSStorageClear() local 585 void* data = nullptr; JSStorageGetSync() local 629 void* data = nullptr; JSStorageSetSync() local 673 void* data = nullptr; JSStorageDeleteSync() local 707 void* data = nullptr; JSStorageClearSync() local 729 void* data = nullptr; JSStorageOn() local 762 void* data = nullptr; JSStorageOff() local [all...] |
/applications/standard/app_samples/code/BasicFeature/Connectivity/StageSocket/server_python/ |
H A D | TCP_Server.py | 30 data = conn.recv(1024) 31 print('data recv ', data.decode()) 36 client.send(data)
|
/foundation/ability/ability_runtime/services/abilitymgr/src/ |
H A D | prepare_terminate_callback_proxy.cpp | 25 MessageParcel data; in DoPrepareTerminate() local 26 if (!data.WriteInterfaceToken(IPrepareTerminateCallback::GetDescriptor())) { in DoPrepareTerminate() 37 int error = remote->SendRequest(ON_DO_PREPARE_TERMINATE, data, reply, option); in DoPrepareTerminate()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/include/bundle/ |
H A D | bundle_manager_callback_stub.h | 36 int32_t OnRemoteRequest(uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) override;
40 int32_t OnQueryInstallationFinishedInner(MessageParcel& data, MessageParcel& reply);
43 MessageParcel& data, MessageParcel& reply);
|
/foundation/ability/dmsfwk/services/dtbschedmgr/include/ |
H A D | dms_free_install_callback_stub.h | 37 int32_t OnRemoteRequest(uint32_t code, MessageParcel& data, MessageParcel& reply, MessageOption& option) override; 41 int32_t OnInstallFinishedInner(MessageParcel& data, MessageParcel& reply); 43 MessageParcel& data, MessageParcel& reply);
|
/foundation/ability/dmsfwk_lite/include/ |
H A D | dmslite_session.h | 31 int32_t SendDmsMessage(const char *data, int32_t len, const char *deviceId, IDmsListener *callback);
34 void InvokeCallback(const void *data, int32_t result);
37 void HandleBytesReceived(int32_t sessionId, const void *data, uint32_t dataLen);
|
/foundation/ability/dmsfwk/interfaces/innerkits/distributed_event/include/ |
H A D | dms_listener_stub.h | 35 int32_t OnRemoteRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option) override;
38 void DSchedEventNotifyInner(MessageParcel &data, MessageParcel &reply);
40 using DistributedScheduleFunc = void (DSchedEventListenerStub::*)(MessageParcel &data, MessageParcel &reply);
|