channel.h

Go to the documentation of this file.

 
#ifndef CHANNEL_H
#define CHANNEL_H
 
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
 
#include <liblfds711.h>
 
#include "constants.h"
 
typedef enum channel_bss_ops_e {
    CH_OP_RES_SET_RESOURCE1 = 0,
 
    CH_OP_RES_SET_RESOURCE2,
 
    CH_OP_QUERY_LOG_FLIP
} channel_bss_ops_t;
 
typedef struct channel_bss_msg_s {
    uint64_t id;
 
    channel_bss_ops_t op;
 
    void *p;
 
    size_t result;
} channel_bss_msg_t;
 
typedef struct channel_bss_queue_s {
    struct lfds711_queue_bss_element qbsse[CHANNEL_BSS_QUEUE_LEN];
 
    struct lfds711_queue_bss_state qbsss;
} channel_bss_queue_t;
 
typedef struct channel_bss_s {
    channel_bss_queue_t bss;
 
    channel_bss_queue_t vl;
} channel_bss_t;
 
 
channel_bss_msg_t * channel_bss_msg_create(uint64_t id,
                                               channel_bss_ops_t op,
                                               void *p);
void     channel_bss_msg_release(channel_bss_msg_t *msg);
int      channel_bss_send(channel_bss_t *ch, channel_bss_msg_t *msg);
int      channel_bss_recv(channel_bss_t *ch, channel_bss_msg_t **msg);
int      channel_bssvl_send(channel_bss_t *ch, channel_bss_msg_t *msg);
int      channel_bssvl_recv(channel_bss_t *ch, channel_bss_msg_t **msg);
uint64_t channel_bss_assign_msg_id(uint64_t *id_base);
 
 
typedef struct channel_log_msg_s {
    uint32_t log_msg_id;
 
    char *log_msg;
 
    bool exit;
} channel_log_msg_t;
 
typedef struct channel_log_s {
    struct lfds711_queue_bss_element qbsse[CHANNEL_LOG_QUEUE_LEN];
 
    struct lfds711_queue_bss_state qbsss;
} channel_log_t;
 
channel_log_msg_t * channel_log_msg_create(uint32_t log_msg_id, char *log_msg,
                                           bool exit);
void channel_log_msg_release(channel_log_msg_t *msg);
int  channel_log_send(channel_log_t *ch, channel_log_msg_t *msg);
int  channel_log_recv(channel_log_t *ch, channel_log_msg_t **msg);
 
#endif /* End of  CHANNEL_H */