ril_probe.h

Go to the documentation of this file.

 
#ifndef __RIL_PROBE_H__
#define __RIL_PROBE_H__
 
#include <pthread.h>
#include <stdatomic.h>
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
 
#include "ril_config.h"

#define RIL_PROBE_TIMEOUT_MAX_MS 60000U

typedef struct
{
    uint8_t  apn_index;  
    uint64_t generation; 

    char ifname[RIL_BACKEND_IFNAME_MAX];
 
    uint8_t                   probe_mask;  
    uint8_t                   probe_count; 
    const ril_probe_config_t* probes;      
    uint32_t                  timeout_ms;  
} ril_probe_request_t;

typedef struct
{
    uint8_t  apn_index;  
    uint64_t generation; 
    bool     healthy;    
    bool     available;  
} ril_probe_state_event_t;

typedef struct
{
    void (*execute)(const ril_probe_request_t* request, const atomic_bool* stop, bool* healthy, bool* available,
                    void* context);
    int (*thread_create)(pthread_t* thread, const pthread_attr_t* attr, void* (*entry)(void*), void* context);
    int (*thread_join)(pthread_t thread, void** result);
    int (*thread_cancel)(pthread_t thread);
    void* context; 
} ril_probe_ops_t;

bool ril_probe_targets_are_healthy(uint8_t executed_count, uint8_t succeeded_count);

uint64_t ril_probe_address_deadline(uint64_t now_ms, uint64_t deadline_ms, size_t remaining_addresses);

bool ril_probe_bind_error_is_unavailable(int error_code);

int ril_probe_bind_interface(int fd, const char* ifname);

typedef struct
{
    ril_probe_config_t      probes[RIL_CONFIG_MAX_PROBES]; 
    ril_probe_ops_t         ops;                           
    pthread_mutex_t         mutex;                         
    pthread_cond_t          condition;                     
    pthread_t               worker;                        
    atomic_bool             stop;                          
    ril_probe_request_t     request;                       
    ril_probe_state_event_t result;                        
    uint8_t                 probe_count;                   
    bool                    request_ready;                 
    bool                    request_inflight;              
    bool                    result_ready;                  
    bool                    sync_ready;                    
    bool                    worker_started;                
    bool                    initialized;                   
} ril_probe_t;

int ril_probe_init(ril_probe_t* probe, const ril_config_t* config, const ril_probe_ops_t* ops);

int ril_probe_schedule(ril_probe_t* probe, const ril_probe_request_t* request);

int ril_probe_collect(ril_probe_t* probe, ril_probe_state_event_t* result);

void ril_probe_deinit(ril_probe_t* probe);
 
#endif /* __RIL_PROBE_H__ */