ril_event_queue.h

Go to the documentation of this file.

 
#ifndef __RIL_EVENT_QUEUE_H__
#define __RIL_EVENT_QUEUE_H__
 
#include <pthread.h>
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
 
#include "ril_backend.h"
#include "ril_probe.h"

#define RIL_NOTIFICATION_QUEUE_CAPACITY 32U

#define RIL_STATE_QUEUE_CAPACITY 32U

typedef struct ril_notification_node ril_notification_node_t;

typedef enum
{
    RIL_QUEUE_NOTIFICATION = 1, 
    RIL_QUEUE_STATE,            
} ril_queue_class_t;

typedef enum
{
    RIL_NOTIFICATION_SMS = 1, 
    RIL_NOTIFICATION_VOICE,   
} ril_notification_type_t;

typedef enum
{
    RIL_STATE_RADIO_REFRESH = 1, 
    RIL_STATE_SIM,               
    RIL_STATE_DATA,              
    RIL_STATE_PROBE,             
} ril_state_event_type_t;

typedef struct
{
    tbox_radio_rf_mode_t             rf_mode;      
    tbox_radio_registration_status_t registration; 
} ril_radio_state_event_t;

typedef struct
{
    ril_notification_type_t type; 
    union
    {
        tbox_sms_message_t sms;   
        tbox_voice_event_t voice; 
    } data;                       
} ril_notification_t;

typedef struct
{
    ril_state_event_type_t type; 
    union
    {
        ril_radio_state_event_t  radio; 
        tbox_sim_state_t         sim;   
        ril_backend_data_event_t data;  
        ril_probe_state_event_t  probe; 
    } data;                             
} ril_state_event_t;

typedef struct
{
    uint64_t notification_dropped; 
    uint64_t state_dropped;        
} ril_event_queue_stats_t;

typedef struct
{
    pthread_mutex_t mutex;
    ril_notification_node_t* notification_head;
    ril_notification_node_t* notification_tail;
    ril_state_event_t states[RIL_STATE_QUEUE_CAPACITY];
 
    size_t                  notification_count; 
    size_t                  state_head;         
    size_t                  state_count;        
    ril_queue_class_t       next_queue;         
    ril_event_queue_stats_t stats;              
    bool                    initialized;        
} ril_event_queues_t;

int ril_event_queues_init(ril_event_queues_t* queues);

void ril_event_queues_deinit(ril_event_queues_t* queues);

int ril_event_queues_push_notification(ril_event_queues_t* queues, const ril_notification_t* notification);

int ril_event_queues_pop_notification(ril_event_queues_t* queues, ril_notification_t* notification);

int ril_event_queues_push_state(ril_event_queues_t* queues, const ril_state_event_t* event);

int ril_event_queues_pop_state(ril_event_queues_t* queues, ril_state_event_t* event);

int ril_event_queues_pop_next(ril_event_queues_t* queues, ril_queue_class_t* queue_class,
                              ril_notification_t* notification, ril_state_event_t* state);

size_t ril_event_queues_notification_count(ril_event_queues_t* queues);

size_t ril_event_queues_state_count(ril_event_queues_t* queues);

void ril_event_queues_get_stats(ril_event_queues_t* queues, ril_event_queue_stats_t* stats);
 
#endif /* __RIL_EVENT_QUEUE_H__ */