1 /*
2 * Copyright (c) 2023 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15 #include "uv_queue.h"
16
17 namespace OHOS::Request {
Call(napi_env env,void * data,uv_after_work_cb afterCallback)18 bool UvQueue::Call(napi_env env, void *data, uv_after_work_cb afterCallback)
19 {
20 uv_loop_s *loop = nullptr;
21 napi_get_uv_event_loop(env, &loop);
22 if (loop == nullptr) {
23 return false;
24 }
25 uv_work_t *work = new (std::nothrow) uv_work_t;
26 if (work == nullptr) {
27 return false;
28 }
29 work->data = data;
30 uv_queue_work(
31 loop, work, [](uv_work_t *work) {}, afterCallback);
32 return true;
33 }
34
DeleteRef(napi_env env,napi_ref ref)35 void UvQueue::DeleteRef(napi_env env, napi_ref ref)
36 {
37 UvCallbackData *callbackData = new (std::nothrow) UvCallbackData();
38 if (callbackData == nullptr) {
39 return;
40 }
41 callbackData->env = env;
42 callbackData->ref = ref;
43 UvQueue::Call(env, reinterpret_cast<void *>(callbackData), UvDelete);
44 }
45
UvDelete(uv_work_t * work,int status)46 void UvQueue::UvDelete(uv_work_t *work, int status)
47 {
48 UvCallbackData *callbackData = reinterpret_cast<UvCallbackData *>(work->data);
49 if (callbackData != nullptr) {
50 napi_delete_reference(callbackData->env, callbackData->ref);
51 delete callbackData;
52 }
53 delete work;
54 }
55 } // namespace OHOS::Request