/applications/standard/app_samples/code/SuperFeature/DistributedAppDev/JsDistributedMusicPlayer/entry/src/main/js/MainAbility/model/ |
H A D | RemoteDeviceModel.js | 73 this.#deviceManager.on('deviceStateChange', (data) => { 74 logger.debug(TAG, `deviceStateChange data=${JSON.stringify(data)}`) 75 switch (data.action) { 78 this.deviceList.push(data.device) 95 if (this.deviceList[j].deviceId !== data.device.deviceId) { 96 list[j] = data.device 101 logger.debug(TAG, `offline, updated device list=${JSON.stringify(data.device)}`) 108 this.#deviceManager.on('discoverSuccess', (data) => { 110 logger.debug(TAG, `discoverSuccess data [all...] |
H A D | KvStoreModel.js | 16 import distributedData from '@ohos.data.distributedData' 77 this.kvStore.put(key, value).then((data) => { 78 this.kvStore.get(key).then((data) => { 79 logger.debug(TAG, `kvStore.get ${key}=${JSON.stringify(data)}`) 81 logger.debug(TAG, `kvStore.put ${key} finished, data= ${JSON.stringify(data)}`) 92 self.kvStore.on('dataChange', 1, (data) => { 93 logger.debug(TAG, `dataChange ${JSON.stringify(data)} insert ${data.insertEntries.length} update ${data [all...] |
/applications/standard/systemui/product/pc/controlpanel/src/main/ets/workers/ |
H A D | PluginDataSourceWorker.js | 30 let data = msg.data; 31 switch (data.action) { 33 initConfig(data.data); 39 loadData(data.data); 42 updatePluginComponentData(data.data); 93 parentPort.onerror = function (data) { [all...] |
/applications/standard/systemui/product/pc/statusbar/src/main/ets/workers/ |
H A D | PluginDataSourceWorker.js | 29 let data = msg.data; 30 switch (data.action) { 32 initConfig(data.data); 38 loadData(data.data); 41 updatePluginComponentData(data.data); 92 parentPort.onerror = function (data) { [all...] |
/applications/standard/systemui/product/phone/dropdownpanel/src/main/ets/workers/ |
H A D | PluginDataSourceWorker.js | 29 let data = msg.data; 30 switch (data.action) { 32 initConfig(data.data); 38 loadData(data.data); 41 updatePluginComponentData(data.data); 92 parentPort.onerror = function (data) { [all...] |
/applications/standard/systemui/product/phone/statusbar/src/main/ets/workers/ |
H A D | PluginDataSourceWorker.js | 29 let data = msg.data; 30 switch (data.action) { 32 initConfig(data.data); 38 loadData(data.data); 41 updatePluginComponentData(data.data); 92 parentPort.onerror = function (data) { [all...] |
/applications/standard/app_samples/code/SuperFeature/DistributedAppDev/DistributeCalc/entry/src/main/js/MainAbility/common/ |
H A D | RemoteDeviceModel.js | 121 this.deviceManager.on('deviceStateChange', (data) => { 122 logger.info(TAG, `deviceStateChange data=${JSON.stringify(data)}`) 123 switch (data.action) { 125 this.changeState(data.device, deviceManager.DeviceStateChange.AVAILABLE) 128 this.changeStateOnline(data.device) 131 this.changeStateOffline(data.device) 137 this.deviceManager.on('discoverSuccess', (data) => { 138 if (data === null) { 142 logger.info(TAG, `deviceFound data [all...] |
H A D | kvstoreModel.js | 15 import distributedData from '@ohos.data.distributedData'; 66 this.kvStore.put(key, value + 'end').then((data) => { 67 logger.debug(TAG, `kvStore.put ${key} finished, data=${JSON.stringify(data)}`) 107 this.kvStore?.on('dataChange', distributedData.SubscribeType.SUBSCRIBE_TYPE_REMOTE, (data) => { 108 logger.debug(TAG, `dataChange, ${JSON.stringify(data)}`) 109 logger.debug(TAG, `dataChange, insert ${data.insertEntries.length} update ${data.updateEntries.length}`) 110 let entries = data.insertEntries.length > 0 ? data [all...] |
/applications/standard/settings/napi/settings/ |
H A D | napi_settings.cpp | 291 [](napi_env env, void* data) { in napi_get_uri() 294 [](napi_env env, napi_status status, void* data) { in napi_get_uri() 295 if (data == nullptr) { in napi_get_uri() 296 SETTING_LOG_INFO("uri c_b asy end data is null"); in napi_get_uri() 300 AsyncCallbackInfo* asyncCallbackInfo = (AsyncCallbackInfo*)data; in napi_get_uri() 343 [](napi_env env, void* data) { in napi_get_uri() 347 [](napi_env env, napi_status status, void* data) { in napi_get_uri() 349 AsyncCallbackInfo* asyncCallbackInfo = (AsyncCallbackInfo*)data; in napi_get_uri() 479 void GetValueExecuteExt(napi_env env, void *data) in GetValueExecuteExt() argument 481 if (data in GetValueExecuteExt() 521 CompleteCall(napi_env env, napi_status status, void *data, const napi_value retVaule) CompleteCall() argument 542 CompletePromise(napi_env env, napi_status status, void *data, const napi_value retVaule) CompletePromise() argument 556 SetValueExecuteExt(napi_env env, void *data, const std::string setValue) SetValueExecuteExt() argument 1115 SetValueExecuteCB(napi_env env, void *data) SetValueExecuteCB() argument [all...] |
/applications/standard/contacts_data/ability/common/utils/src/ |
H A D | contacts_common_event.cpp | 22 void ContactsCommonEvent::OnReceiveEvent(const OHOS::EventFwk::CommonEventData &data) in OnReceiveEvent() argument 24 OHOS::AAFwk::Want want = data.GetWant(); in OnReceiveEvent() 25 std::string action = data.GetWant().GetAction(); in OnReceiveEvent() 27 int msgCode = data.GetCode(); in OnReceiveEvent() 28 std::string msgData = data.GetData(); in OnReceiveEvent() 36 OHOS::EventFwk::CommonEventData data; in PublishContactEvent() local 37 data.SetWant(want); in PublishContactEvent() 38 data.SetCode(eventCode); in PublishContactEvent() 39 data.SetData(eventData); in PublishContactEvent() 42 bool publishResult = OHOS::EventFwk::CommonEventManager::PublishCommonEvent(data, publishInf in PublishContactEvent() [all...] |
H A D | contacts_json_utils.cpp | 48 Json::Value data; in ConvertResultSet() local 51 GetValue(columnNames, i, data, resultSet); in ConvertResultSet() 53 arrayValue.append(data); in ConvertResultSet() 58 void ContactsJsonUtils::GetValue(std::vector<std::string> &columnNames, unsigned int &index, Json::Value &data, in GetValue() argument 69 data[typeValue] = intValue; in GetValue() 73 data[typeValue] = doubleValue; in GetValue() 78 data[typeValue] = stringValue; in GetValue()
|
/applications/standard/calendardata/calendarmanager/napi/src/ |
H A D | calendar_enum_napi.cpp | 100 enumItemVec[index].enumName.data(), value[index]); in JsEnumIntInit() 110 napi_status status = napi_define_class(env, enumClassName.data(), NAPI_AUTO_LENGTH, constructor, in JsEnumIntInit() 111 nullptr, property.size(), property.data(), &result); in JsEnumIntInit() 114 status = napi_set_named_property(env, exports, enumClassName.data(), result); in JsEnumIntInit() 129 napi_create_string_utf8(env, enumItemVec[index].enumString.data(), NAPI_AUTO_LENGTH, &value[index]); in JsEnumStringInit() 136 enumItemVec[index].enumName.data(), value[index]); in JsEnumStringInit() 146 napi_status status = napi_define_class(env, enumClassName.data(), NAPI_AUTO_LENGTH, constructor, in JsEnumStringInit() 147 nullptr, property.size(), property.data(), &result); in JsEnumStringInit() 150 status = napi_set_named_property(env, exports, enumClassName.data(), result); in JsEnumStringInit()
|
H A D | napi_queue.cpp | 92 [](napi_env env, void* data) { in AsyncWork() 93 CHECK_RETURN_VOID(data != nullptr, "AsyncWork napi_async_execute_callback nullptr"); in AsyncWork() 94 auto actx = reinterpret_cast<AsyncContext*>(data); in AsyncWork() 100 [](napi_env env, napi_status status, void* data) { in AsyncWork() 101 CHECK_RETURN_VOID(data != nullptr, "AsyncWork napi_async_complete_callback nullptr"); in AsyncWork() 102 auto actx = reinterpret_cast<AsyncContext*>(data); in AsyncWork()
|
H A D | napi_util.cpp | 172 void* data = nullptr; in GetValue() local 173 napi_status status = napi_get_typedarray_info(env, in, &type, &length, &data, &buffer, &offset); in GetValue() 177 CHECK_RETURN((length > 0) && (data != nullptr), "invalid data!", napi_invalid_arg); in GetValue() 178 out.assign((uint8_t*)data, ((uint8_t*)data) + length); in GetValue() 186 void* data = nullptr; in SetValue() local 188 napi_status status = napi_create_arraybuffer(env, in.size(), &data, &buffer); in SetValue() 191 if (memcpy_s(data, in.size(), in.data(), i in SetValue() 225 void* data = nullptr; SetValue() local 251 void* data = nullptr; SetValue() local [all...] |
/applications/sample/wifi-iot/app/samgr/ |
H A D | feature_example.c | 111 (char *)request->data); in FEATURE_OnMessage() 112 Response response = {.data = "Yes, you did!", .len = 0}; in FEATURE_OnMessage() 146 request.data = malloc(request.len); in AsyncCall() 147 if (request.data == NULL) { in AsyncCall() 150 if (strcpy_s(request.data, request.len, body) != EOK) { in AsyncCall() 151 free(request.data); in AsyncCall() 172 request.data = malloc(request.len); in AsyncCallBack() 173 if (request.data == NULL) { in AsyncCallBack() 176 if (strcpy_s(request.data, request.len, body) != EOK) { in AsyncCallBack() 177 free(request.data); in AsyncCallBack() [all...] |
/applications/standard/app_samples/code/BasicFeature/Native/NdkRawfile/entry/src/main/cpp/ |
H A D | rawfile_demo.cpp | 63 napi_value CreateJsArrayValue(napi_env env, std::unique_ptr<uint8_t[]> &data, long length)
in CreateJsArrayValue() argument 67 env, data.get(), length,
in CreateJsArrayValue() 68 [](napi_env env, void *data, void *hint) {
in CreateJsArrayValue() 69 delete[] static_cast<char *>(data);
in CreateJsArrayValue() 82 data.release();
in CreateJsArrayValue() 108 std::unique_ptr<uint8_t[]> data = std::make_unique<uint8_t[]>(len);
in GetRawFileContent() local 110 int res = OH_ResourceManager_ReadRawFile(rawFile, data.get(), len);
in GetRawFileContent() 114 return CreateJsArrayValue(env, data, len);
in GetRawFileContent()
|
/applications/standard/app_samples/code/BasicFeature/Native/NdkVulkan/entry/src/main/cpp/render/vulkan/ |
H A D | vulkan_example.cpp | 154 createInfo.ppEnabledExtensionNames = extensions.data(); in CreateInstance() 196 vkEnumeratePhysicalDevices(instance, &deviceCount, devices.data()); in PickPhysicalDevice() 237 createInfo.pQueueCreateInfos = queueCreateInfos.data(); in CreateLogicalDevice() 242 createInfo.ppEnabledExtensionNames = deviceExtensions.data(); in CreateLogicalDevice() 295 vkGetSwapchainImagesKHR(device, swapChain, &imageCount, swapChainImages.data()); in CreateSwapChain() 480 vertexInputState.pVertexAttributeDescriptions = vertexInputAttributes.data(); in PrepareVertexInputState() 554 dynamicState.pDynamicStates = dynamicStates.data(); in PrepareDynamicState() 702 void *data = nullptr; in UpdateVertices() local 703 CheckResult(vkMapMemory(device, vertexStagingBuffer.memory, 0, vertexBufferSize, 0, &data)); in UpdateVertices() 704 memcpy(data, vertice in UpdateVertices() [all...] |
/applications/standard/contacts_data/contacts/src/ |
H A D | contacts_api.cpp | 613 void ExecuteDone(napi_env env, napi_status status, void *data) in ExecuteDone() argument 616 ExecuteHelper *executeHelper = reinterpret_cast<ExecuteHelper *>(data); in ExecuteDone() 654 void ExecuteSyncDone(napi_env env, napi_status status, void *data) in ExecuteSyncDone() argument 661 if (data != nullptr) { in ExecuteSyncDone() 662 ExecuteHelper *executeHelper = reinterpret_cast<ExecuteHelper *>(data); in ExecuteSyncDone() 1022 void Execute(napi_env env, void *data) in Execute() argument 1024 ExecuteHelper *executeHelper = static_cast<ExecuteHelper *>(data); in Execute() 1211 void *data; in AddContact() local 1212 napi_get_cb_info(env, info, &argc, argv, &thisVar, &data); in AddContact() 1256 void *data; in DeleteContact() local 1301 void *data; UpdateContact() local 1353 void *data; QueryContact() local 1414 void *data; QueryContacts() local 1472 void *data; QueryContactsByEmail() local 1535 void *data; QueryContactsByPhoneNumber() local 1596 void *data; QueryGroups() local 1647 void *data; QueryHolders() local 1692 void *data; QueryKey() local 1750 void *data; QueryMyCard() local 1801 void *data; IsMyCard() local 1846 void *data; IsLocalContact() local [all...] |
/applications/standard/app_samples/code/BasicFeature/Media/ImageEffect/entry/src/main/cpp/backend/ |
H A D | image_edit.cpp | 201 std::vector<std::vector<FilterArrayData>> data; in GetFilters() local 206 CHECK_AND_RETURN_RET_LOG(is_array == true, data, "GetFilters napi_is_array fail! status=%{public}d", status); in GetFilters() 210 CHECK_AND_RETURN_RET_LOG(array_length.first == napi_ok, data, in GetFilters() 216 CHECK_AND_RETURN_RET_LOG(status == napi_ok, data, "GetFilters napi_get_element fail! status=%{public}d", in GetFilters() 220 CHECK_AND_RETURN_RET_LOG(child_length.first == napi_ok, data, in GetFilters() 231 CHECK_AND_RETURN_RET_LOG(status == napi_ok, data, in GetFilters() 241 data.push_back(row); in GetFilters() 244 return data; in GetFilters()
|
/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)
|
H A D | TLS_Server.py | 32 data = conn.recv(1024) 33 print('data recv ', data.decode()) 38 client.send(data)
|
/applications/sample/camera/media/ |
H A D | player_sample.cpp | 245 uint8_t *data = nullptr; in streamProcess() local 269 data = sample->streamSample->GetBufferAddress(buffer.idx); in streamProcess() 270 if (data == nullptr) { in streamProcess() 275 readLen = fread(data + buffer.offset, 1, len, pFile); in streamProcess() 293 uint8_t *data = nullptr; in streamProcess() local 311 data = sample->streamSample->GetSharedBuffer(bufferSize); in streamProcess() 312 if (data == nullptr) { in streamProcess() 316 readLen = fread(data, 1, bufferSize, pFile); in streamProcess() 318 sample->streamSample->QueueSharedBuffer(data, readLen); in streamProcess() 320 sample->streamSample->QueueSharedBuffer(data, in streamProcess() [all...] |
/applications/standard/app_samples/code/Performance/PerformanceLibrary/feature/nativeThreadsCallJS/src/main/cpp/ |
H A D | hello.cpp | 35 CallbackContext *context = (CallbackContext *)workReq->data; in WorkCallback() 47 CallbackContext *context = (CallbackContext *)workReq->data; in AfterWorkCallback() 97 // 创建工作数据结构,自定义数据结构添加在data中 in CallbackUvWorkTest() 109 workReq->data = (void *)context; in CallbackUvWorkTest() 150 static void ThreadSafeCallJs(napi_env env, napi_value js_cb, void *context, void *data) in ThreadSafeCallJs() argument 152 CallbackContext *argContent = (CallbackContext *)data; in ThreadSafeCallJs()
|
/applications/sample/camera/gallery/src/ |
H A D | picture_ability_slice.cpp | 121 printf("receive the data -> %s\n", reinterpret_cast<char*>(want.data)); in OnStart() 129 uint16_t imagePathLen = strlen(PHOTO_DIRECTORY) + strlen(reinterpret_cast<char*>(want.data)) + 1; in OnStart() 135 if (sprintf_s(imagePath, imagePathLen + 1, "%s/%s", PHOTO_DIRECTORY, reinterpret_cast<char*>(want.data)) < 0) { in OnStart()
|
/applications/standard/contacts_data/contacts/include/ |
H A D | contacts_api.h | 48 void Execute(napi_env env, void *data); 49 void ExecuteAsync(napi_env env, void *data); 50 void ExecuteDone(napi_env env, napi_status status, void *data); 51 void ExecuteSyncDone(napi_env env, napi_status status, void *data);
|