openharmony/multimedia_drm_framework
1
0
Fork 0
mirror of https://github.com/openharmony/multimedia_drm_framework.git synced 2026-08-27 03:41:20 -04:00
Code Issues Packages Projects Releases Wiki Activity

update frameworks/js/drm_napi/key_session_callback_napi.cpp.

Browse Source 
Signed-off-by: baoxy92 <baoxianyue@hisilicon.com>
This commit is contained in:
baoxy92
2024-12-31 06:42:08 +00:00
committed by Gitee
parent 99b24c0790
commit 88efdc80bc
1 changed files with 48 additions and 74 deletions
Download Patch File Download Diff File Expand all files Collapse all files
frameworks/js/drm_napi/key_session_callback_napi.cpp
+48 -74
View File
@@ -40,61 +40,6 @@ void MediaKeySessionCallbackNapi::ClearCallbackReference(const std::string event
callbackMap_.erase(eventType);
}
void MediaKeySessionCallbackNapi::WorkCallbackInterruptDone(uv_work_t *work, int status)
{
// Js Thread
std::shared_ptr<MediaKeySessionJsCallback> context(static_cast<MediaKeySessionJsCallback *>(work->data),
[work](MediaKeySessionJsCallback *ptr) {
delete ptr;
delete work;
});
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(work != nullptr, "work is nullptr");
MediaKeySessionJsCallback *event = reinterpret_cast<MediaKeySessionJsCallback *>(work->data);
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(event != nullptr, "event is nullptr");
std::string request = event->callbackName;
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(event->callback != nullptr, "event is nullptr");
napi_env env = event->callback->env_;
napi_ref callback = event->callback->cb_;
napi_handle_scope scope = nullptr;
napi_open_handle_scope(env, &scope);
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(scope != nullptr, "scope is nullptr");
DRM_DEBUG_LOG("JsCallBack %{public}s, uv_queue_work_with_qos start", request.c_str());
do {
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(status != UV_ECANCELED, "%{public}s cancelled", request.c_str());
napi_value jsCallback = nullptr;
napi_status nstatus = napi_get_reference_value(env, callback, &jsCallback);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok && jsCallback != nullptr,
"%{public}s get reference value fail", request.c_str());
// Call back function
if (event->callbackName == "keysChange") {
napi_value statusTable;
napi_value hasNewGoodLicense;
nstatus = NapiParamUtils::SetDrmKeysChangeEventInfo(env, event->keysChangeParame,
statusTable, hasNewGoodLicense);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok,
"%{public}s fail to create keysession keyschange callback", request.c_str());
napi_value args[ARGS_TWO] = { statusTable, hasNewGoodLicense };
napi_value result = nullptr;
nstatus = napi_call_function(env, nullptr, jsCallback, ARGS_TWO, args, &result);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok, "%{public}s fail to call Interrupt callback",
request.c_str());
} else {
napi_value args[ARGS_ONE] = { nullptr };
nstatus = NapiParamUtils::SetDrmEventInfo(env, event->eventParame, args[PARAM0]);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok && args[PARAM0] != nullptr,
"%{public}s fail to create keysession callback", request.c_str());
napi_value result = nullptr;
nstatus = napi_call_function(env, nullptr, jsCallback, ARGS_ONE, args, &result);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok, "%{public}s fail to call Interrupt callback",
request.c_str());
}
} while (0);
napi_close_handle_scope(env, scope);
}
void MediaKeySessionCallbackNapi::SendEvent(const std::string &event, int32_t extra, const std::vector<uint8_t> &data)
{
std::lock_guard<std::mutex> lock(mutex_);
@@ -109,25 +54,54 @@ void MediaKeySessionCallbackNapi::SendEvent(const std::string &event, int32_t ex
void MediaKeySessionCallbackNapi::OnJsCallbackInterrupt(std::unique_ptr<MediaKeySessionJsCallback> &jsCb)
{
uv_loop_s *loop = nullptr;
napi_get_uv_event_loop(env_, &loop);
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(loop != nullptr, "loop nullptr, No memory");
uv_work_t *work = new (std::nothrow) uv_work_t;
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(work != nullptr, "work nullptr, No memory");
if (jsCb.get() == nullptr) {
DRM_DEBUG_LOG("OnJsCallBackInterrupt: jsCb.get() is null");
delete work;
return;
}
work->data = reinterpret_cast<void *>(jsCb.get());
int ret = uv_queue_work_with_qos(
loop, work, [](uv_work_t *work) {}, WorkCallbackInterruptDone, uv_qos_default);
if (ret != 0) {
DRM_DEBUG_LOG("Failed to execute libuv work queue");
delete work;
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(jsCb.get() != nullptr, "OnJsCallbackInterrupt: jsCb.get() is null");
MediaKeySessionJsCallback *event = jsCb.get();
auto task = [event]() {
std::shared_ptr<MediaKeySessionJsCallback> context(static_cast<MediaKeySessionJsCallback*>(event),
[](MediaKeySessionJsCallback* ptr) { delete ptr;
});
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(event != nullptr, "event is nullptr");
std::string request = event->callbackName;
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(event->callback != nullptr, "event is nullptr");
napi_env env = event->callback->env_;
napi_ref callback = event->callback->cb_;
napi_handle_scope scope = nullptr;
napi_open_handle_scope(env, &scope);
DRM_NAPI_CHECK_AND_RETURN_VOID_LOG(scope != nullptr, "scope is nullptr");
DRM_DEBUG_LOG("JsCallBack %{public}s, dowork", request.c_str());
do {
napi_value jsCallback = nullptr;
napi_status nstatus = napi_get_reference_value(env, callback, &jsCallback);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok && jsCallback != nullptr,
"%{public}s get reference value fail", request.c_str());
napi_value result = nullptr;
if (event->callbackName == "keysChange") {
napi_value statusTable;
napi_value hasNewGoodLicense;
nstatus = NapiParamUtils::SetDrmKeysChangeEventInfo(env, event->keysChangeParame,
statusTable, hasNewGoodLicense);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok,
"%{public}s fail to create keysession keyschange callback", request.c_str());
napi_value args[ARGS_TWO] = { statusTable, hasNewGoodLicense };
nstatus = napi_call_function(env, nullptr, jsCallback, ARGS_TWO, args, &result);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok,
"%{public}s fail to call Interrupt callback", request.c_str());
} else {
napi_value args[ARGS_ONE] = { nullptr };
nstatus = NapiParamUtils::SetDrmEventInfo(env, event->eventParame, args[PARAM0]);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok && args[PARAM0] != nullptr,
"%{public}s fail to create keysession callback", request.c_str());
nstatus = napi_call_function(env, nullptr, jsCallback, ARGS_ONE, args, &result);
DRM_NAPI_CHECK_AND_CLOSE_RETURN_VOID_LOG(nstatus == napi_ok,
"%{public}s fail to call Interrupt callback", request.c_str());
}
} while (0);
napi_close_handle_scope(env, scope);
};
if (napi_status::napi_ok != napi_send_event(env_, task, napi_eprio_immediate)) {
DRM_ERR_LOG("OnJsCallbackInterrupt: Failed to SendEvent");
} else {
jsCb.release();
}