/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/ |
H A D | js_query.cpp | 387 query.In(ctxt->field, ctxt->intList); in InNumber() 389 query.In(ctxt->field, ctxt->longList); in InNumber() 391 query.In(ctxt->field, ctxt->doubleList); in InNumber() 421 query.In(ctxt->field, ctxt->valueList); in InString() 436 query.NotIn(ctxt->field, ctxt->intList); in NotInNumber() 438 query.NotIn(ctxt->field, ctxt->longList); in NotInNumber() 440 query.NotIn(ctxt->field, ctxt->doubleList); in NotInNumber() 470 query.NotIn(ctxt->field, ctxt->valueList); in NotInString() 499 query.Like(ctxt->field, ctxt->value); in Like() 528 query.Unlike(ctxt->field, ctxt->value); in Unlike() [all …]
|
H A D | js_single_kv_store.cpp | 205 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Put() 262 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Delete() 361 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in PutBatch() 400 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in DeleteBatch() 421 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in StartTransaction() 443 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Commit() 465 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Rollback() 499 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in EnableSync() 537 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in SetSyncRange() 573 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Backup() [all …]
|
H A D | js_device_kv_store.cpp | 101 ctxt->status = JSUtil::GetValue(env, argv[pos], ctxt->key); in Get() 118 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Get() 122 ctxt->status = JSUtil::SetValue(env, ctxt->value, result); in Get() 197 ctxt->status = GetVariantArgs(env, argc, argv, ctxt->va); in GetEntries() 198 … ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, Status::INVALID_ARGUMENT, ctxt->va.errMsg); in GetEntries() 207 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in GetEntries() 242 … ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, Status::INVALID_ARGUMENT, ctxt->va.errMsg); in GetResultSet() 259 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in GetResultSet() 291 ctxt->status = GetVariantArgs(env, argc, argv, ctxt->va); in GetResultSize() 292 …ASSERT_BUSINESS_ERR(ctxt, ctxt->status != napi_invalid_arg, Status::INVALID_ARGUMENT, ctxt->va.err… in GetResultSize() [all …]
|
H A D | js_kv_store_resultset.cpp | 69 return ctxt->self; in New() 85 return ctxt->output; in GetCount() 100 return ctxt->output; in GetPosition() 115 return ctxt->output; in MoveToFirst() 130 return ctxt->output; in MoveToLast() 145 return ctxt->output; in MoveToNext() 160 return ctxt->output; in MoveToPrevious() 183 return ctxt->output; in Move() 207 return ctxt->output; in MoveToPosition() 222 return ctxt->output; in IsFirst() [all …]
|
H A D | js_kv_manager.cpp | 155 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in GetKVStore() 158 ctxt->kvStore->SetSchemaInfo(!ctxt->options.schema.empty()); in GetKVStore() 188 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->appId); in CloseKVStore() 189 …ASSERT_BUSINESS_ERR(ctxt, (ctxt->status == napi_ok) && !ctxt->appId.empty(), Status::INVALID_ARGUM… in CloseKVStore() 191 ctxt->status = JSUtil::GetValue(env, argv[1], ctxt->storeId); in CloseKVStore() 192 …ASSERT_BUSINESS_ERR(ctxt, (ctxt->status == napi_ok) && JSUtil::IsValid(ctxt->storeId), Status::INV… in CloseKVStore() 202 status = GenerateNapiError(status, ctxt->jsCode, ctxt->error); in CloseKVStore() 204 ctxt->status in CloseKVStore() 248 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in DeleteKVStore() 271 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->appId); in GetAllKVStoreId() [all …]
|
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/cloud_data/src/ |
H A D | js_cloud_share.cpp | 85 ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in AllocResourceAndShare() 91 … ctxt->storeId, ctxt->predicates->GetDistributedPredicates(), ctxt->columns, ctxt->participants); in AllocResourceAndShare() 139 … ctxt->status = (GenerateNapiError(status, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Share() 143 int32_t result = proxy->Share(ctxt->sharingRes, ctxt->participants, ctxt->results); in Share() 145 ctxt->status = (GenerateNapiError(result, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Share() 193 int32_t result = proxy->Unshare(ctxt->sharingRes, ctxt->participants, ctxt->results); in Unshare() 195 ctxt->status = (GenerateNapiError(result, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Unshare() 239 ctxt->status = (GenerateNapiError(result, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Exit() 291 ctxt->status = (GenerateNapiError(result, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in ChangePrivilege() 335 ctxt->status = (GenerateNapiError(result, ctxt->jsCode, ctxt->error) == Status::SUCCESS) ? in Query() [all …]
|
H A D | js_config.cpp | 80 ctxt->status = (GenerateNapiError(state, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in EnableCloud() 87 ctxt->status = (GenerateNapiError(cStatus, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in EnableCloud() 124 ctxt->status = (GenerateNapiError(state, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in DisableCloud() 131 ctxt->status = (GenerateNapiError(cStatus, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in DisableCloud() 182 ctxt->status = (GenerateNapiError(state, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in ChangeAppCloudSwitch() 187 int32_t cStatus = proxy->ChangeAppSwitch(ctxt->accountId, ctxt->bundleName, ctxt->state); in ChangeAppCloudSwitch() 189 ctxt->status = (GenerateNapiError(cStatus, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in ChangeAppCloudSwitch() 234 ctxt->status = (GenerateNapiError(state, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in Clean() 241 ctxt->status = (GenerateNapiError(cStatus, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in Clean() 301 ctxt->status = (GenerateNapiError(state, ctxt->jsCode, ctxt->error) == Status::SUCCESS) in NotifyDataChange() [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
H A D | js_query.cpp | 355 query.In(ctxt->field, ctxt->intList); in InNumber() 357 query.In(ctxt->field, ctxt->longList); in InNumber() 359 query.In(ctxt->field, ctxt->doubleList); in InNumber() 384 query.In(ctxt->field, ctxt->valueList); in InString() 397 query.NotIn(ctxt->field, ctxt->intList); in NotInNumber() 399 query.NotIn(ctxt->field, ctxt->longList); in NotInNumber() 401 query.NotIn(ctxt->field, ctxt->doubleList); in NotInNumber() 426 query.NotIn(ctxt->field, ctxt->valueList); in NotInString() 450 query.Like(ctxt->field, ctxt->value); in Like() 474 query.Unlike(ctxt->field, ctxt->value); in Unlike() [all …]
|
H A D | js_single_kv_store.cpp | 82 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->key); in Get() 100 ctxt->status = JSUtil::SetValue(env, ctxt->value, result); in Get() 165 ctxt->status = GetVariantArgs(env, argc, argv, ctxt->va); in GetEntries() 213 ctxt->status = GetVariantArgs(env, argc, argv, ctxt->va); in GetResultSet() 243 ctxt->status = napi_get_reference_value(env, ctxt->ref, &result); in GetResultSet() 339 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->deviceId); in RemoveDeviceData() 374 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->deviceIdList); in Sync() 376 ctxt->status = JSUtil::GetValue(env, argv[1], ctxt->mode); in Sync() 389 (int)ctxt->deviceIdList.size(), ctxt->mode, ctxt->allowedDelayMs); in Sync() 393 …status = kvStore->Sync(ctxt->deviceIdList, static_cast<SyncMode>(ctxt->mode), ctxt->allowedDelayMs… in Sync() [all …]
|
H A D | js_device_kv_store.cpp | 90 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->deviceId); in Get() 92 ctxt->status = JSUtil::GetValue(env, argv[1], ctxt->key); in Get() 98 std::string deviceKey = GetDeviceKey(ctxt->deviceId, ctxt->key); in Get() 115 ctxt->status = JSUtil::SetValue(env, ctxt->value, result); in Get() 204 ctxt->status = GetVariantArgs(env, argc, argv, ctxt->va); in GetEntries() 259 ctxt->status = GetVariantArgs(env, argc, argv, ctxt->va); in GetResultSet() 353 ctxt->status = GetVariantArgs(env, argc, argv, ctxt->va); in GetResultSize() 354 …CHECK_ARGS_RETURN_VOID(ctxt, (ctxt->va.type == ArgsType::DEVICEID_QUERY) || (ctxt->va.type == Args… in GetResultSize() 430 ctxt->status = JSUtil::GetValue(env, argv[1], ctxt->mode); in Sync() 443 (int)ctxt->deviceIdList.size(), ctxt->mode, ctxt->allowedDelayMs); in Sync() [all …]
|
H A D | js_kv_manager.cpp | 81 ctxt->status = napi_get_reference_value(env, ctxt->ref, &result); in CreateKVManager() 149 ctxt->kvStore->SetSchemaInfo(!ctxt->options.schema.empty()); in GetKVStore() 154 ctxt->status = napi_get_reference_value(env, ctxt->ref, &result); in GetKVStore() 156 ctxt->status = napi_delete_reference(env, ctxt->ref); in GetKVStore() 180 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->appId); in CloseKVStore() 181 … CHECK_ARGS_RETURN_VOID(ctxt, (ctxt->status == napi_ok) && !ctxt->appId.empty(), "invalid appId!"); in CloseKVStore() 182 ctxt->status = JSUtil::GetValue(env, argv[1], ctxt->storeId); in CloseKVStore() 183 …CHECK_ARGS_RETURN_VOID(ctxt, (ctxt->status == napi_ok) && !ctxt->storeId.empty(), "invalid storeId… in CloseKVStore() 196 ctxt->status in CloseKVStore() 259 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->appId); in GetAllKVStoreId() [all …]
|
H A D | js_kv_store.cpp | 133 ctxt->GetCbInfo(env, info, [env, ctxt](size_t argc, napi_value* argv) { in Put() 136 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->key); in Put() 138 ctxt->status = JSUtil::GetValue(env, argv[1], ctxt->value); in Put() 171 ctxt->GetCbInfo(env, info, [env, ctxt](size_t argc, napi_value* argv) { in Delete() 174 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->key); in Delete() 179 return NapiQueue::AsyncWork(env, ctxt, std::string(__FUNCTION__), [ctxt]() { in Delete() 255 ctxt->GetCbInfo(env, info, [env, ctxt](size_t argc, napi_value* argv) { in PutBatch() 391 ctxt->status = napi_get_value_bool(env, argv[0], &ctxt->enable); in EnableSync() 423 ctxt->status = JSUtil::GetValue(env, argv[0], ctxt->localLabels); in SetSyncRange() 425 ctxt->status = JSUtil::GetValue(env, argv[1], ctxt->remoteSupportLabels); in SetSyncRange() [all …]
|
H A D | js_kv_store_resultset.cpp | 64 return ctxt->self; in New() 80 return ctxt->output; in GetCount() 95 return ctxt->output; in GetPosition() 110 return ctxt->output; in MoveToFirst() 125 return ctxt->output; in MoveToLast() 140 return ctxt->output; in MoveToNext() 155 return ctxt->output; in MoveToPrevious() 176 return ctxt->output; in Move() 197 return ctxt->output; in MoveToPosition() 212 return ctxt->output; in IsFirst() [all …]
|
/ohos5.0/foundation/distributeddatamgr/udmf/framework/jskitsimpl/data/ |
H A D | system_defined_appitem_napi.cpp | 50 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in New() 82 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in GetSystemDefinedAppItem() 107 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetAppId() 111 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetAppId() 140 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetAppName() 144 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetAppName() 173 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetAppIconId() 177 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetAppIconId() 210 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetAppLabelId() 243 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetBundleName() [all …]
|
H A D | system_defined_form_napi.cpp | 49 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in New() 81 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in GetSystemDefinedForm() 106 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetFormId() 110 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetFormId() 139 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetFormName() 143 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetFormName() 172 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetBundleName() 176 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetBundleName() 205 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetAbilityName() 209 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetAbilityName() [all …]
|
H A D | unified_data_properties_napi.cpp | 42 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in New() 49 return ctxt->self; in New() 68 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in GetPropertiesNapi() 80 return ctxt->output; in GetExtras() 94 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetExtras() 111 return ctxt->output; in GetTag() 125 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetTag() 143 return ctxt->output; in GetShareOptions() 154 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetShareOptions() 158 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetShareOptions() [all …]
|
H A D | type_descriptor_napi.cpp | 47 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in New() 53 return ctxt->self; in New() 79 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in GetDescriptorNapi() 93 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in BelongsTo() 103 return ctxt->output; in BelongsTo() 116 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in IsLowerLevelType() 126 return ctxt->output; in IsLowerLevelType() 139 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in IsHigherLevelType() 149 return ctxt->output; in IsHigherLevelType() 170 return ctxt->output; in Equals() [all …]
|
H A D | unified_data_channel_napi.cpp | 87 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in InsertData() 94 auto execute = [ctxt]() { in InsertData() 101 ctxt->status = NapiDataUtils::SetValue(env, ctxt->key, result); in InsertData() 102 ASSERT_WITH_ERRCODE(ctxt, ctxt->status == napi_ok, E_ERROR, "output failed!"); in InsertData() 121 ctxt->status = GetNamedProperty(env, argv[0], "key", ctxt->key); in UpdateData() 127 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in UpdateData() 180 ctxt->status = ConvertUnifiedDataSetToNapi(env, ctxt->unifiedDataSet, result); in QueryData() 227 ctxt->status = ConvertUnifiedDataSetToNapi(env, ctxt->unifiedDataSet, result); in DeleteData() 292 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in SetAppShareOptions() 295 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in SetAppShareOptions() [all …]
|
H A D | uniform_type_descriptor_napi.cpp | 74 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in GetTypeDescriptor() 86 return ctxt->output; in GetTypeDescriptor() 101 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in GetUniformDataTypeByFilenameExtension() 105 … ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok && !belongsTo.empty(), E_INVALID_PARAMETERS, in GetUniformDataTypeByFilenameExtension() 124 return ctxt->output; in GetUniformDataTypeByFilenameExtension() 139 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in GetUniformDataTypeByMIMEType() 163 return ctxt->output; in GetUniformDataTypeByMIMEType() 178 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in GetMultiUniformDataTypesByFilenameExtension() 199 return ctxt->output; in GetMultiUniformDataTypesByFilenameExtension() 214 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, E_INVALID_PARAMETERS, in GetMultiUniformDataTypesByMIMEType() [all …]
|
H A D | application_defined_record_napi.cpp | 44 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in New() 50 return ctxt->self; in New() 76 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in GetApplicationDefinedRecord() 88 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, "set type failed!"); in GetApplicationDefinedType() 89 return ctxt->output; in GetApplicationDefinedType() 101 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetApplicationDefinedType() 105 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetApplicationDefinedType() 121 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, "set rawData failed!"); in GetRawData() 122 return ctxt->output; in GetRawData() 134 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetRawData() [all …]
|
H A D | file_napi.cpp | 43 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in New() 49 return ctxt->self; in New() 74 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in GetFile() 87 return ctxt->output; in GetDetails() 99 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetDetails() 103 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, ctxt->error); in SetDetails() 118 ctxt->status = NapiDataUtils::SetValue(env, file->value_->GetUri(), ctxt->output); in GetUri() 119 ASSERT_ERR(ctxt->env, ctxt->status == napi_ok, Status::E_ERROR, "set uri failed!"); in GetUri() 120 return ctxt->output; in GetUri() 132 ASSERT_BUSINESS_ERR(ctxt, ctxt->status == napi_ok, in SetUri() [all …]
|
/ohos5.0/base/time/time_service/framework/js/napi/common/src/ |
H A D | napi_work.cpp | 80 delete ctxt; in AsyncEnqueue() 87 napi_create_promise(ctxt->env, &ctxt->deferred, &promise); in AsyncEnqueue() 100 if (ctxt->execute != nullptr && ctxt->status == napi_ok) { in AsyncEnqueue() 112 ctxt->complete(ctxt->output); in AsyncEnqueue() 117 reinterpret_cast<void *>(ctxt), &ctxt->work); in AsyncEnqueue() 133 napi_get_undefined(ctxt->env, &ctxt->output); in GenerateOutput() 179 if (ctxt->execute != nullptr && ctxt->status == napi_ok) { in SyncEnqueue() 183 if (ctxt->complete != nullptr && (ctxt->status == napi_ok)) { in SyncEnqueue() 184 ctxt->complete(ctxt->output); in SyncEnqueue() 195 napi_get_undefined(ctxt->env, &ctxt->output); in GenerateOutputSync() [all …]
|
/ohos5.0/foundation/multimedia/av_session/frameworks/js/napi/session/src/ |
H A D | napi_async_work.cpp | 84 ctxt->taskName = name; in Enqueue() 104 if (!ctxt->taskName.empty() && ctxt->taskId > INVALID_TASK_ID) { in Enqueue() 107 if (ctxt->execute && ctxt->status == napi_ok) { in Enqueue() 118 ctxt->complete(ctxt->output); in Enqueue() 120 if (!ctxt->taskName.empty() && ctxt->taskId > INVALID_TASK_ID) { in Enqueue() 125 reinterpret_cast<void*>(ctxt.get()), &ctxt->work); in Enqueue() 127 ctxt->hold = ctxt; // save crossing-thread ctxt. in Enqueue() 137 napi_get_undefined(ctxt->env, &ctxt->output); in GenerateOutput() 145 napi_create_int32(ctxt->env, ctxt->errCode, &code); in GenerateOutput() 159 napi_get_reference_value(ctxt->env, ctxt->callbackRef, &callback); in GenerateOutput() [all …]
|
/ohos5.0/foundation/multimedia/audio_framework/frameworks/js/napi/common/ |
H A D | napi_async_work.cpp | 95 ctxt->taskName = name; in Enqueue() 98 napi_create_promise(ctxt->env, &ctxt->deferred, &promise); in Enqueue() 112 if (ctxt->execute && ctxt->status == napi_ok) { in Enqueue() 125 ctxt->complete(ctxt->output); in Enqueue() 129 reinterpret_cast<void*>(ctxt.get()), &ctxt->work); in Enqueue() 131 ctxt->hold = ctxt; // save crossing-thread ctxt. in Enqueue() 141 napi_get_undefined(ctxt->env, &ctxt->output); in CommonCallbackRoutine() 149 napi_create_int32(ctxt->env, ctxt->errCode, &code); in CommonCallbackRoutine() 156 napi_resolve_deferred(ctxt->env, ctxt->deferred, result[RESULT_DATA]); in CommonCallbackRoutine() 159 napi_reject_deferred(ctxt->env, ctxt->deferred, result[RESULT_ERROR]); in CommonCallbackRoutine() [all …]
|
/ohos5.0/foundation/multimedia/drm_framework/frameworks/js/drm_napi/ |
H A D | napi_async_work.cpp | 86 ctxt->taskName = name; in Enqueue() 89 napi_create_promise(ctxt->env, &ctxt->deferred, &promise); in Enqueue() 103 if (ctxt->execute && ctxt->status == napi_ok) { in Enqueue() 116 ctxt->complete(ctxt->output); in Enqueue() 120 reinterpret_cast<void*>(ctxt.get()), &ctxt->work); in Enqueue() 122 ctxt->hold = ctxt; // save crossing-thread ctxt. in Enqueue() 132 napi_get_undefined(ctxt->env, &ctxt->output); in CommonCallbackRoutine() 140 napi_create_int32(ctxt->env, ctxt->errCode, &code); in CommonCallbackRoutine() 147 napi_resolve_deferred(ctxt->env, ctxt->deferred, result[RESULT_DATA]); in CommonCallbackRoutine() 150 napi_reject_deferred(ctxt->env, ctxt->deferred, result[RESULT_ERROR]); in CommonCallbackRoutine() [all …]
|