threads.h

Go to the documentation of this file.

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright (c) 2013-2018 Linaro Limited
 * Copyright (c) 2019-2024 Nokia
 */
 
 
#ifndef ODPH_LINUX_H_
#define ODPH_LINUX_H_
 
#include <odp_api.h>
 
#include <pthread.h>
#include <getopt.h>
#include <sys/types.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
typedef struct {
    void *(*start)(void *);    
    void *arg;                  
    odp_thread_type_t thr_type; 
    odp_instance_t instance;    
} odph_linux_thr_params_t;
 
typedef struct {
    pthread_t      thread; 
    pthread_attr_t attr;   
    int            cpu;    
    odph_linux_thr_params_t thr_params;
} odph_linux_pthread_t;
 
typedef struct {
    pid_t pid;      
    int   cpu;      
    int   status;   
} odph_linux_process_t;
 
typedef struct {
    int (*start)(void *arg);
 
    void *arg;
 
    odp_thread_type_t thr_type;
 
    uint64_t stack_size;
 
} odph_thread_param_t;
 
typedef struct {
    uint32_t status;
 
    odp_atomic_u32_t *init_status;
 
    odp_mem_model_t mem_model;
 
    odp_instance_t instance;
 
    odph_thread_param_t thr_params;
 
} odph_thread_start_args_t;
 
typedef struct {
    odph_thread_start_args_t start_args;
 
    int cpu;
 
    uint8_t last;
 
    union {
        struct {
            pthread_t   thread_id; 
            pthread_attr_t  attr;   
        } thread;
 
        struct {
            pid_t       pid;    
            int     status; 
        } proc;
    };
 
} odph_thread_t;
 
typedef struct {
    odp_mem_model_t mem_model; 
} odph_helper_options_t;
 
typedef struct {
    odp_instance_t instance;
 
    const odp_cpumask_t *cpumask;
 
    int thread_model;
 
    int sync;
 
    uint64_t sync_timeout;
 
    int share_param;
 
} odph_thread_common_param_t;
 
typedef struct {
    odp_bool_t is_sig;
 
    int ret;
} odph_thread_join_result_t;
 
void odph_thread_param_init(odph_thread_param_t *param);
 
void odph_thread_common_param_init(odph_thread_common_param_t *param);
 
int odph_thread_create(odph_thread_t thread[],
               const odph_thread_common_param_t *param,
               const odph_thread_param_t thr_param[],
               int num);
 
int odph_thread_join(odph_thread_t thread[], int num);
 
int odph_thread_join_result(odph_thread_t thread[], odph_thread_join_result_t res[], int num);
 
int odph_odpthread_setaffinity(const int cpu);
 
int odph_odpthread_getaffinity(void);
 
int odph_parse_options(int argc, char *argv[]);
 
int odph_options(odph_helper_options_t *options);
 
#ifdef __cplusplus
}
#endif
 
#endif