26 lines
541 B
C
26 lines
541 B
C
//
|
|
// Created by haraldwolff on 12.08.22.
|
|
//
|
|
|
|
#pragma once
|
|
|
|
#include <stdint.h>
|
|
#include <pthread.h>
|
|
|
|
#include <bs_types.h>
|
|
#include <bs_progress.h>
|
|
|
|
#ifndef MAX_MSG_POOL
|
|
#define MAX_MSG_POOL 128
|
|
#endif
|
|
|
|
#ifndef MAX_MSG_PAYLOAD_LENGTH
|
|
#define MAX_MSG_PAYLOAD_LENGTH 4096
|
|
#endif
|
|
|
|
void bs_msg_queue_init(bs_msg_queue_t *queue);
|
|
int bs_msg_queue_push(bs_msg_queue_t *queue, bs_msg_buffer_t* msg);
|
|
int bs_msg_queue_pop(bs_msg_queue_t *queue, bs_msg_buffer_t** msg, bs_msg_queue_flags_t flags );
|
|
|
|
int bs_msg_buffer_create(bs_msg_buffer_t **msg);
|