#include "xdasd_mqueue.h"
#include "xdasd_thread.h"
#include <stdio.h>
#include <string.h>
#include <malloc.h>
Go to the source code of this file.
Data Structures | |
struct | mqueue_tag |
Internal message queue structure. More... | |
Typedefs | |
typedef struct mqueue_tag | mqueue_t |
Internal message queue structure. | |
Functions | |
static void * | bg_proc (void *data) |
The message queue background processor thread procedure. | |
int | xdasd_mqueue_append (MsgQueue mq, void *msg) |
Append data to a queue, signal background thread to process. | |
MsgQueue | xdasd_mqueue_create (MsgPut_t *put, MsgGet_t *get, MsgProc_t *proc) |
Initialize the message queue sub-system. | |
void | xdasd_mqueue_destroy (MsgQueue mq) |
Cleanup a message queue object. |
This module implements a generic thread-safe background processing message queue. Messages are added to the queue by direct call, and removed from the queue by a background thread that submits them to the specified processor in serialized fashion.
Definition in file xdasd_mqueue.c.