msg_queue.h

Go to the documentation of this file.

/*
 SPDX-License-Identifier: GPL-3.0-or-later
 myMPD (c) 2018-2025 Juergen Mang <mail@jcgames.de>
 https://github.com/jcorporation/mympd
*/
 
#ifndef MYMPD_QUEUE_H
#define MYMPD_QUEUE_H
 
#include <pthread.h>
#include <stdbool.h>
#include <time.h>
 
extern struct t_mympd_queue *webserver_queue;
extern struct t_mympd_queue *mympd_api_queue;
#ifdef MYMPD_ENABLE_LUA
    extern struct t_mympd_queue *script_queue;
    extern struct t_mympd_queue *script_worker_queue;
#endif
 
struct t_mympd_msg {
    void *data;                
    unsigned id;               
    time_t timestamp;          
    struct t_mympd_msg *next;  
};
 
enum mympd_queue_types {
    QUEUE_TYPE_REQUEST,  
    QUEUE_TYPE_RESPONSE  
};
 
struct t_mympd_queue {
    unsigned length;              
    struct t_mympd_msg *head;     
    struct t_mympd_msg *tail;     
    pthread_mutex_t mutex;        
    pthread_cond_t wakeup;        
    const char *name;             
    enum mympd_queue_types type;  
    // to wakeup the mympd_api event loop
    int event_fd;                 
    // to wakeup the mongoose event loop
    unsigned long mg_conn_id;     
    void *mg_mgr;                 
};
 
struct t_mympd_queue *mympd_queue_create(const char *name, enum mympd_queue_types type,
        bool event);
void *mympd_queue_free(struct t_mympd_queue *queue);
bool mympd_queue_push(struct t_mympd_queue *queue, void *data, unsigned id);
void *mympd_queue_shift(struct t_mympd_queue *queue, int timeout_ms, unsigned id);
int mympd_queue_expire_age(struct t_mympd_queue *queue, time_t max_age_s);
bool mympd_mg_wakeup_send(const void *data);
 
#endif