OrgACRN
/
sof
mirror of https://github.com/thesofproject/sof.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

ll_schedule: rename num_clients to registered_cores 

Rename the 'num_clients' in struct ll_schedule_domain to 'registered_cores'
to reflect the real use of it.

Signed-off-by: Keyon Jie <yang.jie@linux.intel.com>
This commit is contained in:
Keyon Jie 2021-04-27 09:53:55 +08:00 committed by Liam Girdwood
parent 538d7dba7a
commit 364ee49c53
2 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/include/sof/schedule/ll_schedule_domain.h
View File

@ -45,7 +45,7 @@ struct ll_schedule_domain {
uint64_t next_tick; /**< ticks just set for next run */ uint64_t next_tick; /**< ticks just set for next run */
spinlock_t lock; /**< standard lock */ spinlock_t lock; /**< standard lock */
atomic_t total_num_tasks; /**< total number of registered tasks */ atomic_t total_num_tasks; /**< total number of registered tasks */
atomic_t num_clients; /**< number of registered cores */ atomic_t registered_cores; /**< number of registered cores */
uint32_t ticks_per_ms; /**< number of clock ticks per ms */ uint32_t ticks_per_ms; /**< number of clock ticks per ms */
int type; /**< domain type */ int type; /**< domain type */
int clk; /**< source clock */ int clk; /**< source clock */
@ -89,7 +89,7 @@ static inline struct ll_schedule_domain *domain_init
spinlock_init(&domain->lock); spinlock_init(&domain->lock);
atomic_init(&domain->total_num_tasks, 0); atomic_init(&domain->total_num_tasks, 0);
atomic_init(&domain->num_clients, 0); atomic_init(&domain->registered_cores, 0);
return domain; return domain;
} }

16
src/schedule/ll_schedule.c
View File

@ -150,7 +150,7 @@ static void schedule_ll_clients_enable(struct ll_schedule_data *sch)
for (i = 0; i < CONFIG_CORE_COUNT; i++) { for (i = 0; i < CONFIG_CORE_COUNT; i++) {
if (domain->registered[i] && !domain->enabled[i]) { if (domain->registered[i] && !domain->enabled[i]) {
atomic_add(&domain->num_clients, 1); atomic_add(&domain->registered_cores, 1);
domain_enable(domain, i); domain_enable(domain, i);
domain->enabled[i] = true; domain->enabled[i] = true;
} }
@ -191,7 +191,7 @@ static void schedule_ll_tasks_run(void *data)
struct ll_schedule_data *sch = data; struct ll_schedule_data *sch = data;
struct ll_schedule_domain *domain = sch->domain; struct ll_schedule_domain *domain = sch->domain;
#ifndef __ZEPHYR__ #ifndef __ZEPHYR__
uint32_t num_clients; uint32_t registered_cores;
#endif #endif
uint32_t flags; uint32_t flags;
@ -213,12 +213,10 @@ static void schedule_ll_tasks_run(void *data)
/* TODO: no need for atomic operations, /* TODO: no need for atomic operations,
* already protected by spin_lock * already protected by spin_lock
*/ */
num_clients = atomic_sub(&domain->num_clients, 1) - 1; registered_cores = atomic_sub(domain->registered_cores, 1) - 1;
if (!num_clients) if (!registered_cores)
domain_clear(domain); domain_clear(domain);
#endif #endif
spin_unlock(&domain->lock); spin_unlock(&domain->lock);
perf_cnt_init(&sch->pcd); perf_cnt_init(&sch->pcd);
@ -242,7 +240,7 @@ static void schedule_ll_tasks_run(void *data)
/* re-enable domain only if all clients are done */ /* re-enable domain only if all clients are done */
#ifndef __ZEPHYR__ #ifndef __ZEPHYR__
/* Under Zephyr each client has to be enabled separately */ /* Under Zephyr each client has to be enabled separately */
if (!num_clients) if (!registered_cores)
#endif #endif
schedule_ll_clients_enable(sch); schedule_ll_clients_enable(sch);
@ -320,7 +318,7 @@ static int schedule_ll_domain_set(struct ll_schedule_data *sch,
total = atomic_add(&domain->total_num_tasks, 1); total = atomic_add(&domain->total_num_tasks, 1);
if (total == 0 || !registered) { if (total == 0 || !registered) {
/* First task on core: count and enable it */ /* First task on core: count and enable it */
atomic_add(&domain->num_clients, 1); atomic_add(&domain->registered_cores, 1);
domain_enable(domain, core); domain_enable(domain, core);
domain->enabled[core] = true; domain->enabled[core] = true;
} }
@ -353,7 +351,7 @@ static void schedule_ll_domain_clear(struct ll_schedule_data *sch,
domain->registered[cpu_get_id()] = false; domain->registered[cpu_get_id()] = false;
if (atomic_read(&domain->num_clients)) { if (atomic_read(&domain->num_clients)) {
count = atomic_sub(&domain->num_clients, 1); count = atomic_sub(&domain->registered_cores, 1);
if (count == 1) if (count == 1)
domain_clear(domain); domain_clear(domain);
} }