Skip to content

Commit 2a90b10

Browse files
committed
Rename PAL task APIs
1 parent bd529f6 commit 2a90b10

File tree

14 files changed

+38
-37
lines changed

14 files changed

+38
-37
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ and this project adheres to [0-based versioning](https://0ver.org/).
1111

1212
- Improve macro comments in `libs/common/macros.h`.
1313
- Improve macro and comments documentation.
14+
- Rename PAL task APIs.
1415

1516
## v0.14.1 - 30-August-2025
1617

apps/examples/async/main.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -269,7 +269,7 @@ static void async_ctor(struct async *me) {
269269
static void ticker_task(void *param) {
270270
(void)param;
271271

272-
am_pal_wait_all_tasks();
272+
am_pal_task_wait_all();
273273

274274
uint32_t now_ticks = am_pal_time_get_tick(AM_PAL_TICK_DOMAIN_DEFAULT);
275275
while (am_ao_get_cnt() > 0) {
@@ -282,7 +282,7 @@ static void ticker_task(void *param) {
282282
static void input_task(void *param) {
283283
(void)param;
284284

285-
am_pal_wait_all_tasks();
285+
am_pal_task_wait_all();
286286

287287
int ch;
288288
uint32_t prev_ms = am_pal_time_get_ms() - 2 * ASYNC_TWO_NEWLINES_TIMEOUT_MS;

apps/examples/dpp/main.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ AM_NORETURN void am_assert_failure(
109109
static void ticker_task(void *param) {
110110
(void)param;
111111

112-
am_pal_wait_all_tasks();
112+
am_pal_task_wait_all();
113113

114114
uint32_t now_ticks = am_pal_time_get_tick(AM_PAL_TICK_DOMAIN_DEFAULT);
115115
while (am_ao_get_cnt() > 0) {

apps/examples/fork/main.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ static void progress_ctor(struct progress *me) {
159159
AM_NORETURN static void ticker_task(void *param) {
160160
(void)param;
161161

162-
am_pal_wait_all_tasks();
162+
am_pal_task_wait_all();
163163

164164
uint32_t now_ticks = am_pal_time_get_tick(AM_PAL_TICK_DOMAIN_DEFAULT);
165165
for (;;) {
@@ -170,7 +170,7 @@ AM_NORETURN static void ticker_task(void *param) {
170170
}
171171

172172
static void job_task(void *param) {
173-
am_pal_wait_all_tasks();
173+
am_pal_task_wait_all();
174174

175175
static struct am_event success = {.id = EVT_FORK_SUCCESS};
176176
static struct am_event failure = {.id = EVT_FORK_FAILURE};

apps/examples/ringbuf/main.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ static const struct am_event *m_queue_ringbuf_writer[1];
5252
AM_NORETURN static void ticker_task(void *param) {
5353
(void)param;
5454

55-
am_pal_wait_all_tasks();
55+
am_pal_task_wait_all();
5656

5757
uint32_t now_ticks = am_pal_time_get_tick(AM_PAL_TICK_DOMAIN_DEFAULT);
5858
for (;;) {

apps/examples/smokers/main.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -323,7 +323,7 @@ static void agent_ctor(void) {
323323
static void ticker_task(void *param) {
324324
(void)param;
325325

326-
am_pal_wait_all_tasks();
326+
am_pal_task_wait_all();
327327

328328
uint32_t now_ticks = am_pal_time_get_tick(AM_PAL_TICK_DOMAIN_DEFAULT);
329329
while (am_ao_get_cnt() > 0) {

apps/examples/workers/main.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ static void balancer_ctor(int nworkers) {
237237
static void ticker_task(void *param) {
238238
(void)param;
239239

240-
am_pal_wait_all_tasks();
240+
am_pal_task_wait_all();
241241

242242
uint32_t now_ticks = am_pal_time_get_tick(AM_PAL_TICK_DOMAIN_DEFAULT);
243243
while (am_ao_get_cnt() > 0) {

libs/ao/preemptive/port.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636
#include "ao/ao.h"
3737
#include "state.h"
3838

39-
void am_ao_state_ctor_(void) { am_pal_lock_all_tasks(); }
39+
void am_ao_state_ctor_(void) { am_pal_task_lock_all(); }
4040

4141
static void am_ao_handle(void *ctx, const struct am_event *event) {
4242
AM_ASSERT(ctx);
@@ -55,7 +55,7 @@ static void am_ao_handle(void *ctx, const struct am_event *event) {
5555
static void am_ao_task(void *param) {
5656
AM_ASSERT(param);
5757

58-
am_pal_wait_all_tasks();
58+
am_pal_task_wait_all();
5959

6060
struct am_ao *ao = (struct am_ao *)param;
6161

@@ -77,7 +77,7 @@ bool am_ao_run_all(void) {
7777

7878
if (!AM_ATOMIC_LOAD_N(&me->startup_complete)) {
7979
/* start all AOs */
80-
am_pal_unlock_all_tasks();
80+
am_pal_task_unlock_all();
8181
AM_ATOMIC_STORE_N(&me->startup_complete, true);
8282
}
8383
/* wait all AOs to complete */

libs/pal/freertos/pal.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -169,10 +169,10 @@ int am_pal_get_cpu_count(void) {
169169
#endif
170170
}
171171

172-
void am_pal_wait_all_tasks(void) {}
172+
void am_pal_task_wait_all(void) {}
173173

174-
void am_pal_lock_all_tasks(void) {}
174+
void am_pal_task_lock_all(void) {}
175175

176-
void am_pal_unlock_all_tasks(void) {}
176+
void am_pal_task_unlock_all(void) {}
177177

178-
void am_pal_run_all_tasks(void) { vTaskStartScheduler(); }
178+
void am_pal_task_run_all(void) { vTaskStartScheduler(); }

libs/pal/libuv/pal.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -408,15 +408,15 @@ int am_pal_get_cpu_count(void) {
408408
return 1;
409409
}
410410

411-
void am_pal_lock_all_tasks(void) { am_pal_mutex_lock(startup_complete_mutex_); }
411+
void am_pal_task_lock_all(void) { am_pal_mutex_lock(startup_complete_mutex_); }
412412

413-
void am_pal_unlock_all_tasks(void) {
413+
void am_pal_task_unlock_all(void) {
414414
am_pal_mutex_unlock(startup_complete_mutex_);
415415
}
416416

417-
void am_pal_wait_all_tasks(void) {
417+
void am_pal_task_wait_all(void) {
418418
am_pal_mutex_lock(startup_complete_mutex_);
419419
am_pal_mutex_unlock(startup_complete_mutex_);
420420
}
421421

422-
void am_pal_run_all_tasks(void) {}
422+
void am_pal_task_run_all(void) {}

0 commit comments

Comments
 (0)