• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
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 #ifndef FFRT_API_C_EXECUTOR_TASK_H
16 #define FFRT_API_C_EXECUTOR_TASK_H
17 
18 #include "type_def.h"
19 
20 typedef enum {
21     ffrt_normal_task = 0,
22     ffrt_io_task = 1,
23     ffrt_uv_task // only used to register func for libuv
24 } ffrt_executor_task_type_t;
25 
26 typedef struct ffrt_executor_task {
27     uintptr_t reserved[2];
28     uintptr_t type; // 0: TaskCtx, 1: io task, User Space Address: libuv work
29     void* wq[2];
30 } ffrt_executor_task_t;
31 
32 typedef void (*ffrt_executor_task_func)(ffrt_executor_task_t* data, ffrt_qos_t qos);
33 
34 FFRT_C_API void ffrt_executor_task_register_func(ffrt_executor_task_func func, ffrt_executor_task_type_t type);
35 FFRT_C_API void ffrt_executor_task_submit(ffrt_executor_task_t *task, const ffrt_task_attr_t *attr);
36 FFRT_C_API int ffrt_executor_task_cancel(ffrt_executor_task_t *task, const ffrt_qos_t qos);
37 
38 #ifdef FFRT_IO_TASK_SCHEDULER
39 // poller
40 typedef void (*ffrt_poller_cb)(void*, uint32_t, uint8_t);
41 typedef void (*ffrt_timer_cb)(void*);
42 FFRT_C_API int ffrt_poller_register(int fd, uint32_t events, void* data, ffrt_poller_cb cb);
43 FFRT_C_API int ffrt_poller_deregister(int fd);
44 FFRT_C_API int ffrt_timer_start(uint64_t timeout, void* data, ffrt_timer_cb cb);
45 FFRT_C_API void ffrt_timer_stop(int handle);
46 FFRT_C_API ffrt_timer_query_t ffrt_timer_query(int handle);
47 FFRT_C_API void ffrt_poller_wakeup();
48 
49 FFRT_C_API void ffrt_submit_coroutine(void* co, ffrt_coroutine_ptr_t exec,
50     ffrt_function_t destroy, const ffrt_deps_t* in_deps, const ffrt_deps_t* out_deps, const ffrt_task_attr_t* attr);
51 
52 // waker
53 FFRT_C_API void ffrt_wake_coroutine(void* task);
54 
55 // get
56 FFRT_C_API void* ffrt_get_current_task();
57 
58 #endif
59 #endif