3596537005
Ensure that the memory operations before the call to rte_eal_remote_launch are visible to the worker thread. Use the function pointer to execute in worker thread as the guard variable. Ensure that the memory operations in worker thread, that happen before it returns the status of the assigned function, are visible to the main thread. Use the variable containing the lcore's state as the guard variable. Signed-off-by: Honnappa Nagarahalli <honnappa.nagarahalli@arm.com> Reviewed-by: Ola Liljedahl <ola.liljedahl@arm.com> Reviewed-by: Feifei Wang <feifei.wang2@arm.com>
86 lines
1.7 KiB
C
86 lines
1.7 KiB
C
/* SPDX-License-Identifier: BSD-3-Clause
|
|
* Copyright(c) 2010-2014 Intel Corporation
|
|
*/
|
|
|
|
#include <errno.h>
|
|
#include <stdint.h>
|
|
#include <stdio.h>
|
|
#include <sys/queue.h>
|
|
|
|
#include <rte_launch.h>
|
|
#include <rte_memory.h>
|
|
#include <rte_eal.h>
|
|
#include <rte_atomic.h>
|
|
#include <rte_pause.h>
|
|
#include <rte_per_lcore.h>
|
|
#include <rte_lcore.h>
|
|
|
|
#include "eal_private.h"
|
|
|
|
/*
|
|
* Wait until a lcore finished its job.
|
|
*/
|
|
int
|
|
rte_eal_wait_lcore(unsigned worker_id)
|
|
{
|
|
while (__atomic_load_n(&lcore_config[worker_id].state,
|
|
__ATOMIC_ACQUIRE) != WAIT)
|
|
rte_pause();
|
|
|
|
return lcore_config[worker_id].ret;
|
|
}
|
|
|
|
/*
|
|
* Check that every WORKER lcores are in WAIT state, then call
|
|
* rte_eal_remote_launch() for all of them. If call_main is true
|
|
* (set to CALL_MAIN), also call the function on the main lcore.
|
|
*/
|
|
int
|
|
rte_eal_mp_remote_launch(int (*f)(void *), void *arg,
|
|
enum rte_rmt_call_main_t call_main)
|
|
{
|
|
int lcore_id;
|
|
int main_lcore = rte_get_main_lcore();
|
|
|
|
/* check state of lcores */
|
|
RTE_LCORE_FOREACH_WORKER(lcore_id) {
|
|
if (lcore_config[lcore_id].state != WAIT)
|
|
return -EBUSY;
|
|
}
|
|
|
|
/* send messages to cores */
|
|
RTE_LCORE_FOREACH_WORKER(lcore_id) {
|
|
rte_eal_remote_launch(f, arg, lcore_id);
|
|
}
|
|
|
|
if (call_main == CALL_MAIN) {
|
|
lcore_config[main_lcore].ret = f(arg);
|
|
lcore_config[main_lcore].state = WAIT;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
/*
|
|
* Return the state of the lcore identified by worker_id.
|
|
*/
|
|
enum rte_lcore_state_t
|
|
rte_eal_get_lcore_state(unsigned lcore_id)
|
|
{
|
|
return lcore_config[lcore_id].state;
|
|
}
|
|
|
|
/*
|
|
* Do a rte_eal_wait_lcore() for every lcore. The return values are
|
|
* ignored.
|
|
*/
|
|
void
|
|
rte_eal_mp_wait_lcore(void)
|
|
{
|
|
unsigned lcore_id;
|
|
|
|
RTE_LCORE_FOREACH_WORKER(lcore_id) {
|
|
rte_eal_wait_lcore(lcore_id);
|
|
}
|
|
}
|