git.droids-corp.org
/
dpdk.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
use macro to declare constructor functions
[dpdk.git]
/
examples
/
performance-thread
/
common
/
lthread_sched.c
diff --git
a/examples/performance-thread/common/lthread_sched.c
b/examples/performance-thread/common/lthread_sched.c
index
301cf94
..
779aeb1
100644
(file)
--- a/
examples/performance-thread/common/lthread_sched.c
+++ b/
examples/performance-thread/common/lthread_sched.c
@@
-76,7
+76,6
@@
#include <sys/mman.h>
#include <sched.h>
#include <sys/mman.h>
#include <sched.h>
-#include <rte_config.h>
#include <rte_prefetch.h>
#include <rte_per_lcore.h>
#include <rte_atomic.h>
#include <rte_prefetch.h>
#include <rte_per_lcore.h>
#include <rte_atomic.h>
@@
-118,8
+117,7
@@
uint64_t diag_mask;
/* constructor */
/* constructor */
-void lthread_sched_ctor(void) __attribute__ ((constructor));
-void lthread_sched_ctor(void)
+RTE_INIT(lthread_sched_ctor)
{
memset(schedcore, 0, sizeof(schedcore));
rte_atomic16_init(&num_schedulers);
{
memset(schedcore, 0, sizeof(schedcore));
rte_atomic16_init(&num_schedulers);
@@
-269,7
+267,7
@@
struct lthread_sched *_lthread_sched_create(size_t stack_size)
struct lthread_sched *new_sched;
unsigned lcoreid = rte_lcore_id();
struct lthread_sched *new_sched;
unsigned lcoreid = rte_lcore_id();
-
LTHREAD
_ASSERT(stack_size <= LTHREAD_MAX_STACK_SIZE);
+
RTE
_ASSERT(stack_size <= LTHREAD_MAX_STACK_SIZE);
if (stack_size == 0)
stack_size = LTHREAD_MAX_STACK_SIZE;
if (stack_size == 0)
stack_size = LTHREAD_MAX_STACK_SIZE;
@@
-370,8
+368,8
@@
void lthread_scheduler_shutdown_all(void)
/*
* Resume a suspended lthread
*/
/*
* Resume a suspended lthread
*/
-static inline void
-_lthread_resume(struct lthread *lt)
__attribute__ ((always_inline))
;
+static
__rte_always_
inline void
+_lthread_resume(struct lthread *lt);
static inline void _lthread_resume(struct lthread *lt)
{
struct lthread_sched *sched = THIS_SCHED;
static inline void _lthread_resume(struct lthread *lt)
{
struct lthread_sched *sched = THIS_SCHED;
@@
-563,11
+561,14
@@
void lthread_run(void)
* Return the scheduler for this lcore
*
*/
* Return the scheduler for this lcore
*
*/
-struct lthread_sched *_lthread_sched_get(int lcore_id)
+struct lthread_sched *_lthread_sched_get(
unsigned
int lcore_id)
{
{
- if (lcore_id > LTHREAD_MAX_LCORES)
- return NULL;
- return schedcore[lcore_id];
+ struct lthread_sched *res = NULL;
+
+ if (lcore_id < LTHREAD_MAX_LCORES)
+ res = schedcore[lcore_id];
+
+ return res;
}
/*
}
/*
@@
-579,10
+580,9
@@
int lthread_set_affinity(unsigned lcoreid)
struct lthread *lt = THIS_LTHREAD;
struct lthread_sched *dest_sched;
struct lthread *lt = THIS_LTHREAD;
struct lthread_sched *dest_sched;
- if (unlikely(lcoreid > LTHREAD_MAX_LCORES))
+ if (unlikely(lcoreid >
=
LTHREAD_MAX_LCORES))
return POSIX_ERRNO(EINVAL);
return POSIX_ERRNO(EINVAL);
-
DIAG_EVENT(lt, LT_DIAG_LTHREAD_AFFINITY, lcoreid, 0);
dest_sched = schedcore[lcoreid];
DIAG_EVENT(lt, LT_DIAG_LTHREAD_AFFINITY, lcoreid, 0);
dest_sched = schedcore[lcoreid];